Skip to content

Commit d6c929e

Browse files
authored
filter child resource if resource type not present in filter (#607)
1 parent d79dcb4 commit d6c929e

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

pkg/sync/syncer.go

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -848,14 +848,23 @@ func (s *syncer) getSubResources(ctx context.Context, parent *v2.Resource) error
848848
ctx, span := tracer.Start(ctx, "syncer.getSubResources")
849849
defer span.End()
850850

851+
syncResourceTypeMap := make(map[string]bool)
852+
for _, rt := range s.syncResourceTypes {
853+
syncResourceTypeMap[rt] = true
854+
}
855+
851856
for _, a := range parent.GetAnnotations() {
852857
if a.MessageIs((*v2.ChildResourceType)(nil)) {
853858
crt := &v2.ChildResourceType{}
854859
err := a.UnmarshalTo(crt)
855860
if err != nil {
856861
return err
857862
}
858-
863+
if len(s.syncResourceTypes) > 0 {
864+
if shouldSync := syncResourceTypeMap[crt.GetResourceTypeId()]; !shouldSync {
865+
continue
866+
}
867+
}
859868
childAction := Action{
860869
Op: SyncResourcesOp,
861870
ResourceTypeID: crt.GetResourceTypeId(),

0 commit comments

Comments
 (0)