testing

package
v0.21.2 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2021 License: Apache-2.0 Imports: 60 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeFactory 

func MakeFactory(ctor Ctor, unstructured bool, logger *zap.SugaredLogger) Factory

MakeFactory creates a reconciler factory with fake clients and controller created by `ctor`.

func MarkAddedToChannel 

func MarkAddedToChannel(s *v1beta1.Subscription)

func MarkReferencesResolved 

func MarkReferencesResolved(s *v1beta1.Subscription)

func MarkSubscriptionReady 

func MarkSubscriptionReady(s *v1beta1.Subscription)

func NewApiServerSource added in v0.19.0 

func NewApiServerSource(name, namespace string, o ...ApiServerSourceOption) *v1beta1.ApiServerSource

NewApiServerSource creates a v1beta1 ApiServer with ApiServerOptions

func NewBroker added in v0.16.0 

func NewBroker(name, namespace string, o ...BrokerOption) *v1beta1.Broker

NewBroker creates a Broker with BrokerOptions.

func NewChannel 

func NewChannel(name, namespace string, o ...ChannelOption) *v1beta1.Channel

NewChannel creates a Channel with ChannelOptions

func NewChannelable added in v0.16.0 

func NewChannelable(name, namespace string, imcopt ...ChannelableOption) *v1alpha1.Channelable

NewChannelable creates an Channelable with ChannelableOptions.

func NewConfigMap added in v0.16.0 

func NewConfigMap(name, namespace string, o ...ConfigMapOption) *v1.ConfigMap

NewConfigMap creates a new ConfigMap.

func NewContainerSource added in v0.19.0 

func NewContainerSource(name, namespace string, o ...ContainerSourceOption) *v1beta1.ContainerSource

NewContainerSource creates a v1beta1 ContainerSource with ContainerSourceOptions

func NewEndpoints added in v0.16.0 

func NewEndpoints(name, namespace string, so ...EndpointsOption) *corev1.Endpoints

NewEndpoints creates a Endpoints with EndpointsOptions

func NewEventType added in v0.16.0 

func NewEventType(name, namespace string, o ...EventTypeOption) *v1beta1.EventType

NewEventType creates a EventType with EventTypeOptions.

func NewFlowsParallel 

func NewFlowsParallel(name, namespace string, popt ...FlowsParallelOption) *v1beta1.Parallel

NewFlowsParallel creates an Parallel with ParallelOptions.

func NewInMemoryChannel 

func NewInMemoryChannel(name, namespace string, imcopt ...InMemoryChannelOption) *v1beta1.InMemoryChannel

NewInMemoryChannel creates a v1beta1.InMemoryChannel with InMemoryChannelOption .

func NewNamespace 

func NewNamespace(name string, o ...NamespaceOption) *corev1.Namespace

NewNamespace creates a Namespace with NamespaceOptions

func NewPingSource added in v0.20.0 

func NewPingSource(name, namespace string, o ...PingSourceOption) *v1beta1.PingSource

NewPingSource creates a PingSource with PingSourceOption.

func NewScheme 

func NewScheme() *runtime.Scheme

func NewSequence 

func NewSequence(name, namespace string, popt ...SequenceOption) *v1beta1.Sequence

NewSequence creates an Sequence with SequenceOptions.

func NewService added in v0.16.0 

func NewService(name, namespace string, so ...ServiceOption) *corev1.Service

NewService creates a Service with ServiceOptions

func NewSinkBinding added in v0.19.0 

func NewSinkBinding(name, namespace string, o ...SinkBindingOption) *sourcesv1beta1.SinkBinding

NewSinkBinding creates a SinkBinding with SinkBindingOptions

func NewSubscription 

func NewSubscription(name, namespace string, so ...SubscriptionOption) *v1beta1.Subscription

NewSubscription creates a Subscription with SubscriptionOptions

func NewSubscriptionWithoutNamespace 

func NewSubscriptionWithoutNamespace(name string, so ...SubscriptionOption) *v1beta1.Subscription

NewSubscriptionWithoutNamespace creates a Subscription with SubscriptionOptions but without a specific namespace

func NewTrigger 

func NewTrigger(name, namespace, broker string, to ...TriggerOption) *v1beta1.Trigger

NewTrigger creates a Trigger with TriggerOptions.

func NewUnstructured added in v0.16.0 

func NewUnstructured(gvk metav1.GroupVersionKind, name, namespace string, uo ...UnstructuredOption) *unstructured.Unstructured

NewUnstructured creates a unstructured.Unstructured with UnstructuredOption

