testing

package

Go to main page

Versions in this module

v0

v0.14.2

Apr 30, 2020

v0.14.1

Apr 21, 2020

v0.14.0

Apr 14, 2020

Changes in this version

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

+ func WithInitPingSourceV1A2Conditions(s *v1alpha2.PingSource)

+ func WithPingSourceClusterScopeAnnotation(c *v1alpha1.PingSource)

+ func WithPingSourceResourceScopeAnnotation(c *v1alpha1.PingSource)

+ func WithPingSourceV1A2ClusterScopeAnnotation(c *v1alpha2.PingSource)

+ func WithPingSourceV1A2Deleted(c *v1alpha2.PingSource)

+ func WithPingSourceV1A2Deployed(s *v1alpha2.PingSource)

+ func WithPingSourceV1A2EventType(s *v1alpha2.PingSource)

+ func WithPingSourceV1A2ResourceScopeAnnotation(c *v1alpha2.PingSource)

+ func WithPingSourceV1A2SinkNotFound(s *v1alpha2.PingSource)

+ func WithValidPingSourceV1A2Resources(s *v1alpha2.PingSource)

+ func WithValidPingSourceV1A2Schedule(s *v1alpha2.PingSource)

type BrokerOption

+ func WithBrokerAddressURI(uri *apis.URL) BrokerOption

+ func WithBrokerClass(bc string) BrokerOption

+ func WithFilterAvailable() BrokerOption

+ func WithIngressAvailable() BrokerOption

type ContainerSourceOption

+ func WithContainerSourcePropagateReceiveAdapterStatus(d *appsv1.Deployment) ContainerSourceOption

+ func WithContainerSourcePropagateSinkbindingStatus(status *sourcesv1alpha2.SinkBindingStatus) ContainerSourceOption

type CustomResourceDefinitionOption

+ func WithCustomResourceDefinitionGroup(group string) CustomResourceDefinitionOption

+ func WithCustomResourceDefinitionNames(names apiextensionsv1beta1.CustomResourceDefinitionNames) CustomResourceDefinitionOption

+ func WithCustomResourceDefinitionVersions(versions []apiextensionsv1beta1.CustomResourceDefinitionVersion) CustomResourceDefinitionOption

+ type EndpointsOption func(*corev1.Endpoints)

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

+ func WithEndpointsAnnotations(annotations map[string]string) EndpointsOption

+ func WithEndpointsLabels(labels map[string]string) EndpointsOption

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

type Listers

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

+ func (l *Listers) GetPingSourceV1alpha2Lister() sourcev1alpha2listers.PingSourceLister

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

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

+ func (l *Listers) GetV1Beta1BrokerLister() eventingv1beta1listers.BrokerLister

type PingSourceOption

+ func WithPingSourceNotDeployed(name string) PingSourceOption

type PingSourceV1A2Option

+ func WithPingSourceV1A2Finalizers(finalizers ...string) PingSourceV1A2Option

+ func WithPingSourceV1A2Sink(uri *apis.URL) PingSourceV1A2Option

v0.13.8

Apr 21, 2020

v0.13.7

Apr 10, 2020

v0.13.6

Apr 2, 2020

v0.13.5

Mar 25, 2020

v0.13.4

Mar 19, 2020

v0.13.3

Mar 10, 2020

v0.13.2

Mar 7, 2020

v0.13.1

Mar 4, 2020

v0.13.0

Mar 3, 2020

Changes in this version

+ func MarkAddedToChannel(s *v1alpha1.Subscription)

+ func MarkReferencesResolved(s *v1alpha1.Subscription)

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

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

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

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

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

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

+ func WithConfigMapPropagationDeletionTimestamp(cmp *v1alpha1.ConfigMapPropagation)

+ func WithConfigMapPropagationNotPropagated(cmp *v1alpha1.ConfigMapPropagation)

+ func WithConfigMapPropagationPropagated(cmp *v1alpha1.ConfigMapPropagation)

+ func WithInitConfigMapPropagationConditions(cmp *v1alpha1.ConfigMapPropagation)

+ func WithInitPingSourceConditions(s *v1alpha1.PingSource)

+ func WithInvalidPingSourceSchedule(s *v1alpha1.PingSource)

+ func WithPingSourceDeleted(c *v1alpha1.PingSource)

+ func WithPingSourceDeployed(s *v1alpha1.PingSource)

+ func WithPingSourceEventType(s *v1alpha1.PingSource)

+ func WithPingSourceSinkNotFound(s *v1alpha1.PingSource)

+ func WithValidPingSourceResources(s *v1alpha1.PingSource)

+ func WithValidPingSourceSchedule(s *v1alpha1.PingSource)

type BrokerOption

+ func WithBrokerFinalizers(finalizers ...string) BrokerOption

+ func WithBrokerResourceVersion(rv string) BrokerOption

type ChannelOption

+ func WithBackingChannelUnknown(reason, msg string) ChannelOption

+ func WithChannelGeneration(gen int64) ChannelOption

+ func WithChannelNoAddress() ChannelOption

