v1beta1

Documentation

Index

• func AllRouteTrafficAtRevision(names test.ResourceNames) func(r *v1beta1.Route) (bool, error)
• func CheckConfigurationState(client *test.ServingBetaClients, name string, ...) error
• func CheckRevisionState(client *test.ServingBetaClients, name string, ...) error
• func CheckRouteState(client *test.ServingBetaClients, name string, ...) error
• func CheckServiceState(client *test.ServingBetaClients, name string, ...) error
• func Configuration(names test.ResourceNames, fopt ...rtesting.ConfigOption) *v1beta1.Configuration
• func ConfigurationSpec(imagePath string) *v1.ConfigurationSpec
• func CreateConfiguration(t pkgTest.T, clients *test.Clients, names test.ResourceNames, ...) (*v1beta1.Configuration, error)
• func CreateRoute(t pkgTest.T, clients *test.Clients, names test.ResourceNames, ...) (*v1beta1.Route, error)
• func CreateService(t pkgTest.T, clients *test.Clients, names test.ResourceNames, ...) (*v1beta1.Service, error)
• func IsConfigurationReady(c *v1beta1.Configuration) (bool, error)
• func IsRevisionAtExpectedGeneration(expectedGeneration string) func(r *v1beta1.Revision) (bool, error)
• func IsRevisionPinned(r *v1beta1.Revision) (bool, error)
• func IsRevisionReady(r *v1beta1.Revision) (bool, error)
• func IsRouteNotReady(r *v1beta1.Route) (bool, error)
• func IsRouteReady(r *v1beta1.Route) (bool, error)
• func IsServiceNotReady(s *v1beta1.Service) (bool, error)
• func IsServiceReady(s *v1beta1.Service) (bool, error)
• func LogResourceObject(t pkgTest.T, value ResourceObjects)
• func PatchConfig(t pkgTest.T, clients *test.Clients, svc *v1beta1.Configuration, ...) (*v1beta1.Configuration, error)
• func PatchService(t pkgTest.T, clients *test.Clients, svc *v1beta1.Service, ...) (*v1beta1.Service, error)
• func RetryingRouteInconsistency(innerCheck spoof.ResponseChecker) spoof.ResponseChecker
• func Route(names test.ResourceNames, fopt ...rtesting.RouteOption) *v1beta1.Route
• func Service(names test.ResourceNames, fopt ...rtesting.ServiceOption) *v1beta1.Service
• func UpdateServiceRouteSpec(t pkgTest.T, clients *test.Clients, names test.ResourceNames, rs v1.RouteSpec) (*v1beta1.Service, error)
• func WaitForConfigLatestPinnedRevision(clients *test.Clients, names test.ResourceNames) (string, error)
• func WaitForConfigLatestRevision(clients *test.Clients, names test.ResourceNames, ensurePinned bool) (string, error)
• func WaitForConfigLatestUnpinnedRevision(clients *test.Clients, names test.ResourceNames) (string, error)
• func WaitForConfigurationState(client *test.ServingBetaClients, name string, ...) error
• func WaitForRevisionState(client *test.ServingBetaClients, name string, ...) error
• func WaitForRouteState(client *test.ServingBetaClients, name string, ...) error
• func WaitForServiceLatestRevision(clients *test.Clients, names test.ResourceNames) (string, error)
• func WaitForServiceState(client *test.ServingBetaClients, name string, ...) error
• type ResourceObjects
  • func CreateServiceReady(t pkgTest.T, clients *test.Clients, names *test.ResourceNames, ...) (*ResourceObjects, error)
  • func GetResourceObjects(clients *test.Clients, names test.ResourceNames) (*ResourceObjects, error)

Functions

func AllRouteTrafficAtRevision

func AllRouteTrafficAtRevision(names test.ResourceNames) func(r *v1beta1.Route) (bool, error)

AllRouteTrafficAtRevision will check the revision that route r is routing traffic to and return true if 100% of the traffic is routing to revisionName.

func CheckConfigurationState

func CheckConfigurationState(client *test.ServingBetaClients, name string, inState func(r *v1beta1.Configuration) (bool, error)) error

CheckConfigurationState verifies the status of the Configuration called name from client is in a particular state by calling `inState` and expecting `true`. This is the non-polling variety of WaitForConfigurationState

func CheckRevisionState

func CheckRevisionState(client *test.ServingBetaClients, name string, inState func(r *v1beta1.Revision) (bool, error)) error

CheckRevisionState verifies the status of the Revision called name from client is in a particular state by calling `inState` and expecting `true`. This is the non-polling variety of WaitForRevisionState