func ToUnstructured 

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 WithBackingChannelReady 

func WithBackingChannelReady(c *v1beta1.Channel)

func WithBrokerDeletionTimestamp added in v0.16.0 

func WithBrokerDeletionTimestamp(b *v1beta1.Broker)

func WithBrokerReady added in v0.16.0 

func WithBrokerReady(b *v1beta1.Broker)

WithBrokerReady sets .Status to ready.

func WithChannelDeleted 

func WithChannelDeleted(c *v1beta1.Channel)

func WithChannelableDeleted added in v0.16.0 

func WithChannelableDeleted(imc *v1alpha1.Channelable)

func WithContainerSourceDeleted added in v0.19.0 

func WithContainerSourceDeleted(c *v1beta1.ContainerSource)

func WithEventTypeBrokerDoesNotExist added in v0.16.0 

func WithEventTypeBrokerDoesNotExist(et *v1beta1.EventType)

WithEventTypeBrokerNotFound calls .Status.MarkFilterFailed on the EventType.

func WithEventTypeBrokerExists added in v0.16.0 

func WithEventTypeBrokerExists(et *v1beta1.EventType)

WithEventTypeBrokerExists calls .Status.MarkBrokerExists on the EventType.

func WithEventTypeBrokerReady added in v0.16.0 

func WithEventTypeBrokerReady(et *v1beta1.EventType)

WithEventTypeBrokerReady calls .Status.MarkBrokerReady on the EventType.

func WithEventTypeDeletionTimestamp added in v0.16.0 

func WithEventTypeDeletionTimestamp(et *v1beta1.EventType)

func WithFlowsParallelDeleted 

func WithFlowsParallelDeleted(p *v1beta1.Parallel)

func WithInMemoryChannelDeleted 

func WithInMemoryChannelDeleted(imc *v1beta1.InMemoryChannel)

func WithInMemoryChannelDuckAnnotationV1Beta1 added in v0.16.0 

func WithInMemoryChannelDuckAnnotationV1Beta1(imc *v1beta1.InMemoryChannel)

func WithInitBrokerConditions added in v0.16.0 

func WithInitBrokerConditions(b *v1beta1.Broker)

WithInitBrokerConditions initializes the Broker's conditions.

func WithInitChannelConditions 

func WithInitChannelConditions(c *v1beta1.Channel)

WithInitChannelConditions initializes the Channel's conditions.

func WithInitContainerSourceConditions added in v0.19.0 

func WithInitContainerSourceConditions(s *v1beta1.ContainerSource)

WithInitContainerSourceConditions initializes the ContainerSource's conditions.

func WithInitEventTypeConditions added in v0.16.0 

func WithInitEventTypeConditions(et *v1beta1.EventType)

WithInitEventTypeConditions initializes the EventType's conditions.

func WithInitFlowsParallelConditions 

func WithInitFlowsParallelConditions(p *v1beta1.Parallel)

func WithInitInMemoryChannelConditions 

func WithInitInMemoryChannelConditions(imc *v1beta1.InMemoryChannel)

func WithInitPingSourceConditions added in v0.20.0 

func WithInitPingSourceConditions(s *v1beta1.PingSource)

func WithInitSequenceConditions 

func WithInitSequenceConditions(p *v1beta1.Sequence)

func WithInitSubscriptionConditions 

func WithInitSubscriptionConditions(s *v1beta1.Subscription)

WithInitSubscriptionConditions initializes the Subscriptions's conditions.

func WithInitTriggerConditions 

func WithInitTriggerConditions(t *v1beta1.Trigger)

WithInitTriggerConditions initializes the Triggers's conditions.

func WithNamespaceDeleted 

func WithNamespaceDeleted(n *corev1.Namespace)

func WithNoAnnotations added in v0.16.0 

func WithNoAnnotations(c *v1beta1.Channel)

func WithPingSourceCloudEventAttributes added in v0.20.0 

func WithPingSourceCloudEventAttributes(s *v1beta1.PingSource)

func WithPingSourceDeleted added in v0.20.0 

func WithPingSourceDeleted(c *v1beta1.PingSource)

func WithPingSourceDeployed added in v0.20.0 

func WithPingSourceDeployed(s *v1beta1.PingSource)

func WithPingSourceSinkNotFound added in v0.20.0 

func WithPingSourceSinkNotFound(s *v1beta1.PingSource)

func WithSequenceDeleted 

func WithSequenceDeleted(p *v1beta1.Sequence)

