circbufsync

package

v0.11.4 Latest Latest Go to latest Published: Aug 9, 2023 License: MPL-2.0 Imports: 2 Imported by: 0

Details

Package circbufsync wraps armon/circbuf to be safe for concurrent read/write operations.

This section is empty.

This section is empty.

This section is empty.

type Buffer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Buffer implements a subset of the *circbuf.Buffer methods where each exposed method is safe for concurrent read/write access.

func New(buf *circbuf.Buffer) *Buffer

New creates a new synced circbuf.Buffer.

func (b *Buffer) Bytes() []byte

Bytes mimics circbuf.Buffer

func (b *Buffer) Write(p []byte) (int, error)

Bytes mimics circbuf.Write