sstable

Documentation

Index

• Constants
• Variables
• func NewStaticCollector(m map[string]string) func() sstable.TablePropertyCollector
• type DiskWriter
  • func NewDiskWriter(ctx context.Context, tierFS pyramid.FS, ns committed.Namespace, hash hash.Hash, ...) (*DiskWriter, error)
  • 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) WriteRecord(record committed.Record) error
• type Iterator
  • func NewIterator(it sstable.Iterator, derefer func() error) *Iterator
  • func (iter *Iterator) Close()
  • func (iter *Iterator) Err() error
  • func (iter *Iterator) Next() bool
  • func (iter *Iterator) SeekGE(lookup committed.Key)
  • func (iter *Iterator) Value() *committed.Record
• type NewSSTableReaderFn
• type RangeManager
  • func NewPebbleSSTableRangeManager(cache *pebble.Cache, fs pyramid.FS, hash crypto.Hash) *RangeManager
  • func NewPebbleSSTableRangeManagerWithNewReader(newReader NewSSTableReaderFn, cache Unrefer, fs pyramid.FS, hash crypto.Hash) *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

const (
	MetadataFirstKey         = "min_key"
	MetadataLastKey          = "max_key"
	MetadataNumRecordsKey    = "count"
	MetadataEstimatedSizeKey = "estimated_size_bytes"
)

Variables

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 NewDiskWriter(ctx context.Context, tierFS pyramid.FS, ns committed.Namespace, hash hash.Hash, metadata graveler.Metadata) (*DiskWriter, error)

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)

AddMetadata associates metadata value (which will be stringified) with key. Keys and values are also calculated as part of the resulting range ID

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

func NewIterator

func NewIterator(it sstable.Iterator, derefer func() error) *Iterator

func (*Iterator) Close

func (iter *Iterator) Close()

func (*Iterator) Err

func (iter *Iterator) Err() error

func (*Iterator) Next

func (iter *Iterator) Next() bool

func (*Iterator) SeekGE

func (iter *Iterator) SeekGE(lookup committed.Key)

func (*Iterator) Value

func (iter *Iterator) Value() *committed.Record

type NewSSTableReaderFn

type NewSSTableReaderFn func(ctx context.Context, ns committed.Namespace, id committed.ID) (*sstable.Reader, error)

type RangeManager

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

func NewPebbleSSTableRangeManager

func NewPebbleSSTableRangeManager(cache *pebble.Cache, fs pyramid.FS, hash crypto.Hash) *RangeManager

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) Exists

func (m *RangeManager) Exists(ctx context.Context, ns committed.Namespace, id committed.ID) (bool, error)

func (*RangeManager) GetURI

func (m *RangeManager) GetURI(ctx context.Context, ns committed.Namespace, id committed.ID) (string, 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 (m *RangeManager) GetValueGE(ctx context.Context, ns committed.Namespace, id committed.ID, lookup committed.Key) (*committed.Record, error)

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

type Unrefer

type Unrefer interface {
	Unref()
}