testing

package
v0.15.0 Latest Latest
Warning

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

 Go to latest Published: May 27, 2020 License: Apache-2.0 Imports: 65 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var NoopIAMPolicyManager iam.IAMPolicyManager = noopManager(struct{}{})

Functions

func AvailableEndpoints added in v0.15.0 

func AvailableEndpoints() *corev1.Endpoints

func InjectPubsubClient added in v0.15.0 

func InjectPubsubClient(td map[string]interface{}, c *pubsub.Client)

func MakeFactory 

func MakeFactory(ctor Ctor) Factory

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

func NewBroker added in v0.15.0 

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

NewBroker creates a Broker with BrokerOptions. The Broker has the brokerv1beta1 broker class by default.

func NewBrokerCell added in v0.15.0 

func NewBrokerCell(name, namespace string, o ...BrokerCellOption) *intv1alpha1.BrokerCell

NewBrokerCell creates a BrokerCell with BrokerCellOptions.

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

func NewCloudBuildSource(name, namespace string, so ...CloudBuildSourceOption) *v1alpha1.CloudBuildSource

NewCloudBuildSource creates a CloudBuildSource with CloudBuildSourceOptions

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

func NewConfigMap(name, namespace string, cmo ...ConfigMapOption) *corev1.ConfigMap

NewConfigMap creates a ConfigMap with ConfigMapOptions.

func NewDeployment 

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

NewDeployment creates a Deployment with DeploymentOptions.

func NewEndpoints added in v0.15.0 

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

NewEndpoints creates a Endpoints with EndpointsOptions

func NewNamespace 

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

NewNamespace creates a Namespace with NamespaceOptions

func NewPubSubPullSubscription added in v0.15.0 

func NewPubSubPullSubscription(name, namespace string, so ...PubSubPullSubscriptionOption) *v1alpha1.PullSubscription

NewPubSubPullSubscription creates a PullSubscription with PullSubscriptionOptions

func NewPubSubPullSubscriptionWithNoDefaults added in v0.15.0 

func NewPubSubPullSubscriptionWithNoDefaults(name, namespace string, so ...PubSubPullSubscriptionOption) *v1alpha1.PullSubscription

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

func NewPubSubTopic added in v0.15.0 

func NewPubSubTopic(name, namespace string, so ...PubSubTopicOption) *v1alpha1.Topic

NewPubSubTopic creates a Topic with TopicOptions

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

func NewServiceAccount(name, namespace, gServiceAccount string, so ...ServiceAccountOption) *corev1.ServiceAccount

NewServiceAccount creates a ServiceAccount

func NewTopic 

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

NewTopic creates a Topic with TopicOptions

func NewTrigger added in v0.15.0 

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

NewTrigger creates a Trigger with TriggerOptions.

func NewUnstructured 

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

NewUnstructured creates a unstructured.Unstructured with UnstructuredOption

func NoSubscriptionsExist added in v0.15.0 

func NoSubscriptionsExist() func(*testing.T, *rtesting.TableRow)

func NoTopicsExist added in v0.15.0 

func NoTopicsExist() func(*testing.T, *rtesting.TableRow)

func OnlySubscriptions added in v0.15.0 

func OnlySubscriptions(ids ...string) func(*testing.T, *rtesting.TableRow)

func OnlyTopics added in v0.15.0 

func OnlyTopics(ids ...string) func(*testing.T, *rtesting.TableRow)

func SubscriptionExists added in v0.15.0 

func SubscriptionExists(id string) func(*testing.T, *rtesting.TableRow)

func TestPubsubClient added in v0.15.0 

func TestPubsubClient(ctx context.Context, projectID string) (*pubsub.Client, func())

func TopicExists added in v0.15.0 

func TopicExists(id string) func(*testing.T, *rtesting.TableRow)

func WithBrokerCellDeletionTimestamp added in v0.15.0 

func WithBrokerCellDeletionTimestamp(bc *intv1alpha1.BrokerCell)

func WithBrokerCellReady added in v0.15.0 

func WithBrokerCellReady(bc *intv1alpha1.BrokerCell)

func WithBrokerDeletionTimestamp added in v0.15.0 

func WithBrokerDeletionTimestamp(b *brokerv1beta1.Broker)

