testing

package
v0.17.2 Latest Latest
Warning

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

 Go to latest Published: Aug 20, 2020 License: Apache-2.0 Imports: 57 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeFactory added in v0.6.0 

func MakeFactory(ctor Ctor, unstructured bool, logger *zap.SugaredLogger) Factory

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

func NewApiServerSourceV1Alpha2 added in v0.17.0 

func NewApiServerSourceV1Alpha2(name, namespace string, o ...V1Alpha2ApiServerSourceOption) *v1alpha2.ApiServerSource

NewApiServerSourceV1Alpha2 creates a v1alpha2 ApiServer with ApiServerOptions

func NewApiServerSourceV1Beta1 added in v0.17.0 

func NewApiServerSourceV1Beta1(name, namespace string, o ...V1Beta1ApiServerSourceOption) *v1beta1.ApiServerSource

NewApiServerSourceV1Beta1 creates a v1beta1 ApiServer with ApiServerOptions

func NewConfigMap added in v0.13.0 

func NewConfigMap(name, namespace string, o ...ConfigMapOption) *v1.ConfigMap

NewConfigMap creates a new ConfigMap.

func NewConfigMapPropagation added in v0.13.0 

func NewConfigMapPropagation(name, namespace string, o ...ConfigMapPropagationOption) *v1alpha1.ConfigMapPropagation

NewConfigMapPropagation creates a ConfigMapPropagation.

func NewContainerSourceV1Alpha2 added in v0.17.0 

func NewContainerSourceV1Alpha2(name, namespace string, o ...ContainerSourceV1Alpha2Option) *sourcesv1alpha2.ContainerSource

NewContainerSource creates a v1alpha2 ContainerSource with ContainerSourceOptions

func NewContainerSourceV1Beta1 added in v0.17.0 

func NewContainerSourceV1Beta1(name, namespace string, o ...ContainerSourceV1Beta1Option) *sourcesv1beta1.ContainerSource

NewContainerSource creates a v1beta1 ContainerSource with ContainerSourceOptions

func NewCustomResourceDefinition added in v0.7.0 

func NewCustomResourceDefinition(name string, o ...CustomResourceDefinitionOption) *apiextensionsv1.CustomResourceDefinition

NewCustomResourceDefinition creates a CustomResourceDefinition with CustomResourceDefinitionOption.

func NewDeployment added in v0.6.0 

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

NewDeployment creates a Deployment with DeploymentOptions.

func NewEndpoints added in v0.14.0 

func NewEndpoints(name, namespace string, so ...EndpointsOption) *corev1.Endpoints

NewEndpoints creates a Endpoints with EndpointsOptions

func NewEventType added in v0.6.0 

func NewEventType(name, namespace string, o ...EventTypeOption) *v1beta1.EventType

NewEventType creates a EventType with EventTypeOptions.

func NewNamespace added in v0.6.0 

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

NewNamespace creates a Namespace with NamespaceOptions

func NewPingSourceV1Alpha2 added in v0.13.0 

func NewPingSourceV1Alpha2(name, namespace string, o ...PingSourceV1A2Option) *v1alpha2.PingSource

NewPingSourceV1Alpha2 creates a PingSource with PingSourceOption.

func NewPingSourceV1Beta1 added in v0.17.0 

func NewPingSourceV1Beta1(name, namespace string, o ...PingSourceV1B1Option) *v1beta1.PingSource

NewPingSourceV1Beta1 creates a PingSource with PingSourceOption.

func NewScheme added in v0.6.0 

func NewScheme() *runtime.Scheme

func NewService added in v0.6.0 

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

NewService creates a Service with ServiceOptions

func NewSinkBindingV1Alpha1 added in v0.13.0 

func NewSinkBindingV1Alpha1(name, namespace string, o ...SinkBindingV1Alpha1Option) *sourcesv1alpha1.SinkBinding

NewSinkBindingV1Alpha1 creates a SinkBinding with SinkBindingOptions

func NewSinkBindingV1Alpha2 added in v0.13.0 

func NewSinkBindingV1Alpha2(name, namespace string, o ...SinkBindingV1Alpha2Option) *sourcesv1alpha2.SinkBinding

NewSinkBindingV1Alpha2 creates a SinkBinding with SinkBindingOptions

func NewSinkBindingV1Beta1 added in v0.17.0 

func NewSinkBindingV1Beta1(name, namespace string, o ...SinkBindingV1Beta1Option) *sourcesv1beta1.SinkBinding

NewSinkBindingV1Beta1 creates a SinkBinding with SinkBindingOptions

func NewUnstructured added in v0.6.0 

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

