testing

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Jan 8, 2019 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	HookComplete   = testing.HookComplete
	HookIncomplete = testing.HookIncomplete
)

Variables

View Source 
var (
	InduceFailure             = testing.InduceFailure
	KeyOrDie                  = testing.KeyOrDie
	NewHooks                  = testing.NewHooks
	ExpectNormalEventDelivery = testing.ExpectNormalEventDelivery
	ValidateCreates           = testing.ValidateCreates
	ValidateUpdates           = testing.ValidateUpdates
	ConfigMapFromTestFile     = testing.ConfigMapFromTestFile
	Eventf                    = testing.Eventf

	TestLogger = logtesting.TestLogger
)

Functions

func MarkActive added in v0.3.0 

func MarkActive(r *v1alpha1.Revision)

MarkActive calls .Status.MarkActive on the Revision.

func MarkContainerMissing added in v0.3.0 

func MarkContainerMissing(rev *v1alpha1.Revision)

MarkContainerMissing calls .Status.MarkContainerMissing on the Revision.

func MarkIngressReady added in v0.3.0 

func MarkIngressReady(r *v1alpha1.Route)

MarkIngressReady propagates a Ready=True ClusterIngress status to the Route.

func MarkProgressDeadlineExceeded added in v0.3.0 

func MarkProgressDeadlineExceeded(r *v1alpha1.Revision)

MarkProgressDeadlineExceeded calls the method of the same name on the Revision with the message we expect the Revision Reconciler to pass.

func MarkRevisionReady added in v0.3.0 

func MarkRevisionReady(r *v1alpha1.Revision)

MarkRevisionReady calls the necessary helpers to make the Revision Ready=True.

func MarkServiceTimeout added in v0.3.0 

func MarkServiceTimeout(r *v1alpha1.Revision)

MarkServiceTimeout calls .Status.MarkServiceTimeout on the Revision.

func MarkTrafficAssigned added in v0.3.0 

func MarkTrafficAssigned(r *v1alpha1.Route)

MarkTrafficAssigned calls the method of the same name on .Status

func MutateK8sService added in v0.3.0 

func MutateK8sService(svc *corev1.Service)

MutateK8sService changes the service in a way that must be reconciled.

func WithAddress added in v0.3.0 

func WithAddress(r *v1alpha1.Route)

WithAddress sets the .Status.Address field to the prototypical internal hostname.

func WithAnotherDomain added in v0.3.0 

func WithAnotherDomain(r *v1alpha1.Route)

WithAnotherDomain sets the .Status.Domain field to an atypical domain.

func WithBuild added in v0.3.0 

func WithBuild(cfg *v1alpha1.Configuration)

WithBuild adds a Build to the provided Configuration.

func WithDomain added in v0.3.0 

func WithDomain(r *v1alpha1.Route)

WithDomain sets the .Status.Domain field to the prototypical domain.

func WithDomainInternal added in v0.3.0 

func WithDomainInternal(r *v1alpha1.Route)

WithDomainInternal sets the .Status.DomainInternal field to the prototypical internal domain.

func WithEmptyLTTs added in v0.3.0 

func WithEmptyLTTs(r *v1alpha1.Revision)

WithEmptyLTTs clears the LastTransitionTime fields on all of the conditions of the provided Revision.

func WithHPAClass added in v0.3.0 

func WithHPAClass(pa *autoscalingv1alpha1.PodAutoscaler)

WithHPAClass updates the PA to add the hpa class annotation.

func WithInitRevConditions added in v0.3.0 

func WithInitRevConditions(r *v1alpha1.Revision)

WithInitRevConditions calls .Status.InitializeConditions() on a Revision.

func WithInitRouteConditions added in v0.3.0 

func WithInitRouteConditions(rt *v1alpha1.Route)

WithInitRouteConditions initializes the Service's conditions.

func WithInitSvcConditions added in v0.3.0 

