testing

package
v0.33.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 24, 2022 License: Apache-2.0 Imports: 65 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BrokerUUID        = "e7185016-5d98-4b54-84e8-3b1cd4acc6b4"
	BrokerNamespace   = "test-namespace"
	BrokerName        = "test-broker"
	ExternalTopicName = "test-topic"

	SecretFinalizerName = "kafka.eventing/" + BrokerUUID

	TriggerName      = "test-trigger"
	TriggerNamespace = "test-namespace"
)
View Source 
const (
	ChannelName             = "kc"
	ChannelNamespace        = "test-nc"
	ChannelUUID             = "c1234567-8901-2345-6789-123456789101"
	ChannelBootstrapServers = "kafka-1:9092,kafka-2:9093"
	ChannelServiceName      = "kc-kn-channel"

	Subscription1Name     = "sub-1"
	Subscription2Name     = "sub-2"
	Subscription1UUID     = "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1"
	Subscription2UUID     = "34c5aec8-deb6-11e8-9f32-f2801f1b9fd1"
	Subscription1URI      = "sub-1-uri"
	Subscription2URI      = "sub-2-uri"
	Subscription1ReplyURI = "sub-1-reply-uri"
)
View Source 
const (
	ConfigMapNamespace = "test-namespace-config-map"
	ConfigMapName      = "test-config-cm"

	ServiceNamespace = "test-service-namespace"
	ServiceName      = "test-service"

	Service2Name = "test-service-2"

	TriggerUUID = "e7185016-5d98-4b54-84e8-3b1cd4acc6b5"

	SecretResourceVersion = "1234"
	SecretUUID            = "a7185016-5d98-4b54-84e8-3b1cd4acc6b6"

	SystemNamespace = "knative-eventing"

	DispatcherPodUUID = "a7185016-5d98-4b54-84e8-3b1cd4acc6bp"
)
View Source 
const (
	ConsumerNamePrefix = "test-cg"
	ConsumerNamespace  = "test-cg-ns"

	SecretName = "secret-name"
)
View Source 
const (
	ConsumerGroupName      = "test-cg"
	ConsumerGroupNamespace = "test-cg-ns"

	ConsumerGroupTestKey = ConsumerGroupNamespace + "/" + ConsumerGroupName
)
View Source 
const (
	SinkUUID      = "e7185016-5d98-4b54-84e8-3b1cd4acc6b5"
	SinkNamespace = "sink-namespace"
	SinkName      = "sink-name"

	SinkNumPartitions     = 10
	SinkReplicationFactor = 3

	SinkNotPresentErrFormat = "failed to describe topics %v: %v"
)
View Source 
const (
	SourceName             = "ks"
	SourceNamespace        = "test-ns"
	SourceConsumerGroup    = "ks-group"
	SourceUUID             = "uuid"
	SourceBootstrapServers = "kafka:9092"
)

Variables

View Source 
var (
	Formats = []string{base.Protobuf, base.Json}

	ServiceURL         = ServiceURLFrom(ServiceNamespace, ServiceName)
	ServiceDestination = ServiceURLDestination(ServiceNamespace, ServiceName)
)
View Source 
var (
	ConsumerUUID = "c1234567-8901-2345-6789-123456789102"
	ConsumerName = fmt.Sprintf("%s-%d", ConsumerNamePrefix, 1)

	ConsumerSubscriberURI     = apis.HTTP("localhost")
	ConsumerDeadLetterSinkURI = apis.HTTP("dls.com")
)
View Source 
var (
	ConsumerLabels = map[string]string{"c": "C"}

	ConsumerSourceLabel = map[string]string{
		kafkainternals.ConsumerLabelSelector: SourceUUID,
	}

	ConsumerTriggerLabel = map[string]string{
		kafkainternals.ConsumerLabelSelector: TriggerUUID,
	}

	ConsumerSubscription1Label = map[string]string{
		kafkainternals.ConsumerLabelSelector: Subscription1UUID,
	}

	ConsumerSubscription2Label = map[string]string{
		kafkainternals.ConsumerLabelSelector: Subscription2UUID,
	}

	OwnerAsTriggerLabel = map[string]string{
		kafkainternals.UserFacingResourceLabelSelector: "trigger",
	}

	OwnerAsSourceLabel = map[string]string{
		kafkainternals.UserFacingResourceLabelSelector: "kafkasource",
	}

	OwnerAsChannelLabel = map[string]string{
		kafkainternals.UserFacingResourceLabelSelector: "kafkachannel",
		kafkainternals.KafkaChannelNameLabel:           ChannelName,
	}
)
View Source 
var (
	SourceTopics = []string{"t1", "t2"}
)

