testing

package
v0.6.1 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2019 License: Apache-2.0 Imports: 54 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeFactory added in v0.6.0 

func MakeFactory(ctor Ctor) Factory

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

func MarkActive added in v0.6.0 

func MarkActive(r *v1alpha1.Revision)

MarkActive calls .Status.MarkActive on the Revision.

func MarkCertificateNotReady added in v0.6.0 

func MarkCertificateNotReady(r *v1alpha1.Route)

MarkCertificateNotReady calls the method of the same name on .Status

func MarkCertificateReady added in v0.6.0 

func MarkCertificateReady(r *v1alpha1.Route)

MarkCertificateReady calls the method of the same name on .Status

func MarkConfigurationNotOwned added in v0.6.0 

func MarkConfigurationNotOwned(service *v1alpha1.Service)

MarkConfigurationNotOwned calls the function of the same name on the Service's status.

func MarkContainerMissing added in v0.6.0 

func MarkContainerMissing(rev *v1alpha1.Revision)

MarkContainerMissing calls .Status.MarkContainerMissing on the Revision.

func MarkIngressReady added in v0.6.0 

func MarkIngressReady(r *v1alpha1.Route)

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

func MarkProgressDeadlineExceeded added in v0.6.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.6.0 

func MarkRevisionReady(r *v1alpha1.Revision)

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

func MarkRouteNotOwned added in v0.6.0 

func MarkRouteNotOwned(service *v1alpha1.Service)

MarkRouteNotOwned calls the function of the same name on the Service's status.

func MarkServiceNotOwned added in v0.6.0 

func MarkServiceNotOwned(r *v1alpha1.Route)

MarkServiceNotOwned calls the function of the same name on the Service's status.

func MarkServiceTimeout added in v0.6.0 

func MarkServiceTimeout(r *v1alpha1.Revision)

MarkServiceTimeout calls .Status.MarkServiceTimeout on the Revision.

func MarkTrafficAssigned added in v0.6.0 

func MarkTrafficAssigned(r *v1alpha1.Route)

MarkTrafficAssigned calls the method of the same name on .Status

func MutateK8sService added in v0.6.0 

func MutateK8sService(svc *corev1.Service)

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

func NewScheme added in v0.6.0 

func NewScheme() *runtime.Scheme

func SKS added in v0.6.0 

func SKS(ns, name string, so ...SKSOption) *netv1alpha1.ServerlessService

SKS creates a generic ServerlessService object.

func Service added in v0.6.0 

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

Service creates a service with ServiceOptions

func ServiceWithoutNamespace added in v0.6.0 

func ServiceWithoutNamespace(name string, so ...ServiceOption) *v1alpha1.Service

ServiceWithoutNamespace creates a service with ServiceOptions but without a specific namespace

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

func WithAddress(r *v1alpha1.Route)

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

func WithAnotherDomain added in v0.6.0 

func WithAnotherDomain(r *v1alpha1.Route)

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

func WithAnotherRouteFinalizer added in v0.6.0 

func WithAnotherRouteFinalizer(r *v1alpha1.Route)

WithAnotherRouteFinalizer adds a non-Route finalizer to the Route.

func WithBuild added in v0.6.0 

func WithBuild(cfg *v1alpha1.Configuration)

WithBuild adds a Build to the provided Configuration.

func WithConfigDeletionTimestamp added in v0.6.0 

func WithConfigDeletionTimestamp(r *v1alpha1.Configuration)

WithConfigDeletionTimestamp will set the DeletionTimestamp on the Config.

func WithConfigOwnersRemoved added in v0.6.0 

func WithConfigOwnersRemoved(cfg *v1alpha1.Configuration)

WithConfigOwnersRemoved clears the owner references of this Configuration.

func WithDomain added in v0.6.0 

func WithDomain(r *v1alpha1.Route)

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

func WithDomainInternal added in v0.6.0 

func WithDomainInternal(r *v1alpha1.Route)

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

func WithEndpointsOwnersRemoved added in v0.6.0 

func WithEndpointsOwnersRemoved(eps *corev1.Endpoints)

WithEndpointsOwnersRemoved clears the owner references of this Endpoints resource.

