mirror of
https://code.tvl.fyi/depot.git:/tools/nixery.git
synced 2024-10-23 12:53:04 +00:00
94fb63b5eb
Previously background contexts where created where necessary (e.g. in GCS interactions). Should I begin to use request timeouts or other context-dependent things in the future, it's useful to have the actual HTTP request context around. This threads the request context through the application to all places that need it.
38 lines
1.2 KiB
Go
38 lines
1.2 KiB
Go
// Package storage implements an interface that can be implemented by
|
|
// storage backends, such as Google Cloud Storage or the local
|
|
// filesystem.
|
|
package storage
|
|
|
|
import (
|
|
"context"
|
|
"io"
|
|
"net/http"
|
|
)
|
|
|
|
type Persister = func(io.Writer) (string, int64, error)
|
|
|
|
type Backend interface {
|
|
// Name returns the name of the storage backend, for use in
|
|
// log messages and such.
|
|
Name() string
|
|
|
|
// Persist provides a user-supplied function with a writer
|
|
// that stores data in the storage backend.
|
|
//
|
|
// It needs to return the SHA256 hash of the data written as
|
|
// well as the total number of bytes, as those are required
|
|
// for the image manifest.
|
|
Persist(context.Context, string, Persister) (string, int64, error)
|
|
|
|
// Fetch retrieves data from the storage backend.
|
|
Fetch(ctx context.Context, path string) (io.ReadCloser, error)
|
|
|
|
// Move renames a path inside the storage backend. This is
|
|
// used for staging uploads while calculating their hashes.
|
|
Move(ctx context.Context, old, new string) error
|
|
|
|
// Serve provides a handler function to serve HTTP requests
|
|
// for layers in the storage backend.
|
|
ServeLayer(digest string, r *http.Request, w http.ResponseWriter) error
|
|
}
|