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

Method SubscribeWithErr

coderd/database/pubsub/pubsub.go:38–38  ·  view source on GitHub ↗
(event string, listener ListenerWithErr)

Source from the content-addressed store, hash-verified

36type Subscriber interface {
37 Subscribe(event string, listener Listener) (cancel func(), err error)
38 SubscribeWithErr(event string, listener ListenerWithErr) (cancel func(), err error)
39}
40
41type Publisher interface {

Callers 15

startMethod · 0.65
followMethod · 0.65
watchWorkspaceMethod · 0.65
watchAllWorkspaceBuildsMethod · 0.65
workspaceAgentLogsMethod · 0.65
watchInboxNotificationsMethod · 0.65
watchChatsMethod · 0.65
TestPubsubMemoryFunction · 0.65
TestPubsub_DisconnectFunction · 0.65
SubscribeWithErrMethod · 0.65
TestUpdateStatsFunction · 0.65
TestAwaitSubagentCompletionFunction · 0.65

Implementers 8

mockPubsubcoderd/workspaceupdates_test.go
PGPubsubcoderd/database/pubsub/pubsub.go
MemoryPubsubcoderd/database/pubsub/pubsub_memory.g
fakePubsubcoderd/database/pubsub/watchdog_test.g
racyPubsubcoderd/database/pubsub/pubsub_linux_te
MockPubsubcoderd/database/pubsub/psmock/psmock.g
MockPubsubMockRecordercoderd/database/pubsub/psmock/psmock.g
errInjectingPubsubcoderd/aibridged/reload_test.go

Calls

no outgoing calls

Tested by 13

TestPubsubMemoryFunction · 0.52
TestPubsub_DisconnectFunction · 0.52
SubscribeWithErrMethod · 0.52
TestUpdateStatsFunction · 0.52
TestAwaitSubagentCompletionFunction · 0.52
TestRegenerateChatTitle_PersistsAndBroadcastsFunction · 0.52
TestRegenerateChatTitle_PersistsAndBroadcasts_IdleChatReleasesManualLockFunction · 0.52
TestAutoPromote_InsertFailureSkipsStatusUpdateFunction · 0.52
TestPromoteQueuedMessageReloadsChatWhenModelConfigChangesDuringPendingFunction · 0.52
TestAcquireJobFunction · 0.52
TestFailJobFunction · 0.52
TestCompleteJobFunction · 0.52