Documentation
¶
Overview ¶
Package gcs builds a complete objlog store on Google Cloud Storage.
Index ¶
- type Options
- type Store
- func (s *Store) NewReclaimer(opts lifecycle.Options) (*lifecycle.Reclaimer, error)
- func (s *Store) ReaderCatalog() catalog.Reader
- func (s *Store) RetentionManager() catalog.RetentionManager
- func (s *Store) SegmentStore() reader.SegmentStore
- func (s *Store) SinkFactory() writer.SinkFactory
- func (s *Store) WriterManager() catalog.WriterManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options struct {
Client *storage.Client
Bucket string
// Prefix is the common object key root. Catalog metadata defaults to
// <prefix>/catalog and segment objects default to <prefix>/segments.
Prefix string
// StreamID scopes catalog metadata and segment object keys to one stream.
StreamID string
// CatalogPrefix overrides the catalog metadata prefix.
CatalogPrefix string
// SegmentRootPrefix overrides the segment sink root. Final segment objects
// are placed under <segment-root>/segments.
SegmentRootPrefix string
// SegmentContentType is attached to committed segment objects.
SegmentContentType string
// CatalogLeafSegmentLimit and CatalogIndexRefLimit override the catalog
// page fan-out. Zero keeps the catalog defaults. They are writer-side
// settings; readers follow page references regardless of the values.
CatalogLeafSegmentLimit int
CatalogIndexRefLimit int
}
Options configures a complete GCS-backed objlog store.
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store wires GCS catalog metadata, segment writes, and segment reads.
func (*Store) NewReclaimer ¶
NewReclaimer creates an explicitly scheduled object lifecycle worker.
func (*Store) ReaderCatalog ¶
func (*Store) RetentionManager ¶
func (s *Store) RetentionManager() catalog.RetentionManager
func (*Store) SegmentStore ¶
func (s *Store) SegmentStore() reader.SegmentStore
func (*Store) SinkFactory ¶
func (s *Store) SinkFactory() writer.SinkFactory
func (*Store) WriterManager ¶
func (s *Store) WriterManager() catalog.WriterManager
Click to show internal directories.
Click to hide internal directories.