NewUnstructured creates a unstructured.Unstructured with UnstructuredOption

func ToUnstructured added in v0.6.0 

func ToUnstructured(t *testing.T, objs []runtime.Object) (us []runtime.Object)

ToUnstructured takes a list of k8s resources and converts them to Unstructured objects. We must pass objects as Unstructured to the dynamic client fake, or it won't handle them properly.

func WithApiServerSourceDeletedV1B1 added in v0.17.0 

func WithApiServerSourceDeletedV1B1(c *v1beta1.ApiServerSource)

func WithApiServerSourceDeployedV1B1 added in v0.17.0 

func WithApiServerSourceDeployedV1B1(s *v1beta1.ApiServerSource)

func WithApiServerSourceDeploymentUnavailableV1B1 added in v0.17.0 

func WithApiServerSourceDeploymentUnavailableV1B1(s *v1beta1.ApiServerSource)

func WithApiServerSourceNoSufficientPermissionsV1B1 added in v0.17.0 

func WithApiServerSourceNoSufficientPermissionsV1B1(s *v1beta1.ApiServerSource)

func WithApiServerSourceSinkNotFoundV1B1 added in v0.17.0 

func WithApiServerSourceSinkNotFoundV1B1(s *v1beta1.ApiServerSource)

func WithApiServerSourceSufficientPermissionsV1B1 added in v0.17.0 

func WithApiServerSourceSufficientPermissionsV1B1(s *v1beta1.ApiServerSource)

func WithConfigMapPropagationDeletionTimestamp added in v0.13.0 

func WithConfigMapPropagationDeletionTimestamp(cmp *v1alpha1.ConfigMapPropagation)

func WithConfigMapPropagationNotPropagated added in v0.13.0 

func WithConfigMapPropagationNotPropagated(cmp *v1alpha1.ConfigMapPropagation)

WithConfigMapPropagationNotPropagated calls .Status.MarkConfigMapPropagationNotPropagated on the ConfigMapPropagation.

func WithConfigMapPropagationPropagated added in v0.13.0 

func WithConfigMapPropagationPropagated(cmp *v1alpha1.ConfigMapPropagation)

WithConfigMapPropagationPropagated calls .Status.MarkConfigMapPropagationPropagated on the ConfigMapPropagation.

func WithContainerSourceDeleted added in v0.6.0 

func WithContainerSourceDeleted(c *sourcesv1beta1.ContainerSource)

func WithEventTypeBrokerDoesNotExist added in v0.6.0 

func WithEventTypeBrokerDoesNotExist(et *v1beta1.EventType)

WithEventTypeBrokerNotFound calls .Status.MarkFilterFailed on the EventType.

func WithEventTypeBrokerExists added in v0.6.0 

func WithEventTypeBrokerExists(et *v1beta1.EventType)

WithEventTypeBrokerExists calls .Status.MarkBrokerExists on the EventType.

func WithEventTypeBrokerReady added in v0.6.0 

func WithEventTypeBrokerReady(et *v1beta1.EventType)

WithEventTypeBrokerReady calls .Status.MarkBrokerReady on the EventType.

func WithEventTypeDeletionTimestamp added in v0.6.0 

func WithEventTypeDeletionTimestamp(et *v1beta1.EventType)

func WithInitApiServerSourceConditionsV1B1 added in v0.17.0 

func WithInitApiServerSourceConditionsV1B1(s *v1beta1.ApiServerSource)

WithInitApiServerSourceConditionsV1B1 initializes the v1beta1 ApiServerSource's conditions.

func WithInitConfigMapPropagationConditions added in v0.13.0 

func WithInitConfigMapPropagationConditions(cmp *v1alpha1.ConfigMapPropagation)

WithInitConfigMapPropagationConditions initializes the ConfigMapPropagation's conditions.

func WithInitContainerSourceConditionsV1B1 added in v0.17.0 

func WithInitContainerSourceConditionsV1B1(s *sourcesv1beta1.ContainerSource)

WithInitContainerSourceConditions initializes the ContainerSource's conditions.

func WithInitEventTypeConditions added in v0.6.0 

func WithInitEventTypeConditions(et *v1beta1.EventType)

WithInitEventTypeConditions initializes the EventType's conditions.

func WithInitPingSourceV1A2Conditions added in v0.14.0 

func WithInitPingSourceV1A2Conditions(s *v1alpha2.PingSource)

func WithNamespaceDeleted added in v0.6.0 

func WithNamespaceDeleted(n *corev1.Namespace)

func WithPingSourceV1A2CloudEventAttributes added in v0.16.0 

