test

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Jun 26, 2020 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const (
	StockImageName = "villardl/stock-60d7d0dbe2427b272042abacd4e1e644"
)
View Source 
const (
	// TestTag identifies the test id
	TestTag = "testid"
)

Variables

This section is empty.

Functions

func CheckDeploymentReady 

func CheckDeploymentReady(obj runtime.Object) (bool, error)

func CheckExperimentFailure 

func CheckExperimentFailure(obj runtime.Object) (bool, error)

func CheckExperimentFinished 

func CheckExperimentFinished(obj runtime.Object) (bool, error)

func CheckExperimentPause added in v0.1.0 

func CheckExperimentPause(obj runtime.Object) (bool, error)

func CheckExperimentSuccess 

func CheckExperimentSuccess(obj runtime.Object) (bool, error)

func CheckLatestReadyRevisionName 

func CheckLatestReadyRevisionName(name string) func(obj runtime.Object) (bool, error)

func CheckServiceFound 

func CheckServiceFound(obj runtime.Object) (bool, error)

func CheckServiceNotFound 

func CheckServiceNotFound(reason string) func(obj runtime.Object) (bool, error)

func CheckServiceReady 

func CheckServiceReady(obj runtime.Object) (bool, error)

func GetAbortExperimentResponse 

func GetAbortExperimentResponse() api.Response

func GetDefaultMockResponse 

func GetDefaultMockResponse() api.Response

func GetFailureMockResponse 

func GetFailureMockResponse() api.Response

func GetSuccessMockResponse 

func GetSuccessMockResponse() api.Response

func Logger 

func Logger(t *testing.T) logr.Logger

Logger creates logger for the test

func WaitForDelete 

func WaitForDelete(ctx context.Context, cl client.Client, obj runtime.Object) error

WaitForDelete polls the obj existence

func WaitForState 

func WaitForState(ctx context.Context, cl client.Client, obj runtime.Object, inState InStateFunc) error

WaitForState polls the status of the object called name from client every `interval` until `inState` returns `true` indicating it is done, returns an error or timeout

Types

type AnalyticsService 

type AnalyticsService struct {

	// Mock maps request to response. The key maps to request.name
	Mock map[string]api.Response
	// contains filtered or unexported fields
}

AnalyticsService with mock response

func StartAnalytics 

func StartAnalytics() *AnalyticsService

StartAnalytics starts fake analytics service

func (*AnalyticsService) AddMock 

func (s *AnalyticsService) AddMock(name string, response api.Response)

Mock adds response for testid

func (*AnalyticsService) Close 

func (s *AnalyticsService) Close()

Close the service

func (*AnalyticsService) GetURL 

func (s *AnalyticsService) GetURL() string

GetURL returns the service URL

func (*AnalyticsService) ServeHTTP 

func (s *AnalyticsService) ServeHTTP(w http.ResponseWriter, r *http.Request)

type DeploymentBuilder 

type DeploymentBuilder appsv1.Deployment

func NewKubernetesDeployment 

func NewKubernetesDeployment(name, namespace string) *DeploymentBuilder

NewKubernetesDeployment returns a kubernetes deployment

func (*DeploymentBuilder) Build 

func (d *DeploymentBuilder) Build() *appsv1.Deployment

Build converts builder to deployment

func (*DeploymentBuilder) WithContainer 

func (d *DeploymentBuilder) WithContainer(name, image string, port int) *DeploymentBuilder

WithContainer adds a container spec to the deployment

func (*DeploymentBuilder) WithLabels 

func (d *DeploymentBuilder) WithLabels(l map[string]string) *DeploymentBuilder

WithLabels adds labels to the deployment

type ExperimentBuilder 

type ExperimentBuilder v1alpha1.Experiment

ExperimentBuilder builds experiment object

func NewExperiment 

func NewExperiment(name string, namespace string) *ExperimentBuilder

NewExperiment create a new miminal experiment object

func (*ExperimentBuilder) Build 

func (b *ExperimentBuilder) Build() *v1alpha1.Experiment

Build the experiment object

func (*ExperimentBuilder) WithAnalyticsHost 

func (b *ExperimentBuilder) WithAnalyticsHost(host string) *ExperimentBuilder