+ func WithChannelObservedGeneration(gen int64) ChannelOption

+ type ConfigMapOption func(*v1.ConfigMap)

+ func WithConfigMapData(data map[string]string) ConfigMapOption

+ func WithConfigMapLabels(labels metav1.LabelSelector) ConfigMapOption

+ func WithConfigMapOwnerReference(ConfigMapPropagation *v1alpha1.ConfigMapPropagation) ConfigMapOption

+ type ConfigMapPropagationOption func(*v1alpha1.ConfigMapPropagation)

+ func WithConfigMapPropagationGeneration(gen int64) ConfigMapPropagationOption

+ func WithConfigMapPropagationSelector(selector metav1.LabelSelector) ConfigMapPropagationOption

+ func WithConfigMapPropagationStatusObservedGeneration(gen int64) ConfigMapPropagationOption

+ func WithConfigMapPropagationUID(uid string) ConfigMapPropagationOption

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

+ func WithInitConfigMapStatus() ConfigMapPropagationOption

type InMemoryChannelOption

+ func WithInMemoryChannelChannelServiceNotReady(reason, message string) InMemoryChannelOption

+ func WithInMemoryChannelReady(host string) InMemoryChannelOption

+ func WithInMemoryChannelReadySubscriber(uid string) InMemoryChannelOption

+ func WithInMemoryChannelReadySubscriberAndGeneration(uid string, observedGeneration int64) InMemoryChannelOption

+ func WithInMemoryScopeAnnotation(value string) InMemoryChannelOption

type Listers

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

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

+ type PingSourceOption func(*v1alpha1.PingSource)

+ func WithPingSourceApiVersion(apiVersion string) PingSourceOption

+ func WithPingSourceObjectMetaGeneration(generation int64) PingSourceOption

+ func WithPingSourceSink(uri *apis.URL) PingSourceOption

+ func WithPingSourceSpec(spec v1alpha1.PingSourceSpec) PingSourceOption

+ func WithPingSourceStatusObservedGeneration(generation int64) PingSourceOption

+ func WithPingSourceUID(uid string) PingSourceOption

+ type PingSourceV1A2Option func(*v1alpha2.PingSource)

+ func WithPingSourceV1A2Spec(spec v1alpha2.PingSourceSpec) PingSourceV1A2Option

+ type SinkBindingV1Alpha1Option func(*sourcesv1alpha1.SinkBinding)

+ func WithCloudEventOverridesV1A1(overrides duckv1.CloudEventOverrides) SinkBindingV1Alpha1Option

+ func WithSinkV1A1(sink duckv1.Destination) SinkBindingV1Alpha1Option

+ func WithSubjectV1A1(subject tracker.Reference) SinkBindingV1Alpha1Option

+ type SinkBindingV1Alpha2Option func(*sourcesv1alpha2.SinkBinding)

+ func WithCloudEventOverridesV1A2(overrides duckv1.CloudEventOverrides) SinkBindingV1Alpha2Option

+ func WithSinkV1A2(sink duckv1.Destination) SinkBindingV1Alpha2Option

+ func WithSubjectV1A2(subject tracker.Reference) SinkBindingV1Alpha2Option

type SubscriptionOption

+ func MarkNotAddedToChannel(reason, msg string) SubscriptionOption

+ func WithSubscriptionDeadLetterSinkURI(uri *apis.URL) SubscriptionOption

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

v0.12.0

Jan 21, 2020

Changes in this version

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

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

+ func WithInitLegacyApiServerSourceConditions(s *v1alpha1.ApiServerSource)

+ func WithLegacyApiServerSourceDeleted(c *v1alpha1.ApiServerSource)

+ func WithLegacyApiServerSourceDeployed(s *v1alpha1.ApiServerSource)

+ func WithLegacyApiServerSourceDeploymentUnavailable(s *v1alpha1.ApiServerSource)

+ func WithLegacyApiServerSourceEventTypes(s *v1alpha1.ApiServerSource)

+ func WithLegacyApiServerSourceNoSufficientPermissions(s *v1alpha1.ApiServerSource)

+ func WithLegacyApiServerSourceSinkNotFound(s *v1alpha1.ApiServerSource)

+ func WithLegacyApiServerSourceSufficientPermissions(s *v1alpha1.ApiServerSource)

type BrokerOption

+ func WithBrokerGeneration(gen int64) BrokerOption

+ func WithBrokerStatusObservedGeneration(gen int64) BrokerOption

type EventTypeOption

+ func WithEventTypeBrokerFailed(reason, message string) EventTypeOption

+ func WithEventTypeBrokerUnknown(reason, message string) EventTypeOption

type FlowsParallelOption

+ func WithFlowsParallelGeneration(gen int64) FlowsParallelOption

+ func WithFlowsParallelStatusObservedGeneration(gen int64) FlowsParallelOption

type FlowsSequenceOption

+ func WithFlowsSequenceGeneration(gen int64) FlowsSequenceOption

+ func WithFlowsSequenceStatusObservedGeneration(gen int64) FlowsSequenceOption

