Documentation
¶
Index ¶
- Constants
- Variables
- func NewStaticCollector(m map[string]string) func() sstable.TablePropertyCollector
- type DiskWriter
- func (dw *DiskWriter) Abort() error
- func (dw *DiskWriter) Close() (*committed.WriteResult, error)
- func (dw *DiskWriter) GetApproximateSize() uint64
- func (dw *DiskWriter) GetFS() pyramid.FS
- func (dw *DiskWriter) GetStoredFile() pyramid.StoredFile
- func (dw *DiskWriter) SetMetadata(key, value string)
- func (dw *DiskWriter) ShouldBreakAtKey(key graveler.Key, params *committed.Params) bool
- func (dw *DiskWriter) WriteRecord(record committed.Record) error
- type Iterator
- type NewSSTableReaderFn
- type RangeManager
- func (m *RangeManager) Close() error
- func (m *RangeManager) Exists(ctx context.Context, ns committed.Namespace, id committed.ID) (bool, error)
- func (m *RangeManager) GetURI(ctx context.Context, ns committed.Namespace, id committed.ID) (string, error)
- func (m *RangeManager) GetValue(ctx context.Context, ns committed.Namespace, id committed.ID, ...) (*committed.Record, error)
- func (m *RangeManager) GetValueGE(ctx context.Context, ns committed.Namespace, id committed.ID, ...) (*committed.Record, error)
- func (m *RangeManager) GetWriter(ctx context.Context, ns committed.Namespace, metadata graveler.Metadata) (committed.RangeWriter, error)
- func (m *RangeManager) NewRangeIterator(ctx context.Context, ns committed.Namespace, tid committed.ID) (committed.ValueIterator, error)
- type Unrefer
Constants ¶
View Source
const ( MetadataFirstKey = "min_key" MetadataLastKey = "max_key" MetadataNumRecordsKey = "count" MetadataEstimatedSizeKey = "estimated_size_bytes" )
Variables ¶
View Source
var ( // ErrKeyNotFound is the error returned when a path is not found ErrKeyNotFound = errors.New("path not found") )
Functions ¶
func NewStaticCollector ¶
func NewStaticCollector(m map[string]string) func() sstable.TablePropertyCollector
NewStaticCollector returns an SSTable collector that will add the properties in m when writing ends.
Types ¶
type DiskWriter ¶
type DiskWriter struct {
// contains filtered or unexported fields
}
func NewDiskWriter ¶
func (*DiskWriter) Abort ¶
func (dw *DiskWriter) Abort() error
func (*DiskWriter) Close ¶
func (dw *DiskWriter) Close() (*committed.WriteResult, error)
func (*DiskWriter) GetApproximateSize ¶
func (dw *DiskWriter) GetApproximateSize() uint64
func (*DiskWriter) GetFS ¶
func (dw *DiskWriter) GetFS() pyramid.FS
func (*DiskWriter) GetStoredFile ¶
func (dw *DiskWriter) GetStoredFile() pyramid.StoredFile
func (*DiskWriter) SetMetadata ¶
func (dw *DiskWriter) SetMetadata(key, value string)
SetMetadata associates metadata value (which will be stringified) with key. Keys and values are also calculated as part of the resulting range ID
func (*DiskWriter) ShouldBreakAtKey ¶ added in v0.63.0
ShouldBreakAtKey returns true if should break range after the given key
func (*DiskWriter) WriteRecord ¶
func (dw *DiskWriter) WriteRecord(record committed.Record) error
type Iterator ¶
type Iterator struct {
// contains filtered or unexported fields
}
Iterator returns ordered iteration of the SSTable entries
type NewSSTableReaderFn ¶
type RangeManager ¶
type RangeManager struct {
// contains filtered or unexported fields
}
func NewPebbleSSTableRangeManagerWithNewReader ¶
func NewPebbleSSTableRangeManagerWithNewReader(newReader NewSSTableReaderFn, cache Unrefer, fs pyramid.FS, hash crypto.Hash) *RangeManager
func (*RangeManager) Close ¶
func (m *RangeManager) Close() error
func (*RangeManager) GetValue ¶
func (m *RangeManager) GetValue(ctx context.Context, ns committed.Namespace, id committed.ID, lookup committed.Key) (*committed.Record, error)
GetValue returns the Record matching the key in the SSTable referenced by the id. If key is not found, (nil, ErrKeyNotFound) is returned.
func (*RangeManager) GetValueGE ¶
func (*RangeManager) GetWriter ¶
func (m *RangeManager) GetWriter(ctx context.Context, ns committed.Namespace, metadata graveler.Metadata) (committed.RangeWriter, error)
GetWriter returns a new SSTable writer instance
func (*RangeManager) NewRangeIterator ¶
func (m *RangeManager) NewRangeIterator(ctx context.Context, ns committed.Namespace, tid committed.ID) (committed.ValueIterator, error)
NewRangeIterator takes a given SSTable and returns an EntryIterator seeked to >= "from" path
Click to show internal directories.
Click to hide internal directories.