MCPcopy Index your code

hub / github.com/tus/tusd / functions

Functions707 in github.com/tus/tusd

↓ 340 callersMethodString
()
pkg/s3store/s3store_util_test.go:100
↓ 104 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/handler/handler_mock_test.go:130
↓ 100 callersMethodGetUpload
GetUpload fetches the upload with a given ID. If no such upload can be found, ErrNotFound must be returned.
pkg/handler/datastore.go:122
↓ 99 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/s3store/s3store_mock_test.go:34
↓ 94 callersMethodGetInfo
Read the fileinformation used to validate the offset and respond to HEAD requests.
pkg/handler/datastore.go:95
↓ 94 callersFunctionSubTest
(t *testing.T, name string, runTest func(*testing.T, *MockFullDataStore, *handler.StoreComposer))
pkg/handler/subtest_test.go:11
↓ 93 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/handler/handler_mock_test.go:292
↓ 93 callersMethodRun
(handler http.Handler, t *testing.T)
pkg/handler/utils_test.go:61
↓ 84 callersFunctionNewHandler
NewHandler creates a routed tus protocol handler. This is the simplest way to use tusd but may not be as configurable as you require. If you are integ
pkg/handler/handler.go:21
↓ 66 callersMethodsendError
Send the error in the response body. The status code will be looked up in ErrStatusCodes. If none is found 500 Internal Error will be used.
pkg/handler/unrouted_handler.go:1272
↓ 61 callersFunctionNewMockFullUpload
NewMockFullUpload creates a new mock instance.
pkg/handler/handler_mock_test.go:123
↓ 48 callersMethodSet
(s string)
cmd/tusd/cli/flags.go:111
↓ 43 callersMethodClose
()
pkg/gcsstore/gcsservice.go:52
↓ 40 callersMethodNewUpload
Create a new upload using the size as the file's length. The method must return an unique id which is used to identify the upload. If no backend (e.g.
pkg/handler/datastore.go:118
↓ 37 callersFunctionNew
New constructs a new storage using the supplied bucket and service object.
pkg/s3store/s3store.go:212
↓ 36 callersFunctionNewMockS3API
NewMockS3API creates a new mock instance.
pkg/s3store/s3store_mock_test.go:27
↓ 35 callersMethodWriteChunk
Write the chunk read from src into the file specified by the id at the given offset. The handler will take care of validating the offset and limiting
pkg/handler/datastore.go:92
↓ 34 callersMethodGetObject
(ctx context.Context, input *s3.GetObjectInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:201
↓ 31 callersMethodUnlock
Unlock releases an existing lock for the given upload.
pkg/handler/datastore.go:193
↓ 30 callersMethodError
()
pkg/handler/error.go:12
↓ 28 callersMethodLock
Lock attempts to obtain an exclusive lock for the upload specified by its id. If the lock can be acquired, it will return without error. The requestUn
pkg/handler/datastore.go:191
↓ 28 callersFunctionNewError
NewError constructs a new Error object with the given error code and message. The corresponding HTTP response will have the provided status code and a
pkg/handler/error.go:25
↓ 24 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/azurestore/azurestore_mock_test.go:73
↓ 24 callersFunctionNewStoreComposer
NewStoreComposer creates a new and empty store composer.
pkg/handler/composer.go:22
↓ 24 callersMethodUseCore
UseCore will set the used core data store. If the argument is nil, the property will be unset.
pkg/handler/composer.go:67
↓ 23 callersMethodNewLock
NewLock creates a new unlocked lock object for the given upload ID.
pkg/handler/datastore.go:176
↓ 22 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/gcsstore/gcsstore_mock_test.go:129
↓ 22 callersMethodListParts
(ctx context.Context, input *s3.ListPartsInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:199
↓ 22 callersMethodNewBlob
(ctx context.Context, name string)
pkg/azurestore/azureservice.go:63
↓ 20 callersFunctionNewReaderMatcher
NewReaderMatcher returns a gomock.Matcher which can be used in tests for expecting io.Readers as arguments. It will only report an argument x as match
pkg/handler/utils_test.go:106
↓ 20 callersFunctionprintStartupLog
(msg string, args ...interface{})
cmd/tusd/cli/log.go:64
↓ 19 callersFunctionNewMockAzBlob
NewMockAzBlob creates a new mock instance.
pkg/azurestore/azurestore_mock_test.go:66
↓ 18 callersMethodAddGroup
(name string, constructor func(*flag.FlagSet))
internal/grouped_flags/grouped_flags.go:35
↓ 18 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/azurestore/azurestore_mock_test.go:35
↓ 17 callersMethodPutObject
(ctx context.Context, input *s3.PutObjectInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:198
↓ 17 callersMethodWrite
(msg []byte)
cmd/tusd/cli/log.go:59
↓ 16 callersMethodFinishUpload
FinisherDataStore is the interface which can be implemented by DataStores which need to do additional operations once an entire upload has been comple
pkg/handler/datastore.go:105
↓ 16 callersMethodHeadObject
(ctx context.Context, input *s3.HeadObjectInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:202
↓ 16 callersMethodkeyWithPrefix
(key string)
pkg/s3store/s3store.go:1231
↓ 14 callersMethodDelete
Delete the blob
pkg/azurestore/azureservice.go:77
↓ 13 callersMethodIs
(target error)
pkg/handler/error.go:16
↓ 13 callersMethodUseIn
UseIn sets this store as the core data store in the passed composer and adds all possible extension to it.
pkg/s3store/s3store.go:263
↓ 13 callersMethodUseLocker
(ext Locker)
pkg/handler/composer.go:76
↓ 12 callersMethodDownload
Download returns a readcloser to download the contents of the blob
pkg/azurestore/azureservice.go:84
↓ 12 callersFunctionNew
(service AzService)
pkg/azurestore/azurestore.go:38
↓ 12 callersMethodkeyWithPrefix
(key string)
pkg/gcsstore/gcsstore.go:343
↓ 11 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/hooks/hooks_mock_test.go:32
↓ 11 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/handler/handler_mock_test.go:254
↓ 11 callersMethodGetReader
GetReader returns an io.ReadCloser which allows iterating of the content of an upload. It should attempt to provide a reader even if the upload has no
pkg/handler/datastore.go:99
↓ 11 callersMethodInvokeHook
InvokeHook is invoked for every hook that is executed. req contains the corresponding information about the hook type, the involved upload, and causin
pkg/hooks/hooks.go:40
↓ 11 callersFunctionNew
New creates a new file based storage backend. The directory specified will be used as the only storage entry. This method does not check whether the p
pkg/filestore/filestore.go:63
↓ 11 callersFunctionNewMockAzService
NewMockAzService creates a new mock instance.
pkg/azurestore/azurestore_mock_test.go:28
↓ 11 callersFunctionNewMockFullLock
NewMockFullLock creates a new mock instance.
pkg/handler/handler_mock_test.go:285
↓ 11 callersFunctionNewMockFullLocker
NewMockFullLocker creates a new mock instance.
pkg/handler/handler_mock_test.go:247
↓ 11 callersMethodRead
(p []byte)
pkg/gcsstore/gcsservice.go:54
↓ 11 callersMethodUploadPart
(ctx context.Context, input *s3.UploadPartInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:200
↓ 11 callersMethodlogCall
logCall logs an API call with its input, output, and error
internal/s3log/s3log.go:64
↓ 11 callersFunctionnewHookEvent
(c *httpContext, info FileInfo)
pkg/handler/hooks.go:31
↓ 10 callersMethodAsLengthDeclarableUpload
(upload Upload)
pkg/handler/datastore.go:160
↓ 10 callersMethodAsServableUpload
(upload Upload)
pkg/handler/datastore.go:211
↓ 10 callersMethodAsTerminatableUpload
(upload Upload)
pkg/handler/datastore.go:135
↓ 10 callersMethodDeclareLength
(ctx context.Context, length int64)
pkg/handler/datastore.go:164
↓ 10 callersMethodTerminate
Terminate an upload so any further requests to the upload resource will return the ErrNotFound error.
pkg/handler/datastore.go:128
↓ 10 callersMethodUseTerminater
(ext TerminaterDataStore)
pkg/handler/composer.go:71
↓ 10 callersFunctionisApprox
(got N, expected N, tolerance float64)
internal/e2e/e2e_test.go:895
↓ 10 callersMethodobserveRequestDuration
(start time.Time, label string)
pkg/s3store/s3store.go:278
↓ 10 callersMethodsendResp
sendResp writes the header to w with the specified status code.
pkg/handler/unrouted_handler.go:1293
↓ 9 callersFunctionNew
New constructs a new GCS storage backend using the supplied GCS bucket name and service object.
pkg/gcsstore/gcsstore.go:48
↓ 9 callersMethodServeContent
ServeContent serves the uploaded data as specified by the GET request. It allows data stores to delegate the handling of range requests and conditiona
pkg/handler/datastore.go:204
↓ 9 callersFunctionaddIETFUploadCompleteHeader
addIETFUploadCompleteHeader writes the Upload-Complete or Upload-Incomplete header depending on the interop version.
pkg/handler/utils_test.go:137
↓ 8 callersMethodCreateMultipartUpload
(ctx context.Context, input *s3.CreateMultipartUploadInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:203
↓ 8 callersFunctionNewMockGCSAPI
NewMockGCSAPI creates a new mock instance.
pkg/gcsstore/gcsstore_mock_test.go:122
↓ 8 callersFunctionNewUploadPartInputMatcher
(expect *s3.UploadPartInput)
pkg/s3store/s3store_util_test.go:16
↓ 8 callersMethodmetadataKeyWithPrefix
(key string)
pkg/s3store/s3store.go:1240
↓ 8 callersFunctionnewReadCloser
(b []byte)
pkg/azurestore/azurestore_test.go:438
↓ 8 callersFunctionspawnTusd
(ctx context.Context, t *testing.T, args ...string)
internal/e2e/e2e_test.go:846
↓ 7 callersMethodFilterObjects
(ctx context.Context, params GCSFilterParams)
pkg/gcsstore/gcsservice.go:70
↓ 7 callersMethodGetObjectSize
(ctx context.Context, params GCSObjectParams)
pkg/gcsstore/gcsservice.go:64
↓ 7 callersMethodGetOffset
Get the offset of the blob and its indexes
pkg/azurestore/azureservice.go:86
↓ 7 callersMethodMergeWith
MergeWith returns a copy of resp1, where non-default values from resp2 overwrite values from resp1.
pkg/handler/http.go:53
↓ 7 callersFunctionNew
New creates a new in-memory locker.
pkg/memorylocker/memorylocker.go:39
↓ 7 callersMethodString
()
pkg/hooks/grpc/proto/hook.pb.go:112
↓ 7 callersMethodWriteHeader
(statusCode int)
pkg/handler/unrouted_handler.go:1743
↓ 7 callersFunctionfile_pkg_hooks_grpc_proto_hook_proto_rawDescGZIP
()
pkg/hooks/grpc/proto/hook.pb.go:708
↓ 7 callersFunctionisAwsErrorCode
(err error, code string)
pkg/s3store/s3store.go:1179
↓ 6 callersMethodAbortMultipartUpload
(ctx context.Context, input *s3.AbortMultipartUploadInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:204
↓ 6 callersMethodAsConcatableUpload
(upload Upload)
pkg/handler/datastore.go:142
↓ 6 callersMethodConcatUploads
ConcatUploads concatenates the content from the provided partial uploads and writes the result in the destination upload. The caller (usually the hand
pkg/handler/datastore.go:152
↓ 6 callersFunctionNew
New creates a new file based storage backend. The directory specified will be used as the only storage entry. This method does not check whether the p
pkg/filelocker/filelocker.go:54
↓ 6 callersMethodReadObject
(ctx context.Context, params GCSObjectParams)
pkg/gcsstore/gcsservice.go:63
↓ 6 callersMethodUpload
Upload the blob
pkg/azurestore/azureservice.go:79
↓ 6 callersMethodUseConcater
(ext ConcaterDataStore)
pkg/handler/composer.go:81
↓ 6 callersMethodUseLengthDeferrer
(ext LengthDeferrerDataStore)
pkg/handler/composer.go:86
↓ 6 callersMethodgetContext
getContext tries to retrieve a httpContext from the request or constructs a new one.
pkg/handler/context.go:74
↓ 6 callersFunctiongetIETFDraftInteropVersion
getIETFDraftInteropVersion returns the resumable upload draft interop version from the headers.
pkg/handler/unrouted_handler.go:1489
↓ 6 callersMethodlockUpload
lockUpload creates a new lock for the given upload ID and attempts to lock it. The created lock is returned if it was aquired successfully.
pkg/handler/unrouted_handler.go:1446
↓ 5 callersMethodCompleteMultipartUpload
(ctx context.Context, input *s3.CompleteMultipartUploadInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:207
↓ 5 callersMethodInvokeHook
InvokeHook is invoked for every hook that is executed. HookRequest contains the corresponding information about the hook type, the involved upload, an
pkg/hooks/grpc/proto/hook_grpc.pb.go:30
↓ 5 callersFunctionParseMetadataHeader
ParseMetadataHeader parses the Upload-Metadata header as defined in the File Creation extension. e.g. Upload-Metadata: name bHVucmpzLnBuZw==,type aW1h
pkg/handler/unrouted_handler.go:1580
↓ 5 callersMethodSize
()
pkg/gcsstore/gcsservice.go:56
next →1–100 of 707, ranked by callers