Documentation ¶ Overview ¶ Package pubsubstream owns bounded, loss-reporting adapter delivery queues. Index ¶ type Buffer func New(limits pubsub.Limits) (*Buffer, error) func (b *Buffer) Done() <-chan struct{} func (b *Buffer) Err() error func (b *Buffer) Finish(err error) func (b *Buffer) Next(ctx context.Context) (pubsub.Message, error) func (b *Buffer) Push(message pubsub.Message) error Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Buffer ¶ type Buffer struct { // contains filtered or unexported fields } Buffer stores owned message snapshots and never silently evicts queued payloads. Finish is terminal and discards pending data; callers can observe the loss error. func New ¶ func New(limits pubsub.Limits) (*Buffer, error) func (*Buffer) Done ¶ func (b *Buffer) Done() <-chan struct{} func (*Buffer) Err ¶ func (b *Buffer) Err() error func (*Buffer) Finish ¶ func (b *Buffer) Finish(err error) func (*Buffer) Next ¶ func (b *Buffer) Next(ctx context.Context) (pubsub.Message, error) func (*Buffer) Push ¶ func (b *Buffer) Push(message pubsub.Message) error Source Files ¶ View all Source files buffer.go Click to show internal directories. Click to hide internal directories.
Documentation
¶
Source Files