types

type CacheClient interface {
	// general purpose
	Del(key string) error
	Dels(keys []string) error
	Exists(key string) (bool, error)
	Expire(key string, expire int) error
	Incr(key string) error
	Pipeline(commands []*CacheCommand) (reply interface{}, err error)
	Ping() error

	// Set operations
	Set(key string, value interface{}) error
	SetEx(key string, value interface{}, expire int) error

	// Get operations
	Get(key string) ([]byte, error)
	GetInt(key string) (int, error)
	GetInt64(key string) (int64, error)
	GetFloat64(key string) (float64, error)
	GetString(key string) (string, error)

	// HashMap get
	HGetAll(key string) (map[string]string, error)
	HGet(key string, field string) ([]byte, error)
	HGetInt(key string, field string) (int, error)
	HGetInt64(key string, field string) (int64, error)
	HGetFloat64(key string, field string) (float64, error)
	HGetString(key string, field string) (string, error)
	HMGet(key string, fields []string) ([][]byte, error)
	HSet(key string, field interface{}, value interface{}) (int, error)
	HMSet(key string, args map[string]interface{}) error
	HDel(key string, field interface{}) (int, error)
	HDels(key string, fields []interface{}) (int, error)

	// set
	SIsMember(key string, member interface{}) (bool, error)
	SAdd(key string, members interface{}) error
	SRem(key string, members interface{}) error
	SInter(keys []string) ([]string, error)
	SUnion(keys []string) ([]string, error)
	SDiff(keys []string) ([]string, error)
	SMembers(key string) ([]string, error)

	// zset
	ZAdd(key string, score int64, member interface{}) error
	ZCard(key string) (int, error)
	ZRange(key string, min, max int64) (map[string]string, error)
	ZRemRangeByScore(key string, min, max interface{}) error
	ZRangeByScore(key string, min, max interface{}) ([]string, error)
	ZScore(key string, member interface{}) (int64, error)
	ZInterstore(newKey string, keys ...interface{}) (int64, error)

	// list
	RPop(key string) ([]byte, error)
}

type CacheCommand struct {
	Name string
	Args []interface{}
}

type CacheProvider interface {
	Provider
	My() CacheClient
	By(string) CacheClient
}

type Configer interface {
	GetLogConfig() interface{} // 日志配置
	// 数据库配置
	GetMysqlConfig() interface{} // mysql数据库配置
	// 缓存配置
	GetRedisConfig() interface{} // redis缓存配置
	// GetRabbitmqConfig 获取RabbitMq队列配置
	GetRabbitmqConfig() interface{}
	// GetKafkaConfig 获取kafka消息队列配置
	GetKafkaConfig() interface{}
	GetNosqlConfig() interface{} // NoSQL服务配置
	GetKvConfig() interface{}    // kv型服务配置
}

type DbClient interface {
	// Rebind transforms a query from QUESTION to the DB driver's bindvar type.
	Rebind(query string) string

	Get(dest interface{}, query string, args ...interface{}) error
	Queryx(query string, args ...interface{}) (*sqlx.Rows, error)
}

type DbProvider interface {
	Provider

	My() *sqlx.DB // 默认我们的数据库连接
	Master() *sqlx.DB
	Slave(int) *sqlx.DB
	By(string) *sqlx.DB // 获取某个名字的数据库连接
}

type KvProvider interface {
}

type LogProvider interface {
	Provider

	GetStdLogger() *log.Logger

	// Log add go-kit log compatibility
	Log(keyvals ...interface{}) error

	Trace(msg string, keyvals ...interface{})
	Debug(msg string, keyvals ...interface{})
	Info(msg string, keyvals ...interface{})
	Warn(msg string, keyvals ...interface{})
	Error(msg string, keyvals ...interface{})
	Fatal(msg string, keyvals ...interface{})
	Panic(msg string, keyvals ...interface{})
}

type Mq interface {
	GetDefaultOptions() map[MqOptionType]MqOptioner
	CreateProducer(name string, args ...map[MqOptionType]MqOptioner) (MqProducer, error)
	CreateConsumer(name string, processFunc MqMsgProcessFunc, args ...map[MqOptionType]MqOptioner) (MqConsumer, error)
}

type MqConsumer interface {
	Consume() // 消费消息
	Close()
}

type MqMsgAction int

type MqMsgProcessFunc func([]byte) MqMsgAction

type MqOptionType int

type MqOptioner interface {
	GetType() MqOptionType // 获取配置项类型，现在有几个配置项: exchange配置项, queue配置项, publish配置项
}

type MqProducer interface {
	Publish(data []byte, args ...interface{}) error // MQ发送消息
	GetLastConfirmedId() uint64                     // 获取上一次确认发送成功的消息Tag
	Close()
}

type MqProvider interface {
	Provider
	My() Mq
	By(string) Mq // 获取某个Mq能力提供者
}

type NosqlProvider interface {
}

type Provider interface {
	Init(rootConfiger Configer, logger LogProvider, args ...interface{}) error // 初始化底层能力
}

type SdkConfigItem struct {
	Log      interface{} `mapstructure:"log"`    // 日志配置
	Mysql    interface{} `mapstructure:"mysql"`  // 数据库配置
	Redis    interface{} `mapstructure:"redis"`  // 缓存配置
	RabbitMq interface{} `mapstructure:"aliyun"` // rabbitmq消息队列配置
	Kafka    interface{} `mapstructure:"kafka"`  // kafka消息队列配置
	Alidts   interface{} `mapstructure:"alidts"` // aliyun dts数据同步服务配置
	Nosql    interface{} `mapstructure:"nosql"`  // NoSQL配置
	Kv       interface{} `mapstructure:"kv"`     // Key/Value数据库配置
}

type SdkType int