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

blob

package

Go to main page

Versions in this module

v0

v0.8.7

Oct 20, 2025

v0.8.6

Oct 8, 2025

v0.8.5

Sep 15, 2025

v0.8.4

Sep 4, 2025

v0.8.3

Jul 30, 2025

v0.8.2

Jul 24, 2025

v0.8.1

Jul 22, 2025

v0.8.0

Jul 22, 2025

v0.7.0

Jul 15, 2025

v0.6.1

Jul 1, 2025

Changes in this version

+ type AfterCopyObjectHook func(req *CopyObjectParams, resp *CopyObjectResponse)

+ type AfterDeleteObjectHook func(req string, resp bool)

+ type AfterPutObjectHook func(req *PutObjectParams, resp *PutObjectResponse)

+ type BlobChangeCallback func(key string, eventType BlobEventType)

+ type BlobEventType uint8

+ const BlobEventCopy

+ const BlobEventDelete

+ const BlobEventPut

type BlobService

+ func (b *BlobService) OnBlobChange(callback BlobChangeCallback)

+ type IBlobBackend interface

+ CompleteMultipartUpload func(ctx context.Context, params *CompleteMultipartUploadParams) (*PutObjectResponse, error)

+ CopyObject func(ctx context.Context, params *CopyObjectParams) (*CopyObjectResponse, error)

+ Delegate func() any

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

+ GetObject func(ctx context.Context, key string) (*GetObjectResponse, error)

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

+ ListObjects func(ctx context.Context) ([]*BlobInfo, error)

+ PutObject func(ctx context.Context, params *PutObjectParams) (*PutObjectResponse, error)

+ PutObjectMultipart func(ctx context.Context, params *PutObjectMultipartParams) (*PutObjectMultipartResponse, error)

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

+ type Service interface

+ Backend func() IBlobBackend

+ Index func() IBlobIndex

+ OnBlobChange func(callback BlobChangeCallback)

v0.6.0

Jun 24, 2025

v0.5.0

Jun 18, 2025

Changes in this version

+ var ErrInvalidKey = errors.New("invalid key")

+ func ValidateKey(key string) bool

+ type BlobBackend interface

+ CompleteMultipartUpload func(ctx context.Context, params *CompleteMultipartUploadParams) (*PutObjectResponse, error)

+ CopyObject func(ctx context.Context, params *CopyObjectParams) (*CopyObjectResponse, error)

+ Delegate func() any

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

+ GetObject func(ctx context.Context, key string) (*GetObjectResponse, error)

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

+ ListObjects func(ctx context.Context) ([]*BlobInfo, error)

+ PutObject func(ctx context.Context, params *PutObjectParams) (*PutObjectResponse, error)

+ PutObjectMultipart func(ctx context.Context, params *PutObjectMultipartParams) (*PutObjectMultipartResponse, error)

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

+ type BlobIndex struct

+ func (bi *BlobIndex) Close() error

+ func (bi *BlobIndex) Count() int

+ func (bi *BlobIndex) FilterAfterTime(after time.Time) ([]*BlobInfo, error)

+ func (bi *BlobIndex) FilterBeforeTime(before time.Time) ([]*BlobInfo, error)

+ func (bi *BlobIndex) FilterByKeyGlob(pattern string) ([]*BlobInfo, error)

+ func (bi *BlobIndex) FilterByPrefix(prefix string) ([]*BlobInfo, error)

+ func (bi *BlobIndex) FilterBySuffix(suffix string) ([]*BlobInfo, error)

+ func (bi *BlobIndex) FilterByTime(filter TimeFilter) ([]*BlobInfo, error)

+ func (bi *BlobIndex) Get(key string) (*BlobInfo, bool)

+ func (bi *BlobIndex) Iter() iter.Seq[*BlobInfo]

+ func (bi *BlobIndex) List() ([]*BlobInfo, error)

+ func (bi *BlobIndex) Remove(key string) error

+ func (bi *BlobIndex) Set(blob *BlobInfo) error

+ func (bi *BlobIndex) SetMany(blobs []*BlobInfo) error

+ type BlobInfo struct

+ ETag string

+ Key string

+ LastModified string

+ Size int64

+ type BlobService struct

+ func NewBlobService(cfg *S3Config, db *sqlx.DB) (*BlobService, error)

+ func (b *BlobService) Backend() BlobBackend

+ func (b *BlobService) Index() *BlobIndex

+ func (b *BlobService) Shutdown(ctx context.Context) error

+ func (b *BlobService) Start(ctx context.Context) error

+ type CompleteMultipartUploadParams struct

+ Key string

+ Parts []*CompletedPart

+ UploadID string

+ type CompletedPart struct

+ ETag string

+ PartNumber int

+ type CopyObjectParams struct

+ DestinationKey string

+ SourceKey string

+ type CopyObjectResponse struct

+ ETag string

+ LastModified time.Time

+ type GetObjectResponse struct

+ Body io.ReadCloser

+ ETag string

+ LastModified time.Time

+ Size int64

+ type IBlobIndex interface

+ Count func() int

+ FilterAfterTime func(after time.Time) ([]*BlobInfo, error)

+ FilterBeforeTime func(before time.Time) ([]*BlobInfo, error)

+ FilterByKeyGlob func(pattern string) ([]*BlobInfo, error)

+ FilterByPrefix func(prefix string) ([]*BlobInfo, error)

+ FilterBySuffix func(suffix string) ([]*BlobInfo, error)

+ FilterByTime func(filter TimeFilter) ([]*BlobInfo, error)

+ Get func(key string) (*BlobInfo, bool)

+ Iter func() iter.Seq[*BlobInfo]

+ List func() ([]*BlobInfo, error)

+ Remove func(key string) error

+ Set func(blob *BlobInfo) error

+ SetMany func(blobs []*BlobInfo) error

+ type PutObjectMultipartParams struct

+ Key string

+ Parts uint16

+ type PutObjectMultipartResponse struct

+ Key string

+ URLs []string

+ UploadID string

+ type PutObjectParams struct

+ Body io.Reader

+ ETag string

+ Key string

+ Size int64

+ type PutObjectPresignedResponse struct

+ Name string

+ PresignedURLs []string

+ UploadID string

+ type PutObjectResponse struct

+ ETag string

+ Key string

+ LastModified time.Time

+ Size int64

+ Version string

+ type S3Backend struct

+ func NewS3Backend(s3Client *s3.Client, config *S3Config) *S3Backend

+ func NewS3BackendWithConfig(cfg *S3Config) *S3Backend

+ func (s *S3Backend) CompleteMultipartUpload(ctx context.Context, params *CompleteMultipartUploadParams) (*PutObjectResponse, error)

+ func (s *S3Backend) CopyObject(ctx context.Context, params *CopyObjectParams) (*CopyObjectResponse, error)

+ func (s *S3Backend) Delegate() any

+ func (s *S3Backend) DeleteObject(ctx context.Context, key string) (bool, error)

+ func (s *S3Backend) GetObject(ctx context.Context, key string) (*GetObjectResponse, error)

+ func (s *S3Backend) GetObjectPresigned(ctx context.Context, key string) (string, error)

+ func (s *S3Backend) ListObjects(ctx context.Context) ([]*BlobInfo, error)

+ func (s *S3Backend) PutObject(ctx context.Context, params *PutObjectParams) (*PutObjectResponse, error)

+ func (s *S3Backend) PutObjectMultipart(ctx context.Context, params *PutObjectMultipartParams) (*PutObjectMultipartResponse, error)

+ func (s *S3Backend) PutObjectPresigned(ctx context.Context, key string) (string, error)

+ type S3Config struct

+ AccessKey string

+ BucketName string

+ Endpoint string

+ Region string

+ SecretKey string

+ UseAccelerate bool

+ func (c *S3Config) Validate() error

+ func (s3c S3Config) LogValue() slog.Value

+ type TimeFilter struct

+ After *time.Time

+ Before *time.Time