server

Documentation

Index

• func New(c *conf.Config, s *service.Service) (svr *rpc.Server)
• type RPC
  • func (r *RPC) ArcCache2(c context.Context, a *archive.ArgCache2, res *struct{}) (err error)
  • func (r *RPC) ArcFieldCache2(c context.Context, a *archive.ArgFieldCache2, res *struct{}) (err error)
  • func (r *RPC) Archive3(c context.Context, a *archive.ArgAid2, res *api.Arc) (err error)
  • func (r *RPC) Archives3(c context.Context, a *archive.ArgAids2, res *map[int64]*api.Arc) (err error)
  • func (r *RPC) ArchivesWithPlayer(c context.Context, a *archive.ArgPlayer, ...) (err error)
  • func (r *RPC) Auth(c context.Context, arg *rpc.Auth, res *struct{}) (err error)
  • func (r *RPC) Click3(c context.Context, a *archive.ArgAid2, res *api.Click) (err error)
  • func (r *RPC) DelVideo2(c context.Context, a *archive.ArgVideo2, res *struct{}) (err error)
  • func (r *RPC) Description2(c context.Context, a *archive.ArgAid, reDes *string) (err error)
  • func (r *RPC) MaxAID(c context.Context, a *struct{}, res *int64) (err error)
  • func (r *RPC) Page3(c context.Context, a *archive.ArgAid2, res *[]*api.Page) (err error)
  • func (r *RPC) Ping(c context.Context, arg *struct{}, res *struct{}) (err error)
  • func (r *RPC) RankAllArcs3(c context.Context, a *archive.ArgRankAll2, res *archive.RankArchives3) (err error)
  • func (r *RPC) RankArcs3(c context.Context, a *archive.ArgRank2, res *archive.RankArchives3) (err error)
  • func (r *RPC) RankTopArcs3(c context.Context, a *archive.ArgRankTop2, res *[]*api.Arc) (err error)
  • func (r *RPC) RanksArcs3(c context.Context, a *archive.ArgRanks2, res *map[int16]*archive.RankArchives3) (err error)
  • func (r *RPC) RanksTopCount2(c context.Context, a *archive.ArgRankTopsCount2, res *map[int16]int) (err error)
  • func (r *RPC) Recommend3(c context.Context, a *archive.ArgAid2, res *[]*api.Arc) (err error)
  • func (r *RPC) SetStat2(c context.Context, a *api.Stat, res *struct{}) (err error)
  • func (r *RPC) Stat3(c context.Context, a *archive.ArgAid2, res *api.Stat) (err error)
  • func (r *RPC) Stats3(c context.Context, a *archive.ArgAids2, res *map[int64]*api.Stat) (err error)
  • func (r *RPC) Types2(c context.Context, a *struct{}, res *map[int16]*archive.ArcType) (err error)
  • func (r *RPC) UpArcs3(c context.Context, a *archive.ArgUpArcs2, res *[]*api.Arc) (err error)
  • func (r *RPC) UpCount2(c context.Context, a *archive.ArgUpCount2, count *int) (err error)
  • func (r *RPC) UpVideo2(c context.Context, a *archive.ArgVideo2, res *struct{}) (err error)
  • func (r *RPC) UpsArcs3(c context.Context, a *archive.ArgUpsArcs2, res *map[int64][]*api.Arc) (err error)
  • func (r *RPC) UpsPassed2(c context.Context, a *archive.ArgUpsArcs2, ...) (err error)
  • func (r *RPC) Video3(c context.Context, a *archive.ArgVideo2, res *api.Page) (err error)
  • func (r *RPC) Videoshot2(c context.Context, a *archive.ArgCid2, res *archive.Videoshot) (err error)
  • func (r *RPC) View3(c context.Context, a *archive.ArgAid2, av *archive.View3) (err error)
  • func (r *RPC) Views3(c context.Context, a *archive.ArgAids2, res *map[int64]*archive.View3) (err error)

Functions

func New

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

New new rpc server.

Types

type RPC

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

RPC rpc.

func (*RPC) ArcCache2

func (r *RPC) ArcCache2(c context.Context, a *archive.ArgCache2, res *struct{}) (err error)

ArcCache2 update archive cache.

func (*RPC) ArcFieldCache2

func (r *RPC) ArcFieldCache2(c context.Context, a *archive.ArgFieldCache2, res *struct{}) (err error)

ArcFieldCache2 update archive by field changed.

func (*RPC) Archive3

func (r *RPC) Archive3(c context.Context, a *archive.ArgAid2, res *api.Arc) (err error)

Archive3 receive aid, then init archive info.

func (*RPC) Archives3

func (r *RPC) Archives3(c context.Context, a *archive.ArgAids2, res *map[int64]*api.Arc) (err error)

Archives3 receive aids, then init archives info.

func (*RPC) ArchivesWithPlayer

func (r *RPC) ArchivesWithPlayer(c context.Context, a *archive.ArgPlayer, res *map[int64]*archive.ArchiveWithPlayer) (err error)

ArchivesWithPlayer archives with player info

func (*RPC) Auth

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

Auth check connection success.

func (*RPC) Click3

func (r *RPC) Click3(c context.Context, a *archive.ArgAid2, res *api.Click) (err error)

Click3 archive click.

func (*RPC) DelVideo2

func (r *RPC) DelVideo2(c context.Context, a *archive.ArgVideo2, res *struct{}) (err error)

DelVideo2 delete video by aid & cid.

func (*RPC) Description2

func (r *RPC) Description2(c context.Context, a *archive.ArgAid, reDes *string) (err error)

Description2 get description by aid.

func (*RPC) MaxAID

func (r *RPC) MaxAID(c context.Context, a *struct{}, res *int64) (err error)

MaxAID get max aid

func (*RPC) Page3

func (r *RPC) Page3(c context.Context, a *archive.ArgAid2, res *[]*api.Page) (err error)

Page3 get videos by aid

func (*RPC) Ping

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

Ping check connection success.

func (*RPC) RankAllArcs3

func (r *RPC) RankAllArcs3(c context.Context, a *archive.ArgRankAll2, res *archive.RankArchives3) (err error)

RankAllArcs3 left 7 days all Arcs

func (*RPC) RankArcs3

func (r *RPC) RankArcs3(c context.Context, a *archive.ArgRank2, res *archive.RankArchives3) (err error)

RankArcs3 Arcs by rid

func (*RPC) RankTopArcs3

func (r *RPC) RankTopArcs3(c context.Context, a *archive.ArgRankTop2, res *[]*api.Arc) (err error)

RankTopArcs3 Arcs by reids

func (*RPC) RanksArcs3

func (r *RPC) RanksArcs3(c context.Context, a *archive.ArgRanks2, res *map[int16]*archive.RankArchives3) (err error)

RanksArcs3 Arcs by rids

func (*RPC) RanksTopCount2

func (r *RPC) RanksTopCount2(c context.Context, a *archive.ArgRankTopsCount2, res *map[int16]int) (err error)

RanksTopCount2 top region count.

func (*RPC) Recommend3

func (r *RPC) Recommend3(c context.Context, a *archive.ArgAid2, res *[]*api.Arc) (err error)

Recommend3 from archive_recommend by aid

func (*RPC) SetStat2

func (r *RPC) SetStat2(c context.Context, a *api.Stat, res *struct{}) (err error)

SetStat2 set all stat cache(redis)

func (*RPC) Stat3

func (r *RPC) Stat3(c context.Context, a *archive.ArgAid2, res *api.Stat) (err error)

Stat3 archive stat.

func (*RPC) Stats3

func (r *RPC) Stats3(c context.Context, a *archive.ArgAids2, res *map[int64]*api.Stat) (err error)

Stats3 archive stats.

func (*RPC) Types2

func (r *RPC) Types2(c context.Context, a *struct{}, res *map[int16]*archive.ArcType) (err error)

Types2 get all types

func (*RPC) UpArcs3

func (r *RPC) UpArcs3(c context.Context, a *archive.ArgUpArcs2, res *[]*api.Arc) (err error)

UpArcs3 up archives.

func (*RPC) UpCount2

func (r *RPC) UpCount2(c context.Context, a *archive.ArgUpCount2, count *int) (err error)

UpCount2 up count.

func (*RPC) UpVideo2

func (r *RPC) UpVideo2(c context.Context, a *archive.ArgVideo2, res *struct{}) (err error)

UpVideo2 up video by aid & cid.

func (*RPC) UpsArcs3

func (r *RPC) UpsArcs3(c context.Context, a *archive.ArgUpsArcs2, res *map[int64][]*api.Arc) (err error)

UpsArcs3 ups archives.

func (*RPC) UpsPassed2

func (r *RPC) UpsPassed2(c context.Context, a *archive.ArgUpsArcs2, res *map[int64][]*archive.AidPubTime) (err error)

UpsPassed2 ups pass aid and ptime

func (*RPC) Video3

func (r *RPC) Video3(c context.Context, a *archive.ArgVideo2, res *api.Page) (err error)

Video3 get video by aid & cid.

func (*RPC) Videoshot2

func (r *RPC) Videoshot2(c context.Context, a *archive.ArgCid2, res *archive.Videoshot) (err error)

Videoshot2 get vidoshot info data.

func (*RPC) View3

func (r *RPC) View3(c context.Context, a *archive.ArgAid2, av *archive.View3) (err error)

View3 view archive.

func (*RPC) Views3

func (r *RPC) Views3(c context.Context, a *archive.ArgAids2, res *map[int64]*archive.View3) (err error)

Views3 view archive.