testing

package
v0.26.4 Latest Latest
Warning

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

 Go to latest Published: Jan 21, 2022 License: Apache-2.0 Imports: 56 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeFactory added in v0.17.0 

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

func MarkAddedToChannel(s *v1.Subscription)

func MarkReferencesResolved added in v0.18.0 

func MarkReferencesResolved(s *v1.Subscription)

func MarkSubscriptionReady added in v0.18.0 

func MarkSubscriptionReady(s *v1.Subscription)

func NewApiServerSource added in v0.19.0 

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

NewApiServerSource creates a v1 ApiServer with ApiServerOptions

func NewBroker added in v0.17.0 

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

NewBroker creates a Broker with BrokerOptions.

func NewChannel added in v0.18.0 

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

NewChannel creates a Channel with ChannelOptions

func NewConfigMap added in v0.17.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) *v1.ContainerSource

NewContainerSource creates a v1 ContainerSource with ContainerSourceOptions

func NewDeployment added in v0.23.0 

func NewDeployment(name, namespace string, do ...DeploymentOption) *appsv1.Deployment

NewDeployment creates a Deployment with DeploymentOptions.

func NewEndpoints added in v0.17.0 

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

NewEndpoints creates a Endpoints with EndpointsOptions

func NewEventType added in v0.23.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) *flowsv1.Parallel

NewFlowsParallel creates an Parallel with ParallelOptions.

func NewInMemoryChannel added in v0.17.0 

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

NewInMemoryChannel creates a v1.InMemoryChannel with InMemoryChannelOption .

func NewNamespace added in v0.22.0 

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

NewNamespace creates a Namespace with NamespaceOptions

func NewPingSource added in v0.23.0 

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

NewPingSource creates a PingSource with PingSourceOption.

func NewScheme added in v0.17.0 

func NewScheme() *runtime.Scheme

func NewSequence 

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

NewSequence creates an Sequence with SequenceOptions.

func NewService added in v0.18.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) *sourcesv1.SinkBinding

NewSinkBinding creates a SinkBinding with SinkBindingOptions

func NewSubscription added in v0.18.0 

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

NewSubscription creates a Subscription with SubscriptionOptions

func NewSubscriptionWithoutNamespace added in v0.18.0 

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

NewSubscriptionWithoutNamespace creates a Subscription with SubscriptionOptions but without a specific namespace

func NewTrigger added in v0.17.0 

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

NewTrigger creates a Trigger with TriggerOptions.

func NewUnstructured added in v0.17.0 

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

NewUnstructured creates a unstructured.Unstructured with UnstructuredOption

func ToUnstructured added in v0.17.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 WithApiServerSourceDeleted added in v0.19.0 

func WithApiServerSourceDeleted(c *v1.ApiServerSource)

func WithApiServerSourceDeployed added in v0.19.0 

func WithApiServerSourceDeployed(s *v1.ApiServerSource)

func WithApiServerSourceDeploymentUnavailable added in v0.19.0 

func WithApiServerSourceDeploymentUnavailable(s *v1.ApiServerSource)

func WithApiServerSourceNoSufficientPermissions added in v0.19.0 

func WithApiServerSourceNoSufficientPermissions(s *v1.ApiServerSource)

func WithApiServerSourceSinkNotFound added in v0.19.0 

func WithApiServerSourceSinkNotFound(s *v1.ApiServerSource)

func WithApiServerSourceSufficientPermissions added in v0.19.0 

func WithApiServerSourceSufficientPermissions(s *v1.ApiServerSource)

func WithBackingChannelReady added in v0.18.0 

func WithBackingChannelReady(c *eventingv1.Channel)

func WithBrokerDeletionTimestamp added in v0.17.0 

func WithBrokerDeletionTimestamp(b *v1.Broker)

func WithBrokerReady added in v0.17.0 

func WithBrokerReady(b *v1.Broker)

WithBrokerReady sets .Status to ready.

func WithChannelDeleted added in v0.18.0 

func WithChannelDeleted(c *eventingv1.Channel)

func WithEventTypeBrokerDoesNotExist added in v0.23.0 

func WithEventTypeBrokerDoesNotExist(et *v1beta1.EventType)

WithEventTypeBrokerNotFound calls .Status.MarkFilterFailed on the EventType.

func WithEventTypeBrokerExists added in v0.23.0 

func WithEventTypeBrokerExists(et *v1beta1.EventType)

