server

Documentation

Index

• func New(c *conf.Config, s *service.Service) (svr *rpc.Server)
• type RPC
  • func (r *RPC) Auth(c context.Context, arg *rpc.Auth, res *struct{}) (err error)
  • func (r *RPC) ConsumePoint(c context.Context, a *model.ArgPointConsume, status *int8) (err error)
  • func (r *RPC) Ping(c context.Context, arg *struct{}, res *struct{}) (err error)
  • func (r *RPC) PointAdd(c context.Context, a *model.ArgPoint, status *int8) (err error)
  • func (r *RPC) PointAddByBp(c context.Context, arg *model.ArgPointAdd, res *int64) (err error)
  • func (r *RPC) PointHistory(c context.Context, arg *model.ArgRPCPointHistory, res *model.PointHistoryResp) (err error)
  • func (r *RPC) PointInfo(c context.Context, a *model.ArgRPCMid, res *model.PointInfo) (err error)

Functions

func New

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

New init rpc.

Types

type RPC

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

RPC represent rpc server

func (*RPC) Auth

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

Auth check connection success.

func (*RPC) ConsumePoint

func (r *RPC) ConsumePoint(c context.Context, a *model.ArgPointConsume, status *int8) (err error)

ConsumePoint point consume.

func (*RPC) Ping

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

Ping check connection success.

func (*RPC) PointAdd

func (r *RPC) PointAdd(c context.Context, a *model.ArgPoint, status *int8) (err error)

PointAdd point add.

func (*RPC) PointAddByBp

func (r *RPC) PointAddByBp(c context.Context, arg *model.ArgPointAdd, res *int64) (err error)

PointAddByBp point add by bp.

func (*RPC) PointHistory

func (r *RPC) PointHistory(c context.Context, arg *model.ArgRPCPointHistory, res *model.PointHistoryResp) (err error)

PointHistory point history.

func (*RPC) PointInfo

func (r *RPC) PointInfo(c context.Context, a *model.ArgRPCMid, res *model.PointInfo) (err error)

PointInfo point info.