Versions in this module Expand all Collapse all v1 v1.7.1 Jan 29, 2021 v1.7.0 Dec 8, 2020 Changes in this version + const ReadOnly + const Sync + var CastagnoliCrcTable = crc32.MakeTable(crc32.Castagnoli) + var ErrEOF = errors.New("End of mapped region") + var LSMSize *expvar.Map + var NoEventLog trace.EventLog = nilEventLog + 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 CompareKeys(key1, key2 []byte) int + func Copy(a []byte) []byte + func CreateSyncedFile(filename string, sync bool) (*os.File, error) + func FileSync(f *os.File) error + func FixedDuration(d time.Duration) string + func KeyWithTs(key []byte, ts uint64) []byte + func Madvise(b []byte, readahead bool) error + func Mmap(fd *os.File, writable bool, size int64) ([]byte, error) + func Munmap(b []byte) error + func OpenExistingFile(filename string, flags uint32) (*os.File, error) + func OpenSyncedFile(filename string, sync bool) (*os.File, error) + func OpenTruncFile(filename string, sync bool) (*os.File, error) + func ParseKey(key []byte) []byte + func ParseTs(key []byte) uint64 + func SafeCopy(a, src []byte) []byte + func SameKey(src, dst []byte) bool + 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 Slice struct + func (s *Slice) Resize(sz int) []byte + 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 ValueStruct struct + ExpiresAt uint64 + Meta byte + UserMeta byte + Value []byte + Version uint64 + func (v *ValueStruct) Decode(b []byte) + func (v *ValueStruct) Encode(b []byte) + func (v *ValueStruct) EncodeTo(buf *bytes.Buffer) + func (v *ValueStruct) EncodedSize() uint16 + type WaterMark struct + Name string + func (w *WaterMark) Begin(index uint64) + func (w *WaterMark) BeginMany(indices []uint64) + func (w *WaterMark) Done(index uint64) + func (w *WaterMark) DoneMany(indices []uint64) + func (w *WaterMark) DoneUntil() uint64 + func (w *WaterMark) Init(closer *Closer, eventLogging bool) + func (w *WaterMark) LastIndex() uint64 + func (w *WaterMark) SetDoneUntil(val uint64) + func (w *WaterMark) WaitForMark(ctx context.Context, index uint64) error