repository

Apr 7, 2024

Changes in this version

type RedisDataRepo

+ func (r *RedisDataRepo) GetValue(ctx context.Context, key string, value interface{}) error

Feb 20, 2024

Changes in this version

+ func NewJsonDataSource(cfg model.FileConfig) datasource.JsonDataSource

+ func NewJsonDataSourceFromPath(path string) datasource.JsonDataSource

+ func NewMongoDataSource(cfg model.DatabaseConfig) datasource.MongoDataSource

+ func NewMysqlDatasource(cfg model.DatabaseConfig) datasource.MysqlDataSource

+ func NewRedisDataRepo(cfg model.DatabaseConfig) datasource.RedisDataSource

+ type JsonRepo struct

+ func (j *JsonRepo) DataSourceName() scene.ImplName

+ func (j *JsonRepo) Dispose() error

+ func (j *JsonRepo) Load() ([]byte, error)

+ func (j *JsonRepo) Save(data []byte) error

+ func (j *JsonRepo) Setup() error

+ func (j *JsonRepo) Status() error

+ type MongoRepo struct

+ func (j *MongoRepo) DataSourceName() scene.ImplName

+ func (m *MongoRepo) Collection(coll string) *mongo.Collection

+ func (m *MongoRepo) Database() *mongo.Database

+ func (m *MongoRepo) Dispose() error

+ func (m *MongoRepo) Setup() error

+ func (m *MongoRepo) Status() error

+ type MysqlRepo struct

+ func (m *MysqlRepo) Connection() *sql.DB

+ func (m *MysqlRepo) DataSourceName() scene.ImplName

+ func (m *MysqlRepo) Dispose() error

+ func (m *MysqlRepo) Setup() error

+ func (m *MysqlRepo) Status() error

+ type RedisDataRepo struct

+ 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) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) error

+ func (r *RedisDataRepo) Setup() error

+ func (r *RedisDataRepo) Status() error