extractIDFromPath extracts the upload ID from a path, which has already been stripped of the base path (done by the user). Effectively, we only remove

invokeHookSync executes a hook of the given type with the given event data. If the hook was not executed properly (e.g. an error occurred or not handl

usesIETFDraft returns whether a HTTP request uses a supported version of the resumable upload draft from IETF (instead of tus v1) and support has been

GetObjectAttrs returns the associated attributes of a GCS object. See: https://pkg.go.dev/cloud.google.com/go/storage#ObjectAttrs

Setup is invoked once the hook backend is initalized.

uid returns a unique id. These ids consist of 128 bits from a cryptographically strong pseudo-random generator and are like uuids, but without the das

addIETFContentTypeHeader writes the Content-Type header depending on the interop version.

finishUploadIfComplete checks whether an upload is completed (i.e. upload offset matches upload size) and if so, it will call the data store's FinishU

DeleteObject deletes the object defined by GCSObjectParams

StageSentinelBlock stages a marker block so that a freshly created upload always has at least one uncommitted block (see GetOffset).

Make an absolute URLs to the given upload id. If the base path is absolute it will be prepended else the host and protocol from the request is used.

These helper functions convert an int block ID to a base-64 string and vice versa

checkForNotFoundError checks if the error indicates that a resource was not found. If so, we return the corresponding tusd error.

isIETFDraftUploadComplete returns whether a HTTP request upload is complete according to the set resumable upload draft version from IETF.

writeChunk reads the body from the requests r and appends it to the upload with the corresponding id. Afterwards, it will set the necessary response h

Commit the uploaded blocks to the BlockBlob

ComposeFrom composes multiple object types together,

ComposeObjects composes multiple GCS objects in to a single object. Since GCS limits composition to a max of 32 objects, additional logic has been add

DeleteObjectWithPrefix will delete objects who match the provided filter parameters.

FilterObjects returns a list of GCS object IDs that match the passed GCSFilterParams. It expects GCS objects to be of the format [uid]_[chunk_idx] whe

New creates a wrapper around the provided S3 API that logs all calls to `logger`

NewHandlerWithHooks creates a tusd request handler, whose notifcation channels and callbacks are configured to emit the hooks on the provided hook han

NewUnroutedHandler creates a new handler without routing using the given configuration. It exposes the http handlers which need to be combined with a

SetConcurrentPartUploads changes the limit on how many concurrent part uploads to S3 are allowed.

StopUpload interrupts a running upload from the server-side. This means that the current request body is closed, so that the data store does not get a

Compose takes a bucket name, a list of initial source names, and a destination string to compose multiple GCS objects together

createFile creates the file with the content. If the corresponding directory does not exist, it is created. If the file already exists, its content is

defaultBinPath returns the path to the file storing the binary data, if it is not customized using the pre-create hook.

emitFinishEvents calls the PreFinishResponseCallback function and sends the necessary message on the CompleteUpload channel.

filterContentType returns the values for the Content-Type and Content-Disposition headers for a given upload. These values should be used in responses

getIETFDraftUploadLimits returns the Upload-Limit header for a given upload according to the set resumable upload draft version from IETF.

incUploadsCreated increases the counter for completed uploads atomically by one.

infoPath returns the path to the .info file storing the file's info.

jsonEncode converts a value to a JSON string, handling errors gracefully

newContext constructs a new httpContext for the given request. This should only be done once per request and the context should be stored in the reque

newDelayedContext returns a context with delayed cancellation propagation. If the parent context is done, the new context will also be cancelled but o

sanitizeForLogging creates a copy of the input with large values removed that we don't want to print in the logs.

terminateUpload passes a given upload to the DataStore's Terminater, send the corresponding upload info on the TerminatedUploads channnel and updates

validateUploadId checks whether an ID included in a FileInfoChanges struct is allowed.

writeInfo updates the entire information. Everything will be overwritten.

Acquire will block until the semaphore can be acquired.

CleanupPlugins closes the connections to all plugins and ensures that their processes are properly stopped. You must call this function when the main

DelFile terminates an upload permanently.

EXPECT returns an object that allows the caller to indicate expected use.

GetFile handles requests to download a file using a GET request. This is not part of the specification.

GetObjectSize returns the byte length of the specified GCS object.

HeadFile returns the length and offset for the HEAD request

Load retrieves the map of the counter pointers atomically

Middleware checks various aspects of the request and ensures that it conforms with the spec. Also handles method overriding for clients which cannot m

New creates a new collector which read froms the provided Metrics struct.

New creates a semaphore with the given concurrency limit.

New Azure service for communication to Azure BlockBlob Storage API

NewMockFullDataStore creates a new mock instance.

NewMockHookHandler creates a new mock instance.

NewMockS3API creates a new mock instance.

Binds to a UNIX socket. If the file already exists, try to remove it before binding again. This logic is borrowed from Gunicorn (see https://github.co

PatchFile adds a chunk to an upload. This operation is only allowed if enough space in the upload is left.

PostFile creates a new file upload using the datastore after validating the length and parsing the metadata.

PostFile creates a new file upload using the datastore after validating the length and parsing the metadata.

ReadObject reads a GCSObjectParams, returning a GCSReader object if successful, and an error otherwise

Release frees the acquired slot in the semaphore.

SerializeMetadataHeader serializes a map of strings into the Upload-Metadata header format used in the response for HEAD requests. e.g. Upload-Metadat