func WithHPAClass added in v0.6.0 

func WithHPAClass(pa *autoscalingv1alpha1.PodAutoscaler)

WithHPAClass updates the PA to add the hpa class annotation.

func WithHTTPSDomain added in v0.6.0 

func WithHTTPSDomain(r *v1alpha1.Route)

func WithInitRevConditions added in v0.6.0 

func WithInitRevConditions(r *v1alpha1.Revision)

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

func WithInitRouteConditions added in v0.6.0 

func WithInitRouteConditions(rt *v1alpha1.Route)

WithInitRouteConditions initializes the Service's conditions.

func WithInitSvcConditions added in v0.6.0 

func WithInitSvcConditions(s *v1alpha1.Service)

WithInitSvcConditions initializes the Service's conditions.

func WithInlineRollout added in v0.6.0 

func WithInlineRollout(s *v1alpha1.Service)

WithInlineRollout configures the Service to be "run latest" via inline Route/Configuration

func WithK8sSvcOwnersRemoved added in v0.6.0 

func WithK8sSvcOwnersRemoved(svc *corev1.Service)

WithK8sSvcOwnersRemoved clears the owner references of this Service.

func WithKPAClass added in v0.6.0 

func WithKPAClass(pa *autoscalingv1alpha1.PodAutoscaler)

WithKPAClass updates the PA to add the kpa class annotation.

func WithLocalDomain added in v0.6.0 

func WithLocalDomain(r *v1alpha1.Route)

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

func WithLogURL added in v0.6.0 

func WithLogURL(r *v1alpha1.Revision)

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

func WithManualRollout added in v0.6.0 

func WithManualRollout(s *v1alpha1.Service)

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

func WithManualStatus added in v0.6.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.6.0 

func WithNoBuild(r *v1alpha1.Revision)

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

func WithObservedGen added in v0.6.0 

func WithObservedGen(cfg *v1alpha1.Configuration)

WithObservedGen sets the observed generation of the Configuration.

func WithOngoingBuild added in v0.6.0 

func WithOngoingBuild(r *v1alpha1.Revision)

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

func WithPADeletionTimestamp added in v0.6.0 

func WithPADeletionTimestamp(r *autoscalingv1alpha1.PodAutoscaler)

WithPADeletionTimestamp will set the DeletionTimestamp on the PodAutoscaler.

func WithPAOwnersRemoved added in v0.6.0 

func WithPAOwnersRemoved(pa *autoscalingv1alpha1.PodAutoscaler)

WithPAOwnersRemoved clears the owner references of this PA resource.

func WithPodAutoscalerOwnersRemoved added in v0.6.0 

func WithPodAutoscalerOwnersRemoved(r *autoscalingv1alpha1.PodAutoscaler)

WithPodAutoscalerOwnersRemoved clears the owner references of this PodAutoscaler.

func WithPrivateService added in v0.6.0 

func WithPrivateService(sks *netv1alpha1.ServerlessService)

WithPrivateService annotates SKS status with the private service name.

func WithProxyMode added in v0.6.0 

func WithProxyMode(sks *netv1alpha1.ServerlessService)

WithProxyMode puts SKS into proxy mode.

func WithPubService added in v0.6.0 

func WithPubService(sks *netv1alpha1.ServerlessService)

WithPubService annotates SKS status with the given service name.

func WithReadyRoute added in v0.6.0 

func WithReadyRoute(s *v1alpha1.Service)

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

func WithRevisionDeletionTimestamp added in v0.6.0 

func WithRevisionDeletionTimestamp(r *v1alpha1.Revision)

WithRevisionDeletionTimestamp will set the DeletionTimestamp on the Revision.

func WithRouteDeletionTimestamp added in v0.6.0 

func WithRouteDeletionTimestamp(r *v1alpha1.Route)

WithRouteDeletionTimestamp will set the DeletionTimestamp on the Route.

func WithRouteFinalizer added in v0.6.0 

func WithRouteFinalizer(r *v1alpha1.Route)

WithRouteFinalizer adds the Route finalizer to the Route.

func WithRouteOwnersRemoved added in v0.6.0 

func WithRouteOwnersRemoved(r *v1alpha1.Route)

