testing

package
v0.17.4 Latest Latest
Warning

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

Go to latest
Published: Oct 29, 2020 License: Apache-2.0 Imports: 70 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 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 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 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 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 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) (*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 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 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 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 WithBrokerDeliverySpec added in v0.17.0

func WithBrokerDeliverySpec(deliverySpec *eventingduckv1beta1.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 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 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 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() eventsv1beta1listers.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 (*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

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 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 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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL