object

type CommonPrefix struct {
	Prefix string `xml:"Prefix"`
}

type CopyOption func(*CopyOptions)

type CopyOptions struct {
	// Source version ID
	SourceVersionID string

	// Destination metadata and tags
	UserMetadata map[string]string
	UserTags     map[string]string

	// Replace metadata and/or tagging instead of copying existing
	ReplaceMetadata bool
	ReplaceTagging  bool

	// Object header overrides
	ContentType        string
	ContentEncoding    string
	ContentDisposition string
	CacheControl       string
	Expires            time.Time

	// Storage class
	StorageClass string

	// Conditional copy headers
	MatchETag     string
	NotMatchETag  string
	MatchModified time.Time
	NotModified   time.Time

	// Custom headers
	CustomHeaders http.Header

	// Use S3 Accelerate endpoint
	UseAccelerate bool
}

type DeleteOption func(*DeleteOptions)

type DeleteOptions struct {
	// Version ID
	VersionID string

	// Force delete when possible
	ForceDelete bool

	// Custom headers
	CustomHeaders http.Header
}

type DestinationInfo struct {
	Bucket string
	Object string
}

type GetOption func(*GetOptions)

type GetOptions struct {
	// Range header
	RangeStart int64
	RangeEnd   int64
	SetRange   bool

	// Version ID
	VersionID string

	// Conditional headers
	MatchETag     string
	NotMatchETag  string
	MatchModified time.Time
	NotModified   time.Time

	// Custom headers
	CustomHeaders http.Header

	// Response header overrides (query params like response-content-type)
	ResponseHeaderOverrides url.Values

	// Use S3 Accelerate endpoint
	UseAccelerate bool

	// Server-side encryption for encrypted objects
	SSE sse.Encrypter

	// Client-side encryption helper
	CSE *cse.Client

	// SSE-C headers for encrypted objects (deprecated, use SSE field)
	SSECustomerAlgorithm string
	SSECustomerKey       string
	SSECustomerKeyMD5    string
}

type LegalHoldOption func(*LegalHoldOptions)

type LegalHoldOptions struct {
	VersionID string
}

type ListBucketV2Result struct {
	XMLName               xml.Name           `xml:"ListBucketResult"`
	Name                  string             `xml:"Name"`
	Prefix                string             `xml:"Prefix"`
	KeyCount              int                `xml:"KeyCount"`
	MaxKeys               int                `xml:"MaxKeys"`
	Delimiter             string             `xml:"Delimiter"`
	IsTruncated           bool               `xml:"IsTruncated"`
	Contents              []types.ObjectInfo `xml:"Contents"`
	CommonPrefixes        []CommonPrefix     `xml:"CommonPrefixes"`
	ContinuationToken     string             `xml:"ContinuationToken"`
	NextContinuationToken string             `xml:"NextContinuationToken"`
	StartAfter            string             `xml:"StartAfter"`
}

type ListMultipartUploadsOptions struct {
	Prefix         string
	Delimiter      string
	KeyMarker      string
	UploadIDMarker string
	MaxUploads     int
}

type ListMultipartUploadsResult struct {
	XMLName            xml.Name          `xml:"ListMultipartUploadsResult"`
	Bucket             string            `xml:"Bucket"`
	KeyMarker          string            `xml:"KeyMarker"`
	UploadIDMarker     string            `xml:"UploadIdMarker"`
	NextKeyMarker      string            `xml:"NextKeyMarker"`
	NextUploadIDMarker string            `xml:"NextUploadIdMarker"`
	MaxUploads         int               `xml:"MaxUploads"`
	IsTruncated        bool              `xml:"IsTruncated"`
	Uploads            []MultipartUpload `xml:"Upload"`
	CommonPrefixes     []CommonPrefix    `xml:"CommonPrefixes"`
}

type ListOption func(*ListOptions)

type ListOptions struct {
	// Prefix filter
	Prefix string

	// Recursive listing
	Recursive bool

	// StopChan is an optional signal channel to stop listing early
	StopChan <-chan struct{}

	// Max keys
	MaxKeys int

	// Start token
	StartAfter string

	// Use ListObjectsV2
	UseV2 bool

	// Include object versions
	WithVersions bool

	// Include object metadata
	WithMetadata bool

	// Custom headers
	CustomHeaders http.Header

	// Use S3 Accelerate endpoint
	UseAccelerate bool
}

