Functions — github.com/accretional/collector

hub / github.com/accretional/collector / functions

Functions726 in github.com/accretional/collector

⨍ Functions 726◇ Types & classes 79

FunctionTestConnectionManager_RecoverFromRestart_MarksStaleConnections

(t *testing.T)

pkg/dispatch/connection_persistence_test.go:112

FunctionTestConnectionManager_SessionID

(t *testing.T)

pkg/dispatch/connection_persistence_test.go:40

FunctionTestConnection_BasicConnect

TestConnection_BasicConnect tests basic connection establishment

pkg/dispatch/dispatcher_test.go:74

FunctionTestConnection_BidirectionalConnect

TestConnection_BidirectionalConnect tests bidirectional connection setup

pkg/dispatch/dispatcher_test.go:135

FunctionTestConnection_InvalidRequests

TestConnection_InvalidRequests tests error handling

pkg/dispatch/dispatcher_test.go:309

FunctionTestConnection_MultipleConnections

TestConnection_MultipleConnections tests multiple simultaneous connections

pkg/dispatch/dispatcher_test.go:178

FunctionTestConnection_RealNetwork

TestConnection_RealNetwork tests connections over real network

pkg/dispatch/dispatcher_test.go:396

FunctionTestConnection_SharedNamespaces

TestConnection_SharedNamespaces tests namespace sharing logic

pkg/dispatch/dispatcher_test.go:228

FunctionTestCreateCollectionValidation

TestCreateCollectionValidation tests that CreateCollection validates namespace and name

pkg/collection/security_test.go:255

FunctionTestCreateRecord_AtomicityOnFailure

Transaction & Atomicity Tests

pkg/collection/durability_test.go:53

FunctionTestDefaultCollectionRepo_Isolation

TestDefaultCollectionRepo_Isolation tests that DefaultCollectionRepo properly isolates operations

pkg/collection/repo_test.go:467

FunctionTestDeleteBackup

TestDeleteBackup tests backup deletion

pkg/collection/backup_test.go:279

FunctionTestDeleteFile_Success

(t *testing.T)

pkg/collection/filesystem_test.go:82

FunctionTestDispatch_AutoRouteLocal

TestDispatch_AutoRouteLocal tests auto-routing to local handler

pkg/dispatch/dispatcher_test.go:792

FunctionTestDispatch_AutoRouteRemote

TestDispatch_AutoRouteRemote tests auto-routing to remote collector

pkg/dispatch/dispatcher_test.go:835

FunctionTestDispatch_InvalidRequests

TestDispatch_InvalidRequests tests error handling for Dispatch

pkg/dispatch/dispatcher_test.go:891

FunctionTestDispatch_NoCollectorForNamespace

TestDispatch_NoCollectorForNamespace tests when no collector handles the namespace

pkg/dispatch/dispatcher_test.go:1004

FunctionTestDispatch_TargetNotFound

TestDispatch_TargetNotFound tests dispatching to non-existent target

pkg/dispatch/dispatcher_test.go:966

FunctionTestDispatch_ToSpecificTarget

TestDispatch_ToSpecificTarget tests dispatching to a specific collector

pkg/dispatch/dispatcher_test.go:735

FunctionTestDispatcherIntegration

TestDispatcherIntegration tests dispatcher service registration and validation

pkg/registry/integration_test.go:75

FunctionTestDispatcherWithRegistryValidation

(t *testing.T)

pkg/dispatch/dispatcher_registry_test.go:58

FunctionTestDispatcherWithoutRegistryValidation

(t *testing.T)

pkg/dispatch/dispatcher_registry_test.go:153

FunctionTestDynamicServiceLookup

TestDynamicServiceLookup tests dynamic service discovery and method validation

pkg/registry/integration_test.go:201

FunctionTestEndToEndIntegration

TestEndToEndIntegration tests the complete system with registry validation

pkg/integration/e2e_test.go:25

