Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBroadcastRedisQueue ¶
Types ¶
type BroadcastRedisQueue ¶
type BroadcastRedisQueue struct {
// contains filtered or unexported fields
}
func (*BroadcastRedisQueue) Close ¶
func (r *BroadcastRedisQueue) Close() error
func (*BroadcastRedisQueue) Get ¶
func (r *BroadcastRedisQueue) Get(ctx context.Context) ([]byte, error)
func (*BroadcastRedisQueue) Len ¶
func (r *BroadcastRedisQueue) Len() int
type FifoRedisQueue ¶
type FifoRedisQueue struct {
// contains filtered or unexported fields
}
func (*FifoRedisQueue) Close ¶
func (r *FifoRedisQueue) Close() error
func (*FifoRedisQueue) Len ¶
func (r *FifoRedisQueue) Len() int
Click to show internal directories.
Click to hide internal directories.