Documentation
¶
Index ¶
- type Iterator
- type 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, batchSize int) (graveler.ValueIterator, error)
- func (p *Manager) Set(ctx context.Context, st graveler.StagingToken, key graveler.Key, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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, batchSize int) *Iterator
NewStagingIterator initiates the staging iterator with a batchSize
func (*Iterator) Value ¶
func (s *Iterator) Value() *graveler.ValueRecord
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func NewManager ¶
func (*Manager) DropByPrefix ¶
Click to show internal directories.
Click to hide internal directories.