objectstore

Jun 16, 2026

Changes in this version

type GCSObjectStore

+ func (g *GCSObjectStore) ListByPrefix(ctx context.Context, prefix string) ([]ObjectInfo, error)

type InMemoryObjectStore

+ func (m *InMemoryObjectStore) ListByPrefix(_ context.Context, prefix string) ([]ObjectInfo, error)

+ func (m *InMemoryObjectStore) SetCreatedAt(key string, t time.Time)

+ type ObjectInfo struct

+ Key string

+ LastModified time.Time

type ObjectStore

+ ListByPrefix func(ctx context.Context, prefix string) ([]ObjectInfo, error)

type S3ObjectStore

+ func (s *S3ObjectStore) ListByPrefix(ctx context.Context, prefix string) ([]ObjectInfo, error)

Apr 13, 2026

Changes in this version

+ type Config struct

+ AccessKeyID *schemas.EnvVar

+ Bucket schemas.EnvVar

+ Compress bool

+ Credentials *schemas.EnvVar

+ CredentialsJSON *schemas.EnvVar

+ Endpoint *schemas.EnvVar

+ ForcePathStyle bool

+ Prefix string

+ ProjectID *schemas.EnvVar

+ Region *schemas.EnvVar

+ RoleARN *schemas.EnvVar

+ SecretAccessKey *schemas.EnvVar

+ SessionToken *schemas.EnvVar

+ Type StoreType

+ func (c *Config) GetPrefix() string

+ type GCSObjectStore struct

+ func NewGCSObjectStore(ctx context.Context, cfg *Config, logger schemas.Logger) (*GCSObjectStore, error)

+ func (g *GCSObjectStore) Close() error

+ func (g *GCSObjectStore) Delete(ctx context.Context, key string) error

+ func (g *GCSObjectStore) DeleteBatch(ctx context.Context, keys []string) error

+ func (g *GCSObjectStore) Get(ctx context.Context, key string) ([]byte, error)

+ func (g *GCSObjectStore) Ping(ctx context.Context) error

+ func (g *GCSObjectStore) Put(ctx context.Context, key string, data []byte, tags map[string]string) error

+ type InMemoryObjectStore struct

+ GetErr error

+ PutErr error

+ func NewInMemoryObjectStore() *InMemoryObjectStore

+ func (m *InMemoryObjectStore) Close() error

+ func (m *InMemoryObjectStore) Delete(_ context.Context, key string) error

+ func (m *InMemoryObjectStore) DeleteBatch(_ context.Context, keys []string) error

+ func (m *InMemoryObjectStore) Get(_ context.Context, key string) ([]byte, error)

+ func (m *InMemoryObjectStore) GetTags(key string) map[string]string

+ func (m *InMemoryObjectStore) Keys() []string

+ func (m *InMemoryObjectStore) Len() int

+ func (m *InMemoryObjectStore) Ping(_ context.Context) error

+ func (m *InMemoryObjectStore) Put(_ context.Context, key string, data []byte, tags map[string]string) error

+ type ObjectStore interface

+ Close func() error

+ Delete func(ctx context.Context, key string) error

+ DeleteBatch func(ctx context.Context, keys []string) error

+ Get func(ctx context.Context, key string) ([]byte, error)

+ Ping func(ctx context.Context) error

+ Put func(ctx context.Context, key string, data []byte, tags map[string]string) error

+ func NewObjectStore(ctx context.Context, cfg *Config, logger schemas.Logger) (ObjectStore, error)

+ type S3ObjectStore struct

+ func NewS3ObjectStore(ctx context.Context, cfg *Config, logger schemas.Logger) (*S3ObjectStore, error)

+ func (s *S3ObjectStore) Close() error

+ func (s *S3ObjectStore) Delete(ctx context.Context, key string) error

+ func (s *S3ObjectStore) DeleteBatch(ctx context.Context, keys []string) error

+ func (s *S3ObjectStore) Get(ctx context.Context, key string) ([]byte, error)

+ func (s *S3ObjectStore) Ping(ctx context.Context) error

+ func (s *S3ObjectStore) Put(ctx context.Context, key string, data []byte, tags map[string]string) error

+ type StoreType string

+ const StoreTypeGCS

+ const StoreTypeS3