common

Documentation

Index

• Constants
• func GetOwnerEngine(ctx context.Context, reader client.Reader, ns string, engineName string) (*v1alpha1.Engine, error)
• type GetNewSecretManager
• type K8sReader
• type MockK8sReader
  • func NewMockK8sReader(ctrl *gomock.Controller) *MockK8sReader
  • func (m *MockK8sReader) EXPECT() *MockK8sReaderMockRecorder
  • func (m *MockK8sReader) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error
  • func (m *MockK8sReader) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
• type MockK8sReaderMockRecorder
  • func (mr *MockK8sReaderMockRecorder) Get(ctx, key, obj interface{}) *gomock.Call
  • func (mr *MockK8sReaderMockRecorder) List(ctx, list interface{}, opts ...interface{}) *gomock.Call
• type MockSecretManager
  • func NewMockSecretManager(ctrl *gomock.Controller) *MockSecretManager
  • func (m *MockSecretManager) CreateEngine(ctx context.Context, engine, engineType string, options map[string]string) error
  • func (m *MockSecretManager) DeleteEngine(ctx context.Context, engine string) error
  • func (m *MockSecretManager) DeletePath(ctx context.Context, engine, secretPath string, options map[string]string) error
  • func (m *MockSecretManager) EXPECT() *MockSecretManagerMockRecorder
  • func (m *MockSecretManager) ExistEngine(ctx context.Context, engine string) (bool, error)
  • func (m *MockSecretManager) GetSecrets(ctx context.Context, engine, secretPath string, options map[string]string) (map[string]interface{}, error)
  • func (m *MockSecretManager) Put(ctx context.Context, engine, secretPath string, data map[string]interface{}, ...) error
• type MockSecretManagerMockRecorder
  • func (mr *MockSecretManagerMockRecorder) CreateEngine(ctx, engine, engineType, options interface{}) *gomock.Call
  • func (mr *MockSecretManagerMockRecorder) DeleteEngine(ctx, engine interface{}) *gomock.Call
  • func (mr *MockSecretManagerMockRecorder) DeletePath(ctx, engine, secretPath, options interface{}) *gomock.Call
  • func (mr *MockSecretManagerMockRecorder) ExistEngine(ctx, engine interface{}) *gomock.Call
  • func (mr *MockSecretManagerMockRecorder) GetSecrets(ctx, engine, secretPath, options interface{}) *gomock.Call
  • func (mr *MockSecretManagerMockRecorder) Put(ctx, engine, secretPath, data, options interface{}) *gomock.Call
• type SecretManager

Constants

const (
	ErrNoParentReferences = "CR does not have parent ref"
)

const (
	ErrNotFoundPath = "path does not exist"
)

Functions

func GetOwnerEngine

func GetOwnerEngine(ctx context.Context, reader client.Reader, ns string, engineName string) (*v1alpha1.Engine, error)

Types

type GetNewSecretManager

type GetNewSecretManager func(props map[string][]byte) (SecretManager, error)

type K8sReader

type K8sReader interface {
	client.Reader
}

type MockK8sReader

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

MockK8sReader is a mock of K8sReader interface.

func NewMockK8sReader

func NewMockK8sReader(ctrl *gomock.Controller) *MockK8sReader

NewMockK8sReader creates a new mock instance.

func (*MockK8sReader) EXPECT

func (m *MockK8sReader) EXPECT() *MockK8sReaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockK8sReader) Get

func (m *MockK8sReader) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error

Get mocks base method.

func (*MockK8sReader) List

func (m *MockK8sReader) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

List mocks base method.

type MockK8sReaderMockRecorder

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

MockK8sReaderMockRecorder is the mock recorder for MockK8sReader.

func (*MockK8sReaderMockRecorder) Get

func (mr *MockK8sReaderMockRecorder) Get(ctx, key, obj interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockK8sReaderMockRecorder) List

func (mr *MockK8sReaderMockRecorder) List(ctx, list interface{}, opts ...interface{}) *gomock.Call

List indicates an expected call of List.

type MockSecretManager

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

MockSecretManager is a mock of SecretManager interface.

func NewMockSecretManager

func NewMockSecretManager(ctrl *gomock.Controller) *MockSecretManager

NewMockSecretManager creates a new mock instance.

func (*MockSecretManager) CreateEngine

func (m *MockSecretManager) CreateEngine(ctx context.Context, engine, engineType string, options map[string]string) error

CreateEngine mocks base method.

func (*MockSecretManager) DeleteEngine

func (m *MockSecretManager) DeleteEngine(ctx context.Context, engine string) error

DeleteEngine mocks base method.

func (*MockSecretManager) DeletePath

func (m *MockSecretManager) DeletePath(ctx context.Context, engine, secretPath string, options map[string]string) error

DeletePath mocks base method.

func (*MockSecretManager) EXPECT

func (m *MockSecretManager) EXPECT() *MockSecretManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSecretManager) ExistEngine

func (m *MockSecretManager) ExistEngine(ctx context.Context, engine string) (bool, error)

ExistEngine mocks base method.

func (*MockSecretManager) GetSecrets

func (m *MockSecretManager) GetSecrets(ctx context.Context, engine, secretPath string, options map[string]string) (map[string]interface{}, error)

GetSecrets mocks base method.

func (*MockSecretManager) Put

func (m *MockSecretManager) Put(ctx context.Context, engine, secretPath string, data map[string]interface{}, options map[string]string) error

Put mocks base method.

type MockSecretManagerMockRecorder

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

MockSecretManagerMockRecorder is the mock recorder for MockSecretManager.

func (*MockSecretManagerMockRecorder) CreateEngine

func (mr *MockSecretManagerMockRecorder) CreateEngine(ctx, engine, engineType, options interface{}) *gomock.Call

CreateEngine indicates an expected call of CreateEngine.

func (*MockSecretManagerMockRecorder) DeleteEngine

func (mr *MockSecretManagerMockRecorder) DeleteEngine(ctx, engine interface{}) *gomock.Call

DeleteEngine indicates an expected call of DeleteEngine.

func (*MockSecretManagerMockRecorder) DeletePath

func (mr *MockSecretManagerMockRecorder) DeletePath(ctx, engine, secretPath, options interface{}) *gomock.Call

DeletePath indicates an expected call of DeletePath.

func (*MockSecretManagerMockRecorder) ExistEngine

func (mr *MockSecretManagerMockRecorder) ExistEngine(ctx, engine interface{}) *gomock.Call

ExistEngine indicates an expected call of ExistEngine.

func (*MockSecretManagerMockRecorder) GetSecrets

func (mr *MockSecretManagerMockRecorder) GetSecrets(ctx, engine, secretPath, options interface{}) *gomock.Call

GetSecrets indicates an expected call of GetSecrets.

func (*MockSecretManagerMockRecorder) Put

func (mr *MockSecretManagerMockRecorder) Put(ctx, engine, secretPath, data, options interface{}) *gomock.Call

Put indicates an expected call of Put.

type SecretManager

type SecretManager interface {
	Put(ctx context.Context, engine string, secretPath string, data map[string]interface{}, options map[string]string) error
	GetSecrets(ctx context.Context, engine string, secretPath string, options map[string]string) (map[string]interface{}, error)
	CreateEngine(ctx context.Context, engine string, engineType string, options map[string]string) error
	ExistEngine(ctx context.Context, engine string) (bool, error)
	DeletePath(ctx context.Context, engine string, secretPath string, options map[string]string) error
	DeleteEngine(ctx context.Context, engine string) error
}