func WithSubscriptionDeleted 

func WithSubscriptionDeleted(s *v1beta1.Subscription)

TODO: this can be a runtime object

func WithSubscriptionReady 

func WithSubscriptionReady(s *v1beta1.Subscription)

func WithTriggerDeleted 

func WithTriggerDeleted(t *v1beta1.Trigger)

TODO: this can be a runtime object

Types

type ApiServerSourceOption added in v0.19.0 

type ApiServerSourceOption func(*v1beta1.ApiServerSource)

ApiServerSourceOption enables further configuration of a v1beta1 ApiServer.

func WithApiServerSourceSpec added in v0.19.0 

func WithApiServerSourceSpec(spec v1beta1.ApiServerSourceSpec) ApiServerSourceOption

type BrokerOption added in v0.16.0 

type BrokerOption func(*v1beta1.Broker)

BrokerOption enables further configuration of a Broker.

func WithBrokerAddress added in v0.16.0 

func WithBrokerAddress(address string) BrokerOption

WithBrokerAddress sets the Broker's address.

func WithBrokerAddressURI added in v0.16.0 

func WithBrokerAddressURI(uri *apis.URL) BrokerOption

WithBrokerAddressURI sets the Broker's address as URI.

func WithBrokerClass added in v0.16.0 

func WithBrokerClass(bc string) BrokerOption

func WithBrokerConfig added in v0.16.0 

func WithBrokerConfig(config *duckv1.KReference) BrokerOption

WithBrokerChannel sets the Broker's ChannelTemplateSpec to the specified CRD.

func WithBrokerFinalizers added in v0.16.0 

func WithBrokerFinalizers(finalizers ...string) BrokerOption

func WithBrokerGeneration added in v0.16.0 

func WithBrokerGeneration(gen int64) BrokerOption

func WithBrokerResourceVersion added in v0.16.0 

func WithBrokerResourceVersion(rv string) BrokerOption

func WithBrokerStatusObservedGeneration added in v0.16.0 

func WithBrokerStatusObservedGeneration(gen int64) BrokerOption

func WithFilterAvailable added in v0.16.0 

func WithFilterAvailable() BrokerOption

func WithFilterFailed added in v0.16.0 

func WithFilterFailed(reason, msg string) BrokerOption

WithFilterFailed calls .Status.MarkFilterFailed on the Broker.

func WithIngressAvailable added in v0.16.0 

func WithIngressAvailable() BrokerOption

func WithIngressFailed added in v0.16.0 

func WithIngressFailed(reason, msg string) BrokerOption

WithIngressFailed calls .Status.MarkIngressFailed on the Broker.

func WithTriggerChannelFailed added in v0.16.0 

func WithTriggerChannelFailed(reason, msg string) BrokerOption

WithTriggerChannelFailed calls .Status.MarkTriggerChannelFailed on the Broker.

func WithTriggerChannelReady added in v0.16.0 

func WithTriggerChannelReady() BrokerOption

WithTriggerChannelReady calls .Status.PropagateTriggerChannelReadiness on the Broker.

type ChannelOption 

type ChannelOption func(*v1beta1.Channel)

ChannelOption enables further configuration of a Channel.

func WithBackingChannelFailed 

func WithBackingChannelFailed(reason, msg string) ChannelOption

func WithBackingChannelObjRef 

func WithBackingChannelObjRef(objRef *duckv1.KReference) ChannelOption

func WithBackingChannelUnknown 

func WithBackingChannelUnknown(reason, msg string) ChannelOption

func WithChannelAddress 

func WithChannelAddress(hostname string) ChannelOption

func WithChannelGeneration 

func WithChannelGeneration(gen int64) ChannelOption

func WithChannelNoAddress 

func WithChannelNoAddress() ChannelOption

func WithChannelObservedGeneration 

func WithChannelObservedGeneration(gen int64) ChannelOption

func WithChannelReadySubscriber 

func WithChannelReadySubscriber(uid string) ChannelOption

func WithChannelReadySubscriberAndGeneration 

func WithChannelReadySubscriberAndGeneration(uid string, observedGeneration int64) ChannelOption

func WithChannelSubscriberStatuses 

func WithChannelSubscriberStatuses(subscriberStatuses []eventingduckv1beta1.SubscriberStatus) ChannelOption

func WithChannelTemplate 

func WithChannelTemplate(typeMeta metav1.TypeMeta) ChannelOption

type ChannelableOption added in v0.16.0 

type ChannelableOption func(*v1alpha1.Channelable)

