resources

Documentation

Index

• type ComponentReconciler
• type Reconciler
• type Resource
• type ResourceWithBrokerConfigAndString
• type ResourceWithBrokerConfigAndVolume
• type ResourceWithBrokerIDAndLog
• type ResourceWithBrokerIDAndStorage
• type ResourceWithLogAndExternalListenerSpecificInfos
• type ResourceWithLogAndExternalListenerSpecificInfosAndIstioRevision
• 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 ResourceWithLogAndExternalListenerSpecificInfos

type ResourceWithLogAndExternalListenerSpecificInfos func(log logr.Logger,
	externalListenerConfig v1beta1.ExternalListenerConfig, ingressConfig v1beta1.IngressConfig,
	ingressConfigName, defaultIngressConfigName string) runtime.Object

ResourceWithLogAndExternalListenerSpecificInfos function with log and externalListenerConfig and ingressConfig parameter with name and default ingress config name

type ResourceWithLogAndExternalListenerSpecificInfosAndIstioRevision

type ResourceWithLogAndExternalListenerSpecificInfosAndIstioRevision func(log logr.Logger,
	externalListenerConfig v1beta1.ExternalListenerConfig, ingressConfig v1beta1.IngressConfig,
	ingressConfigName, defaultIngressConfigName, istioRevision string) runtime.Object

ResourceWithLogAndExternalListenerSpecificInfosAndIstioRevision function with log and externalListenerConfig and ingressConfig parameter with name and default ingress config name and istio revision

type ResourceWithLogs

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

ResourceWithLogs function with log parameter