config

Documentation

Overview

Package config is a generated GoMock package.

Index

• Constants
• type ConfigMapConfig
  • func NewConfigMapConfig(name, namespace string) (*ConfigMapConfig, error)
  • func (c *ConfigMapConfig) Get(ctx context.Context) (result testkube.Config, err error)
  • func (c *ConfigMapConfig) GetTelemetryEnabled(ctx context.Context) (ok bool, err error)
  • func (c *ConfigMapConfig) GetUniqueClusterId(ctx context.Context) (clusterId string, err error)
  • func (c *ConfigMapConfig) Upsert(ctx context.Context, result testkube.Config) (updated testkube.Config, err error)
• type MockRepository
  • func NewMockRepository(ctrl *gomock.Controller) *MockRepository
  • func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder
  • func (m *MockRepository) Get(arg0 context.Context) (testkube.Config, error)
  • func (m *MockRepository) GetTelemetryEnabled(arg0 context.Context) (bool, error)
  • func (m *MockRepository) GetUniqueClusterId(arg0 context.Context) (string, error)
  • func (m *MockRepository) Upsert(arg0 context.Context, arg1 testkube.Config) (testkube.Config, error)
• type MockRepositoryMockRecorder
  • func (mr *MockRepositoryMockRecorder) Get(arg0 interface{}) *gomock.Call
  • func (mr *MockRepositoryMockRecorder) GetTelemetryEnabled(arg0 interface{}) *gomock.Call
  • func (mr *MockRepositoryMockRecorder) GetUniqueClusterId(arg0 interface{}) *gomock.Call
  • func (mr *MockRepositoryMockRecorder) Upsert(arg0, arg1 interface{}) *gomock.Call
• type MongoRepository
  • func NewMongoRepository(db *mongo.Database, opts ...Opt) *MongoRepository
  • func (r *MongoRepository) Get(ctx context.Context) (result testkube.Config, err error)
  • func (r *MongoRepository) GetTelemetryEnabled(ctx context.Context) (ok bool, err error)
  • func (r *MongoRepository) GetUniqueClusterId(ctx context.Context) (clusterId string, err error)
  • func (r *MongoRepository) Upsert(ctx context.Context, result testkube.Config) (updated testkube.Config, err error)
• type Opt
  • func WithMongoRepositoryCollection(collection *mongo.Collection) Opt
• type Repository

Constants

const CollectionName = "config"

const Id = "api"

Types

type ConfigMapConfig

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

ConfigMapConfig contains configmap config properties

func NewConfigMapConfig

func NewConfigMapConfig(name, namespace string) (*ConfigMapConfig, error)

NewConfigMapConfig is a constructor for configmap config

func (*ConfigMapConfig) Get

func (c *ConfigMapConfig) Get(ctx context.Context) (result testkube.Config, err error)

Get config

func (*ConfigMapConfig) GetTelemetryEnabled

func (c *ConfigMapConfig) GetTelemetryEnabled(ctx context.Context) (ok bool, err error)

GetTelemetryEnabled get telemetry enabled

func (*ConfigMapConfig) GetUniqueClusterId

func (c *ConfigMapConfig) GetUniqueClusterId(ctx context.Context) (clusterId string, err error)

GetUniqueClusterId gets unique cluster based ID

func (*ConfigMapConfig) Upsert

func (c *ConfigMapConfig) Upsert(ctx context.Context, result testkube.Config) (updated testkube.Config, err error)

Upsert inserts record if not exists, updates otherwise

type MockRepository

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

MockRepository is a mock of Repository interface.

func NewMockRepository

func NewMockRepository(ctrl *gomock.Controller) *MockRepository

NewMockRepository creates a new mock instance.

func (*MockRepository) EXPECT

func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder

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

func (*MockRepository) Get

func (m *MockRepository) Get(arg0 context.Context) (testkube.Config, error)

Get mocks base method.

func (*MockRepository) GetTelemetryEnabled

func (m *MockRepository) GetTelemetryEnabled(arg0 context.Context) (bool, error)

GetTelemetryEnabled mocks base method.

func (*MockRepository) GetUniqueClusterId

func (m *MockRepository) GetUniqueClusterId(arg0 context.Context) (string, error)

GetUniqueClusterId mocks base method.

func (*MockRepository) Upsert

func (m *MockRepository) Upsert(arg0 context.Context, arg1 testkube.Config) (testkube.Config, error)

Upsert mocks base method.

type MockRepositoryMockRecorder

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

MockRepositoryMockRecorder is the mock recorder for MockRepository.

func (*MockRepositoryMockRecorder) Get

func (mr *MockRepositoryMockRecorder) Get(arg0 interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockRepositoryMockRecorder) GetTelemetryEnabled

func (mr *MockRepositoryMockRecorder) GetTelemetryEnabled(arg0 interface{}) *gomock.Call

GetTelemetryEnabled indicates an expected call of GetTelemetryEnabled.

func (*MockRepositoryMockRecorder) GetUniqueClusterId

func (mr *MockRepositoryMockRecorder) GetUniqueClusterId(arg0 interface{}) *gomock.Call

GetUniqueClusterId indicates an expected call of GetUniqueClusterId.

func (*MockRepositoryMockRecorder) Upsert

func (mr *MockRepositoryMockRecorder) Upsert(arg0, arg1 interface{}) *gomock.Call

Upsert indicates an expected call of Upsert.

type MongoRepository

type MongoRepository struct {
	Coll *mongo.Collection
}

func NewMongoRepository

func NewMongoRepository(db *mongo.Database, opts ...Opt) *MongoRepository

func (*MongoRepository) Get

func (r *MongoRepository) Get(ctx context.Context) (result testkube.Config, err error)

func (*MongoRepository) GetTelemetryEnabled

func (r *MongoRepository) GetTelemetryEnabled(ctx context.Context) (ok bool, err error)

func (*MongoRepository) GetUniqueClusterId

func (r *MongoRepository) GetUniqueClusterId(ctx context.Context) (clusterId string, err error)

func (*MongoRepository) Upsert

func (r *MongoRepository) Upsert(ctx context.Context, result testkube.Config) (updated testkube.Config, err error)

type Opt

type Opt func(*MongoRepository)

func WithMongoRepositoryCollection

func WithMongoRepositoryCollection(collection *mongo.Collection) Opt

type Repository

type Repository interface {
	// GetUniqueClusterId gets unique cluster based ID
	GetUniqueClusterId(ctx context.Context) (string, error)

	// GetTelemetryEnabled get telemetry enabled
	GetTelemetryEnabled(ctx context.Context) (ok bool, err error)

	// Get gets execution result by id
	Get(ctx context.Context) (testkube.Config, error)

	// Upsert inserts record if not exists, updates otherwise
	Upsert(ctx context.Context, config testkube.Config) (testkube.Config, error)
}