Documentation
¶
Index ¶
- type MessagePool
- func (p *MessagePool) Contains(cp func(interface{}) bool) bool
- func (p *MessagePool) Obtain(num int, cp func(interface{}) bool, duration time.Duration) []interface{}
- func (p *MessagePool) ObtainOne(cp func(interface{}) bool, duration time.Duration) interface{}
- func (p *MessagePool) Push(msg interface{})
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessagePool ¶
type MessagePool struct {
// contains filtered or unexported fields
}
func New ¶
func New() *MessagePool
func (*MessagePool) Contains ¶
func (p *MessagePool) Contains(cp func(interface{}) bool) bool
func (*MessagePool) Obtain ¶
func (p *MessagePool) Obtain(num int, cp func(interface{}) bool, duration time.Duration) []interface{}
func (*MessagePool) ObtainOne ¶
func (p *MessagePool) ObtainOne(cp func(interface{}) bool, duration time.Duration) interface{}
func (*MessagePool) Push ¶
func (p *MessagePool) Push(msg interface{})
Source Files
Click to show internal directories.
Click to hide internal directories.