testing

package
v0.13.3-mod Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2020 License: Apache-2.0 Imports: 62 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 *v1alpha1.Subscription)

func MarkReferencesResolved 

func MarkReferencesResolved(s *v1alpha1.Subscription)

func MarkSubscriptionReady 

func MarkSubscriptionReady(s *v1alpha1.Subscription)

func NewApiServerSource 

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

NewApiServerSource creates a ApiServer with ApiServerOptions

func NewBroker 

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

NewBroker creates a Broker with BrokerOptions.

func NewChannel 

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

NewChannel creates a Channel with ChannelOptions

func NewConfigMap 

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

NewConfigMap creates a new ConfigMap.

func NewConfigMapPropagation 

func NewConfigMapPropagation(name, namespace string, o ...ConfigMapPropagationOption) *v1alpha1.ConfigMapPropagation

NewConfigMapPropagation creates a ConfigMapPropagation.

func NewContainerSource 

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

NewContainerSource creates a ContainerSource with ContainerSourceOptions

func NewCronJobSource 

func NewCronJobSource(name, namespace string, o ...CronJobSourceOption) *v1alpha1.CronJobSource

NewCronJobSource creates a CronJobSource with CronJobOptions.

func NewCustomResourceDefinition 

func NewCustomResourceDefinition(name string, o ...CustomResourceDefinitionOption) *apiextensionsv1beta1.CustomResourceDefinition

NewCustomResourceDefinition creates a CustomResourceDefinition with CustomResourceDefinitionOption.

func NewDeployment 

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

NewDeployment creates a Deployment with DeploymentOptions.

func NewEventType 

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

NewEventType creates a EventType with EventTypeOptions.

func NewFlowsParallel 

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

NewFlowsParallel creates an Parallel with ParallelOptions.

func NewFlowsSequence 

func NewFlowsSequence(name, namespace string, popt ...FlowsSequenceOption) *v1alpha1.Sequence

NewSequence creates an Sequence with SequenceOptions.

func NewInMemoryChannel 

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

NewInMemoryChannel creates an InMemoryChannel with InMemoryChannelOptions.

func NewLegacyApiServerSource 

func NewLegacyApiServerSource(name, namespace string, o ...LegacyApiServerSourceOption) *v1alpha1.ApiServerSource

NewLegacyApiServerSource creates a ApiServer with ApiServerOptions

func NewLegacySinkBinding 

func NewLegacySinkBinding(name, namespace string, o ...LegacySinkBindingOption) *legacysourcesv1alpha1.SinkBinding

NewLegacySinkBinding creates a SinkBinding with SinkBindingOptions

func NewNamespace 

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

NewNamespace creates a Namespace with NamespaceOptions

func NewPingSourceV1Alpha1 

func NewPingSourceV1Alpha1(name, namespace string, o ...PingSourceOption) *v1alpha1.PingSource

NewPingSourceV1Alpha1 creates a PingSource with PingSourceOption.

func NewPingSourceV1Alpha2 

func NewPingSourceV1Alpha2(name, namespace string, o ...PingSourceV1A2Option) *v1alpha2.PingSource

NewPingSourceV1Alpha2 creates a PingSource with PingSourceOption.

func NewScheme 

func NewScheme() *runtime.Scheme

func NewService 

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

NewService creates a Service with ServiceOptions

func NewSinkBindingV1Alpha1 

func NewSinkBindingV1Alpha1(name, namespace string, o ...SinkBindingV1Alpha1Option) *sourcesv1alpha1.SinkBinding

NewSinkBindingV1Alpha1 creates a SinkBinding with SinkBindingOptions

func NewSinkBindingV1Alpha2 

func NewSinkBindingV1Alpha2(name, namespace string, o ...SinkBindingV1Alpha2Option) *sourcesv1alpha2.SinkBinding

NewSinkBindingV1Alpha2 creates a SinkBinding with SinkBindingOptions

func NewSubscription 

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

NewSubscription creates a Subscription with SubscriptionOptions

func NewSubscriptionWithoutNamespace 

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

NewSubscriptionWithoutNamespace creates a Subscription with SubscriptionOptions but without a specific namespace

func NewTrigger 

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

NewTrigger creates a Trigger with TriggerOptions.

func NewUnstructured 

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 WithApiServerSourceDeleted 

func WithApiServerSourceDeleted(c *v1alpha1.ApiServerSource)

func WithApiServerSourceDeployed 

func WithApiServerSourceDeployed(s *v1alpha1.ApiServerSource)

func WithApiServerSourceDeploymentUnavailable 

func WithApiServerSourceDeploymentUnavailable(s *v1alpha1.ApiServerSource)

func WithApiServerSourceEventTypes 

func WithApiServerSourceEventTypes(s *v1alpha1.ApiServerSource)

func WithApiServerSourceNoSufficientPermissions 

func WithApiServerSourceNoSufficientPermissions(s *v1alpha1.ApiServerSource)

