Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/tus/tusd
/ functions
Functions
707 in github.com/tus/tusd
⨍
Functions
707
◇
Types & classes
140
↓ 340 callers
Method
String
()
pkg/s3store/s3store_util_test.go:100
↓ 104 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/handler/handler_mock_test.go:130
↓ 100 callers
Method
GetUpload
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 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/s3store/s3store_mock_test.go:34
↓ 94 callers
Method
GetInfo
Read the fileinformation used to validate the offset and respond to HEAD requests.
pkg/handler/datastore.go:95
↓ 94 callers
Function
SubTest
(t *testing.T, name string, runTest func(*testing.T, *MockFullDataStore, *handler.StoreComposer))
pkg/handler/subtest_test.go:11
↓ 93 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/handler/handler_mock_test.go:292
↓ 93 callers
Method
Run
(handler http.Handler, t *testing.T)
pkg/handler/utils_test.go:61
↓ 84 callers
Function
NewHandler
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 callers
Method
sendError
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 callers
Function
NewMockFullUpload
NewMockFullUpload creates a new mock instance.
pkg/handler/handler_mock_test.go:123
↓ 48 callers
Method
Set
(s string)
cmd/tusd/cli/flags.go:111
↓ 43 callers
Method
Close
()
pkg/gcsstore/gcsservice.go:52
↓ 40 callers
Method
NewUpload
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 callers
Function
New
New constructs a new storage using the supplied bucket and service object.
pkg/s3store/s3store.go:212
↓ 36 callers
Function
NewMockS3API
NewMockS3API creates a new mock instance.
pkg/s3store/s3store_mock_test.go:27
↓ 35 callers
Method
WriteChunk
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 callers
Method
GetObject
(ctx context.Context, input *s3.GetObjectInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:201
↓ 31 callers
Method
Unlock
Unlock releases an existing lock for the given upload.
pkg/handler/datastore.go:193
↓ 30 callers
Method
Error
()
pkg/handler/error.go:12
↓ 28 callers
Method
Lock
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 callers
Function
NewError
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 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/azurestore/azurestore_mock_test.go:73
↓ 24 callers
Function
NewStoreComposer
NewStoreComposer creates a new and empty store composer.
pkg/handler/composer.go:22
↓ 24 callers
Method
UseCore
UseCore will set the used core data store. If the argument is nil, the property will be unset.
pkg/handler/composer.go:67
↓ 23 callers
Method
NewLock
NewLock creates a new unlocked lock object for the given upload ID.
pkg/handler/datastore.go:176
↓ 22 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/gcsstore/gcsstore_mock_test.go:129
↓ 22 callers
Method
ListParts
(ctx context.Context, input *s3.ListPartsInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:199
↓ 22 callers
Method
NewBlob
(ctx context.Context, name string)
pkg/azurestore/azureservice.go:63
↓ 20 callers
Function
NewReaderMatcher
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 callers
Function
printStartupLog
(msg string, args ...interface{})
cmd/tusd/cli/log.go:64
↓ 19 callers
Function
NewMockAzBlob
NewMockAzBlob creates a new mock instance.
pkg/azurestore/azurestore_mock_test.go:66
↓ 18 callers
Method
AddGroup
(name string, constructor func(*flag.FlagSet))
internal/grouped_flags/grouped_flags.go:35
↓ 18 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/azurestore/azurestore_mock_test.go:35
↓ 17 callers
Method
PutObject
(ctx context.Context, input *s3.PutObjectInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:198
↓ 17 callers
Method
Write
(msg []byte)
cmd/tusd/cli/log.go:59
↓ 16 callers
Method
FinishUpload
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 callers
Method
HeadObject
(ctx context.Context, input *s3.HeadObjectInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:202
↓ 16 callers
Method
keyWithPrefix
(key string)
pkg/s3store/s3store.go:1231
↓ 14 callers
Method
Delete
Delete the blob
pkg/azurestore/azureservice.go:77
↓ 13 callers
Method
Is
(target error)
pkg/handler/error.go:16
↓ 13 callers
Method
UseIn
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 callers
Method
UseLocker
(ext Locker)
pkg/handler/composer.go:76
↓ 12 callers
Method
Download
Download returns a readcloser to download the contents of the blob
pkg/azurestore/azureservice.go:84
↓ 12 callers
Function
New
(service AzService)
pkg/azurestore/azurestore.go:38
↓ 12 callers
Method
keyWithPrefix
(key string)
pkg/gcsstore/gcsstore.go:343
↓ 11 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/hooks/hooks_mock_test.go:32
↓ 11 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
pkg/handler/handler_mock_test.go:254
↓ 11 callers
Method
GetReader
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 callers
Method
InvokeHook
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 callers
Function
New
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 callers
Function
NewMockAzService
NewMockAzService creates a new mock instance.
pkg/azurestore/azurestore_mock_test.go:28
↓ 11 callers
Function
NewMockFullLock
NewMockFullLock creates a new mock instance.
pkg/handler/handler_mock_test.go:285
↓ 11 callers
Function
NewMockFullLocker
NewMockFullLocker creates a new mock instance.
pkg/handler/handler_mock_test.go:247
↓ 11 callers
Method
Read
(p []byte)
pkg/gcsstore/gcsservice.go:54
↓ 11 callers
Method
UploadPart
(ctx context.Context, input *s3.UploadPartInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:200
↓ 11 callers
Method
logCall
logCall logs an API call with its input, output, and error
internal/s3log/s3log.go:64
↓ 11 callers
Function
newHookEvent
(c *httpContext, info FileInfo)
pkg/handler/hooks.go:31
↓ 10 callers
Method
AsLengthDeclarableUpload
(upload Upload)
pkg/handler/datastore.go:160
↓ 10 callers
Method
AsServableUpload
(upload Upload)
pkg/handler/datastore.go:211
↓ 10 callers
Method
AsTerminatableUpload
(upload Upload)
pkg/handler/datastore.go:135
↓ 10 callers
Method
DeclareLength
(ctx context.Context, length int64)
pkg/handler/datastore.go:164
↓ 10 callers
Method
Terminate
Terminate an upload so any further requests to the upload resource will return the ErrNotFound error.
pkg/handler/datastore.go:128
↓ 10 callers
Method
UseTerminater
(ext TerminaterDataStore)
pkg/handler/composer.go:71
↓ 10 callers
Function
isApprox
(got N, expected N, tolerance float64)
internal/e2e/e2e_test.go:895
↓ 10 callers
Method
observeRequestDuration
(start time.Time, label string)
pkg/s3store/s3store.go:278
↓ 10 callers
Method
sendResp
sendResp writes the header to w with the specified status code.
pkg/handler/unrouted_handler.go:1293
↓ 9 callers
Function
New
New constructs a new GCS storage backend using the supplied GCS bucket name and service object.
pkg/gcsstore/gcsstore.go:48
↓ 9 callers
Method
ServeContent
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 callers
Function
addIETFUploadCompleteHeader
addIETFUploadCompleteHeader writes the Upload-Complete or Upload-Incomplete header depending on the interop version.
pkg/handler/utils_test.go:137
↓ 8 callers
Method
CreateMultipartUpload
(ctx context.Context, input *s3.CreateMultipartUploadInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:203
↓ 8 callers
Function
NewMockGCSAPI
NewMockGCSAPI creates a new mock instance.
pkg/gcsstore/gcsstore_mock_test.go:122
↓ 8 callers
Function
NewUploadPartInputMatcher
(expect *s3.UploadPartInput)
pkg/s3store/s3store_util_test.go:16
↓ 8 callers
Method
metadataKeyWithPrefix
(key string)
pkg/s3store/s3store.go:1240
↓ 8 callers
Function
newReadCloser
(b []byte)
pkg/azurestore/azurestore_test.go:438
↓ 8 callers
Function
spawnTusd
(ctx context.Context, t *testing.T, args ...string)
internal/e2e/e2e_test.go:846
↓ 7 callers
Method
FilterObjects
(ctx context.Context, params GCSFilterParams)
pkg/gcsstore/gcsservice.go:70
↓ 7 callers
Method
GetObjectSize
(ctx context.Context, params GCSObjectParams)
pkg/gcsstore/gcsservice.go:64
↓ 7 callers
Method
GetOffset
Get the offset of the blob and its indexes
pkg/azurestore/azureservice.go:86
↓ 7 callers
Method
MergeWith
MergeWith returns a copy of resp1, where non-default values from resp2 overwrite values from resp1.
pkg/handler/http.go:53
↓ 7 callers
Function
New
New creates a new in-memory locker.
pkg/memorylocker/memorylocker.go:39
↓ 7 callers
Method
String
()
pkg/hooks/grpc/proto/hook.pb.go:112
↓ 7 callers
Method
WriteHeader
(statusCode int)
pkg/handler/unrouted_handler.go:1743
↓ 7 callers
Function
file_pkg_hooks_grpc_proto_hook_proto_rawDescGZIP
()
pkg/hooks/grpc/proto/hook.pb.go:708
↓ 7 callers
Function
isAwsErrorCode
(err error, code string)
pkg/s3store/s3store.go:1179
↓ 6 callers
Method
AbortMultipartUpload
(ctx context.Context, input *s3.AbortMultipartUploadInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:204
↓ 6 callers
Method
AsConcatableUpload
(upload Upload)
pkg/handler/datastore.go:142
↓ 6 callers
Method
ConcatUploads
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 callers
Function
New
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 callers
Method
ReadObject
(ctx context.Context, params GCSObjectParams)
pkg/gcsstore/gcsservice.go:63
↓ 6 callers
Method
Upload
Upload the blob
pkg/azurestore/azureservice.go:79
↓ 6 callers
Method
UseConcater
(ext ConcaterDataStore)
pkg/handler/composer.go:81
↓ 6 callers
Method
UseLengthDeferrer
(ext LengthDeferrerDataStore)
pkg/handler/composer.go:86
↓ 6 callers
Method
getContext
getContext tries to retrieve a httpContext from the request or constructs a new one.
pkg/handler/context.go:74
↓ 6 callers
Function
getIETFDraftInteropVersion
getIETFDraftInteropVersion returns the resumable upload draft interop version from the headers.
pkg/handler/unrouted_handler.go:1489
↓ 6 callers
Method
lockUpload
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 callers
Method
CompleteMultipartUpload
(ctx context.Context, input *s3.CompleteMultipartUploadInput, opt ...func(*s3.Options))
pkg/s3store/s3store.go:207
↓ 5 callers
Method
InvokeHook
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 callers
Function
ParseMetadataHeader
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 callers
Method
Size
()
pkg/gcsstore/gcsservice.go:56
next →
1–100 of 707, ranked by callers