package
18.0.0-dev.vnet-windows.4+incompatible
Repository: https://github.com/gravitational/teleport.git
Documentation: pkg.go.dev

# Functions

NewBuffer creates a new fanout buffer instance.

# Variables

ErrBufferClosed is an error indicating that the event buffer as a whole has been closed.
ErrGracePeriodExceeded is an error returned by Cursor.Read indicating that the cursor fell too far behind.
ErrUseOfClosedCursor is an error indicating that Cursor.Read was called after the cursor had either been explicitly closed, or had previously returned an error.

# Structs

Buffer is a circular buffer that keeps track of how many cursors exist, and how many have seen each item, so that it knows when items can be cleared.
Config holds all configuration parameters for the fanout buffer.
Cursor is a cursor into a fanout buffer.