raftstore

type Config struct {
	NodeID        uint64 // Identity of raft server instance.
	WalPath       string // Path of WAL(Write after Log)
	IpAddr        string // IP address of node
	HeartbeatPort int
	ReplicatePort int
	RetainLogs    uint64 // // RetainLogs controls how many logs we leave after truncate. The default value is 20000.
}

type NodeManager interface {
	// AddNode used to add node address information.
	AddNode(nodeId uint64, addr string)

	// AddNode adds node address with specified port.
	AddNodeWithPort(nodeId uint64, addr string, heartbeat int, replicate int)

	// DeleteNode used to delete node address information
	// of specified node ID from NodeManager if possible.
	DeleteNode(nodeId uint64)
}

type NodeResolver interface {
	raft.SocketResolver
	NodeManager
}

type Partition interface {
	// Submit submits command data to raft log.
	Submit(cmd []byte) (resp interface{}, err error)

	// ChaneMember submits member change event and information to raft log.
	ChangeMember(changeType proto.ConfChangeType, peer proto.Peer, context []byte) (resp interface{}, err error)

	// Stop removes this raft partition from raft server and make this partition shutdown.
	Stop() error

	// Delete stop and delete this partition forever.
	Delete() error

	// Status returns current raft status.
	Status() (status *PartitionStatus)

	// LeaderTerm returns current term of leader in raft group.
	LeaderTerm() (leaderId, term uint64)

	// IsLeader returns true if this node current is the leader in the raft group it belong to.
	IsLeader() bool

	// AppliedIndex returns current index value of applied raft log in this raft store partition.
	AppliedIndex() uint64

	// Truncate raft log
	Truncate(index uint64)
}

type PartitionConfig struct {
	ID      uint64
	Applied uint64
	Leader  uint64
	Term    uint64
	Peers   []PeerAddress
	SM      PartitionFsm
}

type PartitionFsm interface {
	raft.StateMachine
	Store
}

type PartitionStatus = raft.Status

type PeerAddress struct {
	proto.Peer
	Address       string
	HeartbeatPort int
	ReplicatePort int
}

type RaftStore interface {
	CreatePartition(cfg *PartitionConfig) (Partition, error)
	Stop()
	RaftConfig() *raft.Config
	NodeManager
}

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

type Store interface {
	Put(key, val interface{}) (interface{}, error)
	Get(key interface{}) (interface{}, error)
	Del(key interface{}) (interface{}, error)
}