chunks

Documentation

Index

• Variables
• type ChunkRange
• type Chunks
  • func (c *Chunks) CloseReader() error
  • func (c *Chunks) Flush() error
  • func (c *Chunks) GetChunkRanges() []ChunkRange
  • func (c *Chunks) GetLeftmostAbsentRange(min, max uint64) (l uint64, r uint64, err error)
  • func (c *Chunks) Open() error
  • func (c *Chunks) ReadNext() (uint64, []byte, error)
  • func (c *Chunks) SeekReader(pos uint64) error
  • func (c *Chunks) Write(pos uint64, payload []byte) error
• type ChunksInterface

Variables

var ErrNotFound = errors.New("not found")

Types

type ChunkRange

type ChunkRange struct {
	L, R uint64
}

type Chunks

type Chunks struct {
	Dir                string
	ChunkNamePrefix    string
	CompressionLevel   int
	MaxEntriesPerChunk int
	MaxChunkSize       int
	// contains filtered or unexported fields
}

func (*Chunks) CloseReader

func (c *Chunks) CloseReader() error

func (*Chunks) Flush

func (c *Chunks) Flush() error

func (*Chunks) GetChunkRanges

func (c *Chunks) GetChunkRanges() []ChunkRange

func (*Chunks) GetLeftmostAbsentRange

func (c *Chunks) GetLeftmostAbsentRange(min, max uint64) (l uint64, r uint64, err error)

func (*Chunks) Open

func (c *Chunks) Open() error

func (*Chunks) ReadNext

func (c *Chunks) ReadNext() (uint64, []byte, error)

func (*Chunks) SeekReader

func (c *Chunks) SeekReader(pos uint64) error

func (*Chunks) Write

func (c *Chunks) Write(pos uint64, payload []byte) error

type ChunksInterface

type ChunksInterface interface {
	Open() error
	GetLeftmostAbsentRange(min, max uint64) (l uint64, r uint64, err error)
	Flush() error
	Write(pos uint64, payload []byte) error
	CloseReader() error
	SeekReader(pos uint64) error
	ReadNext() (uint64, []byte, error)
	GetChunkRanges() []ChunkRange
}