func CheckRouteState

func CheckRouteState(client *test.ServingBetaClients, name string, inState func(r *v1beta1.Route) (bool, error)) error

CheckRouteState verifies the status of the Route called name from client is in a particular state by calling `inState` and expecting `true`. This is the non-polling variety of WaitForRouteState

func CheckServiceState

func CheckServiceState(client *test.ServingBetaClients, name string, inState func(s *v1beta1.Service) (bool, error)) error

CheckServiceState verifies the status of the Service called name from client is in a particular state by calling `inState` and expecting `true`. This is the non-polling variety of WaitForServiceState.

func Configuration

func Configuration(names test.ResourceNames, fopt ...rtesting.ConfigOption) *v1beta1.Configuration

Configuration returns a Configuration object in namespace with the name names.Config that uses the image specified by names.Image

func ConfigurationSpec

func ConfigurationSpec(imagePath string) *v1.ConfigurationSpec

ConfigurationSpec returns the spec of a configuration to be used throughout different CRD helpers.

func CreateConfiguration

func CreateConfiguration(t pkgTest.T, clients *test.Clients, names test.ResourceNames, fopt ...rtesting.ConfigOption) (*v1beta1.Configuration, error)

CreateConfiguration create a configuration resource in namespace with the name names.Config that uses the image specified by names.Image.

func CreateRoute

func CreateRoute(t pkgTest.T, clients *test.Clients, names test.ResourceNames, fopt ...rtesting.RouteOption) (*v1beta1.Route, error)

CreateRoute creates a route in the given namespace using the route name in names

func CreateService

func CreateService(t pkgTest.T, clients *test.Clients, names test.ResourceNames, fopt ...rtesting.ServiceOption) (*v1beta1.Service, error)

CreateService creates a service in namespace with the name names.Service and names.Image

func IsConfigurationReady

func IsConfigurationReady(c *v1beta1.Configuration) (bool, error)

IsConfigurationReady will check the status conditions of the config and return true if the config is ready. This means it has at least created one revision and that has become ready.

func IsRevisionAtExpectedGeneration

func IsRevisionAtExpectedGeneration(expectedGeneration string) func(r *v1beta1.Revision) (bool, error)

IsRevisionAtExpectedGeneration returns a function that will check if the annotations on the revision include an annotation for the generation and that the annotation is set to the expected value.

func IsRevisionPinned

func IsRevisionPinned(r *v1beta1.Revision) (bool, error)

IsRevisionPinned will check if the revision is pinned to a route.

func IsRevisionReady

func IsRevisionReady(r *v1beta1.Revision) (bool, error)

IsRevisionReady will check the status conditions of the revision and return true if the revision is ready to serve traffic. It will return false if the status indicates a state other than deploying or being ready. It will also return false if the type of the condition is unexpected.

func IsRouteNotReady

func IsRouteNotReady(r *v1beta1.Route) (bool, error)

IsRouteNotReady will check the status conditions of the route and return true if the route is not ready.

func IsRouteReady

func IsRouteReady(r *v1beta1.Route) (bool, error)

IsRouteReady will check the status conditions of the route and return true if the route is ready.

func IsServiceNotReady

func IsServiceNotReady(s *v1beta1.Service) (bool, error)

IsServiceNotReady will check the status conditions of the service and return true if the service is not ready.

func IsServiceReady

func IsServiceReady(s *v1beta1.Service) (bool, error)

IsServiceReady will check the status conditions of the service and return true if the service is ready. This means that its configurations and routes have all reported ready.

func LogResourceObject

func LogResourceObject(t pkgTest.T, value ResourceObjects)

LogResourceObject logs the resource object with the resource name and value

func PatchConfig

func PatchConfig(t pkgTest.T, clients *test.Clients, svc *v1beta1.Configuration, fopt ...rtesting.ConfigOption) (*v1beta1.Configuration, error)

PatchConfig patches the existing configuration passed in with the applied mutations. Returns the latest configuration object

func PatchService

func PatchService(t pkgTest.T, clients *test.Clients, svc *v1beta1.Service, fopt ...rtesting.ServiceOption) (*v1beta1.Service, error)

PatchService patches the existing service passed in with the applied mutations. Returns the latest service object

func RetryingRouteInconsistency

func RetryingRouteInconsistency(innerCheck spoof.ResponseChecker) spoof.ResponseChecker

RetryingRouteInconsistency retries common requests seen when creating a new route

func Route

