MCPcopy Index your code
hub / github.com/coder/coder / NewInMemory

Function NewInMemory

coderd/database/pubsub/pubsub_memory.go:90–94  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

88}
89
90func NewInMemory() Pubsub {
91 return &MemoryPubsub{
92 listeners: make(map[string]map[uuid.UUID]genericListener),
93 }
94}

Callers 15

Test_logFollower_completeBeforeFollowFunction · 0.92
Test_logFollower_completeBeforeSubscribeFunction · 0.92
Test_logFollower_EndOfLogsFunction · 0.92
TestTracker_MultipleInstancesFunction · 0.92
TestUpdateStatsFunction · 0.92
TestBatchUpdateMetadataFunction · 0.92
TestPubsubWorkspaceClaimPublisherFunction · 0.92
TestPubsubWorkspaceClaimListenerFunction · 0.92
TestAcquirer_SingleFunction · 0.92
TestAcquirer_MultipleSameDomainFunction · 0.92
TestAcquirer_WaitsOnNoJobsFunction · 0.92
TestAcquirer_RetriesPendingFunction · 0.92

Calls

no outgoing calls

Tested by 15

Test_logFollower_completeBeforeFollowFunction · 0.74
Test_logFollower_completeBeforeSubscribeFunction · 0.74
Test_logFollower_EndOfLogsFunction · 0.74
TestTracker_MultipleInstancesFunction · 0.74
TestUpdateStatsFunction · 0.74
TestBatchUpdateMetadataFunction · 0.74
TestPubsubWorkspaceClaimPublisherFunction · 0.74
TestPubsubWorkspaceClaimListenerFunction · 0.74
TestAcquirer_SingleFunction · 0.74
TestAcquirer_MultipleSameDomainFunction · 0.74
TestAcquirer_WaitsOnNoJobsFunction · 0.74
TestAcquirer_RetriesPendingFunction · 0.74