func WithPingSourceV1A2CloudEventAttributes(s *v1alpha2.PingSource)

func WithPingSourceV1A2ClusterScopeAnnotation added in v0.14.0 

func WithPingSourceV1A2ClusterScopeAnnotation(c *v1alpha2.PingSource)

func WithPingSourceV1A2Deleted added in v0.14.0 

func WithPingSourceV1A2Deleted(c *v1alpha2.PingSource)

func WithPingSourceV1A2Deployed added in v0.14.0 

func WithPingSourceV1A2Deployed(s *v1alpha2.PingSource)

func WithPingSourceV1A2ResourceScopeAnnotation added in v0.14.0 

func WithPingSourceV1A2ResourceScopeAnnotation(c *v1alpha2.PingSource)

func WithPingSourceV1A2SinkNotFound added in v0.14.0 

func WithPingSourceV1A2SinkNotFound(s *v1alpha2.PingSource)

func WithValidPingSourceV1A2Resources added in v0.14.0 

func WithValidPingSourceV1A2Resources(s *v1alpha2.PingSource)

func WithValidPingSourceV1A2Schedule added in v0.14.0 

func WithValidPingSourceV1A2Schedule(s *v1alpha2.PingSource)

Types

type Buildable 

type Buildable interface {
	Build() runtime.Object
}

Buildable allows test fixtures to use the builder pattern. The table test runner will call Build() on any Buildable objects and use the result as the test fixture.

type ConfigMapOption added in v0.13.0 

type ConfigMapOption func(*v1.ConfigMap)

ConfigMapOption enables further configuration of a ConfigMap.

func WithConfigMapData added in v0.13.0 

func WithConfigMapData(data map[string]string) ConfigMapOption

func WithConfigMapLabels added in v0.13.0 

func WithConfigMapLabels(labels metav1.LabelSelector) ConfigMapOption

func WithConfigMapOwnerReference added in v0.13.0 

func WithConfigMapOwnerReference(ConfigMapPropagation *v1alpha1.ConfigMapPropagation) ConfigMapOption

type ConfigMapPropagationOption added in v0.13.0 

type ConfigMapPropagationOption func(*v1alpha1.ConfigMapPropagation)

ConfigMapPropagationOption enables further configuration of a ConfigMapPropagation.

func WithConfigMapPropagationGeneration added in v0.13.0 

func WithConfigMapPropagationGeneration(gen int64) ConfigMapPropagationOption

func WithConfigMapPropagationSelector added in v0.13.0 

func WithConfigMapPropagationSelector(selector metav1.LabelSelector) ConfigMapPropagationOption

func WithConfigMapPropagationStatusObservedGeneration added in v0.13.0 

func WithConfigMapPropagationStatusObservedGeneration(gen int64) ConfigMapPropagationOption

func WithConfigMapPropagationUID added in v0.13.0 

func WithConfigMapPropagationUID(uid string) ConfigMapPropagationOption

func WithCopyConfigMapStatus added in v0.13.0 

func WithCopyConfigMapStatus(name, source, operation, ready, reason string) ConfigMapPropagationOption

func WithInitConfigMapStatus added in v0.13.0 

func WithInitConfigMapStatus() ConfigMapPropagationOption

type ContainerSourceV1Alpha2Option added in v0.17.0 

type ContainerSourceV1Alpha2Option func(*sourcesv1alpha2.ContainerSource)

ContainerSourceV1Alpha2Option enables further configuration of a ContainerSource.

func WithContainerSourceSpecV1A2 added in v0.17.0 

func WithContainerSourceSpecV1A2(spec sourcesv1alpha2.ContainerSourceSpec) ContainerSourceV1Alpha2Option

type ContainerSourceV1Beta1Option added in v0.17.0 

type ContainerSourceV1Beta1Option func(*sourcesv1beta1.ContainerSource)

ContainerSourceV1Beta1Option enables further configuration of a ContainerSource.

func WithContainerSourceAnnotationsV1B1 added in v0.17.0 

func WithContainerSourceAnnotationsV1B1(annotations map[string]string) ContainerSourceV1Beta1Option

func WithContainerSourceLabelsV1B1 added in v0.17.0 

func WithContainerSourceLabelsV1B1(labels map[string]string) ContainerSourceV1Beta1Option

func WithContainerSourceObjectMetaGenerationV1B1 added in v0.17.0 

func WithContainerSourceObjectMetaGenerationV1B1(generation int64) ContainerSourceV1Beta1Option

func WithContainerSourcePropagateReceiveAdapterStatusV1B1 added in v0.17.0 

