storage

type Bucket interface {
	Get(ctx context.Context, key string) (*Object, error)
	Head(ctx context.Context, key string) (*ObjectInfo, error)
	Put(ctx context.Context, key string, body io.Reader, options PutOptions) error
	Delete(ctx context.Context, key string) error
	List(ctx context.Context, options ListOptions) (*ListPage, error)
	Presign(ctx context.Context, key string, options PresignOptions) (*url.URL, error)
}

type Factory func(ctx context.Context, config pwruntime.StorageBucketConfig) (Bucket, error)

type ListOptions struct {
	Prefix string
	// Limit bounds one page; zero takes the backend's default.
	Limit int
	// Cursor continues a listing from a previous page's NextCursor.
	Cursor string
}

type ListPage struct {
	Objects []ObjectInfo
	// NextCursor continues the listing when non-empty.
	NextCursor string
}

type Object struct {
	ObjectInfo
	Body io.ReadCloser
}

type ObjectInfo struct {
	Key          string
	Size         int64
	ETag         string
	ContentType  string
	LastModified time.Time
	// Metadata is user metadata, without any backend prefix.
	Metadata map[string]string
}

type PresignOptions struct {
	// Method is GET, PUT, HEAD or DELETE; empty means GET.
	Method string
	// Expires bounds the URL's life; zero takes the backend's default, and
	// more than a backend accepts is an error rather than a clamp.
	Expires time.Duration
	// ContentType, when set, is signed on a PUT, so the sender must send
	// exactly it.
	ContentType string
	// Headers are further request headers the sender must reproduce, such
	// as Content-Disposition on a PUT.
	Headers map[string]string
}

type PutOptions struct {
	// ContentType is the media type served back with the object. It is
	// required; a store that guesses from a key would guess differently on
	// two backends.
	ContentType string
	// ContentLength is the body's size when known, which lets a backend
	// stream rather than buffer.
	ContentLength int64
	// Metadata is user metadata kept beside the object.
	Metadata map[string]string
}

type SelfServing interface {
	VerifySignedRequest(r *http.Request, key string) (method string, err error)
}