type InMemoryChannelOption

+ func WithInMemoryChannelDeploymentFailed(reason, message string) InMemoryChannelOption

+ func WithInMemoryChannelDeploymentUnknown(reason, message string) InMemoryChannelOption

+ func WithInMemoryChannelGeneration(gen int64) InMemoryChannelOption

+ func WithInMemoryChannelStatusObservedGeneration(gen int64) InMemoryChannelOption

+ type LegacyApiServerSourceOption func(*v1alpha1.ApiServerSource)

+ func WithLegacyApiServerSourceObjectMetaGeneration(generation int64) LegacyApiServerSourceOption

+ func WithLegacyApiServerSourceSink(uri string) LegacyApiServerSourceOption

+ func WithLegacyApiServerSourceSinkDepRef(uri string) LegacyApiServerSourceOption

+ func WithLegacyApiServerSourceSpec(spec v1alpha1.ApiServerSourceSpec) LegacyApiServerSourceOption

+ func WithLegacyApiServerSourceStatusObservedGeneration(generation int64) LegacyApiServerSourceOption

+ func WithLegacyApiServerSourceUID(uid string) LegacyApiServerSourceOption

+ type LegacySinkBindingOption func(*legacysourcesv1alpha1.SinkBinding)

+ func WithLegacySink(sink duckv1.Destination) LegacySinkBindingOption

+ func WithLegacySubject(subject tracker.Reference) LegacySinkBindingOption

type Listers

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

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

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

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

type SubscriptionOption

+ func WithSubscriptionReferencesResolvedUnknown(reason, msg string) SubscriptionOption

+ func WithSubscriptionStatusObservedGeneration(gen int64) SubscriptionOption

type TriggerOption

+ func WithTriggerBrokerUnknown(reason, message string) TriggerOption

+ func WithTriggerGeneration(gen int64) TriggerOption

+ func WithTriggerStatusObservedGeneration(gen int64) TriggerOption

+ func WithTriggerSubscribedUnknown(reason, message string) TriggerOption

+ func WithTriggerSubscriptionNotConfigured() TriggerOption

v0.11.0

Dec 10, 2019

Changes in this version

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

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

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

+ func WithApiServerSourceNoSufficientPermissions(s *v1alpha1.ApiServerSource)

+ func WithApiServerSourceSufficientPermissions(s *v1alpha1.ApiServerSource)

+ func WithFlowsParallelDeleted(p *v1alpha1.Parallel)

+ func WithFlowsSequenceDeleted(p *v1alpha1.Sequence)

+ func WithInitFlowsParallelConditions(p *v1alpha1.Parallel)

+ func WithInitFlowsSequenceConditions(p *v1alpha1.Sequence)

+ type FlowsParallelOption func(*v1alpha1.Parallel)

+ func WithFlowsParallelAddressableNotReady(reason, message string) FlowsParallelOption

+ func WithFlowsParallelBranchStatuses(branchStatuses []v1alpha1.ParallelBranchStatus) FlowsParallelOption

+ func WithFlowsParallelBranches(branches []v1alpha1.ParallelBranch) FlowsParallelOption

+ func WithFlowsParallelChannelTemplateSpec(cts *eventingduck.ChannelTemplateSpec) FlowsParallelOption

+ func WithFlowsParallelChannelsNotReady(reason, message string) FlowsParallelOption

+ func WithFlowsParallelIngressChannelStatus(status v1alpha1.ParallelChannelStatus) FlowsParallelOption

+ func WithFlowsParallelReply(reply *duckv1.Destination) FlowsParallelOption

+ func WithFlowsParallelSubscriptionsNotReady(reason, message string) FlowsParallelOption

+ type FlowsSequenceOption func(*v1alpha1.Sequence)

+ func WithFlowsSequenceAddressableNotReady(reason, message string) FlowsSequenceOption

+ func WithFlowsSequenceChannelStatuses(channelStatuses []v1alpha1.SequenceChannelStatus) FlowsSequenceOption

+ func WithFlowsSequenceChannelTemplateSpec(cts *eventingduckv1alpha1.ChannelTemplateSpec) FlowsSequenceOption

+ func WithFlowsSequenceChannelsNotReady(reason, message string) FlowsSequenceOption

+ func WithFlowsSequenceReply(reply *duckv1.Destination) FlowsSequenceOption

+ func WithFlowsSequenceSteps(steps []duckv1.Destination) FlowsSequenceOption

+ func WithFlowsSequenceSubscriptionStatuses(subscriptionStatuses []v1alpha1.SequenceSubscriptionStatus) FlowsSequenceOption

+ func WithFlowsSequenceSubscriptionsNotReady(reason, message string) FlowsSequenceOption

type Listers

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

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

type ParallelOption

+ func WithParallelDeprecatedStatus() ParallelOption

type SequenceOption

+ func WithSequenceDeprecatedStatus() SequenceOption

+ type SinkBindingOption func(*v1alpha1.SinkBinding)

+ func WithSink(sink duckv1.Destination) SinkBindingOption

