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.