integration

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

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

type CompositeProvider struct {
	ContentProvider
	MetadataProvider
	ListProvider
	ObjectResolver
}

type ContentProvider interface {
	// GetContent retrieves the content of an S3 object.
	GetContent(ctx context.Context, ref *ObjectReference) ([]byte, error)

	// GetContentStream retrieves the content as a stream for large objects.
	GetContentStream(ctx context.Context, ref *ObjectReference) (io.ReadCloser, error)

	// GetContentType retrieves only the content type without downloading.
	GetContentType(ctx context.Context, ref *ObjectReference) (string, error)

	// GetSize retrieves the object size in bytes.
	GetSize(ctx context.Context, ref *ObjectReference) (int64, error)
}

type ContentProviderFunc func(ctx context.Context, ref *ObjectReference) ([]byte, error)

type ContentWriter interface {
	// PutContent uploads content to an S3 object.
	PutContent(ctx context.Context, ref *ObjectReference, content []byte, contentType string) error

	// PutContentStream uploads content from a stream.
	PutContentStream(ctx context.Context, ref *ObjectReference, reader io.Reader, size int64, contentType string) error
}

type DefaultResolver struct {
	// DefaultConnection is used when no connection is specified.
	DefaultConnection string

	// DefaultBucket is used when only a key is provided.
	DefaultBucket string
}

type ListProvider interface {
	// ListObjects lists objects in a bucket with optional prefix.
	ListObjects(ctx context.Context, connection, bucket, prefix string, maxKeys int) ([]ObjectMetadata, error)

	// ListBuckets lists all accessible buckets.
	ListBuckets(ctx context.Context, connection string) ([]string, error)
}

type MetadataProvider interface {
	// GetMetadata retrieves metadata for an S3 object.
	GetMetadata(ctx context.Context, ref *ObjectReference) (*ObjectMetadata, error)

	// Exists checks if an object exists.
	Exists(ctx context.Context, ref *ObjectReference) (bool, error)

	// GetETag retrieves the ETag of an object.
	GetETag(ctx context.Context, ref *ObjectReference) (string, error)
}

type ObjectExistsFunc func(ctx context.Context, ref *ObjectReference) (bool, error)

type ObjectMetadata struct {
	// Reference is the object reference.
	Reference *ObjectReference

	// Size is the object size in bytes.
	Size int64

	// ContentType is the MIME type of the object.
	ContentType string

	// LastModified is when the object was last modified.
	LastModified time.Time

	// ETag is the entity tag (typically an MD5 hash).
	ETag string

	// CustomMetadata contains user-defined metadata.
	CustomMetadata map[string]string

	// StorageClass is the S3 storage class.
	StorageClass string

	// VersionID is the version ID (if versioning is enabled).
	VersionID string
}

type ObjectReference struct {
	// Connection is the name of the S3 connection (empty for default).
	Connection string

	// Bucket is the S3 bucket name.
	Bucket string

	// Key is the object key (path).
	Key string
}

type ObjectResolver interface {
	// ParseURI parses an S3 URI (e.g., "s3://bucket/key") into an ObjectReference.
	ParseURI(uri string) (*ObjectReference, error)

	// ParseARN parses an S3 ARN (e.g., "arn:aws:s3:::bucket/key") into an ObjectReference.
	ParseARN(arn string) (*ObjectReference, error)

	// Resolve resolves a string that could be a URI, ARN, or simple path.
	Resolve(ref string) (*ObjectReference, error)
}

type ResolverMiddleware func(ObjectResolver) ObjectResolver

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

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