func Route(names test.ResourceNames, fopt ...rtesting.RouteOption) *v1beta1.Route

Route returns a Route object in namespace using the route and configuration names in names.

func Service

func Service(names test.ResourceNames, fopt ...rtesting.ServiceOption) *v1beta1.Service

Service returns a Service object in namespace with the name names.Service that uses the image specified by names.Image.

func UpdateServiceRouteSpec

func UpdateServiceRouteSpec(t pkgTest.T, clients *test.Clients, names test.ResourceNames, rs v1.RouteSpec) (*v1beta1.Service, error)

UpdateServiceRouteSpec updates a service to use the route name in names.

func WaitForConfigLatestPinnedRevision

func WaitForConfigLatestPinnedRevision(clients *test.Clients, names test.ResourceNames) (string, error)

WaitForConfigLatestPinnedRevision enables the check for pinned revision in WaitForConfigLatestRevision.

func WaitForConfigLatestRevision

func WaitForConfigLatestRevision(clients *test.Clients, names test.ResourceNames, ensurePinned bool) (string, error)

WaitForConfigLatestRevision takes a revision in through names and compares it to the current state of LatestCreatedRevisionName in Configuration. Once an update is detected in the LatestCreatedRevisionName, the function waits for the created revision to be set in LatestReadyRevisionName before returning the name of the revision. Make sure to enable ensurePinned flag if the revision has an associated Route.

func WaitForConfigLatestUnpinnedRevision

func WaitForConfigLatestUnpinnedRevision(clients *test.Clients, names test.ResourceNames) (string, error)

WaitForConfigLatestUnpinnedRevision disables the check for pinned revision in WaitForConfigLatestRevision.

func WaitForConfigurationState

func WaitForConfigurationState(client *test.ServingBetaClients, name string, inState func(c *v1beta1.Configuration) (bool, error), desc string) error

WaitForConfigurationState polls the status of the Configuration called name from client every PollInterval until inState returns `true` indicating it is done, returns an error or PollTimeout. desc will be used to name the metric that is emitted to track how long it took for name to get into the state checked by inState.

func WaitForRevisionState

func WaitForRevisionState(client *test.ServingBetaClients, name string, inState func(r *v1beta1.Revision) (bool, error), desc string) error

WaitForRevisionState polls the status of the Revision called name from client every `PollInterval` until `inState` returns `true` indicating it is done, returns an error or PollTimeout. desc will be used to name the metric that is emitted to track how long it took for name to get into the state checked by inState.

func WaitForRouteState

func WaitForRouteState(client *test.ServingBetaClients, name string, inState func(r *v1beta1.Route) (bool, error), desc string) error

WaitForRouteState polls the status of the Route called name from client every PollInterval until inState returns `true` indicating it is done, returns an error or PollTimeout. desc will be used to name the metric that is emitted to track how long it took for name to get into the state checked by inState.

func WaitForServiceLatestRevision

func WaitForServiceLatestRevision(clients *test.Clients, names test.ResourceNames) (string, error)

WaitForServiceLatestRevision takes a revision in through names and compares it to the current state of LatestCreatedRevisionName in Service. Once an update is detected in the LatestCreatedRevisionName, the function waits for the created revision to be set in LatestReadyRevisionName before returning the name of the revision.

func WaitForServiceState

func WaitForServiceState(client *test.ServingBetaClients, name string, inState func(s *v1beta1.Service) (bool, error), desc string) error

WaitForServiceState polls the status of the Service called name from client every `PollInterval` until `inState` returns `true` indicating it is done, returns an error or PollTimeout. desc will be used to name the metric that is emitted to track how long it took for name to get into the state checked by inState.

Types

type ResourceObjects

type ResourceObjects struct {
	Route    *v1beta1.Route
	Config   *v1beta1.Configuration
	Service  *v1beta1.Service
	Revision *v1beta1.Revision
}

ResourceObjects holds types of the resource objects.

func CreateServiceReady

func CreateServiceReady(t pkgTest.T, clients *test.Clients, names *test.ResourceNames, fopt ...rtesting.ServiceOption) (*ResourceObjects, error)

CreateServiceReady creates a new Service in state 'Ready'. This function expects Service and Image name passed in through 'names'. Names is updated with the Route and Configuration created by the Service and ResourceObjects is returned with the Service, Route, and Configuration objects. Returns error if the service does not come up correctly.

func GetResourceObjects

func GetResourceObjects(clients *test.Clients, names test.ResourceNames) (*ResourceObjects, error)

GetResourceObjects obtains the services resources from the k8s API server.