network

type ConnectionProvider ¶

type ConnectionProvider interface {
	// Call returns true if and only if the call was successful
	Call(server string, svcName string, svcMeth string, args interface{}, reply interface{}) bool
	// Me returns the address of this Host
	Me() string
	NumPeers() int
}

Serves as an additional abstraction over labrpc/networking. Raft + the client

identify servers by indices. This interface is responsible for taking a call, translating the index into either a 'labrpc' end or an actual network connection and executing the rpc just as labrpc does. Using this class should let us maintain a similar interface in our code but swap out whether we want to use labrpc or real ip addresses

func New(peers []*labrpc.ClientEnd, me int) ConnectionProvider

type LabrpcConnectionProvider ¶

type LabrpcConnectionProvider struct {
	// contains filtered or unexported fields
}

Implements the ConnectionProvider interface using the laprpc library

func (cp *LabrpcConnectionProvider) Call(server string, svcName string, svcMeth string, args interface{}, reply interface{}) bool

func (cp *LabrpcConnectionProvider) Me() string

func (cp *LabrpcConnectionProvider) NumPeers() int

type Libp2pConnectionProvider ¶

type Libp2pConnectionProvider struct {
	Host   host.Host
	Client *gorpc.Client
	Server *gorpc.Server
}

Libp2pConnectionProvider implements the ConnectionProvider interface using libp2p

func NewLibp2p() *Libp2pConnectionProvider

func (cp *Libp2pConnectionProvider) Call(server string, svcName string, svcMeth string, args interface{}, reply interface{}) bool

func (cp *Libp2pConnectionProvider) Me() string

func (cp *Libp2pConnectionProvider) NumPeers() int