config

Feb 27, 2023

Changes in this version

+ type ConfigMapConfig struct

+ 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 struct

+ 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 struct

+ 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 Opt

+ func WithMongoRepositoryCollection(collection *mongo.Collection) Opt

Jan 25, 2023

Changes in this version

type MongoRepository

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

+ type Opt func(*MongoRepository)

+ func WithCollection(collection *mongo.Collection) Opt

Jan 24, 2023

Changes in this version

+ const CollectionName

+ const Id

+ type MongoRepository struct

+ Coll *mongo.Collection

+ func NewMongoRespository(db *mongo.Database) *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) (err error)

+ type Repository interface

+ Get func(ctx context.Context) (testkube.Config, error)

+ GetTelemetryEnabled func(ctx context.Context) (ok bool, err error)

+ GetUniqueClusterId func(ctx context.Context) (string, error)

+ Upsert func(ctx context.Context, config testkube.Config) (testkube.Config, error)