testing

package
v0.23.0 Latest Latest
Warning

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

 Go to latest Published: May 25, 2021 License: Apache-2.0 Imports: 68 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func ApiVersion added in v0.17.0 

func ApiVersion(gvk metav1.GroupVersionKind) string

func AvailableEndpoints added in v0.15.0 

func AvailableEndpoints() *corev1.Endpoints

func GetFailedTestClientCreateFunc added in v0.19.0 

func GetFailedTestClientCreateFunc(target string, maxCallTime int) func(context.Context, string, ...option.ClientOption) (*pubsub.Client, error)

GetFailedTestClientCreateFunc returns a pubsub client creation function that will fail when the invoke time reaches maxCallTime. When maxCallTime is set to 0, it will always fail.

func GetTestClientCreateFunc added in v0.19.0 

func GetTestClientCreateFunc(target string) func(context.Context, string, ...option.ClientOption) (*pubsub.Client, error)

GetTestClientCreateFunc returns a client creation function with same type as pubsub.NewClient. With this helper function, multiple clients can be created. This is necessary for any test involving multiple projects. Eg. in sources multiple project is allowed for topics.

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) *brokerv1.Broker

NewBroker creates a Broker with BrokerOptions. The Broker has the brokerv1 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 NewBrokerDeliveryConfigMapFromDeliverySpec added in v0.18.3 

func NewBrokerDeliveryConfigMapFromDeliverySpec(spec *eventingduckv1.DeliverySpec) *corev1.ConfigMap

NewBrokerDeliveryConfigMapFromDeliverySpec creates a new cluster defaulted broker delivery configuration map from a given delivery spec.

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

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

NewConfigMap creates a ConfigMap with ConfigMapOptions.

func NewDataresidencyConfigMapFromRegions added in v0.18.0 

func NewDataresidencyConfigMapFromRegions(regions []string) *corev1.ConfigMap

NewDataresidencyConfigMapFromRegions Create new data residency configuration map from list of allowed persistence regions

func NewDataresidencyTestStore added in v0.18.0 

func NewDataresidencyTestStore(t *testing.T, config *corev1.ConfigMap) *dataresidency.Store

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

func NewSecret(name, namespace string, so ...SecretOption) *corev1.Secret

NewSecret creates a Secret.

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 string, so ...ServiceAccountOption) *corev1.ServiceAccount

NewServiceAccount creates a ServiceAccount

func NewTrigger added in v0.15.0 

func NewTrigger(name, namespace, broker string, to ...TriggerOption) *brokerv1.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 SubscriptionDoesNotExist added in v0.21.0 

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

func SubscriptionExists added in v0.15.0 

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

func SubscriptionHasDeadLetterPolicy added in v0.17.0 

func SubscriptionHasDeadLetterPolicy(id string, wantPolicy *pubsub.DeadLetterPolicy) func(*testing.T, *rtesting.TableRow)

func SubscriptionHasRetryPolicy added in v0.17.0 

func SubscriptionHasRetryPolicy(id string, wantPolicy *pubsub.RetryPolicy) func(*testing.T, *rtesting.TableRow)

func TestPubsubClient added in v0.15.0 

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

func TopicDoesNotExist added in v0.21.0 

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

func TopicExists added in v0.15.0 

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

func TopicExistsWithConfig added in v0.18.0 

func TopicExistsWithConfig(id string, expectedTopicConfig *pubsub.TopicConfig) func(*testing.T, *rtesting.TableRow)

func WithBrokerBrokerCellReady added in v0.16.0 

func WithBrokerBrokerCellReady(b *brokerv1.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 *brokerv1.Broker)

func WithBrokerSetDefaults added in v0.16.0 

func WithBrokerSetDefaults(b *brokerv1.Broker)

func WithBrokerSubscriptionReady added in v0.15.0 

func WithBrokerSubscriptionReady(b *brokerv1.Broker)

func WithBrokerTopicReady added in v0.15.0 

func WithBrokerTopicReady(b *brokerv1.Broker)

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 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 *brokerv1.Broker)

WithInitBrokerConditions initializes the Broker's conditions.

func WithInitChannelConditions 

func WithInitChannelConditions(c *v1beta1.Channel)

WithInitChannelConditions initializes the Channels's conditions.

func WithInitTriggerConditions added in v0.15.0 

func WithInitTriggerConditions(t *brokerv1.Trigger)

WithInitTriggerConditions initializes the Triggers's conditions.

func WithNamespaceDeleted 

func WithNamespaceDeleted(n *corev1.Namespace)

