objstore

Mar 12, 2026

Changes in this version

+ func WithLimit(limit uint32) func(o *commonListOptions)

type Common

+ GetObject func(ctx context.Context, bucket string, name string, ...) (io.Reader, error)

+ RemoveObjectsSingleErr func(ctx context.Context, bucket string, names []string) error

+ RemoveVersionedObjects func(ctx context.Context, bucket string, objects []NameAndVersion) []error

+ type NameAndVersion struct

+ Name string

+ Version string

Feb 5, 2026

Changes in this version

+ var ErrBucketDoesntExist = errors.New("bucket doesn't exists")

+ func WithAfter(after string) func(o *commonListOptions)

+ func WithPrefix(prefix string) func(o *commonListOptions)

+ func WithVersionID(versionID string) func(o *commonObjectOptions)

+ func WithVersions() func(o *commonListOptions)

type Common

+ func WrapS3common(client s3client.Client, provider s3.Provider) Common

+ func WrapSwiftCommon(client *gophercloud.ServiceClient) Common

+ CreateBucket func(ctx context.Context, bucket string) error

+ EnableBucketVersioning func(ctx context.Context, bucket string) error

+ IsBucketVersioned func(ctx context.Context, bucket string) (bool, error)

+ ListObjects func(ctx context.Context, bucket string, opts ...func(o *commonListOptions)) iter.Seq2[CommonObjectInfo, error]

+ ObjectExists func(ctx context.Context, bucket string, name string, ...) (bool, error)

+ ObjectInfo func(ctx context.Context, bucket string, name string, ...) (*CommonObjectInfo, error)

+ PutObject func(ctx context.Context, bucket string, name string, reader io.Reader, len uint64) error

+ RemoveBucket func(ctx context.Context, bucket string) error

+ RemoveObject func(ctx context.Context, bucket string, name string, ...) error

+ RemoveObjects func(ctx context.Context, bucket string, names []string) error

+ type CommonObjectInfo struct

+ Etag string

+ Key string

+ LastModified time.Time

+ Size uint64

+ VersionID string

Jan 27, 2026

Changes in this version

+ func NewCredsSvc(ctx context.Context, conf *Config, rc redis.UniversalClient) (*credsSvc, error)

+ func NewRegistry(ctx context.Context, creds CredsService, metricsSvc metrics.Service) (*clients, error)

+ func StorageTypeFromRequest(r *http.Request) dom.StorageType

+ type Clients interface

+ AsS3 func(ctx context.Context, storage, user string) (s3client.Client, error)

+ AsSwift func(ctx context.Context, storage, user string) (*gophercloud.ServiceClient, error)

+ type Common interface

+ BucketExists func(ctx context.Context, bucket string) (bool, error)

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

+ type CommonConfig struct

+ RateLimit ratelimit.RateLimit

+ Type dom.StorageType

+ type Config = StoragesConfig[*s3.Storage, *swift.Storage]

+ type CredsService interface

+ FindS3Credentials func(storage, accessKey string) (user string, cred s3.CredentialsV4, err error)

+ GetS3Address func(storage string) (s3.StorageAddress, error)

+ GetS3Credentials func(storage, user string) (s3.CredentialsV4, error)

+ GetSwiftAddress func(storage string) (swift.StorageAddress, error)

+ GetSwiftCredentials func(storage, user string) (swift.Credentials, error)

+ HasUser func(storage, user string) error

+ ListUsers func(storage string) []string

+ MainStorage func() string

+ SetS3Credentials func(ctx context.Context, storage, user string, cred s3.CredentialsV4) error

+ SetSwiftCredentials func(ctx context.Context, storage, user string, cred swift.Credentials) error

+ Storages func() map[string]dom.StorageType

+ ValidateReplicationID func(id entity.UniversalReplicationID) error

+ type DynamicCredentialsConfig struct

+ DisableEncryption bool

+ Enabled bool

+ MasterPassword string

+ PollInterval time.Duration

+ func (c *DynamicCredentialsConfig) Validate() error

+ type GenericStorage struct

+ S3 S3Config

+ Swift SwiftConfig

+ func (a GenericStorage[S3conf, SwiftConf]) MarshalYAML() (any, error)

+ func (a GenericStorage[S3conf, SwiftConf]) UserList() []string

+ func (s *GenericStorage[S3conf, SwiftConf]) UnmarshalYAML(node *yaml.Node) error

+ func (s GenericStorage[S3Config, SwiftConfig]) Validate() error

+ type Storage = GenericStorage[*s3.Storage, *swift.Storage]

+ type StorageConfig interface

+ HasUser func(user string) bool

+ UserList func() []string

+ Validate func() error

+ type StoragesConfig struct

+ DynamicCredentials DynamicCredentialsConfig

+ Main string

+ Storages map[string]GenericStorage[S3Config, SwiftConfig]

+ func (s StoragesConfig[S3Config, SwiftConfig]) Exists(stor, user string) error

+ func (s StoragesConfig[S3Config, SwiftConfig]) Types() map[string]dom.StorageType

+ func (s StoragesConfig[S3Config, SwiftConfig]) ViperUnmarshallerHookFunc() mapstructure.DecodeHookFuncType

+ func (s StoragesConfig[S3conf, SwiftConf]) GetMain() GenericStorage[S3conf, SwiftConf]

+ func (s StoragesConfig[S3conf, SwiftConf]) S3Storages() map[string]S3conf

+ func (s StoragesConfig[S3conf, SwiftConf]) SwiftStorages() map[string]SwiftConf

+ func (s StoragesConfig[_, _]) RateLimitConf() map[string]ratelimit.RateLimit

+ func (s StoragesConfig[_, _]) Validate() error