circbufsync

Documentation

Overview

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

Index

• type Buffer
  • func New(buf *circbuf.Buffer) *Buffer
  • func (b *Buffer) Bytes() []byte
  • func (b *Buffer) Write(p []byte) (int, error)

Types

type Buffer

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

func New(buf *circbuf.Buffer) *Buffer

New creates a new synced circbuf.Buffer.

func (*Buffer) Bytes

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

Bytes mimics circbuf.Buffer

func (*Buffer) Write

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

Bytes mimics circbuf.Write