blob

type BlobBackend interface {
	GetObject(ctx context.Context, key string) (*GetObjectResponse, error)
	GetObjectPresigned(ctx context.Context, key string) (string, error)
	PutObject(ctx context.Context, params *PutObjectParams) (*PutObjectResponse, error)
	PutObjectPresigned(ctx context.Context, key string) (string, error)
	PutObjectMultipart(ctx context.Context, params *PutObjectMultipartParams) (*PutObjectMultipartResponse, error)
	CompleteMultipartUpload(ctx context.Context, params *CompleteMultipartUploadParams) (*PutObjectResponse, error)
	CopyObject(ctx context.Context, params *CopyObjectParams) (*CopyObjectResponse, error)
	DeleteObject(ctx context.Context, key string) (bool, error)
	ListObjects(ctx context.Context) ([]*BlobInfo, error)
	Delegate() any
	// contains filtered or unexported methods
}

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

type BlobInfo struct {
	Key          string `json:"key" db:"key"`
	ETag         string `json:"etag" db:"etag"`
	Size         int64  `json:"size" db:"size"`
	LastModified string `json:"lastModified" db:"last_modified"`
}

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

type CompleteMultipartUploadParams struct {
	Key      string           `json:"key"`
	UploadID string           `json:"uploadId"`
	Parts    []*CompletedPart `json:"parts"`
}

type CompletedPart struct {
	PartNumber int    `json:"partNumber"`
	ETag       string `json:"etag"`
}

type CopyObjectParams struct {
	SourceKey      string
	DestinationKey string
}

type CopyObjectResponse struct {
	ETag         string
	LastModified time.Time
}

type GetObjectResponse struct {
	Body         io.ReadCloser
	ETag         string
	Size         int64
	LastModified time.Time
}

type IBlobIndex interface {
	Get(key string) (*BlobInfo, bool)
	Set(blob *BlobInfo) error
	SetMany(blobs []*BlobInfo) error
	Remove(key string) error
	List() ([]*BlobInfo, error)
	Iter() iter.Seq[*BlobInfo]
	Count() int
	FilterByKeyGlob(pattern string) ([]*BlobInfo, error)
	FilterByPrefix(prefix string) ([]*BlobInfo, error)
	FilterBySuffix(suffix string) ([]*BlobInfo, error)
	FilterByTime(filter TimeFilter) ([]*BlobInfo, error)
	FilterAfterTime(after time.Time) ([]*BlobInfo, error)
	FilterBeforeTime(before time.Time) ([]*BlobInfo, error)
}

type PutObjectMultipartParams struct {
	Key   string `json:"key" binding:"required"`
	Parts uint16 `json:"parts" binding:"required"`
}

type PutObjectMultipartResponse struct {
	Key      string   `json:"key"`
	UploadID string   `json:"uploadId"`
	URLs     []string `json:"urls"`
}

type PutObjectParams struct {
	Key  string
	ETag string
	Size int64
	Body io.Reader
}

type PutObjectPresignedResponse struct {
	Name          string   `json:"name" binding:"required"`
	UploadID      string   `json:"uploadId"`
	PresignedURLs []string `json:"presignedUrls"`
}

type PutObjectResponse struct {
	Key          string
	Version      string
	ETag         string
	Size         int64
	LastModified time.Time
}

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

type S3Config struct {
	BucketName    string `mapstructure:"bucket_name"`
	Region        string `mapstructure:"region"`
	AccessKey     string `mapstructure:"access_key"`
	SecretKey     string `mapstructure:"secret_key"`
	Endpoint      string `mapstructure:"endpoint"`
	UseAccelerate bool   `mapstructure:"use_accelerate"`
}

type TimeFilter struct {
	Before *time.Time
	After  *time.Time
}