service

Documentation

Index

• Constants
• func Init(workerIp string, rpcPort int64)
• type IWorkerService
  • func NewWorkerService(rpcPort int64, workerId string, workerIp string) IWorkerService
• type WorkerConsumer
  • func (this *WorkerConsumer) ConsumerDelayMsg(req message.Request, res *message.Response) error

Constants

const (
	MAX_REQ_CNT    = 3
	MIN_DELAY_TIME = 100 //ms
)

Functions

func Init

func Init(workerIp string, rpcPort int64)

Types

type IWorkerService

type IWorkerService interface {
	Stop()
	// contains filtered or unexported methods
}

var WorkerService IWorkerService

func NewWorkerService

func NewWorkerService(rpcPort int64, workerId string, workerIp string) IWorkerService

type WorkerConsumer

type WorkerConsumer struct {
}

func (*WorkerConsumer) ConsumerDelayMsg

func (this *WorkerConsumer) ConsumerDelayMsg(req message.Request, res *message.Response) error

延时消息消费