+ func WithSubject(subject tracker.Reference) SinkBindingOption

v0.10.2

Dec 3, 2019

v0.10.1

Nov 13, 2019

Changes in this version

type TriggerOption

+ func WithTriggerSubscriberResolvedFailed(reason, message string) TriggerOption

+ func WithTriggerSubscriberResolvedSucceeded() TriggerOption

+ func WithTriggerSubscriberResolvedUnknown(reason, message string) TriggerOption

v0.10.0

Oct 29, 2019

Changes in this version

type ApiServerSourceOption

+ func WithApiServerSourceSinkDepRef(uri string) ApiServerSourceOption

type BrokerOption

+ func WithBrokerChannel(crdType metav1.TypeMeta) BrokerOption

type ParallelOption

+ func WithParallelDeprecatedBranchReplyStatus() ParallelOption

+ func WithParallelDeprecatedReplyStatus() ParallelOption

type SequenceOption

+ func WithSequenceDeprecatedReplyStatus() SequenceOption

type SubscriptionOption

+ func WithSubscriptionReplyDeprecated() SubscriptionOption

+ func WithSubscriptionReplyNotDeprecated(gvk metav1.GroupVersionKind, name string) SubscriptionOption

type TriggerOption

+ func WithInjectionAnnotation(injectionAnnotation string) TriggerOption

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

v0.9.0

Sep 17, 2019

Changes in this version

+ func NewParallel(name, namespace string, popt ...ParallelOption) *v1alpha1.Parallel

+ func WithInitParallelConditions(p *v1alpha1.Parallel)

+ func WithParallelDeleted(p *v1alpha1.Parallel)

type ApiServerSourceOption

+ func WithApiServerSourceObjectMetaGeneration(generation int64) ApiServerSourceOption

+ func WithApiServerSourceStatusObservedGeneration(generation int64) ApiServerSourceOption

+ func WithApiServerSourceUID(uid string) ApiServerSourceOption

type ChannelOption

+ func WithChannelReadySubscriber(uid string) ChannelOption

+ func WithChannelReadySubscriberAndGeneration(uid string, observedGeneration int64) ChannelOption

+ func WithChannelSubscriberStatuses(subscriberStatuses []eventingduckv1alpha1.SubscriberStatus) ChannelOption

+ func WithChannelTemplate(typeMeta metav1.TypeMeta) ChannelOption

type ContainerSourceOption

+ func WithContainerSourceObjectMetaGeneration(generation int64) ContainerSourceOption

+ func WithContainerSourceStatusObservedGeneration(generation int64) ContainerSourceOption

type CronJobSourceOption

+ func WithCronJobApiVersion(apiVersion string) CronJobSourceOption

+ func WithCronJobSourceObjectMetaGeneration(generation int64) CronJobSourceOption

+ func WithCronJobSourceStatusObservedGeneration(generation int64) CronJobSourceOption

+ func WithCronJobSourceUID(uid string) CronJobSourceOption

type Listers

+ func (l *Listers) GetParallelLister() messaginglisters.ParallelLister

+ type ParallelOption func(*v1alpha1.Parallel)

+ func WithParallelAddressableNotReady(reason, message string) ParallelOption

+ func WithParallelBranchStatuses(branchStatuses []v1alpha1.ParallelBranchStatus) ParallelOption

+ func WithParallelBranches(branches []v1alpha1.ParallelBranch) ParallelOption

+ func WithParallelChannelTemplateSpec(cts *eventingduck.ChannelTemplateSpec) ParallelOption

+ func WithParallelChannelsNotReady(reason, message string) ParallelOption

+ func WithParallelIngressChannelStatus(status v1alpha1.ParallelChannelStatus) ParallelOption

+ func WithParallelReply(reply *corev1.ObjectReference) ParallelOption

+ func WithParallelSubscriptionsNotReady(reason, message string) ParallelOption

type TriggerOption

+ func WithDependencyAnnotation(dependencyAnnotation string) TriggerOption

+ func WithTriggerDependencyFailed(reason, message string) TriggerOption

+ func WithTriggerDependencyReady() TriggerOption

+ func WithTriggerDependencyUnknown(reason, message string) TriggerOption

+ func WithUnmarshalFailedDependencyAnnotation() TriggerOption

v0.8.1

Nov 18, 2019

v0.8.0

Aug 6, 2019

Changes in this version

+ func NewChoice(name, namespace string, popt ...ChoiceOption) *v1alpha1.Choice

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

+ func NewMessagingChannel(name, namespace string, o ...MessagingChannelOption) *v1alpha1.Channel

+ func WithApiServerSourceDeploymentUnavailable(s *v1alpha1.ApiServerSource)

+ func WithBackingChannelReady(c *v1alpha1.Channel)

+ func WithChoiceDeleted(p *v1alpha1.Choice)

+ func WithInitChoiceConditions(p *v1alpha1.Choice)

+ func WithInitMessagingChannelConditions(c *v1alpha1.Channel)

+ func WithMessagingChannelDeleted(c *v1alpha1.Channel)

