Documentation

Index

Constants

View Source
const (
	CertKey    = "certificates"
	AppNameKey = "appname"
)

Variables

This section is empty.

Functions

func PEMToCertificate

func PEMToCertificate(pemCert PEMCertificate) (tls.Certificate, error)

Types

type CheckCounterPod

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

CheckCounterPod is a step which checks if counter has been updated in test pod

func NewCheckCounterPod

func NewCheckCounterPod(testService *testkit.TestService, expectedValue int, opts ...retrygo.Option) *CheckCounterPod

NewCheckCounterPod returns new CheckCounterPod

func (*CheckCounterPod) Cleanup

func (s *CheckCounterPod) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (*CheckCounterPod) Name

func (s *CheckCounterPod) Name() string

Name returns name name of the step

func (*CheckCounterPod) Run

func (s *CheckCounterPod) Run() error

Run executes the step

type ConnectApplication

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

ConnectApplication is a step which connects application with client certificates and saves connected httpClient in the state

func NewConnectApplication

func NewConnectApplication(connector *testkit.ConnectorClient, state ConnectApplicationState, tenant, group string) *ConnectApplication

NewConnectApplication returns new ConnectApplication

func (ConnectApplication) Cleanup

func (s ConnectApplication) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (ConnectApplication) Name

func (s ConnectApplication) Name() string

Name returns name name of the step

func (ConnectApplication) Run

func (s ConnectApplication) Run() error

Run executes the step

type ConnectApplicationState

type ConnectApplicationState interface {
	SetGatewayClientCerts(certs []tls.Certificate)
}

ConnectApplicationState allows ConnectApplication to save connected http.Client for further use by other steps

type ConnectApplicationUsingCompass

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

ConnectApplicationUsingCompass is a step which connects application with client certificates and saves connected httpClient in the state

func NewConnectApplicationUsingCompass

NewConnectApplicationUsingCompass returns new ConnectApplicationUsingCompass

func (ConnectApplicationUsingCompass) Cleanup

Cleanup removes all resources that may possibly created by the step

func (ConnectApplicationUsingCompass) Name

Name returns name name of the step

func (ConnectApplicationUsingCompass) Run

Run executes the step

type ConnectApplicationUsingCompassLegacy

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

ConnectApplicationUsingCompass is a step which connects application with client certificates and saves connected httpClient in the state

func NewConnectApplicationUsingCompassLegacy

NewConnectApplicationUsingCompass returns new ConnectApplicationUsingCompass

func (ConnectApplicationUsingCompassLegacy) Cleanup

Cleanup removes all resources that may possibly created by the step

func (ConnectApplicationUsingCompassLegacy) Name

Name returns name name of the step

func (ConnectApplicationUsingCompassLegacy) Run

Run executes the step

type ConnectApplicationUsingCompassLegacyState

type ConnectApplicationUsingCompassLegacyState interface {
	SetGatewayClientCerts(certs []tls.Certificate)
	GetCompassAppID() string
}

ConnectApplicationUsingCompassState allows ConnectApplicationUsingCompass to save connected http.Client for further use by other steps

type ConnectApplicationUsingCompassState

type ConnectApplicationUsingCompassState interface {
	SetGatewayClientCerts(certs []tls.Certificate)
	GetCompassAppID() string
}

ConnectApplicationUsingCompassState allows ConnectApplicationUsingCompass to save connected http.Client for further use by other steps

type CreateApplication

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

CreateApplication is a step which creates new Application

func NewCreateApplication

func NewCreateApplication(name, accessLabel string, skipInstallation bool, tenant, group string,
	applications appconnectorclientset.ApplicationInterface, httpSourceClient esclientset.HTTPSourceInterface) *CreateApplication

NewCreateApplication returns new CreateApplication

func (*CreateApplication) Cleanup

func (s *CreateApplication) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (*CreateApplication) Name

func (s *CreateApplication) Name() string

Name returns name name of the step

func (*CreateApplication) Run

func (s *CreateApplication) Run() error

Run executes the step

type CreateKnativeTrigger

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

func NewCreateKnativeTrigger

func NewCreateKnativeTrigger(triggerName, brokerName, endpoint string, trigger eventingv1alpha1client.TriggerInterface) *CreateKnativeTrigger

NewCreateKnativeTrigger returns new CreateKnativeTrigger

func (CreateKnativeTrigger) Cleanup

func (c CreateKnativeTrigger) Cleanup() error

func (CreateKnativeTrigger) Name

func (c CreateKnativeTrigger) Name() string

func (CreateKnativeTrigger) Run

func (c CreateKnativeTrigger) Run() error

type CreateLambdaServiceBindingUsage

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

CreateLambdaServiceBindingUsage is a step which creates new ServiceBindingUsage

