controller

Documentation

Index

• type CustomResourceController
  • func New(kubeConfigFile, masterHost string) (*CustomResourceController, error)
  • func (c *CustomResourceController) CreateCustomResourceDefinition() (*apiextensionsv1beta1.CustomResourceDefinition, error)
  • func (c *CustomResourceController) GetKafkaClusters() ([]spec.Kafkacluster, error)
  • func (c *CustomResourceController) MonitorKafkaEvents(eventsChannel chan spec.KafkaclusterWatchEvent, signalChannel chan int)
  • func (c *CustomResourceController) SetKafkaclusterState(cluster spec.Kafkacluster) error
  • func (*CustomResourceController) Watch(client *rest.RESTClient, eventsChannel chan spec.KafkaclusterWatchEvent, ...)

Types

type CustomResourceController

type CustomResourceController struct {
	ApiExtensionsClient *apiextensionsclient.Clientset
	DefaultOption       metav1.GetOptions
	// contains filtered or unexported fields
}

func New

func New(kubeConfigFile, masterHost string) (*CustomResourceController, error)

func (*CustomResourceController) CreateCustomResourceDefinition

func (c *CustomResourceController) CreateCustomResourceDefinition() (*apiextensionsv1beta1.CustomResourceDefinition, error)

func (*CustomResourceController) GetKafkaClusters

func (c *CustomResourceController) GetKafkaClusters() ([]spec.Kafkacluster, error)

func (*CustomResourceController) MonitorKafkaEvents

func (c *CustomResourceController) MonitorKafkaEvents(eventsChannel chan spec.KafkaclusterWatchEvent, signalChannel chan int)

func (*CustomResourceController) SetKafkaclusterState

func (c *CustomResourceController) SetKafkaclusterState(cluster spec.Kafkacluster) error

func (*CustomResourceController) Watch

func (*CustomResourceController) Watch(client *rest.RESTClient, eventsChannel chan spec.KafkaclusterWatchEvent, signalChannel chan int)