consumer

Documentation

Index

• 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)

Types

type Reconciler

type Reconciler struct {
	SerDe contract.FormatSerDe

	Enqueue func(c *kafkainternals.Consumer)

	Resolver            *resolver.URIResolver
	Tracker             tracker.Interface
	ConsumerGroupLister kafkainternalslisters.ConsumerGroupLister
	SecretLister        corelisters.SecretLister
	PodLister           corelisters.PodLister
	KubeClient          kubernetes.Interface
}

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)