Versions in this module Expand all Collapse all v1 v1.0.1 Aug 24, 2020 Changes in this version + const MAX_REQ_CNT + const MIN_DELAY_TIME + func Init(workerIp string, rpcPort int64) + type IWorkerService interface + Stop func() + var WorkerService IWorkerService + func NewWorkerService(rpcPort int64, workerId string, workerIp string) IWorkerService + type WorkerConsumer struct + func (this *WorkerConsumer) ConsumerDelayMsg(req message.Request, res *message.Response) error
Go to main page