package boltbk

import "github.com/gravitational/teleport/lib/backend/boltbk"

Package boltbk implements BoltDB backed backend for standalone instances This is a legacy backend which only exists for backward compatibility purposes

Production Teleport clusters should be using either etcd or DynamoDB backends.

Index ¶

• func Exists(path string) (bool, error)
• func GetBucket(b *bolt.Tx, buckets []string) (*bolt.Bucket, error)
• func GetName() string
• func New(params backend.Params) (backend.Backend, error)
• func UpsertBucket(b *bolt.Tx, buckets []string) (*bolt.Bucket, error)
• type BoltBackend
• func (b *BoltBackend) AcquireLock(token string, ttl time.Duration) error
• func (b *BoltBackend) Clock() clockwork.Clock
• func (b *BoltBackend) Close() error
• func (b *BoltBackend) CompareAndSwapVal(bucket []string, key string, newData []byte, prevData []byte, ttl time.Duration) error
• func (b *BoltBackend) CreateVal(bucket []string, key string, val []byte, ttl time.Duration) error
• func (b *BoltBackend) DeleteBucket(path []string, bucket string) error
• func (b *BoltBackend) DeleteKey(path []string, key string) error
• func (b *BoltBackend) GetItems(path []string, opts ...backend.OpOption) ([]backend.Item, error)
• func (b *BoltBackend) GetKeys(path []string, opts ...backend.OpOption) ([]string, error)
• func (b *BoltBackend) GetVal(path []string, key string) ([]byte, error)
• func (b *BoltBackend) ReleaseLock(token string) error
• func (bk *BoltBackend) UpsertItems(bucket []string, items []backend.Item) error
• func (b *BoltBackend) UpsertVal(path []string, key string, val []byte, ttl time.Duration) error

Functions ¶

func Exists ¶

func Exists(path string) (bool, error)

Exists returns true if backend has been used before

func GetBucket ¶

func GetBucket(b *bolt.Tx, buckets []string) (*bolt.Bucket, error)

func GetName ¶

func GetName() string

GetName() is a part of the backend API and returns the name of this backend as shown in 'storage/type' section of Teleport YAML config

func New ¶

func New(params backend.Params) (backend.Backend, error)

New initializes and returns a fully created BoltDB backend. It's a properly implemented Backend.NewFunc, part of a backend API

func UpsertBucket ¶

func UpsertBucket(b *bolt.Tx, buckets []string) (*bolt.Bucket, error)

Types ¶

type BoltBackend ¶

type BoltBackend struct {
	sync.Mutex
	// contains filtered or unexported fields
}

BoltBackend is a boltdb-based backend used in tests and standalone mode

func (*BoltBackend) AcquireLock ¶

func (b *BoltBackend) AcquireLock(token string, ttl time.Duration) error

func (*BoltBackend) Clock ¶

func (b *BoltBackend) Clock() clockwork.Clock

Clock returns clock assigned to the backend

func (*BoltBackend) Close ¶

func (b *BoltBackend) Close() error

Close closes the backend resources

func (*BoltBackend) CompareAndSwapVal ¶

func (b *BoltBackend) CompareAndSwapVal(bucket []string, key string, newData []byte, prevData []byte, ttl time.Duration) error

CompareAndSwapVal compares and swap values in atomic operation, succeeds if prevData matches the value stored in the databases, requires prevData as a non-empty value. Returns trace.CompareFailed in case if value did not match

func (*BoltBackend) CreateVal ¶

func (b *BoltBackend) CreateVal(bucket []string, key string, val []byte, ttl time.Duration) error

func (*BoltBackend) DeleteBucket ¶

func (b *BoltBackend) DeleteBucket(path []string, bucket string) error

func (*BoltBackend) DeleteKey ¶

func (b *BoltBackend) DeleteKey(path []string, key string) error

func (*BoltBackend) GetItems ¶

func (b *BoltBackend) GetItems(path []string, opts ...backend.OpOption) ([]backend.Item, error)

GetItems fetches keys and values and returns them to the caller.

func (*BoltBackend) GetKeys ¶

func (b *BoltBackend) GetKeys(path []string, opts ...backend.OpOption) ([]string, error)

func (*BoltBackend) GetVal ¶

func (b *BoltBackend) GetVal(path []string, key string) ([]byte, error)

func (*BoltBackend) ReleaseLock ¶

func (b *BoltBackend) ReleaseLock(token string) error

func (*BoltBackend) UpsertItems ¶

func (bk *BoltBackend) UpsertItems(bucket []string, items []backend.Item) error

func (*BoltBackend) UpsertVal ¶

func (b *BoltBackend) UpsertVal(path []string, key string, val []byte, ttl time.Duration) error

Source Files ¶

boltbk.go doc.go