cluster

Documentation

Index

• Constants
• type ClusterController
  • func NewClusterController(client kubernetes.Interface, fireflyClient fireflyclient.Interface, ...) (*ClusterController, error)
  • func (ctrl *ClusterController) Run(ctx context.Context, workers int)

Constants

const (
	ClusterReady    = "ClusterReady"
	ClusterNotReady = "ClusterNotReady"
)

cluster event reason list

const (

	// name of the cluster controller finalizer
	ClusterControllerFinalizerName = "cluster.firefly.io/finalizer"
)

Types

type ClusterController

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

func NewClusterController

func NewClusterController(
	client kubernetes.Interface,
	fireflyClient fireflyclient.Interface,
	clusterInformer clusterinformers.ClusterInformer,
	resyncPeriod time.Duration) (*ClusterController, error)

NewClusterController returns a new *Controller.

func (*ClusterController) Run

func (ctrl *ClusterController) Run(ctx context.Context, workers int)

Run will not return until stopCh is closed. workers determines how many cluster will be handled in parallel.