Categorygithub.com/Peakchen/go-zerocorequeue
package
0.0.0-20240201022239-0ae679bc1fb1
Repository: https://github.com/peakchen/go-zero.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
12
Dependents
0
Files
321 SLOC

# Functions

NewBalancedPusher returns a BalancedPusher.
NewMultiPusher returns a MultiPusher.
NewQueue returns a Queue.

# Variables

ErrNoAvailablePusher indicates no pusher available.

# Structs

A BalancedPusher is used to push messages to multiple pusher with round robin algorithm.
A MultiPusher is a pusher that can push messages to multiple underlying pushers.
No description provided by the author

# Interfaces

No description provided by the author
No description provided by the author
A MessageQueue interface represents a message queue.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Type aliases

No description provided by the author
No description provided by the author