WithEventTypeBrokerExists calls .Status.MarkBrokerExists on the EventType.

func WithEventTypeBrokerReady added in v0.23.0 

func WithEventTypeBrokerReady(et *v1beta1.EventType)

WithEventTypeBrokerReady calls .Status.MarkBrokerReady on the EventType.

func WithEventTypeDeletionTimestamp added in v0.23.0 

func WithEventTypeDeletionTimestamp(et *v1beta1.EventType)

func WithFlowsParallelDeleted 

func WithFlowsParallelDeleted(p *flowsv1.Parallel)

func WithInMemoryChannelDeleted added in v0.17.0 

func WithInMemoryChannelDeleted(imc *v1.InMemoryChannel)

func WithInMemoryChannelDuckAnnotationV1Beta1 added in v0.17.0 

func WithInMemoryChannelDuckAnnotationV1Beta1(imc *v1.InMemoryChannel)

func WithInitApiServerSourceConditions added in v0.19.0 

func WithInitApiServerSourceConditions(s *v1.ApiServerSource)

WithInitApiServerSourceConditions initializes the v1 ApiServerSource's conditions.

func WithInitBrokerConditions added in v0.17.0 

func WithInitBrokerConditions(b *v1.Broker)

WithInitBrokerConditions initializes the Broker's conditions.

func WithInitChannelConditions added in v0.18.0 

func WithInitChannelConditions(c *eventingv1.Channel)

WithInitChannelConditions initializes the Channel's conditions.

func WithInitContainerSourceConditions added in v0.19.0 

func WithInitContainerSourceConditions(s *v1.ContainerSource)

WithInitContainerSourceConditions initializes the ContainerSource's conditions.

func WithInitEventTypeConditions added in v0.23.0 

func WithInitEventTypeConditions(et *v1beta1.EventType)

WithInitEventTypeConditions initializes the EventType's conditions.

func WithInitFlowsParallelConditions 

func WithInitFlowsParallelConditions(p *flowsv1.Parallel)

func WithInitInMemoryChannelConditions added in v0.17.0 

func WithInitInMemoryChannelConditions(imc *v1.InMemoryChannel)

func WithInitPingSourceConditions added in v0.23.0 

func WithInitPingSourceConditions(s *v1.PingSource)

func WithInitSequenceConditions 

func WithInitSequenceConditions(p *flowsv1.Sequence)

func WithInitSubscriptionConditions added in v0.18.0 

func WithInitSubscriptionConditions(s *v1.Subscription)

WithInitSubscriptionConditions initializes the Subscriptions's conditions.

func WithInitTriggerConditions added in v0.17.0 

func WithInitTriggerConditions(t *v1.Trigger)

WithInitTriggerConditions initializes the Triggers's conditions.

func WithNamespaceDeleted added in v0.22.0 

func WithNamespaceDeleted(n *corev1.Namespace)

func WithNoAnnotations added in v0.18.0 

func WithNoAnnotations(c *eventingv1.Channel)

func WithPingSourceCloudEventAttributes added in v0.23.0 

func WithPingSourceCloudEventAttributes(s *v1.PingSource)

func WithPingSourceDeleted added in v0.23.0 

func WithPingSourceDeleted(c *v1.PingSource)

func WithPingSourceDeployed added in v0.23.0 

func WithPingSourceDeployed(s *v1.PingSource)

func WithPingSourceSinkNotFound added in v0.23.0 

func WithPingSourceSinkNotFound(s *v1.PingSource)

func WithSequenceDeleted 

func WithSequenceDeleted(p *flowsv1.Sequence)

func WithSubscriptionDeleted added in v0.18.0 

func WithSubscriptionDeleted(s *v1.Subscription)

TODO: this can be a runtime object

func WithSubscriptionReady added in v0.18.0 

func WithSubscriptionReady(s *v1.Subscription)

func WithTriggerDeleted added in v0.17.0 

func WithTriggerDeleted(t *v1.Trigger)

Types

type ApiServerSourceOption added in v0.19.0 

type ApiServerSourceOption func(*v1.ApiServerSource)

ApiServerSourceOption enables further configuration of a v1 ApiServer.

func WithApiServerSourceObjectMetaGeneration added in v0.19.0 

func WithApiServerSourceObjectMetaGeneration(generation int64) ApiServerSourceOption

