testing

package
v0.0.0-...-c52b3dd Latest Latest
Warning

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

 Go to latest Published: Mar 3, 2020 License: Apache-2.0 Imports: 46 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeFactory 

func MakeFactory(ctor Ctor) Factory

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

func NewChannel 

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

NewChannel creates a Channel with ChannelOptions

func NewChannelWithoutNamespace 

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

NewChannelWithoutNamespace creates a Channel with ChannelOptions but without a specific namespace

func NewCloudAuditLogsSource 

func NewCloudAuditLogsSource(name, namespace string, opts ...CloudAuditLogsSourceOption) *v1alpha1.CloudAuditLogsSource

func NewCloudPubSubSource 

func NewCloudPubSubSource(name, namespace string, so ...CloudPubSubSourceOption) *v1alpha1.CloudPubSubSource

NewCloudPubSubSource creates a CloudPubSubSource with CloudPubSubSourceOptions

func NewCloudSchedulerSource 

func NewCloudSchedulerSource(name, namespace string, so ...CloudSchedulerSourceOption) *v1alpha1.CloudSchedulerSource

NewCloudSchedulerSource creates a CloudSchedulerSource with CloudSchedulerSourceOptions

func NewCloudStorageSource 

func NewCloudStorageSource(name, namespace string, so ...CloudStorageSourceOption) *v1alpha1.CloudStorageSource

NewCloudStorageSource creates a CloudStorageSource with CloudStorageSourceOptions

func NewDeployment 

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

NewDeployment creates a Deployment with DeploymentOptions.

func NewNamespace 

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

NewNamespace creates a Namespace with NamespaceOptions

func NewPullSubscription 

