redis_mq

type Consumer = *consumer

type ConsumerOption func(options *ConsumerOptions)

type ConsumerOptions struct {
	RateLimitPeriod time.Duration
	UseBLPop        bool
}

type Handler interface {
	HandleMessage(msg *Message)
}

type Message struct {
	ID        string `json:"id"`
	Body      []byte `json:"body"`
	Timestamp int64  `json:"timestamp"`
	DelayTime int64  `json:"delayTime"`
	// contains filtered or unexported fields
}

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