v1alpha1

Documentation

Index

• func NewConsumerGroupInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, ...) cache.SharedIndexInformer
• func NewConsumerInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, ...) cache.SharedIndexInformer
• func NewFilteredConsumerGroupInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, ...) cache.SharedIndexInformer
• func NewFilteredConsumerInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, ...) cache.SharedIndexInformer
• type ConsumerGroupInformer
• type ConsumerInformer
• type Interface
  • func New(f internalinterfaces.SharedInformerFactory, namespace string, ...) Interface

Functions

func NewConsumerGroupInformer

func NewConsumerGroupInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer

NewConsumerGroupInformer constructs a new informer for ConsumerGroup type. Always prefer using an informer factory to get a shared informer instead of getting an independent one. This reduces memory footprint and number of connections to the server.

func NewConsumerInformer

func NewConsumerInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer

NewConsumerInformer constructs a new informer for Consumer type. Always prefer using an informer factory to get a shared informer instead of getting an independent one. This reduces memory footprint and number of connections to the server.

func NewFilteredConsumerGroupInformer

func NewFilteredConsumerGroupInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer

NewFilteredConsumerGroupInformer constructs a new informer for ConsumerGroup type. Always prefer using an informer factory to get a shared informer instead of getting an independent one. This reduces memory footprint and number of connections to the server.

func NewFilteredConsumerInformer

func NewFilteredConsumerInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer

NewFilteredConsumerInformer constructs a new informer for Consumer type. Always prefer using an informer factory to get a shared informer instead of getting an independent one. This reduces memory footprint and number of connections to the server.

Types

type ConsumerGroupInformer

type ConsumerGroupInformer interface {
	Informer() cache.SharedIndexInformer
	Lister() v1alpha1.ConsumerGroupLister
}

ConsumerGroupInformer provides access to a shared informer and lister for ConsumerGroups.

type ConsumerInformer

type ConsumerInformer interface {
	Informer() cache.SharedIndexInformer
	Lister() v1alpha1.ConsumerLister
}

ConsumerInformer provides access to a shared informer and lister for Consumers.

type Interface

type Interface interface {
	// Consumers returns a ConsumerInformer.
	Consumers() ConsumerInformer
	// ConsumerGroups returns a ConsumerGroupInformer.
	ConsumerGroups() ConsumerGroupInformer
}

Interface provides access to all the informers in this group version.

func New

func New(f internalinterfaces.SharedInformerFactory, namespace string, tweakListOptions internalinterfaces.TweakListOptionsFunc) Interface

New returns a new Interface.