WithRouteOwnersRemoved clears the owner references of this Route.

func WithRunLatestRollout added in v0.6.0 

func WithRunLatestRollout(s *v1alpha1.Service)

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

func WithSKSOwnersRemoved added in v0.6.0 

func WithSKSOwnersRemoved(sks *netv1alpha1.ServerlessService)

WithSKSOwnersRemoved clears the owner references of this SKS resource.

func WithSKSReady added in v0.6.0 

func WithSKSReady(sks *netv1alpha1.ServerlessService)

WithSKSReady marks SKS as ready.

func WithServiceDeletionTimestamp added in v0.6.0 

func WithServiceDeletionTimestamp(r *v1alpha1.Service)

WithServiceDeletionTimestamp will set the DeletionTimestamp on the Service.

func WithServiceStatusRouteNotReady added in v0.6.0 

func WithServiceStatusRouteNotReady(s *v1alpha1.Service)

WithServiceStatusRouteNotReady sets the `RoutesReady` condition on the service to `Unknown`.

func WithSubsets added in v0.6.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.6.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.6.0 

func WithSuccessfulBuild(r *v1alpha1.Revision)

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

func WithSvcStatusAddress added in v0.6.0 

func WithSvcStatusAddress(s *v1alpha1.Service)

WithSvcStatusAddress updates the service's status with the address.

func WithSvcStatusDomain added in v0.6.0 

func WithSvcStatusDomain(s *v1alpha1.Service)

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

func WithTraffic added in v0.6.0 

func WithTraffic(pa *autoscalingv1alpha1.PodAutoscaler)

WithTraffic updates the PA to reflect it receiving traffic.

Types

type BuildOption added in v0.6.0 

type BuildOption func(*unstructured.Unstructured)

BuildOption enables further configuration of a Build.

func WithSucceededFalse added in v0.6.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.6.0 

func WithSucceededUnknown(reason, message string) BuildOption

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

type ClusterIngressOption added in v0.6.0 

type ClusterIngressOption func(*netv1alpha1.ClusterIngress)

ClusterIngressOption enables further configuration of the Cluster Ingress.

func WithHosts added in v0.6.0 

func WithHosts(index int, hosts ...string) ClusterIngressOption

WithHosts sets the Hosts of the ingress rule specified index

type ConfigOption added in v0.6.0 

type ConfigOption func(*v1alpha1.Configuration)

ConfigOption enables further configuration of a Configuration.

func MarkLatestCreatedFailed added in v0.6.0 

func MarkLatestCreatedFailed(msg string) ConfigOption

MarkLatestCreatedFailed calls .Status.MarkLatestCreatedFailed.

func MarkRevisionCreationFailed added in v0.6.0 

func MarkRevisionCreationFailed(msg string) ConfigOption

MarkRevisionCreationFailed calls .Status.MarkRevisionCreationFailed.

func WithConfigContainerConcurrency added in v0.6.0 

func WithConfigContainerConcurrency(cc v1beta1.RevisionContainerConcurrencyType) ConfigOption

WithConfigContainerConcurrency sets the given Configuration's concurrency.

func WithConfigLabel added in v0.6.0 

func WithConfigLabel(key, value string) ConfigOption

WithConfigLabel attaches a particular label to the configuration.

func WithCreatedAndReady added in v0.6.0 

func WithCreatedAndReady(created, ready string) ConfigOption

WithCreatedAndReady sets the latest{Created,Ready}RevisionName on the Configuration.

func WithGeneration added in v0.6.0 

func WithGeneration(gen int64) ConfigOption

WithGeneration sets the generation of the Configuration.

func WithLatestCreated added in v0.6.0 

func WithLatestCreated(name string) ConfigOption

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

func WithLatestReady added in v0.6.0 

func WithLatestReady(name string) ConfigOption

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

type Ctor added in v0.6.0 

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

Ctor functions create a k8s controller with given params.

type EndpointsOption added in v0.6.0 

type EndpointsOption func(*corev1.Endpoints)

EndpointsOption enables further configuration of the Kubernetes Endpoints.

type K8sServiceOption added in v0.6.0 

type K8sServiceOption func(*corev1.Service)

K8sServiceOption enables further configuration of the Kubernetes Service.

func OverrideServiceName added in v0.6.0 

func OverrideServiceName(name string) K8sServiceOption

OverrideServiceName changes the name of the Kubernetes Service.

func WithClusterIP added in v0.6.0 

func WithClusterIP(ip string) K8sServiceOption

WithClusterIP assigns a ClusterIP to the K8s Service.

func WithExternalName added in v0.6.0 

func WithExternalName(name string) K8sServiceOption

WithExternalName gives external name to the K8s Service.

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

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

func (*Listers) GetCMCertificateLister added in v0.6.0 

func (l *Listers) GetCMCertificateLister() certmanagerlisters.CertificateLister

GetCMCertificateLister gets lister for Cert Manager Certificate resource.

func (*Listers) GetCMCertificateObjects added in v0.6.0 

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

GetCMCertificateObjects gets a list of Cert-Manager Certificate objects.

func (*Listers) GetCachingObjects added in v0.6.0 

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

func (*Listers) GetCertificateLister added in v0.6.0 

func (l *Listers) GetCertificateLister() networkinglisters.CertificateLister

GetCertificateLister get lister for Certificate resource.

func (*Listers) GetClusterIngressLister added in v0.6.0 

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

GetClusterIngressLister get lister for ClusterIngress resource.

func (*Listers) GetConfigMapLister added in v0.6.0 

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

func (*Listers) GetConfigurationLister added in v0.6.0 

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

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

func (l *Listers) GetGatewayLister() istiolisters.GatewayLister

GetGatewayLister gets lister for Istio Gateway resource.

func (*Listers) GetHorizontalPodAutoscalerLister added in v0.6.0 

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

func (*Listers) GetImageLister added in v0.6.0 

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

func (*Listers) GetK8sServiceLister added in v0.6.0 

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

func (*Listers) GetKnCertificateLister added in v0.6.0 

func (l *Listers) GetKnCertificateLister() networkinglisters.CertificateLister

GetKnCertificateLister gets lister for Knative Certificate resource.

func (*Listers) GetKubeObjects added in v0.6.0 

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

func (*Listers) GetPodAutoscalerLister added in v0.6.0 

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

func (*Listers) GetRevisionLister added in v0.6.0 

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

func (*Listers) GetRouteLister added in v0.6.0 

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

func (*Listers) GetSecretLister added in v0.6.0 

func (l *Listers) GetSecretLister() corev1listers.SecretLister

func (*Listers) GetServerlessServiceLister added in v0.6.0 

func (l *Listers) GetServerlessServiceLister() networkinglisters.ServerlessServiceLister

GetServerlessServiceLister returns a lister for the ServerlessService objects.

func (*Listers) GetServiceLister added in v0.6.0 

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

func (*Listers) GetServingObjects added in v0.6.0 

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

func (*Listers) GetSharedObjects added in v0.6.0 

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

func (*Listers) GetVirtualServiceLister added in v0.6.0 

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

type PodAutoscalerOption added in v0.6.0 

type PodAutoscalerOption func(*autoscalingv1alpha1.PodAutoscaler)

PodAutoscalerOption is an option that can be applied to a PA.

func MarkResourceNotOwnedByPA added in v0.6.0 

func MarkResourceNotOwnedByPA(rType, name string) PodAutoscalerOption

MarkResourceNotOwnedByPA marks PA when it's now owning a resources it is supposed to own.

func WithBufferedTraffic added in v0.6.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.6.0 

func WithContainerConcurrency(cc v1beta1.RevisionContainerConcurrencyType) PodAutoscalerOption

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

func WithMetricAnnotation added in v0.6.0 

func WithMetricAnnotation(metric string) PodAutoscalerOption

WithMetricAnnotation adds a metric annotation to the PA.

func WithNoTraffic added in v0.6.0 

func WithNoTraffic(reason, message string) PodAutoscalerOption

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

func WithPAStatusService added in v0.6.0 

func WithPAStatusService(svc string) PodAutoscalerOption

WithPAStatusService annotats PA Status with the provided service name.

func WithPanicThresholdPercentageAnnotation added in v0.6.0 

func WithPanicThresholdPercentageAnnotation(percentage string) PodAutoscalerOption

