bleve: github.com/blevesearch/bleve/index/store/metrics Index | Files

package metrics

import "github.com/blevesearch/bleve/index/store/metrics"

Package metrics provides a bleve.store.KVStore implementation that wraps another, real KVStore implementation, and uses go-metrics to track runtime performance metrics.

Index

Package Files

batch.go iterator.go reader.go stats.go store.go util.go writer.go

Constants

const MaxErrors = 100
const Name = "metrics"

func New Uses

func New(mo store.MergeOperator, config map[string]interface{}) (store.KVStore, error)

func TimerMap Uses

func TimerMap(timer metrics.Timer) map[string]interface{}

func WriteTimerCSV Uses

func WriteTimerCSV(w io.Writer, timer metrics.Timer)

func WriteTimerCSVHeader Uses

func WriteTimerCSVHeader(w io.Writer, prefix string)

func WriteTimerJSON Uses

func WriteTimerJSON(w io.Writer, timer metrics.Timer)

type Batch Uses

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

func (*Batch) Close Uses

func (b *Batch) Close() error

func (*Batch) Delete Uses

func (b *Batch) Delete(key []byte)

func (*Batch) Merge Uses

func (b *Batch) Merge(key, val []byte)

func (*Batch) Reset Uses

func (b *Batch) Reset()

func (*Batch) Set Uses

func (b *Batch) Set(key, val []byte)

type Iterator Uses

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

func (*Iterator) Close Uses

func (i *Iterator) Close() error

func (*Iterator) Current Uses

func (i *Iterator) Current() ([]byte, []byte, bool)

func (*Iterator) Key Uses

func (i *Iterator) Key() []byte

func (*Iterator) Next Uses

func (i *Iterator) Next()

func (*Iterator) Seek Uses

func (i *Iterator) Seek(x []byte)

func (*Iterator) Valid Uses

func (i *Iterator) Valid() bool

func (*Iterator) Value Uses

func (i *Iterator) Value() []byte

type Reader Uses

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

func (*Reader) Close Uses

func (r *Reader) Close() error

func (*Reader) Get Uses

func (r *Reader) Get(key []byte) (v []byte, err error)

func (*Reader) MultiGet Uses

func (r *Reader) MultiGet(keys [][]byte) (vals [][]byte, err error)

func (*Reader) PrefixIterator Uses

func (r *Reader) PrefixIterator(prefix []byte) (i store.KVIterator)

func (*Reader) RangeIterator Uses

func (r *Reader) RangeIterator(start, end []byte) (i store.KVIterator)

type Store Uses

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

func (*Store) AddError Uses

func (s *Store) AddError(op string, err error, key []byte)

func (*Store) Close Uses

func (s *Store) Close() error

func (*Store) Reader Uses

func (s *Store) Reader() (store.KVReader, error)

func (*Store) Stats Uses

func (s *Store) Stats() json.Marshaler

func (*Store) StatsMap Uses

func (s *Store) StatsMap() map[string]interface{}

func (*Store) WriteCSV Uses

func (s *Store) WriteCSV(w io.Writer)

func (*Store) WriteCSVHeader Uses

func (s *Store) WriteCSVHeader(w io.Writer)

func (*Store) WriteJSON Uses

func (s *Store) WriteJSON(w io.Writer) (err error)

func (*Store) Writer Uses

func (s *Store) Writer() (store.KVWriter, error)

type StoreError Uses

type StoreError struct {
    Time string
    Op   string
    Err  string
    Key  string
}

type Writer Uses

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

func (*Writer) Close Uses

func (w *Writer) Close() error

func (*Writer) ExecuteBatch Uses

func (w *Writer) ExecuteBatch(b store.KVBatch) (err error)

func (*Writer) NewBatch Uses

func (w *Writer) NewBatch() store.KVBatch

func (*Writer) NewBatchEx Uses

func (w *Writer) NewBatchEx(options store.KVBatchOptions) ([]byte, store.KVBatch, error)

Package metrics imports 10 packages (graph) and is imported by 30 packages. Updated 2018-11-11. Refresh now. Tools for package owners.