informer_replicasets.go

package main

import (
	"context"

	"github.com/rs/zerolog"

	"k8s.io/client-go/informers"
	"k8s.io/client-go/tools/cache"
)

func createReplicasetInformer(ctx context.Context, factory informers.SharedInformerFactory) (cache.SharedIndexInformer, error) {
	logger := zerolog.Ctx(ctx)

	logger.Debug().Msgf("starting replicaset informer\n")

	jobInformer := factory.Apps().V1().ReplicaSets().Informer()

	return jobInformer, nil
}