WithPanicThresholdPercentageAnnotation returns a PodAutoscalerOption which sets the PodAutoscaler autoscaling.knative.dev/targetPanicPercentage annotation to the provided value.

func WithPanicWindowPercentageAnnotation added in v0.6.0 

func WithPanicWindowPercentageAnnotation(percentage string) PodAutoscalerOption

WithWindowPanicPercentageAnnotation retturn a PodAutoscalerOption which set the PodAutoscaler autoscaling.knative.dev/windowPanicPercentage annotation to the provided value.

func WithProtocolType added in v0.6.0 

func WithProtocolType(pt networking.ProtocolType) PodAutoscalerOption

WithProtocolType sets the protocol type on the PodAutoscaler.

func WithTargetAnnotation added in v0.6.0 

func WithTargetAnnotation(target string) PodAutoscalerOption

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

func WithWindowAnnotation added in v0.6.0 

func WithWindowAnnotation(window string) PodAutoscalerOption

WithWindowAnnotation returns a PodAutoScalerOption which sets the PodAutoscaler autoscaling.knative.dev/window annotation to the provided value.

type PodOption added in v0.6.0 

type PodOption func(*corev1.Pod)

PodOption enables further configuration of a Pod.

func WithFailingContainer added in v0.6.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.6.0 

type RevisionOption func(*v1alpha1.Revision)

RevisionOption enables further configuration of a Revision.

func MarkActivating added in v0.6.0 

func MarkActivating(reason, message string) RevisionOption

MarkActivating calls .Status.MarkActivating on the Revision.

func MarkContainerExiting added in v0.6.0 

func MarkContainerExiting(exitCode int32, message string) RevisionOption

MarkContainerExiting calls .Status.MarkContainerExiting on the Revision.

func MarkDeploying added in v0.6.0 

func MarkDeploying(reason string) RevisionOption

MarkDeploying calls .Status.MarkDeploying on the Revision.

func MarkInactive added in v0.6.0 

func MarkInactive(reason, message string) RevisionOption

MarkInactive calls .Status.MarkInactive on the Revision.

func MarkResourceNotOwned added in v0.6.0 

func MarkResourceNotOwned(kind, name string) RevisionOption

MarkResourceNotOwned calls the function of the same name on the Revision's status.

func WithBuildRef added in v0.6.0 

func WithBuildRef(name string) RevisionOption

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

func WithCreationTimestamp added in v0.6.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.6.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.6.0 

func WithLastPinned(t time.Time) RevisionOption

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

func WithRevContainerConcurrency added in v0.6.0 

func WithRevContainerConcurrency(cc v1beta1.RevisionContainerConcurrencyType) RevisionOption

WithRevContainerConcurrency sets the given Revision's concurrency.

func WithRevName added in v0.6.0 

func WithRevName(name string) RevisionOption

WithRevName sets the name of the revision

func WithRevStatus added in v0.6.0 

func WithRevStatus(st v1alpha1.RevisionStatus) RevisionOption

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

func WithServiceName added in v0.6.0 

func WithServiceName(sn string) RevisionOption

WithServiceName propagates the given service name to the revision status.

type RouteOption added in v0.6.0 

type RouteOption func(*v1alpha1.Route)

RouteOption enables further configuration of a Route.

func MarkConfigurationFailed added in v0.6.0 

func MarkConfigurationFailed(name string) RouteOption

MarkConfigurationFailed calls the method of the same name on .Status

func MarkConfigurationNotReady added in v0.6.0 

func MarkConfigurationNotReady(name string) RouteOption

MarkConfigurationNotReady calls the method of the same name on .Status

func MarkMissingTrafficTarget added in v0.6.0 

func MarkMissingTrafficTarget(kind, revision string) RouteOption

MarkMissingTrafficTarget calls the method of the same name on .Status

func WithConfigTarget added in v0.6.0 

func WithConfigTarget(config string) RouteOption

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

func WithIngressClass added in v0.6.0 

func WithIngressClass(ingressClass string) RouteOption

WithIngressClass sets the ingress class annotation on the Route.

func WithRevTarget added in v0.6.0 

