services

Documentation

Index

• func BindIntegratedServiceSpec(inputSpec integratedservices.IntegratedServiceSpec, boundSpec interface{}) error
• func IsManagedByPipeline(meta v1.ObjectMeta) bool
• func SetManagedByPipeline(meta *v1.ObjectMeta)
• type HelmService
• type Logger
• type MockHelmService
  • func (_m *MockHelmService) ApplyDeployment(ctx context.Context, clusterID uint, namespace string, chartName string, ...) (_result_0 error)
  • func (_m *MockHelmService) ApplyDeploymentSkipCRDs(ctx context.Context, clusterID uint, namespace string, chartName string, ...) (_result_0 error)
  • func (_m *MockHelmService) DeleteDeployment(ctx context.Context, clusterID uint, releaseName string, namespace string) (_result_0 error)
  • func (_m *MockHelmService) GetDeployment(ctx context.Context, clusterID uint, releaseName string, namespace string) (_result_0 *helm.GetDeploymentResponse, _result_1 error)
• type NoopLogger
• type SecretStore
• type ServiceNameMapper
  • func NewServiceNameMapper() ServiceNameMapper
• type StatusMapper
  • func NewServiceStatusMapper() StatusMapper

Functions

func BindIntegratedServiceSpec

func BindIntegratedServiceSpec(inputSpec integratedservices.IntegratedServiceSpec, boundSpec interface{}) error

BindIntegratedServiceSpec binds an incoming integrated service specific raw spec (json) into the appropriate struct

func IsManagedByPipeline

func IsManagedByPipeline(meta v1.ObjectMeta) bool

func SetManagedByPipeline

func SetManagedByPipeline(meta *v1.ObjectMeta)

Types

type HelmService

type HelmService interface {
	ApplyDeployment(
		ctx context.Context,
		clusterID uint,
		namespace string,
		chartName string,
		releaseName string,
		values []byte,
		chartVersion string,
	) error

	ApplyDeploymentSkipCRDs(
		ctx context.Context,
		clusterID uint,
		namespace string,
		chartName string,
		releaseName string,
		values []byte,
		chartVersion string,
	) error

	// DeleteDeployment deletes a deployment from a specific cluster.
	DeleteDeployment(ctx context.Context, clusterID uint, releaseName, namespace string) error

	// GetDeployment gets a deployment by release name from a specific cluster.
	GetDeployment(ctx context.Context, clusterID uint, releaseName, namespace string) (*helm.GetDeploymentResponse, error)
}

HelmService provides an interface for using Helm on a specific cluster.

type Logger

type Logger = common.Logger

Logger is the fundamental interface for all log operations.

type MockHelmService

type MockHelmService struct {
	mock.Mock
}

MockHelmService is an autogenerated mock for the HelmService type.

func (*MockHelmService) ApplyDeployment

func (_m *MockHelmService) ApplyDeployment(ctx context.Context, clusterID uint, namespace string, chartName string, releaseName string, values []uint8, chartVersion string) (_result_0 error)

ApplyDeployment provides a mock function.

func (*MockHelmService) ApplyDeploymentSkipCRDs

func (_m *MockHelmService) ApplyDeploymentSkipCRDs(ctx context.Context, clusterID uint, namespace string, chartName string, releaseName string, values []uint8, chartVersion string) (_result_0 error)

ApplyDeploymentSkipCRDs provides a mock function.

func (*MockHelmService) DeleteDeployment

func (_m *MockHelmService) DeleteDeployment(ctx context.Context, clusterID uint, releaseName string, namespace string) (_result_0 error)

DeleteDeployment provides a mock function.

func (*MockHelmService) GetDeployment

func (_m *MockHelmService) GetDeployment(ctx context.Context, clusterID uint, releaseName string, namespace string) (_result_0 *helm.GetDeploymentResponse, _result_1 error)

GetDeployment provides a mock function.

type NoopLogger

type NoopLogger = common.NoopLogger

NoopLogger is a logger that discards every log event.

type SecretStore

type SecretStore = common.SecretStore

SecretStore is a common interface for various parts of the application to read secrets from the platform's secret store.

type ServiceNameMapper

type ServiceNameMapper interface {
	MapServiceName(serviceName string) string
}

ServiceNameMapper maps integrated service names that are different in external / legacy systems

func NewServiceNameMapper

func NewServiceNameMapper() ServiceNameMapper

type StatusMapper

type StatusMapper interface {
	MapStatus(serviceInstance v1alpha1.ServiceInstance) integratedservices.IntegratedServiceStatus
}

func NewServiceStatusMapper

func NewServiceStatusMapper() StatusMapper