func NewPullSubscription(name, namespace string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription

NewPullSubscription creates a PullSubscription with PullSubscriptionOptions

func NewPullSubscriptionWithNoDefaults 

func NewPullSubscriptionWithNoDefaults(name, namespace string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription

NewPullSubscriptionWithNoDefaults creates a PullSubscription with PullSubscriptionOptions but does not set defaults.

func NewPullSubscriptionWithoutNamespace 

func NewPullSubscriptionWithoutNamespace(name string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription

NewPullSubscriptionWithoutNamespace creates a PullSubscription with PullSubscriptionOptions but without a specific namespace

func NewService 

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

NewService creates a Service with ServiceOptions

func NewTopic 

func NewTopic(name, namespace string, so ...TopicOption) *v1alpha1.Topic

NewTopic creates a Topic with TopicOptions

func NewUnstructured 

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

NewUnstructured creates a unstructured.Unstructured with UnstructuredOption

func WithChannelDefaults 

func WithChannelDefaults(s *v1alpha1.Channel)

func WithChannelDeleted 

func WithChannelDeleted(s *v1alpha1.Channel)

func WithCloudAuditLogsSourceDeletionTimestamp 

func WithCloudAuditLogsSourceDeletionTimestamp(s *v1alpha1.CloudAuditLogsSource)

func WithCloudSchedulerSourceDeletionTimestamp 

func WithCloudSchedulerSourceDeletionTimestamp(s *v1alpha1.CloudSchedulerSource)

func WithInitChannelConditions 

func WithInitChannelConditions(s *v1alpha1.Channel)

WithInitChannelConditions initializes the Channels's conditions.

func WithInitCloudAuditLogsSourceConditions 

func WithInitCloudAuditLogsSourceConditions(s *v1alpha1.CloudAuditLogsSource)

func WithInitCloudPubSubSourceConditions 

func WithInitCloudPubSubSourceConditions(ps *v1alpha1.CloudPubSubSource)

WithInitCloudPubSubSourceConditions initializes the CloudPubSubSource's conditions.

func WithInitCloudSchedulerSourceConditions 

func WithInitCloudSchedulerSourceConditions(s *v1alpha1.CloudSchedulerSource)

WithInitCloudSchedulerSourceConditions initializes the CloudSchedulerSources's conditions.

func WithInitCloudStorageSourceConditions 

func WithInitCloudStorageSourceConditions(s *v1alpha1.CloudStorageSource)

WithInitCloudStorageSourceConditions initializes the CloudStorageSources's conditions.

func WithInitPullSubscriptionConditions 

func WithInitPullSubscriptionConditions(s *v1alpha1.PullSubscription)

WithInitPullSubscriptionConditions initializes the PullSubscriptions's conditions.

func WithInitTopicConditions 

func WithInitTopicConditions(s *v1alpha1.Topic)

WithInitTopicConditions initializes the Topics's conditions.

func WithNamespaceDeleted 

func WithNamespaceDeleted(n *corev1.Namespace)

func WithPullSubscriptionDeleted 

func WithPullSubscriptionDeleted(s *v1alpha1.PullSubscription)

func WithPullSubscriptionMarkDeployed 

func WithPullSubscriptionMarkDeployed(ps *v1alpha1.PullSubscription)

func WithTopicDeleted 

func WithTopicDeleted(t *v1alpha1.Topic)

func WithTopicPublisherDeployed 

func WithTopicPublisherDeployed(s *v1alpha1.Topic)

Types

type ChannelOption 

type ChannelOption func(*v1alpha1.Channel)

ChannelOption enables further configuration of a Channel.

func WithChannelAddress 

func WithChannelAddress(url string) ChannelOption

func WithChannelGenerateName 

func WithChannelGenerateName(generateName string) ChannelOption

func WithChannelLabels 

func WithChannelLabels(labels map[string]string) ChannelOption

func WithChannelOwnerReferences 

func WithChannelOwnerReferences(ownerReferences []metav1.OwnerReference) ChannelOption

func WithChannelReady 

func WithChannelReady(topicID string) ChannelOption

func WithChannelSpec 

func WithChannelSpec(spec v1alpha1.ChannelSpec) ChannelOption

func WithChannelSubscribers 

func WithChannelSubscribers(subscribers []duckv1alpha1.SubscriberSpec) ChannelOption

func WithChannelSubscribersStatus 

func WithChannelSubscribersStatus(subscribers []duckv1alpha1.SubscriberStatus) ChannelOption

func WithChannelTopic 

func WithChannelTopic(topicID string) ChannelOption

func WithChannelTopicFailed 

func WithChannelTopicFailed(reason, message string) ChannelOption

func WithChannelTopicID 

func WithChannelTopicID(topicID string) ChannelOption

func WithChannelTopicUnknown 

func WithChannelTopicUnknown(reason, message string) ChannelOption

func WithChannelUID 

func WithChannelUID(uid types.UID) ChannelOption

type CloudAuditLogsSourceOption 

type CloudAuditLogsSourceOption func(*v1alpha1.CloudAuditLogsSource)

func WithCloudAuditLogsSourceFinalizers 

func WithCloudAuditLogsSourceFinalizers(finalizers ...string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceMethodName 

func WithCloudAuditLogsSourceMethodName(methodName string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceProject 

func WithCloudAuditLogsSourceProject(project string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceProjectID 

func WithCloudAuditLogsSourceProjectID(projectID string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourcePullSubscriptionFailed 

func WithCloudAuditLogsSourcePullSubscriptionFailed(reason, message string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourcePullSubscriptionReady 

func WithCloudAuditLogsSourcePullSubscriptionReady() CloudAuditLogsSourceOption

func WithCloudAuditLogsSourcePullSubscriptionUnknown 

func WithCloudAuditLogsSourcePullSubscriptionUnknown(reason, message string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceResourceName 

func WithCloudAuditLogsSourceResourceName(resourceName string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceServiceName 

func WithCloudAuditLogsSourceServiceName(serviceName string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSink 

func WithCloudAuditLogsSourceSink(gvk metav1.GroupVersionKind, name string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSinkID 

func WithCloudAuditLogsSourceSinkID(sinkID string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSinkNotReady 

func WithCloudAuditLogsSourceSinkNotReady(reason, messageFmt string, messageA ...interface{}) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSinkReady 

func WithCloudAuditLogsSourceSinkReady() CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSinkURI 

func WithCloudAuditLogsSourceSinkURI(url *apis.URL) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceTopicFailed 

func WithCloudAuditLogsSourceTopicFailed(reason, message string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceTopicReady 

func WithCloudAuditLogsSourceTopicReady(topicID string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceTopicUnknown 

func WithCloudAuditLogsSourceTopicUnknown(reason, message string) CloudAuditLogsSourceOption

type CloudPubSubSourceOption 

type CloudPubSubSourceOption func(*v1alpha1.CloudPubSubSource)

CloudPubSubSourceOption enables further configuration of a CloudPubSubSource.

func WithCloudPubSubSourceFinalizers 

func WithCloudPubSubSourceFinalizers(finalizers ...string) CloudPubSubSourceOption

func WithCloudPubSubSourceObjectMetaGeneration 

func WithCloudPubSubSourceObjectMetaGeneration(generation int64) CloudPubSubSourceOption

func WithCloudPubSubSourcePullSubscriptionFailed 

func WithCloudPubSubSourcePullSubscriptionFailed(reason, message string) CloudPubSubSourceOption

WithCloudPubSubSourcePullSubscriptionFailed marks the condition that the status of PullSubscription is False

func WithCloudPubSubSourcePullSubscriptionReady 

func WithCloudPubSubSourcePullSubscriptionReady() CloudPubSubSourceOption

WithCloudPubSubSourcePullSubscriptionReady marks the condition that the topic is not ready

func WithCloudPubSubSourcePullSubscriptionUnknown 

func WithCloudPubSubSourcePullSubscriptionUnknown(reason, message string) CloudPubSubSourceOption

WithCloudPubSubSourcePullSubscriptionUnknown marks the condition that the topic is Unknown

func WithCloudPubSubSourceSink 

func WithCloudPubSubSourceSink(gvk metav1.GroupVersionKind, name string) CloudPubSubSourceOption

func WithCloudPubSubSourceSinkURI 

func WithCloudPubSubSourceSinkURI(url *apis.URL) CloudPubSubSourceOption

WithCloudPubSubSourceSinkURI sets the status for sink URI

func WithCloudPubSubSourceStatusObservedGeneration 

func WithCloudPubSubSourceStatusObservedGeneration(generation int64) CloudPubSubSourceOption

func WithCloudPubSubSourceTopic 

func WithCloudPubSubSourceTopic(topicID string) CloudPubSubSourceOption

type CloudSchedulerSourceOption 

type CloudSchedulerSourceOption func(*v1alpha1.CloudSchedulerSource)

CloudSchedulerSourceOption enables further configuration of a CloudSchedulerSource.

func WithCloudSchedulerSourceData 

func WithCloudSchedulerSourceData(data string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceFinalizers 

func WithCloudSchedulerSourceFinalizers(finalizers ...string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceJobName 

func WithCloudSchedulerSourceJobName(jobName string) CloudSchedulerSourceOption

WithCloudSchedulerSourceJobName sets the status for job Name

func WithCloudSchedulerSourceJobNotReady 

func WithCloudSchedulerSourceJobNotReady(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourceJobNotReady marks the condition that the CloudSchedulerSource Job is not ready.

func WithCloudSchedulerSourceJobReady 

func WithCloudSchedulerSourceJobReady(jobName string) CloudSchedulerSourceOption

WithCloudSchedulerSourceJobReady marks the condition that the CloudSchedulerSource Job is ready and sets Status.JobName to jobName.

func WithCloudSchedulerSourceLocation 

func WithCloudSchedulerSourceLocation(location string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceProject 

func WithCloudSchedulerSourceProject(project string) CloudSchedulerSourceOption

func WithCloudSchedulerSourcePullSubscriptionFailed 

func WithCloudSchedulerSourcePullSubscriptionFailed(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourcePullSubscriptionFailed marks the condition that the topic is False.

func WithCloudSchedulerSourcePullSubscriptionReady 

func WithCloudSchedulerSourcePullSubscriptionReady() CloudSchedulerSourceOption

WithCloudSchedulerSourcePullSubscriptionReady marks the condition that the topic is ready.

func WithCloudSchedulerSourcePullSubscriptionUnknown 

func WithCloudSchedulerSourcePullSubscriptionUnknown(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourcePullSubscriptionUnknown marks the condition that the topic is Unknown.

func WithCloudSchedulerSourceSchedule 

func WithCloudSchedulerSourceSchedule(schedule string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceSink 

func WithCloudSchedulerSourceSink(gvk metav1.GroupVersionKind, name string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceSinkURI 

func WithCloudSchedulerSourceSinkURI(url *apis.URL) CloudSchedulerSourceOption

WithCloudSchedulerSourceSinkURI sets the status for sink URI

func WithCloudSchedulerSourceTopicFailed 

func WithCloudSchedulerSourceTopicFailed(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourceTopicFailed marks the condition that the status of topic is False.

func WithCloudSchedulerSourceTopicReady 

func WithCloudSchedulerSourceTopicReady(topicID, projectID string) CloudSchedulerSourceOption

WithCloudSchedulerSourceTopicNotReady marks the condition that the topic is not ready.

func WithCloudSchedulerSourceTopicUnknown 

func WithCloudSchedulerSourceTopicUnknown(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourceTopicUnknown marks the condition that the status of topic is Unknown.

type CloudStorageSourceOption 

type CloudStorageSourceOption func(*v1alpha1.CloudStorageSource)

CloudStorageSourceOption enables further configuration of a CloudStorageSource.

func WithCloudStorageSourceBucket 

func WithCloudStorageSourceBucket(bucket string) CloudStorageSourceOption

func WithCloudStorageSourceEventTypes 

func WithCloudStorageSourceEventTypes(eventTypes []string) CloudStorageSourceOption

func WithCloudStorageSourceFinalizers 

func WithCloudStorageSourceFinalizers(finalizers ...string) CloudStorageSourceOption

func WithCloudStorageSourceNotificationID 

func WithCloudStorageSourceNotificationID(notificationID string) CloudStorageSourceOption

WithCloudStorageSourceNotificationId sets the status for Notification ID

func WithCloudStorageSourceNotificationNotReady 

func WithCloudStorageSourceNotificationNotReady(reason, message string) CloudStorageSourceOption

WithCloudStorageSourceNotificationNotReady marks the condition that the GCS Notification is not ready.

func WithCloudStorageSourceNotificationReady 

func WithCloudStorageSourceNotificationReady(notificationID string) CloudStorageSourceOption

WithCloudStorageSourceNotificationReady marks the condition that the GCS Notification is ready.

func WithCloudStorageSourceObjectMetaGeneration 

func WithCloudStorageSourceObjectMetaGeneration(generation int64) CloudStorageSourceOption

func WithCloudStorageSourceProject 

func WithCloudStorageSourceProject(project string) CloudStorageSourceOption

func WithCloudStorageSourceProjectID 

func WithCloudStorageSourceProjectID(projectID string) CloudStorageSourceOption

WithCloudStorageSourceProjectId sets the status for Project ID

func WithCloudStorageSourcePullSubscriptionFailed 

func WithCloudStorageSourcePullSubscriptionFailed(reason, message string) CloudStorageSourceOption

WithCloudStorageSourcePullSubscriptionFailed marks the condition that the status of topic is False

func WithCloudStorageSourcePullSubscriptionReady 

func WithCloudStorageSourcePullSubscriptionReady() CloudStorageSourceOption

WithCloudStorageSourcePullSubscriptionReady marks the condition that the topic is ready.

func WithCloudStorageSourcePullSubscriptionUnknown 

func WithCloudStorageSourcePullSubscriptionUnknown(reason, message string) CloudStorageSourceOption

WithCloudStorageSourcePullSubscriptionUnknown marks the condition that the status of topic is Unknown.

func WithCloudStorageSourceSink 

func WithCloudStorageSourceSink(gvk metav1.GroupVersionKind, name string) CloudStorageSourceOption

func WithCloudStorageSourceSinkURI 

func WithCloudStorageSourceSinkURI(url *apis.URL) CloudStorageSourceOption

WithCloudStorageSourceSinkURI sets the status for sink URI

func WithCloudStorageSourceStatusObservedGeneration 

func WithCloudStorageSourceStatusObservedGeneration(generation int64) CloudStorageSourceOption

func WithCloudStorageSourceTopicFailed 

func WithCloudStorageSourceTopicFailed(reason, message string) CloudStorageSourceOption

WithCloudStorageSourceTopicFailed marks the condition that the topic is False

func WithCloudStorageSourceTopicID 

func WithCloudStorageSourceTopicID(topicID string) CloudStorageSourceOption

func WithCloudStorageSourceTopicReady 

func WithCloudStorageSourceTopicReady(topicID string) CloudStorageSourceOption

WithCloudStorageSourceTopicNotReady marks the condition that the topic is not ready

func WithCloudStorageSourceTopicUnknown 

func WithCloudStorageSourceTopicUnknown(reason, message string) CloudStorageSourceOption

WithCloudStorageSourceTopicUnknown marks the condition that the topic is False

func WithDeletionTimestamp 

func WithDeletionTimestamp() CloudStorageSourceOption

type Ctor 

type Ctor func(context.Context, *Listers, configmap.Watcher, map[string]interface{}) controller.Reconciler

Ctor functions create a k8s controller with given params.

type DeploymentOption 

type DeploymentOption func(*appsv1.Deployment)

DeploymentOption enables further configuration of a Deployment.

func WithDeploymentAnnotations 

func WithDeploymentAnnotations(annotations map[string]string) DeploymentOption

func WithDeploymentContainer 

func WithDeploymentContainer(name, image string, 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 Listers 

type Listers struct {
	servingv1alpha1listers.ConfigurationLister
	// contains filtered or unexported fields
}

func NewListers 

func NewListers(objs []runtime.Object) Listers

func (*Listers) GetAllObjects 

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

func (*Listers) GetChannelLister 

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

func (*Listers) GetCloudAuditLogsSourceLister 

func (l *Listers) GetCloudAuditLogsSourceLister() eventslisters.CloudAuditLogsSourceLister

func (*Listers) GetCloudPubSubSourceLister 

func (l *Listers) GetCloudPubSubSourceLister() eventslisters.CloudPubSubSourceLister

func (*Listers) GetCloudSchedulerSourceLister 

func (l *Listers) GetCloudSchedulerSourceLister() eventslisters.CloudSchedulerSourceLister

func (*Listers) GetCloudStorageSourceLister 

func (l *Listers) GetCloudStorageSourceLister() eventslisters.CloudStorageSourceLister

func (*Listers) GetConfigMapLister 

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

func (*Listers) GetDeploymentLister 

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

func (*Listers) GetEndpointsLister 

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

func (*Listers) GetEventsObjects 

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

func (*Listers) GetJobLister 

func (l *Listers) GetJobLister() batchv1listers.JobLister

func (*Listers) GetK8sServiceLister 

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

func (*Listers) GetKubeObjects 

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

func (*Listers) GetNamespaceLister 

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

func (*Listers) GetPullSubscriptionLister 

func (l *Listers) GetPullSubscriptionLister() pubsublisters.PullSubscriptionLister

func (*Listers) GetRoleBindingLister 

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

func (*Listers) GetServiceAccountLister 

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

func (*Listers) GetServingObjects 

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

func (*Listers) GetSinkObjects 

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

func (*Listers) GetTopicLister 

func (l *Listers) GetTopicLister() pubsublisters.TopicLister

func (*Listers) GetV1ServiceLister 

func (l *Listers) GetV1ServiceLister() servingv1listers.ServiceLister

func (*Listers) GetV1alpha1ServiceLister 

func (l *Listers) GetV1alpha1ServiceLister() servingv1alpha1listers.ServiceLister

func (*Listers) GetV1beta1ServiceLister 

func (l *Listers) GetV1beta1ServiceLister() servingv1beta1listers.ServiceLister

type NamespaceOption 

type NamespaceOption func(*corev1.Namespace)

NamespaceOption enables further configuration of a Namespace.

func WithNamespaceLabeled 

func WithNamespaceLabeled(labels map[string]string) NamespaceOption

type PullSubscriptionOption 

type PullSubscriptionOption func(*v1alpha1.PullSubscription)

PullSubscriptionOption enables further configuration of a PullSubscription.

func WithPullSubscriptionAnnotations 

func WithPullSubscriptionAnnotations(annotations map[string]string) PullSubscriptionOption

func WithPullSubscriptionFailed 

func WithPullSubscriptionFailed() PullSubscriptionOption

func WithPullSubscriptionFinalizers 

func WithPullSubscriptionFinalizers(finalizers ...string) PullSubscriptionOption

func WithPullSubscriptionGenerateName 

func WithPullSubscriptionGenerateName(generateName string) PullSubscriptionOption

func WithPullSubscriptionJobFailure 

func WithPullSubscriptionJobFailure(subscriptionID, reason, message string) PullSubscriptionOption

func WithPullSubscriptionLabels 

func WithPullSubscriptionLabels(labels map[string]string) PullSubscriptionOption

func WithPullSubscriptionMarkNoSubscription 

func WithPullSubscriptionMarkNoSubscription(reason, message string) PullSubscriptionOption

func WithPullSubscriptionMarkNoTransformer 

func WithPullSubscriptionMarkNoTransformer(reason, message string) PullSubscriptionOption

func WithPullSubscriptionMarkSink 

func WithPullSubscriptionMarkSink(uri string) PullSubscriptionOption

func WithPullSubscriptionMarkSubscribed 

func WithPullSubscriptionMarkSubscribed(subscriptionID string) PullSubscriptionOption

func WithPullSubscriptionMarkTransformer 

func WithPullSubscriptionMarkTransformer(uri string) PullSubscriptionOption

func WithPullSubscriptionMode 

func WithPullSubscriptionMode(mode v1alpha1.ModeType) PullSubscriptionOption

func WithPullSubscriptionObjectMetaGeneration 

func WithPullSubscriptionObjectMetaGeneration(generation int64) PullSubscriptionOption

func WithPullSubscriptionOwnerReferences 

func WithPullSubscriptionOwnerReferences(ownerReferences []metav1.OwnerReference) PullSubscriptionOption

func WithPullSubscriptionProjectID 

func WithPullSubscriptionProjectID(projectID string) PullSubscriptionOption

func WithPullSubscriptionReady 

func WithPullSubscriptionReady(sink string) PullSubscriptionOption

func WithPullSubscriptionReadyStatus 

func WithPullSubscriptionReadyStatus(status corev1.ConditionStatus, reason, message string) PullSubscriptionOption

func WithPullSubscriptionSink 

func WithPullSubscriptionSink(gvk metav1.GroupVersionKind, name string) PullSubscriptionOption

func WithPullSubscriptionSinkNotFound 

func WithPullSubscriptionSinkNotFound() PullSubscriptionOption

func WithPullSubscriptionSpec 

func WithPullSubscriptionSpec(spec v1alpha1.PullSubscriptionSpec) PullSubscriptionOption

func WithPullSubscriptionSpecWithNoDefaults 

func WithPullSubscriptionSpecWithNoDefaults(spec v1alpha1.PullSubscriptionSpec) PullSubscriptionOption

Same as withPullSubscriptionSpec but does not set defaults

func WithPullSubscriptionStatusObservedGeneration 

func WithPullSubscriptionStatusObservedGeneration(generation int64) PullSubscriptionOption

func WithPullSubscriptionSubscriptionID 

func WithPullSubscriptionSubscriptionID(subscriptionID string) PullSubscriptionOption

func WithPullSubscriptionTransformer 

func WithPullSubscriptionTransformer(gvk metav1.GroupVersionKind, name string) PullSubscriptionOption

func WithPullSubscriptionTransformerURI 

func WithPullSubscriptionTransformerURI(uri string) PullSubscriptionOption

func WithPullSubscriptionUID 

func WithPullSubscriptionUID(uid types.UID) PullSubscriptionOption

func WithPullSubscriptionUnknown 

func WithPullSubscriptionUnknown() PullSubscriptionOption

type ServiceOption 

type ServiceOption func(*corev1.Service)

ServiceOption enables further configuration of a Service.

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 TopicOption 

type TopicOption func(*v1alpha1.Topic)

TopicOption enables further configuration of a Topic.

func WithTopicAddress 

func WithTopicAddress(uri string) TopicOption

func WithTopicFailed 

func WithTopicFailed() TopicOption

func WithTopicFinalizers 

func WithTopicFinalizers(finalizers ...string) TopicOption

func WithTopicJobFailure 

func WithTopicJobFailure(topicID, reason, message string) TopicOption

func WithTopicLabels 

func WithTopicLabels(labels map[string]string) TopicOption

func WithTopicNoTopic 

func WithTopicNoTopic(reason, message string) TopicOption

func WithTopicOwnerReferences 

func WithTopicOwnerReferences(ownerReferences []metav1.OwnerReference) TopicOption

func WithTopicProjectID 

func WithTopicProjectID(projectID string) TopicOption

func WithTopicPropagationPolicy 

func WithTopicPropagationPolicy(policy string) TopicOption

func WithTopicPublisherNotConfigured 

func WithTopicPublisherNotConfigured() TopicOption

func WithTopicPublisherNotDeployed 

func WithTopicPublisherNotDeployed(reason, message string) TopicOption

func WithTopicPublisherUnknown 

func WithTopicPublisherUnknown(reason, message string) TopicOption

func WithTopicReady 

func WithTopicReady(topicID string) TopicOption

func WithTopicSpec 

func WithTopicSpec(spec v1alpha1.TopicSpec) TopicOption

func WithTopicTopicDeleted 

func WithTopicTopicDeleted(topicID string) TopicOption

func WithTopicTopicID 

func WithTopicTopicID(topicID string) TopicOption

func WithTopicUID 

func WithTopicUID(uid types.UID) TopicOption

func WithTopicUnknown 

func WithTopicUnknown() TopicOption

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.