func WithRevTarget(revision string) RouteOption

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

func WithRouteLabel added in v0.6.0 

func WithRouteLabel(key, value string) RouteOption

WithRouteLabel sets the specified label on the Route.

func WithRouteUID added in v0.6.0 

func WithRouteUID(uid types.UID) RouteOption

WithRouteUID sets the Route's UID

func WithSpecTraffic added in v0.6.0 

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

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

func WithStatusTraffic added in v0.6.0 

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

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

type SKSOption added in v0.6.0 

type SKSOption func(sks *netv1alpha1.ServerlessService)

SKSOption is a callback type for decorate SKS objects.

func WithDeployRef added in v0.6.0 

func WithDeployRef(name string) SKSOption

WithDeployRef annotates SKS with a deployment objectRef

type ServiceOption added in v0.6.0 

type ServiceOption func(*v1alpha1.Service)

ServiceOption enables further configuration of a Service.

func WithConfigAnnotations added in v0.6.0 

func WithConfigAnnotations(annotations map[string]string) ServiceOption

WithConfigAnnotations assigns config annotations to a service

func WithEnv added in v0.6.0 

func WithEnv(evs ...corev1.EnvVar) ServiceOption

WithEnv configures the Service to use the provided environment variables.

func WithEnvFrom added in v0.6.0 

func WithEnvFrom(evs ...corev1.EnvFromSource) ServiceOption

WithEnvFrom configures the Service to use the provided environment variables.

func WithFailedConfig added in v0.6.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.6.0 

func WithFailedRoute(reason, message string) ServiceOption

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

func WithInlineConfigSpec added in v0.6.0 

func WithInlineConfigSpec(config v1alpha1.ConfigurationSpec) ServiceOption

WithInlineConfigSpec confgures the Service to use the given config spec

func WithInlineRouteSpec added in v0.6.0 

func WithInlineRouteSpec(config v1alpha1.RouteSpec) ServiceOption

WithInlineRouteSpec confgures the Service to use the given route spec

func WithPinnedRollout added in v0.6.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 WithPinnedRolloutConfigSpec added in v0.6.0 

func WithPinnedRolloutConfigSpec(name string, config v1alpha1.ConfigurationSpec) ServiceOption

WithPinnedRolloutConfigSpec WithPinnedRollout2

func WithReadyConfig added in v0.6.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.6.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.6.0 

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

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

func WithReleaseRolloutAndPercentageConfigSpec added in v0.6.0 

func WithReleaseRolloutAndPercentageConfigSpec(percentage int, config v1alpha1.ConfigurationSpec, names ...string) ServiceOption

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

func WithReleaseRolloutConfigSpec added in v0.6.0 

func WithReleaseRolloutConfigSpec(config v1alpha1.ConfigurationSpec, names ...string) ServiceOption

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

func WithResourceRequirements added in v0.6.0 

func WithResourceRequirements(resourceRequirements corev1.ResourceRequirements) ServiceOption

WithResourceRequirements attaches resource requirements to the service

func WithRevisionTimeoutSeconds added in v0.6.0 

func WithRevisionTimeoutSeconds(revisionTimeoutSeconds int64) ServiceOption

WithRevisionTimeoutSeconds sets revision timeout

func WithRunLatestConfigSpec added in v0.6.0 

func WithRunLatestConfigSpec(config v1alpha1.ConfigurationSpec) ServiceOption

WithRunLatestConfigSpec confgures the Service to use a "runLatest" configuration

func WithServiceAnnotations added in v0.6.0 

func WithServiceAnnotations(annotations map[string]string) ServiceOption

func WithServiceLabel added in v0.6.0 

func WithServiceLabel(key, value string) ServiceOption

WithServiceLabel attaches a particular label to the service.

func WithServiceLatestReadyRevision added in v0.6.0 

func WithServiceLatestReadyRevision(lrr string) ServiceOption

WithServiceLatestReadyRevision sets the latest ready revision on the Service's status.

func WithSvcStatusTraffic added in v0.6.0 

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

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

func WithVolume added in v0.6.0 

func WithVolume(name, mountPath string, volumeSource corev1.VolumeSource) ServiceOption

WithVolume adds a volume to the service

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.