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) CheckVersion(c context.Context, arg *struct{}, res *model.SeqVersion) (err error)
  • func (r *RPC) ID(c context.Context, a *model.ArgBusiness, res *int64) (err error)
  • func (r *RPC) ID32(c context.Context, a *model.ArgBusiness, res *int32) (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 creates rpc server.

Types

type RPC

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

RPC rpc.

func (*RPC) Auth

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

Auth check connection success.

func (*RPC) CheckVersion

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

CheckVersion check db health.

func (*RPC) ID

func (r *RPC) ID(c context.Context, a *model.ArgBusiness, res *int64) (err error)

ID return id.

func (*RPC) ID32

func (r *RPC) ID32(c context.Context, a *model.ArgBusiness, res *int32) (err error)

ID32 return id32.

func (*RPC) Ping

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

Ping check connection success.