bolt

Documentation

Index

• Constants
• func NewPluginMetricsCollector(tickDuration time.Duration) *pluginMetricsCollector
• func WithNoSync(s *KVStore)
• type Bucket
  • func (b *Bucket) Cursor(opts ...kv.CursorHint) (kv.Cursor, error)
  • func (b *Bucket) Delete(key []byte) error
  • func (b *Bucket) ForwardCursor(seek []byte, opts ...kv.CursorOption) (kv.ForwardCursor, error)
  • func (b *Bucket) Get(key []byte) ([]byte, error)
  • func (b *Bucket) GetBatch(keys ...[]byte) ([][]byte, error)
  • func (b *Bucket) Put(key []byte, value []byte) error
• type Client
  • func NewClient(log *zap.Logger) *Client
  • func (c *Client) Close() error
  • func (c *Client) Collect(ch chan<- prometheus.Metric)
  • func (c *Client) DB() *bolt.DB
  • func (c *Client) Describe(ch chan<- *prometheus.Desc)
  • func (c *Client) ID() platform2.ID
  • func (c *Client) Open(ctx context.Context) error
• type Cursor
  • func (c *Cursor) Close() error
  • func (c *Cursor) Err() error
  • func (c *Cursor) First() ([]byte, []byte)
  • func (c *Cursor) Last() ([]byte, []byte)
  • func (c *Cursor) Next() (k []byte, v []byte)
  • func (c *Cursor) Prev() (k []byte, v []byte)
  • func (c *Cursor) Seek(prefix []byte) ([]byte, []byte)
• type KVOption
• type KVStore
  • func NewKVStore(log *zap.Logger, path string, opts ...KVOption) *KVStore
  • func (s *KVStore) Backup(ctx context.Context, w io.Writer) error
  • func (s *KVStore) Close() error
  • func (s *KVStore) CreateBucket(ctx context.Context, name []byte) error
  • func (s *KVStore) DB() *bolt.DB
  • func (s *KVStore) DeleteBucket(ctx context.Context, name []byte) error
  • func (s *KVStore) Flush(ctx context.Context)
  • func (s *KVStore) Open(ctx context.Context) error
  • func (s *KVStore) RLock()
  • func (s *KVStore) RUnlock()
  • func (s *KVStore) Restore(ctx context.Context, r io.Reader) error
  • func (s *KVStore) Update(ctx context.Context, fn func(tx kv.Tx) error) error
  • func (s *KVStore) View(ctx context.Context, fn func(tx kv.Tx) error) error
  • func (s *KVStore) WithDB(db *bolt.DB)
• type Tx
  • func (tx *Tx) Bucket(b []byte) (kv.Bucket, error)
  • func (tx *Tx) Context() context.Context
  • func (tx *Tx) WithContext(ctx context.Context)

Constants

const DefaultFilename = "influxd.bolt"

Functions

func NewPluginMetricsCollector

func NewPluginMetricsCollector(tickDuration time.Duration) *pluginMetricsCollector

func WithNoSync

func WithNoSync(s *KVStore)

WithNoSync WARNING: this is useful for tests only this skips fsyncing on every commit to improve write performance in exchange for no guarantees that the db will persist.

Types

type Bucket

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

Bucket implements kv.Bucket.

func (*Bucket) Cursor

func (b *Bucket) Cursor(opts ...kv.CursorHint) (kv.Cursor, error)

Cursor retrieves a cursor for iterating through the entries in the key value store.

func (*Bucket) Delete

func (b *Bucket) Delete(key []byte) error

Delete removes the provided key.

func (*Bucket) ForwardCursor

func (b *Bucket) ForwardCursor(seek []byte, opts ...kv.CursorOption) (kv.ForwardCursor, error)

ForwardCursor retrieves a cursor for iterating through the entries in the key value store in a given direction (ascending / descending).

func (*Bucket) Get

func (b *Bucket) Get(key []byte) ([]byte, error)

Get retrieves the value at the provided key.

func (*Bucket) GetBatch

func (b *Bucket) GetBatch(keys ...[]byte) ([][]byte, error)

GetBatch retrieves the values for the provided keys.

func (*Bucket) Put

func (b *Bucket) Put(key []byte, value []byte) error

Put sets the value at the provided key.

type Client

type Client struct {
	Path string

	IDGenerator    platform2.IDGenerator
	TokenGenerator platform.TokenGenerator
	platform.TimeGenerator
	// contains filtered or unexported fields
}