func WithApiServerSourceReferenceModeEventTypes added in v0.19.0 

func WithApiServerSourceReferenceModeEventTypes(source string) ApiServerSourceOption

func WithApiServerSourceResourceModeEventTypes added in v0.19.0 

func WithApiServerSourceResourceModeEventTypes(source string) ApiServerSourceOption

func WithApiServerSourceSink added in v0.19.0 

func WithApiServerSourceSink(uri *apis.URL) ApiServerSourceOption

func WithApiServerSourceSpec added in v0.19.0 

func WithApiServerSourceSpec(spec v1.ApiServerSourceSpec) ApiServerSourceOption

func WithApiServerSourceStatusObservedGeneration added in v0.19.0 

func WithApiServerSourceStatusObservedGeneration(generation int64) ApiServerSourceOption

func WithApiServerSourceUID added in v0.19.0 

func WithApiServerSourceUID(uid string) ApiServerSourceOption

type BrokerOption added in v0.17.0 

type BrokerOption func(*v1.Broker)

BrokerOption enables further configuration of a Broker.

func WithBrokerAddress added in v0.17.0 

func WithBrokerAddress(address string) BrokerOption

WithBrokerAddress sets the Broker's address.

func WithBrokerAddressURI added in v0.17.0 

func WithBrokerAddressURI(uri *apis.URL) BrokerOption

WithBrokerAddressURI sets the Broker's address as URI.

func WithBrokerClass added in v0.17.0 

func WithBrokerClass(bc string) BrokerOption

func WithBrokerConfig added in v0.17.0 

func WithBrokerConfig(config *duckv1.KReference) BrokerOption

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

func WithBrokerFinalizers added in v0.17.0 

func WithBrokerFinalizers(finalizers ...string) BrokerOption

func WithBrokerGeneration added in v0.17.0 

func WithBrokerGeneration(gen int64) BrokerOption

func WithBrokerResourceVersion added in v0.17.0 

func WithBrokerResourceVersion(rv string) BrokerOption

func WithBrokerStatusObservedGeneration added in v0.17.0 

func WithBrokerStatusObservedGeneration(gen int64) BrokerOption

func WithChannelAPIVersionAnnotation added in v0.17.0 

func WithChannelAPIVersionAnnotation(apiVersion string) BrokerOption

func WithChannelAddressAnnotation added in v0.17.0 

func WithChannelAddressAnnotation(address string) BrokerOption

func WithChannelKindAnnotation added in v0.17.0 

func WithChannelKindAnnotation(kind string) BrokerOption

func WithChannelNameAnnotation added in v0.17.0 

func WithChannelNameAnnotation(name string) BrokerOption

func WithDeadLeaderSink added in v0.25.0 

func WithDeadLeaderSink(ref *duckv1.KReference, uri string) BrokerOption

func WithFilterAvailable added in v0.17.0 

func WithFilterAvailable() BrokerOption

func WithFilterFailed added in v0.17.0 

func WithFilterFailed(reason, msg string) BrokerOption

WithFilterFailed calls .Status.MarkFilterFailed on the Broker.

func WithIngressAvailable added in v0.17.0 

func WithIngressAvailable() BrokerOption

func WithIngressFailed added in v0.17.0 

func WithIngressFailed(reason, msg string) BrokerOption

WithIngressFailed calls .Status.MarkIngressFailed on the Broker.

func WithTriggerChannelFailed added in v0.17.0 

func WithTriggerChannelFailed(reason, msg string) BrokerOption

WithTriggerChannelFailed calls .Status.MarkTriggerChannelFailed on the Broker.

func WithTriggerChannelReady added in v0.17.0 

func WithTriggerChannelReady() BrokerOption

WithTriggerChannelReady calls .Status.PropagateTriggerChannelReadiness on the Broker.

type ChannelOption added in v0.18.0 

type ChannelOption func(*eventingv1.Channel)

ChannelOption enables further configuration of a Channel.

func WithBackingChannelFailed added in v0.18.0 

func WithBackingChannelFailed(reason, msg string) ChannelOption

func WithBackingChannelObjRef added in v0.18.0 

func WithBackingChannelObjRef(objRef *duckv1.KReference) ChannelOption

func WithBackingChannelUnknown added in v0.18.0 

func WithBackingChannelUnknown(reason, msg string) ChannelOption

func WithChannelAddress added in v0.18.0 