func (*ExperimentBuilder) WithDummySuccessCriterion 

func (b *ExperimentBuilder) WithDummySuccessCriterion() *ExperimentBuilder

WithDummySuccessCriterion adds a dummy success criterion

func (*ExperimentBuilder) WithHostInTargetService added in v0.2.0 

func (b *ExperimentBuilder) WithHostInTargetService(host, gateway string) *ExperimentBuilder

func (*ExperimentBuilder) WithKNativeService 

func (b *ExperimentBuilder) WithKNativeService(name string) *ExperimentBuilder

WithKNativeService adds KNative target service

func (*ExperimentBuilder) WithKubernetesTargetService 

func (b *ExperimentBuilder) WithKubernetesTargetService(name, baseline, candidate string) *ExperimentBuilder

WithKubernetesTargetService adds Kubernetes targetService

func (*ExperimentBuilder) WithKubernetesTargetServiceKind added in v0.2.0 

func (b *ExperimentBuilder) WithKubernetesTargetServiceKind(kind string) *ExperimentBuilder

WithKubernetesTargetServiceKind specifies kind of baseline/candidate

func (*ExperimentBuilder) WithResumeAction added in v0.1.0 

func (b *ExperimentBuilder) WithResumeAction() *ExperimentBuilder

func (*ExperimentBuilder) WithSuccessCriterion 

func (b *ExperimentBuilder) WithSuccessCriterion(sc v1alpha1.SuccessCriterion) *ExperimentBuilder

WithSuccessCriterion adds a success criterion

type Hook 

type Hook func(ctx context.Context, cl client.Client) error

Hook defines a function with a client.

func CheckObjectDeleted 

func CheckObjectDeleted(objects ...runtime.Object) Hook

func CreateObject added in v0.1.1 

func CreateObject(obj runtime.Object) Hook

func DeleteExperiment 

func DeleteExperiment(name string, namespace string) Hook

func DeleteObject 

func DeleteObject(obj runtime.Object) Hook

func DeleteObjectIfExists 

func DeleteObjectIfExists(obj runtime.Object) Hook

func ResumeExperiment added in v0.1.0 

func ResumeExperiment(exp *v1alpha1.Experiment) Hook

func UpdateObject added in v0.1.0 

func UpdateObject(obj runtime.Object) Hook

type InStateFunc 

type InStateFunc func(obj runtime.Object) (bool, error)

func WantAllStates 

func WantAllStates(stateFns ...InStateFunc) InStateFunc

type KnativeServiceBuilder 

type KnativeServiceBuilder servingalpha1.Service

KnativeServiceBuilder builds Knative service object

func NewKnativeService 

func NewKnativeService(name string, namespace string) *KnativeServiceBuilder

NewKnativeService creates a default Knative service with one revision

func (*KnativeServiceBuilder) Build 

func (b *KnativeServiceBuilder) Build() *servingalpha1.Service

Build the Knative Service object

func (*KnativeServiceBuilder) WithEnv 

func (b *KnativeServiceBuilder) WithEnv(name string, value string) *KnativeServiceBuilder

func (*KnativeServiceBuilder) WithImage 

func (b *KnativeServiceBuilder) WithImage(name string) *KnativeServiceBuilder

func (*KnativeServiceBuilder) WithRevision 

func (b *KnativeServiceBuilder) WithRevision(revisionName string, percent int64) *KnativeServiceBuilder

type ServiceBuilder 

type ServiceBuilder corev1.Service

func NewKubernetesService 

func NewKubernetesService(name, namespace string) *ServiceBuilder

NewKubernetesService returns a kubernetes service

func (*ServiceBuilder) Build 

func (s *ServiceBuilder) Build() *corev1.Service

Build converts builder to service

func (*ServiceBuilder) WithPorts 

func (s *ServiceBuilder) WithPorts(ports map[string]int) *ServiceBuilder

WithPorts adds ports to the service

func (*ServiceBuilder) WithSelector 

func (s *ServiceBuilder) WithSelector(selector map[string]string) *ServiceBuilder

WithSelector adds selector labels to the service

Source Files

View all Source files

Directories

Path Synopsis
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License.
 Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License.

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.