dedb_client_go

type Client struct {
	// contains filtered or unexported fields
}

type ClientConfig struct {
	RedisDbConfig     RedisDbConfig
	RedisSearchConfig RedisSearchConfig
	Server            string
	Streams           []string
	StreamIds         map[string]string
	ConsumerGroup     string
	EventChannel      chan<- *api.Event
	ErrorChannel      chan<- error
}

type RedisDbConfig struct {
	DbAddress     string `envconfig:"DEDB_REDIS_DB_ADDRESS"`
	Username      string `envconfig:"DEDB_REDIS_DB_USERNAME"`
	Password      string `envconfig:"DEDB_REDIS_DB_PASSWORD"`
	RedisCa       string `envconfig:"DEDB_REDIS_DB_CA"`
	RedisUserCert string `envconfig:"DEDB_REDIS_DB_USER_CERT"`
	RedisUserKey  string `envconfig:"DEDB_REDIS_DB_USER_KEY"`
	Index         string `envconfig:"DEDB_REDIS_DB_INDEX"`
	MinIdle       int    `envconfig:"DEDB_REDIS_DB_MINIDLE"`
	MaxActive     int    `envconfig:"DEDB_REDIS_DB_MAXACTIVE"`
	IdleTimeout   int64  `envconfig:"DEDB_REDIS_DB_IDLE_TIMEOUT"`
	DbIndex       int    `envconfig:"DEDB_REDIS_DB_DB_INDEX"`
}

type RedisSearchConfig struct {
	DbAddress     string `envconfig:"REDIS_SEARCH_DB_ADDRESS"`
	Username      string `envconfig:"REDIS_SEARCH_DB_USERNAME"`
	Password      string `envconfig:"REDIS_SEARCH_PASSWORD"`
	RedisCa       string `envconfig:"REDIS_SEARCH_CA"`
	RedisUserCert string `envconfig:"REDIS_SEARCH_USER_CERT"`
	RedisUserKey  string `envconfig:"REDIS_SEARCH_USER_KEY"`
	Index         string `envconfig:"REDIS_SEARCH_INDEX"`
	MinIdle       int    `envconfig:"REDIS_SEARCH_MINIDLE"`
	MaxActive     int    `envconfig:"REDIS_SEARCH_MAXACTIVE"`
	IdleTimeout   int64  `envconfig:"REDIS_SEARCH_IDLE_TIMEOUT"`
	DbIndex       int    `envconfig:"REDIS_SEARCH_DB_INDEX"`
}