MCPcopy Create free account

hub / github.com/tus/tusd / functions

Functions707 in github.com/tus/tusd

⨍ Functions 707◇ Types & classes 140
FunctionTestHead
(t *testing.T)
pkg/handler/head_test.go:11
FunctionTestHookEventHeaderIsolation
TestHookEventHeaderIsolation verifies that modifying the original request headers after creating a HookEvent does not affect the event headers.
pkg/handler/hooks_test.go:63
FunctionTestHookEventHeaderRace
TestHookEventHeaderRace demonstrates a race condition that occurs when the http.Header map is shared between the original request and HookEvent. This
pkg/handler/hooks_test.go:17
FunctionTestLockRelease
TestLockRelease asserts that an incoming request will cause any ongoing request for the same upload resource to be closed quickly and cleanly.
internal/e2e/e2e_test.go:465
FunctionTestLoggingS3API
go:generate mockgen -destination=./s3log_mock_test.go -package=s3log github.com/tus/tusd/v2/pkg/s3store S3API
internal/s3log/s3log_test.go:18
FunctionTestMain
(m *testing.M)
internal/e2e/e2e_test.go:35
FunctionTestMemoryLocker_LockAndUnlock
(t *testing.T)
pkg/memorylocker/memorylocker_test.go:14
FunctionTestMemoryLocker_LockAndUnlock
(t *testing.T)
pkg/filelocker/filelocker_test.go:15
FunctionTestMemoryLocker_RequestUnlock
(t *testing.T)
pkg/memorylocker/memorylocker_test.go:55
FunctionTestMemoryLocker_Timeout
(t *testing.T)
pkg/memorylocker/memorylocker_test.go:28
FunctionTestNetworkReadTimeout
TestNetworkReadTimeout tests that tusd correctly stops a request if no data has been received for the specified timeout. All data until this timeout s
internal/e2e/e2e_test.go:126
FunctionTestNewDelayedContext
(t *testing.T)
pkg/handler/delayed_context_test.go:13
FunctionTestNewHandlerWithHooks
go:generate mockgen -source=hooks.go -destination=hooks_mock_test.go -package=hooks
pkg/hooks/hooks_test.go:17
FunctionTestNewUpload
(t *testing.T)
pkg/azurestore/azurestore_test.go:43
FunctionTestNewUpload
(t *testing.T)
pkg/gcsstore/gcsstore_test.go:44
FunctionTestNewUpload
(t *testing.T)
pkg/s3store/s3store_test.go:32
FunctionTestNewUploadLargerMaxObjectSize
(t *testing.T)
pkg/s3store/s3store_test.go:231
FunctionTestNewUploadTooLargeBlob
(t *testing.T)
pkg/azurestore/azurestore_test.go:115
FunctionTestNewUploadWithMetadataObjectPrefix
(t *testing.T)
pkg/s3store/s3store_test.go:124
FunctionTestNewUploadWithObjectPrefix
(t *testing.T)
pkg/s3store/s3store_test.go:79
FunctionTestNewUploadWithPrefix
(t *testing.T)
pkg/azurestore/azurestore_test.go:74
FunctionTestNewUploadWithPrefix
(t *testing.T)
pkg/gcsstore/gcsstore_test.go:72
FunctionTestNotFound
(t *testing.T)
pkg/filestore/filestore_test.go:168
FunctionTestOptions
(t *testing.T)
pkg/handler/options_test.go:10
FunctionTestParseMetadataHeader
(t *testing.T)
pkg/handler/unrouted_handler_test.go:9
FunctionTestPartProducerConsumesEntireReaderWithoutError
(t *testing.T)
pkg/s3store/s3store_part_producer_test.go:28
FunctionTestPartProducerExitsWhenContextIsCancelled
(t *testing.T)
pkg/s3store/s3store_part_producer_test.go:63
FunctionTestPartProducerExitsWhenUnableToReadFromFile
(t *testing.T)
pkg/s3store/s3store_part_producer_test.go:85
FunctionTestPatch
(t *testing.T)
pkg/handler/patch_test.go:19
FunctionTestPost
(t *testing.T)
pkg/handler/post_test.go:16
FunctionTestReadObject
(t *testing.T)
pkg/gcsstore/gcsservice_test.go:267
FunctionTestS3ServableUploadServeContent
(t *testing.T)
pkg/s3store/serve_content_test.go:43
FunctionTestS3ServableUploadServeContentIncomplete
(t *testing.T)
pkg/s3store/serve_content_test.go:147
FunctionTestS3ServableUploadServeContentInternalError
(t *testing.T)
pkg/s3store/serve_content_test.go:121
FunctionTestS3ServableUploadServeContentNotModified
(t *testing.T)
pkg/s3store/serve_content_test.go:220
FunctionTestS3ServableUploadServeContentRangeNotSatisfiable
(t *testing.T)
pkg/s3store/serve_content_test.go:180
FunctionTestS3ServableUploadServeContentWithRange
(t *testing.T)
pkg/s3store/serve_content_test.go:81
FunctionTestS3StoreAsServerDataStore
(t *testing.T)
pkg/s3store/serve_content_test.go:23
FunctionTestSetObjectMetadata
(t *testing.T)
pkg/gcsstore/gcsservice_test.go:308
FunctionTestShutdown
TestShutdown asserts that tusd closes all ongoing upload requests and shuts down cleanly on its own when receiving a signal to stop. This test is not
internal/e2e/e2e_unix_test.go:24
FunctionTestStopUpload
TestSuccessfulUpload asserts that ongoing upload requests get properly closed when the hooks instruct tusd to stop the upload.
internal/e2e/e2e_test.go:727
FunctionTestSuccessfulUpload
TestSuccessfulUpload tests that tusd can perform a single upload from actual HTTP requests.
internal/e2e/e2e_test.go:69
FunctionTestTerminate
(t *testing.T)
pkg/azurestore/azurestore_test.go:352
FunctionTestTerminate
(t *testing.T)
pkg/gcsstore/gcsstore_test.go:259
FunctionTestTerminate
(t *testing.T)
pkg/handler/terminate_test.go:13
FunctionTestTerminate
(t *testing.T)
pkg/s3store/s3store_test.go:1116
FunctionTestTerminateWithErrors
(t *testing.T)
pkg/s3store/s3store_test.go:1156
FunctionTestUnexpectedNetworkClose
TestUnexpectedNetworkClose tests that tusd correctly saves the transmitted data if the client connection gets interrupted unexpectedly during the uplo
internal/e2e/e2e_test.go:252
FunctionTestUnexpectedNetworkReset
TestUnexpectedNetworkReset tests that tusd correctly saves the transmitted data if the client connection gets interrupted unexpectedly by a TCP RST.
internal/e2e/e2e_test.go:355
FunctionTestUploadLengthExceeded
TestUploadLengthExceeded asserts that uploading appending requests are limited to the length specified in the upload. If more data is transmitted, tus
internal/e2e/e2e_test.go:608
FunctionTestWriteChunk
(t *testing.T)
pkg/azurestore/azurestore_test.go:269
FunctionTestWriteChunk
(t *testing.T)
pkg/gcsstore/gcsstore_test.go:376
FunctionTestWriteChunk
(t *testing.T)
pkg/s3store/s3store_test.go:781
FunctionTestWriteChunkAllowTooSmallLast
(t *testing.T)
pkg/s3store/s3store_test.go:1057
FunctionTestWriteChunkCleansUpTempFiles
This test ensures that the S3Store will cleanup all files that it creates during a call to WriteChunk, even if an error occurs during that invocation.
pkg/s3store/s3store_test.go:1417
FunctionTestWriteChunkPrependsIncompletePart
(t *testing.T)
pkg/s3store/s3store_test.go:919
FunctionTestWriteChunkPrependsIncompletePartAndWritesANewIncompletePart
(t *testing.T)
pkg/s3store/s3store_test.go:991
FunctionTestWriteChunkWriteIncompletePartBecauseTooSmall
(t *testing.T)
pkg/s3store/s3store_test.go:867
FunctionTestWriteObject
(t *testing.T)
pkg/gcsstore/gcsservice_test.go:383
MethodUnlock
Unlock releases a lock. If no such lock exists, no error will be returned.
pkg/memorylocker/memorylocker.go:97
MethodUnlock
()
pkg/filelocker/filelocker.go:164
MethodUnlock
Unlock mocks base method.
pkg/handler/handler_mock_test.go:311
MethodUnlock
Unlock indicates an expected call of Unlock.
pkg/handler/handler_mock_test.go:319
MethodUnwrap
Unwrap provides access to the underlying http.ResponseWriter.
pkg/handler/unrouted_handler.go:1751
MethodUpload
Upload a block to Azure Blob Storage and add it to the indexes to be after upload is finished
pkg/azurestore/azureservice.go:192
MethodUpload
Upload the infoBlob to Azure Blob Storage Because the info file is presumed to be smaller than azblob.BlockBlobMaxUploadBlobBytes (256MiB), we can upl
pkg/azurestore/azureservice.go:293
MethodUpload
Upload mocks base method.
pkg/azurestore/azurestore_mock_test.go:150
MethodUpload
Upload indicates an expected call of Upload.
pkg/azurestore/azurestore_mock_test.go:158
MethodUploadPart
(context.Context, *s3.UploadPartInput, ...func(*s3.Options))
pkg/s3store/s3store_test.go:1393
MethodUploadPart
UploadPart mocks base method.
pkg/s3store/s3store_mock_test.go:219
MethodUploadPart
UploadPart indicates an expected call of UploadPart.
pkg/s3store/s3store_mock_test.go:232
MethodUploadPart
UploadPart implements the s3store.S3API interface
internal/s3log/s3log.go:104
MethodUploadPart
UploadPart mocks base method.
internal/s3log/s3log_mock_test.go:219
MethodUploadPart
UploadPart indicates an expected call of UploadPart.
internal/s3log/s3log_mock_test.go:232
MethodUploadPartCopy
UploadPartCopy mocks base method.
pkg/s3store/s3store_mock_test.go:239
MethodUploadPartCopy
UploadPartCopy indicates an expected call of UploadPartCopy.
pkg/s3store/s3store_mock_test.go:252
MethodUploadPartCopy
UploadPartCopy implements the s3store.S3API interface
internal/s3log/s3log.go:168
MethodUploadPartCopy
UploadPartCopy mocks base method.
internal/s3log/s3log_mock_test.go:239
MethodUploadPartCopy
UploadPartCopy indicates an expected call of UploadPartCopy.
internal/s3log/s3log_mock_test.go:252
MethodUsage
()
internal/grouped_flags/grouped_flags.go:61
MethodUseIn
UseIn adds this locker to the passed composer.
pkg/memorylocker/memorylocker.go:46
MethodUseIn
UseIn sets this store as the core data store in the passed composer and adds all possible extension to it.
pkg/azurestore/azurestore.go:46
MethodUseIn
UseIn adds this locker to the passed composer.
pkg/filelocker/filelocker.go:59
MethodUseIn
(composer *handler.StoreComposer)
pkg/gcsstore/gcsstore.go:55
MethodUseIn
UseIn sets this store as the core data store in the passed composer and adds all possible extension to it.
pkg/filestore/filestore.go:73
MethodWriteChunk
(ctx context.Context, offset int64, src io.Reader)
pkg/azurestore/azurestore.go:159
MethodWriteChunk
(ctx context.Context, offset int64, src io.Reader)
pkg/gcsstore/gcsstore.go:92
MethodWriteChunk
(ctx context.Context, offset int64, src io.Reader)
pkg/filestore/filestore.go:220
MethodWriteChunk
WriteChunk mocks base method.
pkg/handler/handler_mock_test.go:221
MethodWriteChunk
WriteChunk indicates an expected call of WriteChunk.
pkg/handler/handler_mock_test.go:230
MethodWriteChunk
(ctx context.Context, offset int64, src io.Reader)
pkg/s3store/s3store.go:410
MethodWriteObject
WriteObject mocks base method.
pkg/gcsstore/gcsstore_mock_test.go:235
MethodWriteObject
WriteObject indicates an expected call of WriteObject.
pkg/gcsstore/gcsstore_mock_test.go:244
Function_HookHandler_InvokeHook_Handler
(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
pkg/hooks/grpc/proto/hook_grpc.pb.go:83
Method__init__
Constructor. Args: channel: A grpc.Channel.
examples/hooks/grpc/hook_pb2_grpc.py:32
Method__init__
(self, *args, **kwargs)
examples/hooks/grpc/server.py:10
Functionadd_HookHandlerServicer_to_server
(servicer, server)
examples/hooks/grpc/hook_pb2_grpc.py:61
Methoddo_GET
(self)
examples/hooks/http/server.py:10
Methoddo_POST
(self)
examples/hooks/http/server.py:15
Functioninit
()
pkg/hooks/grpc/proto/hook.pb.go:752
← previousnext →601–700 of 707, ranked by callers