Documentation ¶
Index ¶
Constants ¶
View Source
const ( PrefixQueue = "jobq" PrefixRecovery = "jobc" )
Variables ¶
This section is empty.
Functions ¶
func GetMachineId ¶
func RecoveryHandle ¶
Types ¶
type Server ¶
type Server struct { ErrChan chan error // contains filtered or unexported fields }
func (*Server) TransportMsg ¶
type WorkerPool ¶
type WorkerPool struct {
// contains filtered or unexported fields
}
func NewWorkerPool ¶
func NewWorkerPool(num, qsize, interval int) *WorkerPool
func (*WorkerPool) InitRecoveryAll ¶
func (p *WorkerPool) InitRecoveryAll(cache *cache.CacheData) error
func (*WorkerPool) Run ¶
func (p *WorkerPool) Run(cache *cache.CacheData, cp *kafka.ClientPool)
func (*WorkerPool) Stop ¶
func (p *WorkerPool) Stop()
Click to show internal directories.
Click to hide internal directories.