database

Oct 15, 2021

Changes in this version

+ type ConfigCache interface

+ GetConfigObject func(context.Context, *configV1.ConfigRef) (*configV1.ConfigObject, error)

+ GetScripts func(context.Context, *configV1.BrowserConfig) ([]*configV1.ConfigObject, error)

+ func NewConfigCache(db DbAdapter, ttl time.Duration) ConfigCache

+ type DbAdapter interface

+ GetConfigObject func(context.Context, *configV1.ConfigRef) (*configV1.ConfigObject, error)

+ GetConfigsForSelector func(context.Context, configV1.Kind, *configV1.Label) ([]*configV1.ConfigObject, error)

+ type MockConnection struct

+ func NewMockConnection() *MockConnection

+ func (c *MockConnection) Close() error

+ func (c *MockConnection) GetConfigObject(ctx context.Context, ref *configV1.ConfigRef) (*configV1.ConfigObject, error)

+ func (c *MockConnection) GetConfigsForSelector(ctx context.Context, kind configV1.Kind, label *configV1.Label) ([]*configV1.ConfigObject, error)

+ func (c *MockConnection) GetMock() *r.Mock

+ type Options struct

+ Address string

+ Database string

+ MaxOpenConnections int

+ MaxRetries int

+ Password string

+ QueryTimeout time.Duration

+ UseOpenTracing bool

+ Username string

+ type RethinkDbConnection struct

+ func NewRethinkDbConnection(opts Options) *RethinkDbConnection

+ func (c *RethinkDbConnection) Close() error

+ func (c *RethinkDbConnection) Connect() error

+ func (c *RethinkDbConnection) GetConfigObject(ctx context.Context, ref *configV1.ConfigRef) (*configV1.ConfigObject, error)

+ func (c *RethinkDbConnection) GetConfigsForSelector(ctx context.Context, kind configV1.Kind, label *configV1.Label) ([]*configV1.ConfigObject, error)