Versions in this module Expand all Collapse all v0 v0.2.0 Aug 11, 2017 Changes in this version + type CustomResourceController struct + ApiExtensionsClient *apiextensionsclient.Clientset + DefaultOption metav1.GetOptions + func New(kubeConfigFile, masterHost string) (*CustomResourceController, error) + func (*CustomResourceController) Watch(client *rest.RESTClient, eventsChannel chan spec.KafkaclusterWatchEvent, ...) + 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
Go to main page