testing

package

Go to main page

Versions in this module

v0

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