wsrepository

Documentation

Index

• type Rep
  • func NewRep(svcCtx *wssvc.ServiceContext) *Rep
  • func (r *Rep) AddUserConn(uid string, platform string) error
  • func (r *Rep) DelUserConn(ctx context.Context, uid string, platform string) error
  • func (r *Rep) GetUserConn(ctx context.Context, uid string) (map[string]string, error)

Types

type Rep

type Rep struct {
	Redis              *redis.Redis
	SendMsgPeriodLimit *limit.PeriodLimit
	// contains filtered or unexported fields
}

func NewRep

func NewRep(svcCtx *wssvc.ServiceContext) *Rep

func (*Rep) AddUserConn

func (r *Rep) AddUserConn(uid string, platform string) error

func (*Rep) DelUserConn

func (r *Rep) DelUserConn(ctx context.Context, uid string, platform string) error

func (*Rep) GetUserConn

func (r *Rep) GetUserConn(ctx context.Context, uid string) (map[string]string, error)