func WithApiServerSourceSinkNotFound 

func WithApiServerSourceSinkNotFound(s *v1alpha1.ApiServerSource)

func WithApiServerSourceSufficientPermissions 

func WithApiServerSourceSufficientPermissions(s *v1alpha1.ApiServerSource)

func WithBackingChannelReady 

func WithBackingChannelReady(c *v1alpha1.Channel)

func WithBrokerDeletionTimestamp 

func WithBrokerDeletionTimestamp(b *v1alpha1.Broker)

func WithBrokerReady 

func WithBrokerReady(b *v1alpha1.Broker)

WithBrokerReady sets .Status to ready.

func WithChannelDeleted 

func WithChannelDeleted(c *v1alpha1.Channel)

func WithConfigMapPropagationDeletionTimestamp 

func WithConfigMapPropagationDeletionTimestamp(cmp *v1alpha1.ConfigMapPropagation)

func WithConfigMapPropagationNotPropagated 

func WithConfigMapPropagationNotPropagated(cmp *v1alpha1.ConfigMapPropagation)

WithConfigMapPropagationNotPropagated calls .Status.MarkConfigMapPropagationNotPropagated on the ConfigMapPropagation.

func WithConfigMapPropagationPropagated 

func WithConfigMapPropagationPropagated(cmp *v1alpha1.ConfigMapPropagation)

WithConfigMapPropagationPropagated calls .Status.MarkConfigMapPropagationPropagated on the ConfigMapPropagation.

func WithContainerSourceDeleted 

func WithContainerSourceDeleted(c *legacysourcesv1alpha1.ContainerSource)

func WithContainerSourceDeployed 

func WithContainerSourceDeployed(s *legacysourcesv1alpha1.ContainerSource)

func WithCronJobSourceDeleted 

func WithCronJobSourceDeleted(c *v1alpha1.CronJobSource)

func WithCronJobSourceDeployed 

func WithCronJobSourceDeployed(s *v1alpha1.CronJobSource)

func WithCronJobSourceEventType 

func WithCronJobSourceEventType(s *v1alpha1.CronJobSource)

func WithCronJobSourceSinkNotFound 

func WithCronJobSourceSinkNotFound(s *v1alpha1.CronJobSource)

func WithEventTypeBrokerDoesNotExist 

func WithEventTypeBrokerDoesNotExist(et *v1alpha1.EventType)

WithEventTypeBrokerNotFound calls .Status.MarkFilterFailed on the EventType.

func WithEventTypeBrokerExists 

func WithEventTypeBrokerExists(et *v1alpha1.EventType)

WithEventTypeBrokerExists calls .Status.MarkBrokerExists on the EventType.

func WithEventTypeBrokerReady 

func WithEventTypeBrokerReady(et *v1alpha1.EventType)

WithEventTypeBrokerReady calls .Status.MarkBrokerReady on the EventType.

func WithEventTypeDeletionTimestamp 

func WithEventTypeDeletionTimestamp(et *v1alpha1.EventType)

func WithFlowsParallelDeleted 

func WithFlowsParallelDeleted(p *v1alpha1.Parallel)

func WithFlowsSequenceDeleted 

func WithFlowsSequenceDeleted(p *v1alpha1.Sequence)

func WithInMemoryChannelDeleted 

func WithInMemoryChannelDeleted(imc *v1alpha1.InMemoryChannel)

func WithInitApiServerSourceConditions 

func WithInitApiServerSourceConditions(s *v1alpha1.ApiServerSource)

WithInitApiServerSourceConditions initializes the ApiServerSource's conditions.

func WithInitBrokerConditions 

func WithInitBrokerConditions(b *v1alpha1.Broker)

WithInitBrokerConditions initializes the Broker's conditions.

func WithInitChannelConditions 

func WithInitChannelConditions(c *v1alpha1.Channel)

WithInitChannelConditions initializes the Channel's conditions.

func WithInitConfigMapPropagationConditions 

func WithInitConfigMapPropagationConditions(cmp *v1alpha1.ConfigMapPropagation)

WithInitConfigMapPropagationConditions initializes the ConfigMapPropagation's conditions.

func WithInitContainerSourceConditions 

func WithInitContainerSourceConditions(s *legacysourcesv1alpha1.ContainerSource)

WithInitContainerSourceConditions initializes the ContainerSource's conditions.

func WithInitCronJobSourceConditions 

func WithInitCronJobSourceConditions(s *v1alpha1.CronJobSource)

WithInitCronJobSourceConditions initializes the CronJobSource's conditions.

func WithInitEventTypeConditions 

func WithInitEventTypeConditions(et *v1alpha1.EventType)

WithInitEventTypeConditions initializes the EventType's conditions.

func WithInitFlowsParallelConditions 

func WithInitFlowsParallelConditions(p *v1alpha1.Parallel)

func WithInitFlowsSequenceConditions 