FunctionTestErrOperationInProgress_Error

(t *testing.T)

pkg/collection/operation_state_test.go:215

FunctionTestFilePathTraversal

(t *testing.T)

pkg/collection/durability_test.go:689

FunctionTestFileSize_SmallVsLarge

(t *testing.T)

pkg/collection/filesystem_test.go:194

FunctionTestFileSystemConsistency_DeleteOrphanedFiles

Filesystem Safety Tests

pkg/collection/durability_test.go:724

FunctionTestFileSystemPathTraversal

TestFileSystemPathTraversal tests that filesystem operations reject path traversal attempts

pkg/collection/security_test.go:142

FunctionTestFileSystemSafePaths

TestFileSystemSafePaths tests that safe paths work correctly

pkg/collection/security_test.go:201

FunctionTestGetFile_NotFound

(t *testing.T)

pkg/collection/filesystem_test.go:71

FunctionTestGrpcServer_ConcurrentMixedOperations

(t *testing.T)

pkg/collection/grpc_server_test.go:509

FunctionTestGrpcServer_ConcurrentRequests

TestGrpcServer_Concurrency tests concurrent requests to the gRPC server

pkg/collection/grpc_server_test.go:479

FunctionTestGrpcServer_CreateCollection

TestGrpcServer_CreateCollection tests the CreateCollection gRPC endpoint

pkg/collection/grpc_server_test.go:24

FunctionTestGrpcServer_CreateCollection_WithIndexedFields

(t *testing.T)

pkg/collection/grpc_server_test.go:86

FunctionTestGrpcServer_CreateCollection_WithServerEndpoint

(t *testing.T)

pkg/collection/grpc_server_test.go:58

FunctionTestGrpcServer_Discover

TestGrpcServer_Discover tests the Discover gRPC endpoint

pkg/collection/grpc_server_test.go:110

FunctionTestGrpcServer_Discover_WithFilters

(t *testing.T)

pkg/collection/grpc_server_test.go:142

FunctionTestGrpcServer_Discover_WithPagination

(t *testing.T)

pkg/collection/grpc_server_test.go:213

FunctionTestGrpcServer_ErrorHandling_NilCollection

TestGrpcServer_ErrorHandling tests error handling in the gRPC server

pkg/collection/grpc_server_test.go:461

FunctionTestGrpcServer_Integration_CreateAndRoute

TestGrpcServer_Integration tests end-to-end flow

pkg/collection/grpc_server_test.go:559

FunctionTestGrpcServer_Route

TestGrpcServer_Route tests the Route gRPC endpoint

pkg/collection/grpc_server_test.go:247

FunctionTestGrpcServer_Route_NonExistent

(t *testing.T)

pkg/collection/grpc_server_test.go:285

FunctionTestGrpcServer_SearchCollections

TestGrpcServer_SearchCollections tests the SearchCollections gRPC endpoint

pkg/collection/grpc_server_test.go:310

FunctionTestGrpcServer_SearchCollections_AcrossNamespaces

(t *testing.T)

pkg/collection/grpc_server_test.go:386

FunctionTestGrpcServer_SearchCollections_SpecificCollections

(t *testing.T)

pkg/collection/grpc_server_test.go:422

FunctionTestGrpcServer_SearchCollections_WithQuery

(t *testing.T)

pkg/collection/grpc_server_test.go:347

FunctionTestInvalidJSON_Handling

Data Corruption & Validation Tests

pkg/collection/durability_test.go:504

FunctionTestInvalidRecordIDs

Path Safety Tests

pkg/collection/durability_test.go:646

FunctionTestIssue1_JSONSchemaErrorHandling

TestIssue1_JSONSchemaErrorHandling tests that JSON schema errors are properly handled. Issue: Silent error on JSON schema creation (store.go:55-59) Th

pkg/db/sqlite/json_issues_test.go:20

FunctionTestIssue2_EnableJSONValidationBeforeSearch

