store

import "github.com/afreidah/g3/internal/store"

Index

PostgresStore provides a shared PostgreSQL metadata index for g3 objects and buckets. Implements backend.MetadataStore.

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

func NewPostgres(ctx context.Context, cfg *config.DatabaseConfig) (*PostgresStore, error)

NewPostgres connects to PostgreSQL, runs migrations, and returns a store.

func (s *PostgresStore) Close() error

Close closes the connection pool.

func (s *PostgresStore) DeleteObject(ctx context.Context, bucket, key string) error

DeleteObject removes an object record from the index.

func (s *PostgresStore) GetBucket(ctx context.Context, name string) (*backend.BucketRecord, error)

GetBucket retrieves a bucket record by name. Returns nil if not found.

func (s *PostgresStore) GetObject(ctx context.Context, bucket, key string) (*backend.ObjectRecord, error)

GetObject retrieves an object record by bucket and key. Returns nil if not found.

func (s *PostgresStore) ListBuckets(ctx context.Context) ([]*backend.BucketRecord, error)

ListBuckets returns all bucket records ordered by name.

func (s *PostgresStore) ListObjects(ctx context.Context, bucket, prefix, startAfter string, maxKeys int) ([]*backend.ObjectRecord, error)

ListObjects returns object records matching a bucket and optional key prefix, ordered by key.

func (s *PostgresStore) PutBucket(ctx context.Context, rec *backend.BucketRecord) error

PutBucket inserts or replaces a bucket record.

func (s *PostgresStore) PutObject(ctx context.Context, rec *backend.ObjectRecord) error

PutObject inserts or replaces an object record.

SQLiteStore provides a local SQLite metadata index for g3 objects and buckets. Implements backend.MetadataStore.

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

func NewSQLite(path string) (*SQLiteStore, error)

New opens or creates a SQLite database at the given path and runs schema migrations.

func (s *SQLiteStore) Close() error

Close closes the database connection.

func (s *SQLiteStore) DeleteObject(ctx context.Context, bucket, key string) error