func WithBrokerSubscriptionReady added in v0.15.0 

func WithBrokerSubscriptionReady(b *brokerv1beta1.Broker)

func WithBrokerTopicReady added in v0.15.0 

func WithBrokerTopicReady(b *brokerv1beta1.Broker)

func WithChannelDefaults 

func WithChannelDefaults(s *v1alpha1.Channel)

func WithChannelDeleted 

func WithChannelDeleted(s *v1alpha1.Channel)

func WithChannelDeletionTimestamp added in v0.14.0 

func WithChannelDeletionTimestamp(s *v1alpha1.Channel)

func WithCloudAuditLogsSourceDeletionTimestamp added in v0.12.0 

func WithCloudAuditLogsSourceDeletionTimestamp(s *v1alpha1.CloudAuditLogsSource)

func WithCloudBuildSourceDeletionTimestamp added in v0.14.0 

func WithCloudBuildSourceDeletionTimestamp(s *v1alpha1.CloudBuildSource)

func WithCloudPubSubSourceDeletionTimestamp added in v0.14.0 

func WithCloudPubSubSourceDeletionTimestamp(s *v1alpha1.CloudPubSubSource)

func WithCloudSchedulerSourceDeletionTimestamp added in v0.12.0 

func WithCloudSchedulerSourceDeletionTimestamp(s *v1alpha1.CloudSchedulerSource)

func WithIngressAvailable added in v0.15.0 

func WithIngressAvailable(b *brokerv1beta1.Broker)

func WithInitBrokerCellConditions added in v0.15.0 

func WithInitBrokerCellConditions(bc *intv1alpha1.BrokerCell)

WithInitBrokerCellConditions initializes the BrokerCell's conditions.

func WithInitBrokerConditions added in v0.15.0 

func WithInitBrokerConditions(b *brokerv1beta1.Broker)

WithInitBrokerConditions initializes the Broker's conditions.

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

func WithInitCloudBuildSourceConditions(bs *v1alpha1.CloudBuildSource)

WithInitCloudBuildSourceConditions initializes the CloudBuildSource's conditions.

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

func WithInitTriggerConditions(t *brokerv1beta1.Trigger)

WithInitTriggerConditions initializes the Triggers's conditions.

func WithNamespaceDeleted 

func WithNamespaceDeleted(n *corev1.Namespace)

func WithPubSubInitPullSubscriptionConditions added in v0.15.0 

func WithPubSubInitPullSubscriptionConditions(s *v1alpha1.PullSubscription)

WithPubSubInitPullSubscriptionConditions initializes the PullSubscriptions's conditions.

func WithPubSubInitTopicConditions added in v0.15.0 

func WithPubSubInitTopicConditions(s *v1alpha1.Topic)

WithPubSubInitTopicConditions initializes the Topics's conditions.

func WithPubSubPullSubscriptionDeleted added in v0.15.0 

func WithPubSubPullSubscriptionDeleted(s *v1alpha1.PullSubscription)

func WithPubSubPullSubscriptionMarkDeployed added in v0.15.0 

func WithPubSubPullSubscriptionMarkDeployed(ps *v1alpha1.PullSubscription)

func WithPubSubTopicDeleted added in v0.15.0 

func WithPubSubTopicDeleted(t *v1alpha1.Topic)

func WithPubSubTopicPublisherDeployed added in v0.15.0 

func WithPubSubTopicPublisherDeployed(s *v1alpha1.Topic)

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)

func WithTriggerBrokerReady added in v0.15.0 

func WithTriggerBrokerReady(t *brokerv1beta1.Trigger)

WithTriggerBrokerReady initializes the Triggers's conditions as if its Broker were ready.

func WithTriggerDeletionTimestamp added in v0.15.0 

func WithTriggerDeletionTimestamp(t *brokerv1beta1.Trigger)

func WithTriggerDependencyReady added in v0.15.0 

func WithTriggerDependencyReady(t *brokerv1beta1.Trigger)

func WithTriggerSubscriberResolvedSucceeded added in v0.15.0 

func WithTriggerSubscriberResolvedSucceeded(t *brokerv1beta1.Trigger)

func WithTriggerSubscriptionReady added in v0.15.0 

func WithTriggerSubscriptionReady(t *brokerv1beta1.Trigger)

