testing

package
v0.16.0 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 2020 License: Apache-2.0 Imports: 67 Imported by: 6

Documentation

Index

Constants

View Source 
const (
	SubscriptionID = "subID"
)

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) *v1beta1.Channel

NewChannel creates a Channel with ChannelOptions

func NewChannelWithoutNamespace 

func NewChannelWithoutNamespace(name string, co ...ChannelOption) *v1beta1.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) *v1beta1.CloudAuditLogsSource

func NewCloudBuildSource added in v0.14.0 

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

NewCloudBuildSource creates a CloudBuildSource with CloudBuildSourceOptions

func NewCloudPubSubSource added in v0.12.0 

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

NewCloudPubSubSource creates a CloudPubSubSource with CloudPubSubSourceOptions

func NewCloudSchedulerSource added in v0.12.0 

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

NewCloudSchedulerSource creates a CloudSchedulerSource with CloudSchedulerSourceOptions

func NewCloudStorageSource added in v0.12.0 

func NewCloudStorageSource(name, namespace string, so ...CloudStorageSourceOption) *v1beta1.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 NewGCPAuthTestStore added in v0.16.0 

func NewGCPAuthTestStore(t *testing.T, config *corev1.ConfigMap) *gcpauth.Store

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) *v1beta1.PullSubscription

NewPullSubscription creates a PullSubscription with PullSubscriptionOptions

func NewPullSubscriptionWithoutNamespace 

func NewPullSubscriptionWithoutNamespace(name string, so ...PullSubscriptionOption) *v1beta1.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, to ...TopicOption) *v1beta1.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 WithBrokerBrokerCellReady added in v0.16.0 

func WithBrokerBrokerCellReady(b *brokerv1beta1.Broker)

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

func WithBrokerCellSetDefaults(bc *intv1alpha1.BrokerCell)

func WithBrokerDeletionTimestamp added in v0.15.0 

func WithBrokerDeletionTimestamp(b *brokerv1beta1.Broker)

func WithBrokerSetDefaults added in v0.16.0 