Functions

func BootstrapServers added in v0.18.0 

func BootstrapServers(bootstrapServers []string) func(obj duckv1.KRShaped)

func BrokerAddressable added in v0.18.0 

func BrokerAddressable(env *config.Env) func(broker *eventing.Broker)

func BrokerConfig 

func BrokerConfig(bootstrapServers string, numPartitions, replicationFactor int, options ...CMOption) *corev1.ConfigMap

func BrokerConfigMapAnnotations added in v0.29.4 

func BrokerConfigMapAnnotations() reconcilertesting.BrokerOption

func BrokerConfigMapSecretAnnotation added in v0.29.4 

func BrokerConfigMapSecretAnnotation(name string) reconcilertesting.BrokerOption

func BrokerDLSResolved added in v0.27.0 

func BrokerDLSResolved(uri string) func(broker *eventing.Broker)

func BrokerDispatcherPod added in v0.18.0 

func BrokerDispatcherPod(namespace string, annotations map[string]string) runtime.Object

func BrokerDispatcherPodUpdate added in v0.18.0 

func BrokerDispatcherPodUpdate(namespace string, annotations map[string]string) clientgotesting.UpdateActionImpl

func BrokerReady 

func BrokerReady(broker *eventing.Broker)

func BrokerReceiverPod added in v0.18.0 

func BrokerReceiverPod(namespace string, annotations map[string]string) runtime.Object

func BrokerReceiverPodUpdate added in v0.18.0 

func BrokerReceiverPodUpdate(namespace string, annotations map[string]string) clientgotesting.UpdateActionImpl

func BrokerReference added in v0.29.0 

func BrokerReference() *contract.Reference

func BrokerSecretWithFinalizer added in v0.32.4 

func BrokerSecretWithFinalizer(ns, name, finalizerName string) *corev1.Secret

func BrokerTopic added in v0.18.0 

func BrokerTopic() string

func ChannelAddressable added in v0.28.0 

func ChannelAddressable(env *config.Env) func(obj duckv1.KRShaped)

func ChannelAsOwnerReference added in v0.31.0 

func ChannelAsOwnerReference() metav1.OwnerReference

func ChannelDispatcherPod added in v0.28.0 

func ChannelDispatcherPod(namespace string, annotations map[string]string) runtime.Object

func ChannelDispatcherPodUpdate added in v0.28.0 

func ChannelDispatcherPodUpdate(namespace string, annotations map[string]string) clientgotesting.UpdateActionImpl

func ChannelReceiverPod added in v0.28.0 

func ChannelReceiverPod(namespace string, annotations map[string]string) runtime.Object

func ChannelReceiverPodUpdate added in v0.28.0 

func ChannelReceiverPodUpdate(namespace string, annotations map[string]string) clientgotesting.UpdateActionImpl

func ChannelReference added in v0.29.0 

func ChannelReference() *contract.Reference

func ChannelTopic added in v0.28.0 

func ChannelTopic() string

func ConfigMapUpdate 

func ConfigMapUpdate(env *config.Env, contract *contract.Contract, options ...reconcilertesting.ConfigMapOption) clientgotesting.UpdateActionImpl