func NewCreateServiceBindingUsage

func NewCreateServiceBindingUsage(name, serviceBindingName, lambdaName string,
	serviceBindingUsages sbuclientset.ServiceBindingUsageInterface,
	knativeBroker eventingv1alpha1clientset.BrokerInterface,
	knativeSubscription messagingv1alpha1clientset.SubscriptionInterface) *CreateLambdaServiceBindingUsage

NewCreateServiceBindingUsage returns new CreateLambdaServiceBindingUsage

func (*CreateLambdaServiceBindingUsage) Cleanup

Cleanup removes all resources that may possibly created by the step

func (*CreateLambdaServiceBindingUsage) Name

Name returns name name of the step

func (*CreateLambdaServiceBindingUsage) Run

Run executes the step

type CreateLegacyServiceInstance

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

CreateLegacyServiceInstance is a step which creates new ServiceInstance

func NewCreateLegacyServiceInstance

func NewCreateLegacyServiceInstance(name, instanceName string, get func() string, serviceInstances servicecatalogclientset.ServiceInstanceInterface, serviceClasses servicecatalogclientset.ServiceClassInterface) *CreateLegacyServiceInstance

NewCreateLegacyServiceInstance returns new CreateLegacyServiceInstance

func (*CreateLegacyServiceInstance) Cleanup

func (s *CreateLegacyServiceInstance) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (*CreateLegacyServiceInstance) Name

Name returns name name of the step

func (*CreateLegacyServiceInstance) Run

Run executes the step

type CreateMapping

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

CreateMapping is a step which creates new Mapping

func NewCreateMapping

func NewCreateMapping(name string, mappings appbrokerclientset.ApplicationMappingInterface) *CreateMapping

NewCreateMapping returns new CreateMapping

func (*CreateMapping) Cleanup

func (s *CreateMapping) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (*CreateMapping) Name

func (s *CreateMapping) Name() string

Name returns name name of the step

func (*CreateMapping) Run

func (s *CreateMapping) Run() error

Run executes the step

type CreateNamespace

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

CreateNamespace is a step which creates new Namespace

func NewCreateNamespace

func NewCreateNamespace(name string, namespaces coreclient.NamespaceInterface) *CreateNamespace

NewCreateApplication returns new CreateApplication

func (*CreateNamespace) Cleanup

func (s *CreateNamespace) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (*CreateNamespace) Name

func (s *CreateNamespace) Name() string

Name returns name name of the step

func (*CreateNamespace) Run

func (s *CreateNamespace) Run() error

Run executes the step

type CreateServiceBinding

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

CreateServiceBinding is a step which creates new ServiceBinding

func NewCreateServiceBinding

func NewCreateServiceBinding(name, serviceName string, serviceBindings servicecatalogclientset.ServiceBindingInterface) *CreateServiceBinding

NewCreateServiceBinding returns new CreateServiceBinding

func (*CreateServiceBinding) Cleanup

func (s *CreateServiceBinding) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (*CreateServiceBinding) Name

func (s *CreateServiceBinding) Name() string

Name returns name name of the step

func (*CreateServiceBinding) Run

func (s *CreateServiceBinding) Run() error

Run executes the step

type CreateServiceInstance

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

CreateServiceInstance is a step which creates new ServiceInstance

func NewCreateServiceInstance

func NewCreateServiceInstance(name, instanceName string, getClassIDFn func() string, getPlanIDFn func() string, serviceInstances servicecatalogclientset.ServiceInstanceInterface, serviceClasses servicecatalogclientset.ServiceClassInterface, servicePlans servicecatalogclientset.ServicePlanInterface) *CreateServiceInstance

NewCreateServiceInstance returns new NewCreateServiceInstance

func (*CreateServiceInstance) Cleanup

func (s *CreateServiceInstance) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (*CreateServiceInstance) Name

func (s *CreateServiceInstance) Name() string

Name returns name name of the step

func (*CreateServiceInstance) Run

func (s *CreateServiceInstance) Run() error

Run executes the step

type DeployFunction

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

DeployFunction deploys function to the cluster. The function will do PUT /counter to connected application upon receiving an event

func NewDeployFunction

func NewDeployFunction(name, expectedPayload string, port int, client dynamic.ResourceInterface, legacy bool) *DeployFunction

func (*DeployFunction) Cleanup

func (s *DeployFunction) Cleanup() error

func (*DeployFunction) Name

func (s *DeployFunction) Name() string

func (*DeployFunction) Run

func (s *DeployFunction) Run() error

type LegacyServiceLabel

type LegacyServiceLabel struct {
	ID         string `json:"id"`
	APIDefID   string `json:"apiDefID"`
	EventDefID string `json:"eventDefID"`
}

type LoadStoredCertificates

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