func WithBrokerSetDefaults(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 WithChannelDeleted 

func WithChannelDeleted(s *v1beta1.Channel)

func WithChannelDeletionTimestamp added in v0.14.0 

func WithChannelDeletionTimestamp(c *v1beta1.Channel)

func WithChannelSetDefaults added in v0.16.0 

func WithChannelSetDefaults(c *v1beta1.Channel)

func WithCloudAuditLogsSourceDeletionTimestamp added in v0.12.0 

func WithCloudAuditLogsSourceDeletionTimestamp(s *v1beta1.CloudAuditLogsSource)

func WithCloudAuditLogsSourceSetDefaults added in v0.16.0 

func WithCloudAuditLogsSourceSetDefaults(s *v1beta1.CloudAuditLogsSource)

func WithCloudAuditLogsSourceSinkReady added in v0.12.0 

func WithCloudAuditLogsSourceSinkReady(s *v1beta1.CloudAuditLogsSource)

func WithCloudBuildSourceDeletionTimestamp added in v0.14.0 

func WithCloudBuildSourceDeletionTimestamp(bs *v1beta1.CloudBuildSource)

func WithCloudBuildSourceSetDefault added in v0.16.0 

func WithCloudBuildSourceSetDefault(bs *v1beta1.CloudBuildSource)

func WithCloudPubSubSourceDeletionTimestamp added in v0.14.0 

func WithCloudPubSubSourceDeletionTimestamp(s *v1beta1.CloudPubSubSource)

func WithCloudPubSubSourcePullSubscriptionReady added in v0.12.0 

func WithCloudPubSubSourcePullSubscriptionReady(ps *v1beta1.CloudPubSubSource)

WithCloudPubSubSourcePullSubscriptionReady marks the condition that the topic is not ready

func WithCloudPubSubSourceSetDefaults added in v0.16.0 

func WithCloudPubSubSourceSetDefaults(ps *v1beta1.CloudPubSubSource)

func WithCloudSchedulerSourceDeletionTimestamp added in v0.12.0 

func WithCloudSchedulerSourceDeletionTimestamp(s *v1beta1.CloudSchedulerSource)

func WithCloudSchedulerSourcePullSubscriptionReady added in v0.12.0 

func WithCloudSchedulerSourcePullSubscriptionReady(s *v1beta1.CloudSchedulerSource)

WithCloudSchedulerSourcePullSubscriptionReady marks the condition that the topic is ready.

func WithCloudSchedulerSourceSetDefaults added in v0.16.0 

func WithCloudSchedulerSourceSetDefaults(s *v1beta1.CloudSchedulerSource)

func WithCloudStorageSourceSetDefaults added in v0.16.0 

func WithCloudStorageSourceSetDefaults(s *v1beta1.CloudStorageSource)

func WithDeletionTimestamp added in v0.10.0 

func WithDeletionTimestamp(s *v1beta1.CloudStorageSource)

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(c *v1beta1.Channel)

WithInitChannelConditions initializes the Channels's conditions.

func WithInitCloudAuditLogsSourceConditions added in v0.12.0 

func WithInitCloudAuditLogsSourceConditions(s *v1beta1.CloudAuditLogsSource)

func WithInitCloudBuildSourceConditions added in v0.14.0 

func WithInitCloudBuildSourceConditions(bs *v1beta1.CloudBuildSource)

WithInitCloudBuildSourceConditions initializes the CloudBuildSource's conditions.

func WithInitCloudPubSubSourceConditions added in v0.12.0 

func WithInitCloudPubSubSourceConditions(ps *v1beta1.CloudPubSubSource)

WithInitCloudPubSubSourceConditions initializes the CloudPubSubSource's conditions.

func WithInitCloudSchedulerSourceConditions added in v0.12.0 

func WithInitCloudSchedulerSourceConditions(s *v1beta1.CloudSchedulerSource)

WithInitCloudSchedulerSourceConditions initializes the CloudSchedulerSources's conditions.

func WithInitCloudStorageSourceConditions added in v0.12.0 

func WithInitCloudStorageSourceConditions(s *v1beta1.CloudStorageSource)

WithInitCloudStorageSourceConditions initializes the CloudStorageSources's conditions.

func WithInitPullSubscriptionConditions 

func WithInitPullSubscriptionConditions(s *v1beta1.PullSubscription)

WithInitPullSubscriptionConditions initializes the PullSubscriptions's conditions.

func WithInitTopicConditions 

func WithInitTopicConditions(t *v1beta1.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 WithPullSubscriptionDefaultGCPAuth added in v0.16.0 

func WithPullSubscriptionDefaultGCPAuth(s *v1beta1.PullSubscription)

func WithPullSubscriptionDeleted 

func WithPullSubscriptionDeleted(s *v1beta1.PullSubscription)

func WithPullSubscriptionSetDefaults added in v0.16.0 

func WithPullSubscriptionSetDefaults(s *v1beta1.PullSubscription)

func WithTopicDeleted 

func WithTopicDeleted(t *v1beta1.Topic)

func WithTopicFailed added in v0.12.0 

func WithTopicFailed(t *v1beta1.Topic)

func WithTopicPublisherDeployed added in v0.12.2 

func WithTopicPublisherDeployed(t *v1beta1.Topic)

func WithTopicPublisherNotConfigured added in v0.12.2 

func WithTopicPublisherNotConfigured(t *v1beta1.Topic)

func WithTopicSetDefaults added in v0.16.0 

func WithTopicSetDefaults(t *v1beta1.Topic)

func WithTopicUnknown added in v0.12.0 

func WithTopicUnknown(t *v1beta1.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 WithTriggerSetDefaults added in v0.16.0 

func WithTriggerSetDefaults(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 WithBrokerCellAnnotations added in v0.16.0 

func WithBrokerCellAnnotations(annotations map[string]string) BrokerCellOption

func WithBrokerCellFanoutAvailable added in v0.15.0 

func WithBrokerCellFanoutAvailable() BrokerCellOption

func WithBrokerCellFanoutFailed added in v0.15.0 

func WithBrokerCellFanoutFailed(reason, msg string) BrokerCellOption

func WithBrokerCellFanoutUnknown added in v0.16.0 

func WithBrokerCellFanoutUnknown(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 WithBrokerCellRetryUnknown added in v0.16.0 

func WithBrokerCellRetryUnknown(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 WithBrokerBrokerCellFailed added in v0.16.0 

func WithBrokerBrokerCellFailed(reason, msg string) BrokerOption

func WithBrokerBrokerCellUnknown added in v0.16.0 

func WithBrokerBrokerCellUnknown(reason, msg string) BrokerOption

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

type ChannelOption 

type ChannelOption func(*v1beta1.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 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 WithChannelServiceAccount added in v0.16.0 

func WithChannelServiceAccount(kServiceAccount 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 v1beta1.ChannelSpec) ChannelOption

func WithChannelSubscribers 

func WithChannelSubscribers(subscribers []duckv1beta1.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(*v1beta1.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 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 WithCloudAuditLogsSourceServiceAccount added in v0.16.0 

func WithCloudAuditLogsSourceServiceAccount(kServiceAccount 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 WithCloudAuditLogsSourceSinkURI added in v0.12.0 

func WithCloudAuditLogsSourceSinkURI(url *apis.URL) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSubscriptionID added in v0.16.0 

func WithCloudAuditLogsSourceSubscriptionID(subscriptionID string) 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 WithCloudAuditLogsSourceUID added in v0.16.0 

func WithCloudAuditLogsSourceUID(uid 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(*v1beta1.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 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 WithCloudBuildSourceServiceAccount added in v0.16.0 

func WithCloudBuildSourceServiceAccount(kServiceAccount string) CloudBuildSourceOption

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

func WithCloudBuildSourceSubscriptionID(subscriptionID 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(*v1beta1.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 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 WithCloudPubSubSourcePullSubscriptionUnknown added in v0.12.0 

func WithCloudPubSubSourcePullSubscriptionUnknown(reason, message string) CloudPubSubSourceOption

WithCloudPubSubSourcePullSubscriptionUnknown marks the condition that the topic is Unknown

func WithCloudPubSubSourceServiceAccount added in v0.16.0 

func WithCloudPubSubSourceServiceAccount(kServiceAccount string) CloudPubSubSourceOption

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

func WithCloudPubSubSourceSubscriptionID(subscriptionID string) 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(*v1beta1.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 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 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 WithCloudSchedulerSourceServiceAccount added in v0.16.0 

func WithCloudSchedulerSourceServiceAccount(kServiceAccount 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 WithCloudSchedulerSourceSubscriptionID added in v0.16.0 

func WithCloudSchedulerSourceSubscriptionID(subscriptionID string) CloudSchedulerSourceOption

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(*v1beta1.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 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 WithCloudStorageSourceServiceAccount added in v0.16.0 

func WithCloudStorageSourceServiceAccount(kServiceAccount string) CloudStorageSourceOption

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

func WithCloudStorageSourceSubscriptionID(subscriptionID string) 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

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

func WithDeploymentAvailable() DeploymentOption

WithDeploymentAvailable marks the Deployment as available.

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) GetHPALister added in v0.16.0 

func (l *Listers) GetHPALister() hpav2beta2listers.HorizontalPodAutoscalerLister

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) 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 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(tid, sid string) PubsubAction

type PullSubscriptionOption 

type PullSubscriptionOption func(*v1beta1.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 WithPullSubscriptionMarkDeployed added in v0.12.0 

func WithPullSubscriptionMarkDeployed(name, namespace string) PullSubscriptionOption

func WithPullSubscriptionMarkNoDeployed added in v0.16.0 

func WithPullSubscriptionMarkNoDeployed(name, namespace 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 v1beta1.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 v1beta1.PullSubscriptionSpec) PullSubscriptionOption

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(*v1beta1.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 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 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 WithTopicReadyAndPublisherDeployed added in v0.16.0 

func WithTopicReadyAndPublisherDeployed(topicID string) TopicOption

func WithTopicSpec 

func WithTopicSpec(spec v1beta1.TopicSpec) TopicOption

func WithTopicTopicDeleted 

func WithTopicTopicDeleted(topicID string) TopicOption

func WithTopicTopicID 

func WithTopicTopicID(topicID string) TopicOption

func WithTopicUID 

func WithTopicUID(uid types.UID) 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.