Categorygithub.com/jialequ/linux-sdkcorequeue
package
0.0.0-20240422121023-d12999f4ab47
Repository: https://github.com/jialequ/linux-sdk.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