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

Method Subscribe

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

Source from the content-addressed store, hash-verified

35
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

Callers 15

SubscribeMethod · 0.65
TestWorkspaceUpdatesFunction · 0.65
TestAIProvidersChangedPubsubFunction · 0.65
watchWorkspaceMethod · 0.65
workspaceAgentLogsMethod · 0.65
watchWorkspaceAgentMetadataMethod · 0.65
TestDriverFunction · 0.65
TestPubsubMemoryFunction · 0.65
TestPGPubsub_MetricsFunction · 0.65
TestPGPubsubDriverFunction · 0.65
TestPubSub_DoesntBlockNotifyFunction · 0.65
TestPubSub_DoesntRaceListenUnlistenFunction · 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 15

SubscribeMethod · 0.52
TestWorkspaceUpdatesFunction · 0.52
TestAIProvidersChangedPubsubFunction · 0.52
TestDriverFunction · 0.52
TestPubsubMemoryFunction · 0.52
TestPGPubsub_MetricsFunction · 0.52
TestPGPubsubDriverFunction · 0.52
TestPubSub_DoesntBlockNotifyFunction · 0.52
TestPubSub_DoesntRaceListenUnlistenFunction · 0.52
TestPubsubFunction · 0.52
TestPubsub_orderingFunction · 0.52
TestMeasureLatencyFunction · 0.52