gcs

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 14, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package gcs builds a complete objlog store on Google Cloud Storage.

Index

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 New

func New(opts Options) (*Store, error)

New builds a complete GCS-backed objlog store.

func (*Store) NewReclaimer

func (s *Store) NewReclaimer(opts lifecycle.Options) (*lifecycle.Reclaimer, error)

NewReclaimer creates an explicitly scheduled object lifecycle worker.

func (*Store) ReaderCatalog

func (s *Store) ReaderCatalog() catalog.Reader

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL