testing

package
v0.16.1 Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2020 License: Apache-2.0 Imports: 54 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 NewApiServerSource added in v0.6.0 

func NewApiServerSource(name, namespace string, o ...ApiServerSourceOption) *v1alpha2.ApiServerSource

NewApiServerSource creates a 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 NewContainerSource added in v0.6.0 

func NewContainerSource(name, namespace string, o ...ContainerSourceOption) *sourcesv1alpha2.ContainerSource

NewContainerSource creates a ContainerSource with ContainerSourceOptions

func NewCustomResourceDefinition added in v0.7.0 

func NewCustomResourceDefinition(name string, o ...CustomResourceDefinitionOption) *apiextensionsv1beta1.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 NewPingSourceV1Alpha1 added in v0.13.0 

func NewPingSourceV1Alpha1(name, namespace string, o ...PingSourceOption) *v1alpha1.PingSource

NewPingSourceV1Alpha1 creates a PingSource with PingSourceOption.

func NewPingSourceV1Alpha2 added in v0.13.0 

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

NewPingSourceV1Alpha2 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 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 WithApiServerSourceDeleted added in v0.6.0 

func WithApiServerSourceDeleted(c *v1alpha2.ApiServerSource)

func WithApiServerSourceDeployed added in v0.6.0 

func WithApiServerSourceDeployed(s *v1alpha2.ApiServerSource)

func WithApiServerSourceDeploymentUnavailable added in v0.8.0 

func WithApiServerSourceDeploymentUnavailable(s *v1alpha2.ApiServerSource)

func WithApiServerSourceNoSufficientPermissions added in v0.11.0 

func WithApiServerSourceNoSufficientPermissions(s *v1alpha2.ApiServerSource)

func WithApiServerSourceSinkNotFound added in v0.6.0 

func WithApiServerSourceSinkNotFound(s *v1alpha2.ApiServerSource)

func WithApiServerSourceSufficientPermissions added in v0.11.0 

func WithApiServerSourceSufficientPermissions(s *v1alpha2.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 *sourcesv1alpha2.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 WithInitApiServerSourceConditions added in v0.6.0 

func WithInitApiServerSourceConditions(s *v1alpha2.ApiServerSource)

WithInitApiServerSourceConditions initializes the ApiServerSource's conditions.

func WithInitConfigMapPropagationConditions added in v0.13.0 

func WithInitConfigMapPropagationConditions(cmp *v1alpha1.ConfigMapPropagation)

WithInitConfigMapPropagationConditions initializes the ConfigMapPropagation's conditions.

func WithInitContainerSourceConditions added in v0.6.0 

func WithInitContainerSourceConditions(s *sourcesv1alpha2.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 WithInitPingSourceConditions added in v0.13.0 

func WithInitPingSourceConditions(s *v1alpha1.PingSource)

WithInitPingSourceConditions initializes the PingSource's conditions.

func WithInitPingSourceV1A2Conditions added in v0.14.0 

func WithInitPingSourceV1A2Conditions(s *v1alpha2.PingSource)

func WithInvalidPingSourceSchedule added in v0.13.0 

func WithInvalidPingSourceSchedule(s *v1alpha1.PingSource)

func WithNamespaceDeleted added in v0.6.0 

func WithNamespaceDeleted(n *corev1.Namespace)

func WithPingSourceClusterScopeAnnotation added in v0.14.0 

func WithPingSourceClusterScopeAnnotation(c *v1alpha1.PingSource)

func WithPingSourceDeleted added in v0.13.0 

func WithPingSourceDeleted(c *v1alpha1.PingSource)

func WithPingSourceDeployed added in v0.13.0 

func WithPingSourceDeployed(s *v1alpha1.PingSource)

func WithPingSourceEventType added in v0.13.0 

func WithPingSourceEventType(s *v1alpha1.PingSource)

func WithPingSourceResourceScopeAnnotation added in v0.14.0 

func WithPingSourceResourceScopeAnnotation(c *v1alpha1.PingSource)

func WithPingSourceSinkNotFound added in v0.13.0 

func WithPingSourceSinkNotFound(s *v1alpha1.PingSource)

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 WithValidPingSourceResources added in v0.13.0 

func WithValidPingSourceResources(s *v1alpha1.PingSource)

func WithValidPingSourceSchedule added in v0.13.0 

func WithValidPingSourceSchedule(s *v1alpha1.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 ApiServerSourceOption added in v0.6.0 

type ApiServerSourceOption func(*v1alpha2.ApiServerSource)

ApiServerSourceOption enables further configuration of a ApiServer.

func WithApiServerSourceEventTypes added in v0.6.0 

func WithApiServerSourceEventTypes(source string) ApiServerSourceOption

func WithApiServerSourceObjectMetaGeneration added in v0.9.0 

func WithApiServerSourceObjectMetaGeneration(generation int64) ApiServerSourceOption

func WithApiServerSourceSink added in v0.6.0 

func WithApiServerSourceSink(uri *apis.URL) ApiServerSourceOption

func WithApiServerSourceSpec added in v0.6.0 

func WithApiServerSourceSpec(spec v1alpha2.ApiServerSourceSpec) ApiServerSourceOption

func WithApiServerSourceStatusObservedGeneration added in v0.9.0 

func WithApiServerSourceStatusObservedGeneration(generation int64) ApiServerSourceOption

func WithApiServerSourceUID added in v0.9.0 

func WithApiServerSourceUID(uid string) ApiServerSourceOption

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 ContainerSourceOption added in v0.6.0 

type ContainerSourceOption func(*sourcesv1alpha2.ContainerSource)

ContainerSourceOption enables further configuration of a ContainerSource.

func WithContainerSourceAnnotations added in v0.6.0 

func WithContainerSourceAnnotations(annotations map[string]string) ContainerSourceOption

func WithContainerSourceLabels added in v0.6.0 

func WithContainerSourceLabels(labels map[string]string) ContainerSourceOption

func WithContainerSourceObjectMetaGeneration added in v0.9.0 

func WithContainerSourceObjectMetaGeneration(generation int64) ContainerSourceOption

func WithContainerSourcePropagateReceiveAdapterStatus added in v0.14.0 

func WithContainerSourcePropagateReceiveAdapterStatus(d *appsv1.Deployment) ContainerSourceOption

func WithContainerSourcePropagateSinkbindingStatus added in v0.14.0 

func WithContainerSourcePropagateSinkbindingStatus(status *sourcesv1alpha2.SinkBindingStatus) ContainerSourceOption

func WithContainerSourceSpec added in v0.6.0 

func WithContainerSourceSpec(spec sourcesv1alpha2.ContainerSourceSpec) ContainerSourceOption

func WithContainerSourceStatusObservedGeneration added in v0.9.0 

func WithContainerSourceStatusObservedGeneration(generation int64) ContainerSourceOption

func WithContainerSourceUID added in v0.6.0 

func WithContainerSourceUID(uid types.UID) ContainerSourceOption

func WithContainerUnobservedGeneration added in v0.16.0 

func WithContainerUnobservedGeneration() ContainerSourceOption

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(*apiextensionsv1beta1.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 apiextensionsv1beta1.CustomResourceDefinitionNames) CustomResourceDefinitionOption

func WithCustomResourceDefinitionVersions added in v0.14.0 

func WithCustomResourceDefinitionVersions(versions []apiextensionsv1beta1.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) 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) GetContainerSourceLister added in v0.6.0 

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

func (*Listers) GetCustomResourceDefinitionLister added in v0.7.0 

func (l *Listers) GetCustomResourceDefinitionLister() apiextensionsv1beta1listers.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) GetPingSourceLister added in v0.13.0 

func (l *Listers) GetPingSourceLister() sourcelisters.PingSourceLister

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) 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 PingSourceOption added in v0.13.0 

type PingSourceOption func(*v1alpha1.PingSource)

PingSourceOption enables further configuration of a CronJob.

func WithPingSourceApiVersion added in v0.13.0 

func WithPingSourceApiVersion(apiVersion string) PingSourceOption

func WithPingSourceNotDeployed added in v0.14.0 

func WithPingSourceNotDeployed(name string) PingSourceOption

func WithPingSourceObjectMetaGeneration added in v0.13.0 

func WithPingSourceObjectMetaGeneration(generation int64) PingSourceOption

func WithPingSourceSink added in v0.13.0 

func WithPingSourceSink(uri *apis.URL) PingSourceOption

func WithPingSourceSpec added in v0.13.0 

func WithPingSourceSpec(spec v1alpha1.PingSourceSpec) PingSourceOption

func WithPingSourceStatusObservedGeneration added in v0.13.0 

func WithPingSourceStatusObservedGeneration(generation int64) PingSourceOption

func WithPingSourceUID added in v0.13.0 

func WithPingSourceUID(uid string) PingSourceOption

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

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.