proxy

type AdminConfig struct {
	Host     string `json:"host,omitempty"`
	Port     uint32 `json:"port,omitempty"`
	LogLevel string `json:"log_level,omitempty"`
}

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

type App struct {
	Name     string    `json:"name"`
	Services []Service `json:"service,omitempty"`
}

type AppBuilder struct {
	VirtualDatabase   v1alpha1.VirtualDatabase
	TrafficStrategies []v1alpha1.TrafficStrategy
	DatabaseEndpoints []v1alpha1.DatabaseEndpoint
	QoSClaims         []v1alpha1.QoSClaim
}

type CircuitBreak struct {
	Regex []string `json:"regex"`
}

type ConcurrencyControl struct {
	Regex          []string      `json:"regex"`
	Duration       time.Duration `json:"duration"`
	MaxConcurrency int           `json:"max_concurrency"`
}

type Config struct {
	Port string
}

type DatabaseStrategy struct {
	DatabaseShardingAlgorithmName string `json:"database_sharding_algorithm_name"`
	DatabaseShardingColumn        string `json:"database_sharding_column"`
}

type DatabaseTableStrategy struct {
	TableStrategy
	DatabaseStrategy
}

type Endpoint struct {
	IP   string `json:"ip"`
	Port uint32 `json:"port"`
}

type GlobalConfig struct {
	EgressDevice string `json:"egress_device"`
	BridgeDevice string `json:"bridge_device"`
}

type MasterHighAvailablity struct {
	Type                      string `json:"type"`
	User                      string `json:"user"`
	Password                  string `json:"password"`
	MonitorInterval           uint64 `json:"monitor_period"`
	ConnectInterval           uint64 `json:"connect_period"`
	ConnectTimeout            uint64 `json:"connect_timeout"`
	ConnectMaxFailures        uint64 `json:"connect_failure_threshold"`
	PingInterval              uint64 `json:"ping_period"`
	PingTimeout               uint64 `json:"ping_timeout"`
	PingMaxFailures           uint64 `json:"ping_failure_threshold"`
	ReplicationLagInterval    uint64 `json:"replication_lag_period"`
	ReplicationLagTimeout     uint64 `json:"replication_lag_timeout"`
	ReplicationLagMaxFailures uint64 `json:"replication_lag_failure_threshold"`
	MaxReplicationLag         uint64 `json:"max_replication_lag"`
	ReadOnlyInterval          uint64 `json:"read_only_period"`
	ReadOnlyTimeout           uint64 `json:"read_only_timeout"`
	ReadOnlyMaxFailures       uint64 `json:"read_only_failure_threshold"`
}

type MySQLConfig struct {
	Nodes []MySQLNode `json:"node"`
}

type MySQLConfigBuilder struct {
	VirtualDatabaseService v1alpha1.VirtualDatabaseService
	TrafficStrategy        v1alpha1.TrafficStrategy
	DatabaseEndpoints      []v1alpha1.DatabaseEndpoint
}

type MySQLNode struct {
	Name     string `json:"name"`
	Db       string `json:"db"`
	User     string `json:"user"`
	Password string `json:"password"`
	Host     string `json:"host"`
	Port     uint32 `json:"port"`
	Weight   int    `json:"weight"`
	Role     string `json:"role"`
}

type NodeGroupConfig struct {
	Members []NodeGroupMember `json:"member"`
}

type NodeGroupConfigBuilder struct {
	DataShards        v1alpha1.DataShard
	DatabaseEndpoints []v1alpha1.DatabaseEndpoint
}

type NodeGroupMember struct {
	Name      string   `json:"name"`
	Reads     []string `json:"reads"`
	ReadWrite string   `json:"readwrite"`
}

type PisaDaemonConfig struct {
	// Global GlobalConfig `json:"global"`
	Apps []App `json:"app"`
}

type PisaDaemonConfigBuilder struct {
	AppBuilders []*AppBuilder
}

type PisaProxyConfig struct {
	Admin     AdminConfig     `json:"admin"`
	MySQL     MySQLConfig     `json:"mysql"`
	Proxy     ProxyConfig     `json:"proxy"`
	NodeGroup NodeGroupConfig `json:"node_group,omitempty"`
}