ChannelableOption enables further configuration of a v1alpha1.Channelable.

func WithChannelableAddress added in v0.16.0 

func WithChannelableAddress(a string) ChannelableOption

func WithChannelableGeneration added in v0.16.0 

func WithChannelableGeneration(gen int64) ChannelableOption

func WithChannelableReady added in v0.16.0 

func WithChannelableReady() ChannelableOption

func WithChannelableReadySubscriber added in v0.16.0 

func WithChannelableReadySubscriber(uid string) ChannelableOption

func WithChannelableReadySubscriberAndGeneration added in v0.16.0 

func WithChannelableReadySubscriberAndGeneration(uid string, observedGeneration int64) ChannelableOption

func WithChannelableStatusObservedGeneration added in v0.16.0 

func WithChannelableStatusObservedGeneration(gen int64) ChannelableOption

func WithChannelableStatusSubscribers added in v0.16.0 

func WithChannelableStatusSubscribers(subscriberStatuses []duckv1beta1.SubscriberStatus) ChannelableOption

func WithChannelableSubscribers added in v0.16.0 

func WithChannelableSubscribers(subscribers []v1alpha1.SubscriberSpec) ChannelableOption

type ConfigMapOption added in v0.16.0 

type ConfigMapOption func(*v1.ConfigMap)

ConfigMapOption enables further configuration of a ConfigMap.

func WithConfigMapData added in v0.16.0 

func WithConfigMapData(data map[string]string) ConfigMapOption

func WithConfigMapLabels added in v0.16.0 

func WithConfigMapLabels(labels metav1.LabelSelector) ConfigMapOption

type ContainerSourceOption added in v0.19.0 

type ContainerSourceOption func(*v1beta1.ContainerSource)

ContainerSourceOption enables further configuration of a ContainerSource.

func WithContainerSourceAnnotations added in v0.19.0 

func WithContainerSourceAnnotations(annotations map[string]string) ContainerSourceOption

func WithContainerSourceLabels added in v0.19.0 

func WithContainerSourceLabels(labels map[string]string) ContainerSourceOption

func WithContainerSourceObjectMetaGeneration added in v0.19.0 

func WithContainerSourceObjectMetaGeneration(generation int64) ContainerSourceOption

func WithContainerSourcePropagateReceiveAdapterStatus added in v0.19.0 

func WithContainerSourcePropagateReceiveAdapterStatus(d *appsv1.Deployment) ContainerSourceOption

func WithContainerSourcePropagateSinkbindingStatus added in v0.19.0 

func WithContainerSourcePropagateSinkbindingStatus(status *v1beta1.SinkBindingStatus) ContainerSourceOption

func WithContainerSourceSpec added in v0.19.0 

func WithContainerSourceSpec(spec v1beta1.ContainerSourceSpec) ContainerSourceOption

func WithContainerSourceStatusObservedGeneration added in v0.19.0 

func WithContainerSourceStatusObservedGeneration(generation int64) ContainerSourceOption

func WithContainerSourceUID added in v0.19.0 

func WithContainerSourceUID(uid types.UID) ContainerSourceOption

func WithContainerUnobservedGeneration added in v0.19.0 

func WithContainerUnobservedGeneration() ContainerSourceOption

type Ctor 

type Ctor func(context.Context, *Listers, configmap.Watcher) controller.Reconciler

Ctor functions create a k8s controller with given params.

type EndpointsOption added in v0.16.0 

type EndpointsOption func(*corev1.Endpoints)

EndpointsOption enables further configuration of a Endpoints.

func WithEndpointsAddresses added in v0.16.0 

func WithEndpointsAddresses(addrs ...corev1.EndpointAddress) EndpointsOption

func WithEndpointsAnnotations added in v0.16.0 

func WithEndpointsAnnotations(annotations map[string]string) EndpointsOption

func WithEndpointsLabels added in v0.16.0 

func WithEndpointsLabels(labels map[string]string) EndpointsOption

func WithEndpointsNotReadyAddresses added in v0.16.0 

func WithEndpointsNotReadyAddresses(addrs ...corev1.EndpointAddress) EndpointsOption

type EventTypeOption added in v0.16.0 

type EventTypeOption func(*v1beta1.EventType)

EventTypeOption enables further configuration of an EventType.

func WithEventTypeBroker added in v0.16.0 

func WithEventTypeBroker(broker string) EventTypeOption

func WithEventTypeBrokerFailed added in v0.16.0 

func WithEventTypeBrokerFailed(reason, message string) EventTypeOption

