Interface RelayPublisher

server/internal/realtime/redis_relay.go:509–511 · view source on GitHub ↗

RelayPublisher is implemented by Redis relay backends that can publish a caller-supplied event id for local/Redis loopback deduplication.

Source from the content-addressed store, hash-verified

507	// RelayPublisher is implemented by Redis relay backends that can publish a
508	// caller-supplied event id for local/Redis loopback deduplication.
509	type RelayPublisher interface {
510	PublishWithID(scopeType, scopeID, exclude string, frame []byte, id string) error
511	}
512
513	func NewDualWriteBroadcaster(local Hub, relay RelayPublisher) DualWriteBroadcaster {
514	return newDualWriteBroadcaster(local, relay)

NotifyTaskAvailableMethod · 0.65

NotifyRuntimeProfilesChangedMethod · 0.65

BroadcastToScopeMethod · 0.65

SendToUserMethod · 0.65

BroadcastMethod · 0.65

PublishWithIDMethod · 0.65

recordingRelayPublisherserver/internal/daemonws/hub_test.go

localFirstDaemonRelayPublisherserver/internal/daemonws/hub_test.go

RedisRelayserver/internal/realtime/redis_relay.g

localFirstPublisherserver/internal/realtime/redis_relay_t

ShardedStreamRelayserver/internal/realtime/sharded_strea

recordingManagedRelayserver/internal/realtime/relay_lifecyc

MirroredRelayserver/internal/realtime/relay_lifecyc

no outgoing calls

no test coverage detected