func NewLoadStoredCertificates

func NewLoadStoredCertificates(ds *testkit.DataStore, state LoadStoredCertificatesState) *LoadStoredCertificates

NewLoadStoredCertificates loads previously stored certificates

func (LoadStoredCertificates) Cleanup

func (s LoadStoredCertificates) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (LoadStoredCertificates) Name

func (s LoadStoredCertificates) Name() string

Name returns name name of the step

func (LoadStoredCertificates) Run

func (s LoadStoredCertificates) Run() error

Run executes the step

type LoadStoredCertificatesState

type LoadStoredCertificatesState interface {
	SetGatewayClientCerts(certs []tls.Certificate)
	SetApplicationName(string)
}

type PEMCertificate

type PEMCertificate struct {
	Certificate [][]byte `json:"certificate"`
	PrivateKey  []byte   `json:"private_key"`
}

func CertificatesToPEM

func CertificatesToPEM(certificate tls.Certificate) (PEMCertificate, error)

type RegisterApplicationInCompass

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

RegisterApplicationInCompass is a step which registers new Application with API and Event in Compass

func NewRegisterApplicationInCompass

func NewRegisterApplicationInCompass(name, apiURL string, applications acclient.ApplicationInterface, director *testkit.CompassDirectorClient, httpSources esclient.HTTPSourceInterface, state RegisterApplicationInCompassState) *RegisterApplicationInCompass

NewRegisterApplicationInCompass returns new RegisterApplicationInCompass

func (*RegisterApplicationInCompass) Cleanup

func (s *RegisterApplicationInCompass) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (*RegisterApplicationInCompass) Name

Name returns name of the step

func (*RegisterApplicationInCompass) Run

Run executes the step

type RegisterApplicationInCompassState

type RegisterApplicationInCompassState interface {
	GetCompassAppID() string
	SetCompassAppID(appID string)
	SetServiceClassID(serviceID string)
	SetServicePlanID(servicePlanID string)
}

RegisterApplicationInCompassState represents RegisterApplicationInCompass dependencies

type RegisterLegacyApplicationInCompass

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

RegisterLegacyApplicationInCompass is a step which registers new Application with API and Event in Compass

func RegisterEmptyApplicationInCompass

RegisterEmptyApplicationInCompass returns new RegisterLegacyApplicationInCompass

func (*RegisterLegacyApplicationInCompass) Cleanup

Cleanup removes all resources that may possibly created by the step

func (*RegisterLegacyApplicationInCompass) Name

Name returns name of the step

func (*RegisterLegacyApplicationInCompass) Run

Run executes the step

type RegisterLegacyApplicationInCompassState

type RegisterLegacyApplicationInCompassState interface {
	GetCompassAppID() string
	SetCompassAppID(appID string)
	SetServiceClassID(serviceID string)
}

RegisterApplicationInCompassState represents RegisterApplicationInCompass dependencies

type RegisterLegacyServiceInCompass

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

RegisterApplicationInCompass is a step which registers new Application with API and Event in Compass

func NewRegisterLegacyServiceInCompass

func NewRegisterLegacyServiceInCompass(name, apiURL string, testService *testkit.TestService, state RegisterServiceInCompassState) *RegisterLegacyServiceInCompass

NewRegisterApplicationInCompass returns new RegisterLegacyServiceInCompass

func (*RegisterLegacyServiceInCompass) Cleanup

Cleanup removes all resources that may possibly created by the step

func (*RegisterLegacyServiceInCompass) Name

Name returns name of the step

func (*RegisterLegacyServiceInCompass) Run

Run executes the step

type RegisterServiceInCompassState

type RegisterServiceInCompassState interface {
	GetRegistryClient() *testkit.RegistryClient
	GetCompassAppID() string
	SetServicePlanID(servicePlanID string)
}

type RegisterTestService

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

func NewRegisterTestService

func NewRegisterTestService(name string, testService *testkit.TestService, state RegisterTestServiceState) *RegisterTestService

func (*RegisterTestService) Cleanup

func (s *RegisterTestService) Cleanup() error

func (*RegisterTestService) Name

func (s *RegisterTestService) Name() string

func (*RegisterTestService) Run

func (s *RegisterTestService) Run() error

type RegisterTestServiceState

type RegisterTestServiceState interface {
	SetServiceClassID(serviceID string)
	GetServiceClassID() string
	GetRegistryClient() *testkit.RegistryClient
}

type ResetCounterPod

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

ResetCounterPod resets the request counter deployed as a service

func NewResetCounterPod

func NewResetCounterPod(testService *testkit.TestService, opts ...retrygo.Option) *ResetCounterPod

NewResetCounterPod returns new ResetCounterPod

func (*ResetCounterPod) Cleanup