func WithInitSvcConditions(s *v1alpha1.Service)

WithInitSvcConditions initializes the Service's conditions.

func WithKPAClass added in v0.3.0 

func WithKPAClass(pa *autoscalingv1alpha1.PodAutoscaler)

WithKPAClass updates the PA to add the kpa class annotation.

func WithLatestCreated added in v0.3.0 

func WithLatestCreated(cfg *v1alpha1.Configuration)

WithLatestCreated initializes the .status.latestCreatedRevisionName to be the name of the latest revision that the Configuration would have created.

func WithLatestReady added in v0.3.0 

func WithLatestReady(cfg *v1alpha1.Configuration)

WithLatestReady initializes the .status.latestReadyRevisionName to be the name of the latest revision that the Configuration would have created.

func WithLocalDomain added in v0.3.0 

func WithLocalDomain(r *v1alpha1.Route)

WithLocalDomain sets the .Status.Domain field to use `svc.cluster.local` suffix.

func WithLogURL added in v0.3.0 

func WithLogURL(r *v1alpha1.Revision)

WithLogURL sets the .Status.LogURL to the expected value.

func WithManualRollout added in v0.3.0 

func WithManualRollout(s *v1alpha1.Service)

WithManualRollout configures the Service to use a "manual" rollout.

func WithManualStatus added in v0.3.0 

func WithManualStatus(s *v1alpha1.Service)

WithManualStatus configures the Service to have the appropriate status for a "manual" rollout type.

func WithNoBuild added in v0.3.0 

func WithNoBuild(r *v1alpha1.Revision)

WithNoBuild updates the status conditions to propagate a Build status as-if no BuildRef was specified.

func WithObservedGen added in v0.3.0 

func WithObservedGen(cfg *v1alpha1.Configuration)

WithObservedGen sets the observed generation of the Configuration.

func WithOngoingBuild added in v0.3.0 

func WithOngoingBuild(r *v1alpha1.Revision)

WithOngoingBuild propagates the status of an in-progress Build to the Revision's status.

func WithReadyRoute added in v0.3.0 

func WithReadyRoute(s *v1alpha1.Service)

WithReadyRoute reflects the Route's readiness in the Service resource.

func WithRunLatestRollout added in v0.3.0 

func WithRunLatestRollout(s *v1alpha1.Service)

WithRunLatestRollout configures the Service to use a "runLatest" rollout.

func WithSubsets added in v0.3.0 

func WithSubsets(ep *corev1.Endpoints)

WithSubsets adds subsets to the body of a Revision, enabling us to refer readiness.

func WithSucceededTrue added in v0.3.0 

func WithSucceededTrue(orig *unstructured.Unstructured)

WithSucceededTrue updates the status of the provided unstructured Build object with the expected success condition.

func WithSuccessfulBuild added in v0.3.0 

func WithSuccessfulBuild(r *v1alpha1.Revision)

WithSuccessfulBuild propagates the status of a successful Build to the Revision's status.

func WithSvcStatusAddress added in v0.3.0 

func WithSvcStatusAddress(s *v1alpha1.Service)

WithSvcStatusAddress updates the service's status with the address.

func WithSvcStatusDomain added in v0.3.0 

func WithSvcStatusDomain(s *v1alpha1.Service)

WithSvcStatusDomain propagates the domain name to the status of the Service.

func WithTraffic added in v0.3.0 

func WithTraffic(pa *autoscalingv1alpha1.PodAutoscaler)

WithTraffic updates the PA to reflect it receiving traffic.

Types

type ActionRecorder 

type ActionRecorder = testing.ActionRecorder

type ActionRecorderList 

type ActionRecorderList = testing.ActionRecorderList

type BuildOption added in v0.3.0 

type BuildOption func(*unstructured.Unstructured)

BuildOption enables further configuration of a Build.

func WithSucceededFalse added in v0.3.0 

func WithSucceededFalse(reason, message string) BuildOption