type PisaProxyConfigBuilder struct {
	AdminConfigBuilder     *AdminConfigBuilder
	MySQLConfigBuilder     *MySQLConfigBuilder
	ProxyConfigBuilder     *ProxyConfigBuilder
	NodeGroupConfigBuilder *NodeGroupConfigBuilder
}

type Plugin struct {
	CircuitBreaks       []CircuitBreak       `json:"circuit_break,omitempty"`
	ConcurrencyControls []ConcurrencyControl `json:"concurrency_control,omitempty"`
}

type Proxy struct {
	BackendType string `json:"backend_type"`
	DB          string `json:"db"`
	ListenAddr  string `json:"listen_addr"`
	Name        string `json:"name"`
	Password    string `json:"password"`
	// TODO: should be refactored to a new pool configuration
	PoolSize           uint32              `json:"pool_size,omitempty"`
	User               string              `json:"user"`
	SimpleLoadBalance  *SimpleLoadBalance  `json:"simple_loadbalance,omitempty"`
	ReadWriteSplitting *ReadWriteSplitting `json:"read_write_splitting,omitempty"`
	Plugin             *Plugin             `json:"plugin,omitempty"`
	ServerVersion      string              `json:"server_version,omitempty"`
	Sharding           []Sharding          `json:"sharding,omitempty"`
}

type ProxyBuilder struct {
	VirtualDatabaseService v1alpha1.VirtualDatabaseService
	TrafficStrategy        v1alpha1.TrafficStrategy
	DatabaseEndpoints      []v1alpha1.DatabaseEndpoint
	DataShard              v1alpha1.DataShard
}

type ProxyConfig struct {
	Config []Proxy `json:"config"`
}

type ProxyConfigBuilder struct {
	ProxyBuilders []*ProxyBuilder
}

type QoSClassKind string

type QoSGroup struct {
	Rate string `json:"rate,omitempty"`
	Ceil string `json:"ceil,omitempty"`
}

type ReadWriteDiscovery struct {
	*MasterHighAvailablity
}

type ReadWriteSplitting struct {
	Static  *ReadWriteSplittingStatic  `json:"static,omitempty"`
	Dynamic *ReadWriteSplittingDynamic `json:"dynamic,omitempty"`
}

type ReadWriteSplittingDynamic struct {
	DefaultTarget string                   `json:"default_target"`
	Rules         []ReadWriteSplittingRule `json:"rule"`
	Discovery     ReadWriteDiscovery       `json:"discovery"`
}

type ReadWriteSplittingRule struct {
	Name          string   `json:"name"`
	Type          string   `json:"type"`
	Regex         []string `json:"regex,omitempty"`
	Target        string   `json:"target,omitempty"`
	AlgorithmName string   `json:"algorithm_name"`
}

type ReadWriteSplittingStatic struct {
	DefaultTarget string                   `json:"default_target"`
	Rules         []ReadWriteSplittingRule `json:"rule"`
}

type Service struct {
	Name      string     `json:"name"`
	QoSGroup  QoSGroup   `json:"qos_group"`
	Endpoints []Endpoint `json:"endpoints"`
}

type ServiceBuilder struct {
	VirtualDatabaseService v1alpha1.VirtualDatabaseService
	TrafficStrategy        v1alpha1.TrafficStrategy
	QoSClaim               v1alpha1.QoSClaim
	DatabaseEndpoints      []v1alpha1.DatabaseEndpoint
}

type Sharding struct {
	TableName       string   `json:"table_name"`
	ActualDatanodes []string `json:"actual_datanodes"`
	// BindingTables [][]string `json:"binding_tables"`
	// BroadcastTables []string `json:"broadcast_tables"`
	TableStrategy         *TableStrategy         `json:"table_strategy,omitempty"`
	DatabaseStrategy      *DatabaseStrategy      `json:"database_strategy,omitempty"`
	DatabaseTableStrategy *DatabaseTableStrategy `json:"database_table_strategy,omitempty"`
}

type SimpleLoadBalance struct {
	BalancerType string   `json:"balance_type"`
	Nodes        []string `json:"nodes"`
}

type TableStrategy struct {
	TableShardingAlgorithmName string `json:"table_sharding_algorithm_name"`
	TableShardingColumn        string `json:"table_sharding_column"`
	ShardingCount              uint32 `json:"sharding_count"`
}