metadata

type Adapter interface {
	// NewResource return a new resource
	NewResource() Resource
	// NewContainer return a new container
	NewContainer() Container
}

type Container interface {
	// SetAddrs set addrs
	SetAddrs(addr, shardAddr string)
	// Addr returns address that used for client request
	Addr() string
	// ShardAddr returns address that used for communication between the resource replications
	ShardAddr() string
	// SetID update the container id
	SetID(id uint64)
	// ID returns the container id
	ID() uint64
	// Labels returns the lable tag of the container
	Labels() []metapb.Pair
	// SetLabels set labels
	SetLabels(labels []metapb.Pair)
	// The start timestamp of the current container
	StartTimestamp() int64
	// SetStartTimestamp set the start timestamp of the current container
	SetStartTimestamp(int64)
	// Version returns version and githash
	Version() (string, string)
	// SetVersion set version
	SetVersion(version string, githash string)
	// DeployPath returns the container deploy path
	DeployPath() string
	// SetDeployPath set deploy path
	SetDeployPath(string)
	// State returns the state of the container
	State() metapb.ContainerState
	// SetState set state
	SetState(metapb.ContainerState)
	// The last heartbeat timestamp of the container.
	LastHeartbeat() int64
	//SetLastHeartbeat set the last heartbeat timestamp of the container.
	SetLastHeartbeat(int64)
	// PhysicallyDestroyed return true if the contianer is physically destroyed,
	// which means it can never up again
	PhysicallyDestroyed() bool
	// SetPhysicallyDestroyed set physicallyDestroyed
	SetPhysicallyDestroyed(bool)

	// Clone returns the cloned value
	Clone() Container
	// Marshal returns error if marshal failed
	Marshal() ([]byte, error)
	// Unmarshal returns error if unmarshal failed
	Unmarshal(data []byte) error
}

type Resource interface {
	// ID returns the resource id
	ID() uint64
	// SetID update the resource id
	SetID(id uint64)
	// Group resource group
	Group() uint64
	// SetGroup set raft group
	SetGroup(uint64)
	// Peers returns the repication peers
	Peers() []metapb.Replica
	// SetPeers update the repication peers
	SetPeers(peers []metapb.Replica)
	// Range resource range
	Range() ([]byte, []byte)
	// SetStartKey set startKey
	SetStartKey([]byte)
	// SetEndKey set startKey
	SetEndKey([]byte)
	// Epoch returns resource epoch
	Epoch() metapb.ResourceEpoch
	// SetEpoch set epoch
	SetEpoch(metapb.ResourceEpoch)
	// State resource state
	State() metapb.ResourceState
	// SetState set resource state
	SetState(metapb.ResourceState)
	// Unique is identifier of the resources, used for dynamic create resources.
	Unique() string
	// SetUnique set Unique
	SetUnique(string)
	// Data resource data
	Data() []byte
	// SetData set resource data
	SetData([]byte)
	// RuleGroups used for placement rule engine to use, all rule group will used if nil returned.
	RuleGroups() []string
	// SetRuleGroups set rule groups
	SetRuleGroups(...string)
	// Labels returns the lable tag of the resource
	Labels() []metapb.Pair
	// SetLabels set labels
	SetLabels(labels []metapb.Pair)
	// Clone returns the cloned value
	Clone() Resource
	// Marshal returns error if marshal failed
	Marshal() ([]byte, error)
	// Unmarshal returns error if unmarshal failed
	Unmarshal(data []byte) error
}

type RoleChangeHandler interface {
	ProphetBecomeLeader()
	ProphetBecomeFollower()
}

type TestContainer struct {
	CID                  uint64        `json:"cid"`
	CAddr                string        `json:"addr"`
	CShardAddr           string        `json:"shardAddr"`
	CLabels              []metapb.Pair `json:"labels"`
	StartTS              int64         `json:"startTS"`
	CLastHeartbeat       int64         `json:"lastHeartbeat"`
	CVerion              string        `json:"version"`
	CGitHash             string        `json:"gitHash"`
	CDeployPath          string        `json:"deployPath"`
	CPhysicallyDestroyed bool          `json:"physicallyDestroyed"`

	CState  metapb.ContainerState `json:"state"`
	CAction metapb.Action         `json:"action"`
}

type TestResource struct {
	ResID         uint64               `json:"id"`
	ResGroup      uint64               `json:"group"`
	Version       uint64               `json:"version"`
	ResPeers      []metapb.Replica     `json:"peers"`
	ResLabels     []metapb.Pair        `json:"labels"`
	Start         []byte               `json:"start"`
	End           []byte               `json:"end"`
	ResEpoch      metapb.ResourceEpoch `json:"epoch"`
	ResState      metapb.ResourceState `json:"state"`
	ResUnique     string               `json:"unique"`
	ResData       []byte               `json:"data"`
	ResRuleGroups []string             `json:"rule-groups"`
	Err           bool                 `json:"-"`
}