WithSucceededFalse updates the status of the provided unstructured Build object with the expected failure condition.

func WithSucceededUnknown added in v0.3.0 

func WithSucceededUnknown(reason, message string) BuildOption

WithSucceededUnknown updates the status of the provided unstructured Build object with the expected in-flight condition.

type ConfigOption added in v0.3.0 

type ConfigOption func(*v1alpha1.Configuration)

ConfigOption enables further configuration of a Configuration.

func MarkLatestCreatedFailed added in v0.3.0 

func MarkLatestCreatedFailed(msg string) ConfigOption

MarkLatestCreatedFailed calls .Status.MarkLatestCreatedFailed.

func MarkRevisionCreationFailed added in v0.3.0 

func MarkRevisionCreationFailed(msg string) ConfigOption

MarkRevisionCreationFailed calls .Status.MarkRevisionCreationFailed.

func WithConfigConcurrencyModel added in v0.3.0 

func WithConfigConcurrencyModel(ss v1alpha1.RevisionRequestConcurrencyModelType) ConfigOption

WithConfigConcurrencyModel sets the given Configuration's concurrency model.

func WithConfigLabel added in v0.3.0 

func WithConfigLabel(key, value string) ConfigOption

WithConfigLabel attaches a particular label to the configuration.

func WithGeneration added in v0.3.0 

func WithGeneration(gen int64) ConfigOption

WithGeneration sets the generation of the Configuration.

type Ctor 

type Ctor func(*Listers, reconciler.Options) controller.Reconciler

Ctor functions create a k8s controller with given params.

type EndpointsOption added in v0.3.0 

type EndpointsOption func(*corev1.Endpoints)

EndpointsOption enables further configuration of the Kubernetes Endpoints.

type EventList added in v0.3.0 

type EventList = testing.EventList

type Factory 

type Factory = testing.Factory

func MakeFactory 

func MakeFactory(ctor Ctor) Factory

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

type FakeClock 

type FakeClock struct {
	Time time.Time
}

func (FakeClock) Now 

func (c FakeClock) Now() time.Time

type FakeStatsReporter added in v0.3.0 

type FakeStatsReporter = testing.FakeStatsReporter

type HookResult 

type HookResult = testing.HookResult

type K8sServiceOption added in v0.3.0 

type K8sServiceOption func(*corev1.Service)

K8sServiceOption enables further configuration of the Kubernetes Service.

func WithClusterIP added in v0.3.0 

func WithClusterIP(ip string) K8sServiceOption

func WithExternalName added in v0.3.0 

func WithExternalName(name string) K8sServiceOption

type Listers 

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

func NewListers 

func NewListers(objs []runtime.Object) Listers

func (*Listers) GetBuildObjects 

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

func (*Listers) GetCachingObjects 

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

func (*Listers) GetClusterIngressLister 

func (l *Listers) GetClusterIngressLister() networkinglisters.ClusterIngressLister

GetClusterIngressLister get lister for ClusterIngress resource.

func (*Listers) GetConfigMapLister 

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

func (*Listers) GetConfigurationLister 

func (l *Listers) GetConfigurationLister() servinglisters.ConfigurationLister

func (*Listers) GetDeploymentLister 

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

func (*Listers) GetEndpointsLister 

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

func (*Listers) GetHorizontalPodAutoscalerLister added in v0.3.0 

func (l *Listers) GetHorizontalPodAutoscalerLister() autoscalingv1listers.HorizontalPodAutoscalerLister

func (*Listers) GetImageLister 

func (l *Listers) GetImageLister() cachinglisters.ImageLister

func (*Listers) GetK8sServiceLister 

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

func (*Listers) GetKubeObjects 

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

func (*Listers) GetPodAutoscalerLister added in v0.3.0 

func (l *Listers) GetPodAutoscalerLister() kpalisters.PodAutoscalerLister

func (*Listers) GetRevisionLister 

