buffer

type Config struct {
	Type   string                      `json:"type" yaml:"type"`
	Memory sequential.MemoryConfig     `json:"memory" yaml:"memory"`
	Mmap   sequential.MmapBufferConfig `json:"mmap_file" yaml:"mmap_file"`
	None   struct{}                    `json:"none" yaml:"none"`
}

type Empty struct {
	// contains filtered or unexported fields
}

type Sequential interface {
	// ShiftMessage removes the oldest message from the stack. Returns the
	// backlog in bytes.
	ShiftMessage() (int, error)

	// NextMessage reads the oldest message, the message is preserved until
	// ShiftMessage is called.
	NextMessage() (types.Message, error)

	// PushMessage adds a new message to the stack. Returns the backlog in
	// bytes.
	PushMessage(types.Message) (int, error)

	// CloseOnceEmpty closes the Buffer once the buffer has been emptied, this
	// is a way for a writer to signal to a reader that it is finished writing
	// messages, and therefore the reader can close once it is caught up. This
	// call blocks until the close is completed.
	CloseOnceEmpty()

	// Close closes the Buffer so that blocked readers or writers become
	// unblocked.
	Close()
}

type SequentialWrapper struct {
	// contains filtered or unexported fields
}

type Type interface {
	types.Producer
	types.Consumer
	types.Closable
}

type TypeSpec struct {
	// contains filtered or unexported fields
}