follower

Documentation

Index

• Constants
• func GetFollowersFromAnnotation(fedObject fedcorev1a1.GenericFederatedObject) (sets.Set[FollowerReference], error)
• func SkipSync(federatedObject fedcorev1a1.GenericFederatedObject) bool
• type Controller
  • func NewFollowerController(kubeClient kubernetes.Interface, fedClient fedclient.Interface, ...) (*Controller, error)
  • func (c *Controller) HasSynced() bool
  • func (c *Controller) IsControllerReady() bool
  • func (c *Controller) Run(ctx context.Context)
• type FollowerReference

Constants

const (
	ControllerName         = "follower-controller"
	PrefixedControllerName = common.DefaultPrefix + ControllerName
)

const (
	EventReasonFailedInferFollowers = "FailedInferFollowers"
	EventReasonFailedUpdateFollower = "FailedUpdateFollower"
)

Functions

func GetFollowersFromAnnotation

func GetFollowersFromAnnotation(
	fedObject fedcorev1a1.GenericFederatedObject,
) (sets.Set[FollowerReference], error)

func SkipSync

func SkipSync(federatedObject fedcorev1a1.GenericFederatedObject) bool

Types

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

func NewFollowerController

func NewFollowerController(
	kubeClient kubernetes.Interface,
	fedClient fedclient.Interface,
	informerManager informermanager.InformerManager,
	ftcInformer fedcorev1a1informers.FederatedTypeConfigInformer,
	fedObjectInformer fedcorev1a1informers.FederatedObjectInformer,
	clusterFedObjectInformer fedcorev1a1informers.ClusterFederatedObjectInformer,
	metrics stats.Metrics,
	logger klog.Logger,
	workerCount int,
) (*Controller, error)

func (*Controller) HasSynced

func (c *Controller) HasSynced() bool

func (*Controller) IsControllerReady

func (c *Controller) IsControllerReady() bool

func (*Controller) Run

func (c *Controller) Run(ctx context.Context)

type FollowerReference

type FollowerReference struct {
	GroupKind schema.GroupKind
	Namespace string
	Name      string
}