func WithInitFlowsSequenceConditions(p *v1alpha1.Sequence)

func WithInitInMemoryChannelConditions 

func WithInitInMemoryChannelConditions(imc *v1alpha1.InMemoryChannel)

func WithInitLegacyApiServerSourceConditions 

func WithInitLegacyApiServerSourceConditions(s *v1alpha1.ApiServerSource)

WithInitApiServerSourceConditions initializes the ApiServerSource's conditions.

func WithInitPingSourceConditions 

func WithInitPingSourceConditions(s *v1alpha1.PingSource)

WithInitPingSourceConditions initializes the PingSource's conditions.

func WithInitSubscriptionConditions 

func WithInitSubscriptionConditions(s *v1alpha1.Subscription)

WithInitSubscriptionConditions initializes the Subscriptions's conditions.

func WithInitTriggerConditions 

func WithInitTriggerConditions(t *v1alpha1.Trigger)

WithInitTriggerConditions initializes the Triggers's conditions.

func WithInvalidCronJobSourceSchedule 

func WithInvalidCronJobSourceSchedule(s *v1alpha1.CronJobSource)

func WithInvalidPingSourceSchedule 

func WithInvalidPingSourceSchedule(s *v1alpha1.PingSource)

func WithLegacyApiServerSourceDeleted 

func WithLegacyApiServerSourceDeleted(c *v1alpha1.ApiServerSource)

func WithLegacyApiServerSourceDeployed 

func WithLegacyApiServerSourceDeployed(s *v1alpha1.ApiServerSource)

func WithLegacyApiServerSourceDeploymentUnavailable 

func WithLegacyApiServerSourceDeploymentUnavailable(s *v1alpha1.ApiServerSource)

func WithLegacyApiServerSourceEventTypes 

func WithLegacyApiServerSourceEventTypes(s *v1alpha1.ApiServerSource)

func WithLegacyApiServerSourceNoSufficientPermissions 

func WithLegacyApiServerSourceNoSufficientPermissions(s *v1alpha1.ApiServerSource)

func WithLegacyApiServerSourceSinkNotFound 

func WithLegacyApiServerSourceSinkNotFound(s *v1alpha1.ApiServerSource)

func WithLegacyApiServerSourceSufficientPermissions 

func WithLegacyApiServerSourceSufficientPermissions(s *v1alpha1.ApiServerSource)

func WithNamespaceDeleted 

func WithNamespaceDeleted(n *corev1.Namespace)

func WithPingSourceDeleted 

func WithPingSourceDeleted(c *v1alpha1.PingSource)

func WithPingSourceDeployed 

func WithPingSourceDeployed(s *v1alpha1.PingSource)

func WithPingSourceEventType 

func WithPingSourceEventType(s *v1alpha1.PingSource)

func WithPingSourceSinkNotFound 

func WithPingSourceSinkNotFound(s *v1alpha1.PingSource)

func WithSubscriptionDeleted 

func WithSubscriptionDeleted(s *v1alpha1.Subscription)

TODO: this can be a runtime object

func WithSubscriptionReady 

func WithSubscriptionReady(s *v1alpha1.Subscription)

func WithTriggerDeleted 

func WithTriggerDeleted(t *v1alpha1.Trigger)

TODO: this can be a runtime object

func WithValidCronJobSourceResources 

func WithValidCronJobSourceResources(s *v1alpha1.CronJobSource)

func WithValidCronJobSourceSchedule 

func WithValidCronJobSourceSchedule(s *v1alpha1.CronJobSource)

func WithValidPingSourceResources 

func WithValidPingSourceResources(s *v1alpha1.PingSource)

func WithValidPingSourceSchedule 

func WithValidPingSourceSchedule(s *v1alpha1.PingSource)

Types

type ApiServerSourceOption 

type ApiServerSourceOption func(*v1alpha1.ApiServerSource)

ApiServerSourceOption enables further configuration of a ApiServer.

func WithApiServerSourceObjectMetaGeneration 

func WithApiServerSourceObjectMetaGeneration(generation int64) ApiServerSourceOption

func WithApiServerSourceSink 

func WithApiServerSourceSink(uri string) ApiServerSourceOption

func WithApiServerSourceSinkDepRef 

func WithApiServerSourceSinkDepRef(uri string) ApiServerSourceOption

func WithApiServerSourceSpec 

func WithApiServerSourceSpec(spec v1alpha1.ApiServerSourceSpec) ApiServerSourceOption

func WithApiServerSourceStatusObservedGeneration 

func WithApiServerSourceStatusObservedGeneration(generation int64) ApiServerSourceOption

func WithApiServerSourceUID 

func WithApiServerSourceUID(uid string) ApiServerSourceOption

type BrokerOption 

type BrokerOption func(*v1alpha1.Broker)

BrokerOption enables further configuration of a Broker.

func WithBrokerAddress 

