automigration

Documentation

Index

• Constants
• type Controller
  • func NewAutoMigrationController(ctx context.Context, kubeClient kubeclient.Interface, ...) (*Controller, error)
  • func (c *Controller) HasSynced() bool
  • func (c *Controller) IsControllerReady() bool
  • func (c *Controller) Run(ctx context.Context)
• type FederatedObject

Constants

const (
	EventReasonAutoMigrationInfoUpdated = "AutoMigrationInfoUpdated"
	AutoMigrationControllerName         = "auto-migration"
)

Types

type Controller

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

func NewAutoMigrationController

func NewAutoMigrationController(
	ctx context.Context,
	kubeClient kubeclient.Interface,
	fedClient fedclient.Interface,
	fedObjectInformer fedcorev1a1informers.FederatedObjectInformer,
	clusterFedObjectInformer fedcorev1a1informers.ClusterFederatedObjectInformer,
	federatedInformer informermanager.FederatedInformerManager,
	ftcManager informermanager.FederatedTypeConfigManager,
	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

IsControllerReady implements controllermanager.Controller

func (*Controller) Run

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

type FederatedObject

type FederatedObject struct {
	Object      *unstructured.Unstructured
	ClusterName string
}

An object with an origin information.