cluster

Documentation

Index

• func NewClusterController(clientset versioned.Interface, kubeClientset kubernetes.Interface) controller.Controller
• type Event
• type FakeClusterController
  • func NewFakeClusterController(size int) (*watch.FakeWatcher, *FakeClusterController)
  • func (c FakeClusterController) Run(ctx context.Context) error

Functions

func NewClusterController

func NewClusterController(clientset versioned.Interface, kubeClientset kubernetes.Interface) controller.Controller

NewClusterController returns new cluster controller.

Types

type Event

type Event string

Event represents an event processed by cluster controller.

const (
	ClusterAdded   Event = "Added"
	ClusterUpdated Event = "Updated"
	ClusterDeleted Event = "Deleted"
)

Available event types.

type FakeClusterController

type FakeClusterController struct {
	*operator.FakeClusterOperator
	// contains filtered or unexported fields
}

FakeClusterController can be used as a cluster controller in tests. It simulates the cluster controller behaviour with fake clientsets and a fake cluster operator.

func NewFakeClusterController

func NewFakeClusterController(size int) (*watch.FakeWatcher, *FakeClusterController)

NewFakeClusterController returns new operator controller among with prepended watcher. Created controller uses fake clientSets and operator. Size indicates watcher events channel buffer.

func (FakeClusterController) Run

func (c FakeClusterController) Run(ctx context.Context) error