data_store

Oct 17, 2024

Changes in this version

type Gorm

+ Debug bool

+ Driver string

Jun 27, 2024

Changes in this version

type Kafka

+ IsSASL bool

+ Password string

+ Username string

Jun 13, 2024

Changes in this version

type ElasticSearch

+ ApiKey string

Jan 10, 2024

Changes in this version

type MongoDB

+ ReplicaSet string

+ Replicas []string

Jan 9, 2024

Changes in this version

+ type Gcs struct

+ BaseUrl string

+ BucketName string

+ CredentialsFile string

+ func (gcs *Gcs) Bucket() (*storage.BucketHandle, *storage.Client, error)

+ func (gcs *Gcs) Client() (*storage.Client, error)

+ func (gcs *Gcs) LoadFromConfig(key string, config *viper.Viper) error

+ type Solr struct

+ Client *solr.JSONClient

+ Host string

+ Port string

+ Scheme string

+ func (ds *Solr) LoadFromConfig(key string, config *viper.Viper) error

Jan 5, 2024

Changes in this version

+ type MongoDB struct

+ Collection string

+ DbName string

+ Host string

+ Password string

+ Port string

+ UserName string

+ func (ds *MongoDB) Dispose()

+ func (ds *MongoDB) Instance() *mongo.Client

+ func (ds *MongoDB) LoadFromConfig(key string, config *viper.Viper) error

type Redis

+ ReadTimeout int

Oct 9, 2023

Changes in this version

type Redis

+ Channel string

Aug 30, 2023

Changes in this version

type Gorm

+ Charset string

Jun 21, 2023

Changes in this version

type Kafka

+ MaxMessageBytes int

Mar 8, 2023

Changes in this version

type Mysql

+ ConnMaxLifetime int

+ MaxIdleConns int

+ MaxOpenConns int

Sep 29, 2022

Changes in this version

type Cassandra

+ ProtoVersion int

Aug 3, 2022

Changes in this version

+ type RedisCluster struct

+ Addr []string

+ MasterName string

+ Password string

+ func (ds *RedisCluster) Client() *redis.ClusterClient

+ func (ds *RedisCluster) LoadFromConfig(key string, config *viper.Viper) error

type RedisSentinel

+ Addr []string

Jul 19, 2022

Changes in this version

+ type Gorm struct

+ Addr string

+ AllowNativePasswords bool

+ DBName string

+ Net string

+ Password string

+ ReadTimeout int

+ Timeout int

+ User string

+ WriteTimeout int

+ func (ds *Gorm) Db() *gorm.DB

+ func (ds *Gorm) LoadFromConfig(key string, config *viper.Viper) error

Jul 8, 2022

Changes in this version

+ const ESDefaultTimeout

+ type Cassandra struct

+ Hosts []string

+ Keyspace string

+ Port int

+ ReconnectInterval int

+ Timeout int

+ func (ds *Cassandra) Cluster() *gocql.ClusterConfig

+ func (ds *Cassandra) Init() error

+ func (ds *Cassandra) LoadFromConfig(key string, config *viper.Viper) error

+ func (ds *Cassandra) Session() *gocql.Session

+ type ElasticSearch struct

+ Hosts []string

+ Timeout time.Duration

+ func (ds *ElasticSearch) Client() *elasticsearch.Client

+ func (ds *ElasticSearch) LoadFromConfig(key string, config *viper.Viper) error

+ type Kafka struct

+ Hosts []string

+ Topic string

+ func (ds *Kafka) LoadFromConfig(key string, config *viper.Viper) error

+ func (ds *Kafka) Producer() sarama.AsyncProducer

+ type Mysql struct

+ Addr string

+ AllowNativePasswords bool

+ DBName string

+ Net string

+ Password string

+ ReadTimeout int

+ Timeout int

+ User string

+ WriteTimeout int

+ func (ds *Mysql) Db() *sql.DB

+ func (ds *Mysql) LoadFromConfig(key string, config *viper.Viper) error

+ type Postgres struct

+ func (ds *Postgres) LoadFromConfig(key string, config *viper.Viper) error

+ type Redis struct

+ Addr string

+ DB int

+ Password string

+ func (ds *Redis) Client() *redis.Client

+ func (ds *Redis) LoadFromConfig(key string, config *viper.Viper) error

+ type RedisSentinel struct

+ Addrs []string

+ MasterName string

+ Password string

+ Username string

+ func (ds *RedisSentinel) Client() *redis.Client

+ func (ds *RedisSentinel) LoadFromConfig(key string, config *viper.Viper) error