testing

package
v0.13.2 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2020 License: Apache-2.0 Imports: 46 Imported by: 6

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

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

func NewCloudPubSubSource added in v0.12.0 

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

NewCloudPubSubSource creates a CloudPubSubSource with CloudPubSubSourceOptions

func NewCloudSchedulerSource added in v0.12.0 

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

NewCloudSchedulerSource creates a CloudSchedulerSource with CloudSchedulerSourceOptions

func NewCloudStorageSource added in v0.12.0 

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

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

func WithCloudAuditLogsSourceDeletionTimestamp(s *v1alpha1.CloudAuditLogsSource)

func WithCloudSchedulerSourceDeletionTimestamp added in v0.12.0 

func WithCloudSchedulerSourceDeletionTimestamp(s *v1alpha1.CloudSchedulerSource)

func WithInitChannelConditions 

func WithInitChannelConditions(s *v1alpha1.Channel)

WithInitChannelConditions initializes the Channels's conditions.

func WithInitCloudAuditLogsSourceConditions added in v0.12.0 

func WithInitCloudAuditLogsSourceConditions(s *v1alpha1.CloudAuditLogsSource)

func WithInitCloudPubSubSourceConditions added in v0.12.0 

func WithInitCloudPubSubSourceConditions(ps *v1alpha1.CloudPubSubSource)

WithInitCloudPubSubSourceConditions initializes the CloudPubSubSource's conditions.

func WithInitCloudSchedulerSourceConditions added in v0.12.0 

func WithInitCloudSchedulerSourceConditions(s *v1alpha1.CloudSchedulerSource)

WithInitCloudSchedulerSourceConditions initializes the CloudSchedulerSources's conditions.

func WithInitCloudStorageSourceConditions added in v0.12.0 

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

func WithPullSubscriptionMarkDeployed(ps *v1alpha1.PullSubscription)

func WithTopicDeleted 

func WithTopicDeleted(t *v1alpha1.Topic)

func WithTopicPublisherDeployed added in v0.12.2 

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

func WithChannelTopicFailed(reason, message string) ChannelOption

func WithChannelTopicID added in v0.12.0 

func WithChannelTopicID(topicID string) ChannelOption

func WithChannelTopicUnknown added in v0.12.0 

func WithChannelTopicUnknown(reason, message string) ChannelOption

func WithChannelUID 

func WithChannelUID(uid types.UID) ChannelOption

type CloudAuditLogsSourceOption added in v0.12.0 

type CloudAuditLogsSourceOption func(*v1alpha1.CloudAuditLogsSource)

func WithCloudAuditLogsSourceFinalizers added in v0.12.0 

