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

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

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

Jump to

Keyboard shortcuts

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