func ConsumerGroupAsOwnerRef added in v0.30.0 

func ConsumerGroupAsOwnerRef() metav1.OwnerReference

func ConsumerGroupReady added in v0.29.0 

func ConsumerGroupReady(cg *kafkainternals.ConsumerGroup)

func ConsumerNoReply added in v0.30.0 

func ConsumerNoReply() *kafkainternals.ReplyStrategy

func ConsumerTopicReply added in v0.30.0 

func ConsumerTopicReply() *kafkainternals.ReplyStrategy

func DispatcherPodAsOwnerReference added in v0.30.0 

func DispatcherPodAsOwnerReference(name string) reconcilertesting.ConfigMapOption

func GetSubscriberSpec added in v0.30.0 

func GetSubscriberSpec(s *SubscriberInfo) *eventingduckv1.SubscriberSpec

func InitSinkConditions added in v0.18.0 

func InitSinkConditions(obj duckv1.KRShaped)

func InitSourceConditions added in v0.28.0 

func InitSourceConditions(obj duckv1.KRShaped)

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 NewChannel added in v0.28.0 

func NewChannel(options ...KRShapedOption) *messagingv1beta1.KafkaChannel

func NewConfigMapFromContract added in v0.18.0 

func NewConfigMapFromContract(contract *contract.Contract, env *config.Env, options ...reconcilertesting.ConfigMapOption) runtime.Object

func NewConfigMapWithBinaryData added in v0.28.0 

func NewConfigMapWithBinaryData(env *config.Env, data []byte, options ...reconcilertesting.ConfigMapOption) runtime.Object

func NewConfigMapWithTextData added in v0.28.0 

func NewConfigMapWithTextData(namespace, name string, data map[string]string) runtime.Object

func NewConsumer added in v0.29.0 

func NewConsumer(ordinal int, opts ...ConsumerOption) *kafkainternals.Consumer

func NewConsumerGroup added in v0.28.0 

func NewConsumerGroup(opts ...ConsumerGroupOption) *kafkainternals.ConsumerGroup

func NewConsumerSpec added in v0.29.0 

func NewConsumerSpec(opts ...ConsumerSpecOption) kafkainternals.ConsumerSpec

func NewConsumerSpecAuth added in v0.29.0 

func NewConsumerSpecAuth() *kafkainternals.Auth

func NewConsumerSpecDelivery added in v0.29.0 

func NewConsumerSpecDelivery(order internals.DeliveryOrdering, options ...DeliverySpecOption) *kafkainternals.DeliverySpec

func NewConsumerSpecFilters added in v0.29.0 

func NewConsumerSpecFilters() *kafkainternals.Filters

func NewConsumerSpecSubscriber added in v0.30.0 

func NewConsumerSpecSubscriber(uri string) duckv1.Destination

func NewDeletedBroker 

func NewDeletedBroker(options ...reconcilertesting.BrokerOption) runtime.Object

func NewDeletedChannel added in v0.31.0 

func NewDeletedChannel(options ...KRShapedOption) runtime.Object

func NewDeletedConsumeGroup added in v0.32.0 

func NewDeletedConsumeGroup(opts ...ConsumerGroupOption) runtime.Object

func NewDeletedSink added in v0.18.0 

func NewDeletedSink(options ...KRShapedOption) runtime.Object

func NewDeletedSource added in v0.27.0 

func NewDeletedSource(options ...KRShapedOption) runtime.Object

func NewDispatcherPod 

func NewDispatcherPod(name string, options ...PodOption) *corev1.Pod

func NewFactory 

func NewFactory(env *config.Env, ctor Ctor) Factory

func NewLegacySASLSSLSecret added in v0.31.2 

func NewLegacySASLSSLSecret(ns, name string) *corev1.Secret

func NewLegacySASLSecret added in v0.31.2 

func NewLegacySASLSecret(ns, name string) *corev1.Secret

