Documentation
¶
Index ¶
- func Migrate(ctx context.Context, d *pgxpool.Pool, writer io.Writer) error
- type DBIterator
- type 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
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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
func (*DBManager) List ¶ added in v0.69.0
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
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(ctx context.Context, store kv.StoreMessage) *Manager
func (*Manager) DropByPrefix ¶
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
Click to show internal directories.
Click to hide internal directories.