consumer

Documentation

Index

• func FalseAnyStatus(*corev1.Pod) bool
• func IsPodNotRunning(p *corev1.Pod) bool
• func NewController(ctx context.Context, watcher configmap.Watcher) *controller.Impl
• type ControllerConfig
• type PodStatusSummary
  • func (s *PodStatusSummary) Error() string
• type PodStatusWaitFunc
• 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 FalseAnyStatus

func FalseAnyStatus(*corev1.Pod) bool

func IsPodNotRunning

func IsPodNotRunning(p *corev1.Pod) bool

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 PodStatusSummary

type PodStatusSummary struct {
	Pod *corev1.Pod
}

func (*PodStatusSummary) Error

func (s *PodStatusSummary) Error() string

type PodStatusWaitFunc

type PodStatusWaitFunc func(p *corev1.Pod) bool

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
	TrustBundleConfigMapLister corelisters.ConfigMapNamespaceLister
}

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)