func WithContainerSourcePropagateReceiveAdapterStatusV1B1(d *appsv1.Deployment) ContainerSourceV1Beta1Option

func WithContainerSourcePropagateSinkbindingStatusV1B1 added in v0.17.0 

func WithContainerSourcePropagateSinkbindingStatusV1B1(status *sourcesv1beta1.SinkBindingStatus) ContainerSourceV1Beta1Option

func WithContainerSourceSpecV1B1 added in v0.17.0 

func WithContainerSourceSpecV1B1(spec sourcesv1beta1.ContainerSourceSpec) ContainerSourceV1Beta1Option

func WithContainerSourceStatusObservedGenerationV1B1 added in v0.17.0 

func WithContainerSourceStatusObservedGenerationV1B1(generation int64) ContainerSourceV1Beta1Option

func WithContainerSourceUIDV1B1 added in v0.17.0 

func WithContainerSourceUIDV1B1(uid types.UID) ContainerSourceV1Beta1Option

func WithContainerUnobservedGenerationV1B1 added in v0.17.0 

func WithContainerUnobservedGenerationV1B1() ContainerSourceV1Beta1Option

type Ctor added in v0.6.0 

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

Ctor functions create a k8s controller with given params.

type CustomResourceDefinitionOption added in v0.7.0 

type CustomResourceDefinitionOption func(*apiextensionsv1.CustomResourceDefinition)

CustomResourceDefinitionOption enables further configuration of a CustomResourceDefinition.

func WithCustomResourceDefinitionGroup added in v0.14.0 

func WithCustomResourceDefinitionGroup(group string) CustomResourceDefinitionOption

func WithCustomResourceDefinitionLabels added in v0.7.0 

func WithCustomResourceDefinitionLabels(labels map[string]string) CustomResourceDefinitionOption

WithCustomResourceDefinitionLabels sets the CRD's labels.

func WithCustomResourceDefinitionNames added in v0.14.0 

func WithCustomResourceDefinitionNames(names apiextensionsv1.CustomResourceDefinitionNames) CustomResourceDefinitionOption

func WithCustomResourceDefinitionVersions added in v0.14.0 

func WithCustomResourceDefinitionVersions(versions []apiextensionsv1.CustomResourceDefinitionVersion) CustomResourceDefinitionOption

type DeploymentOption added in v0.6.0 

type DeploymentOption func(*appsv1.Deployment)

DeploymentOption enables further configuration of a Deployment.

func WithDeploymentAnnotations added in v0.6.0 

func WithDeploymentAnnotations(annotations map[string]string) DeploymentOption

func WithDeploymentAvailable added in v0.8.0 

func WithDeploymentAvailable() DeploymentOption

WithDeploymentAvailable marks the Deployment as available.

func WithDeploymentContainer added in v0.6.0 

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

func WithDeploymentLabels added in v0.6.0 

func WithDeploymentLabels(labels map[string]string) DeploymentOption

func WithDeploymentOwnerReferences added in v0.6.0 

func WithDeploymentOwnerReferences(ownerReferences []metav1.OwnerReference) DeploymentOption

func WithDeploymentServiceAccount added in v0.6.0 

func WithDeploymentServiceAccount(serviceAccountName string) DeploymentOption

type DynamicMocks added in v0.5.0 

type DynamicMocks struct {
	// MockResources corresponds to dynamic.Interface.
	MockResources []MockDynamicResource

	// All other fields correspond to their dynamic.ResourceInterface equivalents.
	MockCreates           []MockDynamicCreate
	MockUpdates           []MockDynamicUpdate
	MockUpdateStatuses    []MockDynamicUpdateStatus
	MockDeletes           []MockDynamicDelete
	MockDeleteCollections []MockDynamicDeleteCollection
	MockGets              []MockDynamicGet
	MockLists             []MockDynamicList
	MockWatches           []MockDynamicWatch
	MockPatches           []MockDynamicPatch
}

The mocks to run on each function type. Each function will run through the mocks in its list until one responds with 'Handled'. If there is more than one mock in the list, then the one that responds 'Handled' will be removed and not run on subsequent calls to the function. If no mocks respond 'Handled', then the real underlying client is called.

type EndpointsOption added in v0.14.0 

type EndpointsOption func(*corev1.Endpoints)

EndpointsOption enables further configuration of a Endpoints.

func WithEndpointsAddresses added in v0.14.0 

func WithEndpointsAddresses(addrs ...corev1.EndpointAddress) EndpointsOption

func WithEndpointsAnnotations added in v0.14.0 

func WithEndpointsAnnotations(annotations map[string]string) EndpointsOption

func WithEndpointsLabels added in v0.14.0 

func WithEndpointsLabels(labels map[string]string) EndpointsOption

func WithEndpointsNotReadyAddresses added in v0.14.0 

func WithEndpointsNotReadyAddresses(addrs ...corev1.EndpointAddress) EndpointsOption

type EventTypeOption added in v0.6.0 

type EventTypeOption func(*v1beta1.EventType)

EventTypeOption enables further configuration of an EventType.

func WithEventTypeBroker added in v0.6.0 

func WithEventTypeBroker(broker string) EventTypeOption

func WithEventTypeBrokerFailed added in v0.12.0 

func WithEventTypeBrokerFailed(reason, message string) EventTypeOption

func WithEventTypeBrokerUnknown added in v0.12.0 

func WithEventTypeBrokerUnknown(reason, message string) EventTypeOption

func WithEventTypeDescription added in v0.6.0 

func WithEventTypeDescription(description string) EventTypeOption

func WithEventTypeLabels added in v0.6.0 

func WithEventTypeLabels(labels map[string]string) EventTypeOption

func WithEventTypeOwnerReference added in v0.6.0 

func WithEventTypeOwnerReference(ownerRef metav1.OwnerReference) EventTypeOption

func WithEventTypeSource added in v0.6.0 

func WithEventTypeSource(source *apis.URL) EventTypeOption

func WithEventTypeType added in v0.6.0 

func WithEventTypeType(t string) EventTypeOption

type Listers added in v0.6.0 

type Listers struct {
	// contains filtered or unexported fields
}

func NewListers added in v0.6.0 

func NewListers(objs []runtime.Object) Listers

func (*Listers) GetAPIExtentionsObjects added in v0.17.0 

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

func (*Listers) GetAllObjects added in v0.6.0 

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

func (*Listers) GetApiServerSourceLister added in v0.6.0 

func (l *Listers) GetApiServerSourceLister() sourcelisters.ApiServerSourceLister

func (*Listers) GetApiServerSourceV1alpha2Lister added in v0.14.0 

func (l *Listers) GetApiServerSourceV1alpha2Lister() sourcev1alpha2listers.ApiServerSourceLister

func (*Listers) GetConfigMapLister added in v0.6.0 

func (l *Listers) GetConfigMapLister() corev1listers.ConfigMapLister

func (*Listers) GetConfigMapPropagationLister added in v0.13.0 

func (l *Listers) GetConfigMapPropagationLister() configslisters.ConfigMapPropagationLister

func (*Listers) GetContainerSourceV1alpha2Lister added in v0.17.0 

func (l *Listers) GetContainerSourceV1alpha2Lister() sourcev1alpha2listers.ContainerSourceLister

func (*Listers) GetContainerSourceV1beta1Lister added in v0.17.0 

func (l *Listers) GetContainerSourceV1beta1Lister() sourcev1beta1listers.ContainerSourceLister

func (*Listers) GetCustomResourceDefinitionLister added in v0.7.0 

func (l *Listers) GetCustomResourceDefinitionLister() apiextensionsv1listers.CustomResourceDefinitionLister

func (*Listers) GetDeploymentLister added in v0.6.0 

func (l *Listers) GetDeploymentLister() appsv1listers.DeploymentLister

func (*Listers) GetEndpointsLister added in v0.6.0 

func (l *Listers) GetEndpointsLister() corev1listers.EndpointsLister

func (*Listers) GetEventingObjects added in v0.6.0 

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

func (*Listers) GetFlowsParallelLister added in v0.11.0 

func (l *Listers) GetFlowsParallelLister() flowslisters.ParallelLister

func (*Listers) GetFlowsSequenceLister added in v0.11.0 

func (l *Listers) GetFlowsSequenceLister() flowslisters.SequenceLister

func (*Listers) GetK8sServiceLister added in v0.6.0 

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

func (*Listers) GetKubeObjects added in v0.6.0 

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

func (*Listers) GetNamespaceLister added in v0.6.0 

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

func (*Listers) GetPingSourceV1alpha2Lister added in v0.14.0 

func (l *Listers) GetPingSourceV1alpha2Lister() sourcev1alpha2listers.PingSourceLister

func (*Listers) GetRoleBindingLister added in v0.6.0 

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

func (*Listers) GetServiceAccountLister added in v0.6.0 

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

func (*Listers) GetServiceLister added in v0.7.0 

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

func (*Listers) GetSinkBindingLister added in v0.14.0 

func (l *Listers) GetSinkBindingLister() sourcelisters.SinkBindingLister

