staging

Documentation

Index

• type DBIterator
  • func NewDBStagingIterator(ctx context.Context, db db.Database, log logging.Logger, ...) *DBIterator
  • func (s *DBIterator) Close()
  • func (s *DBIterator) Err() error
  • func (s *DBIterator) Next() bool
  • func (s *DBIterator) SeekGE(key graveler.Key)
  • func (s *DBIterator) Value() *graveler.ValueRecord
• type DBManager
  • func NewDBManager(db db.Database) *DBManager
  • func (p *DBManager) Drop(ctx context.Context, st graveler.StagingToken) error
  • func (p *DBManager) DropAsync(ctx context.Context, st graveler.StagingToken) error
  • func (p *DBManager) DropByPrefix(ctx context.Context, st graveler.StagingToken, prefix graveler.Key) error
  • func (p *DBManager) DropKey(ctx context.Context, st graveler.StagingToken, key graveler.Key) error
  • func (p *DBManager) Get(ctx context.Context, st graveler.StagingToken, key graveler.Key) (*graveler.Value, error)
  • func (p *DBManager) List(ctx context.Context, st graveler.StagingToken, batchSize int) (graveler.ValueIterator, error)
  • func (p *DBManager) Set(ctx context.Context, st graveler.StagingToken, key graveler.Key, ...) error
  • func (p *DBManager) Update(_ context.Context, _ graveler.StagingToken, _ graveler.Key, ...) error
• type Iterator
  • func NewStagingIterator(ctx context.Context, store kv.StoreMessage, st graveler.StagingToken) (*Iterator, error)
  • func (s *Iterator) Close()
  • func (s *Iterator) Err() error
  • func (s *Iterator) Next() bool
  • func (s *Iterator) SeekGE(key graveler.Key)
  • func (s *Iterator) Value() *graveler.ValueRecord
• type Manager
  • func NewManager(ctx context.Context, store kv.StoreMessage) *Manager
  • func (m *Manager) Drop(ctx context.Context, st graveler.StagingToken) error
  • func (m *Manager) DropAsync(ctx context.Context, st graveler.StagingToken) error
  • func (m *Manager) DropByPrefix(ctx context.Context, st graveler.StagingToken, prefix graveler.Key) error
  • func (m *Manager) DropKey(ctx context.Context, st graveler.StagingToken, key graveler.Key) error
  • func (m *Manager) Get(ctx context.Context, st graveler.StagingToken, key graveler.Key) (*graveler.Value, error)
  • func (m *Manager) List(ctx context.Context, st graveler.StagingToken, _ int) (graveler.ValueIterator, error)
  • func (m *Manager) OnCleanup(cleanupCallback func())
  • func (m *Manager) Set(ctx context.Context, st graveler.StagingToken, key graveler.Key, ...) error
  • func (m *Manager) Update(ctx context.Context, st graveler.StagingToken, key graveler.Key, ...) error

Types

type DBIterator

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

func NewDBStagingIterator

func NewDBStagingIterator(ctx context.Context, db db.Database, log logging.Logger, st graveler.StagingToken, batchSize int) *DBIterator

NewDBStagingIterator initiates the staging iterator with a batchSize

func (*DBIterator) Close

func (s *DBIterator) Close()

func (*DBIterator) Err

func (s *DBIterator) Err() error

func (*DBIterator) Next

func (s *DBIterator) Next() bool

func (*DBIterator) SeekGE

func (s *DBIterator) SeekGE(key graveler.Key)

func (*DBIterator) Value

func (s *DBIterator) Value() *graveler.ValueRecord

type DBManager

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

func NewDBManager

func NewDBManager(db db.Database) *DBManager

func (*DBManager) Drop

func (p *DBManager) Drop(ctx context.Context, st graveler.StagingToken) error

func (*DBManager) DropAsync

func (p *DBManager) DropAsync(ctx context.Context, st graveler.StagingToken) error

func (*DBManager) DropByPrefix

func (p *DBManager) DropByPrefix(ctx context.Context, st graveler.StagingToken, prefix graveler.Key) error

func (*DBManager) DropKey

func (p *DBManager) DropKey(ctx context.Context, st graveler.StagingToken, key graveler.Key) error

func (*DBManager) Get

func (p *DBManager) Get(ctx context.Context, st graveler.StagingToken, key graveler.Key) (*graveler.Value, error)

func (*DBManager) List

func (p *DBManager) List(ctx context.Context, st graveler.StagingToken, batchSize int) (graveler.ValueIterator, error)

List returns an iterator of staged values on the staging token st

func (*DBManager) Set

func (p *DBManager) Set(ctx context.Context, st graveler.StagingToken, key graveler.Key, value *graveler.Value, overwrite bool) error

func (*DBManager) Update

func (p *DBManager) Update(_ context.Context, _ graveler.StagingToken, _ graveler.Key, _ graveler.ValueUpdateFunc) error

type Iterator

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

func NewStagingIterator

func NewStagingIterator(ctx context.Context, store kv.StoreMessage, st graveler.StagingToken) (*Iterator, error)

NewStagingIterator initiates the staging iterator with a batchSize

func (*Iterator) Close

func (s *Iterator) Close()

func (*Iterator) Err

func (s *Iterator) Err() error

func (*Iterator) Next

func (s *Iterator) Next() bool

func (*Iterator) SeekGE

func (s *Iterator) SeekGE(key graveler.Key)

func (*Iterator) Value

func (s *Iterator) Value() *graveler.ValueRecord

type Manager

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

func NewManager

func NewManager(ctx context.Context, store kv.StoreMessage) *Manager

func (*Manager) Drop

func (m *Manager) Drop(ctx context.Context, st graveler.StagingToken) error

func (*Manager) DropAsync

func (m *Manager) DropAsync(ctx context.Context, st graveler.StagingToken) error

func (*Manager) DropByPrefix

func (m *Manager) DropByPrefix(ctx context.Context, st graveler.StagingToken, prefix graveler.Key) error

func (*Manager) DropKey

func (m *Manager) DropKey(ctx context.Context, st graveler.StagingToken, key graveler.Key) error

func (*Manager) Get

func (m *Manager) Get(ctx context.Context, st graveler.StagingToken, key graveler.Key) (*graveler.Value, error)

func (*Manager) List

func (m *Manager) List(ctx context.Context, st graveler.StagingToken, _ int) (graveler.ValueIterator, error)

List TODO niro: Remove batchSize parameter post KV List returns an iterator of staged values on the staging token st

func (*Manager) OnCleanup

func (m *Manager) OnCleanup(cleanupCallback func())

func (*Manager) Set

func (m *Manager) Set(ctx context.Context, st graveler.StagingToken, key graveler.Key, value *graveler.Value, _ bool) error

func (*Manager) Update

func (m *Manager) Update(ctx context.Context, st graveler.StagingToken, key graveler.Key, updateFunc graveler.ValueUpdateFunc) error