func NewLegacySSLSecret added in v0.31.2 

func NewLegacySSLSecret(ns, name string) *corev1.Secret

func NewPerChannelService added in v0.31.0 

func NewPerChannelService(env *config.Env) *corev1.Service

func NewSASLSSLSecret added in v0.31.0 

func NewSASLSSLSecret(ns, name string) *corev1.Secret

func NewSSLSecret added in v0.21.0 

func NewSSLSecret(ns, name string) *corev1.Secret

func NewService 

func NewService(mutations ...func(*corev1.Service)) *corev1.Service

func NewService2 added in v0.30.0 

func NewService2(mutations ...func(*corev1.Service)) *corev1.Service

func NewSink added in v0.18.0 

func NewSink(options ...KRShapedOption) runtime.Object

func NewSource added in v0.27.0 

func NewSource(options ...KRShapedOption) *sources.KafkaSource

func NewSourceSink2Reference added in v0.30.0 

func NewSourceSink2Reference() duckv1.Destination

func NewSourceSinkObject added in v0.27.0 

func NewSourceSinkObject() *corev1.Service

func NewSourceSinkReference added in v0.27.0 

func NewSourceSinkReference() duckv1.Destination

func ServiceURLDestination added in v0.30.3 

func ServiceURLDestination(ns, name string) *duckv1.Destination

func ServiceURLFrom added in v0.25.2 

func ServiceURLFrom(ns, name string) string

func SinkAddressable added in v0.18.0 

func SinkAddressable(configs *config.Env) func(obj duckv1.KRShaped)

func SinkAuthSecretRef added in v0.21.0 

func SinkAuthSecretRef(name string) func(obj duckv1.KRShaped)

func SinkReceiverPod added in v0.18.0 

func SinkReceiverPod(namespace string, annotations map[string]string) runtime.Object

func SinkReceiverPodUpdate added in v0.18.0 

func SinkReceiverPodUpdate(namespace string, annotations map[string]string) clientgotesting.UpdateActionImpl

func SinkReference added in v0.29.0 

func SinkReference() *contract.Reference

func SinkTopic added in v0.18.0 

func SinkTopic() string

func SourceAsOwnerReference added in v0.30.0 

func SourceAsOwnerReference() metav1.OwnerReference

func SourceDispatcherPod added in v0.27.0 

func SourceDispatcherPod(namespace string, annotations map[string]string) runtime.Object

func SourceReference added in v0.29.0 

func SourceReference() *contract.Reference

func StatusBrokerConfigMapUpdatedReady added in v0.28.0 

func StatusBrokerConfigMapUpdatedReady(env *config.Env) func(broker *eventing.Broker)

func StatusBrokerConfigNotParsed added in v0.28.0 

func StatusBrokerConfigNotParsed(reason string) func(broker *eventing.Broker)

func StatusBrokerConfigParsed added in v0.28.0 

func StatusBrokerConfigParsed(broker *eventing.Broker)

func StatusBrokerDataPlaneAvailable added in v0.28.0 

func StatusBrokerDataPlaneAvailable(broker *eventing.Broker)

func StatusBrokerDataPlaneNotAvailable added in v0.28.0 

func StatusBrokerDataPlaneNotAvailable(broker *eventing.Broker)

func StatusBrokerFailedToCreateTopic added in v0.28.0 

func StatusBrokerFailedToCreateTopic(broker *eventing.Broker)

func StatusBrokerProbeFailed added in v0.28.0 

func StatusBrokerProbeFailed(status prober.Status) reconcilertesting.BrokerOption

func StatusBrokerProbeSucceeded added in v0.28.0 

func StatusBrokerProbeSucceeded(broker *eventing.Broker)

func StatusBrokerTopicReady added in v0.28.0 

func StatusBrokerTopicReady(broker *eventing.Broker)

func StatusConfigMapNotUpdatedReady added in v0.28.0 

