staging

Documentation

Index

• Constants
• type Iterator
  • func NewStagingIterator(ctx context.Context, kvStore kv.Store, st graveler.StagingToken, batchSize int) *Iterator
  • 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, storeLimited kv.Store, ...) *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, batchSize int) graveler.ValueIterator
  • 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

Constants

const (
	MaxBatchDelay = 3 * time.Millisecond
)

cleanTokens is async cleaning of deleted staging tokens

Types

type Iterator

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

func NewStagingIterator

func NewStagingIterator(ctx context.Context, kvStore kv.Store, st graveler.StagingToken, batchSize int) *Iterator

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, storeLimited kv.Store, batchDBIOTransactionMarkers bool, executor batch.Batcher) *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, batchSize int) graveler.ValueIterator

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, requireExists bool) error

func (*Manager) Update

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