network

Documentation

Index

• type LocalTransport
  • func (t *LocalTransport) Addr() NetAddr
  • func (t *LocalTransport) Connect(tr Transport) error
  • func (t *LocalTransport) Consume() <-chan RPC
  • func (t *LocalTransport) SendMessage(to NetAddr, payload []byte) error
• type NetAddr
• type RPC
• type Server
  • func NewServer(opts ServerOpts) *Server
  • func (s *Server) Start()
• type ServerOpts
• type Transport
  • func NewLocalTransport(addr NetAddr) Transport

Types

type LocalTransport

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

func (*LocalTransport) Addr

func (t *LocalTransport) Addr() NetAddr

func (*LocalTransport) Connect

func (t *LocalTransport) Connect(tr Transport) error

func (*LocalTransport) Consume

func (t *LocalTransport) Consume() <-chan RPC

func (*LocalTransport) SendMessage

func (t *LocalTransport) SendMessage(to NetAddr, payload []byte) error

type NetAddr

type NetAddr string

type RPC

type RPC struct {
	From    NetAddr
	Payload []byte
}

type Server

type Server struct {
	ServerOpts
	// contains filtered or unexported fields
}

func NewServer

func NewServer(opts ServerOpts) *Server

func (*Server) Start

func (s *Server) Start()

type ServerOpts

type ServerOpts struct {
	Transports []Transport
}

type Transport

type Transport interface {
	Addr() NetAddr
	Consume() <-chan RPC
	Connect(Transport) error
	SendMessage(NetAddr, []byte) error
}

func NewLocalTransport

func NewLocalTransport(addr NetAddr) Transport