func StatusConfigMapNotUpdatedReady(reason, message string) func(obj duckv1.KRShaped)

func StatusConfigMapUpdatedReady added in v0.28.0 

func StatusConfigMapUpdatedReady(env *config.Env) func(obj duckv1.KRShaped)

func StatusConfigNotParsed added in v0.28.0 

func StatusConfigNotParsed(reason string) func(obj duckv1.KRShaped)

func StatusConfigParsed added in v0.28.0 

func StatusConfigParsed(obj duckv1.KRShaped)

func StatusControllerOwnsTopic added in v0.28.0 

func StatusControllerOwnsTopic(topicOwner string) func(obj duckv1.KRShaped)

func StatusDataPlaneAvailable added in v0.28.0 

func StatusDataPlaneAvailable(obj duckv1.KRShaped)

func StatusDataPlaneNotAvailable added in v0.28.0 

func StatusDataPlaneNotAvailable(obj duckv1.KRShaped)

func StatusExternalBrokerTopicNotPresentOrInvalid added in v0.32.0 

func StatusExternalBrokerTopicNotPresentOrInvalid(topicname string) func(broker *eventing.Broker)

func StatusExternalBrokerTopicReady added in v0.32.0 

func StatusExternalBrokerTopicReady(topic string) func(broker *eventing.Broker)

func StatusFailedToCreateTopic added in v0.28.0 

func StatusFailedToCreateTopic(topicName string) func(obj duckv1.KRShaped)

func StatusInitialOffsetsCommitted added in v0.28.0 

func StatusInitialOffsetsCommitted(obj duckv1.KRShaped)

func StatusProbeFailed added in v0.28.0 

func StatusProbeFailed(status prober.Status) func(obj duckv1.KRShaped)

func StatusProbeSucceeded added in v0.28.0 

func StatusProbeSucceeded(obj duckv1.KRShaped)

func StatusTopicNotPresentErr added in v0.28.0 

func StatusTopicNotPresentErr(topic string, err error) func(obj duckv1.KRShaped)

func StatusTopicNotPresentOrInvalid added in v0.32.0 

func StatusTopicNotPresentOrInvalid(topicName string) func(obj duckv1.KRShaped)

func StatusTopicReadyWithName added in v0.28.0 

func StatusTopicReadyWithName(topic string) func(obj duckv1.KRShaped)

func StatusTopicReadyWithOwner added in v0.28.0 

func StatusTopicReadyWithOwner(topic, owner string) func(obj duckv1.KRShaped)

func ToUnstructured added in v0.18.0 

func ToUnstructured(t *testing.T, objs []runtime.Object) (us []runtime.Object)

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 TriggerReference added in v0.29.0 

func TriggerReference() *contract.Reference

func WithBrokerConfig 

func WithBrokerConfig(reference *duckv1.KReference) func(*eventing.Broker)

func WithDeadLetterSinkURI added in v0.29.0 

func WithDeadLetterSinkURI(uri string) func(cg *kafkainternals.ConsumerGroup)

func WithDeletedTimeStamp added in v0.28.0 

func WithDeletedTimeStamp(obj duckv1.KRShaped)

func WithDeletedTimeStampConsumeGroup added in v0.32.0 

func WithDeletedTimeStampConsumeGroup(cg *kafkainternals.ConsumerGroup)

func WithDelivery 

func WithDelivery(mutations ...func(spec *eventingduck.DeliverySpec)) func(*eventing.Broker)

func WithExternalTopic added in v0.32.0 

func WithExternalTopic(topic string) func(*eventing.Broker)

func WithFreshSubscriber added in v0.28.0 

func WithFreshSubscriber(sub *SubscriberInfo)

func WithInitKafkaChannelConditions added in v0.28.0 

func WithInitKafkaChannelConditions(obj duckv1.KRShaped)

func WithNoDeadLetterSinkNamespace added in v0.25.2 