type ListPartsOption func(*ListPartsOptions)

type ListPartsOptions struct {
	PartNumberMarker int
	MaxParts         int
}

type ListPartsResult struct {
	XMLName              xml.Name           `xml:"ListPartsResult"`
	Bucket               string             `xml:"Bucket"`
	Key                  string             `xml:"Key"`
	UploadID             string             `xml:"UploadId"`
	PartNumberMarker     int                `xml:"PartNumberMarker"`
	NextPartNumberMarker int                `xml:"NextPartNumberMarker"`
	MaxParts             int                `xml:"MaxParts"`
	IsTruncated          bool               `xml:"IsTruncated"`
	Initiator            UserIdentity       `xml:"Initiator"`
	Owner                UserIdentity       `xml:"Owner"`
	StorageClass         string             `xml:"StorageClass"`
	Parts                []types.ObjectPart `xml:"Part"`
}

type MultipartListOption func(*ListMultipartUploadsOptions)

type MultipartUpload struct {
	Key          string       `xml:"Key"`
	UploadID     string       `xml:"UploadId"`
	Initiator    UserIdentity `xml:"Initiator"`
	Owner        UserIdentity `xml:"Owner"`
	StorageClass string       `xml:"StorageClass"`
	Initiated    string       `xml:"Initiated"`
}

type PresignOption func(*PresignOptions)

type PresignOptions struct {
	Headers     http.Header
	QueryValues url.Values
}

type PutOption func(*PutOptions)

type PutOptions struct {

	// Content-Type
	ContentType string

	// Content-Encoding
	ContentEncoding string

	// Content-Disposition
	ContentDisposition string

	// Content-Language
	ContentLanguage string

	// Cache-Control
	CacheControl string

	// Expiration time
	Expires time.Time

	// User metadata
	UserMetadata map[string]string

	// User tags
	UserTags map[string]string

	// Storage class
	StorageClass string

	// Checksum mode and algorithm
	ChecksumMode      string
	ChecksumAlgorithm string

	// Custom headers
	CustomHeaders http.Header

	// Whether to send Content-MD5
	SendContentMD5 bool

	// Disable Content-SHA256
	DisableContentSHA256 bool

	// Server-side encryption
	SSE sse.Encrypter

	// Client-side encryption helper
	CSE *cse.Client

	// SSE-S3 / SSE-C options (deprecated, use SSE field)
	SSECustomerAlgorithm string
	SSECustomerKey       string
	SSECustomerKeyMD5    string

	// Multipart part size
	PartSize uint64

	// Number of concurrent uploads
	NumThreads uint

	// Use S3 Accelerate endpoint
	UseAccelerate bool
	// contains filtered or unexported fields
}

type RetentionOption func(*RetentionOptions)

type RetentionOptions struct {
	VersionID        string
	GovernanceBypass bool
}

