rpc

Documentation

Index

• Variables
• type Client
  • func NewClient(addr string, token string, tls *tls.Config) *Client
  • func (r *Client) Call(ctx context.Context, servicePath, serviceMethod string, args interface{}, ...) error
  • func (r *Client) Client(servicePath string) client.XClient
  • func (r *Client) Close() error
• type Empty
• type Server
  • func NewServer(addr string, token string, tls *tls.Config) *Server
  • func (r *Server) Close() error
  • func (r *Server) Register(services ...interface{}) *Server
  • func (r *Server) RegisterFuncName(servicePath, name string, service interface{}) *Server
  • func (r *Server) RegisterName(name string, service interface{}) *Server
  • func (r *Server) Start() error

Variables

var (
	ErrRPCServerDisabled = errors.New("server is disabled")
	ErrInvalidToken      = errors.New("invalid token")
)

Types

type Client

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

func NewClient

func NewClient(addr string, token string, tls *tls.Config) *Client

func (*Client) Call

func (r *Client) Call(ctx context.Context, servicePath, serviceMethod string, args interface{}, reply interface{}) error

func (*Client) Client

func (r *Client) Client(servicePath string) client.XClient

func (*Client) Close

func (r *Client) Close() error

type Empty

type Empty struct{}

type Server

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

func NewServer

func NewServer(addr string, token string, tls *tls.Config) *Server

func (*Server) Close

func (r *Server) Close() error

func (*Server) Register

func (r *Server) Register(services ...interface{}) *Server

func (*Server) RegisterFuncName

func (r *Server) RegisterFuncName(servicePath, name string, service interface{}) *Server

func (*Server) RegisterName

func (r *Server) RegisterName(name string, service interface{}) *Server

func (*Server) Start

func (r *Server) Start() error