rpcservice

Documentation

Index

• Variables
• func RegisterClientRPCService(r func(*client.Service) interface{})
• func RegisterServerRPCService(r func(*server.Service) interface{})
• type ClientRPCService
  • func NewClientRPCService(s *client.Service) *ClientRPCService
  • func (s *ClientRPCService) Status(ctx context.Context, args *rpc.Empty, reply *client.StatusResp) error
• type ServerRPCService
  • func NewServerRPCService(s *server.Service) *ServerRPCService
  • func (s *ServerRPCService) ProxyByType(ctx context.Context, args *rpc.Empty, reply *echo.H) error
  • func (s *ServerRPCService) ProxyByTypeAndName(ctx context.Context, args *rpc.Empty, reply *echo.H) error
  • func (s *ServerRPCService) ProxyTraffic(ctx context.Context, args *rpc.Empty, reply *echo.H) error
  • func (s *ServerRPCService) ServerInfo(ctx context.Context, args *rpc.Empty, reply *echo.H) error

Variables

var (
	ClientRPCServices = []func(*client.Service) interface{}{}
	ServerRPCServices = []func(*server.Service) interface{}{}
)

Functions

func RegisterClientRPCService

func RegisterClientRPCService(r func(*client.Service) interface{})

func RegisterServerRPCService

func RegisterServerRPCService(r func(*server.Service) interface{})

Types

type ClientRPCService

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

func NewClientRPCService

func NewClientRPCService(s *client.Service) *ClientRPCService

func (*ClientRPCService) Status

func (s *ClientRPCService) Status(ctx context.Context, args *rpc.Empty, reply *client.StatusResp) error

type ServerRPCService

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

func NewServerRPCService

func NewServerRPCService(s *server.Service) *ServerRPCService

func (*ServerRPCService) ProxyByType

func (s *ServerRPCService) ProxyByType(ctx context.Context, args *rpc.Empty, reply *echo.H) error

func (*ServerRPCService) ProxyByTypeAndName

func (s *ServerRPCService) ProxyByTypeAndName(ctx context.Context, args *rpc.Empty, reply *echo.H) error

func (*ServerRPCService) ProxyTraffic

func (s *ServerRPCService) ProxyTraffic(ctx context.Context, args *rpc.Empty, reply *echo.H) error

func (*ServerRPCService) ServerInfo

func (s *ServerRPCService) ServerInfo(ctx context.Context, args *rpc.Empty, reply *echo.H) error