handler

Documentation

Index

• type HandlerHeap
  • func (hh HandlerHeap) Len() int
  • func (hh HandlerHeap) Less(i, j int) bool
  • func (hh *HandlerHeap) Pop() interface{}
  • func (hh *HandlerHeap) Push(x interface{})
  • func (hh HandlerHeap) Swap(i, j int)
  • func (hh *HandlerHeap) Update(jh *JobHanelder)
• type HandlerMgr
  • func NewHandlerMgr(sessionMgr interfaces.ISessionMgr) *HandlerMgr
  • func (hm *HandlerMgr) AddRouter(id uint32, router interfaces.RouterCallback)
  • func (hm *HandlerMgr) GetRouter(id uint32) interfaces.RouterCallback
  • func (hm *HandlerMgr) Pop() *JobHanelder
  • func (hm *HandlerMgr) Push(jh *JobHanelder)
  • func (hm *HandlerMgr) SendToHandler(request interfaces.IRequest)
  • func (hm *HandlerMgr) StartPool()
  • func (hm *HandlerMgr) StopPool()
  • func (hm *HandlerMgr) Update(jh *JobHanelder)
• type JobHanelder
  • func NewJobHandler() *JobHanelder
  • func (jh *JobHanelder) AddLoad()
  • func (jh *JobHanelder) GetLoad() uint32
  • func (jh *JobHanelder) InitLoad()
  • func (jh *JobHanelder) Start()
  • func (jh *JobHanelder) Stop()
  • func (jh *JobHanelder) SubLoad()
• type RouterMap

Types

type HandlerHeap

type HandlerHeap []*JobHanelder

func (HandlerHeap) Len

func (hh HandlerHeap) Len() int

func (HandlerHeap) Less

func (hh HandlerHeap) Less(i, j int) bool

func (*HandlerHeap) Pop

func (hh *HandlerHeap) Pop() interface{}

func (*HandlerHeap) Push

func (hh *HandlerHeap) Push(x interface{})

func (HandlerHeap) Swap

func (hh HandlerHeap) Swap(i, j int)

func (*HandlerHeap) Update

func (hh *HandlerHeap) Update(jh *JobHanelder)

type HandlerMgr

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

func NewHandlerMgr

func NewHandlerMgr(sessionMgr interfaces.ISessionMgr) *HandlerMgr

func (*HandlerMgr) AddRouter

func (hm *HandlerMgr) AddRouter(id uint32, router interfaces.RouterCallback)

func (*HandlerMgr) GetRouter

func (hm *HandlerMgr) GetRouter(id uint32) interfaces.RouterCallback

func (*HandlerMgr) Pop

func (hm *HandlerMgr) Pop() *JobHanelder

func (*HandlerMgr) Push

func (hm *HandlerMgr) Push(jh *JobHanelder)

func (*HandlerMgr) SendToHandler

func (hm *HandlerMgr) SendToHandler(request interfaces.IRequest)

func (*HandlerMgr) StartPool

func (hm *HandlerMgr) StartPool()

func (*HandlerMgr) StopPool

func (hm *HandlerMgr) StopPool()

func (*HandlerMgr) Update

func (hm *HandlerMgr) Update(jh *JobHanelder)

type JobHanelder

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

func NewJobHandler

func NewJobHandler() *JobHanelder

func (*JobHanelder) AddLoad

func (jh *JobHanelder) AddLoad()

func (*JobHanelder) GetLoad

func (jh *JobHanelder) GetLoad() uint32

func (*JobHanelder) InitLoad

func (jh *JobHanelder) InitLoad()

func (*JobHanelder) Start

func (jh *JobHanelder) Start()

func (*JobHanelder) Stop

func (jh *JobHanelder) Stop()

func (*JobHanelder) SubLoad

func (jh *JobHanelder) SubLoad()

type RouterMap

type RouterMap map[uint32]interfaces.RouterCallback