backlog

Documentation

Index

• Constants
• Variables
• type Backlog
  • func New() *Backlog
  • func NewFileBacklog(fileSize int, f *os.File) *Backlog
  • func NewSize(buffSize int) *Backlog
  • func (bl *Backlog) Close() error
  • func (bl *Backlog) CloseWithError(err error) error
  • func (bl *Backlog) DataRange() (rpos, wpos uint64, err error)
  • func (bl *Backlog) NewReader() (*Reader, error)
  • func (bl *Backlog) ReadAt(b []byte, offset uint64) (int, error)
  • func (bl *Backlog) Write(b []byte) (int, error)
• type Reader
  • func (r *Reader) DataRange() (rpos, wpos uint64, err error)
  • func (r *Reader) IsValid() bool
  • func (r *Reader) Offset() uint64
  • func (r *Reader) Read(b []byte) (int, error)
  • func (r *Reader) SeekTo(seek uint64) bool

Constants

const (
	BuffSizeAlign = 1024 * 4
)

const (
	FileSizeAlign = 1024 * 1024 * 4
)

Variables

var (
	ErrClosedBacklog = errors.New("closed backlog")
	ErrInvalidOffset = errors.New("invalid offset")
)

Types

type Backlog

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

func New

func New() *Backlog

func NewFileBacklog

func NewFileBacklog(fileSize int, f *os.File) *Backlog

func NewSize

func NewSize(buffSize int) *Backlog

func (*Backlog) Close

func (bl *Backlog) Close() error

func (*Backlog) CloseWithError

func (bl *Backlog) CloseWithError(err error) error

func (*Backlog) DataRange

func (bl *Backlog) DataRange() (rpos, wpos uint64, err error)

func (*Backlog) NewReader

func (bl *Backlog) NewReader() (*Reader, error)

func (*Backlog) ReadAt

func (bl *Backlog) ReadAt(b []byte, offset uint64) (int, error)

func (*Backlog) Write

func (bl *Backlog) Write(b []byte) (int, error)

type Reader

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

func (*Reader) DataRange

func (r *Reader) DataRange() (rpos, wpos uint64, err error)

func (*Reader) IsValid

func (r *Reader) IsValid() bool

func (*Reader) Offset

func (r *Reader) Offset() uint64

func (*Reader) Read

func (r *Reader) Read(b []byte) (int, error)

func (*Reader) SeekTo

func (r *Reader) SeekTo(seek uint64) bool