+ type ChoiceOption func(*v1alpha1.Choice)

+ func WithChoiceAddressableNotReady(reason, message string) ChoiceOption

+ func WithChoiceCaseStatuses(caseStatuses []v1alpha1.ChoiceCaseStatus) ChoiceOption

+ func WithChoiceCases(cases []v1alpha1.ChoiceCase) ChoiceOption

+ func WithChoiceChannelTemplateSpec(cts *eventingduck.ChannelTemplateSpec) ChoiceOption

+ func WithChoiceChannelsNotReady(reason, message string) ChoiceOption

+ func WithChoiceIngressChannelStatus(status v1alpha1.ChoiceChannelStatus) ChoiceOption

+ func WithChoiceReply(reply *corev1.ObjectReference) ChoiceOption

+ func WithChoiceSubscriptionsNotReady(reason, message string) ChoiceOption

type DeploymentOption

+ func WithDeploymentAvailable() DeploymentOption

type Listers

+ func (l *Listers) GetChoiceLister() messaginglisters.ChoiceLister

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

+ type MessagingChannelOption func(*v1alpha1.Channel)

+ func WithBackingChannelFailed(reason, msg string) MessagingChannelOption

+ func WithBackingChannelObjRef(objRef *v1.ObjectReference) MessagingChannelOption

+ func WithMessagingChannelAddress(hostname string) MessagingChannelOption

+ func WithMessagingChannelSubscribers(subscribers []eventingduckv1alpha1.SubscriberSpec) MessagingChannelOption

+ func WithMessagingChannelTemplate(typeMeta metav1.TypeMeta) MessagingChannelOption

+ func WithMesssagingChannelSubscriberStatuses(subscriberStatuses []eventingduckv1alpha1.SubscriberStatus) MessagingChannelOption

+ type MockResourceTracker struct

+ func (at *MockResourceTracker) TrackInNamespace(metav1.Object) func(corev1.ObjectReference) error

type ServiceOption

+ func WithServiceAnnotations(annotations map[string]string) ServiceOption

v0.7.1

Jul 2, 2019

v0.7.0

Jun 25, 2019

Changes in this version

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

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

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

+ func WithBrokerReadyDeprecated(b *v1alpha1.Broker)

+ func WithInMemoryChannelDeleted(imc *v1alpha1.InMemoryChannel)

+ func WithInitInMemoryChannelConditions(imc *v1alpha1.InMemoryChannel)

+ func WithInitSequenceConditions(p *v1alpha1.Sequence)

+ func WithSequenceDeleted(p *v1alpha1.Sequence)

+ func WithValidCronJobSourceResources(s *v1alpha1.CronJobSource)

type BrokerOption

+ func WithBrokerChannelCRD(crdType metav1.TypeMeta) BrokerOption

+ func WithBrokerDeprecated() BrokerOption

+ func WithBrokerIngressChannel(c *corev1.ObjectReference) BrokerOption

+ func WithBrokerTriggerChannel(c *corev1.ObjectReference) BrokerOption

+ type CustomResourceDefinitionOption func(*apiextensionsv1beta1.CustomResourceDefinition)

+ func WithCustomResourceDefinitionLabels(labels map[string]string) CustomResourceDefinitionOption

+ type InMemoryChannelOption func(*v1alpha1.InMemoryChannel)

+ func WithInMemoryChannelAddress(a string) InMemoryChannelOption

+ func WithInMemoryChannelChannelServiceReady() InMemoryChannelOption

+ func WithInMemoryChannelChannelServicetNotReady(reason, message string) InMemoryChannelOption

+ func WithInMemoryChannelDeploymentNotReady(reason, message string) InMemoryChannelOption

+ func WithInMemoryChannelDeploymentReady() InMemoryChannelOption

+ func WithInMemoryChannelEndpointsNotReady(reason, message string) InMemoryChannelOption

+ func WithInMemoryChannelEndpointsReady() InMemoryChannelOption

+ func WithInMemoryChannelServiceReady() InMemoryChannelOption

+ func WithInMemoryChannelServicetNotReady(reason, message string) InMemoryChannelOption

+ func WithInMemoryChannelStatusSubscribers(subscriberStatuses []duckv1alpha1.SubscriberStatus) InMemoryChannelOption

+ func WithInMemoryChannelSubscribers(subscribers []duckv1alpha1.SubscriberSpec) InMemoryChannelOption

type Listers

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

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

+ func (l *Listers) GetSequenceLister() messaginglisters.SequenceLister

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

+ type SequenceOption func(*v1alpha1.Sequence)

+ func WithSequenceAddressableNotReady(reason, message string) SequenceOption

+ func WithSequenceChannelStatuses(channelStatuses []v1alpha1.SequenceChannelStatus) SequenceOption

+ func WithSequenceChannelTemplateSpec(cts v1alpha1.ChannelTemplateSpec) SequenceOption

+ func WithSequenceChannelsNotReady(reason, message string) SequenceOption

+ func WithSequenceReply(reply *corev1.ObjectReference) SequenceOption