func WithEventTypeBrokerUnknown added in v0.16.0 

func WithEventTypeBrokerUnknown(reason, message string) EventTypeOption

func WithEventTypeDescription added in v0.16.0 

func WithEventTypeDescription(description string) EventTypeOption

func WithEventTypeLabels added in v0.16.0 

func WithEventTypeLabels(labels map[string]string) EventTypeOption

func WithEventTypeOwnerReference added in v0.16.0 

func WithEventTypeOwnerReference(ownerRef metav1.OwnerReference) EventTypeOption

func WithEventTypeSource added in v0.16.0 

func WithEventTypeSource(source *apis.URL) EventTypeOption

func WithEventTypeType added in v0.16.0 

func WithEventTypeType(t string) EventTypeOption

type FlowsParallelOption 

type FlowsParallelOption func(*v1beta1.Parallel)

ParallelOption enables further configuration of a Parallel.

func WithFlowsParallelAddressableNotReady 

func WithFlowsParallelAddressableNotReady(reason, message string) FlowsParallelOption

func WithFlowsParallelBranchStatuses 

func WithFlowsParallelBranchStatuses(branchStatuses []v1beta1.ParallelBranchStatus) FlowsParallelOption

func WithFlowsParallelBranches 

func WithFlowsParallelBranches(branches []v1beta1.ParallelBranch) FlowsParallelOption

func WithFlowsParallelChannelTemplateSpec 

func WithFlowsParallelChannelTemplateSpec(cts *messagingv1beta1.ChannelTemplateSpec) FlowsParallelOption

func WithFlowsParallelChannelsNotReady 

func WithFlowsParallelChannelsNotReady(reason, message string) FlowsParallelOption

func WithFlowsParallelGeneration 

func WithFlowsParallelGeneration(gen int64) FlowsParallelOption

func WithFlowsParallelIngressChannelStatus 

func WithFlowsParallelIngressChannelStatus(status v1beta1.ParallelChannelStatus) FlowsParallelOption

func WithFlowsParallelReply 

func WithFlowsParallelReply(reply *duckv1.Destination) FlowsParallelOption

func WithFlowsParallelStatusObservedGeneration 

func WithFlowsParallelStatusObservedGeneration(gen int64) FlowsParallelOption

func WithFlowsParallelSubscriptionsNotReady 

func WithFlowsParallelSubscriptionsNotReady(reason, message string) FlowsParallelOption

type InMemoryChannelOption 

type InMemoryChannelOption func(*v1beta1.InMemoryChannel)

InMemoryChannelOption enables further configuration of a v1beta1.InMemoryChannel.

func WithInMemoryChannelAddress 

func WithInMemoryChannelAddress(a string) InMemoryChannelOption

func WithInMemoryChannelChannelServiceNotReady 

func WithInMemoryChannelChannelServiceNotReady(reason, message string) InMemoryChannelOption

func WithInMemoryChannelChannelServiceReady 

func WithInMemoryChannelChannelServiceReady() InMemoryChannelOption

func WithInMemoryChannelDeploymentFailed 

func WithInMemoryChannelDeploymentFailed(reason, message string) InMemoryChannelOption

func WithInMemoryChannelDeploymentReady 

func WithInMemoryChannelDeploymentReady() InMemoryChannelOption

func WithInMemoryChannelDeploymentUnknown 

func WithInMemoryChannelDeploymentUnknown(reason, message string) InMemoryChannelOption

func WithInMemoryChannelEndpointsNotReady 

func WithInMemoryChannelEndpointsNotReady(reason, message string) InMemoryChannelOption

func WithInMemoryChannelEndpointsReady 

func WithInMemoryChannelEndpointsReady() InMemoryChannelOption

func WithInMemoryChannelGeneration 

func WithInMemoryChannelGeneration(gen int64) InMemoryChannelOption

func WithInMemoryChannelReady 

func WithInMemoryChannelReady(host string) InMemoryChannelOption

func WithInMemoryChannelReadySubscriber 

func WithInMemoryChannelReadySubscriber(uid string) InMemoryChannelOption

func WithInMemoryChannelReadySubscriberAndGeneration 

func WithInMemoryChannelReadySubscriberAndGeneration(uid string, observedGeneration int64) InMemoryChannelOption

func WithInMemoryChannelServiceReady 

func WithInMemoryChannelServiceReady() InMemoryChannelOption

func WithInMemoryChannelServicetNotReady 

func WithInMemoryChannelServicetNotReady(reason, message string) InMemoryChannelOption

