server

Documentation

Index

• func New(c *conf.Config, s *service.Service) (svr *rpc.Server)
• type RPC
  • func (r *RPC) AddAssist(c context.Context, arg *assist.ArgAssist, res *struct{}) (err error)
  • func (r *RPC) Assist(c context.Context, arg *assist.ArgAssist, res *assist.AssistRes) (err error)
  • func (r *RPC) AssistExit(c context.Context, arg *assist.ArgAssist, res *struct{}) (err error)
  • func (r *RPC) AssistIDs(c context.Context, arg *assist.ArgAssists, res *[]int64) (err error)
  • func (r *RPC) AssistLogAdd(c context.Context, arg *assist.ArgAssistLogAdd, res *struct{}) (err error)
  • func (r *RPC) AssistLogCancel(c context.Context, arg *assist.ArgAssistLog, res *struct{}) (err error)
  • func (r *RPC) AssistLogInfo(c context.Context, arg *assist.ArgAssistLog, res *assist.Log) (err error)
  • func (r *RPC) AssistLogs(c context.Context, arg *assist.ArgAssistLogs, res *[]*assist.Log) (err error)
  • func (r *RPC) AssistUps(c context.Context, arg *assist.ArgAssistUps, res *assist.AssistUpsPager) (err error)
  • func (r *RPC) Assists(c context.Context, arg *assist.ArgAssists, res *[]*assist.Assist) (err error)
  • func (r *RPC) Auth(c context.Context, arg *rpc.Auth, res *struct{}) (err error)
  • func (r *RPC) DelAssist(c context.Context, arg *assist.ArgAssist, res *struct{}) (err error)
  • func (r *RPC) Ping(c context.Context, arg *struct{}, res *struct{}) (err error)

Functions

func New

func New(c *conf.Config, s *service.Service) (svr *rpc.Server)

New new rpc server.

Types

type RPC

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

RPC rpc.

func (*RPC) AddAssist

func (r *RPC) AddAssist(c context.Context, arg *assist.ArgAssist, res *struct{}) (err error)

func (*RPC) Assist

func (r *RPC) Assist(c context.Context, arg *assist.ArgAssist, res *assist.AssistRes) (err error)

func (*RPC) AssistExit

func (r *RPC) AssistExit(c context.Context, arg *assist.ArgAssist, res *struct{}) (err error)

AssistExit notice: reuse arg *assist.ArgAssist, except Type field

func (*RPC) AssistIDs

func (r *RPC) AssistIDs(c context.Context, arg *assist.ArgAssists, res *[]int64) (err error)

func (*RPC) AssistLogAdd

func (r *RPC) AssistLogAdd(c context.Context, arg *assist.ArgAssistLogAdd, res *struct{}) (err error)

func (*RPC) AssistLogCancel

func (r *RPC) AssistLogCancel(c context.Context, arg *assist.ArgAssistLog, res *struct{}) (err error)

func (*RPC) AssistLogInfo

func (r *RPC) AssistLogInfo(c context.Context, arg *assist.ArgAssistLog, res *assist.Log) (err error)

func (*RPC) AssistLogs

func (r *RPC) AssistLogs(c context.Context, arg *assist.ArgAssistLogs, res *[]*assist.Log) (err error)

func (*RPC) AssistUps

func (r *RPC) AssistUps(c context.Context, arg *assist.ArgAssistUps, res *assist.AssistUpsPager) (err error)

func (*RPC) Assists

func (r *RPC) Assists(c context.Context, arg *assist.ArgAssists, res *[]*assist.Assist) (err error)

func (*RPC) Auth

func (r *RPC) Auth(c context.Context, arg *rpc.Auth, res *struct{}) (err error)

Auth check connection success.

func (*RPC) DelAssist

func (r *RPC) DelAssist(c context.Context, arg *assist.ArgAssist, res *struct{}) (err error)

func (*RPC) Ping

func (r *RPC) Ping(c context.Context, arg *struct{}, res *struct{}) (err error)

Ping check connection success.