MCPcopy Index your code

hub / github.com/tus/tusd / functions

Functions707 in github.com/tus/tusd

↓ 1 callersFunctionServe
Setups the different components, starts a Listener and give it to http.Serve(). By default it will bind to the specified host/port, unless a UNIX soc
cmd/tusd/cli/serve.go:32
↓ 1 callersFunctionSetEnabledHooks
()
cmd/tusd/cli/flags.go:267
↓ 1 callersMethodSetObjectMetadata
SetObjectMetadata reads a GCSObjectParams and a map of metadata, returning a nil on success and an error otherwise
pkg/gcsstore/gcsservice.go:283
↓ 1 callersFunctionSetupHookMetrics
()
pkg/hooks/hooks.go:189
↓ 1 callersFunctionSetupMetrics
(mux *http.ServeMux, handler *handler.Handler)
cmd/tusd/cli/metrics.go:19
↓ 1 callersFunctionSetupPprof
(globalMux *http.ServeMux)
cmd/tusd/cli/pprof.go:15
↓ 1 callersFunctionSetupStructuredLogger
()
cmd/tusd/cli/log.go:13
↓ 1 callersFunctionShowVersion
()
cmd/tusd/cli/version.go:11
↓ 1 callersMethodSupportedExtensions
SupportedExtensions returns a comma-separated list of the supported tus extensions. The availability of an extension usually depends on whether the pr
pkg/handler/unrouted_handler.go:159
↓ 1 callersMethodWriteObject
Write object writes the file set out by the GCSObjectParams
pkg/gcsstore/gcsservice.go:298
↓ 1 callersMethodacquireUploadSemaphore
()
pkg/s3store/s3store.go:1252
↓ 1 callersMethodappendTo
(file *os.File)
pkg/filestore/filestore.go:282
↓ 1 callersFunctionblockIDBase64ToBinary
(blockID *string)
pkg/azurestore/azureservice.go:329
↓ 1 callersFunctionblockIDBase64ToInt
(blockID *string)
pkg/azurestore/azureservice.go:341
↓ 1 callersFunctionblockIDBinaryToBase64
=== Helper Functions === These helper functions convert a binary block ID to a base-64 string and vice versa NOTE: The blockID must be <= 64 bytes and
pkg/azurestore/azureservice.go:325
↓ 1 callersMethodbytesRead
()
pkg/handler/body_reader.go:131
↓ 1 callersMethodcloseUnreadFiles
closeUnreadFiles should always be called by the consumer to ensure that the channels are properly closed and emptied.
pkg/s3store/s3store_part_producer.go:50
↓ 1 callersMethodcloseWithError
(err error)
pkg/handler/body_reader.go:135
↓ 1 callersMethodconcatUsingDownload
(ctx context.Context, partialUploads []handler.Upload)
pkg/s3store/s3store.go:925
↓ 1 callersMethodconcatUsingMultipart
(ctx context.Context, partialUploads []handler.Upload)
pkg/s3store/s3store.go:983
↓ 1 callersMethoddeleteIncompletePartForUpload
(ctx context.Context, uploadId string)
pkg/s3store/s3store.go:1149
↓ 1 callersMethoddownloadIncompletePartForUpload
(ctx context.Context, uploadId string)
pkg/s3store/s3store.go:1073
↓ 1 callersFunctionextractIDFromURL
extractIDFromURL extracts the upload ID from a full URL or a full path (including the base path). For example: https://example.com/files/1234/5678 -
pkg/handler/unrouted_handler.go:1687
↓ 1 callersMethodfetchInfo
(ctx context.Context)
pkg/s3store/s3store.go:641
↓ 1 callersFunctionfile_pkg_hooks_grpc_proto_hook_proto_init
()
pkg/hooks/grpc/proto/hook.pb.go:753
↓ 1 callersFunctiongetCorsConfig
()
cmd/tusd/cli/serve.go:284
↓ 1 callersFunctiongetHeader
(httpHeader http.Header)
pkg/hooks/grpc/grpc.go:137
↓ 1 callersFunctiongetHookHandler
(config *handler.Config)
cmd/tusd/cli/hooks.go:14
↓ 1 callersFunctiongetHostAndProtocol
getHostAndProtocol extracts the host and used protocol (either HTTP or HTTPS) from the given request. If `allowForwarded` is set, the X-Forwarded-Host
pkg/handler/unrouted_handler.go:1348
↓ 1 callersFunctiongetIETFDraftUploadLength
getIETFDraftUploadLength returns the length of an upload as defined in the resumable upload draft from IETF. This can either be in the Upload-Length h
pkg/handler/unrouted_handler.go:1537
↓ 1 callersMethodgetIncompletePartForUpload
(ctx context.Context, uploadId string)
pkg/s3store/s3store.go:1107
↓ 1 callersFunctiongetRequestId
getRequestId returns the value of the X-Request-ID header, if available, and also takes care of truncating the input.
pkg/handler/unrouted_handler.go:1698
↓ 1 callersFunctiongetTusdExtraArgs
getTusdExtraArgs returns extra tusd flags from TUSD_EXTRA_ARGS (e.g. for S3/Azure backends in CI).
internal/e2e/e2e_test.go:838
↓ 1 callersMethodhasError
()
pkg/handler/body_reader.go:119
↓ 1 callersMethodheadIncompletePartForUpload
(ctx context.Context, uploadId string)
pkg/s3store/s3store.go:1120
↓ 1 callersMethodincBytesReceived
incBytesReceived increases the number of received bytes atomically be the specified number.
pkg/handler/metrics.go:41
↓ 1 callersMethodincErrorsTotal
incErrorsTotal increases the counter for this error atomically by one.
pkg/handler/metrics.go:34
↓ 1 callersMethodincRequestsTotal
incRequestsTotal increases the counter for this request method atomically by one. The method must be one of GET, HEAD, POST, PATCH, DELETE.
pkg/handler/metrics.go:27
↓ 1 callersMethodincUploadsFinished
incUploadsFinished increases the counter for finished uploads atomically by one.
pkg/handler/metrics.go:46
↓ 1 callersMethodincUploadsTerminated
incUploadsTerminated increases the counter for completed uploads atomically by one.
pkg/handler/metrics.go:56
↓ 1 callersMethodlistAllParts
(ctx context.Context, objectId string, multipartId string)
pkg/s3store/s3store.go:1038
↓ 1 callersFunctionmarshal
(hookReq hooks.HookRequest)
pkg/hooks/grpc/grpc.go:110
↓ 1 callersFunctionnewBodyReader
(c *httpContext, maxSize int64)
pkg/handler/body_reader.go:39
↓ 1 callersFunctionnewErrorsTotalMap
()
pkg/handler/metrics.go:89
↓ 1 callersFunctionnewMetrics
()
pkg/handler/metrics.go:60
↓ 1 callersMethodnextPart
(size int64)
pkg/s3store/s3store_part_producer.go:82
↓ 1 callersFunctionparseConcat
Parse the Upload-Concat header, e.g. Upload-Concat: partial Upload-Concat: final;http://tus.io/files/a /files/b/
pkg/handler/unrouted_handler.go:1635
↓ 1 callersFunctionpostReceiveCallback
(event handler.HookEvent, hookHandler HookHandler)
pkg/hooks/hooks.go:158
↓ 1 callersFunctionpreCreateCallback
(event handler.HookEvent, hookHandler HookHandler)
pkg/hooks/hooks.go:106
↓ 1 callersFunctionpreFinishCallback
(event handler.HookEvent, hookHandler HookHandler)
pkg/hooks/hooks.go:128
↓ 1 callersFunctionpreTerminateCallback
(event handler.HookEvent, hookHandler HookHandler)
pkg/hooks/hooks.go:138
↓ 1 callersMethodputIncompletePartForUpload
(ctx context.Context, uploadId string, file io.ReadSeeker)
pkg/s3store/s3store.go:1138
↓ 1 callersMethodputPartForUpload
(ctx context.Context, uploadPartInput *s3.UploadPartInput, file io.ReadSeeker, size int64)
pkg/s3store/s3store.go:567
↓ 1 callersMethodrecursiveCompose
(ctx context.Context, srcs []string, params GCSComposeParams, lvl int)
pkg/gcsstore/gcsservice.go:201
↓ 1 callersMethodretrievePointerFor
retrievePointerFor returns (after creating it if necessary) the pointer to the counter for the error.
pkg/handler/metrics.go:98
↓ 1 callersMethodsendProgressMessages
sendProgressMessage will send a notification over the UploadProgress channel indicating how much data has been transfered to the server. It will stop
pkg/handler/unrouted_handler.go:1317
↓ 1 callersFunctionserve
()
examples/hooks/grpc/server.py:59
↓ 1 callersFunctionserveTLS
(server *http.Server, listener net.Listener)
cmd/tusd/cli/serve.go:189
↓ 1 callersFunctionsetIETFDraftUploadComplete
setIETFDraftUploadComplete sets the Upload-Complete (Upload-Incomplete) to the provided value, depending on the interop version used in the request.
pkg/handler/unrouted_handler.go:1515
↓ 1 callersFunctionsetupSignalHandler
(server *http.Server, cancelServerCtx context.CancelCauseFunc)
cmd/tusd/cli/serve.go:233
↓ 1 callersMethodsizeOfUploads
The get sum of all sizes for a list of upload ids while checking whether all of these uploads are finished yet. This is used to calculate the size of
pkg/handler/unrouted_handler.go:1393
↓ 1 callersFunctionsplitIds
(id string)
pkg/s3store/s3store.go:1159
↓ 1 callersFunctionunmarshal
(res *pb.HookResponse)
pkg/hooks/grpc/grpc.go:147
↓ 1 callersMethoduploadParts
(ctx context.Context, offset int64, src io.Reader)
pkg/s3store/s3store.go:450
↓ 1 callersMethodvalidateNewUploadLengthHeaders
Verify that the Upload-Length and Upload-Defer-Length headers are acceptable for creating a new upload
pkg/handler/unrouted_handler.go:1421
↓ 1 callersMethodwriteInfo
(ctx context.Context, id string, info handler.FileInfo)
pkg/gcsstore/gcsstore.go:233
↓ 1 callersMethodwriteTo
writeTo writes the HTTP response into w, as specified by the fields in resp.
pkg/handler/http.go:34
MethodAbortMultipartUpload
AbortMultipartUpload mocks base method.
pkg/s3store/s3store_mock_test.go:39
MethodAbortMultipartUpload
AbortMultipartUpload indicates an expected call of AbortMultipartUpload.
pkg/s3store/s3store_mock_test.go:52
MethodAbortMultipartUpload
AbortMultipartUpload implements the s3store.S3API interface
internal/s3log/s3log.go:136
MethodAbortMultipartUpload
AbortMultipartUpload mocks base method.
internal/s3log/s3log_mock_test.go:39
MethodAbortMultipartUpload
AbortMultipartUpload indicates an expected call of AbortMultipartUpload.
internal/s3log/s3log_mock_test.go:52
MethodAsConcatableUpload
(upload handler.Upload)
pkg/filestore/filestore.go:185
MethodAsConcatableUpload
AsConcatableUpload mocks base method.
pkg/handler/handler_mock_test.go:40
MethodAsConcatableUpload
AsConcatableUpload indicates an expected call of AsConcatableUpload.
pkg/handler/handler_mock_test.go:48
MethodAsConcatableUpload
(upload handler.Upload)
pkg/s3store/s3store.go:383
MethodAsLengthDeclarableUpload
(upload handler.Upload)
pkg/azurestore/azurestore.go:155
MethodAsLengthDeclarableUpload
(upload handler.Upload)
pkg/filestore/filestore.go:181
MethodAsLengthDeclarableUpload
AsLengthDeclarableUpload mocks base method.
pkg/handler/handler_mock_test.go:54
MethodAsLengthDeclarableUpload
AsLengthDeclarableUpload indicates an expected call of AsLengthDeclarableUpload.
pkg/handler/handler_mock_test.go:62
MethodAsLengthDeclarableUpload
(upload handler.Upload)
pkg/s3store/s3store.go:379
MethodAsServableUpload
(upload handler.Upload)
pkg/filestore/filestore.go:189
MethodAsServableUpload
(upload handler.Upload)
pkg/s3store/serve_content.go:17
MethodAsTerminatableUpload
(upload handler.Upload)
pkg/azurestore/azurestore.go:151
MethodAsTerminatableUpload
(upload handler.Upload)
pkg/gcsstore/gcsstore.go:88
MethodAsTerminatableUpload
(upload handler.Upload)
pkg/filestore/filestore.go:177
MethodAsTerminatableUpload
AsTerminatableUpload mocks base method.
pkg/handler/handler_mock_test.go:68
MethodAsTerminatableUpload
AsTerminatableUpload indicates an expected call of AsTerminatableUpload.
pkg/handler/handler_mock_test.go:76
MethodAsTerminatableUpload
(upload handler.Upload)
pkg/s3store/s3store.go:375
MethodCapabilities
Capabilities returns a string representing the provided extensions in a human-readable format meant for debugging.
pkg/handler/composer.go:28
MethodClose
Close implements io.Closer for readSeekCloser.
pkg/azurestore/azureservice.go:351
MethodClose
()
pkg/gcsstore/gcsstore_test.go:112
MethodClose
Close mocks base method.
pkg/gcsstore/gcsstore_mock_test.go:40
MethodClose
Close indicates an expected call of Close.
pkg/gcsstore/gcsstore_mock_test.go:48
MethodClose
()
pkg/handler/get_test.go:17
MethodCollect
(metrics chan<- prometheus.Metric)
pkg/prometheuscollector/prometheuscollector.go:67
MethodCommit
After all the blocks have been uploaded, we commit the unstaged blocks by sending a Block List
pkg/azurestore/azureservice.go:272
MethodCommit
infoBlob does not have uncommited blocks, so just return nil
pkg/azurestore/azureservice.go:318
MethodCommit
Commit mocks base method.
pkg/azurestore/azurestore_mock_test.go:78
MethodCommit
Commit indicates an expected call of Commit.
pkg/azurestore/azurestore_mock_test.go:86
← previousnext →201–300 of 707, ranked by callers