rpc

Documentation

Index

• Constants
• type Config
• type NetworkLayer
• type RPCType
• type Server
  • func NewServer(c *Config) (*Server, error)
  • func (s *Server) AddNetworkLayer(layer NetworkLayer)
  • func (s *Server) Close() error
  • func (s *Server) Handoff(conn net.Conn) error
  • func (s *Server) Type() RPCType

Constants

const (
	CommandRPC RPCType = 0x01
	RaftRPC            = 0x02
	GossipRPC          = 0x03
)

Types

type Config

type Config struct {
	Addr string

	Logger *jolt.Logger
}

type NetworkLayer

type NetworkLayer interface {
	Type() RPCType
	Handoff(net.Conn) error
}

type RPCType

type RPCType byte

type Server

type Server struct {
	net.Listener
	*rpc.Server
	// contains filtered or unexported fields
}

func NewServer

func NewServer(c *Config) (*Server, error)

func (*Server) AddNetworkLayer

func (s *Server) AddNetworkLayer(layer NetworkLayer)

func (*Server) Close

func (s *Server) Close() error

func (*Server) Handoff

func (s *Server) Handoff(conn net.Conn) error

func (*Server) Type

func (s *Server) Type() RPCType