Documentation
¶
Index ¶
- type CheckCounterPod
- type ConnectApplication
- type ConnectApplicationState
- type ConnectApplicationUsingCompass
- type ConnectApplicationUsingCompassState
- type CreateApplication
- type CreateKnativeTrigger
- type CreateLambdaServiceBindingUsage
- type CreateMapping
- type CreateNamespace
- type CreateSeparateServiceInstance
- type CreateSeparateServiceInstanceState
- type CreateServiceBinding
- type CreateServiceBindingState
- type CreateServiceInstance
- type CreateServiceInstanceState
- type CreateSubscription
- type DeployLambda
- type RegisterApplicationInCompass
- type RegisterApplicationInCompassState
- type RegisterTestService
- type RegisterTestServiceState
- type SendEvent
- type SendEventState
- type SendEventToMesh
- type Sleep
- type StartTestServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) *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
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
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 ¶
func NewConnectApplicationUsingCompass(connector *testkit.CompassConnectorClient, director *testkit.CompassDirectorClient, state ConnectApplicationUsingCompassState) *ConnectApplicationUsingCompass
NewConnectApplicationUsingCompass returns new ConnectApplicationUsingCompass
func (ConnectApplicationUsingCompass) Cleanup ¶
func (s ConnectApplicationUsingCompass) Cleanup() error
Cleanup removes all resources that may possibly created by the step
func (ConnectApplicationUsingCompass) Name ¶
func (s ConnectApplicationUsingCompass) Name() string
Name returns name name of the step
func (ConnectApplicationUsingCompass) Run ¶
func (s ConnectApplicationUsingCompass) Run() error
Run executes the step
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 acClient.ApplicationInterface, httpSourceClient esClient.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
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 serviceBindingUsageClient.ServiceBindingUsageInterface, knativeBroker knativeEventingV1alpha1.BrokerInterface, knativeSubscription knativeMessagingV1alpha1.SubscriptionInterface) *CreateLambdaServiceBindingUsage
NewCreateServiceBindingUsage returns new CreateLambdaServiceBindingUsage
func (*CreateLambdaServiceBindingUsage) Cleanup ¶
func (s *CreateLambdaServiceBindingUsage) Cleanup() error
Cleanup removes all resources that may possibly created by the step
func (*CreateLambdaServiceBindingUsage) Name ¶
func (s *CreateLambdaServiceBindingUsage) Name() string
Name returns name name of the step
func (*CreateLambdaServiceBindingUsage) Run ¶
func (s *CreateLambdaServiceBindingUsage) Run() error
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 acClient.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
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
type CreateSeparateServiceInstance ¶
type CreateSeparateServiceInstance struct {
// contains filtered or unexported fields
}
CreateSeparateServiceInstance is a step which creates new separate ServiceInstances for API and Event
func NewCreateSeparateServiceInstance ¶
func NewCreateSeparateServiceInstance(name string, serviceInstances serviceCatalogClient.ServiceInstanceInterface, applications acClient.ApplicationInterface, state CreateSeparateServiceInstanceState) *CreateSeparateServiceInstance
NewCreateSeparateServiceInstance returns new CreateSeparateServiceInstance
func (*CreateSeparateServiceInstance) Cleanup ¶
func (s *CreateSeparateServiceInstance) Cleanup() error
Cleanup removes all resources that may possibly created by the step
func (*CreateSeparateServiceInstance) Name ¶
func (s *CreateSeparateServiceInstance) Name() string
Name returns name of the step
func (*CreateSeparateServiceInstance) Run ¶
func (s *CreateSeparateServiceInstance) Run() error
Run executes the step
type CreateSeparateServiceInstanceState ¶
type CreateSeparateServiceInstanceState interface {
SetAPIServiceInstanceName(string)
SetEventServiceInstanceName(string)
GetAPIServiceInstanceName() string
GetEventServiceInstanceName() string
}
CreateSeparateServiceInstanceState represents CreateServiceInstances dependencies
type CreateServiceBinding ¶
type CreateServiceBinding struct {
// contains filtered or unexported fields
}
CreateServiceBinding is a step which creates new ServiceBinding
func NewCreateServiceBinding ¶
func NewCreateServiceBinding(name string, serviceBindings serviceCatalogClient.ServiceBindingInterface, state CreateServiceBindingState) *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
type CreateServiceBindingState ¶
type CreateServiceBindingState interface {
GetAPIServiceInstanceName() string
}
CreateServiceBindingState represents CreateServiceBinding dependencies
type CreateServiceInstance ¶
type CreateServiceInstance struct {
// contains filtered or unexported fields
}
CreateServiceInstance is a step which creates new ServiceInstance
func NewCreateServiceInstance ¶
func NewCreateServiceInstance(name string, serviceInstances serviceCatalogClient.ServiceInstanceInterface, serviceClasses serviceCatalogClient.ServiceClassInterface, state CreateServiceInstanceState) *CreateServiceInstance
NewCreateServiceInstance returns new CreateServiceInstance
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 CreateServiceInstanceState ¶
type CreateServiceInstanceState interface {
GetServiceClassID() string
SetAPIServiceInstanceName(string)
SetEventServiceInstanceName(string)
GetAPIServiceInstanceName() string
GetEventServiceInstanceName() string
}
CreateServiceInstanceState represents CreateServiceInstance dependencies
type CreateSubscription ¶
type CreateSubscription struct {
// contains filtered or unexported fields
}
CreateSubscription is a step which creates new Subscription
func NewCreateSubscription ¶
func NewCreateSubscription(name, sourceID, endpoint string, subscriptions eventingClient.SubscriptionInterface) *CreateSubscription
NewCreateSubscription returns new CreateSubscription
func (*CreateSubscription) Cleanup ¶
func (s *CreateSubscription) Cleanup() error
Cleanup removes all resources that may possibly created by the step
func (*CreateSubscription) Name ¶
func (s *CreateSubscription) Name() string
Name returns name name of the step
type DeployLambda ¶
type DeployLambda struct {
*helpers.LambdaHelper
// contains filtered or unexported fields
}
DeployLambda deploys lambda to the cluster. The lambda will do PUT /counter to connected application upon receiving an event
func NewDeployLambda ¶
func NewDeployLambda(name, expectedPayload string, port int, functions kubelessClient.FunctionInterface, pods coreClient.PodInterface) *DeployLambda
NewDeployLambda returns new DeployLambda
func (*DeployLambda) Cleanup ¶
func (s *DeployLambda) Cleanup() error
Cleanup removes all resources that may possibly created by the step
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, 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 ¶
func (s *RegisterApplicationInCompass) Name() string
Name returns name of the step
func (*RegisterApplicationInCompass) Run ¶
func (s *RegisterApplicationInCompass) Run() error
Run executes the step
type RegisterApplicationInCompassState ¶
type RegisterApplicationInCompassState interface {
GetCompassAppID() string
SetCompassAppID(appID string)
}
RegisterApplicationInCompassState represents RegisterApplicationInCompass dependencies
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 SendEvent ¶
type SendEvent struct {
// contains filtered or unexported fields
}
SendEvent is a step which sends example event to the application gateway
func NewSendEvent ¶
func NewSendEvent(appName, payload string, state SendEventState) *SendEvent
NewSendEvent returns new SendEvent
type SendEventState ¶
type SendEventState interface {
GetEventSender() *testkit.EventSender
}
SendEventState represents SendEvent dependencies
type SendEventToMesh ¶
type SendEventToMesh struct {
// contains filtered or unexported fields
}
SendEvent is a step which sends an example event to the application gateway
func NewSendEventToMesh ¶
func NewSendEventToMesh(appName, payload string, state 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
type Sleep ¶
type Sleep struct {
// contains filtered or unexported fields
}
Sleep is a step sleeps for some time
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
Source Files
¶
- check_counter_pod.go
- connect_application.go
- connect_application_using_compass.go
- create_application.go
- create_knative_trigger.go
- create_mapping.go
- create_namespace.go
- create_separate_service_instance.go
- create_service_binding.go
- create_service_binding_usage.go
- create_service_instance.go
- create_subscription.go
- deploy_lambda.go
- register_application_in_compass.go
- register_test_service.go
- send_event.go
- send_event_to_mesh.go
- sleep.go
- start_test_server.go