func (*Listers) GetSinkBindingV1alpha2Lister added in v0.14.0 

func (l *Listers) GetSinkBindingV1alpha2Lister() sourcev1alpha2listers.SinkBindingLister

func (*Listers) GetSinkBindingV1beta1Lister added in v0.17.0 

func (l *Listers) GetSinkBindingV1beta1Lister() sourcev1beta1listers.SinkBindingLister

func (*Listers) GetSubscriberObjects added in v0.6.0 

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

func (*Listers) GetV1Beta1BrokerLister added in v0.14.0 

func (l *Listers) GetV1Beta1BrokerLister() eventingv1beta1listers.BrokerLister

func (*Listers) GetV1Beta1EventTypeLister added in v0.16.0 

func (l *Listers) GetV1Beta1EventTypeLister() eventingv1beta1listers.EventTypeLister

func (*Listers) GetV1Beta1InMemoryChannelLister added in v0.15.0 

func (l *Listers) GetV1Beta1InMemoryChannelLister() messaginglistersv1beta1.InMemoryChannelLister

func (*Listers) GetV1Beta1MessagingChannelLister added in v0.15.0 

func (l *Listers) GetV1Beta1MessagingChannelLister() messaginglistersv1beta1.ChannelLister

func (*Listers) GetV1Beta1SubscriptionLister added in v0.15.0 

func (l *Listers) GetV1Beta1SubscriptionLister() messaginglistersv1beta1.SubscriptionLister

func (*Listers) GetV1Beta1TriggerLister added in v0.15.0 

func (l *Listers) GetV1Beta1TriggerLister() eventingv1beta1listers.TriggerLister

type MockDynamicContext added in v0.5.0 

type MockDynamicContext struct {
	InnerInterface dynamic.ResourceInterface
	Resource       schema.GroupVersionResource
	Namespace      string
}

type MockDynamicCreate added in v0.5.0 

type MockDynamicCreate func(ctx *MockDynamicContext, obj *unstructured.Unstructured, options metav1.CreateOptions, subresources ...string) (MockHandled, *unstructured.Unstructured, error)

All of the functions in dynamic.Resource get mocked equivalents. For the function dynamic.Resource.Foo(), the mocked equivalent will be: MockDynamicFoo func(ctx *MockDynamicContext[, Foo's arguments]) (MockHandled[, Foo's returns])

type MockDynamicDelete added in v0.5.0 

type MockDynamicDelete func(ctx *MockDynamicContext, name string, options *metav1.DeleteOptions, subresources ...string) (MockHandled, error)

type MockDynamicDeleteCollection added in v0.5.0 

type MockDynamicDeleteCollection func(ctx *MockDynamicContext, options *metav1.DeleteOptions, listOptions metav1.ListOptions) (MockHandled, error)

type MockDynamicGet added in v0.5.0 

type MockDynamicGet func(ctx *MockDynamicContext, name string, options metav1.GetOptions, subresources ...string) (MockHandled, *unstructured.Unstructured, error)

type MockDynamicInterface added in v0.5.0 

type MockDynamicInterface struct {
	// contains filtered or unexported fields
}

func NewMockDynamicInterface added in v0.5.0 

func NewMockDynamicInterface(innerInterface dynamic.Interface, mocks DynamicMocks) *MockDynamicInterface

func (MockDynamicInterface) Resource added in v0.5.0 

func (m MockDynamicInterface) Resource(resource schema.GroupVersionResource) dynamic.NamespaceableResourceInterface

type MockDynamicList added in v0.5.0 

type MockDynamicList func(ctx *MockDynamicContext, opts metav1.ListOptions) (MockHandled, *unstructured.UnstructuredList, error)

type MockDynamicPatch added in v0.5.0 

type MockDynamicPatch func(ctx *MockDynamicContext, name string, pt types.PatchType, data []byte, options metav1.PatchOptions, subresources ...string) (MockHandled, *unstructured.Unstructured, error)

type MockDynamicResource added in v0.5.0 

type MockDynamicResource func(innerInterface dynamic.Interface, resource schema.GroupVersionResource) (MockHandled, dynamic.NamespaceableResourceInterface)

All of the functions in dynamic.Interface get mocked equivalents.

type MockDynamicUpdate added in v0.5.0 

type MockDynamicUpdate func(ctx *MockDynamicContext, obj *unstructured.Unstructured, options metav1.UpdateOptions, subresources ...string) (MockHandled, *unstructured.Unstructured, error)

type MockDynamicUpdateStatus added in v0.5.0 

