server

Documentation

Index

• func New(c *conf.Config, s *service.Service) (svr *rpc.Server)
• type RPC
  • func (r *RPC) AddGlobalFilter(c context.Context, a *model.ArgAddGlobalFilter, res *model.GlobalFilter) (err error)
  • func (r *RPC) AddUpFilters(c context.Context, a *model.ArgAddUpFilters, res *struct{}) (err error)
  • func (r *RPC) AddUserFilters(c context.Context, a *model.ArgAddUserFilters, res *[]*model.UserFilter) (err error)
  • func (r *RPC) AdvanceState(c context.Context, a *model.ArgAdvance, res *model.AdvState) (err error)
  • func (r *RPC) Advances(c context.Context, a *model.ArgMid, res *[]*model.Advance) (err error)
  • func (r *RPC) Auth(c context.Context, arg *rpc.Auth, res *struct{}) (err error)
  • func (r *RPC) BanUsers(c context.Context, a *model.ArgBanUsers, res *struct{}) (err error)
  • func (r *RPC) BuyAdvance(c context.Context, a *model.ArgAdvance, res *struct{}) (err error)
  • func (r *RPC) CancelAdvance(c context.Context, a *model.ArgUpAdvance, res *struct{}) (err error)
  • func (r *RPC) CancelBanUsers(c context.Context, a *model.ArgCancelBanUsers, res *struct{}) (err error)
  • func (r *RPC) DelGlobalFilters(c context.Context, a *model.ArgDelGlobalFilters, affect *int64) (err error)
  • func (r *RPC) DelUserFilters(c context.Context, a *model.ArgDelUserFilters, affect *int64) (err error)
  • func (r *RPC) DenyAdvance(c context.Context, a *model.ArgUpAdvance, res *struct{}) (err error)
  • func (r *RPC) EditDMAttr(c context.Context, a *model.ArgEditDMAttr, res *struct{}) (err error)
  • func (r *RPC) EditDMPool(c context.Context, a *model.ArgEditDMPool, res *struct{}) (err error)
  • func (r *RPC) EditDMState(c context.Context, a *model.ArgEditDMState, res *struct{}) (err error)
  • func (r *RPC) EditUpFilters(c context.Context, a *model.ArgEditUpFilters, res *int64) (err error)
  • func (r *RPC) GlobalFilters(c context.Context, a *model.ArgGlobalFilters, res *[]*model.GlobalFilter) (err error)
  • func (r *RPC) Mask(c context.Context, a *model.ArgMask, res *model.Mask) (err error)
  • func (r *RPC) PassAdvance(c context.Context, a *model.ArgUpAdvance, res *struct{}) (err error)
  • func (r *RPC) Ping(c context.Context, arg *struct{}, res *struct{}) (err error)
  • func (r *RPC) SubjectInfos(c context.Context, a *model.ArgOids, res *map[int64]*model.SubjectInfo) (err error)
  • func (r *RPC) SubtitleGet(c context.Context, arg *model.ArgSubtitleGet, res *model.VideoSubtitles) (err error)
  • func (r *RPC) SubtitleSubjectSubmitGet(c context.Context, arg *model.ArgArchiveID, res *model.SubtitleSubjectReply) (err error)
  • func (r *RPC) SubtitleSujectSubmit(c context.Context, arg *model.ArgSubtitleAllowSubmit, res *struct{}) (err error)
  • func (r *RPC) UpFilters(c context.Context, a *model.ArgUpFilters, res *[]*model.UpFilter) (err error)
  • func (r *RPC) UserFilters(c context.Context, a *model.ArgMid, res *[]*model.UserFilter) (err error)

Functions

func New

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

New new a rpc server.

Types

type RPC

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

RPC rpc server.

func (*RPC) AddGlobalFilter

func (r *RPC) AddGlobalFilter(c context.Context, a *model.ArgAddGlobalFilter, res *model.GlobalFilter) (err error)

AddGlobalFilter add global filters.

func (*RPC) AddUpFilters

func (r *RPC) AddUpFilters(c context.Context, a *model.ArgAddUpFilters, res *struct{}) (err error)

AddUpFilters add up filters.

func (*RPC) AddUserFilters

func (r *RPC) AddUserFilters(c context.Context, a *model.ArgAddUserFilters, res *[]*model.UserFilter) (err error)

AddUserFilters add user filter.

func (*RPC) AdvanceState

func (r *RPC) AdvanceState(c context.Context, a *model.ArgAdvance, res *model.AdvState) (err error)

AdvanceState 高级弹幕状态

func (*RPC) Advances

func (r *RPC) Advances(c context.Context, a *model.ArgMid, res *[]*model.Advance) (err error)

Advances 高级弹幕申请列表

func (*RPC) Auth

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

Auth check connection success.

func (*RPC) BanUsers

func (r *RPC) BanUsers(c context.Context, a *model.ArgBanUsers, res *struct{}) (err error)

BanUsers ban user by upper or assist.

func (*RPC) BuyAdvance

func (r *RPC) BuyAdvance(c context.Context, a *model.ArgAdvance, res *struct{}) (err error)

BuyAdvance 购买高级弹幕

func (*RPC) CancelAdvance

func (r *RPC) CancelAdvance(c context.Context, a *model.ArgUpAdvance, res *struct{}) (err error)

CancelAdvance 取消高级弹幕申请

func (*RPC) CancelBanUsers

func (r *RPC) CancelBanUsers(c context.Context, a *model.ArgCancelBanUsers, res *struct{}) (err error)

CancelBanUsers cancel users by upper or assiat.

func (*RPC) DelGlobalFilters

func (r *RPC) DelGlobalFilters(c context.Context, a *model.ArgDelGlobalFilters, affect *int64) (err error)

DelGlobalFilters delete global filter.

func (*RPC) DelUserFilters

func (r *RPC) DelUserFilters(c context.Context, a *model.ArgDelUserFilters, affect *int64) (err error)

DelUserFilters delete user filters by filter id.

func (*RPC) DenyAdvance

func (r *RPC) DenyAdvance(c context.Context, a *model.ArgUpAdvance, res *struct{}) (err error)

DenyAdvance 拒绝高级弹幕申请

func (*RPC) EditDMAttr

func (r *RPC) EditDMAttr(c context.Context, a *model.ArgEditDMAttr, res *struct{}) (err error)

EditDMAttr edit dm attr

func (*RPC) EditDMPool

func (r *RPC) EditDMPool(c context.Context, a *model.ArgEditDMPool, res *struct{}) (err error)

EditDMPool edit dm pool.

func (*RPC) EditDMState

func (r *RPC) EditDMState(c context.Context, a *model.ArgEditDMState, res *struct{}) (err error)

EditDMState edit dm state.

func (*RPC) EditUpFilters

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

EditUpFilters edit upper filters.

func (*RPC) GlobalFilters

func (r *RPC) GlobalFilters(c context.Context, a *model.ArgGlobalFilters, res *[]*model.GlobalFilter) (err error)

GlobalFilters multi get global filters.

func (*RPC) Mask

func (r *RPC) Mask(c context.Context, a *model.ArgMask, res *model.Mask) (err error)

Mask get web mask.

func (*RPC) PassAdvance

func (r *RPC) PassAdvance(c context.Context, a *model.ArgUpAdvance, res *struct{}) (err error)

PassAdvance 通过高级弹幕申请

func (*RPC) Ping

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

Ping checks connection success.

func (*RPC) SubjectInfos

func (r *RPC) SubjectInfos(c context.Context, a *model.ArgOids, res *map[int64]*model.SubjectInfo) (err error)

SubjectInfos multi get dm subject info by type and oids.

func (*RPC) SubtitleGet

func (r *RPC) SubtitleGet(c context.Context, arg *model.ArgSubtitleGet, res *model.VideoSubtitles) (err error)

SubtitleGet .

func (*RPC) SubtitleSubjectSubmitGet

func (r *RPC) SubtitleSubjectSubmitGet(c context.Context, arg *model.ArgArchiveID, res *model.SubtitleSubjectReply) (err error)

SubtitleSubjectSubmitGet get archive allow submit

func (*RPC) SubtitleSujectSubmit

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

SubtitleSujectSubmit set archive allow submit

func (*RPC) UpFilters

func (r *RPC) UpFilters(c context.Context, a *model.ArgUpFilters, res *[]*model.UpFilter) (err error)

UpFilters multi get up filters.

func (*RPC) UserFilters

func (r *RPC) UserFilters(c context.Context, a *model.ArgMid, res *[]*model.UserFilter) (err error)

UserFilters multi get user filters.