y

package

v0.0.0-...-6882f9d Latest Latest Go to latest Published: May 16, 2017 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dolmen-go/badger

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func AssertTrue(b bool)
func AssertTruef(b bool, format string, args ...interface{})
func Check(err error)
func Check2(_ interface{}, err error)
func Check2f(_ interface{}, err error, format string, args ...interface{})
func Checkf(err error, format string, args ...interface{})
func Errorf(format string, args ...interface{}) error
func Fatalf(format string, args ...interface{})
func OpenSyncedFile(filename string, sync bool) (*os.File, error)
func Printf(format string, args ...interface{})
func Safecopy(a []byte, src []byte) []byte
func Wrap(err error) error
func Wrapf(err error, format string, args ...interface{}) error
type Closer
- func NewCloser() *Closer
- func (c *Closer) Get(name string) *LevelCloser
- func (c *Closer) Register(name string) *LevelCloser
- func (c *Closer) SignalAll()
- func (c *Closer) WaitForAll()
type Iterator
type LevelCloser
- func (lc *LevelCloser) Done()
- func (lc *LevelCloser) GotSignal() bool
- func (lc *LevelCloser) HasBeenClosed() <-chan struct{}
- func (lc *LevelCloser) NumRunning() int
- func (lc *LevelCloser) Signal()
- func (lc *LevelCloser) SignalAndWait()
- func (lc *LevelCloser) Wait()
type MergeIterator
- func NewMergeIterator(iters []Iterator, reversed bool) *MergeIterator
- func (s *MergeIterator) Close()
- func (s *MergeIterator) Key() []byte
- func (s *MergeIterator) Name() string
- 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
- func (s *Slice) Resize(sz int) []byte
type ValueStruct

Constants ¶

This section is empty.

Variables ¶

View Source

var EmptySlice = []byte{}

View Source

var VerboseMode = false

Functions ¶

func AssertTrue ¶

func AssertTrue(b bool)

AssertTrue asserts that b is true. Otherwise, it would log fatal.

func AssertTruef ¶

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

AssertTruef is AssertTrue with extra info.

func Check ¶

func Check(err error)

Check logs fatal if err != nil.

func Check2 ¶

func Check2(_ interface{}, err error)

Check2 acts as convenience wrapper around Check, using the 2nd argument as error.

func Check2f ¶

func Check2f(_ interface{}, err error, format string, args ...interface{})

Check2f acts as convenience wrapper around Checkf, using the 2nd argument as error.

func Checkf ¶

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

Checkf is Check with extra info.

func Errorf ¶

func Errorf(format string, args ...interface{}) error

Errorf creates a new error with stack trace, etc.

func Fatalf ¶

func Fatalf(format string, args ...interface{})

Fatalf logs fatal.

func OpenSyncedFile ¶

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

func Printf ¶

func Printf(format string, args ...interface{})

Printf printfs.

func Safecopy ¶

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

func Wrap ¶

func Wrap(err error) error

Wrap wraps errors from external lib.

func Wrapf ¶

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

Wrapf is Wrap with extra info.

Types ¶

type Closer ¶

type Closer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewCloser ¶

func NewCloser() *Closer

func (*Closer) Get ¶

func (c *Closer) Get(name string) *LevelCloser

func (*Closer) Register ¶

func (c *Closer) Register(name string) *LevelCloser

func (*Closer) SignalAll ¶

func (c *Closer) SignalAll()

func (*Closer) WaitForAll ¶

func (c *Closer) WaitForAll()

type Iterator ¶

type Iterator interface {
	Next()
	Rewind()
	Seek(key []byte)
	Key() []byte
	Value() ValueStruct
	Valid() bool
	Name() string // Mainly for debug or testing.

	// All iterators should be closed so that file garbage collection works.
	Close()
}

Iterator is an interface for a basic iterator.

type LevelCloser ¶

type LevelCloser struct {
	Name string
	// contains filtered or unexported fields
}

func (*LevelCloser) Done ¶

func (lc *LevelCloser) Done()

func (*LevelCloser) GotSignal ¶

func (lc *LevelCloser) GotSignal() bool

func (*LevelCloser) HasBeenClosed ¶

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

func (*LevelCloser) NumRunning ¶

func (lc *LevelCloser) NumRunning() int

func (*LevelCloser) Signal ¶

func (lc *LevelCloser) Signal()

func (*LevelCloser) SignalAndWait ¶

func (lc *LevelCloser) SignalAndWait()

func (*LevelCloser) Wait ¶

func (lc *LevelCloser) Wait()

type MergeIterator ¶

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

MergeIterator merges multiple iterators. NOTE: MergeIterator owns the array of iterators and is responsible for closing them.

func NewMergeIterator ¶

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

NewMergeIterator returns a new MergeIterator from a list of Iterators.

func (*MergeIterator) Close ¶

func (s *MergeIterator) Close()

func (*MergeIterator) Key ¶

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

func (*MergeIterator) Name ¶

func (s *MergeIterator) Name() string

func (*MergeIterator) Next ¶

func (s *MergeIterator) Next()

Next returns the next element. If it is the same as the current key, ignore it.

func (*MergeIterator) Rewind ¶

func (s *MergeIterator) Rewind()

Rewind seeks to first element (or last element for reverse iterator).

func (*MergeIterator) Seek ¶

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

Seek brings us to element with key >= given key.

func (*MergeIterator) Valid ¶

func (s *MergeIterator) Valid() bool

Valid returns whether the MergeIterator is at a valid element.

func (*MergeIterator) Value ¶

func (s *MergeIterator) Value() ValueStruct

type Slice ¶

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

func (*Slice) Resize ¶

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

type ValueStruct ¶

type ValueStruct struct {
	Value      []byte
	Meta       byte
	CASCounter uint16
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL