Versions in this module Expand all Collapse all v1 v1.4.0 Jan 2, 2024 Changes in this version + type Unbounded struct + func NewUnbounded() *Unbounded + func (b *Unbounded) Get() <-chan interface{} + func (b *Unbounded) Load() + func (b *Unbounded) Put(t interface{}) + type UnboundedMsg struct + func NewUUnboundedMsg() *UnboundedMsg + func (b *UnboundedMsg) Get() <-chan *meta.Message + func (b *UnboundedMsg) Load() + func (b *UnboundedMsg) Put(msg *meta.Message)
Go to main page