rpc

Documentation

Index

• Variables
• type Server
  • func NewServer(address, port string) *Server
  • func (s *Server) ListenAddr() string
  • func (s *Server) RegisterAuthedService(namespace string, service interface{}, out interface{})
  • func (s *Server) RegisterService(namespace string, service interface{})
  • func (s *Server) Start(context.Context) error
  • func (s *Server) Stop(ctx context.Context) error

Variables

var (
	AllPerms     = []auth.Permission{"public", "read", "write", "admin"}
	DefaultPerms = []auth.Permission{"public"}
)

Types

type Server

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

func NewServer

func NewServer(address, port string) *Server

func (*Server) ListenAddr

func (s *Server) ListenAddr() string

ListenAddr returns the listen address of the server.

func (*Server) RegisterAuthedService

func (s *Server) RegisterAuthedService(namespace string, service interface{}, out interface{})

RegisterAuthedService registers a service onto the RPC server. All methods on the service will then be exposed over the RPC.

func (*Server) RegisterService

func (s *Server) RegisterService(namespace string, service interface{})

RegisterService registers a service onto the RPC server. All methods on the service will then be exposed over the RPC.

func (*Server) Start

func (s *Server) Start(context.Context) error

Start starts the RPC Server.

func (*Server) Stop

func (s *Server) Stop(ctx context.Context) error

Stop stops the RPC Server.