Versions in this module Expand all Collapse all v0 v0.18.0 Dec 10, 2025 Changes in this version + func NewFromCmdlineOptions() plugin.Plugin + type BlobStoreS3 struct + func New(dataDir string, logger *slog.Logger, promRegistry prometheus.Registerer) (*BlobStoreS3, error) + func NewWithOptions(opts ...BlobStoreS3OptionFunc) (*BlobStoreS3, error) + func (b *BlobStoreS3) GetCommitTimestamp(ctx context.Context) (int64, error) + func (b *BlobStoreS3) SetCommitTimestamp(ctx context.Context, ts int64) error + func (d *BlobStoreS3) Bucket() string + func (d *BlobStoreS3) Client() *s3.Client + func (d *BlobStoreS3) Get(ctx context.Context, key string) ([]byte, error) + func (d *BlobStoreS3) Put(ctx context.Context, key string, value []byte) error + func (d *BlobStoreS3) Start() error + func (d *BlobStoreS3) Stop() error + type BlobStoreS3OptionFunc func(*BlobStoreS3) + func WithBucket(bucket string) BlobStoreS3OptionFunc + func WithLogger(logger *slog.Logger) BlobStoreS3OptionFunc + func WithPrefix(prefix string) BlobStoreS3OptionFunc + func WithPromRegistry(registry prometheus.Registerer) BlobStoreS3OptionFunc + func WithRegion(region string) BlobStoreS3OptionFunc + func WithTimeout(timeout time.Duration) BlobStoreS3OptionFunc + type S3Logger struct + func NewS3Logger(logger *slog.Logger) *S3Logger + func (g *S3Logger) Debugf(msg string, args ...any) + func (g *S3Logger) Errorf(msg string, args ...any) + func (g *S3Logger) Infof(msg string, args ...any) + func (g *S3Logger) Warningf(msg string, args ...any)
Go to main page