Client is a client for the boltDB data store.

func NewClient

func NewClient(log *zap.Logger) *Client

NewClient returns an instance of a Client.

func (*Client) Close

func (c *Client) Close() error

Close the connection to the bolt database

func (*Client) Collect

func (c *Client) Collect(ch chan<- prometheus.Metric)

Collect returns the current state of all metrics of the collector.

func (*Client) DB

func (c *Client) DB() *bolt.DB

DB returns the clients DB.

func (*Client) Describe

func (c *Client) Describe(ch chan<- *prometheus.Desc)

Describe returns all descriptions of the collector.

func (*Client) ID

func (c *Client) ID() platform2.ID

ID retrieves the unique ID for this influx instance.

func (*Client) Open

func (c *Client) Open(ctx context.Context) error

Open / create boltDB file.

type Cursor

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

Cursor is a struct for iterating through the entries in the key value store.

func (*Cursor) Close

func (c *Cursor) Close() error

Close sets the closed to closed

func (*Cursor) Err

func (c *Cursor) Err() error

Err always returns nil as nothing can go wrong™ during iteration

func (*Cursor) First

func (c *Cursor) First() ([]byte, []byte)

First retrieves the first key value pair in the bucket.

func (*Cursor) Last

func (c *Cursor) Last() ([]byte, []byte)

Last retrieves the last key value pair in the bucket.

func (*Cursor) Next

func (c *Cursor) Next() (k []byte, v []byte)

Next retrieves the next key in the bucket.

func (*Cursor) Prev

func (c *Cursor) Prev() (k []byte, v []byte)

Prev retrieves the previous key in the bucket.

func (*Cursor) Seek

func (c *Cursor) Seek(prefix []byte) ([]byte, []byte)

Seek seeks for the first key that matches the prefix provided.

type KVOption

type KVOption func(*KVStore)

type KVStore

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

KVStore is a kv.Store backed by boltdb.

func NewKVStore

func NewKVStore(log *zap.Logger, path string, opts ...KVOption) *KVStore

NewKVStore returns an instance of KVStore with the file at the provided path.

func (*KVStore) Backup

func (s *KVStore) Backup(ctx context.Context, w io.Writer) error

Backup copies all K:Vs to a writer, in BoltDB format.

func (*KVStore) Close

func (s *KVStore) Close() error

Close the connection to the bolt database

func (*KVStore) CreateBucket

func (s *KVStore) CreateBucket(ctx context.Context, name []byte) error

CreateBucket creates a bucket in the underlying boltdb store if it does not already exist

func (*KVStore) DB

func (s *KVStore) DB() *bolt.DB

DB returns a reference to the current Bolt database.

func (*KVStore) DeleteBucket

func (s *KVStore) DeleteBucket(ctx context.Context, name []byte) error

DeleteBucket creates a bucket in the underlying boltdb store if it does not already exist

func (*KVStore) Flush

func (s *KVStore) Flush(ctx context.Context)

Flush removes all bolt keys within each bucket.

func (*KVStore) Open

func (s *KVStore) Open(ctx context.Context) error

Open creates boltDB file it doesn't exists and opens it otherwise.

func (*KVStore) RLock

func (s *KVStore) RLock()

func (*KVStore) RUnlock

func (s *KVStore) RUnlock()

func (*KVStore) Restore

func (s *KVStore) Restore(ctx context.Context, r io.Reader) error

Restore replaces the underlying database with the data from r.

func (*KVStore) Update

func (s *KVStore) Update(ctx context.Context, fn func(tx kv.Tx) error) error

Update opens up an update transaction against the store.

func (*KVStore) View

func (s *KVStore) View(ctx context.Context, fn func(tx kv.Tx) error) error

View opens up a view transaction against the store.

func (*KVStore) WithDB

func (s *KVStore) WithDB(db *bolt.DB)

WithDB sets the boltdb on the store.

type Tx

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

Tx is a light wrapper around a boltdb transaction. It implements kv.Tx.

func (*Tx) Bucket

func (tx *Tx) Bucket(b []byte) (kv.Bucket, error)

Bucket retrieves the bucket named b.

func (*Tx) Context

func (tx *Tx) Context() context.Context

Context returns the context for the transaction.

func (*Tx) WithContext

func (tx *Tx) WithContext(ctx context.Context)

WithContext sets the context for the transaction.