Documentation
¶
Overview ¶
Package buffer provides an implementation of an unbounded buffer.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Unbounded ¶
type Unbounded struct {
// contains filtered or unexported fields
}
Unbounded is an implementation of an unbounded buffer which does not use extra goroutines. This is typically used for passing updates from one entity to another within gRPC.
All methods on this type are thread-safe and don't block on anything except the underlying mutex used for synchronization.
Unbounded supports values of any type to be stored in it by using a channel of `any`. This means that a call to Put() incurs an extra memory allocation, and also that users need a type assertion while reading. For performance critical code paths, using Unbounded is strongly discouraged and defining a new type specific implementation of this buffer is preferred. See internal/transport/transport.go for an example of this.
func NewUnbounded ¶
func NewUnbounded() *Unbounded
NewUnbounded returns a new instance of Unbounded.
func (*Unbounded) Close ¶ added in v1.56.0
func (b *Unbounded) Close()
Close closes the unbounded buffer. No subsequent data may be Put(), and the channel returned from Get() will be closed after all the data is read and Load() is called for the final time.
func (*Unbounded) Get ¶
Get returns a read channel on which values added to the buffer, via Put(), are sent on.
Upon reading a value from this channel, users are expected to call Load() to send the next buffered value onto the channel if there is any.
If the unbounded buffer is closed, the read channel returned by this method is closed after all data is drained.
Source Files