Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

objstore

package

Go to main page

Versions in this module

v0

v0.7.6

May 26, 2026

v0.7.5

May 8, 2026

v0.7.4

Mar 31, 2026

v0.7.3

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

v0.7.2

Feb 20, 2026

v0.7.1

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

v0.7.0

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