testing

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2019 License: Apache-2.0 Imports: 40 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeFactory 

func MakeFactory(ctor Ctor) Factory

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

func NewChannel 

func NewChannel(name, namespace string, so ...ChannelOption) *v1alpha1.Channel

NewChannel creates a Channel with ChannelOptions

func NewChannelWithoutNamespace 

func NewChannelWithoutNamespace(name string, so ...ChannelOption) *v1alpha1.Channel

NewChannelWithoutNamespace creates a Channel with ChannelOptions but without a specific namespace

func NewDeployment 

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

NewDeployment creates a Deployment with DeploymentOptions.

func NewNamespace 

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

NewNamespace creates a Namespace with NamespaceOptions

func NewPullSubscription 

func NewPullSubscription(name, namespace string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription

NewPullSubscription creates a PullSubscription with PullSubscriptionOptions

func NewPullSubscriptionWithoutNamespace 

func NewPullSubscriptionWithoutNamespace(name string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription

NewPullSubscriptionWithoutNamespace creates a PullSubscription with PullSubscriptionOptions but without a specific namespace

func NewService 

func NewService(name, namespace string, so ...ServiceOption) *corev1.Service

NewService creates a Service with ServiceOptions

func NewTopic 

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

NewTopic creates a Topic with TopicOptions

func NewUnstructured 

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

NewUnstructured creates a unstructured.Unstructured with UnstructuredOption

func WithChannelDefaults 

func WithChannelDefaults(s *v1alpha1.Channel)

func WithChannelDeleted 

func WithChannelDeleted(s *v1alpha1.Channel)

func WithInitChannelConditions 

func WithInitChannelConditions(s *v1alpha1.Channel)

WithInitChannelConditions initializes the Channels's conditions.

func WithInitPullSubscriptionConditions 

func WithInitPullSubscriptionConditions(s *v1alpha1.PullSubscription)

WithInitPullSubscriptionConditions initializes the PullSubscriptions's conditions.

func WithInitTopicConditions 

func WithInitTopicConditions(s *v1alpha1.Topic)

WithInitTopicConditions initializes the Topics's conditions.

func WithNamespaceDeleted 

func WithNamespaceDeleted(n *corev1.Namespace)

func WithPullSubscriptionDeleted 

func WithPullSubscriptionDeleted(s *v1alpha1.PullSubscription)

func WithTopicDeleted 

func WithTopicDeleted(s *v1alpha1.Topic)

func WithTopicDeployed 

func WithTopicDeployed(s *v1alpha1.Topic)

Types

type ChannelOption 

type ChannelOption func(*v1alpha1.Channel)

ChannelOption enables further configuration of a Channel.

func WithChannelAddress 

func WithChannelAddress(url string) ChannelOption

func WithChannelGenerateName 

func WithChannelGenerateName(generateName string) ChannelOption

func WithChannelLabels 

func WithChannelLabels(labels map[string]string) ChannelOption

func WithChannelMarkTopicCreating 

func WithChannelMarkTopicCreating(topicID string) ChannelOption

func WithChannelOwnerReferences 

func WithChannelOwnerReferences(ownerReferences []metav1.OwnerReference) ChannelOption

func WithChannelReady 

func WithChannelReady(topicID string) ChannelOption

func WithChannelSpec 

func WithChannelSpec(spec v1alpha1.ChannelSpec) ChannelOption

func WithChannelSubscribers 

func WithChannelSubscribers(subscribers []duckv1alpha1.SubscriberSpec) ChannelOption

func WithChannelSubscribersStatus 

func WithChannelSubscribersStatus(subscribers []duckv1alpha1.SubscriberStatus) ChannelOption

func WithChannelTopic 

func WithChannelTopic(topicID string) ChannelOption

func WithChannelUID 

func WithChannelUID(uid types.UID) ChannelOption

type Ctor 

type Ctor func(context.Context, *Listers, configmap.Watcher) controller.Reconciler

Ctor functions create a k8s controller with given params.

type DeploymentOption 

type DeploymentOption func(*appsv1.Deployment)

DeploymentOption enables further configuration of a Deployment.

func WithDeploymentAnnotations 

func WithDeploymentAnnotations(annotations map[string]string) DeploymentOption

func WithDeploymentContainer 

func WithDeploymentContainer(name, image string, envVars []corev1.EnvVar, containerPorts []corev1.ContainerPort) DeploymentOption

func WithDeploymentLabels 

func WithDeploymentLabels(labels map[string]string) DeploymentOption

func WithDeploymentOwnerReferences 

func WithDeploymentOwnerReferences(ownerReferences []metav1.OwnerReference) DeploymentOption

func WithDeploymentServiceAccount 

func WithDeploymentServiceAccount(serviceAccountName string) DeploymentOption

type Listers 

type Listers struct {
	servingv1alpha1listers.ConfigurationLister
	// contains filtered or unexported fields
}

func NewListers 

func NewListers(objs []runtime.Object) Listers

func (*Listers) GetAllObjects 

func (l *Listers) GetAllObjects() []runtime.Object

func (*Listers) GetChannelLister 

func (l *Listers) GetChannelLister() eventslisters.ChannelLister

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

func (l *Listers) GetK8sServiceLister() corev1listers.ServiceLister

func (*Listers) GetKubeObjects 

func (l *Listers) GetKubeObjects() []runtime.Object

func (*Listers) GetNamespaceLister 

func (l *Listers) GetNamespaceLister() corev1listers.NamespaceLister

func (*Listers) GetPullSubscriptionLister 

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

func (*Listers) GetRoleBindingLister 

func (l *Listers) GetRoleBindingLister() rbacv1listers.RoleBindingLister

func (*Listers) GetServiceAccountLister 

func (l *Listers) GetServiceAccountLister() corev1listers.ServiceAccountLister

func (*Listers) GetServingObjects 

func (l *Listers) GetServingObjects() []runtime.Object

func (*Listers) GetSharedObjects 

func (l *Listers) GetSharedObjects() []runtime.Object

func (*Listers) GetSinkObjects 

func (l *Listers) GetSinkObjects() []runtime.Object

func (*Listers) GetTopicLister 

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

func (*Listers) GetV1alpha1ServiceLister 

func (l *Listers) GetV1alpha1ServiceLister() servingv1alpha1listers.ServiceLister

func (*Listers) GetV1beta1ServiceLister 

func (l *Listers) GetV1beta1ServiceLister() servingv1beta1listers.ServiceLister

type NamespaceOption 

type NamespaceOption func(*corev1.Namespace)

NamespaceOption enables further configuration of a Namespace.

func WithNamespaceLabeled 

func WithNamespaceLabeled(labels map[string]string) NamespaceOption

type PullSubscriptionOption 

type PullSubscriptionOption func(*v1alpha1.PullSubscription)

PullSubscriptionOption enables further configuration of a PullSubscription.

func WithPullSubscriptionFinalizers 

func WithPullSubscriptionFinalizers(finalizers ...string) PullSubscriptionOption

func WithPullSubscriptionGenerateName 

func WithPullSubscriptionGenerateName(generateName string) PullSubscriptionOption

func WithPullSubscriptionLabels 

func WithPullSubscriptionLabels(labels map[string]string) PullSubscriptionOption

func WithPullSubscriptionMarkNoSubscription 

func WithPullSubscriptionMarkNoSubscription(subscriptionID string) PullSubscriptionOption

func WithPullSubscriptionMarkSink 

func WithPullSubscriptionMarkSink(uri string) PullSubscriptionOption

func WithPullSubscriptionMarkSubscribing 

func WithPullSubscriptionMarkSubscribing(subscriptionID string) PullSubscriptionOption

func WithPullSubscriptionMarkUnsubscribing 

func WithPullSubscriptionMarkUnsubscribing(subscriptionID string) PullSubscriptionOption

func WithPullSubscriptionOwnerReferences 

func WithPullSubscriptionOwnerReferences(ownerReferences []metav1.OwnerReference) PullSubscriptionOption

func WithPullSubscriptionReady 

func WithPullSubscriptionReady(sink string) PullSubscriptionOption

func WithPullSubscriptionSink 

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

func WithPullSubscriptionSinkNotFound 

func WithPullSubscriptionSinkNotFound() PullSubscriptionOption

func WithPullSubscriptionSpec 

func WithPullSubscriptionSpec(spec v1alpha1.PullSubscriptionSpec) PullSubscriptionOption

func WithPullSubscriptionSubscription 

func WithPullSubscriptionSubscription(subscriptionID string) PullSubscriptionOption

func WithPullSubscriptionUID 

func WithPullSubscriptionUID(uid types.UID) PullSubscriptionOption

type ServiceOption 

type ServiceOption func(*corev1.Service)

ServiceOption enables further configuration of a Service.

func WithServiceLabels 

func WithServiceLabels(labels map[string]string) ServiceOption

func WithServiceOwnerReferences 

func WithServiceOwnerReferences(ownerReferences []metav1.OwnerReference) ServiceOption

func WithServicePorts 

func WithServicePorts(ports []corev1.ServicePort) ServiceOption

type TopicOption 

type TopicOption func(*v1alpha1.Topic)

TopicOption enables further configuration of a Topic.

func WithTopicAddress 

func WithTopicAddress(uri string) TopicOption

func WithTopicFinalizers 

func WithTopicFinalizers(finalizers ...string) TopicOption

func WithTopicLabels 

func WithTopicLabels(labels map[string]string) TopicOption

func WithTopicMarkTopicCreating 

func WithTopicMarkTopicCreating(topicID string) TopicOption

func WithTopicMarkTopicVerifying 

func WithTopicMarkTopicVerifying(topicID string) TopicOption

func WithTopicOwnerReferences 

func WithTopicOwnerReferences(ownerReferences []metav1.OwnerReference) TopicOption

func WithTopicPropagationPolicy 

func WithTopicPropagationPolicy(policy string) TopicOption

func WithTopicReady 

func WithTopicReady(topicID string) TopicOption

func WithTopicSpec 

func WithTopicSpec(spec v1alpha1.TopicSpec) TopicOption

func WithTopicTopicDeleted 

func WithTopicTopicDeleted(topicID string) TopicOption

func WithTopicTopicDeleting 

func WithTopicTopicDeleting(topicID string) TopicOption

func WithTopicTopicID 

func WithTopicTopicID(topicID string) TopicOption

func WithTopicUID 

func WithTopicUID(uid types.UID) TopicOption

type UnstructuredOption 

type UnstructuredOption func(*unstructured.Unstructured)

UnstructuredOption enables further configuration of a Unstructured.

func WithUnstructuredAddressable 

func WithUnstructuredAddressable(hostname string) UnstructuredOption

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.