func WithBrokerAddress(address string) BrokerOption

WithBrokerAddress sets the Broker's address.

func WithBrokerChannel 

func WithBrokerChannel(crdType metav1.TypeMeta) BrokerOption

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

func WithBrokerFinalizers 

func WithBrokerFinalizers(finalizers ...string) BrokerOption

func WithBrokerGeneration 

func WithBrokerGeneration(gen int64) BrokerOption

func WithBrokerResourceVersion 

func WithBrokerResourceVersion(rv string) BrokerOption

func WithBrokerStatusObservedGeneration 

func WithBrokerStatusObservedGeneration(gen int64) BrokerOption

func WithBrokerTriggerChannel 

func WithBrokerTriggerChannel(c *corev1.ObjectReference) BrokerOption

func WithFilterDeploymentAvailable 

func WithFilterDeploymentAvailable() BrokerOption

func WithFilterFailed 

func WithFilterFailed(reason, msg string) BrokerOption

WithFilterFailed calls .Status.MarkFilterFailed on the Broker.

func WithIngressDeploymentAvailable 

func WithIngressDeploymentAvailable() BrokerOption

func WithIngressFailed 

func WithIngressFailed(reason, msg string) BrokerOption

WithIngressFailed calls .Status.MarkIngressFailed on the Broker.

func WithTriggerChannelFailed 

func WithTriggerChannelFailed(reason, msg string) BrokerOption

WithTriggerChannelFailed calls .Status.MarkTriggerChannelFailed on the Broker.

func WithTriggerChannelReady 

func WithTriggerChannelReady() BrokerOption

WithTriggerChannelReady calls .Status.PropagateTriggerChannelReadiness on the Broker.

type Buildable 

type Buildable interface {
	Build() runtime.Object
}

Buildable allows test fixtures to use the builder pattern. The table test runner will call Build() on any Buildable objects and use the result as the test fixture.

type ChannelOption 

type ChannelOption func(*v1alpha1.Channel)

ChannelOption enables further configuration of a Channel.

func WithBackingChannelFailed 

func WithBackingChannelFailed(reason, msg string) ChannelOption

func WithBackingChannelObjRef 

func WithBackingChannelObjRef(objRef *v1.ObjectReference) 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 []eventingduckv1alpha1.SubscriberStatus) ChannelOption

func WithChannelTemplate 

func WithChannelTemplate(typeMeta metav1.TypeMeta) ChannelOption

type ConfigMapOption 

type ConfigMapOption func(*v1.ConfigMap)

ConfigMapOption enables further configuration of a ConfigMap.

func WithConfigMapData 

func WithConfigMapData(data map[string]string) ConfigMapOption

func WithConfigMapLabels 

func WithConfigMapLabels(labels metav1.LabelSelector) ConfigMapOption

func WithConfigMapOwnerReference 

func WithConfigMapOwnerReference(ConfigMapPropagation *v1alpha1.ConfigMapPropagation) ConfigMapOption

type ConfigMapPropagationOption 

type ConfigMapPropagationOption func(*v1alpha1.ConfigMapPropagation)

ConfigMapPropagationOption enables further configuration of a ConfigMapPropagation.

func WithConfigMapPropagationGeneration 

func WithConfigMapPropagationGeneration(gen int64) ConfigMapPropagationOption

func WithConfigMapPropagationSelector 

func WithConfigMapPropagationSelector(selector metav1.LabelSelector) ConfigMapPropagationOption

func WithConfigMapPropagationStatusObservedGeneration 

func WithConfigMapPropagationStatusObservedGeneration(gen int64) ConfigMapPropagationOption

func WithConfigMapPropagationUID 

func WithConfigMapPropagationUID(uid string) ConfigMapPropagationOption

func WithCopyConfigMapStatus 

func WithCopyConfigMapStatus(name, source, operation, ready, reason string) ConfigMapPropagationOption

func WithInitConfigMapStatus 

func WithInitConfigMapStatus() ConfigMapPropagationOption

type ContainerSourceOption 

type ContainerSourceOption func(*legacysourcesv1alpha1.ContainerSource)

ContainerSourceOption enables further configuration of a ContainerSource.

func WithContainerSourceAnnotations 

func WithContainerSourceAnnotations(annotations map[string]string) ContainerSourceOption

func WithContainerSourceDeployFailed 

func WithContainerSourceDeployFailed(msg string) ContainerSourceOption

func WithContainerSourceDeploying 

func WithContainerSourceDeploying(msg string) ContainerSourceOption

func WithContainerSourceLabels 

func WithContainerSourceLabels(labels map[string]string) ContainerSourceOption

func WithContainerSourceObjectMetaGeneration 

func WithContainerSourceObjectMetaGeneration(generation int64) ContainerSourceOption

func WithContainerSourceSink 

func WithContainerSourceSink(uri string) ContainerSourceOption

func WithContainerSourceSinkMissing 

func WithContainerSourceSinkMissing(msg string) ContainerSourceOption

func WithContainerSourceSinkNotFound 

func WithContainerSourceSinkNotFound(msg string) ContainerSourceOption

func WithContainerSourceSpec 

func WithContainerSourceSpec(spec legacysourcesv1alpha1.ContainerSourceSpec) ContainerSourceOption

func WithContainerSourceStatusObservedGeneration 

func WithContainerSourceStatusObservedGeneration(generation int64) ContainerSourceOption

func WithContainerSourceUID 

func WithContainerSourceUID(uid types.UID) ContainerSourceOption

type CronJobSourceOption 

type CronJobSourceOption func(*v1alpha1.CronJobSource)

CronJobSourceOption enables further configuration of a CronJob.

func WithCronJobApiVersion 

func WithCronJobApiVersion(apiVersion string) CronJobSourceOption

func WithCronJobSourceObjectMetaGeneration 

func WithCronJobSourceObjectMetaGeneration(generation int64) CronJobSourceOption

func WithCronJobSourceSink 

func WithCronJobSourceSink(uri string) CronJobSourceOption

func WithCronJobSourceSpec 

func WithCronJobSourceSpec(spec v1alpha1.CronJobSourceSpec) CronJobSourceOption

func WithCronJobSourceStatusObservedGeneration 

func WithCronJobSourceStatusObservedGeneration(generation int64) CronJobSourceOption

func WithCronJobSourceUID 

func WithCronJobSourceUID(uid string) CronJobSourceOption

type Ctor 

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

Ctor functions create a k8s controller with given params.

type CustomResourceDefinitionOption 

type CustomResourceDefinitionOption func(*apiextensionsv1beta1.CustomResourceDefinition)

CustomResourceDefinitionOption enables further configuration of a CustomResourceDefinition.

func WithCustomResourceDefinitionLabels 

func WithCustomResourceDefinitionLabels(labels map[string]string) CustomResourceDefinitionOption

WithCustomResourceDefinitionLabels sets the CRD's labels.

type DeploymentOption 

type DeploymentOption func(*appsv1.Deployment)

DeploymentOption enables further configuration of a Deployment.

func WithDeploymentAnnotations 

func WithDeploymentAnnotations(annotations map[string]string) DeploymentOption

func WithDeploymentAvailable 

func WithDeploymentAvailable() DeploymentOption

WithDeploymentAvailable marks the Deployment as available.

func WithDeploymentContainer 

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

func WithDeploymentLabels 

func WithDeploymentLabels(labels map[string]string) DeploymentOption

func WithDeploymentOwnerReferences 

func WithDeploymentOwnerReferences(ownerReferences []metav1.OwnerReference) DeploymentOption

func WithDeploymentServiceAccount 

func WithDeploymentServiceAccount(serviceAccountName string) DeploymentOption

type DynamicMocks 

type DynamicMocks struct {
	// MockResources corresponds to dynamic.Interface.
	MockResources []MockDynamicResource

	// All other fields correspond to their dynamic.ResourceInterface equivalents.
	MockCreates           []MockDynamicCreate
	MockUpdates           []MockDynamicUpdate
	MockUpdateStatuses    []MockDynamicUpdateStatus
	MockDeletes           []MockDynamicDelete
	MockDeleteCollections []MockDynamicDeleteCollection
	MockGets              []MockDynamicGet
	MockLists             []MockDynamicList
	MockWatches           []MockDynamicWatch
	MockPatches           []MockDynamicPatch
}

The mocks to run on each function type. Each function will run through the mocks in its list until one responds with 'Handled'. If there is more than one mock in the list, then the one that responds 'Handled' will be removed and not run on subsequent calls to the function. If no mocks respond 'Handled', then the real underlying client is called.

type EventTypeOption 

type EventTypeOption func(*v1alpha1.EventType)

EventTypeOption enables further configuration of an EventType.

func WithEventTypeBroker 

func WithEventTypeBroker(broker string) EventTypeOption

func WithEventTypeBrokerFailed 

func WithEventTypeBrokerFailed(reason, message string) EventTypeOption

func WithEventTypeBrokerUnknown 

func WithEventTypeBrokerUnknown(reason, message string) EventTypeOption

func WithEventTypeDescription 

func WithEventTypeDescription(description string) EventTypeOption

func WithEventTypeLabels 

func WithEventTypeLabels(labels map[string]string) EventTypeOption

func WithEventTypeOwnerReference 

func WithEventTypeOwnerReference(ownerRef metav1.OwnerReference) EventTypeOption

func WithEventTypeSource 

func WithEventTypeSource(source string) EventTypeOption

func WithEventTypeType 

func WithEventTypeType(t string) EventTypeOption

type FlowsParallelOption 

type FlowsParallelOption func(*v1alpha1.Parallel)

ParallelOption enables further configuration of a Parallel.

func WithFlowsParallelAddressableNotReady 