func WithTriggerTopicReady added in v0.15.0 

func WithTriggerTopicReady(t *brokerv1beta1.Trigger)

Types

type BrokerCellOption added in v0.15.0 

type BrokerCellOption func(*intv1alpha1.BrokerCell)

BrokerCellOption enables further configuration of a BrokerCell.

func WithBrokerCellFanoutAvailable added in v0.15.0 

func WithBrokerCellFanoutAvailable() BrokerCellOption

func WithBrokerCellFanoutFailed added in v0.15.0 

func WithBrokerCellFanoutFailed(reason, msg string) BrokerCellOption

func WithBrokerCellFinalizers added in v0.15.0 

func WithBrokerCellFinalizers(finalizers ...string) BrokerCellOption

func WithBrokerCellGeneration added in v0.15.0 

func WithBrokerCellGeneration(gen int64) BrokerCellOption

func WithBrokerCellIngressAvailable added in v0.15.0 

func WithBrokerCellIngressAvailable() BrokerCellOption

func WithBrokerCellIngressFailed added in v0.15.0 

func WithBrokerCellIngressFailed(reason, msg string) BrokerCellOption

func WithBrokerCellRetryAvailable added in v0.15.0 

func WithBrokerCellRetryAvailable() BrokerCellOption

func WithBrokerCellRetryFailed added in v0.15.0 

func WithBrokerCellRetryFailed(reason, msg string) BrokerCellOption

func WithBrokerCellStatusObservedGeneration added in v0.15.0 

func WithBrokerCellStatusObservedGeneration(gen int64) BrokerCellOption

func WithIngressTemplate added in v0.15.0 

func WithIngressTemplate(address string) BrokerCellOption

func WithTargetsCofigFailed added in v0.15.0 

func WithTargetsCofigFailed(reason, msg string) BrokerCellOption

func WithTargetsCofigReady added in v0.15.0 

func WithTargetsCofigReady() BrokerCellOption

type BrokerOption added in v0.15.0 

type BrokerOption func(*brokerv1beta1.Broker)

BrokerOption enables further configuration of a Broker.

func WithBrokerAddress added in v0.15.0 

func WithBrokerAddress(address string) BrokerOption

WithBrokerAddress sets the Broker's address.

func WithBrokerAddressURI added in v0.15.0 

func WithBrokerAddressURI(uri *apis.URL) BrokerOption

WithBrokerAddressURI sets the Broker's address as URI.

func WithBrokerClass added in v0.15.0 

func WithBrokerClass(bc string) BrokerOption

func WithBrokerFinalizers added in v0.15.0 

func WithBrokerFinalizers(finalizers ...string) BrokerOption

func WithBrokerGeneration added in v0.15.0 

func WithBrokerGeneration(gen int64) BrokerOption

func WithBrokerReady added in v0.15.0 

func WithBrokerReady(address string) BrokerOption

func WithBrokerReadyURI added in v0.15.0 

func WithBrokerReadyURI(address *apis.URL) BrokerOption

WithBrokerReadyURI is a convenience function that sets all ready conditions to true.

func WithBrokerResourceVersion added in v0.15.0 

func WithBrokerResourceVersion(rv string) BrokerOption

func WithBrokerStatusObservedGeneration added in v0.15.0 

func WithBrokerStatusObservedGeneration(gen int64) BrokerOption

func WithBrokerUID added in v0.15.0 

func WithBrokerUID(uid string) BrokerOption

func WithIngressFailed added in v0.15.0 

func WithIngressFailed(reason, msg string) BrokerOption

WithIngressFailed calls .Status.MarkIngressFailed on the Broker.

type ChannelOption 

type ChannelOption func(*v1alpha1.Channel)

ChannelOption enables further configuration of a Channel.

func WithChannelAddress 

func WithChannelAddress(url string) ChannelOption

func WithChannelAnnotations added in v0.15.0 

func WithChannelAnnotations(Annotations map[string]string) ChannelOption

func WithChannelGCPServiceAccount added in v0.14.0 