+ func WithSequenceSteps(steps []eventingv1alpha1.SubscriberSpec) SequenceOption

+ func WithSequenceSubscriptionStatuses(subscriptionStatuses []v1alpha1.SequenceSubscriptionStatus) SequenceOption

+ func WithSequenceSubscriptionsNotReady(reason, message string) SequenceOption

type SubscriptionOption

+ func WithSubscriptionGeneration(gen int64) SubscriptionOption

+ func WithSubscriptionReferencesNotResolved(reason, msg string) SubscriptionOption

v0.6.1

Jun 26, 2019

v0.6.0

May 14, 2019

Changes in this version

+ func MakeFactory(ctor Ctor, unstructured bool) Factory

+ func MarkSubscriptionReady(s *v1alpha1.Subscription)

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

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

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

+ func NewChannelWithoutNamespace(name string, o ...ChannelOption) *v1alpha1.Channel

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

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

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

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

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

+ func NewScheme() *runtime.Scheme

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

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

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

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

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

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

+ func WithApiServerSourceDeleted(c *v1alpha1.ApiServerSource)

+ func WithApiServerSourceDeployed(s *v1alpha1.ApiServerSource)

+ func WithApiServerSourceEventTypes(s *v1alpha1.ApiServerSource)

+ func WithApiServerSourceSinkNotFound(s *v1alpha1.ApiServerSource)

+ func WithBrokerDeletionTimestamp(b *v1alpha1.Broker)

+ func WithBrokerReady(b *v1alpha1.Broker)

+ func WithChannelDeleted(c *v1alpha1.Channel)

+ func WithChannelReady(c *v1alpha1.Channel)

+ func WithContainerSourceDeleted(c *v1alpha1.ContainerSource)

+ func WithContainerSourceDeployed(s *v1alpha1.ContainerSource)

+ func WithCronJobSourceDeleted(c *v1alpha1.CronJobSource)

+ func WithCronJobSourceDeployed(s *v1alpha1.CronJobSource)

+ func WithCronJobSourceEventType(s *v1alpha1.CronJobSource)

+ func WithCronJobSourceSinkNotFound(s *v1alpha1.CronJobSource)

+ func WithEventTypeBrokerDoesNotExist(et *v1alpha1.EventType)

+ func WithEventTypeBrokerExists(et *v1alpha1.EventType)

+ func WithEventTypeBrokerNotReady(et *v1alpha1.EventType)

+ func WithEventTypeBrokerReady(et *v1alpha1.EventType)

+ func WithEventTypeDeletionTimestamp(et *v1alpha1.EventType)

+ func WithInitApiServerSourceConditions(s *v1alpha1.ApiServerSource)

+ func WithInitBrokerConditions(b *v1alpha1.Broker)

+ func WithInitChannelConditions(s *v1alpha1.Channel)

+ func WithInitContainerSourceConditions(s *v1alpha1.ContainerSource)

+ func WithInitCronJobSourceConditions(s *v1alpha1.CronJobSource)

+ func WithInitEventTypeConditions(et *v1alpha1.EventType)

+ func WithInitSubscriptionConditions(s *v1alpha1.Subscription)

+ func WithInitTriggerConditions(t *v1alpha1.Trigger)

+ func WithInvalidCronJobSourceSchedule(s *v1alpha1.CronJobSource)

+ func WithNamespaceDeleted(n *corev1.Namespace)

+ func WithSubscriptionDeleted(s *v1alpha1.Subscription)

+ func WithSubscriptionReady(s *v1alpha1.Subscription)

+ func WithTriggerDeleted(t *v1alpha1.Trigger)

+ func WithValidCronJobSourceSchedule(s *v1alpha1.CronJobSource)

+ type ApiServerSourceOption func(*v1alpha1.ApiServerSource)

+ func WithApiServerSourceSink(uri string) ApiServerSourceOption

+ func WithApiServerSourceSpec(spec v1alpha1.ApiServerSourceSpec) ApiServerSourceOption

+ type BrokerOption func(*v1alpha1.Broker)

+ func WithBrokerAddress(address string) BrokerOption

+ func WithBrokerChannelProvisioner(provisioner *corev1.ObjectReference) BrokerOption

+ func WithBrokerIngressChannelReady() BrokerOption

+ func WithBrokerIngressSubscriptionFailed(reason, msg string) BrokerOption

+ func WithFilterDeploymentAvailable() BrokerOption

+ func WithFilterFailed(reason, msg string) BrokerOption

+ func WithIngressChannelFailed(reason, msg string) BrokerOption

+ func WithIngressDeploymentAvailable() BrokerOption

+ func WithIngressFailed(reason, msg string) BrokerOption

+ func WithTriggerChannelFailed(reason, msg string) BrokerOption

+ func WithTriggerChannelReady() BrokerOption

+ type ChannelOption func(*v1alpha1.Channel)

+ func WithChannelAddress(hostname string) ChannelOption

+ func WithChannelGenerateName(generateName string) ChannelOption

+ func WithChannelLabels(labels map[string]string) ChannelOption