func WithTriggerBrokerReady added in v0.15.0 

func WithTriggerBrokerReady(t *brokerv1.Trigger)

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

func WithTriggerDeletionTimestamp added in v0.15.0 

func WithTriggerDeletionTimestamp(t *brokerv1.Trigger)

func WithTriggerDependencyReady added in v0.15.0 

func WithTriggerDependencyReady(t *brokerv1.Trigger)

func WithTriggerSetDefaults added in v0.16.0 

func WithTriggerSetDefaults(t *brokerv1.Trigger)

func WithTriggerSubscriberResolvedSucceeded added in v0.15.0 

func WithTriggerSubscriberResolvedSucceeded(t *brokerv1.Trigger)

func WithTriggerSubscriptionReady added in v0.15.0 

func WithTriggerSubscriptionReady(t *brokerv1.Trigger)

func WithTriggerTopicReady added in v0.15.0 

func WithTriggerTopicReady(t *brokerv1.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 WithBrokerCellIngressUnknown added in v0.20.0 

func WithBrokerCellIngressUnknown(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(*brokerv1.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 WithBrokerDeliverySpec added in v0.17.0 

func WithBrokerDeliverySpec(deliverySpec *eventingduckv1.DeliverySpec) BrokerOption

WithBrokerDeliverySpec sets the Broker's delivery spec.

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

func WithBrokerSubscriptionUnknown(reason, msg string) BrokerOption

func WithBrokerTopicUnknown added in v0.19.0 

func WithBrokerTopicUnknown(reason, msg string) 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 WithChannelBrokerCellFailed added in v0.21.0 

func WithChannelBrokerCellFailed(reason, message string) ChannelOption

func WithChannelBrokerCellReady added in v0.21.0 

func WithChannelBrokerCellReady() ChannelOption

func WithChannelBrokerCellUnknown added in v0.21.0 

func WithChannelBrokerCellUnknown(reason, message string) ChannelOption

func WithChannelReadyURI added in v0.21.0 

func WithChannelReadyURI(address *apis.URL) ChannelOption

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

func WithChannelSpec 

func WithChannelSpec(spec v1beta1.ChannelSpec) ChannelOption

func WithChannelSubscribers 

func WithChannelSubscribers(subscribers ...eventingduckv1.SubscriberSpec) ChannelOption

func WithChannelSubscribersStatus 

func WithChannelSubscribersStatus(subscribers ...eventingduckv1.SubscriberStatus) ChannelOption

func WithChannelSubscriptionFailed added in v0.21.0 

func WithChannelSubscriptionFailed(reason, message string) ChannelOption

func WithChannelSubscriptionReady added in v0.21.0 

func WithChannelSubscriptionReady() ChannelOption

func WithChannelSubscriptionUnknown added in v0.21.0 

func WithChannelSubscriptionUnknown(reason, message string) ChannelOption

func WithChannelTopic 

func WithChannelTopic() ChannelOption

func WithChannelTopicFailed added in v0.12.0 

func WithChannelTopicFailed(reason, message string) ChannelOption

func WithChannelTopicUnknown added in v0.12.0 

func WithChannelTopicUnknown(reason, message string) ChannelOption

func WithChannelUID 

func WithChannelUID(uid types.UID) ChannelOption

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

func WithDeploymentMinimumReplicasUnavailable() DeploymentOption

WithDeploymentMinimumReplicasUnavailable marks the Deployment as unavailable for minimal replica unavailable.

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 {
	servingv1listers.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) GetSecretLister added in v0.20.0 

func (l *Listers) GetSecretLister() corev1listers.SecretLister

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) GetV1beta1TopicLister added in v0.17.0 

func (l *Listers) GetV1beta1TopicLister() inteventsv1beta1listers.TopicLister

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

type SecretOption func(*corev1.Secret)

func WithData added in v0.20.0 

func WithData(data map[string][]byte) SecretOption

type ServiceAccountOption added in v0.14.0 

type ServiceAccountOption func(*corev1.ServiceAccount)

func WithServiceAccountAnnotation added in v0.18.1 

func WithServiceAccountAnnotation(gServiceAccount string) ServiceAccountOption

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

type TriggerOption func(*brokerv1.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 WithTriggerSubscriptionUnknown added in v0.19.0 

func WithTriggerSubscriptionUnknown(reason, msg string) TriggerOption

func WithTriggerTopicUnknown added in v0.19.0 

func WithTriggerTopicUnknown(reason, msg 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

Directories

Path Synopsis

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.