func WithChannelAddress(hostname string) ChannelOption

func WithChannelDelivery added in v0.20.0 

func WithChannelDelivery(d *eventingduckv1.DeliverySpec) ChannelOption

func WithChannelGeneration added in v0.18.0 

func WithChannelGeneration(gen int64) ChannelOption

func WithChannelNoAddress added in v0.18.0 

func WithChannelNoAddress() ChannelOption

func WithChannelObservedGeneration added in v0.18.0 

func WithChannelObservedGeneration(gen int64) ChannelOption

func WithChannelReadySubscriber added in v0.18.0 

func WithChannelReadySubscriber(uid string) ChannelOption

func WithChannelReadySubscriberAndGeneration added in v0.18.0 

func WithChannelReadySubscriberAndGeneration(uid string, observedGeneration int64) ChannelOption

func WithChannelSubscriberStatuses added in v0.18.0 

func WithChannelSubscriberStatuses(subscriberStatuses []eventingduckv1.SubscriberStatus) ChannelOption

func WithChannelTemplate added in v0.18.0 

func WithChannelTemplate(typeMeta metav1.TypeMeta) ChannelOption

type ConfigMapOption added in v0.17.0 

type ConfigMapOption func(*v1.ConfigMap)

ConfigMapOption enables further configuration of a ConfigMap.

func WithConfigMapData added in v0.17.0 

func WithConfigMapData(data map[string]string) ConfigMapOption

func WithConfigMapLabels added in v0.17.0 

func WithConfigMapLabels(labels metav1.LabelSelector) ConfigMapOption

type ContainerSourceOption added in v0.19.0 

type ContainerSourceOption func(*v1.ContainerSource)

ContainerSourceOption enables further configuration of a ContainerSource.

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 *v1.SinkBindingStatus) ContainerSourceOption

func WithContainerSourceSpec added in v0.19.0 