TestIssue2_EnableJSONValidationBeforeSearch tests that Search properly validates EnableJSON state before executing JSON queries. Issue: No EnableJSON

pkg/db/sqlite/json_issues_test.go:181

FunctionTestIssue3_InvalidJSONHandling

TestIssue3_InvalidJSONHandling tests that invalid JSON proto_data is handled properly. Issue: Invalid JSON silently defaults to empty object (store.go

pkg/db/sqlite/json_issues_test.go:273

FunctionTestIssue6_LabelKeyEscaping

TestIssue6_LabelKeyEscaping tests that label keys with special characters are properly escaped. Issue: Label keys containing dots or special JSON path

pkg/db/sqlite/json_issues_test.go:449

FunctionTestListBackups

TestListBackups tests listing backups

pkg/collection/backup_test.go:207

FunctionTestListFiles_Multiple

(t *testing.T)

pkg/collection/filesystem_test.go:111

FunctionTestListProtos

TestListProtos tests listing all registered protos

pkg/registry/registry_test.go:1016

FunctionTestListProtos_100k

TestListProtos_100k tests that ListProtos works with 100k+ registrations.

pkg/registry/registry_scalability_test.go:103

FunctionTestListServices

TestListServices tests listing all registered services

pkg/registry/registry_test.go:1073

FunctionTestListServices_100k

TestListServices_100k tests that ListServices works with 100k+ registrations. This is a regression test for the 10k hard-coded limit.

pkg/registry/registry_scalability_test.go:15

FunctionTestLookupProto

TestLookupProto tests proto lookup by namespace and file name

pkg/registry/registry_test.go:807

FunctionTestLookupProto_NotFound

TestLookupProto_NotFound tests proto lookup when proto doesn't exist

pkg/registry/registry_test.go:842

FunctionTestLookupService

TestLookupService tests service lookup by namespace and service name

pkg/registry/registry_test.go:852

FunctionTestLookupService_NotFound

TestLookupService_NotFound tests service lookup when service doesn't exist

pkg/registry/registry_test.go:894

FunctionTestMetadataConsistency

(t *testing.T)

pkg/collection/durability_test.go:766

FunctionTestMultiCollectorIntegration

TestMultiCollectorIntegration tests two collectors connecting and dispatching to each other

pkg/integration/multi_collector_test.go:168

FunctionTestMultipleNamespaces

TestMultipleNamespaces tests that services can be registered in different namespaces

pkg/registry/integration_test.go:165

FunctionTestOperationState_InvalidJSON

(t *testing.T)

pkg/collection/operation_state_test.go:296

FunctionTestOperationState_JSONSerialization

(t *testing.T)

pkg/collection/operation_state_test.go:72

FunctionTestOperationState_NilMetadata

(t *testing.T)

pkg/collection/operation_state_test.go:261

FunctionTestOperationState_SetGetClear

(t *testing.T)

pkg/collection/operation_state_test.go:11

FunctionTestOperationState_Timeout

(t *testing.T)

pkg/collection/operation_state_test.go:108

FunctionTestOperationTimeouts

(t *testing.T)

pkg/collection/operation_state_test.go:234

FunctionTestPathConfigValidation

TestPathConfigValidation tests that PathConfig methods validate inputs

pkg/collection/security_test.go:96

FunctionTestRealFTS

(t *testing.T)

pkg/collection/collection_test.go:44

FunctionTestRealSqliteIntegration

(t *testing.T)

pkg/collection/collection_test.go:11

FunctionTestRecovery_AfterAbnormalClose

Recovery & Resilience Tests

pkg/collection/durability_test.go:348

FunctionTestRecovery_FTSIndexConsistency

(t *testing.T)

pkg/collection/durability_test.go:436

FunctionTestRegisterProto

(t *testing.T)

pkg/registry/registry_test.go:74

FunctionTestRegisterProto_CircularDependency

TestRegisterProto_CircularDependency tests detection of circular dependencies

pkg/registry/dependency_test.go:130

FunctionTestRegisterProto_ComplexTypes

TestRegisterProto_ComplexTypes tests nested types, enums, maps, oneofs

pkg/registry/registry_test.go:529

FunctionTestRegisterProto_CrossNamespaceDependency

TestRegisterProto_CrossNamespaceDependency tests dependencies across namespaces

pkg/registry/dependency_test.go:266

FunctionTestRegisterProto_DeeplyNestedMessages

TestRegisterProto_DeeplyNestedMessages tests rejection of deeply nested messages

pkg/registry/size_limits_test.go:55

FunctionTestRegisterProto_Duplicate

(t *testing.T)

pkg/registry/registry_test.go:158

FunctionTestRegisterProto_EmptyDependencies

TestRegisterProto_EmptyDependencies tests that protos with no dependencies work

pkg/registry/dependency_test.go:348

FunctionTestRegisterProto_EmptyNamespace

TestRegisterProto_EmptyNamespace tests empty namespace validation

pkg/registry/registry_test.go:253

FunctionTestRegisterProto_HierarchicalNamespacesNotSupported

TestRegisterProto_HierarchicalNamespacesNotSupported tests that hierarchical namespaces (with slashes) are rejected

pkg/registry/dependency_test.go:369

FunctionTestRegisterProto_InvalidNamespaceCharacters

TestRegisterProto_InvalidNamespaceCharacters tests rejection of invalid characters

pkg/registry/validation_test.go:59

FunctionTestRegisterProto_InvalidProtoName

TestRegisterProto_InvalidProtoName tests rejection of invalid proto names

pkg/registry/validation_test.go:104

FunctionTestRegisterProto_MissingDependency

TestRegisterProto_MissingDependency tests that registering a proto with missing dependencies fails

pkg/registry/dependency_test.go:17

FunctionTestRegisterProto_MultipleMessages

TestRegisterProto_MultipleMessages tests multiple message types

pkg/registry/registry_test.go:463

FunctionTestRegisterProto_MultipleMissingDependencies

TestRegisterProto_MultipleMissingDependencies tests multiple missing dependencies

pkg/registry/dependency_test.go:54

FunctionTestRegisterProto_MultipleNamespaces

TestRegisterProto_MultipleNamespaces tests same proto in different namespaces

pkg/registry/registry_test.go:297

FunctionTestRegisterProto_NamespaceTooLong

TestRegisterProto_NamespaceTooLong tests rejection of extremely long namespaces

pkg/registry/validation_test.go:150

FunctionTestRegisterProto_NilName

(t *testing.T)

pkg/registry/registry_test.go:210

FunctionTestRegisterProto_ProtoNameTooLong

TestRegisterProto_ProtoNameTooLong tests rejection of extremely long proto names

pkg/registry/validation_test.go:180

FunctionTestRegisterProto_ProtoSizeTooLarge

TestRegisterProto_ProtoSizeTooLarge tests rejection when proto size exceeds limit

pkg/registry/size_limits_test.go:98

FunctionTestRegisterProto_RecursiveTypes

TestRegisterProto_RecursiveTypes tests self-referencing message types

pkg/registry/registry_test.go:737

FunctionTestRegisterProto_ReservedNamespace

TestRegisterProto_ReservedNamespace tests that reserved namespaces are rejected

pkg/registry/validation_test.go:16

FunctionTestRegisterProto_SlashInNamespaceRejected

TestRegisterProto_SlashInNamespaceRejected tests that forward slashes in namespaces are rejected (hierarchical namespaces are not supported)

pkg/registry/validation_test.go:275

FunctionTestRegisterProto_TooManyMessageTypes

TestRegisterProto_TooManyMessageTypes tests rejection when proto has too many message types

pkg/registry/size_limits_test.go:17

← previous next →501–600 of 726, ranked by callers