router

Documentation

Index

• Constants
• func StartRPCServer(ip string, shardNodeRPCClients map[int]ReplicaRPCClientMap, routerID int, ...)
• func StartShardNodeRPCClients(endpoints []config.ShardNodeEndpoint) (map[int]ReplicaRPCClientMap, error)
• type ReplicaRPCClientMap
• type ShardNodeRPCClient

Constants

const (
	Read int = iota
	Write
)

Functions

func StartRPCServer

func StartRPCServer(ip string, shardNodeRPCClients map[int]ReplicaRPCClientMap, routerID int, port int, parameters config.Parameters)

func StartShardNodeRPCClients

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

Types

type ReplicaRPCClientMap

type ReplicaRPCClientMap map[int]ShardNodeRPCClient

type ShardNodeRPCClient

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