func WithFlowsParallelAddressableNotReady(reason, message string) FlowsParallelOption

func WithFlowsParallelBranchStatuses 

func WithFlowsParallelBranchStatuses(branchStatuses []v1alpha1.ParallelBranchStatus) FlowsParallelOption

func WithFlowsParallelBranches 

func WithFlowsParallelBranches(branches []v1alpha1.ParallelBranch) FlowsParallelOption

func WithFlowsParallelChannelTemplateSpec 

func WithFlowsParallelChannelTemplateSpec(cts *messagingvbeta1.ChannelTemplateSpec) FlowsParallelOption

func WithFlowsParallelChannelsNotReady 

func WithFlowsParallelChannelsNotReady(reason, message string) FlowsParallelOption

func WithFlowsParallelGeneration 

func WithFlowsParallelGeneration(gen int64) FlowsParallelOption

func WithFlowsParallelIngressChannelStatus 

func WithFlowsParallelIngressChannelStatus(status v1alpha1.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 FlowsSequenceOption 

type FlowsSequenceOption func(*v1alpha1.Sequence)

SequenceOption enables further configuration of a Sequence.

func WithFlowsSequenceAddressableNotReady 

func WithFlowsSequenceAddressableNotReady(reason, message string) FlowsSequenceOption

func WithFlowsSequenceChannelStatuses 

func WithFlowsSequenceChannelStatuses(channelStatuses []v1alpha1.SequenceChannelStatus) FlowsSequenceOption

func WithFlowsSequenceChannelTemplateSpec 

func WithFlowsSequenceChannelTemplateSpec(cts *messagingv1beta1.ChannelTemplateSpec) FlowsSequenceOption

func WithFlowsSequenceChannelsNotReady 

func WithFlowsSequenceChannelsNotReady(reason, message string) FlowsSequenceOption

func WithFlowsSequenceGeneration 

func WithFlowsSequenceGeneration(gen int64) FlowsSequenceOption

func WithFlowsSequenceReply 

func WithFlowsSequenceReply(reply *duckv1.Destination) FlowsSequenceOption

func WithFlowsSequenceStatusObservedGeneration 

func WithFlowsSequenceStatusObservedGeneration(gen int64) FlowsSequenceOption

func WithFlowsSequenceSteps 

func WithFlowsSequenceSteps(steps []v1alpha1.SequenceStep) FlowsSequenceOption

func WithFlowsSequenceSubscriptionStatuses 

func WithFlowsSequenceSubscriptionStatuses(subscriptionStatuses []v1alpha1.SequenceSubscriptionStatus) FlowsSequenceOption

func WithFlowsSequenceSubscriptionsNotReady 

func WithFlowsSequenceSubscriptionsNotReady(reason, message string) FlowsSequenceOption

type InMemoryChannelOption 

type InMemoryChannelOption func(*v1alpha1.InMemoryChannel)

InMemoryChannelOption enables further configuration of a 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 []duckv1alpha1.SubscriberStatus) InMemoryChannelOption

func WithInMemoryChannelSubscribers 

func WithInMemoryChannelSubscribers(subscribers []duckv1alpha1.SubscriberSpec) InMemoryChannelOption

func WithInMemoryScopeAnnotation 

func WithInMemoryScopeAnnotation(value string) InMemoryChannelOption

type LegacyApiServerSourceOption 

type LegacyApiServerSourceOption func(*v1alpha1.ApiServerSource)

LegacyApiServerSourceOption enables further configuration of a Legacy ApiServerSource.

func WithLegacyApiServerSourceObjectMetaGeneration 

func WithLegacyApiServerSourceObjectMetaGeneration(generation int64) LegacyApiServerSourceOption

func WithLegacyApiServerSourceSink 

func WithLegacyApiServerSourceSink(uri string) LegacyApiServerSourceOption

func WithLegacyApiServerSourceSinkDepRef 

func WithLegacyApiServerSourceSinkDepRef(uri string) LegacyApiServerSourceOption

func WithLegacyApiServerSourceSpec 

func WithLegacyApiServerSourceSpec(spec v1alpha1.ApiServerSourceSpec) LegacyApiServerSourceOption

func WithLegacyApiServerSourceStatusObservedGeneration 

func WithLegacyApiServerSourceStatusObservedGeneration(generation int64) LegacyApiServerSourceOption

func WithLegacyApiServerSourceUID 

func WithLegacyApiServerSourceUID(uid string) LegacyApiServerSourceOption

type LegacySinkBindingOption 

type LegacySinkBindingOption func(*legacysourcesv1alpha1.SinkBinding)

LegacySinkBindingOption enables further configuration of a SinkBinding.

func WithLegacySink 

func WithLegacySink(sink duckv1.Destination) LegacySinkBindingOption

WithLegacySink assigns the sink of the SinkBinding.

func WithLegacySubject 

