pool

Documentation

Index

• type Handler
• type HandlerFunc
  • func (hf HandlerFunc) Handle(val proto.Message) error
• type Hub
  • func NewHub(ctx context.Context, limit *LimitMux) *Hub
  • func (hub *Hub) Push(res proto.Message)
  • func (hub *Hub) SetHandler(handler Handler)
• type HubPool
  • func NewHubPool(ctx context.Context) *HubPool
  • func (hp *HubPool) AutoHub(key string) (hub *Hub, isNew bool)
  • func (hp *HubPool) GetHub(key string) *Hub
  • func (hp *HubPool) Remove(key string)
  • func (hp *HubPool) RemoveAll()
• type LimitMux
  • func (lm *LimitMux) Locked() bool
  • func (lm *LimitMux) Release()
  • func (lm *LimitMux) Retain() (ok bool)
• type ListMux
  • func NewListMux() *ListMux
  • func (lm *ListMux) Push(val proto.Message)
  • func (lm *ListMux) Shift() (val proto.Message)

Types

type Handler

type Handler interface {
	Handle(proto.Message) error
}

Handler Hub的处理接口

type HandlerFunc

type HandlerFunc func(proto.Message) error

HandlerFunc 函数形式的Handler

func (HandlerFunc) Handle

func (hf HandlerFunc) Handle(val proto.Message) error

Handle 实现Handler的必要接口

type Hub

type Hub struct {
	io.Closer
	// contains filtered or unexported fields
}

Hub 存储资源

func NewHub

func NewHub(ctx context.Context, limit *LimitMux) *Hub

NewHub 创建新的Hub

func (*Hub) Push

func (hub *Hub) Push(res proto.Message)

Push 将资源送入Hub

func (*Hub) SetHandler

func (hub *Hub) SetHandler(handler Handler)

SetHandler 设置handler

type HubPool

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

HubPool 客户端，每种类型的协议使用唯一的客户端

func NewHubPool

func NewHubPool(ctx context.Context) *HubPool

NewHubPool 新建一个HubPool

func (*HubPool) AutoHub

func (hp *HubPool) AutoHub(key string) (hub *Hub, isNew bool)

AutoHub 自动获取Hub，有则返回，无则创建 如果是新建了Hub，isNew将为true，需要外部设置Handler

func (*HubPool) GetHub

func (hp *HubPool) GetHub(key string) *Hub

GetHub 获取指定的Hub

func (*HubPool) Remove

func (hp *HubPool) Remove(key string)

Remove 删除指定Hub

func (*HubPool) RemoveAll

func (hp *HubPool) RemoveAll()

RemoveAll 移除所有hub 这个方法主要是希望将所有缓存的Hub执行一次Close

type LimitMux

type LimitMux struct {
	Max int //NOTE: 最大值
	// contains filtered or unexported fields
}

LimitMux 限制器，用于限制

func (*LimitMux) Locked

func (lm *LimitMux) Locked() bool

Locked 限制器是否出发

func (*LimitMux) Release

func (lm *LimitMux) Release()

Release 释放一个操作

func (*LimitMux) Retain

func (lm *LimitMux) Retain() (ok bool)

Retain 索引值+1

type ListMux

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

ListMux 线程安全list

func NewListMux

func NewListMux() *ListMux

NewListMux 创建一个ListMux

func (*ListMux) Push

func (lm *ListMux) Push(val proto.Message)

Push 将数据安全的送到list中

func (*ListMux) Shift

func (lm *ListMux) Shift() (val proto.Message)

Shift 取出最前面的数据