rpc

Documentation

Index

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

Types

type Server

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

func NewServer

func NewServer(address, port string, authDisabled bool, secret jwt.Signer) *Server

func (*Server) ListenAddr

func (s *Server) ListenAddr() string

ListenAddr returns the listen address of the server.

func (*Server) RegisterService

func (s *Server) RegisterService(namespace string, service, out 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.