func WithLegacySubject(subject tracker.Reference) LegacySinkBindingOption

WithLegacySubject assigns the subject of the SinkBinding.

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) GetBrokerLister 

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

func (*Listers) GetConfigMapLister 

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

func (*Listers) GetConfigMapPropagationLister 

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

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() eventinglisters.EventTypeLister

func (*Listers) GetEventingObjects 

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

func (*Listers) GetFlowsParallelLister 

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

func (*Listers) GetFlowsSequenceLister 

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

func (*Listers) GetInMemoryChannelLister 

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

func (*Listers) GetK8sServiceLister 

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

func (*Listers) GetKubeObjects 

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

func (*Listers) GetLegacyApiServerSourceLister 

func (l *Listers) GetLegacyApiServerSourceLister() legacysourcelisters.ApiServerSourceLister

func (*Listers) GetLegacyContainerSourceLister 

func (l *Listers) GetLegacyContainerSourceLister() legacysourcelisters.ContainerSourceLister

func (*Listers) GetLegacyCronJobSourceLister 

func (l *Listers) GetLegacyCronJobSourceLister() legacysourcelisters.CronJobSourceLister

func (*Listers) GetLegacyObjects 

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

func (*Listers) GetMessagingChannelLister 

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

func (*Listers) GetNamespaceLister 

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

func (*Listers) GetPingSourceLister 

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

func (*Listers) GetRoleBindingLister 

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

func (*Listers) GetServiceAccountLister 

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

func (*Listers) GetServiceLister 

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

func (*Listers) GetSubscriberObjects 

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

func (*Listers) GetSubscriptionLister 

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

func (*Listers) GetTriggerLister 

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

type MockDynamicContext 

type MockDynamicContext struct {
	InnerInterface dynamic.ResourceInterface
	Resource       schema.GroupVersionResource
	Namespace      string
}

type MockDynamicCreate 

type MockDynamicCreate func(ctx *MockDynamicContext, obj *unstructured.Unstructured, options metav1.CreateOptions, subresources ...string) (MockHandled, *unstructured.Unstructured, error)

All of the functions in dynamic.Resource get mocked equivalents. For the function dynamic.Resource.Foo(), the mocked equivalent will be: MockDynamicFoo func(ctx *MockDynamicContext[, Foo's arguments]) (MockHandled[, Foo's returns])

type MockDynamicDelete 

type MockDynamicDelete func(ctx *MockDynamicContext, name string, options *metav1.DeleteOptions, subresources ...string) (MockHandled, error)

type MockDynamicDeleteCollection 

type MockDynamicDeleteCollection func(ctx *MockDynamicContext, options *metav1.DeleteOptions, listOptions metav1.ListOptions) (MockHandled, error)

type MockDynamicGet 

type MockDynamicGet func(ctx *MockDynamicContext, name string, options metav1.GetOptions, subresources ...string) (MockHandled, *unstructured.Unstructured, error)

type MockDynamicInterface 

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

func NewMockDynamicInterface 

func NewMockDynamicInterface(innerInterface dynamic.Interface, mocks DynamicMocks) *MockDynamicInterface

func (MockDynamicInterface) Resource 

func (m MockDynamicInterface) Resource(resource schema.GroupVersionResource) dynamic.NamespaceableResourceInterface

type MockDynamicList 

type MockDynamicList func(ctx *MockDynamicContext, opts metav1.ListOptions) (MockHandled, *unstructured.UnstructuredList, error)

type MockDynamicPatch 

type MockDynamicPatch func(ctx *MockDynamicContext, name string, pt types.PatchType, data []byte, options metav1.PatchOptions, subresources ...string) (MockHandled, *unstructured.Unstructured, error)

type MockDynamicResource 

type MockDynamicResource func(innerInterface dynamic.Interface, resource schema.GroupVersionResource) (MockHandled, dynamic.NamespaceableResourceInterface)

All of the functions in dynamic.Interface get mocked equivalents.

type MockDynamicUpdate 

type MockDynamicUpdate func(ctx *MockDynamicContext, obj *unstructured.Unstructured, options metav1.UpdateOptions, subresources ...string) (MockHandled, *unstructured.Unstructured, error)

type MockDynamicUpdateStatus 

type MockDynamicUpdateStatus func(ctx *MockDynamicContext, obj *unstructured.Unstructured, options metav1.UpdateOptions) (MockHandled, *unstructured.Unstructured, error)

type MockDynamicWatch 

type MockDynamicWatch func(ctx *MockDynamicContext, opts metav1.ListOptions) (MockHandled, watch.Interface, error)

type MockEventRecorder 

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

MockEventRecorder is a recorder.EventRecorder that saves emitted v1 Events.

func NewEventRecorder 

func NewEventRecorder() *MockEventRecorder

func (*MockEventRecorder) AnnotatedEventf 

func (m *MockEventRecorder) AnnotatedEventf(object runtime.Object, annotations map[string]string, eventtype, reason, messageFmt string, args ...interface{})