func WithCloudAuditLogsSourceFinalizers(finalizers ...string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceMethodName added in v0.12.0 

func WithCloudAuditLogsSourceMethodName(methodName string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceProject added in v0.12.0 

func WithCloudAuditLogsSourceProject(project string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceProjectID added in v0.12.0 

func WithCloudAuditLogsSourceProjectID(projectID string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourcePullSubscriptionFailed added in v0.12.0 

func WithCloudAuditLogsSourcePullSubscriptionFailed(reason, message string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourcePullSubscriptionReady added in v0.12.0 

func WithCloudAuditLogsSourcePullSubscriptionReady() CloudAuditLogsSourceOption

func WithCloudAuditLogsSourcePullSubscriptionUnknown added in v0.12.0 

func WithCloudAuditLogsSourcePullSubscriptionUnknown(reason, message string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceResourceName added in v0.12.0 

func WithCloudAuditLogsSourceResourceName(resourceName string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceServiceName added in v0.12.0 

func WithCloudAuditLogsSourceServiceName(serviceName string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSink added in v0.12.0 

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

func WithCloudAuditLogsSourceSinkID added in v0.12.0 

func WithCloudAuditLogsSourceSinkID(sinkID string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSinkNotReady added in v0.12.0 

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

func WithCloudAuditLogsSourceSinkReady added in v0.12.0 

func WithCloudAuditLogsSourceSinkReady() CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSinkURI added in v0.12.0 

func WithCloudAuditLogsSourceSinkURI(url *apis.URL) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceTopicFailed added in v0.12.0 

func WithCloudAuditLogsSourceTopicFailed(reason, message string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceTopicReady added in v0.12.0 

func WithCloudAuditLogsSourceTopicReady(topicID string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceTopicUnknown added in v0.12.0 

func WithCloudAuditLogsSourceTopicUnknown(reason, message string) CloudAuditLogsSourceOption

type CloudPubSubSourceOption added in v0.12.0 

type CloudPubSubSourceOption func(*v1alpha1.CloudPubSubSource)

CloudPubSubSourceOption enables further configuration of a CloudPubSubSource.

func WithCloudPubSubSourceFinalizers added in v0.12.0 

func WithCloudPubSubSourceFinalizers(finalizers ...string) CloudPubSubSourceOption

func WithCloudPubSubSourceObjectMetaGeneration added in v0.12.0 

func WithCloudPubSubSourceObjectMetaGeneration(generation int64) CloudPubSubSourceOption

func WithCloudPubSubSourcePullSubscriptionFailed added in v0.12.0 

func WithCloudPubSubSourcePullSubscriptionFailed(reason, message string) CloudPubSubSourceOption

WithCloudPubSubSourcePullSubscriptionFailed marks the condition that the status of PullSubscription is False

func WithCloudPubSubSourcePullSubscriptionReady added in v0.12.0 

func WithCloudPubSubSourcePullSubscriptionReady() CloudPubSubSourceOption

WithCloudPubSubSourcePullSubscriptionReady marks the condition that the topic is not ready

func WithCloudPubSubSourcePullSubscriptionUnknown added in v0.12.0 

func WithCloudPubSubSourcePullSubscriptionUnknown(reason, message string) CloudPubSubSourceOption

WithCloudPubSubSourcePullSubscriptionUnknown marks the condition that the topic is Unknown

func WithCloudPubSubSourceSink added in v0.12.0 

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

func WithCloudPubSubSourceSinkURI added in v0.12.0 

func WithCloudPubSubSourceSinkURI(url *apis.URL) CloudPubSubSourceOption

WithCloudPubSubSourceSinkURI sets the status for sink URI

func WithCloudPubSubSourceStatusObservedGeneration added in v0.12.0 

func WithCloudPubSubSourceStatusObservedGeneration(generation int64) CloudPubSubSourceOption

func WithCloudPubSubSourceTopic added in v0.12.0 

func WithCloudPubSubSourceTopic(topicID string) CloudPubSubSourceOption

type CloudSchedulerSourceOption added in v0.12.0 

type CloudSchedulerSourceOption func(*v1alpha1.CloudSchedulerSource)

CloudSchedulerSourceOption enables further configuration of a CloudSchedulerSource.

func WithCloudSchedulerSourceData added in v0.12.0 

func WithCloudSchedulerSourceData(data string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceFinalizers added in v0.12.0 

func WithCloudSchedulerSourceFinalizers(finalizers ...string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceJobName added in v0.12.0 

func WithCloudSchedulerSourceJobName(jobName string) CloudSchedulerSourceOption

WithCloudSchedulerSourceJobName sets the status for job Name

func WithCloudSchedulerSourceJobNotReady added in v0.12.0 

func WithCloudSchedulerSourceJobNotReady(reason, message string) CloudSchedulerSourceOption

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

func WithCloudSchedulerSourceJobReady added in v0.12.0 

func WithCloudSchedulerSourceJobReady(jobName string) CloudSchedulerSourceOption

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

func WithCloudSchedulerSourceLocation added in v0.12.0 

func WithCloudSchedulerSourceLocation(location string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceProject added in v0.12.0 

func WithCloudSchedulerSourceProject(project string) CloudSchedulerSourceOption

func WithCloudSchedulerSourcePullSubscriptionFailed added in v0.12.0 

func WithCloudSchedulerSourcePullSubscriptionFailed(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourcePullSubscriptionFailed marks the condition that the topic is False.

func WithCloudSchedulerSourcePullSubscriptionReady added in v0.12.0 

func WithCloudSchedulerSourcePullSubscriptionReady() CloudSchedulerSourceOption

WithCloudSchedulerSourcePullSubscriptionReady marks the condition that the topic is ready.

func WithCloudSchedulerSourcePullSubscriptionUnknown added in v0.12.0 

func WithCloudSchedulerSourcePullSubscriptionUnknown(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourcePullSubscriptionUnknown marks the condition that the topic is Unknown.

func WithCloudSchedulerSourceSchedule added in v0.12.0 

func WithCloudSchedulerSourceSchedule(schedule string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceSink added in v0.12.0 

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

func WithCloudSchedulerSourceSinkURI added in v0.12.0 

func WithCloudSchedulerSourceSinkURI(url *apis.URL) CloudSchedulerSourceOption

WithCloudSchedulerSourceSinkURI sets the status for sink URI

func WithCloudSchedulerSourceTopicFailed added in v0.12.0 

func WithCloudSchedulerSourceTopicFailed(reason, message string) CloudSchedulerSourceOption

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

func WithCloudSchedulerSourceTopicReady added in v0.12.0 

func WithCloudSchedulerSourceTopicReady(topicID, projectID string) CloudSchedulerSourceOption

WithCloudSchedulerSourceTopicNotReady marks the condition that the topic is not ready.

func WithCloudSchedulerSourceTopicUnknown added in v0.12.0 

func WithCloudSchedulerSourceTopicUnknown(reason, message string) CloudSchedulerSourceOption

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

type CloudStorageSourceOption added in v0.12.0 

type CloudStorageSourceOption func(*v1alpha1.CloudStorageSource)

CloudStorageSourceOption enables further configuration of a CloudStorageSource.

func WithCloudStorageSourceBucket added in v0.12.0 

func WithCloudStorageSourceBucket(bucket string) CloudStorageSourceOption

func WithCloudStorageSourceEventTypes added in v0.12.0 

func WithCloudStorageSourceEventTypes(eventTypes []string) CloudStorageSourceOption

func WithCloudStorageSourceFinalizers added in v0.12.0 

func WithCloudStorageSourceFinalizers(finalizers ...string) CloudStorageSourceOption

func WithCloudStorageSourceNotificationID added in v0.12.0 

func WithCloudStorageSourceNotificationID(notificationID string) CloudStorageSourceOption

WithCloudStorageSourceNotificationId sets the status for Notification ID

func WithCloudStorageSourceNotificationNotReady added in v0.12.0 

func WithCloudStorageSourceNotificationNotReady(reason, message string) CloudStorageSourceOption

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

func WithCloudStorageSourceNotificationReady added in v0.12.0 

func WithCloudStorageSourceNotificationReady(notificationID string) CloudStorageSourceOption

WithCloudStorageSourceNotificationReady marks the condition that the GCS Notification is ready.

func WithCloudStorageSourceObjectMetaGeneration added in v0.12.0 

func WithCloudStorageSourceObjectMetaGeneration(generation int64) CloudStorageSourceOption

func WithCloudStorageSourceProject added in v0.12.0 

func WithCloudStorageSourceProject(project string) CloudStorageSourceOption

func WithCloudStorageSourceProjectID added in v0.12.0 

func WithCloudStorageSourceProjectID(projectID string) CloudStorageSourceOption

WithCloudStorageSourceProjectId sets the status for Project ID

func WithCloudStorageSourcePullSubscriptionFailed added in v0.12.0 

func WithCloudStorageSourcePullSubscriptionFailed(reason, message string) CloudStorageSourceOption

WithCloudStorageSourcePullSubscriptionFailed marks the condition that the status of topic is False

func WithCloudStorageSourcePullSubscriptionReady added in v0.12.0 

func WithCloudStorageSourcePullSubscriptionReady() CloudStorageSourceOption

WithCloudStorageSourcePullSubscriptionReady marks the condition that the topic is ready.

func WithCloudStorageSourcePullSubscriptionUnknown added in v0.12.0 

func WithCloudStorageSourcePullSubscriptionUnknown(reason, message string) CloudStorageSourceOption

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

func WithCloudStorageSourceSink added in v0.12.0 

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

func WithCloudStorageSourceSinkURI added in v0.12.0 

func WithCloudStorageSourceSinkURI(url *apis.URL) CloudStorageSourceOption

WithCloudStorageSourceSinkURI sets the status for sink URI

func WithCloudStorageSourceStatusObservedGeneration added in v0.12.0 

func WithCloudStorageSourceStatusObservedGeneration(generation int64) CloudStorageSourceOption

func WithCloudStorageSourceTopicFailed added in v0.12.0 

func WithCloudStorageSourceTopicFailed(reason, message string) CloudStorageSourceOption

WithCloudStorageSourceTopicFailed marks the condition that the topic is False

func WithCloudStorageSourceTopicID added in v0.12.0 

func WithCloudStorageSourceTopicID(topicID string) CloudStorageSourceOption

func WithCloudStorageSourceTopicReady added in v0.12.0 

func WithCloudStorageSourceTopicReady(topicID string) CloudStorageSourceOption

WithCloudStorageSourceTopicNotReady marks the condition that the topic is not ready

func WithCloudStorageSourceTopicUnknown added in v0.12.0 

func WithCloudStorageSourceTopicUnknown(reason, message string) CloudStorageSourceOption

WithCloudStorageSourceTopicUnknown marks the condition that the topic is False

func WithDeletionTimestamp added in v0.10.0 

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

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

func (*Listers) GetCloudPubSubSourceLister added in v0.12.0 

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

func (*Listers) GetCloudSchedulerSourceLister added in v0.12.0 

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

func (*Listers) GetCloudStorageSourceLister added in v0.12.0 

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

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

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

func WithPullSubscriptionAnnotations(annotations map[string]string) PullSubscriptionOption

func WithPullSubscriptionFailed added in v0.12.0 

func WithPullSubscriptionFailed() PullSubscriptionOption

func WithPullSubscriptionFinalizers 

func WithPullSubscriptionFinalizers(finalizers ...string) PullSubscriptionOption

func WithPullSubscriptionGenerateName 

func WithPullSubscriptionGenerateName(generateName string) PullSubscriptionOption

func WithPullSubscriptionJobFailure added in v0.10.0 

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

func WithPullSubscriptionMarkNoTransformer(reason, message string) PullSubscriptionOption

func WithPullSubscriptionMarkSink 

func WithPullSubscriptionMarkSink(uri string) PullSubscriptionOption

func WithPullSubscriptionMarkSubscribed added in v0.12.0 

func WithPullSubscriptionMarkSubscribed(subscriptionID string) PullSubscriptionOption

func WithPullSubscriptionMarkTransformer added in v0.12.0 

func WithPullSubscriptionMarkTransformer(uri string) PullSubscriptionOption

func WithPullSubscriptionMode added in v0.12.1 

func WithPullSubscriptionMode(mode v1alpha1.ModeType) PullSubscriptionOption

func WithPullSubscriptionObjectMetaGeneration added in v0.10.0 

func WithPullSubscriptionObjectMetaGeneration(generation int64) PullSubscriptionOption

func WithPullSubscriptionOwnerReferences 

func WithPullSubscriptionOwnerReferences(ownerReferences []metav1.OwnerReference) PullSubscriptionOption

func WithPullSubscriptionProjectID added in v0.12.0 

func WithPullSubscriptionProjectID(projectID string) PullSubscriptionOption

func WithPullSubscriptionReady 

func WithPullSubscriptionReady(sink string) PullSubscriptionOption

func WithPullSubscriptionReadyStatus added in v0.10.0 

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

func WithPullSubscriptionSpecWithNoDefaults(spec v1alpha1.PullSubscriptionSpec) PullSubscriptionOption

Same as withPullSubscriptionSpec but does not set defaults

func WithPullSubscriptionStatusObservedGeneration added in v0.10.0 

func WithPullSubscriptionStatusObservedGeneration(generation int64) PullSubscriptionOption

func WithPullSubscriptionSubscriptionID added in v0.12.0 

func WithPullSubscriptionSubscriptionID(subscriptionID string) PullSubscriptionOption

func WithPullSubscriptionTransformer added in v0.12.0 

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

func WithPullSubscriptionTransformerURI added in v0.12.0 

func WithPullSubscriptionTransformerURI(uri string) PullSubscriptionOption

func WithPullSubscriptionUID 

func WithPullSubscriptionUID(uid types.UID) PullSubscriptionOption

func WithPullSubscriptionUnknown added in v0.12.0 

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

func WithTopicFailed() TopicOption

func WithTopicFinalizers 

func WithTopicFinalizers(finalizers ...string) TopicOption

func WithTopicJobFailure added in v0.10.0 

func WithTopicJobFailure(topicID, reason, message string) TopicOption

func WithTopicLabels 

func WithTopicLabels(labels map[string]string) TopicOption

func WithTopicNoTopic added in v0.12.0 

func WithTopicNoTopic(reason, message string) TopicOption

func WithTopicOwnerReferences 

func WithTopicOwnerReferences(ownerReferences []metav1.OwnerReference) TopicOption

func WithTopicProjectID added in v0.9.0 

func WithTopicProjectID(projectID string) TopicOption

func WithTopicPropagationPolicy 

func WithTopicPropagationPolicy(policy string) TopicOption

func WithTopicPublisherNotConfigured added in v0.12.2 

func WithTopicPublisherNotConfigured() TopicOption

func WithTopicPublisherNotDeployed added in v0.12.2 

func WithTopicPublisherNotDeployed(reason, message string) TopicOption

func WithTopicPublisherUnknown added in v0.12.2 

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

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.