Documentation
¶
Index ¶
- type DBIterator
- type DBManager
- func (p *DBManager) Drop(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
- type Iterator
- type Manager
- func (m *Manager) Drop(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) 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 DBIterator ¶ added in v0.69.0
type DBIterator struct {
// contains filtered or unexported fields
}
func NewDBStagingIterator ¶ added in v0.69.0
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 ¶ added in v0.69.0
func (s *DBIterator) Close()
func (*DBIterator) Err ¶ added in v0.69.0
func (s *DBIterator) Err() error
func (*DBIterator) Next ¶ added in v0.69.0
func (s *DBIterator) Next() bool
func (*DBIterator) SeekGE ¶ added in v0.69.0
func (s *DBIterator) SeekGE(key graveler.Key)
func (*DBIterator) Value ¶ added in v0.69.0
func (s *DBIterator) Value() *graveler.ValueRecord
type DBManager ¶ added in v0.69.0
type DBManager struct {
// contains filtered or unexported fields
}
func NewDBManager ¶ added in v0.69.0
func (*DBManager) DropByPrefix ¶ added in v0.69.0
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) Value ¶
func (s *Iterator) Value() *graveler.ValueRecord
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func NewManager ¶
func NewManager(store kv.StoreMessage) *Manager
func (*Manager) DropByPrefix ¶
Click to show internal directories.
Click to hide internal directories.