broker

type ChunkRolePosition int

type Cluster struct {
	Name   string        `json:"name"`
	Epoch  uint64        `json:"epoch"`
	Nodes  []*Node       `json:"nodes"`
	Config ClusterConfig `json:"config"`
}

type ClusterConfig struct {
	CompressionStrategy string `json:"compression_strategy"`
}

type ClusterStore struct {
	Chunks []*NodeChunkStore `json:"chunks"`
	Config *ClusterConfig    `json:"cluster_config"`
}

type EtcdConfig struct {
	PathPrefix     string
	FailureTTL     int64
	MigrationLimit int64
	FailureQuorum  int64
}

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

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

type FailedProxyStore struct {
	NodeAddresses []string `json:"node_addresses"`
}

type Host struct {
	Address        string                   `json:"address"`
	Epoch          uint64                   `json:"epoch"`
	Nodes          []*Node                  `json:"nodes"`
	FreeNodes      []string                 `json:"free_nodes"`
	Peers          []*PeerProxy             `json:"peers"`
	ClustersConfig map[string]ClusterConfig `json:"clusters_config"`
}

type MetaDataBroker interface {
	GetClusterNames(ctx context.Context) ([]string, error)
	GetCluster(ctx context.Context, name string) (*Cluster, error)
	GetProxyAddresses(ctx context.Context) ([]string, error)
	GetProxy(ctx context.Context, address string) (*Host, error)
	AddFailure(ctx context.Context, address string, reportID string) error
	GetFailures(ctx context.Context) ([]string, error)
}

type MetaManipulationBroker interface {
	// Basic API
	ReplaceProxy(ctx context.Context, proxyAddress string) (*Host, error)
	CommitMigration(ctx context.Context, task MigrationTaskMeta) error

	// Extended API
	InitGlobalEpoch() error
	CreateCluster(ctx context.Context, clusterName string, nodeNum uint64) error
	AddProxy(ctx context.Context, address string, nodes []string) error
	AddNodesToCluster(ctx context.Context, clusterName string) error
	MigrateSlots(ctx context.Context, clusterName string) error
	RemoveProxy(ctx context.Context, address string) error
	RemoveUnusedProxiesFromCluster(ctx context.Context, clusterName string) error
	RemoveCluster(ctx context.Context, clusterName string) error
	SetConfig(ctx context.Context, clusterName string, config map[string]string) error
}

type MigrationMeta struct {
	Epoch           uint64 `json:"epoch"`
	SrcProxyAddress string `json:"src_proxy_address"`
	SrcNodeAddress  string `json:"src_node_address"`
	DstProxyAddress string `json:"dst_proxy_address"`
	DstNodeAddress  string `json:"dst_node_address"`
}

type MigrationMetaStore struct {
	Epoch         uint64 `json:"epoch"`
	SrcProxyIndex uint64 `json:"src_proxy_index"`
	DstProxyIndex uint64 `json:"dst_proxy_index"`
}

type MigrationTagType string

type MigrationTaskMeta struct {
	DBName string    `json:"db_name"`
	Slots  SlotRange `json:"slot_range"`
}

type Node struct {
	Address      string      `json:"address"`
	ProxyAddress string      `json:"proxy_address"`
	ClusterName  string      `json:"cluster_name"`
	Slots        []SlotRange `json:"slots"`
	Repl         ReplMeta    `json:"repl"`
}

type NodeChunkStore struct {
	RolePosition ChunkRolePosition
	// Currently []SlotRangeStore has only at most one SlotRange with NoneTag
	// and at most one SlotRange with Migrating or Importing Tag.
	Slots [2][]SlotRangeStore `json:"slots"`
	Nodes [4]*NodeStore       `json:"nodes"`
}

type NodeStore struct {
	NodeAddress  string `json:"node_address"`
	ProxyAddress string `json:"proxy_address"`
}

type PeerProxy struct {
	ProxyAddress string      `json:"proxy_address"`
	ClusterName  string      `json:"cluster_name"`
	Slots        []SlotRange `json:"slots"`
}

type ProxyStore struct {
	ProxyIndex    uint64   `json:"proxy_index"`
	ClusterName   string   `json:"cluster_name"`
	NodeAddresses []string `json:"node_addresses"`
}

type ReplMeta struct {
	Role  Role       `json:"role"`
	Peers []ReplPeer `json:"peers"`
}

type ReplPeer struct {
	NodeAddress  string `json:"node_address"`
	ProxyAddress string `json:"proxy_address"`
}

type Role = string

type SlotRange struct {
	Start uint64       `json:"start"`
	End   uint64       `json:"end"`
	Tag   SlotRangeTag `json:"tag"`
}

type SlotRangeStore struct {
	Start uint64            `json:"start"`
	End   uint64            `json:"end"`
	Tag   SlotRangeTagStore `json:"tag"`
}

type SlotRangeTag struct {
	TagType MigrationTagType
	Meta    *MigrationMeta
}

type SlotRangeTagStore struct {
	TagType MigrationTagType    `json:"tag_type"`
	Meta    *MigrationMetaStore `json:"meta"`
}

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