func (s *ResetCounterPod) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (*ResetCounterPod) Name

func (s *ResetCounterPod) Name() string

Name returns name name of the step

func (*ResetCounterPod) Run

func (s *ResetCounterPod) Run() error

Run executes the step

type SendEventToCompatibilityLayer

type SendEventToCompatibilityLayer struct {
	testkit.SendEvent
}

SendEventToCompatibilityLayer is a step which sends example event to the application gateway

func NewSendEventToCompatibilityLayer

func NewSendEventToCompatibilityLayer(appName, payload string, state testkit.SendEventState) *SendEventToCompatibilityLayer

NewSendEventToCompatibilityLayer returns new SendEventToCompatibilityLayer

func (*SendEventToCompatibilityLayer) Cleanup

func (s *SendEventToCompatibilityLayer) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (*SendEventToCompatibilityLayer) Name

Name returns name name of the step

func (*SendEventToCompatibilityLayer) Run

Run executes the step

type SendEventToCompatibilityLayerAndCheckEventId

type SendEventToCompatibilityLayerAndCheckEventId struct {
	testkit.SendEvent
	// contains filtered or unexported fields
}

SendEventToCompatibilityLayerAndCheckEventId is a step which sends an event and checks if the correct EventId has been received

func NewSendEventToCompatibilityLayerAndCheckEventId

func NewSendEventToCompatibilityLayerAndCheckEventId(appName, payload string, state testkit.SendEventState, testService *testkit.TestService,
	opts ...retrygo.Option) *SendEventToCompatibilityLayerAndCheckEventId

NewSendEventToCompatibilityLayerAndCheckEventId returns new SendEventToCompatibilityLayerAndCheckEventId

func (*SendEventToCompatibilityLayerAndCheckEventId) Cleanup

Cleanup removes all resources that may possibly created by the step

func (*SendEventToCompatibilityLayerAndCheckEventId) Name

Name returns name of the step

func (*SendEventToCompatibilityLayerAndCheckEventId) Run

Run executes the step

type SendEventToMesh

type SendEventToMesh struct {
	testkit.SendEvent
}

SendEventToMesh is a step which sends an example event to the application gateway

func NewSendEventToMesh

func NewSendEventToMesh(appName, payload string, state testkit.SendEventState) *SendEventToMesh

NewSendEvent returns new SendEvent

func (*SendEventToMesh) Cleanup

func (s *SendEventToMesh) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (*SendEventToMesh) Name

func (s *SendEventToMesh) Name() string

Name returns name name of the step

func (*SendEventToMesh) Run

func (s *SendEventToMesh) Run() error

Run executes the step

type SendEventToMeshAndCheckEventId

type SendEventToMeshAndCheckEventId struct {
	testkit.SendEvent
	// contains filtered or unexported fields
}

SendEventToMeshAndCheckEventId is a step which sends an event and checks if the correct EventId has been received

func NewSendEventToMeshAndCheckEventId

func NewSendEventToMeshAndCheckEventId(appName, payload string, state testkit.SendEventState, testService *testkit.TestService,
	opts ...retrygo.Option) *SendEventToMeshAndCheckEventId

NewSendEventToMeshAndCheckEventId returns new SendEventToMeshAndCheckEventId

func (*SendEventToMeshAndCheckEventId) Cleanup

Cleanup removes all resources that may possibly created by the step

func (*SendEventToMeshAndCheckEventId) Name

Name returns name of the step

func (*SendEventToMeshAndCheckEventId) Run

Run executes the step

type Sleep

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

Sleep is a step sleeps for some time

func NewSleep

func NewSleep(d time.Duration) *Sleep

NewSleep returns new Sleep

func (Sleep) Cleanup

func (s Sleep) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (Sleep) Name

func (s Sleep) Name() string

Name returns name name of the step

func (Sleep) Run

func (s Sleep) Run() error

Run executes the step

type StartTestServer

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

func NewStartTestServer

func NewStartTestServer(testService *testkit.TestService) *StartTestServer

func (*StartTestServer) Cleanup

func (s *StartTestServer) Cleanup() error

func (*StartTestServer) Name

func (s *StartTestServer) Name() string

func (*StartTestServer) Run

func (s *StartTestServer) Run() error

type StoreCertificatesInCluster

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

func NewStoreCertificatesInCluster

func NewStoreCertificatesInCluster(ds *testkit.DataStore, applicationName string, get func() []tls.Certificate) *StoreCertificatesInCluster

func (StoreCertificatesInCluster) Cleanup

func (s StoreCertificatesInCluster) Cleanup() error

Cleanup removes all resources that may possibly created by the step

func (StoreCertificatesInCluster) Name

Name returns name name of the step

func (StoreCertificatesInCluster) Run

Run executes the step