Interface Publisher

core/services/messaging/interfaces.go:6–8 · view source on GitHub ↗

Publisher publishes JSON-encoded messages to NATS subjects.

Source from the content-addressed store, hash-verified

4
5	// Publisher publishes JSON-encoded messages to NATS subjects.
6	type Publisher interface {
7	Publish(subject string, data any) error
8	}
9
10	// Subscription represents a NATS subscription that can be unsubscribed.
11	type Subscription interface {

handleMCPCIJobFunction · 0.65

PublishMethod · 0.65

UpdateStatusMethod · 0.65

publishCacheInvalidateMethod · 0.65

CancelOperationMethod · 0.65

distributed_sync_test.goFile · 0.65

persistAndBroadcastStartMethod · 0.65

DeleteUUIDMethod · 0.65

Clientcore/services/messaging/client.go

fakeBuscore/services/galleryop/distributed_sy

fakeMessagingClientcore/services/jobs/dispatcher_test.go

scriptedMessagingClientcore/services/nodes/managers_distribut

fakeMessagingClientcore/services/nodes/unloader_test.go

failOnceMessagingClientcore/services/nodes/unloader_test.go

fakePubcore/services/nodes/prefixcache/sync_t

FakeBuscore/services/testutil/fakebus.go

fakeMessagingClientcore/services/agents/events_test.go

mockPublishercore/services/agents/scheduler_test.go

no outgoing calls

no test coverage detected