server

Documentation

Index

• func New(c *conf.Config, s *match.Service) (svr *rpc.Server)
• type RPC
  • func (r *RPC) ActProtocol(c context.Context, a *matmdl.ArgActProtocol, res *matmdl.SubProtocol) (err error)
  • func (r *RPC) ActSubject(c context.Context, a *matmdl.ArgActSubject, res *matmdl.SubjectItem) (err error)
  • func (r *RPC) AddLikeCtimeCache(c context.Context, a *matmdl.ArgLikeUp, res *struct{}) (err error)
  • func (r *RPC) DelLikeCtimeCache(c context.Context, item *matmdl.ArgLikeItem, res *struct{}) (err error)
  • func (r *RPC) LikeUp(c context.Context, a *matmdl.ArgLikeUp, res *struct{}) (err error)
  • func (r *RPC) Matchs(c context.Context, a *matmdl.ArgMatch, res *[]*matmdl.Match) (err error)
  • func (r *RPC) Ping(c context.Context, arg *struct{}, res *struct{}) (err error)
  • func (r *RPC) SubjectUp(c context.Context, a *matmdl.ArgSubjectUp, res *struct{}) (err error)

Functions

func New

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

New new rpc server.

Types

type RPC

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

RPC struct info.

func (*RPC) ActProtocol

func (r *RPC) ActProtocol(c context.Context, a *matmdl.ArgActProtocol, res *matmdl.SubProtocol) (err error)

ActProtocol .

func (*RPC) ActSubject

func (r *RPC) ActSubject(c context.Context, a *matmdl.ArgActSubject, res *matmdl.SubjectItem) (err error)

ActSubject get act subject info.

func (*RPC) AddLikeCtimeCache

func (r *RPC) AddLikeCtimeCache(c context.Context, a *matmdl.ArgLikeUp, res *struct{}) (err error)

AddLikeCtimeCache like ctime cache.

func (*RPC) DelLikeCtimeCache

func (r *RPC) DelLikeCtimeCache(c context.Context, item *matmdl.ArgLikeItem, res *struct{}) (err error)

DelLikeCtimeCache del like ctime cache

func (*RPC) LikeUp

func (r *RPC) LikeUp(c context.Context, a *matmdl.ArgLikeUp, res *struct{}) (err error)

LikeUp up likes cache info and like maxID cache

func (*RPC) Matchs

func (r *RPC) Matchs(c context.Context, a *matmdl.ArgMatch, res *[]*matmdl.Match) (err error)

Matchs return matchs by sid

func (*RPC) Ping

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

Ping check connection success.

func (*RPC) SubjectUp

func (r *RPC) SubjectUp(c context.Context, a *matmdl.ArgSubjectUp, res *struct{}) (err error)

SubjectUp up act_subject cahce info and act_subject maxID cache.