y

Oct 13, 2020

Changes in this version

+ func FileSync(f *os.File) error

+ func FixedDuration(d time.Duration) string

+ type Throttle struct

+ func NewThrottle(max int) *Throttle

+ func (t *Throttle) Do() error

+ func (t *Throttle) Done(err error)

+ func (t *Throttle) Finish() error

type WaterMark

+ Name string

+ func (w *WaterMark) BeginMany(indices []uint64)

+ func (w *WaterMark) DoneMany(indices []uint64)

+ func (w *WaterMark) DoneUntil() uint64

+ func (w *WaterMark) LastIndex() uint64

+ func (w *WaterMark) SetDoneUntil(val uint64)

+ func (w *WaterMark) WaitForMark(ctx context.Context, index uint64) error

May 9, 2018

Changes in this version

+ type WaterMark struct

+ func (w *WaterMark) Begin(readTs uint64)

+ func (w *WaterMark) Done(readTs uint64)

+ func (w *WaterMark) Init()

+ func (w *WaterMark) MinReadTs() uint64

May 2, 2018

Changes in this version

+ const ReadOnly

+ const Sync

+ func OpenExistingFile(filename string, flags uint32) (*os.File, error)

Nov 13, 2017

Changes in this version

+ func SafeCopy(a []byte, src []byte) []byte

Nov 2, 2017

Changes in this version

type ValueStruct

+ ExpiresAt uint64

+ func (v *ValueStruct) EncodeTo(buf *bytes.Buffer)

Oct 31, 2017

Changes in this version

+ func CompareKeys(key1 []byte, key2 []byte) int

+ func Copy(a []byte) []byte

+ func KeyWithTs(key []byte, ts uint64) []byte

+ func ParseKey(key []byte) []byte

+ func ParseTs(key []byte) uint64

+ func SameKey(src, dst []byte) bool

type ValueStruct

+ Version uint64

+ func (v *ValueStruct) Decode(b []byte)

Oct 30, 2017

Changes in this version

+ const CasSize

+ const MetaSize

+ const UserMetaSize

+ var CastagnoliCrcTable = crc32.MakeTable(crc32.Castagnoli)

+ var ErrEOF = errors.New("End of mapped region")

+ var LSMSize *expvar.Map

+ var NumBlockedPuts *expvar.Int

+ var NumBytesRead *expvar.Int

+ var NumBytesWritten *expvar.Int

+ var NumGets *expvar.Int

+ var NumLSMBloomHits *expvar.Map

+ var NumLSMGets *expvar.Map

+ var NumMemtableGets *expvar.Int

+ var NumPuts *expvar.Int

+ var NumReads *expvar.Int

+ var NumWrites *expvar.Int

+ var PendingWrites *expvar.Map

+ var VlogSize *expvar.Map

+ func AssertTrue(b bool)

+ func AssertTruef(b bool, format string, args ...interface{})

+ func Check(err error)

+ func Check2(_ interface{}, err error)

+ func CreateSyncedFile(filename string, sync bool) (*os.File, error)

+ func Madvise(b []byte, readahead bool) error

+ func Mmap(fd *os.File, writable bool, size int64) ([]byte, error) — darwin/amd64, js/wasm, linux/amd64

+ func Mmap(fd *os.File, write bool, size int64) ([]byte, error) — windows/amd64

+ func Munmap(b []byte) error

+ func OpenExistingSyncedFile(filename string, sync bool) (*os.File, error)

+ func OpenSyncedFile(filename string, sync bool) (*os.File, error)

+ func OpenTruncFile(filename string, sync bool) (*os.File, error)

+ func Safecopy(a []byte, src []byte) []byte

+ func ValueStructSerializedSize(size uint16) int

+ func Wrap(err error) error

+ func Wrapf(err error, format string, args ...interface{}) error

+ type Closer struct

+ func NewCloser(initial int) *Closer

+ func (lc *Closer) AddRunning(delta int)

+ func (lc *Closer) Done()

+ func (lc *Closer) HasBeenClosed() <-chan struct{}

+ func (lc *Closer) Signal()

+ func (lc *Closer) SignalAndWait()

+ func (lc *Closer) Wait()

+ type Iterator interface

+ Close func() error

+ Key func() []byte

+ Next func()

+ Rewind func()

+ Seek func(key []byte)

+ Valid func() bool

+ Value func() ValueStruct

+ type MergeIterator struct

+ func NewMergeIterator(iters []Iterator, reversed bool) *MergeIterator

+ func (s *MergeIterator) Close() error

+ func (s *MergeIterator) Key() []byte

+ func (s *MergeIterator) Next()

+ func (s *MergeIterator) Rewind()

+ func (s *MergeIterator) Seek(key []byte)

+ func (s *MergeIterator) Valid() bool

+ func (s *MergeIterator) Value() ValueStruct

+ type Slice struct

+ func (s *Slice) Resize(sz int) []byte

+ type ValueStruct struct

+ CASCounter uint64

+ Meta byte

+ UserMeta byte

+ Value []byte

+ func MakeValueStruct(value []byte, meta byte, userMeta byte, casCounter uint64) ValueStruct

+ func (v *ValueStruct) DecodeEntireSlice(b []byte)

+ func (v *ValueStruct) Encode(b []byte)

+ func (v *ValueStruct) EncodedSize() int