rpc

Documentation

Index

• func Init(c *conf.Config, s *service.Service) (svr *rpc.Server)
• type RPC
  • func (r *RPC) AddSub(c context.Context, arg *model.ArgAddSub, res *struct{}) (err error)
  • func (r *RPC) AdminBind(c context.Context, arg *model.ArgBind, res *struct{}) (err error)
  • func (r *RPC) ArcTags(c context.Context, arg *model.ArgAid, res *[]*model.Tag) (err error)
  • func (r *RPC) CancelSub(c context.Context, arg *model.ArgCancelSub, res *struct{}) (err error)
  • func (r *RPC) ChanneList(c context.Context, arg *model.ArgChanneList, res *[]*model.Channel) (err error)
  • func (r *RPC) ChannelCategories(c context.Context, arg *model.ArgChannelCategories, ...) (err error)
  • func (r *RPC) ChannelCategory(c context.Context, arg *struct{}, res *[]*model.ChannelCategory) (err error)
  • func (r *RPC) ChannelDetail(c context.Context, arg *model.ReqChannelDetail, res *model.ChannelDetail) (err error)
  • func (r *RPC) ChannelResources(c context.Context, arg *model.ArgChannelResource, res *model.ChannelResource) (err error)
  • func (r *RPC) ChannelSquare(c context.Context, arg *model.ReqChannelSquare, res *model.ChannelSquare) (err error)
  • func (r *RPC) CustomSortChannel(c context.Context, arg *model.ArgCustomSort, res *model.CustomSortChannel) (err error)
  • func (r *RPC) DiscoverChannel(c context.Context, arg *model.ArgDiscoverChanneList, res *[]*model.Channel) (err error)
  • func (r *RPC) InfoByID(c context.Context, arg *model.ArgID, res *model.Tag) (err error)
  • func (r *RPC) InfoByIDs(c context.Context, arg *model.ArgIDs, res *[]*model.Tag) (err error)
  • func (r *RPC) InfoByName(c context.Context, arg *model.ArgName, res *model.Tag) (err error)
  • func (r *RPC) InfoByNames(c context.Context, arg *model.ArgNames, res *[]*model.Tag) (err error)
  • func (r *RPC) Ping(c context.Context, arg *struct{}, res *struct{}) (err error)
  • func (r *RPC) RecommandChannel(c context.Context, arg *model.ArgRecommandChannel, res *[]*model.Channel) (err error)
  • func (r *RPC) ResChannelCheckBack(c context.Context, arg *model.ArgResChannel, ...) (err error)
  • func (r *RPC) ResTags(c context.Context, arg *model.ArgResTags, res *map[int64][]*model.Tag) (err error)
  • func (r *RPC) SubTags(c context.Context, arg *model.ArgSub, res *model.Sub) (err error)
  • func (r *RPC) TagTop(c context.Context, arg *model.ReqTagTop, res *model.TagTop) (err error)
  • func (r *RPC) UpBind(c context.Context, arg *model.ArgBind, res *struct{}) (err error)
  • func (r *RPC) UpdateCustomSort(c context.Context, arg *model.ArgUpdateCustomSort, res *struct{}) (err error)

Functions

func Init

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

Init init rpc.

Types

type RPC

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

RPC represent rpc server

func (*RPC) AddSub

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

AddSub AddSub.

func (*RPC) AdminBind

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

AdminBind .

func (*RPC) ArcTags

func (r *RPC) ArcTags(c context.Context, arg *model.ArgAid, res *[]*model.Tag) (err error)

ArcTags return archive tags by aid and mid.

func (*RPC) CancelSub

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

CancelSub CancelSub.

func (*RPC) ChanneList

func (r *RPC) ChanneList(c context.Context, arg *model.ArgChanneList, res *[]*model.Channel) (err error)

ChanneList channel list.

func (*RPC) ChannelCategories

func (r *RPC) ChannelCategories(c context.Context, arg *model.ArgChannelCategories, res *[]*model.ChannelCategory) (err error)

ChannelCategories get all channel category.

func (*RPC) ChannelCategory

func (r *RPC) ChannelCategory(c context.Context, arg *struct{}, res *[]*model.ChannelCategory) (err error)

ChannelCategory get all channel category.

func (*RPC) ChannelDetail

func (r *RPC) ChannelDetail(c context.Context, arg *model.ReqChannelDetail, res *model.ChannelDetail) (err error)

ChannelDetail channel detail.

func (*RPC) ChannelResources

func (r *RPC) ChannelResources(c context.Context, arg *model.ArgChannelResource, res *model.ChannelResource) (err error)

ChannelResources get channel resources.

func (*RPC) ChannelSquare

func (r *RPC) ChannelSquare(c context.Context, arg *model.ReqChannelSquare, res *model.ChannelSquare) (err error)

ChannelSquare channel square.

func (*RPC) CustomSortChannel

func (r *RPC) CustomSortChannel(c context.Context, arg *model.ArgCustomSort, res *model.CustomSortChannel) (err error)

CustomSortChannel custome sort channel.

func (*RPC) DiscoverChannel

func (r *RPC) DiscoverChannel(c context.Context, arg *model.ArgDiscoverChanneList, res *[]*model.Channel) (err error)

DiscoverChannel discover channel.

func (*RPC) InfoByID

func (r *RPC) InfoByID(c context.Context, arg *model.ArgID, res *model.Tag) (err error)

InfoByID Info return a tag info by id

func (*RPC) InfoByIDs

func (r *RPC) InfoByIDs(c context.Context, arg *model.ArgIDs, res *[]*model.Tag) (err error)

InfoByIDs return tags by ids

func (*RPC) InfoByName

func (r *RPC) InfoByName(c context.Context, arg *model.ArgName, res *model.Tag) (err error)

InfoByName Info return a tag info by name.

func (*RPC) InfoByNames

func (r *RPC) InfoByNames(c context.Context, arg *model.ArgNames, res *[]*model.Tag) (err error)

InfoByNames return tags by names

func (*RPC) Ping

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

Ping check connection success.

func (*RPC) RecommandChannel

func (r *RPC) RecommandChannel(c context.Context, arg *model.ArgRecommandChannel, res *[]*model.Channel) (err error)

RecommandChannel RecommandChannel.

func (*RPC) ResChannelCheckBack

func (r *RPC) ResChannelCheckBack(c context.Context, arg *model.ArgResChannel, res *map[int64]*model.ResChannelCheckBack) (err error)

ResChannelCheckBack .

func (*RPC) ResTags

func (r *RPC) ResTags(c context.Context, arg *model.ArgResTags, res *map[int64][]*model.Tag) (err error)

ResTags returns resource tags by resource id .

func (*RPC) SubTags

func (r *RPC) SubTags(c context.Context, arg *model.ArgSub, res *model.Sub) (err error)

SubTags return the user subscribe tags.

func (*RPC) TagTop

func (r *RPC) TagTop(c context.Context, arg *model.ReqTagTop, res *model.TagTop) (err error)

TagTop web-interface tag top, include tag info, and similar tags.

func (*RPC) UpBind

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

UpBind .

func (*RPC) UpdateCustomSort

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

UpdateCustomSort update custome sort tags.