func (l *Listers) GetRevisionLister() servinglisters.RevisionLister

func (*Listers) GetRouteLister 

func (l *Listers) GetRouteLister() servinglisters.RouteLister

func (*Listers) GetServiceLister 

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

func (*Listers) GetServingObjects 

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

func (*Listers) GetSharedObjects 

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

func (*Listers) GetVirtualServiceLister 

func (l *Listers) GetVirtualServiceLister() istiolisters.VirtualServiceLister

type PodAutoscalerOption added in v0.3.0 

type PodAutoscalerOption func(*autoscalingv1alpha1.PodAutoscaler)

func WithBufferedTraffic added in v0.3.0 

func WithBufferedTraffic(reason, message string) PodAutoscalerOption

WithBufferedTraffic updates the PA to reflect that it has received and buffered traffic while it is being activated.

func WithContainerConcurrency added in v0.3.0 

func WithContainerConcurrency(cc int32) PodAutoscalerOption

WithContainerConcurrency returns a PodAutoscalerOption which sets the PodAutoscaler containerConcurrency to the provided value.

func WithMetricAnnotation added in v0.3.0 

func WithMetricAnnotation(metric string) PodAutoscalerOption

WithMetricAnnotation adds a metric annotation to the PA.

func WithNoTraffic added in v0.3.0 

func WithNoTraffic(reason, message string) PodAutoscalerOption

WithNoTraffic updates the PA to reflect the fact that it is not receiving traffic.

func WithTargetAnnotation added in v0.3.0 

func WithTargetAnnotation(target string) PodAutoscalerOption

WithTargetAnnotation returns a PodAutoscalerOption which sets the PodAutoscaler autoscaling.knative.dev/target to the provided value.

type PodOption added in v0.3.0 

type PodOption func(*corev1.Pod)

PodOption enables further configuration of a Pod.

func WithFailingContainer added in v0.3.0 

func WithFailingContainer(name string, exitCode int, message string) PodOption

WithFailingContainer sets the .Status.ContainerStatuses on the pod to include a container named accordingly to fail with the given state.

type RevisionOption added in v0.3.0 

type RevisionOption func(*v1alpha1.Revision)

RevisionOption enables further configuration of a Revision.

func MarkActivating added in v0.3.0 

func MarkActivating(reason, message string) RevisionOption

MarkActivating calls .Status.MarkActivating on the Revision.

func MarkContainerExiting added in v0.3.0 

func MarkContainerExiting(exitCode int32, message string) RevisionOption

MarkContainerExiting calls .Status.MarkContainerExiting on the Revision.

func MarkDeploying added in v0.3.0 

func MarkDeploying(reason string) RevisionOption

MarkDeploying calls .Status.MarkDeploying on the Revision.

func MarkInactive added in v0.3.0 

func MarkInactive(reason, message string) RevisionOption

MarkInactive calls .Status.MarkInactive on the Revision.

func WithBuildRef added in v0.3.0 

func WithBuildRef(name string) RevisionOption

WithBuildRef sets the .Spec.BuildRef on the Revision to match what we'd get using WithBuild(name).

func WithCreationTimestamp added in v0.3.0 

func WithCreationTimestamp(t time.Time) RevisionOption

WithCreationTimestamp sets the Revision's timestamp to the provided time. TODO(mattmoor): Ideally this could be a more generic Option and use meta.Accessor, but unfortunately Go's type system cannot support that.

func WithFailedBuild added in v0.3.0 

func WithFailedBuild(reason, message string) RevisionOption

WithFailedBuild propagates the status of a failed Build to the Revision's status.

func WithLastPinned added in v0.3.0 

func WithLastPinned(t time.Time) RevisionOption

WithLastPinned updates the "last pinned" annotation to the provided timestamp.

func WithRevConcurrencyModel added in v0.3.0 

func WithRevConcurrencyModel(ss v1alpha1.RevisionRequestConcurrencyModelType) RevisionOption

