rpc

Documentation

Index

• func New(c *conf.Config, s *service.Service) (svr *rpc.Server)
• type RPC
  • func (r *RPC) Group(c context.Context, a *model.GroupReq, res *model.GroupResp) (err error)
  • func (r *RPC) Mget(c context.Context, a *model.MgetReq, res *model.MgetResp) (err error)
  • func (r *RPC) Ping(c context.Context, arg *struct{}, res *struct{}) (err error)
  • func (r *RPC) Sort(c context.Context, a *model.SortReq, res *model.SortResp) (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 favorite rpc.

func (*RPC) Group

func (r *RPC) Group(c context.Context, a *model.GroupReq, res *model.GroupResp) (err error)

Group .

func (*RPC) Mget

func (r *RPC) Mget(c context.Context, a *model.MgetReq, res *model.MgetResp) (err error)

Mget .

func (*RPC) Ping

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

Ping check connection success.

func (*RPC) Sort

func (r *RPC) Sort(c context.Context, a *model.SortReq, res *model.SortResp) (err error)

Sort .