gosql

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

type ClusterConfig struct {
	ReplicationConfig ReplicationConfig
	PartitionConfig   PartitionConfig
}

type ClusterConfiger interface {
	GetReplicationConfig() *ReplicationConfig
	GetPartitionConfig() *PartitionConfig
}

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, TableSelector) error

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

type DbPartition struct {
	Total int
	// contains filtered or unexported fields
}

type DbPartitioner interface {
	Pick(prefix string, index int) string
	Partition([]byte, string) int
	TableSelector
}

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 PartitionConfig struct {
	Type    string
	DbTotal int
	Table   *TablePartitionConfig
}

type PartitionConfiger interface {
	GetDbTotal() int
	GetType() string
	GetTablePartitionConfig() *TablePartitionConfig
}

type PreloadTablePartition struct {
	Table           string
	TableTotal      int
	TableChunkTotal int
	// 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, TableSelector)
	// 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, table string) string
	Partition(key []byte) int
	GetTableTotal() int
	GetTableChunkTotal() int
}

type TablePartitionConfig struct {
	DbTotal     int
	TableConfig []*TablePartitionNodeConfig
}

type TablePartitionConfiger interface {
	GetDbTotal() int
	GetTableTotal() int
	GetName() string
}

type TablePartitionNodeConfig struct {
	DbTotal int
	Name    string
	Total   int
}

type TableSelector interface {
	Select([]byte, string) string
}

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 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 {
	Type    string                      `yaml:"type"`
	DbTotal int                         `yaml:"db_total"`
	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 {
	Name  string `yaml:"name"`
	Total int    `yaml:"total"`
}