type Service interface {
	// Put uploads an object
	Put(ctx context.Context, bucketName, objectName string, reader io.Reader, objectSize int64, opts ...PutOption) (types.UploadInfo, error)

	// Get downloads an object
	Get(ctx context.Context, bucketName, objectName string, opts ...GetOption) (io.ReadCloser, types.ObjectInfo, error)

	// FPut uploads a file from a local path
	FPut(ctx context.Context, bucketName, objectName, filePath string, opts ...PutOption) (types.UploadInfo, error)

	// FGet downloads an object to a local file path
	FGet(ctx context.Context, bucketName, objectName, filePath string, opts ...GetOption) (types.ObjectInfo, error)

	// Stat retrieves object info
	Stat(ctx context.Context, bucketName, objectName string, opts ...StatOption) (types.ObjectInfo, error)

	// Delete removes an object
	Delete(ctx context.Context, bucketName, objectName string, opts ...DeleteOption) error

	// List lists objects
	List(ctx context.Context, bucketName string, opts ...ListOption) <-chan types.ObjectInfo

	// ListVersions lists object versions and delete markers
	ListVersions(ctx context.Context, bucketName string, opts ...ListOption) <-chan types.ObjectInfo

	// Copy copies an object
	Copy(ctx context.Context, destBucket, destObject, srcBucket, srcObject string, opts ...CopyOption) (types.CopyInfo, error)

	// Compose creates an object by composing source objects
	Compose(ctx context.Context, dst DestinationInfo, sources []SourceInfo, opts ...PutOption) (types.UploadInfo, error)

	// Append appends data to an object at a specific offset
	Append(ctx context.Context, bucketName, objectName string, reader io.Reader, objectSize int64, offset int64, opts ...PutOption) (types.UploadInfo, error)

	// Select queries object content using S3 Select
	Select(ctx context.Context, bucketName, objectName string, opts s3select.Options) (*s3select.Results, error)

	// Restore initiates a restore request for an archived object
	Restore(ctx context.Context, bucketName, objectName, versionID string, req restore.RestoreRequest) error

	// PresignedPostPolicy creates a presigned POST policy for browser uploads
	PresignedPostPolicy(ctx context.Context, policy *policy.PostPolicy) (*url.URL, map[string]string, error)

	// PresignGet creates a presigned GET URL with optional signed headers
	PresignGet(ctx context.Context, bucketName, objectName string, expires time.Duration, reqParams url.Values, opts ...PresignOption) (*url.URL, http.Header, error)

	// PresignHead creates a presigned HEAD URL with optional signed headers
	PresignHead(ctx context.Context, bucketName, objectName string, expires time.Duration, reqParams url.Values, opts ...PresignOption) (*url.URL, http.Header, error)

	// PresignPut creates a presigned PUT URL with optional signed headers
	PresignPut(ctx context.Context, bucketName, objectName string, expires time.Duration, reqParams url.Values, opts ...PresignOption) (*url.URL, http.Header, error)

	// ListMultipartUploads lists in-progress multipart uploads for a bucket
	ListMultipartUploads(ctx context.Context, bucketName string, opts ...MultipartListOption) (ListMultipartUploadsResult, error)

	// ListObjectParts lists parts for a specific multipart upload
	ListObjectParts(ctx context.Context, bucketName, objectName, uploadID string, opts ...ListPartsOption) (ListPartsResult, error)

	// SetTagging sets object tags
	SetTagging(ctx context.Context, bucketName, objectName string, tags map[string]string) error

	// GetTagging retrieves object tags
	GetTagging(ctx context.Context, bucketName, objectName string) (map[string]string, error)

	// DeleteTagging deletes object tags
	DeleteTagging(ctx context.Context, bucketName, objectName string) error

	// GetACL retrieves object ACL
	GetACL(ctx context.Context, bucketName, objectName string) (acl.ACL, error)

	// SetACL sets object ACL
	SetACL(ctx context.Context, bucketName, objectName string, policy acl.ACL) error

	// SetLegalHold sets legal hold status for an object
	SetLegalHold(ctx context.Context, bucketName, objectName string, hold objectlock.LegalHoldStatus, opts ...LegalHoldOption) error

	// GetLegalHold retrieves legal hold status for an object
	GetLegalHold(ctx context.Context, bucketName, objectName string, opts ...LegalHoldOption) (objectlock.LegalHoldStatus, error)

	// SetRetention sets retention mode and retain-until date for an object
	SetRetention(ctx context.Context, bucketName, objectName string, mode objectlock.RetentionMode, retainUntil time.Time, opts ...RetentionOption) error

	// GetRetention retrieves retention configuration for an object
	GetRetention(ctx context.Context, bucketName, objectName string, opts ...RetentionOption) (objectlock.RetentionMode, time.Time, error)
}

type SourceInfo struct {
	Bucket string
	Object string

	VersionID string

	RangeStart int64
	RangeEnd   int64
	RangeSet   bool

	MatchETag     string
	NotMatchETag  string
	MatchModified time.Time
	NotModified   time.Time
}

type StatOption func(*StatOptions)

type StatOptions struct {
	// Version ID
	VersionID string

	// Custom headers
	CustomHeaders http.Header

	// Use S3 Accelerate endpoint
	UseAccelerate bool
}

type UserIdentity struct {
	ID          string `xml:"ID"`
	DisplayName string `xml:"DisplayName"`
}