Documentation ¶
Index ¶
- Constants
- Variables
- func BootstrapServers(bootstrapServers []string) func(sink *eventing.KafkaSink)
- func BrokerAddressable(configs *Configs) func(broker *eventing.Broker)
- func BrokerConfig(bootstrapServers string, numPartitions, replicationFactor int) *corev1.ConfigMap
- func BrokerConfigMapUpdatedReady(configs *Configs) func(broker *eventing.Broker)
- func BrokerConfigNotParsed(reason string) func(broker *eventing.Broker)
- func BrokerConfigParsed(broker *eventing.Broker)
- func BrokerDataPlaneAvailable(broker *eventing.Broker)
- func BrokerDataPlaneNotAvailable(broker *eventing.Broker)
- func BrokerDispatcherPod(namespace string, annotations map[string]string) runtime.Object
- func BrokerDispatcherPodUpdate(namespace string, annotations map[string]string) clientgotesting.UpdateActionImpl
- func BrokerFailedToCreateTopic(broker *eventing.Broker)
- func BrokerFailedToGetConfigMap(configs *Configs) func(broker *eventing.Broker)
- func BrokerReady(broker *eventing.Broker)
- func BrokerReceiverPod(namespace string, annotations map[string]string) runtime.Object
- func BrokerReceiverPodUpdate(namespace string, annotations map[string]string) clientgotesting.UpdateActionImpl
- func BrokerTopic() string
- func BrokerTopicReady(broker *eventing.Broker)
- func ConfigMapUpdate(configs *Configs, contract *contract.Contract) clientgotesting.UpdateActionImpl
- func InitSinkConditions(sink *eventing.KafkaSink)
- func KReference(configMap *corev1.ConfigMap) *duckv1.KReference
- func NewBroker(options ...reconcilertesting.BrokerOption) runtime.Object
- func NewConfigMap(configs *Configs, data []byte) runtime.Object
- func NewConfigMapFromContract(contract *contract.Contract, configs *Configs) runtime.Object
- func NewDeletedBroker(options ...reconcilertesting.BrokerOption) runtime.Object
- func NewDeletedSink(options ...SinkOption) runtime.Object
- func NewFactory(configs *broker.Configs, ctor Ctor) Factory
- func NewService() *corev1.Service
- func NewSink(options ...SinkOption) runtime.Object
- func SinkAddressable(configs *config.Env) func(sink *eventing.KafkaSink)
- func SinkConfigMapUpdatedReady(configs *config.Env) func(sink *eventing.KafkaSink)
- func SinkConfigParsed(sink *eventing.KafkaSink)
- func SinkControllerDontOwnTopic(sink *eventing.KafkaSink)
- func SinkControllerOwnsTopic(sink *eventing.KafkaSink)
- func SinkDataPlaneAvailable(sink *eventing.KafkaSink)
- func SinkDataPlaneNotAvailable(sink *eventing.KafkaSink)
- func SinkFailedToCreateTopic(sink *eventing.KafkaSink)
- func SinkFailedToGetConfigMap(configs *config.Env) func(sink *eventing.KafkaSink)
- func SinkReceiverPod(namespace string, annotations map[string]string) runtime.Object
- func SinkReceiverPodUpdate(namespace string, annotations map[string]string) clientgotesting.UpdateActionImpl
- func SinkTopic() string
- func SinkTopicNotPresentErr(topic string, err error) func(sink *eventing.KafkaSink)
- func SinkTopicReady(sink *eventing.KafkaSink)
- func SinkTopicReadyWithName(topic string) func(sink *eventing.KafkaSink)
- func SinkTopicReadyWithOwner(topic, owner string) func(sink *eventing.KafkaSink)
- func ToUnstructured(t *testing.T, objs []runtime.Object) (us []runtime.Object)
- func WithBrokerConfig(reference *duckv1.KReference) func(*eventing.Broker)
- func WithDelivery() func(*eventing.Broker)
- type Ctor
- type Listers
- func (l *Listers) GetAllObjects() []runtime.Object
- func (l *Listers) GetBrokerLister() eventinglisters.BrokerLister
- func (l *Listers) GetConfigMapLister() corelisters.ConfigMapLister
- func (l *Listers) GetEventingKafkaObjects() []runtime.Object
- func (l *Listers) GetEventingObjects() []runtime.Object
- func (l *Listers) GetKafkaSinkLister() eventingkafkalisters.KafkaSinkLister
- func (l *Listers) GetKubeObjects() []runtime.Object
- func (l *Listers) GetPodLister() corelisters.PodLister
- func (l *Listers) GetTriggerLister() eventinglisters.TriggerLister
- type SinkOption
Constants ¶
View Source
const ( BrokerUUID = "e7185016-5d98-4b54-84e8-3b1cd4acc6b4" BrokerNamespace = "test-namespace" BrokerName = "test-broker" )
View Source
const ( ConfigMapNamespace = "test-namespace-config-map" ConfigMapName = "test-config-cm" ServiceURL = "http://test-service.test-service-namespace.svc.cluster.local/" TriggerUUID = "e7185016-5d98-4b54-84e8-3b1cd4acc6b5" )
View Source
const ( SinkUUID = "e7185016-5d98-4b54-84e8-3b1cd4acc6b5" SinkNamespace = "sink-namespace" SinkName = "sink-name" SinkNumPartitions = 10 SinkReplicationFactor = 3 SinkNotPresentErrFormat = "failed to describe topic %s: %v" )
Variables ¶
View Source
var DefaultConfigs = &broker.Configs{ Env: config.Env{ DataPlaneConfigMapName: "kafka-broker-brokers-triggers", DataPlaneConfigMapNamespace: "knative-eventing", IngressName: "kafka-broker-receiver", SystemNamespace: "knative-eventing", DataPlaneConfigFormat: base.Json, }, BootstrapServers: "", }
Functions ¶
func BootstrapServers ¶ added in v0.18.0
func BrokerAddressable ¶ added in v0.18.0
func BrokerConfig ¶
func BrokerConfigMapUpdatedReady ¶ added in v0.18.0
func BrokerConfigNotParsed ¶ added in v0.18.0
func BrokerConfigParsed ¶ added in v0.18.0
func BrokerDataPlaneAvailable ¶ added in v0.18.0
func BrokerDataPlaneNotAvailable ¶ added in v0.18.0
func BrokerDispatcherPod ¶ added in v0.18.0
func BrokerDispatcherPodUpdate ¶ added in v0.18.0
func BrokerDispatcherPodUpdate(namespace string, annotations map[string]string) clientgotesting.UpdateActionImpl
func BrokerFailedToCreateTopic ¶ added in v0.18.0
func BrokerFailedToGetConfigMap ¶ added in v0.18.0
func BrokerReady ¶
func BrokerReceiverPod ¶ added in v0.18.0
func BrokerReceiverPodUpdate ¶ added in v0.18.0
func BrokerReceiverPodUpdate(namespace string, annotations map[string]string) clientgotesting.UpdateActionImpl
func BrokerTopic ¶ added in v0.18.0
func BrokerTopic() string
func BrokerTopicReady ¶ added in v0.18.0
func ConfigMapUpdate ¶
func ConfigMapUpdate(configs *Configs, contract *contract.Contract) clientgotesting.UpdateActionImpl
func InitSinkConditions ¶ added in v0.18.0
func KReference ¶
func KReference(configMap *corev1.ConfigMap) *duckv1.KReference
func NewBroker ¶
func NewBroker(options ...reconcilertesting.BrokerOption) runtime.Object
NewBroker creates a new Broker with broker class equals to kafka.BrokerClass.
func NewConfigMap ¶
func NewConfigMapFromContract ¶ added in v0.18.0
func NewDeletedBroker ¶
func NewDeletedBroker(options ...reconcilertesting.BrokerOption) runtime.Object
func NewDeletedSink ¶ added in v0.18.0
func NewDeletedSink(options ...SinkOption) runtime.Object
func NewFactory ¶
func NewService ¶
func NewSink ¶ added in v0.18.0
func NewSink(options ...SinkOption) runtime.Object
func SinkAddressable ¶ added in v0.18.0
func SinkConfigMapUpdatedReady ¶ added in v0.18.0
func SinkConfigParsed ¶ added in v0.18.0
func SinkControllerDontOwnTopic ¶ added in v0.18.0
func SinkControllerOwnsTopic ¶ added in v0.18.0
func SinkDataPlaneAvailable ¶ added in v0.18.0
func SinkDataPlaneNotAvailable ¶ added in v0.18.0
func SinkFailedToCreateTopic ¶ added in v0.18.0
func SinkFailedToGetConfigMap ¶ added in v0.18.0
func SinkReceiverPod ¶ added in v0.18.0
func SinkReceiverPodUpdate ¶ added in v0.18.0
func SinkReceiverPodUpdate(namespace string, annotations map[string]string) clientgotesting.UpdateActionImpl
func SinkTopicNotPresentErr ¶ added in v0.18.0
func SinkTopicReady ¶ added in v0.18.0
func SinkTopicReadyWithName ¶ added in v0.18.0
func SinkTopicReadyWithOwner ¶ added in v0.18.0
func ToUnstructured ¶ added in v0.18.0
ToUnstructured takes a list of k8s resources and converts them to Unstructured objects. We must pass objects as Unstructured to the dynamic client fake, or it won't handle them properly.
func WithBrokerConfig ¶
func WithBrokerConfig(reference *duckv1.KReference) func(*eventing.Broker)
func WithDelivery ¶
Types ¶
type Ctor ¶
type Ctor func(ctx context.Context, listers *Listers, configs *broker.Configs, row *TableRow) pkgcontroller.Reconciler
Ctor functions create a k8s controller with given params.
type Listers ¶
type Listers struct {
// contains filtered or unexported fields
}
func (*Listers) GetAllObjects ¶
func (*Listers) GetBrokerLister ¶
func (l *Listers) GetBrokerLister() eventinglisters.BrokerLister
func (*Listers) GetConfigMapLister ¶
func (l *Listers) GetConfigMapLister() corelisters.ConfigMapLister
func (*Listers) GetEventingKafkaObjects ¶ added in v0.18.0
func (*Listers) GetEventingObjects ¶
func (*Listers) GetKafkaSinkLister ¶ added in v0.18.0
func (l *Listers) GetKafkaSinkLister() eventingkafkalisters.KafkaSinkLister
func (*Listers) GetKubeObjects ¶
func (*Listers) GetPodLister ¶
func (l *Listers) GetPodLister() corelisters.PodLister
func (*Listers) GetTriggerLister ¶
func (l *Listers) GetTriggerLister() eventinglisters.TriggerLister
type SinkOption ¶ added in v0.18.0
Click to show internal directories.
Click to hide internal directories.