func WithNoDeadLetterSinkNamespace(spec *eventingduck.DeliverySpec)

func WithNoSubscriberURI added in v0.29.3 

func WithNoSubscriberURI(sub *SubscriberInfo)

func WithRetry added in v0.19.0 

func WithRetry(retry *int32, policy *eventingduck.BackoffPolicyType, delay *string) func(*eventing.Broker)

func WithServiceNamespace added in v0.25.2 

func WithServiceNamespace(ns string) func(s *corev1.Service)

func WithSubscribers added in v0.28.0 

func WithSubscribers(subscribers ...*SubscriberInfo) func(obj duckv1.KRShaped)

func WithUnknownSubscriber added in v0.30.0 

func WithUnknownSubscriber(sub *SubscriberInfo)

func WithUnreadySubscriber added in v0.28.0 

func WithUnreadySubscriber(sub *SubscriberInfo)

Types

type CMOption added in v0.21.0 

type CMOption func(cm *corev1.ConfigMap)

func BrokerAuthConfig added in v0.21.0 

func BrokerAuthConfig(name string) CMOption

type ConsumerConfigsOption added in v0.29.0 

type ConsumerConfigsOption func(configs *kafkainternals.ConsumerConfigs)

func ConsumerBootstrapServersConfig added in v0.29.0 

func ConsumerBootstrapServersConfig(s string) ConsumerConfigsOption

func ConsumerGroupIdConfig added in v0.29.0 

func ConsumerGroupIdConfig(s string) ConsumerConfigsOption

func ConsumerKeyTypeConfig added in v0.33.0 

func ConsumerKeyTypeConfig(s string) ConsumerConfigsOption

type ConsumerGroupOption added in v0.29.0 

type ConsumerGroupOption func(cg *kafkainternals.ConsumerGroup)

func ConsumerForTrigger added in v0.29.0 

func ConsumerForTrigger() ConsumerGroupOption

func ConsumerGroupConsumerSpec added in v0.29.0 

func ConsumerGroupConsumerSpec(spec kafkainternals.ConsumerSpec) ConsumerGroupOption

func ConsumerGroupOwnerRef added in v0.30.0 

func ConsumerGroupOwnerRef(reference metav1.OwnerReference) ConsumerGroupOption

func ConsumerGroupReplicas added in v0.29.0 

func ConsumerGroupReplicas(replicas int32) ConsumerGroupOption

func ConsumerGroupReplicasStatus added in v0.29.0 

func ConsumerGroupReplicasStatus(replicas int32) ConsumerGroupOption

func ConsumerGroupSelector added in v0.29.0 

func ConsumerGroupSelector(selector map[string]string) ConsumerGroupOption

func ConsumerGroupStatusReplicas added in v0.30.0 

func ConsumerGroupStatusReplicas(replicas int32) ConsumerGroupOption

func ConsumerGroupSubscriber added in v0.30.0 

func ConsumerGroupSubscriber(d duckv1.Destination) ConsumerGroupOption

func WithConsumerGroupFailed added in v0.29.0 

func WithConsumerGroupFailed(reason string, msg string) ConsumerGroupOption

func WithConsumerGroupLabels added in v0.29.0 

func WithConsumerGroupLabels(labels map[string]string) ConsumerGroupOption

func WithConsumerGroupMetaLabels added in v0.30.0 

func WithConsumerGroupMetaLabels(labels map[string]string) ConsumerGroupOption

func WithConsumerGroupName added in v0.29.0 

func WithConsumerGroupName(name string) ConsumerGroupOption

func WithConsumerGroupNamespace added in v0.29.0 

func WithConsumerGroupNamespace(namespace string) ConsumerGroupOption

func WithConsumerGroupOwnerRef added in v0.29.0 

func WithConsumerGroupOwnerRef(ownerref *metav1.OwnerReference) ConsumerGroupOption

type ConsumerOption added in v0.29.0 

