rpc

Documentation

Index

• func RPCServerInit()
• type RPCClient
  • func NewRPCClient() (c *RPCClient, err error)
• type RPCServer
  • func (s *RPCServer) SendNotify(ctx context.Context, in *rpc.ASSendNotifyReq) (res *rpc.ASSendNotifyRes, err error)
  • func (s *RPCServer) SendP2PMsgFromJob(ctx context.Context, in *rpc.ASSendP2PMsgFromJobReq) (res *rpc.ASSendP2PMsgFromJobRes, err error)

Functions

func RPCServerInit

func RPCServerInit()

Types

type RPCClient

type RPCClient struct {
	Logic *client.LogicRPCCli
}

func NewRPCClient

func NewRPCClient() (c *RPCClient, err error)

type RPCServer

type RPCServer struct {
}

func (*RPCServer) SendNotify

func (s *RPCServer) SendNotify(ctx context.Context, in *rpc.ASSendNotifyReq) (res *rpc.ASSendNotifyRes, err error)

func (*RPCServer) SendP2PMsgFromJob

func (s *RPCServer) SendP2PMsgFromJob(ctx context.Context, in *rpc.ASSendP2PMsgFromJobReq) (res *rpc.ASSendP2PMsgFromJobRes, err error)