Documentation ¶
Index ¶
- Constants
- func StartOramNodeRPCClients(endpoints []config.OramNodeEndpoint) (map[int]ReplicaRPCClientMap, error)
- func StartServer(shardNodeServerID int, bindIp string, advertiseIp string, rpcPort int, ...)
- type BatchReplicateRequestAndPathAndStoragePayload
- type Command
- type CommandType
- type OperationType
- type RPCClientMap
- type ReplicaRPCClientMap
- type ReplicateAcksNacksPayload
- type ReplicateRequestAndPathAndStoragePayload
- type ReplicateResponsePayload
- type ReplicateSentBlocksPayload
Constants ¶
View Source
const ( Read = iota Write )
Variables ¶
This section is empty.
Functions ¶
func StartOramNodeRPCClients ¶
func StartOramNodeRPCClients(endpoints []config.OramNodeEndpoint) (map[int]ReplicaRPCClientMap, error)
func StartServer ¶
func StartServer(shardNodeServerID int, bindIp string, advertiseIp string, rpcPort int, replicaID int, raftPort int, joinAddr string, oramNodeRPCClients map[int]ReplicaRPCClientMap, parameters config.Parameters, storages []config.RedisEndpoint, configsPath string)
Types ¶
type BatchReplicateRequestAndPathAndStoragePayload ¶
type BatchReplicateRequestAndPathAndStoragePayload struct { Requests []ReplicateRequestAndPathAndStoragePayload LeaderID int }
type Command ¶
type Command struct { Type CommandType Payload []byte }
type CommandType ¶
type CommandType int
const ( BatchReplicateRequestAndPathAndStorageCommand CommandType = iota ReplicateResponseCommand ReplicateSentBlocksCommand ReplicateAcksNacksCommand )
type OperationType ¶
type OperationType int
type RPCClientMap ¶
type RPCClientMap map[int]ReplicaRPCClientMap
type ReplicaRPCClientMap ¶
type ReplicaRPCClientMap map[int]oramNodeRPCClient
type ReplicateSentBlocksPayload ¶
type ReplicateSentBlocksPayload struct {
SentBlocks []string
}
Click to show internal directories.
Click to hide internal directories.