func WithInMemoryChannelStatusObservedGeneration 

func WithInMemoryChannelStatusObservedGeneration(gen int64) InMemoryChannelOption

func WithInMemoryChannelStatusSubscribers 

func WithInMemoryChannelStatusSubscribers(subscriberStatuses []duckv1beta1.SubscriberStatus) InMemoryChannelOption

func WithInMemoryChannelSubscribers 

func WithInMemoryChannelSubscribers(subscribers []duckv1beta1.SubscriberSpec) InMemoryChannelOption

func WithInMemoryScopeAnnotation 

func WithInMemoryScopeAnnotation(value string) InMemoryChannelOption

type Listers 

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

func NewListers 

func NewListers(objs []runtime.Object) Listers

func (*Listers) GetAllObjects 

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

func (*Listers) GetApiServerSourceLister 

func (l *Listers) GetApiServerSourceLister() sourcelisters.ApiServerSourceLister

func (*Listers) GetApiServerSourceV1alpha2Lister 

func (l *Listers) GetApiServerSourceV1alpha2Lister() sourcev1alpha2listers.ApiServerSourceLister

func (*Listers) GetApiServerSourceV1beta1Lister added in v0.17.0 

func (l *Listers) GetApiServerSourceV1beta1Lister() sourcev1beta1listers.ApiServerSourceLister

func (*Listers) GetBrokerLister 

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

func (*Listers) GetConfigMapLister 

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

func (*Listers) GetConfigMapPropagationLister 

func (l *Listers) GetConfigMapPropagationLister() configslisters.ConfigMapPropagationLister

func (*Listers) GetContainerSourceLister 

func (l *Listers) GetContainerSourceLister() sourcev1alpha2listers.ContainerSourceLister

func (*Listers) GetCustomResourceDefinitionLister 

func (l *Listers) GetCustomResourceDefinitionLister() apiextensionsv1beta1listers.CustomResourceDefinitionLister

func (*Listers) GetDeploymentLister 

func (l *Listers) GetDeploymentLister() appsv1listers.DeploymentLister

func (*Listers) GetEndpointsLister 

func (l *Listers) GetEndpointsLister() corev1listers.EndpointsLister

func (*Listers) GetEventTypeLister 

func (l *Listers) GetEventTypeLister() eventingv1beta1listers.EventTypeLister

func (*Listers) GetEventingObjects 

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

func (*Listers) GetInMemoryChannelLister 

func (l *Listers) GetInMemoryChannelLister() messaginglistersv1beta1.InMemoryChannelLister

func (*Listers) GetK8sServiceLister 

func (l *Listers) GetK8sServiceLister() corev1listers.ServiceLister

func (*Listers) GetKubeObjects 

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

func (*Listers) GetMessagingChannelLister 

func (l *Listers) GetMessagingChannelLister() messaginglistersv1beta1.ChannelLister

func (*Listers) GetNamespaceLister 

func (l *Listers) GetNamespaceLister() corev1listers.NamespaceLister

func (*Listers) GetParallelLister 

func (l *Listers) GetParallelLister() flowslisters.ParallelLister

func (*Listers) GetPingSourceV1beta1Lister added in v0.18.0 

func (l *Listers) GetPingSourceV1beta1Lister() sourcev1beta1listers.PingSourceLister

func (*Listers) GetRoleBindingLister 

func (l *Listers) GetRoleBindingLister() rbacv1listers.RoleBindingLister

func (*Listers) GetSequenceLister 

func (l *Listers) GetSequenceLister() flowslisters.SequenceLister

func (*Listers) GetServiceAccountLister 

func (l *Listers) GetServiceAccountLister() corev1listers.ServiceAccountLister

func (*Listers) GetServiceLister 

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

func (*Listers) GetSinkBindingLister 

func (l *Listers) GetSinkBindingLister() sourcelisters.SinkBindingLister

func (*Listers) GetSinkBindingV1alpha2Lister 

func (l *Listers) GetSinkBindingV1alpha2Lister() sourcev1alpha2listers.SinkBindingLister

func (*Listers) GetSubscriberObjects 

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

func (*Listers) GetSubscriptionLister 

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

func (*Listers) GetTriggerLister 

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

type NamespaceOption 

type NamespaceOption func(*corev1.Namespace)

NamespaceOption enables further configuration of a Namespace.

func WithNamespaceLabeled 

func WithNamespaceLabeled(labels map[string]string) NamespaceOption

type PingSourceOption added in v0.20.0 

type PingSourceOption func(*v1beta1.PingSource)

