gosql

type Cluster struct {
	DP     DbPartitioner
	Shards []*Shard
}

type ClusterConfig struct {
	ReplicationConfig    ReplicationConfig
	DbPartitionConfig    DbPartitionConfig
	TablePartitionConfig TablePartitionConfig
}

type ClusterConfiger interface {
	GetReplicationConfig() *ReplicationConfig
	GetDbPartitionConfig() *DbPartitionConfig
	GetTablePartitionConfig() *TablePartitionConfig
}

type Config struct {
	Cluster *ClusterConfig
	Shards  []*ShardConfig
}

type Configer interface {
	GetClusterConfig() *ClusterConfig
	GetShardsConfig() []*ShardConfig
}

type ConnConfiger interface {
	GetMaxLifetime() time.Duration
	GetMaxIdleConns() int
	GetMaxOpenConns() int
}

type DBHandler func(*sql.DB, TablePartition) error

type DbConfiger interface {
	GetDriver() string
	GetDbname() string
	SetDbname(string)
	ConnConfiger
}

type DbPartition struct {
	Total     int
	Partition Partition
}

type DbPartitionConfig struct {
	YamlDbPartitionConfig
}

type DbPartitionConfiger interface {
	GetTotal() int
	GetType() string
}

type DbPartitioner interface {
	Select(key []byte) int
	Divide(prefix string, num int) string
}

type Decoder interface {
	Decode(interface{}) error
}

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

type MasterNodeConfiger interface {
	GetMasterUrl() string
	DbConfiger
}

type NopDbPartition struct {
}

type NopReplication struct {
}

type NopTablePartition struct {
}

type Option interface {
	// contains filtered or unexported methods
}

type Partition = distributed.Partition

type PreloadTablePartition struct {
	Partition Partition
	// contains filtered or unexported fields
}

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

type ReplicaNodeConfiger interface {
	GetReplicaUrls() []string
	DbConfiger
}

type ReplicaNodeOption interface {
	// contains filtered or unexported methods
}

type Replication = distributed.Replication

type ReplicationConfig struct {
	YamlReplicationConfig
}

type ReplicationConfiger interface {
	GetType() string
}

type Shard struct {
	Master  *MasterNode
	Replica *ReplicaNode

	Executor func(*sql.DB, DBHandler, TablePartition)
	// contains filtered or unexported fields
}

type ShardConfig struct {
	YamlDBConfig
	YamlShardConfig
	// contains filtered or unexported fields
}

type ShardConfiger interface {
	MasterNodeConfiger
	ReplicaNodeConfiger
	ReplicationConfiger
}

type TablePartition interface {
	Select(key []byte, prefix string) string
}

type TablePartitionConfig struct {
	YamlTablePartitionConfig
}

type TablePartitionConfiger interface {
	GetType() string
	GetSpecs() []*TablePartitionSpecsConfig
}

type TablePartitionSpecConfiger interface {
	GetName() string
	GetTotal() int
}

type TablePartitionSpecsConfig = YamlTablePartitionSpecConfig

type YamlClusterConfig struct {
	Replication YamlReplicationConfig `yaml:"replication"`
	Partition   YamlPartitionConfig   `yaml:"partition"`
}

type YamlConfig struct {
	Cluster YamlClusterConfig  `yaml:"cluster"`
	Db      YamlDBConfig       `yaml:"db"`
	Shards  []*YamlShardConfig `yaml:"shards"`
}

type YamlConnConfig struct {
	MaxLifetime  int `yaml:"max_life_time"`
	MaxIdleConns int `yaml:"max_idle_conns"`
	MaxOpenConns int `yaml:"max_open_conns"`
}

type YamlDBConfig struct {
	Driver string         `yaml:"driver"`
	Dbname string         `yaml:"dbname"`
	Conn   YamlConnConfig `yaml:"conn"`
}

type YamlDbPartitionConfig struct {
	Type  string `yaml:"type"`
	Total int    `yaml:"total"`
}

type YamlMasterConfig struct {
	Host           string `yaml:"host"`
	YamlNodeConfig `yaml:",inline"`
}

type YamlNodeConfig struct {
	User     string            `yaml:"user"`
	Password string            `yaml:"password"`
	Protocol string            `yaml:"protocol"`
	Params   map[string]string `yaml:"params"`
}

type YamlPartitionConfig struct {
	Db    YamlDbPartitionConfig    `yaml:"db"`
	Table YamlTablePartitionConfig `yaml:"table"`
}

type YamlReplicasConfig struct {
	Hosts          []string `yaml:"hosts"`
	YamlNodeConfig `yaml:",inline"`
}

type YamlReplicationConfig struct {
	Type string `yaml:"type"`
}

type YamlShardConfig struct {
	Master   YamlMasterConfig   `yaml:"master"`
	Replicas YamlReplicasConfig `yaml:"replicas"`
}

type YamlTablePartitionConfig struct {
	Type  string                       `yaml:"type"`
	Specs []*TablePartitionSpecsConfig `yaml:"specs"`
}

type YamlTablePartitionSpecConfig struct {
	Name  string `yaml:"name"`
	Total int    `yaml:"total"`
}