mtadapter

Documentation

Index

• func NewAdapter(ctx context.Context, processed adapter.EnvConfigAccessor, ...) adapter.Adapter
• func NewController(ctx context.Context, adapter adapter.Adapter) *controller.Impl
• func NewEnvConfig() adapter.EnvConfigAccessor
• type Adapter
  • func (a *Adapter) Remove(obj *v1beta1.KafkaSource)
  • func (a *Adapter) ResolveSecret(ctx context.Context, ns string, ref *corev1.SecretKeySelector) string
  • func (a *Adapter) Start(ctx context.Context) error
  • func (a *Adapter) Update(ctx context.Context, obj *v1beta1.KafkaSource)
• type AdapterConfig
• type MTAdapter
• type Reconciler
  • func (r *Reconciler) ReconcileKind(ctx context.Context, source *v1beta1.KafkaSource) reconciler.Event

Functions

func NewAdapter

func NewAdapter(ctx context.Context, processed adapter.EnvConfigAccessor, ceClient cloudevents.Client) adapter.Adapter

func NewController

func NewController(ctx context.Context, adapter adapter.Adapter) *controller.Impl

NewController initializes the controller and registers event handlers to enqueue events.

func NewEnvConfig

func NewEnvConfig() adapter.EnvConfigAccessor

Types

type Adapter

type Adapter struct {
	// contains filtered or unexported fields
}

func (*Adapter) Remove

func (a *Adapter) Remove(obj *v1beta1.KafkaSource)

func (*Adapter) ResolveSecret

func (a *Adapter) ResolveSecret(ctx context.Context, ns string, ref *corev1.SecretKeySelector) string

ResolveSecret resolves the secret reference

func (*Adapter) Start

func (a *Adapter) Start(ctx context.Context) error

func (*Adapter) Update

func (a *Adapter) Update(ctx context.Context, obj *v1beta1.KafkaSource)

type AdapterConfig

type AdapterConfig struct {
	adapter.EnvConfig

	PodName     string `envconfig:"POD_NAME" required:"true"`
	MPSLimit    int    `envconfig:"VREPLICA_LIMITS_MPS" required:"true"`
	MemoryLimit string `envconfig:"VREPLICA_LIMITS_MEMORY" required:"true"`
}

type MTAdapter

type MTAdapter interface {
	// Update is called when the source is ready and when the specification and/or status has changed.
	Update(ctx context.Context, source *v1beta1.KafkaSource)

	// Remove is called when the source has been deleted.
	Remove(source *v1beta1.KafkaSource)
}

MTAdapter is the interface the multi-tenant KafkaSource adapter must implement

type Reconciler

type Reconciler struct {
	// contains filtered or unexported fields
}

Reconciler updates the internal Adapter cache kafkaSources

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, source *v1beta1.KafkaSource) reconciler.Event