Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IShardController ¶
type IShardController interface { // NotifyNewPeerAdded sends new peer added information to mtvSyncMgr NotifyNewPeerAdded(cp *connection.ConnPeer, t config.NodeType) // NotifyPeerDone sends the new-done information to syncManager. NotifyPeerDone(cp *connection.ConnPeer, t config.NodeType) // HandleRPCReq handles a RPCReq for the relevant shard. HandleRPCReq(req *message.RPCReq) *message.RPCResp // ShardIndex returns the index of the shardController ShardIndex() shard.Index // IsEnabled returns if the processor is in working. IsEnabled() bool }
IShardController defines the local interface which serves as the entry for business logic in a particular shard.
Click to show internal directories.
Click to hide internal directories.