Documentation
¶
Overview ¶
Package storage provides the storage of the broker.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DelayStorage ¶
type DelayStorage interface {
// Produce produce a Message to DelayStorage
Produce(ctx context.Context, msg *types.Message) error
// Consume consume Messages from the queue
Consume(ctx context.Context, now uint64, batchSize int64, fn type2.HandleMessage) error
// Close the queue
Close() error
}
DelayStorage is a queue to store messages with delay time the message will be delivered to the realtime queue after the delay time
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package redis_storage implements a storage with redis.
|
Package redis_storage implements a storage with redis. |
Click to show internal directories.
Click to hide internal directories.