oramnode

Documentation

Index

• func StartServer(oramNodeServerID int, bindIP string, advIP string, rpcPort int, replicaID int, ...)
• func StartShardNodeRPCClients(endpoints []config.ShardNodeEndpoint) (map[int]ReplicaRPCClientMap, error)
• type Command
• type CommandType
• type ReplicaRPCClientMap
• type ReplicateBeginEvictionPayload
• type ReplicateBeginReadPathPayload
• type ReplicateEndEvictionPayload
• type ShardNodeRPCClient
• type ShardNodeRPCClients

Functions

func StartServer

func StartServer(oramNodeServerID int, bindIP string, advIP string, rpcPort int, replicaID int, raftPort int, joinAddr string, shardNodeRPCClients map[int]ReplicaRPCClientMap, redisEndpoints []config.RedisEndpoint, parameters config.Parameters)

func StartShardNodeRPCClients

func StartShardNodeRPCClients(endpoints []config.ShardNodeEndpoint) (map[int]ReplicaRPCClientMap, error)

Types

type Command

type Command struct {
	Type    CommandType
	Payload []byte
}

type CommandType

type CommandType int

const (
	ReplicateBeginEviction CommandType = iota
	ReplicateEndEviction
	ReplicateBeginReadPath
	ReplicateEndReadPath
)

type ReplicaRPCClientMap

type ReplicaRPCClientMap map[int]ShardNodeRPCClient

type ReplicateBeginEvictionPayload

type ReplicateBeginEvictionPayload struct {
	CurrentEvictionCount int
	StorageID            int
}

type ReplicateBeginReadPathPayload

type ReplicateBeginReadPathPayload struct {
	Paths     []int
	StorageID int
}

type ReplicateEndEvictionPayload

type ReplicateEndEvictionPayload struct {
	UpdatedEvictionCount int
	StorageID            int
}

type ShardNodeRPCClient

type ShardNodeRPCClient struct {
	ClientAPI shardnodepb.ShardNodeClient
	Conn      *grpc.ClientConn
}

type ShardNodeRPCClients

type ShardNodeRPCClients map[int]ReplicaRPCClientMap