linear

Documentation

Overview

Package linear implements ClonedBuffer and SharedBuffer.

Index

• Constants
• type Buffer
  • func NewBuffer(linear []byte) (b *Buffer)
  • func (b *Buffer) BlockPopulated(index int)
  • func (b *Buffer) BlocksPopulated(index, count int)
  • func (b *Buffer) Bytes() []byte
  • func (b *Buffer) Close() (err error)
  • func (b *Buffer) Closed() <-chan struct{}
  • func (b *Buffer) Len() int
  • func (b *Buffer) PopulationFinished()
  • func (b *Buffer) ReadAt(target []byte, sourceOffset int64) (n int, err error)
  • func (b *Buffer) WriteAt(source []byte, targetOffset int64) (n int, err error)

Constants

const BlockSize = 131072

Types

type Buffer

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

func NewBuffer

func NewBuffer(linear []byte) (b *Buffer)

func (*Buffer) BlockPopulated

func (b *Buffer) BlockPopulated(index int)

BlockPopulated marks a 128 kB block as available for reading.

func (*Buffer) BlocksPopulated

func (b *Buffer) BlocksPopulated(index, count int)

BlocksPopulated marks adjacent 128 kB blocks as available for reading.

func (*Buffer) Bytes

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

func (*Buffer) Close

func (b *Buffer) Close() (err error)

func (*Buffer) Closed

func (b *Buffer) Closed() <-chan struct{}

func (*Buffer) Len

func (b *Buffer) Len() int

func (*Buffer) PopulationFinished

func (b *Buffer) PopulationFinished()

PopulationFinished indicates that no more blocks will become available, either because all have been populated, or due to cancellation or error.

func (*Buffer) ReadAt

func (b *Buffer) ReadAt(target []byte, sourceOffset int64) (n int, err error)

func (*Buffer) WriteAt

func (b *Buffer) WriteAt(source []byte, targetOffset int64) (n int, err error)