func WithContainerSourceSpec(spec v1.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 added in v0.17.0 

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

Ctor functions create a k8s controller with given params.

type DeploymentOption added in v0.23.0 

type DeploymentOption func(*appsv1.Deployment)

DeploymentOption enables further configuration of a Deployment.

func WithDeploymentAnnotations added in v0.23.0 

func WithDeploymentAnnotations(annotations map[string]string) DeploymentOption

func WithDeploymentAvailable added in v0.23.0 

func WithDeploymentAvailable() DeploymentOption

WithDeploymentAvailable marks the Deployment as available.

func WithDeploymentContainer added in v0.23.0 

func WithDeploymentContainer(name, image string, liveness *corev1.Probe, readiness *corev1.Probe, envVars []corev1.EnvVar, containerPorts []corev1.ContainerPort) DeploymentOption

func WithDeploymentLabels added in v0.23.0 

func WithDeploymentLabels(labels map[string]string) DeploymentOption

func WithDeploymentOwnerReferences added in v0.23.0 

func WithDeploymentOwnerReferences(ownerReferences []metav1.OwnerReference) DeploymentOption

func WithDeploymentServiceAccount added in v0.23.0 

func WithDeploymentServiceAccount(serviceAccountName string) DeploymentOption

type EndpointsOption added in v0.17.0 

type EndpointsOption func(*corev1.Endpoints)

EndpointsOption enables further configuration of a Endpoints.

func WithEndpointsAddresses added in v0.17.0 

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

func WithEndpointsAnnotations added in v0.17.0 

func WithEndpointsAnnotations(annotations map[string]string) EndpointsOption

func WithEndpointsLabels added in v0.17.0 

func WithEndpointsLabels(labels map[string]string) EndpointsOption

func WithEndpointsNotReadyAddresses added in v0.17.0 

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

type EventTypeOption added in v0.23.0 

type EventTypeOption func(*v1beta1.EventType)

EventTypeOption enables further configuration of an EventType.

func WithEventTypeBroker added in v0.23.0 

func WithEventTypeBroker(broker string) EventTypeOption

func WithEventTypeBrokerFailed added in v0.23.0 

func WithEventTypeBrokerFailed(reason, message string) EventTypeOption

func WithEventTypeBrokerUnknown added in v0.23.0 

func WithEventTypeBrokerUnknown(reason, message string) EventTypeOption

func WithEventTypeDescription added in v0.23.0 

func WithEventTypeDescription(description string) EventTypeOption

func WithEventTypeLabels added in v0.23.0 

func WithEventTypeLabels(labels map[string]string) EventTypeOption

func WithEventTypeOwnerReference added in v0.23.0 

func WithEventTypeOwnerReference(ownerRef metav1.OwnerReference) EventTypeOption

func WithEventTypeSource added in v0.23.0 

func WithEventTypeSource(source *apis.URL) EventTypeOption

func WithEventTypeType added in v0.23.0 

func WithEventTypeType(t string) EventTypeOption

type FlowsParallelOption 

type FlowsParallelOption func(*flowsv1.Parallel)

ParallelOption enables further configuration of a Parallel.

func WithFlowsParallelAddressableNotReady 

func WithFlowsParallelAddressableNotReady(reason, message string) FlowsParallelOption

func WithFlowsParallelBranchStatuses 

func WithFlowsParallelBranchStatuses(branchStatuses []flowsv1.ParallelBranchStatus) FlowsParallelOption

func WithFlowsParallelBranches 

func WithFlowsParallelBranches(branches []flowsv1.ParallelBranch) FlowsParallelOption

func WithFlowsParallelChannelTemplateSpec 

func WithFlowsParallelChannelTemplateSpec(cts *messagingv1.ChannelTemplateSpec) FlowsParallelOption

func WithFlowsParallelChannelsNotReady 

func WithFlowsParallelChannelsNotReady(reason, message string) FlowsParallelOption

func WithFlowsParallelGeneration 

func WithFlowsParallelGeneration(gen int64) FlowsParallelOption

func WithFlowsParallelIngressChannelStatus 

func WithFlowsParallelIngressChannelStatus(status flowsv1.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 added in v0.17.0 

type InMemoryChannelOption func(*v1.InMemoryChannel)

InMemoryChannelOption enables further configuration of a v1.InMemoryChannel.

func WithInMemoryChannelAddress added in v0.17.0 

func WithInMemoryChannelAddress(a string) InMemoryChannelOption

func WithInMemoryChannelChannelServiceNotReady added in v0.17.0 

func WithInMemoryChannelChannelServiceNotReady(reason, message string) InMemoryChannelOption

func WithInMemoryChannelChannelServiceReady added in v0.17.0 

func WithInMemoryChannelChannelServiceReady() InMemoryChannelOption

func WithInMemoryChannelDelivery added in v0.20.0 

func WithInMemoryChannelDelivery(d *duckv1.DeliverySpec) InMemoryChannelOption

func WithInMemoryChannelDeploymentFailed added in v0.17.0 

func WithInMemoryChannelDeploymentFailed(reason, message string) InMemoryChannelOption

func WithInMemoryChannelDeploymentReady added in v0.17.0 

func WithInMemoryChannelDeploymentReady() InMemoryChannelOption

func WithInMemoryChannelDeploymentUnknown added in v0.17.0 

func WithInMemoryChannelDeploymentUnknown(reason, message string) InMemoryChannelOption

func WithInMemoryChannelEndpointsNotReady added in v0.17.0 

func WithInMemoryChannelEndpointsNotReady(reason, message string) InMemoryChannelOption

func WithInMemoryChannelEndpointsReady added in v0.17.0 

func WithInMemoryChannelEndpointsReady() InMemoryChannelOption

func WithInMemoryChannelFinalizers added in v0.19.0 

func WithInMemoryChannelFinalizers(finalizers ...string) InMemoryChannelOption

func WithInMemoryChannelGeneration added in v0.17.0 

func WithInMemoryChannelGeneration(gen int64) InMemoryChannelOption

func WithInMemoryChannelReady added in v0.17.0 

func WithInMemoryChannelReady(host string) InMemoryChannelOption

func WithInMemoryChannelReadySubscriber added in v0.17.0 

func WithInMemoryChannelReadySubscriber(uid string) InMemoryChannelOption

func WithInMemoryChannelReadySubscriberAndGeneration added in v0.17.0 

func WithInMemoryChannelReadySubscriberAndGeneration(uid string, observedGeneration int64) InMemoryChannelOption

func WithInMemoryChannelServiceReady added in v0.17.0 

func WithInMemoryChannelServiceReady() InMemoryChannelOption

func WithInMemoryChannelServicetNotReady added in v0.17.0 

func WithInMemoryChannelServicetNotReady(reason, message string) InMemoryChannelOption

func WithInMemoryChannelStatusObservedGeneration added in v0.17.0 

func WithInMemoryChannelStatusObservedGeneration(gen int64) InMemoryChannelOption

func WithInMemoryChannelStatusSubscribers added in v0.17.0 

func WithInMemoryChannelStatusSubscribers(subscriberStatuses []duckv1.SubscriberStatus) InMemoryChannelOption

func WithInMemoryChannelSubscribers added in v0.17.0 

func WithInMemoryChannelSubscribers(subscribers []duckv1.SubscriberSpec) InMemoryChannelOption

func WithInMemoryScopeAnnotation added in v0.17.0 

func WithInMemoryScopeAnnotation(value string) InMemoryChannelOption

type Listers added in v0.17.0 

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

func NewListers added in v0.17.0 

func NewListers(objs []runtime.Object) Listers

func (*Listers) GetAllObjects added in v0.17.0 

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

func (*Listers) GetApiServerSourceLister added in v0.17.0 

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

func (*Listers) GetBrokerLister added in v0.17.0 

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

func (*Listers) GetConfigMapLister added in v0.17.0 

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

func (*Listers) GetContainerSourceLister added in v0.17.0 

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

func (*Listers) GetCustomResourceDefinitionLister added in v0.22.0 

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

func (*Listers) GetDeploymentLister added in v0.17.0 

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

func (*Listers) GetEndpointsLister added in v0.17.0 

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

func (*Listers) GetEventTypeLister added in v0.23.0 

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

func (*Listers) GetEventingObjects added in v0.17.0 

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

func (*Listers) GetInMemoryChannelLister added in v0.17.0 

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

func (*Listers) GetK8sServiceLister added in v0.17.0 

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

func (*Listers) GetKubeObjects added in v0.17.0 

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

func (*Listers) GetMessagingChannelLister added in v0.17.0 

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

func (*Listers) GetNamespaceLister added in v0.17.0 

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

func (*Listers) GetNodeLister added in v0.23.0 

func (l *Listers) GetNodeLister() corev1listers.NodeLister

func (*Listers) GetParallelLister added in v0.17.0 

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

func (*Listers) GetPingSourceLister added in v0.24.0 

func (l *Listers) GetPingSourceLister() sourcelisters.PingSourceLister

func (*Listers) GetPodLister added in v0.23.0 

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

func (*Listers) GetRoleBindingLister added in v0.17.0 

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

func (*Listers) GetSecretLister added in v0.18.0 

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

func (*Listers) GetSequenceLister added in v0.17.0 

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

func (*Listers) GetServiceAccountLister added in v0.17.0 

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

func (*Listers) GetServiceLister added in v0.17.0 

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

func (*Listers) GetSinkBindingLister added in v0.17.0 

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

func (*Listers) GetSubscriberObjects added in v0.17.0 

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

func (*Listers) GetSubscriptionLister added in v0.17.0 

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

func (*Listers) GetTriggerLister added in v0.17.0 

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

type NamespaceOption added in v0.22.0 

type NamespaceOption func(*corev1.Namespace)

NamespaceOption enables further configuration of a Namespace.

func WithNamespaceLabeled added in v0.22.0 

func WithNamespaceLabeled(labels map[string]string) NamespaceOption

type PingSourceOption added in v0.23.0 

type PingSourceOption func(*v1.PingSource)

PingSourceOption enables further configuration of a CronJob.

func WithPingSource added in v0.23.0 

func WithPingSource(uid string) PingSourceOption

func WithPingSourceFinalizers added in v0.23.0 

func WithPingSourceFinalizers(finalizers ...string) PingSourceOption

func WithPingSourceObjectMetaGeneration added in v0.23.0 

func WithPingSourceObjectMetaGeneration(generation int64) PingSourceOption

func WithPingSourceSink added in v0.23.0 

func WithPingSourceSink(uri *apis.URL) PingSourceOption

func WithPingSourceSpec added in v0.23.0 

func WithPingSourceSpec(spec v1.PingSourceSpec) PingSourceOption

func WithPingSourceStatusObservedGeneration added in v0.23.0 

func WithPingSourceStatusObservedGeneration(generation int64) PingSourceOption

type SequenceOption 

type SequenceOption func(*flowsv1.Sequence)

SequenceOption enables further configuration of a Sequence.

func WithSequenceAddressableNotReady 

func WithSequenceAddressableNotReady(reason, message string) SequenceOption

func WithSequenceChannelStatuses 

func WithSequenceChannelStatuses(channelStatuses []flowsv1.SequenceChannelStatus) SequenceOption

func WithSequenceChannelTemplateSpec 

func WithSequenceChannelTemplateSpec(cts *messagingv1.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 []flowsv1.SequenceStep) SequenceOption

func WithSequenceSubscriptionStatuses 

func WithSequenceSubscriptionStatuses(subscriptionStatuses []flowsv1.SequenceSubscriptionStatus) SequenceOption

func WithSequenceSubscriptionsNotReady 

func WithSequenceSubscriptionsNotReady(reason, message string) SequenceOption

type ServiceOption added in v0.18.0 

type ServiceOption func(*corev1.Service)

ServiceOption enables further configuration of a Service.

func WithServiceAnnotations added in v0.18.0 

func WithServiceAnnotations(annotations map[string]string) ServiceOption

func WithServiceLabels added in v0.18.0 

func WithServiceLabels(labels map[string]string) ServiceOption

func WithServiceOwnerReferences added in v0.18.0 

func WithServiceOwnerReferences(ownerReferences []metav1.OwnerReference) ServiceOption

func WithServicePorts added in v0.18.0 

func WithServicePorts(ports []corev1.ServicePort) ServiceOption

type SinkBindingOption added in v0.19.0 

type SinkBindingOption func(*sourcesv1.SinkBinding)

SinkBindingOption enables further configuration of a v1 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 added in v0.18.0 

type SubscriptionOption func(*v1.Subscription)

SubscriptionOption enables further configuration of a Subscription.

func MarkNotAddedToChannel added in v0.18.0 

func MarkNotAddedToChannel(reason, msg string) SubscriptionOption

func WithSubscriptionChannel added in v0.18.0 

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

func WithSubscriptionChannelUsingApiVersionAndGroup added in v0.24.0 

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

func WithSubscriptionChannelUsingGroup added in v0.24.0 

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

func WithSubscriptionDeadLetterSinkURI added in v0.18.0 

func WithSubscriptionDeadLetterSinkURI(uri *apis.URL) SubscriptionOption

func WithSubscriptionDeliveryRef added in v0.18.0 

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

func WithSubscriptionFinalizers added in v0.18.0 

func WithSubscriptionFinalizers(finalizers ...string) SubscriptionOption

func WithSubscriptionGenerateName added in v0.18.0 

func WithSubscriptionGenerateName(generateName string) SubscriptionOption

func WithSubscriptionGeneration added in v0.18.0 

func WithSubscriptionGeneration(gen int64) SubscriptionOption

func WithSubscriptionLabels added in v0.18.0 

func WithSubscriptionLabels(labels map[string]string) SubscriptionOption

func WithSubscriptionOwnerReferences added in v0.18.0 

func WithSubscriptionOwnerReferences(ownerReferences []metav1.OwnerReference) SubscriptionOption

func WithSubscriptionPhysicalSubscriptionReply added in v0.18.0 

func WithSubscriptionPhysicalSubscriptionReply(uri *apis.URL) SubscriptionOption

func WithSubscriptionPhysicalSubscriptionSubscriber added in v0.18.0 

func WithSubscriptionPhysicalSubscriptionSubscriber(uri *apis.URL) SubscriptionOption

func WithSubscriptionReferencesNotResolved added in v0.18.0 

func WithSubscriptionReferencesNotResolved(reason, msg string) SubscriptionOption

func WithSubscriptionReferencesResolvedUnknown added in v0.18.0 

func WithSubscriptionReferencesResolvedUnknown(reason, msg string) SubscriptionOption

func WithSubscriptionReply added in v0.18.0 

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

func WithSubscriptionStatusObservedGeneration added in v0.18.0 

func WithSubscriptionStatusObservedGeneration(gen int64) SubscriptionOption

func WithSubscriptionSubscriberRef added in v0.18.0 

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

func WithSubscriptionSubscriberRefUsingApiVersionAndGroup added in v0.24.0 

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

func WithSubscriptionSubscriberRefUsingGroup added in v0.24.0 

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

func WithSubscriptionUID added in v0.18.0 

func WithSubscriptionUID(uid types.UID) SubscriptionOption

type TriggerOption added in v0.17.0 

type TriggerOption func(*v1.Trigger)

TriggerOption enables further configuration of a Trigger.

func WithAnnotation added in v0.17.0 

func WithAnnotation(key, value string) TriggerOption

func WithDependencyAnnotation added in v0.17.0 

func WithDependencyAnnotation(dependencyAnnotation string) TriggerOption

func WithTriggerBrokerFailed added in v0.17.0 

func WithTriggerBrokerFailed(reason, message string) TriggerOption

WithTriggerBrokerFailed marks the Broker as failed

func WithTriggerBrokerNotConfigured added in v0.17.0 

func WithTriggerBrokerNotConfigured() TriggerOption

WithTriggerBrokerNotConfigured marks the Broker as not having been reconciled.

func WithTriggerBrokerReady added in v0.17.0 

func WithTriggerBrokerReady() TriggerOption

WithTriggerBrokerReady initializes the Triggers's conditions.

func WithTriggerBrokerUnknown added in v0.17.0 

func WithTriggerBrokerUnknown(reason, message string) TriggerOption

WithTriggerBrokerUnknown marks the Broker as unknown

func WithTriggerDeadLeaderSink added in v0.23.0 

func WithTriggerDeadLeaderSink(ref *duckv1.KReference, uri string) TriggerOption

func WithTriggerDeadLetterSinkNotConfigured added in v0.25.0 

func WithTriggerDeadLetterSinkNotConfigured() TriggerOption

func WithTriggerDeadLetterSinkResolvedFailed added in v0.25.0 

func WithTriggerDeadLetterSinkResolvedFailed(reason, message string) TriggerOption

func WithTriggerDeadLetterSinkResolvedSucceeded added in v0.25.0 

func WithTriggerDeadLetterSinkResolvedSucceeded() TriggerOption

func WithTriggerDependencyFailed added in v0.17.0 

func WithTriggerDependencyFailed(reason, message string) TriggerOption

func WithTriggerDependencyReady added in v0.17.0 

func WithTriggerDependencyReady() TriggerOption

func WithTriggerDependencyUnknown added in v0.17.0 

func WithTriggerDependencyUnknown(reason, message string) TriggerOption

func WithTriggerGeneration added in v0.17.0 

func WithTriggerGeneration(gen int64) TriggerOption

func WithTriggerNotSubscribed added in v0.17.0 

func WithTriggerNotSubscribed(reason, message string) TriggerOption

func WithTriggerRetry added in v0.23.0 

func WithTriggerRetry(count int32, backoffPolicy *eventingv1.BackoffPolicyType, backoffDelay *string) TriggerOption

func WithTriggerStatusDeadLetterSinkURI added in v0.25.0 

func WithTriggerStatusDeadLetterSinkURI(uri string) TriggerOption

func WithTriggerStatusObservedGeneration added in v0.17.0 

func WithTriggerStatusObservedGeneration(gen int64) TriggerOption

func WithTriggerStatusSubscriberURI added in v0.17.0 

func WithTriggerStatusSubscriberURI(uri string) TriggerOption

func WithTriggerSubscribed added in v0.17.0 

func WithTriggerSubscribed() TriggerOption

func WithTriggerSubscribedUnknown added in v0.17.0 

func WithTriggerSubscribedUnknown(reason, message string) TriggerOption

func WithTriggerSubscriberRef added in v0.17.0 

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

func WithTriggerSubscriberRefAndURIReference added in v0.17.0 

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

func WithTriggerSubscriberResolvedFailed added in v0.17.0 

func WithTriggerSubscriberResolvedFailed(reason, message string) TriggerOption

func WithTriggerSubscriberResolvedSucceeded added in v0.17.0 

func WithTriggerSubscriberResolvedSucceeded() TriggerOption

func WithTriggerSubscriberResolvedUnknown added in v0.17.0 

func WithTriggerSubscriberResolvedUnknown(reason, message string) TriggerOption

func WithTriggerSubscriberURI added in v0.17.0 

func WithTriggerSubscriberURI(rawurl string) TriggerOption

func WithTriggerSubscriptionNotConfigured added in v0.17.0 

func WithTriggerSubscriptionNotConfigured() TriggerOption

func WithTriggerUID added in v0.17.0 

func WithTriggerUID(uid string) TriggerOption

type UnstructuredOption added in v0.17.0 

type UnstructuredOption func(*unstructured.Unstructured)

UnstructuredOption enables further configuration of a Unstructured.

func WithUnstructuredAddressable added in v0.17.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.