resources

Documentation

Index

• type ComponentReconciler
• type Reconciler
• type Resource
• type ResourceWithBrokerConfigAndString
• type ResourceWithBrokerConfigAndVolume
• type ResourceWithBrokerIdAndLog
• type ResourceWithBrokerIdAndStorage
• type ResourceWithLogAndExternalListenerConfig
• type ResourceWithLogs

Types

type ComponentReconciler

type ComponentReconciler interface {
	Reconcile(log logr.Logger) error
}

ComponentReconciler describes the Reconcile method

type Reconciler

type Reconciler struct {
	client.Client
	DirectClient client.Reader
	KafkaCluster *v1beta1.KafkaCluster
}

Reconciler holds: - cached client : split client reading cached/watched resources from informers and writing to api-server - direct client : to read non-watched resources - KafkaCluster CR

type Resource

type Resource func() runtime.Object

Resource simple function without parameter

type ResourceWithBrokerConfigAndString

type ResourceWithBrokerConfigAndString func(id int32, brokerConfig *v1beta1.BrokerConfig, t string, su []string, log logr.Logger) runtime.Object

ResourceWithBrokerConfigAndString function with brokerConfig, string and log parameters

type ResourceWithBrokerConfigAndVolume

type ResourceWithBrokerConfigAndVolume func(id int32, brokerConfig *v1beta1.BrokerConfig, pvcs []corev1.PersistentVolumeClaim, log logr.Logger) runtime.Object

ResourceWithBrokerConfigAndVolume function with brokerConfig, persistentVolumeClaims and log parameters

type ResourceWithBrokerIdAndLog

type ResourceWithBrokerIdAndLog func(id int32, log logr.Logger) runtime.Object

ResourceWithBrokerIdAndLog function with brokerConfig and log parameters

type ResourceWithBrokerIdAndStorage

type ResourceWithBrokerIdAndStorage func(id int32, storage v1beta1.StorageConfig, log logr.Logger) runtime.Object

ResourceWithBrokerIdAndStorage function with brokerConfig, storageConfig and log parameters

type ResourceWithLogAndExternalListenerConfig

type ResourceWithLogAndExternalListenerConfig func(log logr.Logger, externalListenerConfig v1beta1.ExternalListenerConfig) runtime.Object

ResourceWithLogAndExternalListenerConfig function with log and externalListenerConfig parameter

type ResourceWithLogs

type ResourceWithLogs func(log logr.Logger) runtime.Object

ResourceWithLogs function with log parameter