type MockDynamicUpdateStatus func(ctx *MockDynamicContext, obj *unstructured.Unstructured, options metav1.UpdateOptions) (MockHandled, *unstructured.Unstructured, error)

type MockDynamicWatch added in v0.5.0 

type MockDynamicWatch func(ctx *MockDynamicContext, opts metav1.ListOptions) (MockHandled, watch.Interface, error)

type MockEventRecorder 

type MockEventRecorder struct {
	// contains filtered or unexported fields
}

MockEventRecorder is a recorder.EventRecorder that saves emitted v1 Events.

func NewEventRecorder 

func NewEventRecorder() *MockEventRecorder

func (*MockEventRecorder) AnnotatedEventf 

func (m *MockEventRecorder) AnnotatedEventf(object runtime.Object, annotations map[string]string, eventtype, reason, messageFmt string, args ...interface{})

func (*MockEventRecorder) Event 

func (m *MockEventRecorder) Event(object runtime.Object, eventtype, reason, message string)

func (*MockEventRecorder) Eventf 

func (m *MockEventRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, args ...interface{})

func (*MockEventRecorder) PastEventf 

func (m *MockEventRecorder) PastEventf(object runtime.Object, timestamp metav1.Time, eventtype, reason, messageFmt string, args ...interface{})

type MockHandled 

type MockHandled int
const (
	// This mock has handled the function call, no further mocks nor the real client should be
	// called.
	Handled MockHandled = iota
	// This mock has not handled the function call, subsequent mocks or the real client should be
	// called.
	Unhandled
)

type NamespaceOption added in v0.6.0 

type NamespaceOption func(*corev1.Namespace)

NamespaceOption enables further configuration of a Namespace.

func WithNamespaceLabeled added in v0.6.0 

func WithNamespaceLabeled(labels map[string]string) NamespaceOption

type PingSourceV1A2Option added in v0.13.0 

type PingSourceV1A2Option func(*v1alpha2.PingSource)

PingSourceV1A2Option enables further configuration of a CronJob.

func WithPingSourceV1A2Finalizers added in v0.14.0 

func WithPingSourceV1A2Finalizers(finalizers ...string) PingSourceV1A2Option

func WithPingSourceV1A2NotDeployed added in v0.16.0 

func WithPingSourceV1A2NotDeployed(name string) PingSourceV1A2Option

func WithPingSourceV1A2ObjectMetaGeneration added in v0.16.0 

func WithPingSourceV1A2ObjectMetaGeneration(generation int64) PingSourceV1A2Option

func WithPingSourceV1A2Sink added in v0.14.0 

func WithPingSourceV1A2Sink(uri *apis.URL) PingSourceV1A2Option

func WithPingSourceV1A2Spec added in v0.13.0 

func WithPingSourceV1A2Spec(spec v1alpha2.PingSourceSpec) PingSourceV1A2Option

func WithPingSourceV1A2StatusObservedGeneration added in v0.16.0 

func WithPingSourceV1A2StatusObservedGeneration(generation int64) PingSourceV1A2Option

func WithPingSourceV1A2UID added in v0.16.0 

func WithPingSourceV1A2UID(uid string) PingSourceV1A2Option

type PingSourceV1B1Option added in v0.17.0 

type PingSourceV1B1Option func(*v1beta1.PingSource)

PingSourceV1B1Option enables further configuration of a CronJob.

func WithPingSourceV1B1Spec added in v0.17.0 

func WithPingSourceV1B1Spec(spec v1beta1.PingSourceSpec) PingSourceV1B1Option

type ServiceOption added in v0.6.0 

type ServiceOption func(*corev1.Service)

ServiceOption enables further configuration of a Service.

func WithServiceAnnotations added in v0.8.0 

func WithServiceAnnotations(annotations map[string]string) ServiceOption

func WithServiceLabels added in v0.6.0 

func WithServiceLabels(labels map[string]string) ServiceOption

func WithServiceOwnerReferences added in v0.6.0 

func WithServiceOwnerReferences(ownerReferences []metav1.OwnerReference) ServiceOption

func WithServicePorts added in v0.6.0 

func WithServicePorts(ports []corev1.ServicePort) ServiceOption

type SinkBindingV1Alpha1Option added in v0.13.0 

type SinkBindingV1Alpha1Option func(*sourcesv1alpha1.SinkBinding)

SinkBindingV1Alpha1Option enables further configuration of a SinkBinding.

func WithCloudEventOverridesV1A1 added in v0.13.0 

func WithCloudEventOverridesV1A1(overrides duckv1.CloudEventOverrides) SinkBindingV1Alpha1Option