type ConsumerOption func(cg *kafkainternals.Consumer)

func ConsumerOwnerRef added in v0.30.0 

func ConsumerOwnerRef(reference metav1.OwnerReference) ConsumerOption

func ConsumerReady added in v0.30.0 

func ConsumerReady() ConsumerOption

func ConsumerSpec added in v0.29.0 

func ConsumerSpec(spec kafkainternals.ConsumerSpec) ConsumerOption

func ConsumerUID added in v0.30.0 

func ConsumerUID(uid string) ConsumerOption

type ConsumerSpecOption added in v0.29.0 

type ConsumerSpecOption func(c *kafkainternals.ConsumerSpec)

func ConsumerAuth added in v0.29.0 

func ConsumerAuth(auth *kafkainternals.Auth) ConsumerSpecOption

func ConsumerCloudEventOverrides added in v0.29.0 

func ConsumerCloudEventOverrides(ce *duckv1.CloudEventOverrides) ConsumerSpecOption

func ConsumerConfigs added in v0.29.0 

func ConsumerConfigs(opts ...ConsumerConfigsOption) ConsumerSpecOption

func ConsumerDelivery added in v0.29.0 

func ConsumerDelivery(delivery *kafkainternals.DeliverySpec) ConsumerSpecOption

func ConsumerFilters added in v0.29.0 

func ConsumerFilters(filters *kafkainternals.Filters) ConsumerSpecOption

func ConsumerPlacement added in v0.29.0 

func ConsumerPlacement(pb kafkainternals.PodBind) ConsumerSpecOption

func ConsumerReply added in v0.30.0 

func ConsumerReply(s *kafkainternals.ReplyStrategy) ConsumerSpecOption

func ConsumerSubscriber added in v0.29.0 

func ConsumerSubscriber(dest duckv1.Destination) ConsumerSpecOption

func ConsumerTopics added in v0.29.0 

func ConsumerTopics(topics ...string) ConsumerSpecOption

func ConsumerVReplicas added in v0.29.0 

func ConsumerVReplicas(vreplicas int32) ConsumerSpecOption

type Ctor 

type Ctor func(ctx context.Context, listers *Listers, env *config.Env, row *TableRow) pkgcontroller.Reconciler

Ctor functions create a k8s controller with given params.

type DeliverySpecOption added in v0.30.0 

type DeliverySpecOption func(spec *kafkainternals.DeliverySpec)

func ConsumerInitialOffset added in v0.31.0 

func ConsumerInitialOffset(offset sources.Offset) DeliverySpecOption

func NewConsumerBackoffDelay added in v0.30.0 

func NewConsumerBackoffDelay(delay string) DeliverySpecOption

func NewConsumerBackoffPolicy added in v0.30.0 

func NewConsumerBackoffPolicy(policy eventingduck.BackoffPolicyType) DeliverySpecOption

func NewConsumerRetry added in v0.30.0 

func NewConsumerRetry(r int32) DeliverySpecOption

func NewConsumerSpecDeliveryDeadLetterSink added in v0.30.0 

func NewConsumerSpecDeliveryDeadLetterSink() DeliverySpecOption

func NewConsumerTimeout added in v0.30.0 

func NewConsumerTimeout(timeout string) DeliverySpecOption

type KRShapedOption added in v0.28.0 

type KRShapedOption func(obj duckv1.KRShaped)

func SinkContentMode added in v0.33.1 

func SinkContentMode(cm string) KRShapedOption

func StatusSourceSinkNotResolved added in v0.28.0 

func StatusSourceSinkNotResolved(err string) KRShapedOption

func StatusSourceSinkResolved added in v0.28.0 

func StatusSourceSinkResolved(uri string) KRShapedOption

func WithChannelDeadLetterSinkURI added in v0.30.3 

func WithChannelDeadLetterSinkURI(uri string) KRShapedOption

func WithChannelDelivery added in v0.30.3 

