filewritecache

Documentation

Index

• Variables
• type FileWriteCache
  • func New() *FileWriteCache
  • func (wc *FileWriteCache) ContentLen() int64
  • func (wc *FileWriteCache) NeedsSync() bool
  • func (wc *FileWriteCache) PWrite(p []byte, offset int64) error
  • func (wc *FileWriteCache) ReadAtThrough(p []byte, offset int64, r ReadAter) (int, error)
  • func (wc *FileWriteCache) Right() int64
  • func (wc *FileWriteCache) Sync(bh blobstore.PWriter) error
  • func (wc *FileWriteCache) Truncate(size int64)
• type Patch
  • func NewPatch(offset int64, p []byte) Patch
  • func (p Patch) IsSentinel() bool
  • func (p Patch) Left() int64
  • func (p Patch) Right() int64
  • func (p Patch) String() string
• type Patches
  • func NewPatches() Patches
  • func (ps Patches) FindLRIndex(newp Patch) (int, int)
  • func (ps Patches) Merge(newp Patch) Patches
  • func (ps Patches) Replace(lefti, righti int, newps Patches) Patches
  • func (ps Patches) Reset() Patches
  • func (ps Patches) Truncate(size int64) Patches
• type ReadAter

Variables

var MaxPatchContentLen = 8 * 1024 * 1024

var MaxPatches = 32

Below may overwritten from tests

var PatchSentinel = Patch{Offset: math.MaxInt64}

Types

type FileWriteCache

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

func New

func New() *FileWriteCache

func (*FileWriteCache) ContentLen

func (wc *FileWriteCache) ContentLen() int64

func (*FileWriteCache) NeedsSync

func (wc *FileWriteCache) NeedsSync() bool

func (*FileWriteCache) PWrite

func (wc *FileWriteCache) PWrite(p []byte, offset int64) error

func (*FileWriteCache) ReadAtThrough

func (wc *FileWriteCache) ReadAtThrough(p []byte, offset int64, r ReadAter) (int, error)

func (*FileWriteCache) Right

func (wc *FileWriteCache) Right() int64

func (*FileWriteCache) Sync

func (wc *FileWriteCache) Sync(bh blobstore.PWriter) error

func (*FileWriteCache) Truncate

func (wc *FileWriteCache) Truncate(size int64)

type Patch

type Patch struct {
	Offset int64
	P      []byte
}

func NewPatch

func NewPatch(offset int64, p []byte) Patch

func (Patch) IsSentinel

func (p Patch) IsSentinel() bool

func (Patch) Left

func (p Patch) Left() int64

func (Patch) Right

func (p Patch) Right() int64

func (Patch) String

func (p Patch) String() string

type Patches

type Patches []Patch

func NewPatches

func NewPatches() Patches

func (Patches) FindLRIndex

func (ps Patches) FindLRIndex(newp Patch) (int, int)

func (Patches) Merge

func (ps Patches) Merge(newp Patch) Patches

func (Patches) Replace

func (ps Patches) Replace(lefti, righti int, newps Patches) Patches

func (Patches) Reset

func (ps Patches) Reset() Patches

func (Patches) Truncate

func (ps Patches) Truncate(size int64) Patches

type ReadAter

type ReadAter interface {
	ReadAt(p []byte, offset int64) (int, error)
}