func WithChannelGCPServiceAccount(gServiceAccount 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 WithChannelServiceAccountName added in v0.14.0 

func WithChannelServiceAccountName(name string) ChannelOption

WithChannelServiceAccountName will give status.ServiceAccountName a k8s service account name, which is related on Workload Identity's Google service account.

func WithChannelSpec 

func WithChannelSpec(spec v1alpha1.ChannelSpec) ChannelOption

func WithChannelSubscribers 

func WithChannelSubscribers(subscribers []duckv1alpha1.SubscriberSpec) ChannelOption

func WithChannelSubscribersStatus 

func WithChannelSubscribersStatus(subscribers []eventingduckv1beta1.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

func WithChannelWorkloadIdentityFailed added in v0.14.0 

func WithChannelWorkloadIdentityFailed(reason, message string) ChannelOption

type CloudAuditLogsSourceOption added in v0.12.0 

type CloudAuditLogsSourceOption func(*v1alpha1.CloudAuditLogsSource)

func WithCloudAuditLogsSourceAnnotations added in v0.15.0 

func WithCloudAuditLogsSourceAnnotations(Annotations map[string]string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceFinalizers added in v0.12.0 

func WithCloudAuditLogsSourceFinalizers(finalizers ...string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceGCPServiceAccount added in v0.14.0 

func WithCloudAuditLogsSourceGCPServiceAccount(gServiceAccount 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 WithCloudAuditLogsSourceServiceAccountName added in v0.14.0 

func WithCloudAuditLogsSourceServiceAccountName(name string) CloudAuditLogsSourceOption

WithCloudAuditLogsSourceServiceAccountName will give status.ServiceAccountName a k8s service account name, which is related on Workload Identity's Google service account.

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

func WithCloudAuditLogsSourceWorkloadIdentityFailed added in v0.14.0 

func WithCloudAuditLogsSourceWorkloadIdentityFailed(reason, message string) CloudAuditLogsSourceOption

type CloudBuildSourceOption added in v0.14.0 

type CloudBuildSourceOption func(*v1alpha1.CloudBuildSource)

CloudBuildSourceOption enables further configuration of a CloudBuildSource.

func WithCloudBuildSourceAnnotations added in v0.15.0 

func WithCloudBuildSourceAnnotations(Annotations map[string]string) CloudBuildSourceOption

func WithCloudBuildSourceFinalizers added in v0.14.0 

func WithCloudBuildSourceFinalizers(finalizers ...string) CloudBuildSourceOption

func WithCloudBuildSourceGCPServiceAccount added in v0.14.0 

func WithCloudBuildSourceGCPServiceAccount(gServiceAccount string) CloudBuildSourceOption

func WithCloudBuildSourceObjectMetaGeneration added in v0.14.0 

func WithCloudBuildSourceObjectMetaGeneration(generation int64) CloudBuildSourceOption

func WithCloudBuildSourceProject added in v0.14.0 

func WithCloudBuildSourceProject(project string) CloudBuildSourceOption

func WithCloudBuildSourcePullSubscriptionFailed added in v0.14.0 

func WithCloudBuildSourcePullSubscriptionFailed(reason, message string) CloudBuildSourceOption

WithCloudBuildSourcePullSubscriptionFailed marks the condition that the status of PullSubscription is False

func WithCloudBuildSourcePullSubscriptionReady added in v0.14.0 

func WithCloudBuildSourcePullSubscriptionReady() CloudBuildSourceOption

WithCloudBuildSourcePullSubscriptionReady marks the condition that the topic is not ready

func WithCloudBuildSourcePullSubscriptionUnknown added in v0.14.0 

func WithCloudBuildSourcePullSubscriptionUnknown(reason, message string) CloudBuildSourceOption

WithCloudBuildSourcePullSubscriptionUnknown marks the condition that the topic is Unknown

func WithCloudBuildSourceServiceAccountName added in v0.14.0 

func WithCloudBuildSourceServiceAccountName(name string) CloudBuildSourceOption

WithCloudBuildSourceServiceAccountName will give status.ServiceAccountName a k8s service account name, which is related on Workload Identity's Google service account.

func WithCloudBuildSourceSink added in v0.14.0 

func WithCloudBuildSourceSink(gvk metav1.GroupVersionKind, name string) CloudBuildSourceOption

func WithCloudBuildSourceSinkURI added in v0.14.0 

func WithCloudBuildSourceSinkURI(url *apis.URL) CloudBuildSourceOption

WithCloudBuildSourceSinkURI sets the status for sink URI

func WithCloudBuildSourceStatusObservedGeneration added in v0.14.0 

func WithCloudBuildSourceStatusObservedGeneration(generation int64) CloudBuildSourceOption

func WithCloudBuildSourceTopic added in v0.14.0 

func WithCloudBuildSourceTopic(topicID string) CloudBuildSourceOption

func WithCloudBuildSourceWorkloadIdentityFailed added in v0.14.0 

func WithCloudBuildSourceWorkloadIdentityFailed(reason, message string) CloudBuildSourceOption

type CloudPubSubSourceOption added in v0.12.0 

type CloudPubSubSourceOption func(*v1alpha1.CloudPubSubSource)

CloudPubSubSourceOption enables further configuration of a CloudPubSubSource.

func WithCloudPubSubSourceAnnotations added in v0.15.0 

func WithCloudPubSubSourceAnnotations(Annotations map[string]string) CloudPubSubSourceOption

func WithCloudPubSubSourceFinalizers added in v0.12.0 

func WithCloudPubSubSourceFinalizers(finalizers ...string) CloudPubSubSourceOption

func WithCloudPubSubSourceGCPServiceAccount added in v0.14.0 

func WithCloudPubSubSourceGCPServiceAccount(gServiceAccount string) CloudPubSubSourceOption

func WithCloudPubSubSourceObjectMetaGeneration added in v0.12.0 

func WithCloudPubSubSourceObjectMetaGeneration(generation int64) CloudPubSubSourceOption

func WithCloudPubSubSourceProject added in v0.14.0 

func WithCloudPubSubSourceProject(project string) 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 WithCloudPubSubSourceServiceAccountName added in v0.14.0 

func WithCloudPubSubSourceServiceAccountName(name string) CloudPubSubSourceOption

WithCloudPubSubSourceServiceAccountName will give status.ServiceAccountName a k8s service account name, which is related on Workload Identity's Google service account.

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

func WithCloudPubSubSourceWorkloadIdentityFailed added in v0.14.0 

func WithCloudPubSubSourceWorkloadIdentityFailed(reason, message string) CloudPubSubSourceOption

type CloudSchedulerSourceOption added in v0.12.0 

type CloudSchedulerSourceOption func(*v1alpha1.CloudSchedulerSource)

CloudSchedulerSourceOption enables further configuration of a CloudSchedulerSource.

func WithCloudSchedulerSourceAnnotations added in v0.15.0 

func WithCloudSchedulerSourceAnnotations(Annotations map[string]string) CloudSchedulerSourceOption

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

func WithCloudSchedulerSourceGCPServiceAccount(gServiceAccount 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 WithCloudSchedulerSourceServiceAccountName added in v0.14.0 

func WithCloudSchedulerSourceServiceAccountName(name string) CloudSchedulerSourceOption

WithCloudSchedulerSourceServiceAccountName will give status.ServiceAccountName a k8s service account name, which is related on Workload Identity's Google service account.

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.

func WithCloudSchedulerSourceWorkloadIdentityFailed added in v0.14.0 

func WithCloudSchedulerSourceWorkloadIdentityFailed(reason, message string) CloudSchedulerSourceOption

type CloudStorageSourceOption added in v0.12.0 

type CloudStorageSourceOption func(*v1alpha1.CloudStorageSource)

CloudStorageSourceOption enables further configuration of a CloudStorageSource.

func WithCloudStorageSourceAnnotations added in v0.15.0 

func WithCloudStorageSourceAnnotations(Annotations map[string]string) CloudStorageSourceOption

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

func WithCloudStorageSourceGCPServiceAccount(gServiceAccount 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 WithCloudStorageSourceServiceAccountName added in v0.14.0 

func WithCloudStorageSourceServiceAccountName(name string) CloudStorageSourceOption

WithCloudStorageSourceServiceAccountName will give status.ServiceAccountName a k8s service account name, which is related on Workload Identity's Google service account.

func WithCloudStorageSourceSink added in v0.12.0 

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

func WithCloudStorageSourceSinkDestination added in v0.15.0 

func WithCloudStorageSourceSinkDestination(sink duckv1.Destination) 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 WithCloudStorageSourceWorkloadIdentityFailed added in v0.14.0 

func WithCloudStorageSourceWorkloadIdentityFailed(reason, message string) CloudStorageSourceOption

func WithDeletionTimestamp added in v0.10.0 

func WithDeletionTimestamp() CloudStorageSourceOption

type ConfigMapOption added in v0.15.0 

type ConfigMapOption func(*corev1.ConfigMap)

ConfigMapOption enables further configuration of a ConfigMap.

func WithConfigMapBinaryData added in v0.15.0 

func WithConfigMapBinaryData(data map[string][]byte) ConfigMapOption

func WithConfigMapBinaryDataEntry added in v0.15.0 

func WithConfigMapBinaryDataEntry(key string, value []byte) ConfigMapOption

func WithConfigMapData added in v0.15.0 

func WithConfigMapData(data map[string]string) ConfigMapOption

func WithConfigMapDataEntry added in v0.15.0 

func WithConfigMapDataEntry(key, value string) ConfigMapOption

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

type EndpointsOption func(*corev1.Endpoints)

EndpointsOption enables further configuration of a Endpoints.

func WithEndpointsAddresses added in v0.15.0 

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

func WithEndpointsAnnotations added in v0.15.0 

func WithEndpointsAnnotations(annotations map[string]string) EndpointsOption

func WithEndpointsLabels added in v0.15.0 

func WithEndpointsLabels(labels map[string]string) EndpointsOption

func WithEndpointsNotReadyAddresses added in v0.15.0 

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

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) GetBrokerCellLister added in v0.15.0 

func (l *Listers) GetBrokerCellLister() intlisters.BrokerCellLister

func (*Listers) GetBrokerLister added in v0.15.0 

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

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) GetCloudBuildSourceLister added in v0.14.0 

func (l *Listers) GetCloudBuildSourceLister() eventslisters.CloudBuildSourceLister

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) GetPodLister added in v0.15.0 

func (l *Listers) GetPodLister() corev1listers.PodLister

func (*Listers) GetPubSubPullSubscriptionLister added in v0.15.0 

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

func (*Listers) GetPubSubTopicLister added in v0.15.0 

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

func (*Listers) GetPullSubscriptionLister 

func (l *Listers) GetPullSubscriptionLister() inteventslisters.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() inteventslisters.TopicLister

func (*Listers) GetTriggerLister added in v0.15.0 

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

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

type PubSubPullSubscriptionOption func(*v1alpha1.PullSubscription)

PubSubPullSubscriptionOption enables further configuration of a PullSubscription.

func WithPubSubPullSubscriptionAnnotations added in v0.15.0 

func WithPubSubPullSubscriptionAnnotations(annotations map[string]string) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionDeprecated added in v0.15.0 

func WithPubSubPullSubscriptionDeprecated() PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionFailed added in v0.15.0 

func WithPubSubPullSubscriptionFailed() PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionLabels added in v0.15.0 

func WithPubSubPullSubscriptionLabels(labels map[string]string) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionMarkNoSubscription added in v0.15.0 

func WithPubSubPullSubscriptionMarkNoSubscription(reason, message string) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionMarkNoTransformer added in v0.15.0 

func WithPubSubPullSubscriptionMarkNoTransformer(reason, message string) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionMarkSink added in v0.15.0 

func WithPubSubPullSubscriptionMarkSink(uri *apis.URL) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionMarkSubscribed added in v0.15.0 

func WithPubSubPullSubscriptionMarkSubscribed(subscriptionID string) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionMarkTransformer added in v0.15.0 

func WithPubSubPullSubscriptionMarkTransformer(uri *apis.URL) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionMode added in v0.15.0 

func WithPubSubPullSubscriptionMode(mode v1alpha1.ModeType) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionObjectMetaGeneration added in v0.15.0 

func WithPubSubPullSubscriptionObjectMetaGeneration(generation int64) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionOwnerReferences added in v0.15.0 

func WithPubSubPullSubscriptionOwnerReferences(ownerReferences []metav1.OwnerReference) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionProjectID added in v0.15.0 

func WithPubSubPullSubscriptionProjectID(projectID string) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionReady added in v0.10.0 

func WithPubSubPullSubscriptionReady(sink *apis.URL) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionReadyStatus added in v0.15.0 

func WithPubSubPullSubscriptionReadyStatus(status corev1.ConditionStatus, reason, message string) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionSink added in v0.15.0 

func WithPubSubPullSubscriptionSink(gvk metav1.GroupVersionKind, name string) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionSinkNotFound added in v0.15.0 

func WithPubSubPullSubscriptionSinkNotFound() PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionSpec added in v0.15.0 

func WithPubSubPullSubscriptionSpec(spec v1alpha1.PullSubscriptionSpec) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionSpecWithNoDefaults added in v0.15.0 

func WithPubSubPullSubscriptionSpecWithNoDefaults(spec v1alpha1.PullSubscriptionSpec) PubSubPullSubscriptionOption

Same as withPullSubscriptionSpec but does not set defaults

func WithPubSubPullSubscriptionStatusObservedGeneration added in v0.15.0 

func WithPubSubPullSubscriptionStatusObservedGeneration(generation int64) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionSubscriptionID added in v0.15.0 

func WithPubSubPullSubscriptionSubscriptionID(subscriptionID string) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionTransformer added in v0.15.0 

func WithPubSubPullSubscriptionTransformer(gvk metav1.GroupVersionKind, name string) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionTransformerURI added in v0.15.0 

func WithPubSubPullSubscriptionTransformerURI(uri *apis.URL) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionUID added in v0.15.0 

func WithPubSubPullSubscriptionUID(uid types.UID) PubSubPullSubscriptionOption

func WithPubSubPullSubscriptionUnknown added in v0.15.0 

func WithPubSubPullSubscriptionUnknown() PubSubPullSubscriptionOption

type PubSubTopicOption added in v0.15.0 

type PubSubTopicOption func(*v1alpha1.Topic)

PubSubTopicOption enables further configuration of a Topic.

func WithPubSubTopicAddress added in v0.15.0 

func WithPubSubTopicAddress(uri string) PubSubTopicOption

func WithPubSubTopicAnnotations added in v0.15.0 

func WithPubSubTopicAnnotations(annotations map[string]string) PubSubTopicOption

func WithPubSubTopicDeprecated added in v0.15.0 

func WithPubSubTopicDeprecated() PubSubTopicOption

func WithPubSubTopicFailed added in v0.15.0 

func WithPubSubTopicFailed() PubSubTopicOption

func WithPubSubTopicLabels added in v0.15.0 

func WithPubSubTopicLabels(labels map[string]string) PubSubTopicOption

func WithPubSubTopicNoTopic added in v0.15.0 

func WithPubSubTopicNoTopic(reason, message string) PubSubTopicOption

func WithPubSubTopicOwnerReferences added in v0.15.0 

func WithPubSubTopicOwnerReferences(ownerReferences []metav1.OwnerReference) PubSubTopicOption

func WithPubSubTopicProjectID added in v0.15.0 

func WithPubSubTopicProjectID(projectID string) PubSubTopicOption

func WithPubSubTopicPropagationPolicy added in v0.15.0 

func WithPubSubTopicPropagationPolicy(policy string) PubSubTopicOption

func WithPubSubTopicPublisherNotConfigured added in v0.15.0 

func WithPubSubTopicPublisherNotConfigured() PubSubTopicOption

func WithPubSubTopicPublisherNotDeployed added in v0.15.0 

func WithPubSubTopicPublisherNotDeployed(reason, message string) PubSubTopicOption

func WithPubSubTopicPublisherUnknown added in v0.15.0 

func WithPubSubTopicPublisherUnknown(reason, message string) PubSubTopicOption

func WithPubSubTopicReady added in v0.15.0 

func WithPubSubTopicReady(topicID string) PubSubTopicOption

func WithPubSubTopicSpec added in v0.15.0 

func WithPubSubTopicSpec(spec v1alpha1.TopicSpec) PubSubTopicOption

func WithPubSubTopicTopicID added in v0.15.0 

func WithPubSubTopicTopicID(topicID string) PubSubTopicOption

func WithPubSubTopicUID added in v0.15.0 

func WithPubSubTopicUID(uid types.UID) PubSubTopicOption

func WithPubSubTopicUnknown added in v0.15.0 

func WithPubSubTopicUnknown() PubSubTopicOption

type PubsubAction added in v0.15.0 

type PubsubAction func(context.Context, *testing.T, *pubsub.Client)

func SubscriptionWithTopic added in v0.15.0 

func SubscriptionWithTopic(id string, tid string) PubsubAction

func Topic added in v0.15.0 

func Topic(id string) PubsubAction

func TopicAndSub added in v0.15.0 

func TopicAndSub(id string) PubsubAction

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 *apis.URL) PullSubscriptionOption

func WithPullSubscriptionMarkSubscribed added in v0.12.0 

func WithPullSubscriptionMarkSubscribed(subscriptionID string) PullSubscriptionOption

func WithPullSubscriptionMarkTransformer added in v0.12.0 

func WithPullSubscriptionMarkTransformer(uri *apis.URL) 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 *apis.URL) 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 *apis.URL) PullSubscriptionOption

func WithPullSubscriptionUID 

func WithPullSubscriptionUID(uid types.UID) PullSubscriptionOption

func WithPullSubscriptionUnknown added in v0.12.0 

func WithPullSubscriptionUnknown() PullSubscriptionOption

type ServiceAccountOption added in v0.14.0 

type ServiceAccountOption func(*corev1.ServiceAccount)

func WithServiceAccountOwnerReferences added in v0.14.0 

func WithServiceAccountOwnerReferences(ownerReferences []metav1.OwnerReference) ServiceAccountOption

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

func WithTopicAnnotations(annotations map[string]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 TriggerOption added in v0.15.0 

type TriggerOption func(*brokerv1beta1.Trigger)

TriggerOption enables further configuration of a Trigger.

func WithDependencyAnnotation added in v0.15.0 

func WithDependencyAnnotation(dependencyAnnotation string) TriggerOption

func WithInjectionAnnotation added in v0.15.0 

func WithInjectionAnnotation(injectionAnnotation string) TriggerOption

func WithTriggerBrokerFailed added in v0.15.0 

func WithTriggerBrokerFailed(reason, message string) TriggerOption

WithTriggerBrokerFailed marks the Broker as failed

func WithTriggerBrokerUnknown added in v0.15.0 

func WithTriggerBrokerUnknown(reason, message string) TriggerOption

WithTriggerBrokerUnknown marks the Broker as unknown

func WithTriggerDependencyFailed added in v0.15.0 

func WithTriggerDependencyFailed(reason, message string) TriggerOption

func WithTriggerDependencyUnknown added in v0.15.0 

func WithTriggerDependencyUnknown(reason, message string) TriggerOption

func WithTriggerFinalizers added in v0.15.0 

func WithTriggerFinalizers(finalizers ...string) TriggerOption

func WithTriggerGeneration added in v0.15.0 

func WithTriggerGeneration(gen int64) TriggerOption

func WithTriggerStatusObservedGeneration added in v0.15.0 

func WithTriggerStatusObservedGeneration(gen int64) TriggerOption

func WithTriggerStatusSubscriberURI added in v0.15.0 

func WithTriggerStatusSubscriberURI(uri string) TriggerOption

func WithTriggerSubscriberRef added in v0.15.0 

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

func WithTriggerSubscriberRefAndURIReference added in v0.15.0 

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

func WithTriggerSubscriberResolvedFailed added in v0.15.0 

func WithTriggerSubscriberResolvedFailed(reason, message string) TriggerOption

func WithTriggerSubscriberResolvedUnknown added in v0.15.0 

func WithTriggerSubscriberResolvedUnknown(reason, message string) TriggerOption

func WithTriggerSubscriberURI added in v0.15.0 

func WithTriggerSubscriberURI(rawurl string) TriggerOption

func WithTriggerUID added in v0.15.0 

func WithTriggerUID(uid string) TriggerOption

type UnstructuredOption 

type UnstructuredOption func(*unstructured.Unstructured)

UnstructuredOption enables further configuration of a Unstructured.

func WithUnstructuredAddressable 

func WithUnstructuredAddressable(hostname string) UnstructuredOption

func WithUnstructuredAnnotations added in v0.14.0 

func WithUnstructuredAnnotations(annotations map[string]interface{}) UnstructuredOption

func WithUnstructuredLabels added in v0.14.0 

func WithUnstructuredLabels(labels map[string]interface{}) 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.