sharding

type Config struct {
	*ghostferry.Config

	ShardingKey   string
	ShardingValue int64
	SourceDB      string
	TargetDB      string

	SourceReplicationMaster       *ghostferry.DatabaseConfig
	ReplicatedMasterPositionQuery string
	RunFerryFromReplica           bool

	StatsDAddress string

	JoinedTables map[string][]JoinTable

	// IgnoredTables and IncludedTables are mutually exclusive. Specifying both is an error.
	IgnoredTables  []string
	IncludedTables []string

	PrimaryKeyTables []string

	Throttle *ghostferry.LagThrottlerConfig

	// ShardedCopyFilterConfig is used to configure the sharded copy filter query.
	ShardedCopyFilterConfig *ShardedCopyFilterConfig
}

type IndexConfigPerTable struct {
	IndexHint string
	IndexName string
}

type JoinTable struct {
	TableName, JoinColumn string
}

type ShardedCopyFilter struct {
	ShardingKey      string
	ShardingValue    interface{}
	JoinedTables     map[string][]JoinTable
	PrimaryKeyTables map[string]struct{}

	IndexHint           string
	IndexConfigPerTable map[string]IndexConfigPerTable
	// contains filtered or unexported fields
}

type ShardedCopyFilterConfig struct {

	// See https://dev.mysql.com/doc/refman/8.0/en/index-hints.html for more information on index hints.
	IndexHint string // none or force or use

	// IndexHintingPerTable has greatest specificity and takes precedence over the other options if specified.
	// Otherwise it will inherit the higher level IndexHint.
	// IndexName option is ignored if IndexHint is "none".
	// IndexName option is ignored if it is not an index on the table.
	//
	// example:
	// IndexHintingPerTable: {
	//   "blog": {
	//     "users": {
	//       "IndexHint": "force",
	//       "IndexName": "ix_users_some_id"
	//     }
	//   }
	// }
	IndexHintingPerTable map[string]map[string]IndexConfigPerTable
}

type ShardedTableFilter struct {
	SourceShard      string
	ShardingKey      string
	JoinedTables     map[string][]JoinTable
	Type             ShardedTableFilterType
	Tables           []*regexp.Regexp
	PrimaryKeyTables map[string]struct{}
}

type ShardedTableFilterType int64

type ShardingFerry struct {
	Ferry *ghostferry.Ferry
	// contains filtered or unexported fields
}