MCPcopy
hub / github.com/microsoft/retina / Subscribe

Method Subscribe

pkg/pubsub/types.go:15–15  ·  view source on GitHub ↗

Subscribe subscribes to the given topic and calls the given callback function when a message is published to the topic

(topic PubSubTopic, callback *CallBackFunc)

Source from the content-addressed store, hash-verified

13 // Subscribe subscribes to the given topic and calls the given callback function
14 // when a message is published to the topic
15 Subscribe(topic PubSubTopic, callback *CallBackFunc) string
16 // Unsubscribe unsubscribes from the given topic
17 Unsubscribe(topic PubSubTopic, uuid string) error
18}

Callers 15

NewFunction · 0.65
TestNewCacheFunction · 0.65
TestCacheEndpointsFunction · 0.65
TestCacheServicesFunction · 0.65
TestCacheNodesFunction · 0.65
TestAddPodSvcNodeSameIPFunction · 0.65
TestAddPodDiffNsFunction · 0.65
TestFailDeleteFunction · 0.65
TestCachingNamespaceFunction · 0.65
TestGetAllNamespacesFunction · 0.65
StartMethod · 0.65

Implementers 3

PubSubpkg/pubsub/pubsub.go
MockPubSubInterfacepkg/pubsub/mock_pubsubinterface.go
MockPubSubInterfaceMockRecorderpkg/pubsub/mock_pubsubinterface.go

Calls

no outgoing calls

Tested by 15

TestNewCacheFunction · 0.52
TestCacheEndpointsFunction · 0.52
TestCacheServicesFunction · 0.52
TestCacheNodesFunction · 0.52
TestAddPodSvcNodeSameIPFunction · 0.52
TestAddPodDiffNsFunction · 0.52
TestFailDeleteFunction · 0.52
TestCachingNamespaceFunction · 0.52
TestGetAllNamespacesFunction · 0.52
TestModule_ReconcileFunction · 0.52
TestSubscribeFunction · 0.52