broker

Documentation

Index

• Constants
• func NewController(ctx context.Context, watcher configmap.Watcher, configs *Configs) *controller.Impl
• func ValidateDefaultBackoffDelayMs(env config.Env) error
• type Configs
• type Reconciler
  • func (r *Reconciler) ConfigMapUpdated(ctx context.Context) func(configMap *corev1.ConfigMap)
  • func (r *Reconciler) FinalizeKind(ctx context.Context, broker *eventing.Broker) reconciler.Event
  • func (r *Reconciler) ReconcileKind(ctx context.Context, broker *eventing.Broker) reconciler.Event
  • func (r *Reconciler) SetBootstrapServers(servers string)
  • func (r *Reconciler) SetDefaultTopicDetails(topicDetail sarama.TopicDetail)

Constants

const (
	DefaultTopicNumPartitionConfigMapKey      = "default.topic.partitions"
	DefaultTopicReplicationFactorConfigMapKey = "default.topic.replication.factor"
	BootstrapServersConfigMapKey              = "bootstrap.servers"

	DefaultNumPartitions     = 10
	DefaultReplicationFactor = 1
)

const (
	// TopicPrefix is the Kafka Broker topic prefix - (topic name: knative-broker-<broker-namespace>-<broker-name>).
	TopicPrefix = "knative-broker-"
)

Functions

func NewController

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

func ValidateDefaultBackoffDelayMs

func ValidateDefaultBackoffDelayMs(env config.Env) error

Types

type Configs

type Configs struct {
	config.Env

	BootstrapServers string
}

type Reconciler

type Reconciler struct {
	*base.Reconciler

	Resolver *resolver.URIResolver

	KafkaDefaultTopicDetails     sarama.TopicDetail
	KafkaDefaultTopicDetailsLock sync.RWMutex

	ConfigMapLister corelisters.ConfigMapLister

	// ClusterAdmin creates new sarama ClusterAdmin. It's convenient to add this as Reconciler field so that we can
	// mock the function used during the reconciliation loop.
	ClusterAdmin kafka.NewClusterAdminFunc

	Configs *Configs
	// contains filtered or unexported fields
}

func (*Reconciler) ConfigMapUpdated

func (r *Reconciler) ConfigMapUpdated(ctx context.Context) func(configMap *corev1.ConfigMap)

func (*Reconciler) FinalizeKind

func (r *Reconciler) FinalizeKind(ctx context.Context, broker *eventing.Broker) reconciler.Event

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, broker *eventing.Broker) reconciler.Event

func (*Reconciler) SetBootstrapServers

func (r *Reconciler) SetBootstrapServers(servers string)

SetBootstrapServers change kafka bootstrap brokers addresses. servers: a comma separated list of brokers to connect to.

func (*Reconciler) SetDefaultTopicDetails

func (r *Reconciler) SetDefaultTopicDetails(topicDetail sarama.TopicDetail)