PingSourceOption enables further configuration of a CronJob.

func WithPingSourceFinalizers added in v0.20.0 

func WithPingSourceFinalizers(finalizers ...string) PingSourceOption

func WithPingSourceSink added in v0.20.0 

func WithPingSourceSink(uri *apis.URL) PingSourceOption

func WithPingSourceSpec added in v0.20.0 

func WithPingSourceSpec(spec v1beta1.PingSourceSpec) PingSourceOption

type SequenceOption 

type SequenceOption func(*v1beta1.Sequence)

SequenceOption enables further configuration of a Sequence.

func WithSequenceAddressableNotReady 

func WithSequenceAddressableNotReady(reason, message string) SequenceOption

func WithSequenceChannelStatuses 

func WithSequenceChannelStatuses(channelStatuses []v1beta1.SequenceChannelStatus) SequenceOption

func WithSequenceChannelTemplateSpec 

func WithSequenceChannelTemplateSpec(cts *messagingv1beta1.ChannelTemplateSpec) SequenceOption

func WithSequenceChannelsNotReady 

func WithSequenceChannelsNotReady(reason, message string) SequenceOption

func WithSequenceGeneration 

func WithSequenceGeneration(gen int64) SequenceOption

func WithSequenceReply 

func WithSequenceReply(reply *duckv1.Destination) SequenceOption

func WithSequenceStatusObservedGeneration 

func WithSequenceStatusObservedGeneration(gen int64) SequenceOption

func WithSequenceSteps 

func WithSequenceSteps(steps []v1beta1.SequenceStep) SequenceOption

func WithSequenceSubscriptionStatuses 

func WithSequenceSubscriptionStatuses(subscriptionStatuses []v1beta1.SequenceSubscriptionStatus) SequenceOption

func WithSequenceSubscriptionsNotReady 

func WithSequenceSubscriptionsNotReady(reason, message string) SequenceOption

type ServiceOption added in v0.16.0 

type ServiceOption func(*corev1.Service)

ServiceOption enables further configuration of a Service.

func WithServiceAnnotations added in v0.16.0 

func WithServiceAnnotations(annotations map[string]string) ServiceOption

func WithServiceLabels added in v0.16.0 

func WithServiceLabels(labels map[string]string) ServiceOption

func WithServiceOwnerReferences added in v0.16.0 

func WithServiceOwnerReferences(ownerReferences []metav1.OwnerReference) ServiceOption

func WithServicePorts added in v0.16.0 

func WithServicePorts(ports []corev1.ServicePort) ServiceOption

type SinkBindingOption added in v0.19.0 

type SinkBindingOption func(*sourcesv1beta1.SinkBinding)

SinkBindingOption enables further configuration of a v1beta1 SinkBinding.

func WithCloudEventOverrides added in v0.19.0 

func WithCloudEventOverrides(overrides duckv1.CloudEventOverrides) SinkBindingOption

WithCloudEventOverrides assigns the CloudEventsOverrides of the SinkBinding.

func WithSink added in v0.19.0 

func WithSink(sink duckv1.Destination) SinkBindingOption

WithSink assigns the sink of the SinkBinding.

func WithSubject added in v0.19.0 

func WithSubject(subject tracker.Reference) SinkBindingOption

WithSubject assigns the subject of the SinkBinding.

type SubscriptionOption 

type SubscriptionOption func(*v1beta1.Subscription)

SubscriptionOption enables further configuration of a Subscription.

func MarkNotAddedToChannel 

func MarkNotAddedToChannel(reason, msg string) SubscriptionOption

func WithSubscriptionChannel 

func WithSubscriptionChannel(gvk metav1.GroupVersionKind, name string) SubscriptionOption

func WithSubscriptionDeadLetterSinkURI 

func WithSubscriptionDeadLetterSinkURI(uri *apis.URL) SubscriptionOption

func WithSubscriptionDeliveryRef 

func WithSubscriptionDeliveryRef(gvk metav1.GroupVersionKind, name, namespace string) SubscriptionOption

func WithSubscriptionFinalizers 

func WithSubscriptionFinalizers(finalizers ...string) SubscriptionOption

func WithSubscriptionGenerateName 

func WithSubscriptionGenerateName(generateName string) SubscriptionOption

func WithSubscriptionGeneration 

func WithSubscriptionGeneration(gen int64) SubscriptionOption

func WithSubscriptionLabels 

func WithSubscriptionLabels(labels map[string]string) SubscriptionOption

func WithSubscriptionOwnerReferences 

