gcs

package

v0.17.0 Latest Latest Go to latest Published: Sep 18, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

BlobStoreGCS stores data in a Google Cloud Storage bucket.

func New(
	dataDir string,
	logger *slog.Logger,
	promRegistry prometheus.Registerer,
) (*BlobStoreGCS, error)

New creates a new GCS-backed blob store.

func (d *BlobStoreGCS) Bucket() *storage.BucketHandle

Returns the bucket handle.

func (d *BlobStoreGCS) Client() *storage.Client

Returns the GCS client.

func (d *BlobStoreGCS) Close() error

closes the GCS client.

func (b *BlobStoreGCS) GetCommitTimestamp(ctx context.Context) (int64, error)

func (b *BlobStoreGCS) SetCommitTimestamp(ctx context.Context, timestamp int64) error

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

GcsLogger is a wrapper type to give our logger a consistent interface

func NewGcsLogger(logger *slog.Logger) *GcsLogger

func (g *GcsLogger) Debugf(msg string, args ...any)

func (g *GcsLogger) Errorf(msg string, args ...any)

func (g *GcsLogger) Infof(msg string, args ...any)

func (g *GcsLogger) Warningf(msg string, args ...any)