WithRevConcurrencyModel sets the concurrency model on the Revision.

func WithRevStatus added in v0.3.0 

func WithRevStatus(st v1alpha1.RevisionStatus) RevisionOption

WithRevStatus is a generic escape hatch for creating hard-to-craft status orientations.

type RouteOption added in v0.3.0 

type RouteOption func(*v1alpha1.Route)

RouteOption enables further configuration of a Route.

func MarkConfigurationFailed added in v0.3.0 

func MarkConfigurationFailed(name string) RouteOption

MarkConfigurationFailed calls the method of the same name on .Status

func MarkConfigurationNotReady added in v0.3.0 

func MarkConfigurationNotReady(name string) RouteOption

MarkConfigurationNotReady calls the method of the same name on .Status

func MarkMissingTrafficTarget added in v0.3.0 

func MarkMissingTrafficTarget(kind, revision string) RouteOption

MarkMissingTrafficTarget calls the method of the same name on .Status

func WithConfigTarget added in v0.3.0 

func WithConfigTarget(config string) RouteOption

WithConfigTarget sets the Route's traffic block to point at a particular Configuration.

func WithRevTarget added in v0.3.0 

func WithRevTarget(revision string) RouteOption

WithRevTarget sets the Route's traffic block to point at a particular Revision.

func WithRouteLabel added in v0.3.0 

func WithRouteLabel(key, value string) RouteOption

WithRouteLabel sets the specified label on the Route.

func WithSpecTraffic added in v0.3.0 

func WithSpecTraffic(traffic ...v1alpha1.TrafficTarget) RouteOption

WithSpecTraffic sets the Route's traffic block to the specified traffic targets.

func WithStatusTraffic added in v0.3.0 

func WithStatusTraffic(traffic ...v1alpha1.TrafficTarget) RouteOption

WithStatusTraffic sets the Route's status traffic block to the specified traffic targets.

type ServiceOption added in v0.3.0 

type ServiceOption func(*v1alpha1.Service)

ServiceOption enables further configuration of a Service.

func WithFailedConfig added in v0.3.0 

func WithFailedConfig(name, reason, message string) ServiceOption

WithFailedConfig reflects the Configuration's failure in the Service resource. The failing revision's name is reflected in LatestCreated.

func WithFailedRoute added in v0.3.0 

func WithFailedRoute(reason, message string) ServiceOption

WithFailedRoute reflects a Route's failure in the Service resource.

func WithPinnedRollout added in v0.3.0 

func WithPinnedRollout(name string) ServiceOption

WithPinnedRollout configures the Service to use a "pinned" rollout, which is pinned to the named revision. Deprecated, since PinnedType is deprecated.

func WithReadyConfig added in v0.3.0 

func WithReadyConfig(name string) ServiceOption

WithReadyConfig reflects the Configuration's readiness in the Service resource. This must coincide with the setting of Latest{Created,Ready} to the provided revision name.

func WithReleaseRollout added in v0.3.0 

func WithReleaseRollout(names ...string) ServiceOption

WithReleaseRollout configures the Service to use a "release" rollout, which spans the provided revisions.

func WithReleaseRolloutAndPercentage added in v0.3.0 

func WithReleaseRolloutAndPercentage(percentage int, names ...string) ServiceOption

WithReleaseRolloutAndPercentage configures the Service to use a "release" rollout, which spans the provided revisions.

func WithServiceLabel added in v0.3.0 

func WithServiceLabel(key, value string) ServiceOption

WithServiceLabel attaches a particular label to the service.

func WithSvcStatusTraffic added in v0.3.0 

func WithSvcStatusTraffic(traffic ...v1alpha1.TrafficTarget) ServiceOption

WithSvcStatusTraffic sets the Service's status traffic block to the specified traffic targets.

type TableRow 

type TableRow = testing.TableRow

type TableTest 

type TableTest = testing.TableTest

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.