data_store

Documentation

Overview

Package data_store - Will move this to central repo, temporarily is copy pasted everywhere

Index

• Constants
• type Cassandra
  • 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
  • func (ds *ElasticSearch) Client() *elasticsearch.Client
  • func (ds *ElasticSearch) LoadFromConfig(key string, config *viper.Viper) error
• type Gorm
  • func (ds *Gorm) Db() *gorm.DB
  • func (ds *Gorm) LoadFromConfig(key string, config *viper.Viper) error
• type Kafka
  • func (ds *Kafka) LoadFromConfig(key string, config *viper.Viper) error
  • func (ds *Kafka) Producer() sarama.AsyncProducer
• type Mysql
  • func (ds *Mysql) Db() *sql.DB
  • func (ds *Mysql) LoadFromConfig(key string, config *viper.Viper) error
• type Postgres
  • func (ds *Postgres) LoadFromConfig(key string, config *viper.Viper) error
• type Redis
  • func (ds *Redis) Client() *redis.Client
  • func (ds *Redis) LoadFromConfig(key string, config *viper.Viper) error
• type RedisSentinel
  • func (ds *RedisSentinel) Client() *redis.Client
  • func (ds *RedisSentinel) LoadFromConfig(key string, config *viper.Viper) error

Constants

const (
	ESDefaultTimeout = time.Second
)

Types

type Cassandra

type Cassandra struct {
	Keyspace          string   `mapstructure:"keyspace"`
	Hosts             []string `mapstructure:"hosts"`
	Timeout           int      `mapstructure:"timeout"`
	ReconnectInterval int      `mapstructure:"reconnect_interval"`
	Port              int      `mapstructure:"port"`
	// contains filtered or unexported fields
}

func (*Cassandra) Cluster

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

func (*Cassandra) Init

func (ds *Cassandra) Init() error

func (*Cassandra) LoadFromConfig

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

func (*Cassandra) Session

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

type ElasticSearch

type ElasticSearch struct {
	Hosts   []string      `mapstructure:"hosts"`
	Timeout time.Duration `mapstructure:"timeout"`
	// contains filtered or unexported fields
}

func (*ElasticSearch) Client

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

func (*ElasticSearch) LoadFromConfig

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

type Gorm

type Gorm struct {
	User                 string `mapstructure:"user"`
	Password             string `mapstructure:"password"`
	Net                  string `mapstructure:"net"`
	Addr                 string `mapstructure:"addr"`
	DBName               string `mapstructure:"db_name"`
	AllowNativePasswords bool   `mapstructure:"allow_native_passwords"`
	Timeout              int    `json:"timeout"`
	ReadTimeout          int    `json:"read_timeout"`
	WriteTimeout         int    `json:"write_timeout"`
}

func (*Gorm) Db

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

func (*Gorm) LoadFromConfig

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

type Kafka

type Kafka struct {
	Hosts []string `mapstructure:"hosts"`
	Topic string   `mapstructure:"topic"`
	// contains filtered or unexported fields
}

func (*Kafka) LoadFromConfig

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

func (*Kafka) Producer

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

type Mysql

type Mysql struct {
	User                 string `mapstructure:"user"`
	Password             string `mapstructure:"password"`
	Net                  string `mapstructure:"net"`
	Addr                 string `mapstructure:"addr"`
	DBName               string `mapstructure:"db_name"`
	AllowNativePasswords bool   `mapstructure:"allow_native_passwords"`
	Timeout              int    `json:"timeout"`
	ReadTimeout          int    `json:"read_timeout"`
	WriteTimeout         int    `json:"write_timeout"`
	// contains filtered or unexported fields
}

func (*Mysql) Db

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

func (*Mysql) LoadFromConfig

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

type Postgres

type Postgres struct {
}

func (*Postgres) LoadFromConfig

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

type Redis

type Redis struct {
	Addr     string `mapstructure:"addr"`
	Password string `mapstructure:"password"`
	DB       int    `mapstructure:"db"`
	// contains filtered or unexported fields
}

func (*Redis) Client

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

func (*Redis) LoadFromConfig

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

type RedisSentinel

type RedisSentinel struct {
	MasterName string   `mapstructure:"name"`
	Addrs      []string `mapstructure:"addr"`
	//Username   string   `mapstructure:"username"`
	Password string `mapstructure:"password"`
	// contains filtered or unexported fields
}

RedisSentinel @todo: Merge with redis

func (*RedisSentinel) Client

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

func (*RedisSentinel) LoadFromConfig

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