local

Documentation

Index

• Constants
• type BadgerLogger
  • func (l *BadgerLogger) Debug(_ ...interface{})
  • func (l *BadgerLogger) Debugf(_ string, _ ...interface{})
  • func (l *BadgerLogger) Info(_ ...interface{})
  • func (l *BadgerLogger) Infof(_ string, _ ...interface{})
• type Driver
  • func (d *Driver) Open(ctx context.Context, kvParams kvparams.KV) (kv.Store, error)
• type EntriesIterator
  • func (e *EntriesIterator) Close()
  • func (e *EntriesIterator) Entry() *kv.Entry
  • func (e *EntriesIterator) Err() error
  • func (e *EntriesIterator) Next() bool
• type Store
  • func (s *Store) Close()
  • func (s *Store) Delete(ctx context.Context, partitionKey, key []byte) error
  • func (s *Store) Get(ctx context.Context, partitionKey, key []byte) (*kv.ValueWithPredicate, error)
  • func (s *Store) Scan(ctx context.Context, partitionKey, start []byte) (kv.EntriesIterator, error)
  • func (s *Store) Set(ctx context.Context, partitionKey, key, value []byte) error
  • func (s *Store) SetIf(ctx context.Context, partitionKey, key, value []byte, ...) error

Constants

const (
	DriverName           = "local"
	DefaultDirectoryPath = "~/lakefs/metadata"
	DefaultPrefetchSize  = 256
)

Types

type BadgerLogger

type BadgerLogger struct {
	logging.Logger
}

func (*BadgerLogger) Debug

func (l *BadgerLogger) Debug(_ ...interface{})

func (*BadgerLogger) Debugf

func (l *BadgerLogger) Debugf(_ string, _ ...interface{})

func (*BadgerLogger) Info

func (l *BadgerLogger) Info(_ ...interface{})

func (*BadgerLogger) Infof

func (l *BadgerLogger) Infof(_ string, _ ...interface{})

type Driver

type Driver struct{}

func (*Driver) Open

func (d *Driver) Open(ctx context.Context, kvParams kvparams.KV) (kv.Store, error)

type EntriesIterator

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

func (*EntriesIterator) Close

func (e *EntriesIterator) Close()

func (*EntriesIterator) Entry

func (e *EntriesIterator) Entry() *kv.Entry

func (*EntriesIterator) Err

func (e *EntriesIterator) Err() error

func (*EntriesIterator) Next

func (e *EntriesIterator) Next() bool

type Store

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

func (*Store) Close

func (s *Store) Close()

func (*Store) Delete

func (s *Store) Delete(ctx context.Context, partitionKey, key []byte) error

func (*Store) Get

func (s *Store) Get(ctx context.Context, partitionKey, key []byte) (*kv.ValueWithPredicate, error)

func (*Store) Scan

func (s *Store) Scan(ctx context.Context, partitionKey, start []byte) (kv.EntriesIterator, error)

func (*Store) Set

func (s *Store) Set(ctx context.Context, partitionKey, key, value []byte) error

func (*Store) SetIf

func (s *Store) SetIf(ctx context.Context, partitionKey, key, value []byte, valuePredicate kv.Predicate) error