WithCloudEventOverridesV1A1 assigns the CloudEventsOverrides of the SinkBinding.

func WithSinkV1A1 added in v0.13.0 

func WithSinkV1A1(sink duckv1.Destination) SinkBindingV1Alpha1Option

WithSinkV1A1 assigns the sink of the SinkBinding.

func WithSubjectV1A1 added in v0.13.0 

func WithSubjectV1A1(subject tracker.Reference) SinkBindingV1Alpha1Option

WithSubjectV1A1 assigns the subject of the SinkBinding.

type SinkBindingV1Alpha2Option added in v0.13.0 

type SinkBindingV1Alpha2Option func(*sourcesv1alpha2.SinkBinding)

SinkBindingV1Alpha2Option enables further configuration of a SinkBinding.

func WithCloudEventOverridesV1A2 added in v0.13.0 

func WithCloudEventOverridesV1A2(overrides duckv1.CloudEventOverrides) SinkBindingV1Alpha2Option

WithCloudEventOverridesV1A1 assigns the CloudEventsOverrides of the SinkBinding.

func WithSinkV1A2 added in v0.13.0 

func WithSinkV1A2(sink duckv1.Destination) SinkBindingV1Alpha2Option

WithSinkV1A2 assigns the sink of the SinkBinding.

func WithSubjectV1A2 added in v0.13.0 

func WithSubjectV1A2(subject tracker.Reference) SinkBindingV1Alpha2Option

WithSubjectV1A2 assigns the subject of the SinkBinding.

type SinkBindingV1Beta1Option added in v0.17.0 

type SinkBindingV1Beta1Option func(*sourcesv1beta1.SinkBinding)

SinkBindingV1Beta1Option enables further configuration of a SinkBinding.

func WithCloudEventOverridesV1B1 added in v0.17.0 

func WithCloudEventOverridesV1B1(overrides duckv1.CloudEventOverrides) SinkBindingV1Beta1Option

WithCloudEventOverridesV1B1 assigns the CloudEventsOverrides of the SinkBinding.

func WithSinkV1B1 added in v0.17.0 

func WithSinkV1B1(sink duckv1.Destination) SinkBindingV1Beta1Option

WithSinkV1B1 assigns the sink of the SinkBinding.

func WithSubjectV1B1 added in v0.17.0 

func WithSubjectV1B1(subject tracker.Reference) SinkBindingV1Beta1Option

WithSubjectV1B1 assigns the subject of the SinkBinding.

type UnstructuredOption added in v0.6.0 

type UnstructuredOption func(*unstructured.Unstructured)

UnstructuredOption enables further configuration of a Unstructured.

func WithUnstructuredAddressable added in v0.6.0 

func WithUnstructuredAddressable(hostname string) UnstructuredOption

type V1Alpha2ApiServerSourceOption added in v0.17.0 

type V1Alpha2ApiServerSourceOption func(*v1alpha2.ApiServerSource)

V1Alpha2ApiServerSourceOption enables further configuration of a v1alpha2 ApiServer.

func WithApiServerSourceSpecV1A2 added in v0.17.0 

func WithApiServerSourceSpecV1A2(spec v1alpha2.ApiServerSourceSpec) V1Alpha2ApiServerSourceOption

type V1Beta1ApiServerSourceOption added in v0.17.0 

type V1Beta1ApiServerSourceOption func(*v1beta1.ApiServerSource)

V1Beta1ApiServerSourceOption enables further configuration of a v1beta1 ApiServer.

func WithApiServerSourceEventTypesV1B1 added in v0.17.0 

func WithApiServerSourceEventTypesV1B1(source string) V1Beta1ApiServerSourceOption

func WithApiServerSourceObjectMetaGenerationV1B1 added in v0.17.0 

func WithApiServerSourceObjectMetaGenerationV1B1(generation int64) V1Beta1ApiServerSourceOption

func WithApiServerSourceSinkV1B1 added in v0.17.0 

func WithApiServerSourceSinkV1B1(uri *apis.URL) V1Beta1ApiServerSourceOption

func WithApiServerSourceSpecV1B1 added in v0.17.0 

func WithApiServerSourceSpecV1B1(spec v1beta1.ApiServerSourceSpec) V1Beta1ApiServerSourceOption

func WithApiServerSourceStatusObservedGenerationV1B1 added in v0.17.0 

func WithApiServerSourceStatusObservedGenerationV1B1(generation int64) V1Beta1ApiServerSourceOption

func WithApiServerSourceUIDV1B1 added in v0.17.0 

func WithApiServerSourceUIDV1B1(uid string) V1Beta1ApiServerSourceOption

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.