func WithChannelDelivery(d *eventingduckv1.DeliverySpec) KRShapedOption

func WithCloudEventOverrides added in v0.27.0 

func WithCloudEventOverrides(overrides *duckv1.CloudEventOverrides) KRShapedOption

func WithKeyType added in v0.27.0 

func WithKeyType(keyType string) KRShapedOption

func WithNumPartitions added in v0.28.0 

func WithNumPartitions(np int32) KRShapedOption

func WithReplicationFactor added in v0.28.0 

func WithReplicationFactor(rp int16) KRShapedOption

func WithRetentionDuration added in v0.28.0 

func WithRetentionDuration(rd string) KRShapedOption

func WithSourceSink added in v0.30.0 

func WithSourceSink(d duckv1.Destination) KRShapedOption

type Listers 

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

func (*Listers) GetAllObjects 

func (l *Listers) GetAllObjects() []runtime.Object

func (*Listers) GetBrokerLister 

func (l *Listers) GetBrokerLister() eventinglisters.BrokerLister

func (*Listers) GetConfigMapLister 

func (l *Listers) GetConfigMapLister() corelisters.ConfigMapLister

func (*Listers) GetConsumerGroupLister added in v0.28.0 

func (l *Listers) GetConsumerGroupLister() consumerlisters.ConsumerGroupLister

func (*Listers) GetConsumerLister added in v0.28.0 

func (l *Listers) GetConsumerLister() consumerlisters.ConsumerLister

func (*Listers) GetEventingKafkaBrokerObjects added in v0.27.0 

func (l *Listers) GetEventingKafkaBrokerObjects() []runtime.Object

func (*Listers) GetEventingKafkaObjects added in v0.18.0 

func (l *Listers) GetEventingKafkaObjects() []runtime.Object

func (*Listers) GetEventingObjects 

func (l *Listers) GetEventingObjects() []runtime.Object

func (*Listers) GetKafkaChannelLister added in v0.28.0 

func (l *Listers) GetKafkaChannelLister() eventingkafkachannelslisters.KafkaChannelLister

func (*Listers) GetKafkaInternalsObjects added in v0.29.0 

func (l *Listers) GetKafkaInternalsObjects() []runtime.Object

func (*Listers) GetKafkaSinkLister added in v0.18.0 

func (l *Listers) GetKafkaSinkLister() eventingkafkabrokerlisters.KafkaSinkLister

func (*Listers) GetKafkaSourceLister added in v0.27.0 

func (l *Listers) GetKafkaSourceLister() eventingkafkasourceslisters.KafkaSourceLister

func (*Listers) GetKubeObjects 

func (l *Listers) GetKubeObjects() []runtime.Object

func (*Listers) GetPodLister 

func (l *Listers) GetPodLister() corelisters.PodLister

func (*Listers) GetSecretLister added in v0.21.0 

func (l *Listers) GetSecretLister() corelisters.SecretLister

func (*Listers) GetServiceLister added in v0.31.0 

func (l *Listers) GetServiceLister() corelisters.ServiceLister

func (*Listers) GetSubscriptionLister added in v0.29.0 

func (l *Listers) GetSubscriptionLister() messaginglisters.SubscriptionLister

func (*Listers) GetTriggerLister 

func (l *Listers) GetTriggerLister() eventinglisters.TriggerLister

type PodOption added in v0.30.0 

type PodOption func(pod *corev1.Pod)

func PodAnnotations added in v0.30.0 

func PodAnnotations(annotations map[string]string) PodOption

func PodRunning added in v0.30.0 

func PodRunning() PodOption

type SubscriberInfo added in v0.28.0 

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

func Subscriber1 added in v0.28.0 

func Subscriber1(options ...subscriberInfoOption) *SubscriberInfo

func Subscriber2 added in v0.28.0 

func Subscriber2(options ...subscriberInfoOption) *SubscriberInfo

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.