extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2025-06-20 09:48:07 +02:00
Code Issues Packages Projects Releases Wiki Activity

unbootstrap, fully unbootstrapping (#935)

Browse Source
This commit is contained in:
Michael Quigley 2025-04-17 17:52:53 -04:00
parent bd9a8c04b2
commit e8ca096691
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62
1 changed files with 116 additions and 60 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

176
controller/unbootstrap.go
View File

@ -80,41 +80,69 @@ func unbootstrapServiceEdgeRouterPolicies(edge *rest_management_api_client.ZitiE
} }
func unbootstrapServicePolicies(edge *rest_management_api_client.ZitiEdgeManagement) error { func unbootstrapServicePolicies(edge *rest_management_api_client.ZitiEdgeManagement) error {
filter := "tags.zrok != null" for {
limit := int64(100) filter := "tags.zrok != null"
offset := int64(0) limit := int64(100)
req := &service_policy.ListServicePoliciesParams{ offset := int64(0)
Filter: &filter, listReq := &service_policy.ListServicePoliciesParams{
Limit: &limit, Filter: &filter,
Offset: &offset, Limit: &limit,
Context: context.Background(), Offset: &offset,
} Context: context.Background(),
resp, err := edge.ServicePolicy.ListServicePolicies(req, nil) }
if err != nil { listResp, err := edge.ServicePolicy.ListServicePolicies(listReq, nil)
return err if err != nil {
} return err
for _, sp := range resp.Payload.Data { }
logrus.Infof("found service policy: %v", *sp.ID) if len(listResp.Payload.Data) < 1 {
break
}
for _, sp := range listResp.Payload.Data {
delReq := &service_policy.DeleteServicePolicyParams{
ID: *sp.ID,
Context: context.Background(),
}
_, err := edge.ServicePolicy.DeleteServicePolicy(delReq, nil)
if err == nil {
logrus.Infof("deleted service policy '%v'", *sp.ID)
} else {
return err
}
}
} }
return nil return nil
} }
func unbootstrapServices(edge *rest_management_api_client.ZitiEdgeManagement) error { func unbootstrapServices(edge *rest_management_api_client.ZitiEdgeManagement) error {
filter := "tags.zrok != null" for {
limit := int64(100) filter := "tags.zrok != null"
offset := int64(0) limit := int64(100)
req := &service.ListServicesParams{ offset := int64(0)
Filter: &filter, listReq := &service.ListServicesParams{
Limit: &limit, Filter: &filter,
Offset: &offset, Limit: &limit,
Context: context.Background(), Offset: &offset,
} Context: context.Background(),
resp, err := edge.Service.ListServices(req, nil) }
if err != nil { listResp, err := edge.Service.ListServices(listReq, nil)
return err if err != nil {
} return err
for _, svc := range resp.Payload.Data { }
logrus.Infof("found service: %v (%v)", *svc.ID, *svc.Name) if len(listResp.Payload.Data) < 1 {
break
}
for _, svc := range listResp.Payload.Data {
delReq := &service.DeleteServiceParams{
ID: *svc.ID,
Context: context.Background(),
}
_, err := edge.Service.DeleteService(delReq, nil)
if err == nil {
logrus.Infof("deleted service '%v' (%v)", *svc.ID, *svc.Name)
} else {
return err
}
}
} }
return nil return nil
} }
@ -188,41 +216,69 @@ func unbootstrapIdentities(edge *rest_management_api_client.ZitiEdgeManagement)
} }
func unbootstrapConfigs(edge *rest_management_api_client.ZitiEdgeManagement) error { func unbootstrapConfigs(edge *rest_management_api_client.ZitiEdgeManagement) error {
filter := "tags.zrok != null" for {
limit := int64(100) filter := "tags.zrok != null"
offset := int64(0) limit := int64(100)
req := &apiConfig.ListConfigsParams{ offset := int64(0)
Filter: &filter, listReq := &apiConfig.ListConfigsParams{
Limit: &limit, Filter: &filter,
Offset: &offset, Limit: &limit,
Context: context.Background(), Offset: &offset,
} Context: context.Background(),
resp, err := edge.Config.ListConfigs(req, nil) }
if err != nil { listResp, err := edge.Config.ListConfigs(listReq, nil)
return err if err != nil {
} return err
for _, listCfg := range resp.Payload.Data { }
logrus.Infof("found config: %v", *listCfg.ID) if len(listResp.Payload.Data) < 1 {
break
}
for _, listCfg := range listResp.Payload.Data {
delReq := &apiConfig.DeleteConfigParams{
ID: *listCfg.ID,
Context: context.Background(),
}
_, err := edge.Config.DeleteConfig(delReq, nil)
if err == nil {
logrus.Infof("deleted config '%v'", *listCfg.ID)
} else {
return nil
}
}
} }
return nil return nil
} }
func unbootstrapConfigType(edge *rest_management_api_client.ZitiEdgeManagement) error { func unbootstrapConfigType(edge *rest_management_api_client.ZitiEdgeManagement) error {
filter := fmt.Sprintf("name = \"%v\"", sdk.ZrokProxyConfig) for {
limit := int64(100) filter := fmt.Sprintf("name = \"%v\"", sdk.ZrokProxyConfig)
offset := int64(0) limit := int64(100)
req := &apiConfig.ListConfigTypesParams{ offset := int64(0)
Filter: &filter, listReq := &apiConfig.ListConfigTypesParams{
Limit: &limit, Filter: &filter,
Offset: &offset, Limit: &limit,
Context: context.Background(), Offset: &offset,
} Context: context.Background(),
resp, err := edge.Config.ListConfigTypes(req, nil) }
if err != nil { listResp, err := edge.Config.ListConfigTypes(listReq, nil)
return err if err != nil {
} return err
for _, listCfgType := range resp.Payload.Data { }
logrus.Infof("found config type: %v (%v)", *listCfgType.ID, *listCfgType.Name) if len(listResp.Payload.Data) < 1 {
break
}
for _, listCfgType := range listResp.Payload.Data {
delReq := &apiConfig.DeleteConfigTypeParams{
ID: *listCfgType.ID,
Context: context.Background(),
}
_, err := edge.Config.DeleteConfigType(delReq, nil)
if err == nil {
logrus.Infof("deleted config type '%v' (%v)", *listCfgType.ID, *listCfgType.Name)
} else {
return err
}
}
} }
return nil return nil
} }