consumer

Documentation

Index

• func NewController(ctx context.Context, watcher configmap.Watcher) *controller.Impl
• type ControllerConfig
• type Reconciler
  • func (r *Reconciler) FinalizeKind(ctx context.Context, c *kafkainternals.Consumer) reconciler.Event
  • func (r *Reconciler) ReconcileKind(ctx context.Context, c *kafkainternals.Consumer) reconciler.Event
  • func (r Reconciler) SecretProviderFunc() security.SecretProviderFunc
• type SecretLocator
  • func (s *SecretLocator) SecretName() (string, bool)
  • func (s *SecretLocator) SecretNamespace() (string, bool)

Functions

func NewController

func NewController(ctx context.Context, watcher configmap.Watcher) *controller.Impl

Types

type ControllerConfig

type ControllerConfig struct {
	ContractConfigMapFormat string `required:"true" split_words:"true"`
}

type Reconciler

type Reconciler struct {
	SerDe               contract.FormatSerDe
	Resolver            *resolver.URIResolver
	Tracker             tracker.Interface
	ConsumerGroupLister kafkainternalslisters.ConsumerGroupLister
	SecretLister        corelisters.SecretLister
	PodLister           corelisters.PodLister
	KubeClient          kubernetes.Interface
	KafkaFeatureFlags   *config.KafkaFeatureFlags
}

func (*Reconciler) FinalizeKind

func (r *Reconciler) FinalizeKind(ctx context.Context, c *kafkainternals.Consumer) reconciler.Event

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, c *kafkainternals.Consumer) reconciler.Event

func (Reconciler) SecretProviderFunc

func (r Reconciler) SecretProviderFunc() security.SecretProviderFunc

type SecretLocator

type SecretLocator struct {
	*kafkainternals.Consumer
}

func (*SecretLocator) SecretName

func (s *SecretLocator) SecretName() (string, bool)

func (*SecretLocator) SecretNamespace

func (s *SecretLocator) SecretNamespace() (string, bool)