+ func WithChannelOwnerReferences(ownerReferences []metav1.OwnerReference) ChannelOption

+ func WithChannelProvisioner(gvk metav1.GroupVersionKind, name string) ChannelOption

+ func WithChannelProvisionerNotFound(name, kind string) ChannelOption

+ func WithChannelSubscribers(subscribers []duckv1alpha1.ChannelSubscriberSpec) ChannelOption

+ type ContainerSourceOption func(*v1alpha1.ContainerSource)

+ func WithContainerSourceAnnotations(annotations map[string]string) ContainerSourceOption

+ func WithContainerSourceDeployFailed(msg string) ContainerSourceOption

+ func WithContainerSourceDeploying(msg string) ContainerSourceOption

+ func WithContainerSourceLabels(labels map[string]string) ContainerSourceOption

+ func WithContainerSourceSink(uri string) ContainerSourceOption

+ func WithContainerSourceSinkMissing(msg string) ContainerSourceOption

+ func WithContainerSourceSinkNotFound(msg string) ContainerSourceOption

+ func WithContainerSourceSpec(spec v1alpha1.ContainerSourceSpec) ContainerSourceOption

+ func WithContainerSourceUID(uid types.UID) ContainerSourceOption

+ type CronJobSourceOption func(*v1alpha1.CronJobSource)

+ func WithCronJobSourceSink(uri string) CronJobSourceOption

+ func WithCronJobSourceSpec(spec v1alpha1.CronJobSourceSpec) CronJobSourceOption

+ type Ctor func(*Listers, reconciler.Options) controller.Reconciler

+ type DeploymentOption func(*appsv1.Deployment)

+ func WithDeploymentAnnotations(annotations map[string]string) DeploymentOption

+ func WithDeploymentContainer(name, image string, envVars []corev1.EnvVar, ...) DeploymentOption

+ func WithDeploymentLabels(labels map[string]string) DeploymentOption

+ func WithDeploymentOwnerReferences(ownerReferences []metav1.OwnerReference) DeploymentOption

+ func WithDeploymentServiceAccount(serviceAccountName string) DeploymentOption

+ type EventTypeOption func(*v1alpha1.EventType)

+ func WithEventTypeBroker(broker string) EventTypeOption

+ func WithEventTypeDescription(description string) EventTypeOption

+ func WithEventTypeGenerateName(generateName string) EventTypeOption

+ func WithEventTypeLabels(labels map[string]string) EventTypeOption

+ func WithEventTypeOwnerReference(ownerRef metav1.OwnerReference) EventTypeOption

+ func WithEventTypeSource(source string) EventTypeOption

+ func WithEventTypeType(t string) EventTypeOption

+ type Listers struct

+ func NewListers(objs []runtime.Object) Listers

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

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

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

+ func (l *Listers) GetChannelLister() eventinglisters.ChannelLister

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

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

+ func (l *Listers) GetCronJobSourceLister() sourcelisters.CronJobSourceLister

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

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

+ func (l *Listers) GetEventTypeLister() eventinglisters.EventTypeLister

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

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

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

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

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

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

+ func (l *Listers) GetSharedObjects() []runtime.Object

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

+ func (l *Listers) GetSubscriptionLister() eventinglisters.SubscriptionLister

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

+ type NamespaceOption func(*corev1.Namespace)

+ func WithNamespaceLabeled(labels map[string]string) NamespaceOption

+ type ServiceOption func(*corev1.Service)

+ func WithServiceLabels(labels map[string]string) ServiceOption

+ func WithServiceOwnerReferences(ownerReferences []metav1.OwnerReference) ServiceOption

+ func WithServicePorts(ports []corev1.ServicePort) ServiceOption

+ type SubscriptionOption func(*v1alpha1.Subscription)

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

+ func WithSubscriptionFinalizers(finalizers ...string) SubscriptionOption

+ func WithSubscriptionGenerateName(generateName string) SubscriptionOption

+ func WithSubscriptionLabels(labels map[string]string) SubscriptionOption

+ func WithSubscriptionOwnerReferences(ownerReferences []metav1.OwnerReference) SubscriptionOption

+ func WithSubscriptionPhysicalSubscriptionReply(uri string) SubscriptionOption

+ func WithSubscriptionPhysicalSubscriptionSubscriber(uri string) SubscriptionOption

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

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

+ func WithSubscriptionUID(uid types.UID) SubscriptionOption

+ type TriggerOption func(*v1alpha1.Trigger)

+ func WithTriggerBrokerFailed(reason, message string) TriggerOption

+ func WithTriggerBrokerReady() TriggerOption

+ func WithTriggerNotSubscribed(reason, message string) TriggerOption

+ func WithTriggerStatusSubscriberURI(uri string) TriggerOption

+ func WithTriggerSubscribed() TriggerOption

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

+ func WithTriggerSubscriberURI(uri string) TriggerOption

+ func WithTriggerUID(uid string) TriggerOption

+ type UnstructuredOption func(*unstructured.Unstructured)

+ func WithUnstructuredAddressable(hostname string) UnstructuredOption