func (*MockEventRecorder) Event 

func (m *MockEventRecorder) Event(object runtime.Object, eventtype, reason, message string)

func (*MockEventRecorder) Eventf 

func (m *MockEventRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, args ...interface{})

func (*MockEventRecorder) PastEventf 

func (m *MockEventRecorder) PastEventf(object runtime.Object, timestamp metav1.Time, eventtype, reason, messageFmt string, args ...interface{})

type MockHandled 

type MockHandled int
const (
	// This mock has handled the function call, no further mocks nor the real client should be
	// called.
	Handled MockHandled = iota
	// This mock has not handled the function call, subsequent mocks or the real client should be
	// called.
	Unhandled
)

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 

type PingSourceOption func(*v1alpha1.PingSource)

PingSourceOption enables further configuration of a CronJob.

func WithPingSourceApiVersion 

func WithPingSourceApiVersion(apiVersion string) PingSourceOption

func WithPingSourceObjectMetaGeneration 

func WithPingSourceObjectMetaGeneration(generation int64) PingSourceOption

func WithPingSourceSink 

func WithPingSourceSink(uri *apis.URL) PingSourceOption

func WithPingSourceSpec 

func WithPingSourceSpec(spec v1alpha1.PingSourceSpec) PingSourceOption

func WithPingSourceStatusObservedGeneration 

func WithPingSourceStatusObservedGeneration(generation int64) PingSourceOption

func WithPingSourceUID 

func WithPingSourceUID(uid string) PingSourceOption

type PingSourceV1A2Option 

type PingSourceV1A2Option func(*v1alpha2.PingSource)

PingSourceV1A2Option enables further configuration of a CronJob.

func WithPingSourceV1A2Spec 

func WithPingSourceV1A2Spec(spec v1alpha2.PingSourceSpec) PingSourceV1A2Option

type ServiceOption 

type ServiceOption func(*corev1.Service)

ServiceOption enables further configuration of a Service.

func WithServiceAnnotations 

func WithServiceAnnotations(annotations map[string]string) ServiceOption

func WithServiceLabels 

func WithServiceLabels(labels map[string]string) ServiceOption

func WithServiceOwnerReferences 

func WithServiceOwnerReferences(ownerReferences []metav1.OwnerReference) ServiceOption

func WithServicePorts 

func WithServicePorts(ports []corev1.ServicePort) ServiceOption

type SinkBindingV1Alpha1Option 

type SinkBindingV1Alpha1Option func(*sourcesv1alpha1.SinkBinding)

SinkBindingV1Alpha1Option enables further configuration of a SinkBinding.

func WithCloudEventOverridesV1A1 

func WithCloudEventOverridesV1A1(overrides duckv1.CloudEventOverrides) SinkBindingV1Alpha1Option

WithCloudEventOverridesV1A1 assigns the CloudEventsOverrides of the SinkBinding.

func WithSinkV1A1 

func WithSinkV1A1(sink duckv1.Destination) SinkBindingV1Alpha1Option

WithSinkV1A1 assigns the sink of the SinkBinding.

func WithSubjectV1A1 

func WithSubjectV1A1(subject tracker.Reference) SinkBindingV1Alpha1Option

WithSubjectV1A1 assigns the subject of the SinkBinding.

type SinkBindingV1Alpha2Option 

type SinkBindingV1Alpha2Option func(*sourcesv1alpha2.SinkBinding)

SinkBindingV1Alpha2Option enables further configuration of a SinkBinding.

func WithCloudEventOverridesV1A2 

func WithCloudEventOverridesV1A2(overrides duckv1.CloudEventOverrides) SinkBindingV1Alpha2Option

WithCloudEventOverridesV1A1 assigns the CloudEventsOverrides of the SinkBinding.

func WithSinkV1A2 

func WithSinkV1A2(sink duckv1.Destination) SinkBindingV1Alpha2Option

WithSinkV1A2 assigns the sink of the SinkBinding.

func WithSubjectV1A2 

func WithSubjectV1A2(subject tracker.Reference) SinkBindingV1Alpha2Option

WithSubjectV1A2 assigns the subject of the SinkBinding.

type SubscriptionOption 

type SubscriptionOption func(*v1alpha1.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(*v1alpha1.Trigger)

TriggerOption enables further configuration of a Trigger.

func WithDependencyAnnotation 

func WithDependencyAnnotation(dependencyAnnotation string) TriggerOption

func WithInjectionAnnotation 

func WithInjectionAnnotation(injectionAnnotation 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

func WithUnmarshalFailedDependencyAnnotation 

func WithUnmarshalFailedDependencyAnnotation() TriggerOption

type UnstructuredOption 

type UnstructuredOption func(*unstructured.Unstructured)

UnstructuredOption enables further configuration of a Unstructured.

func WithUnstructuredAddressable 

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.