Documentation ¶
Index ¶
- func NewJsonDataSource(cfg model.FileConfig) datasource.JsonDataSource
- func NewJsonDataSourceFromPath(path string) datasource.JsonDataSource
- func NewMongoDataSource(cfg model.DatabaseConfig, useApiVersion bool) datasource.MongoDataSource
- func NewMysqlDatasource(cfg model.DatabaseConfig) datasource.MysqlDataSource
- func NewRedisDataRepo(cfg model.DatabaseConfig) datasource.RedisDataSource
- type JsonRepo
- type MongoRepo
- type MysqlRepo
- type RedisDataRepo
- func (r *RedisDataRepo) DataSourceName() scene.ImplName
- func (r *RedisDataRepo) Delete(ctx context.Context, key string) error
- func (r *RedisDataRepo) Dispose() error
- func (r *RedisDataRepo) Get(ctx context.Context, key string) (string, error)
- func (r *RedisDataRepo) GetValue(ctx context.Context, key string, value interface{}) error
- func (r *RedisDataRepo) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) error
- func (r *RedisDataRepo) Setup() error
- func (r *RedisDataRepo) Status() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewJsonDataSource ¶
func NewJsonDataSource(cfg model.FileConfig) datasource.JsonDataSource
func NewJsonDataSourceFromPath ¶
func NewJsonDataSourceFromPath(path string) datasource.JsonDataSource
func NewMongoDataSource ¶
func NewMongoDataSource(cfg model.DatabaseConfig, useApiVersion bool) datasource.MongoDataSource
func NewMysqlDatasource ¶
func NewMysqlDatasource(cfg model.DatabaseConfig) datasource.MysqlDataSource
func NewRedisDataRepo ¶
func NewRedisDataRepo(cfg model.DatabaseConfig) datasource.RedisDataSource
Types ¶
type JsonRepo ¶
type JsonRepo struct {
// contains filtered or unexported fields
}
func (*JsonRepo) DataSourceName ¶
type MongoRepo ¶
type MongoRepo struct {
// contains filtered or unexported fields
}
func (*MongoRepo) Collection ¶
func (m *MongoRepo) Collection(coll string) *mongo.Collection
func (*MongoRepo) DataSourceName ¶
type MysqlRepo ¶
type MysqlRepo struct {
// contains filtered or unexported fields
}
func (*MysqlRepo) Connection ¶
func (*MysqlRepo) DataSourceName ¶
type RedisDataRepo ¶
type RedisDataRepo struct {
// contains filtered or unexported fields
}
func (*RedisDataRepo) DataSourceName ¶
func (r *RedisDataRepo) DataSourceName() scene.ImplName
func (*RedisDataRepo) Delete ¶
func (r *RedisDataRepo) Delete(ctx context.Context, key string) error
func (*RedisDataRepo) Dispose ¶
func (r *RedisDataRepo) Dispose() error
func (*RedisDataRepo) GetValue ¶ added in v0.2.5
func (r *RedisDataRepo) GetValue(ctx context.Context, key string, value interface{}) error
func (*RedisDataRepo) Setup ¶
func (r *RedisDataRepo) Setup() error
func (*RedisDataRepo) Status ¶
func (r *RedisDataRepo) Status() error
Click to show internal directories.
Click to hide internal directories.