objectstore

type Client interface {
	Bucket() string
	BucketExists(ctx context.Context) (bool, error)
	EnsureBucket(ctx context.Context) error
	PutObject(ctx context.Context, key string, body io.Reader, size int64, opts PutOptions) (ObjectInfo, error)
	GetObject(ctx context.Context, key string, opts GetOptions) (io.ReadCloser, ObjectInfo, error)
	DeleteObject(ctx context.Context, key string) error
	StatObject(ctx context.Context, key string) (ObjectInfo, error)
	ListObjects(ctx context.Context, opts ListOptions) ([]ObjectInfo, error)
	CopyObject(ctx context.Context, srcKey, dstKey string, opts PutOptions) (ObjectInfo, error)
	PresignPut(ctx context.Context, key string, ttl time.Duration) (*url.URL, error)
	PresignGet(ctx context.Context, key string, ttl time.Duration) (*url.URL, error)
}

type GetOptions struct {
	Offset int64
	Length int64
}

type ListOptions struct {
	Prefix    string
	Recursive bool
	Limit     int
}

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

type MinIOConfig struct {
	Provider         string `json:"provider" yaml:"provider"`
	Endpoint         string `json:"endpoint" yaml:"endpoint"`
	AccessKey        string `json:"access_key" yaml:"access_key"`
	SecretKey        string `json:"secret_key" yaml:"secret_key"`
	SessionToken     string `json:"session_token" yaml:"session_token"`
	Bucket           string `json:"bucket" yaml:"bucket"`
	Region           string `json:"region" yaml:"region"`
	UseSSL           bool   `json:"use_ssl" yaml:"use_ssl"`
	AutoCreateBucket bool   `json:"auto_create_bucket" yaml:"auto_create_bucket"`
}

type ObjectInfo struct {
	Bucket       string
	Key          string
	Size         int64
	ETag         string
	ContentType  string
	LastModified time.Time
}

type Option func(*options)

type PutOptions struct {
	ContentType  string
	Metadata     map[string]string
	CacheControl string
	SSE          any
}