controller

package
v0.0.0-...-e07045a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 10, 2024 License: BSD-3-Clause, Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CustomResourceController

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

func New

func New(kubeConfigFile, masterHost string, namespace 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 (c *CustomResourceController) Watch(client *rest.RESTClient, eventsChannel chan spec.KafkaclusterWatchEvent, signalChannel chan int)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL