extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2025-06-24 19:51:32 +02:00
Code Issues Packages Projects Releases Wiki Activity

cleanups (#935)

Browse Source
This commit is contained in:
Michael Quigley 2025-04-17 12:58:13 -04:00
parent 9ea8d52834
commit a7d3c8aacd
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62
1 changed files with 58 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

88
controller/unbootstrap.go
View File

@ -46,21 +46,35 @@ func Unbootstrap(cfg *config.Config) error {
} }
func unbootstrapServiceEdgeRouterPolicies(edge *rest_management_api_client.ZitiEdgeManagement) error { func unbootstrapServiceEdgeRouterPolicies(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_edge_router_policy.ListServiceEdgeRouterPoliciesParams{ offset := int64(0)
Filter: &filter, listReq := &service_edge_router_policy.ListServiceEdgeRouterPoliciesParams{
Limit: &limit, Filter: &filter,
Offset: &offset, Limit: &limit,
Context: context.Background(), Offset: &offset,
} Context: context.Background(),
resp, err := edge.ServiceEdgeRouterPolicy.ListServiceEdgeRouterPolicies(req, nil) }
if err != nil { listResp, err := edge.ServiceEdgeRouterPolicy.ListServiceEdgeRouterPolicies(listReq, nil)
return err if err != nil {
} return err
for _, serp := range resp.Payload.Data { }
logrus.Infof("found service edge router policy: %v", *serp.ID) if len(listResp.Payload.Data) < 1 {
break
}
for _, serp := range listResp.Payload.Data {
delReq := &service_edge_router_policy.DeleteServiceEdgeRouterPolicyParams{
ID: *serp.ID,
Context: context.Background(),
}
_, err := edge.ServiceEdgeRouterPolicy.DeleteServiceEdgeRouterPolicy(delReq, nil)
if err == nil {
logrus.Infof("deleted service edge router policy '%v'", *serp.ID)
} else {
return err
}
}
} }
return nil return nil
} }
@ -126,21 +140,35 @@ func unbootstrapEdgeRouterPolicies(edge *rest_management_api_client.ZitiEdgeMana
} }
func unbootstrapIdentities(edge *rest_management_api_client.ZitiEdgeManagement) error { func unbootstrapIdentities(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 := &identity.ListIdentitiesParams{ offset := int64(0)
Filter: &filter, listReq := &identity.ListIdentitiesParams{
Limit: &limit, Filter: &filter,
Offset: &offset, Limit: &limit,
Context: context.Background(), Offset: &offset,
} Context: context.Background(),
resp, err := edge.Identity.ListIdentities(req, nil) }
if err != nil { listResp, err := edge.Identity.ListIdentities(listReq, nil)
return err if err != nil {
} return err
for _, identity := range resp.Payload.Data { }
logrus.Infof("found identity: %v", *identity.ID) if len(listResp.Payload.Data) < 1 {
break
}
for _, i := range listResp.Payload.Data {
delReq := &identity.DeleteIdentityParams{
ID: *i.ID,
Context: context.Background(),
}
_, err := edge.Identity.DeleteIdentity(delReq, nil)
if err == nil {
logrus.Infof("deleted identity '%v' (%v)", *i.ID, *i.Name)
} else {
return err
}
}
} }
return nil return nil
} }