Skip to content

Commit

Permalink
Add reconciler on StoragePolicyQuota CR to create/delete correspondin…
Browse files Browse the repository at this point in the history
…g StoragePolicyUsage CRs (#2888)
  • Loading branch information
akankshapanse authored Aug 22, 2024
1 parent 22acecc commit 8dbd0fb
Show file tree
Hide file tree
Showing 4 changed files with 341 additions and 122 deletions.
6 changes: 3 additions & 3 deletions pkg/kubernetes/dynamicInformers.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,9 +36,9 @@ var (
supervisorDynamicInformerInitLock = &sync.Mutex{}
)

// newDynamicInformerFactory creates a dynamic informer factory for a given
// NewDynamicInformerFactory creates a dynamic informer factory for a given
// namespace if it doesn't exist already.
func newDynamicInformerFactory(ctx context.Context, cfg *restclient.Config, namespace string,
func NewDynamicInformerFactory(ctx context.Context, cfg *restclient.Config, namespace string,
isInCluster bool) (dynamicinformer.DynamicSharedInformerFactory, error) {
log := logger.GetLogger(ctx)
var (
Expand Down Expand Up @@ -92,7 +92,7 @@ func GetDynamicInformer(ctx context.Context, crdGroup, crdVersion, crdName, name
log := logger.GetLogger(ctx)
var err error

dynamicInformerFactory, err := newDynamicInformerFactory(ctx, cfg, namespace, isInCluster)
dynamicInformerFactory, err := NewDynamicInformerFactory(ctx, cfg, namespace, isInCluster)
if err != nil {
log.Errorf("could not retrieve dynamic informer factory for %q namespace. Error: %+v", namespace, err)
return nil, err
Expand Down
Loading

0 comments on commit 8dbd0fb

Please sign in to comment.