staging

Documentation

Index

• type Iterator
  • func NewStagingIterator(ctx context.Context, db db.Database, log logging.Logger, ...) *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(db db.Database) *Manager
  • func (p *Manager) Drop(ctx context.Context, st graveler.StagingToken) error
  • func (p *Manager) DropByPrefix(ctx context.Context, st graveler.StagingToken, prefix graveler.Key) error
  • func (p *Manager) DropKey(ctx context.Context, st graveler.StagingToken, key graveler.Key) error
  • func (p *Manager) Get(ctx context.Context, st graveler.StagingToken, key graveler.Key) (*graveler.Value, error)
  • func (p *Manager) List(ctx context.Context, st graveler.StagingToken) (graveler.ValueIterator, error)
  • func (p *Manager) Set(ctx context.Context, st graveler.StagingToken, key graveler.Key, ...) error

Types

type Iterator

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

func NewStagingIterator

func NewStagingIterator(ctx context.Context, db db.Database, log logging.Logger, st graveler.StagingToken) *Iterator

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(db db.Database) *Manager

func (*Manager) Drop

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

func (*Manager) DropByPrefix

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

func (*Manager) DropKey

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

func (*Manager) Get

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

func (*Manager) List

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

func (*Manager) Set

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