v0.5.0

Apr 2, 2019

Changes in this version

+ type DynamicMocks struct

+ MockCreates []MockDynamicCreate

+ MockDeleteCollections []MockDynamicDeleteCollection

+ MockDeletes []MockDynamicDelete

+ MockGets []MockDynamicGet

+ MockLists []MockDynamicList

+ MockPatches []MockDynamicPatch

+ MockResources []MockDynamicResource

+ MockUpdateStatuses []MockDynamicUpdateStatus

+ MockUpdates []MockDynamicUpdate

+ MockWatches []MockDynamicWatch

+ type MockDynamicContext struct

+ InnerInterface dynamic.ResourceInterface

+ Namespace string

+ Resource schema.GroupVersionResource

+ type MockDynamicCreate func(ctx *MockDynamicContext, obj *unstructured.Unstructured, ...) (MockHandled, *unstructured.Unstructured, error)

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

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

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

+ type MockDynamicInterface struct

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

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

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

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

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

+ type MockDynamicUpdate func(ctx *MockDynamicContext, obj *unstructured.Unstructured, ...) (MockHandled, *unstructured.Unstructured, error)

+ type MockDynamicUpdateStatus func(ctx *MockDynamicContext, obj *unstructured.Unstructured, ...) (MockHandled, *unstructured.Unstructured, error)

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

type TestCase

+ DynamicMocks DynamicMocks

v0.4.1

Feb 20, 2019

v0.4.0

Feb 15, 2019

Changes in this version

+ type Buildable interface

+ Build func() runtime.Object

+ type MockClient struct

+ func NewMockClient(innerClient client.Client, mocks Mocks) *MockClient

+ func (m *MockClient) Create(ctx context.Context, obj runtime.Object) error

+ func (m *MockClient) Delete(ctx context.Context, obj runtime.Object, opts ...client.DeleteOptionFunc) error

+ func (m *MockClient) Get(ctx context.Context, key client.ObjectKey, obj runtime.Object) error

+ func (m *MockClient) List(ctx context.Context, opts *client.ListOptions, list runtime.Object) error

+ func (m *MockClient) Status() client.StatusWriter

+ func (m *MockClient) Update(ctx context.Context, obj runtime.Object) error

+ type MockCreate func(innerClient client.Client, ctx context.Context, obj runtime.Object) (MockHandled, error)

+ type MockDelete func(innerClient client.Client, ctx context.Context, obj runtime.Object) (MockHandled, error)

+ type MockEventRecorder struct

+ func NewEventRecorder() *MockEventRecorder

+ func (m *MockEventRecorder) AnnotatedEventf(object runtime.Object, annotations map[string]string, ...)

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

+ func (m *MockEventRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, ...)

+ func (m *MockEventRecorder) PastEventf(object runtime.Object, timestamp metav1.Time, ...)

+ type MockGet func(innerClient client.Client, ctx context.Context, key client.ObjectKey, ...) (MockHandled, error)

+ type MockHandled int

+ const Handled

+ const Unhandled

+ type MockList func(innerClient client.Client, ctx context.Context, opts *client.ListOptions, ...) (MockHandled, error)

+ type MockStatusUpdate func(innerClient client.Client, ctx context.Context, obj runtime.Object) (MockHandled, error)

+ type MockUpdate func(innerClient client.Client, ctx context.Context, obj runtime.Object) (MockHandled, error)

+ type Mocks struct

+ MockCreates []MockCreate

+ MockDeletes []MockDelete

+ MockGets []MockGet

+ MockLists []MockList

+ MockStatusUpdates []MockStatusUpdate

+ MockUpdates []MockUpdate

+ type TestCase struct

+ AdditionalVerification []func(t *testing.T, tc *TestCase)

+ IgnoreTimes bool

+ InitialState []runtime.Object

+ Mocks Mocks

+ Name string

+ Objects []runtime.Object

+ OtherTestData map[string]interface{}

+ ReconcileKey string

+ Scheme *runtime.Scheme

+ WantAbsent []runtime.Object

+ WantErr bool

+ WantErrMsg string

+ WantEvent []corev1.Event

+ WantPresent []runtime.Object

+ WantResult reconcile.Result

+ func (tc *TestCase) GetClient() *MockClient

+ func (tc *TestCase) GetDynamicClient() dynamic.Interface

+ func (tc *TestCase) GetEventRecorder() *MockEventRecorder

+ func (tc *TestCase) Reconcile(r reconcile.Reconciler) (reconcile.Result, error)

+ func (tc *TestCase) Runner(t *testing.T, r reconcile.Reconciler, c *MockClient, ...) func(t *testing.T)

+ func (tc *TestCase) VerifyErr(err error) error

+ func (tc *TestCase) VerifyResult(result reconcile.Result) error

+ func (tc *TestCase) VerifyWantAbsent(c client.Client) error

+ func (tc *TestCase) VerifyWantEvent(eventRecorder *MockEventRecorder) error

+ func (tc *TestCase) VerifyWantPresent(c client.Client) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL