huya

Documentation

Index

• Constants
• Variables
• func HuyaPath(path string) string
• func NewExtraKey() *extraKey
• func NewKeySet() *keySet
• type Concern
  • func NewConcern(notify chan<- concern.Notify) *Concern
  • func (c *Concern) Add(groupCode int64, id interface{}, ctype concern.Type) (*LiveInfo, error)
  • func (k Concern) CurrentLiveKey(keys ...interface{}) string
  • func (c *Concern) FindOrLoadRoom(roomId string) (*LiveInfo, error)
  • func (c *Concern) FindRoom(roomId string, load bool) (*LiveInfo, error)
  • func (c *Concern) ListWatching(groupCode int64, ctype concern.Type) ([]*LiveInfo, []concern.Type, error)
  • func (c *Concern) Start()
  • func (c *Concern) Stop()
• type ConcernEvent
• type ConcernLiveNotify
  • func NewConcernLiveNotify(groupCode int64, l *LiveInfo) *ConcernLiveNotify
  • func (notify *ConcernLiveNotify) GetGroupCode() int64
  • func (notify *ConcernLiveNotify) GetUid() interface{}
  • func (notify *ConcernLiveNotify) Logger() *logrus.Entry
  • func (notify *ConcernLiveNotify) ToMessage() []message.IMessageElement
  • func (notify *ConcernLiveNotify) Type() concern.Type
• type EventType
• type GroupConcernConfig
  • func NewGroupConcernConfig(g *concern_manager.GroupConcernConfig) *GroupConcernConfig
  • func (g *GroupConcernConfig) AtBeforeHook(notify concern.Notify) (hook *concern_manager.HookResult)
  • func (g *GroupConcernConfig) ShouldSendHook(notify concern.Notify) (hook *concern_manager.HookResult)
• type LiveInfo
  • func RoomPage(roomId string) (*LiveInfo, error)
  • func (m *LiveInfo) GetName() string
  • func (m *LiveInfo) Logger() *logrus.Entry
  • func (m *LiveInfo) ToString() string
  • func (m *LiveInfo) Type() EventType
• type StateManager
  • func NewStateManager() *StateManager
  • func (c *StateManager) AddLiveInfo(liveInfo *LiveInfo) error
  • func (k StateManager) CurrentLiveKey(keys ...interface{}) string
  • func (c *StateManager) GetLiveInfo(id string) (*LiveInfo, error)
  • func (c *StateManager) Start() error

Constants

const (
	Site = "huya"
	Host = "https://www.huya.com"
)

Variables

var (
	ErrRoomNotExist = errors.New("房间不存在")
	ErrRoomBanned   = errors.New("涉嫌违规，正在整改中")
)

Functions

func HuyaPath

func HuyaPath(path string) string

func NewExtraKey

func NewExtraKey() *extraKey

func NewKeySet

func NewKeySet() *keySet

Types

type Concern

type Concern struct {
	*StateManager
	// contains filtered or unexported fields
}

func NewConcern

func NewConcern(notify chan<- concern.Notify) *Concern

func (*Concern) Add

func (c *Concern) Add(groupCode int64, id interface{}, ctype concern.Type) (*LiveInfo, error)

func (Concern) CurrentLiveKey

func (k Concern) CurrentLiveKey(keys ...interface{}) string

func (*Concern) FindOrLoadRoom

func (c *Concern) FindOrLoadRoom(roomId string) (*LiveInfo, error)

func (*Concern) FindRoom

func (c *Concern) FindRoom(roomId string, load bool) (*LiveInfo, error)

func (*Concern) ListWatching

func (c *Concern) ListWatching(groupCode int64, ctype concern.Type) ([]*LiveInfo, []concern.Type, error)

func (*Concern) Start

func (c *Concern) Start()

func (*Concern) Stop

func (c *Concern) Stop()

type ConcernEvent

type ConcernEvent interface {
	Type() EventType
}

type ConcernLiveNotify

type ConcernLiveNotify struct {
	LiveInfo
	GroupCode int64 `json:"group_code"`
}

func NewConcernLiveNotify

func NewConcernLiveNotify(groupCode int64, l *LiveInfo) *ConcernLiveNotify

func (*ConcernLiveNotify) GetGroupCode

func (notify *ConcernLiveNotify) GetGroupCode() int64

func (*ConcernLiveNotify) GetUid

func (notify *ConcernLiveNotify) GetUid() interface{}

func (*ConcernLiveNotify) Logger

func (notify *ConcernLiveNotify) Logger() *logrus.Entry

func (*ConcernLiveNotify) ToMessage

func (notify *ConcernLiveNotify) ToMessage() []message.IMessageElement

func (*ConcernLiveNotify) Type

func (notify *ConcernLiveNotify) Type() concern.Type

type EventType

type EventType int64

const (
	Live EventType = iota
)

type GroupConcernConfig

type GroupConcernConfig struct {
	concern_manager.GroupConcernConfig
}

func NewGroupConcernConfig

func NewGroupConcernConfig(g *concern_manager.GroupConcernConfig) *GroupConcernConfig

func (*GroupConcernConfig) AtBeforeHook

func (g *GroupConcernConfig) AtBeforeHook(notify concern.Notify) (hook *concern_manager.HookResult)

func (*GroupConcernConfig) ShouldSendHook

func (g *GroupConcernConfig) ShouldSendHook(notify concern.Notify) (hook *concern_manager.HookResult)

type LiveInfo

type LiveInfo struct {
	RoomId   string `json:"room_id"`
	RoomUrl  string `json:"room_url"`
	Avatar   string `json:"avatar"`
	Name     string `json:"name"`
	RoomName string `json:"room_name"`
	Living   bool   `json:"living"`

	LiveStatusChanged bool `json:"-"`
	LiveTitleChanged  bool `json:"-"`
}

func RoomPage

func RoomPage(roomId string) (*LiveInfo, error)

func (*LiveInfo) GetName

func (m *LiveInfo) GetName() string

func (*LiveInfo) Logger

func (m *LiveInfo) Logger() *logrus.Entry

func (*LiveInfo) ToString

func (m *LiveInfo) ToString() string

func (*LiveInfo) Type

func (m *LiveInfo) Type() EventType

type StateManager

type StateManager struct {
	*concern_manager.StateManager
	// contains filtered or unexported fields
}

func NewStateManager

func NewStateManager() *StateManager

func (*StateManager) AddLiveInfo

func (c *StateManager) AddLiveInfo(liveInfo *LiveInfo) error

func (StateManager) CurrentLiveKey

func (k StateManager) CurrentLiveKey(keys ...interface{}) string

func (*StateManager) GetLiveInfo

func (c *StateManager) GetLiveInfo(id string) (*LiveInfo, error)

func (*StateManager) Start

func (c *StateManager) Start() error