func WithSubscriptionOwnerReferences(ownerReferences []metav1.OwnerReference) SubscriptionOption

func WithSubscriptionPhysicalSubscriptionReply 

func WithSubscriptionPhysicalSubscriptionReply(uri *apis.URL) SubscriptionOption

func WithSubscriptionPhysicalSubscriptionSubscriber 

func WithSubscriptionPhysicalSubscriptionSubscriber(uri *apis.URL) SubscriptionOption

func WithSubscriptionReferencesNotResolved 

func WithSubscriptionReferencesNotResolved(reason, msg string) SubscriptionOption

func WithSubscriptionReferencesResolvedUnknown 

func WithSubscriptionReferencesResolvedUnknown(reason, msg string) SubscriptionOption

func WithSubscriptionReply 

func WithSubscriptionReply(gvk metav1.GroupVersionKind, name, namespace string) SubscriptionOption

func WithSubscriptionStatusObservedGeneration 

func WithSubscriptionStatusObservedGeneration(gen int64) SubscriptionOption

func WithSubscriptionSubscriberRef 

func WithSubscriptionSubscriberRef(gvk metav1.GroupVersionKind, name, namespace string) SubscriptionOption

func WithSubscriptionUID 

func WithSubscriptionUID(uid types.UID) SubscriptionOption

type TriggerOption 

type TriggerOption func(*v1beta1.Trigger)

TriggerOption enables further configuration of a Trigger.

func WithAnnotation added in v0.16.0 

func WithAnnotation(key, value string) TriggerOption

func WithDependencyAnnotation 

func WithDependencyAnnotation(dependencyAnnotation string) TriggerOption

func WithTriggerBrokerFailed 

func WithTriggerBrokerFailed(reason, message string) TriggerOption

WithTriggerBrokerFailed marks the Broker as failed

func WithTriggerBrokerReady 

func WithTriggerBrokerReady() TriggerOption

WithTriggerBrokerReady initializes the Triggers's conditions.

func WithTriggerBrokerUnknown 

func WithTriggerBrokerUnknown(reason, message string) TriggerOption

WithTriggerBrokerUnknown marks the Broker as unknown

func WithTriggerDependencyFailed 

func WithTriggerDependencyFailed(reason, message string) TriggerOption

func WithTriggerDependencyReady 

func WithTriggerDependencyReady() TriggerOption

func WithTriggerDependencyUnknown 

func WithTriggerDependencyUnknown(reason, message string) TriggerOption

func WithTriggerGeneration 

func WithTriggerGeneration(gen int64) TriggerOption

func WithTriggerNotSubscribed 

func WithTriggerNotSubscribed(reason, message string) TriggerOption

func WithTriggerStatusObservedGeneration 

func WithTriggerStatusObservedGeneration(gen int64) TriggerOption

func WithTriggerStatusSubscriberURI 

func WithTriggerStatusSubscriberURI(uri string) TriggerOption

func WithTriggerSubscribed 

func WithTriggerSubscribed() TriggerOption

func WithTriggerSubscribedUnknown 

func WithTriggerSubscribedUnknown(reason, message string) TriggerOption

func WithTriggerSubscriberRef 

func WithTriggerSubscriberRef(gvk metav1.GroupVersionKind, name, namespace string) TriggerOption

func WithTriggerSubscriberRefAndURIReference 

func WithTriggerSubscriberRefAndURIReference(gvk metav1.GroupVersionKind, name, namespace string, rawuri string) TriggerOption

func WithTriggerSubscriberResolvedFailed 

func WithTriggerSubscriberResolvedFailed(reason, message string) TriggerOption

func WithTriggerSubscriberResolvedSucceeded 

func WithTriggerSubscriberResolvedSucceeded() TriggerOption

func WithTriggerSubscriberResolvedUnknown 

func WithTriggerSubscriberResolvedUnknown(reason, message string) TriggerOption

func WithTriggerSubscriberURI 

func WithTriggerSubscriberURI(rawurl string) TriggerOption

func WithTriggerSubscriptionNotConfigured 

func WithTriggerSubscriptionNotConfigured() TriggerOption

func WithTriggerUID 

func WithTriggerUID(uid string) TriggerOption

type UnstructuredOption added in v0.16.0 

type UnstructuredOption func(*unstructured.Unstructured)

UnstructuredOption enables further configuration of a Unstructured.

func WithUnstructuredAddressable added in v0.16.0 

func WithUnstructuredAddressable(hostname string) UnstructuredOption

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.