node

Documentation

Index

• type NodeService
  • func (ns *NodeService) Bye(addr string, none *struct{}) error
  • func (ns *NodeService) Invite(nsAddr string, none *struct{}) error
• type Server
  • func New(selfAddr string) (*Server, error)
  • func (s *Server) Activate()
  • func (s *Server) Close() error
  • func (s *Server) Get(addr, service string) (rpcutil.Client, error)
  • func (s *Server) GetServices(name string) (rpcutil.Clients, error)
  • func (s *Server) Join(addr string) error
  • func (s *Server) Leave(addr string) error
  • func (s *Server) LeaveAll() error
  • func (s *Server) Name() string
  • func (s *Server) Peers() []string
  • func (s *Server) Provides() []string
  • func (s *Server) Rcvr() interface{}
  • func (s *Server) Register(svc services.Service) error
  • func (s *Server) RegisterName(name string, svc services.Service) error
  • func (s *Server) SelfAddr() string
  • func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)
  • func (s *Server) SetNSFactory(factory func() (rpcutil.Client, error))

Types

type NodeService

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

NodeService Remote Stub

func (*NodeService) Bye

func (ns *NodeService) Bye(addr string, none *struct{}) error

Bye ...

func (*NodeService) Invite

func (ns *NodeService) Invite(nsAddr string, none *struct{}) error

Invite ...

type Server

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

Server ...

func New

func New(selfAddr string) (*Server, error)

New ...

func (*Server) Activate

func (s *Server) Activate()

Activate ...

func (*Server) Close

func (s *Server) Close() error

Close ...

func (*Server) Get

func (s *Server) Get(addr, service string) (rpcutil.Client, error)

Get ...

func (*Server) GetServices

func (s *Server) GetServices(name string) (rpcutil.Clients, error)

GetServices ...

func (*Server) Join

func (s *Server) Join(addr string) error

Join ...

func (*Server) Leave

func (s *Server) Leave(addr string) error

Leave ...

func (*Server) LeaveAll

func (s *Server) LeaveAll() error

LeaveAll ...

func (*Server) Name

func (s *Server) Name() string

Name ...

func (*Server) Peers

func (s *Server) Peers() []string

Peers ...

func (*Server) Provides

func (s *Server) Provides() []string

Provides ...

func (*Server) Rcvr

func (s *Server) Rcvr() interface{}

Rcvr ...

func (*Server) Register

func (s *Server) Register(svc services.Service) error

Register ...

func (*Server) RegisterName

func (s *Server) RegisterName(name string, svc services.Service) error

RegisterName ...

func (*Server) SelfAddr

func (s *Server) SelfAddr() string

SelfAddr ...

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

ServeHTTP ...

func (*Server) SetNSFactory

func (s *Server) SetNSFactory(factory func() (rpcutil.Client, error))

SetNSFactory ...