subscribers

func NewHeartbeatSubscriber ¶

func NewHeartbeatSubscriber(bus glocbus.EventBusInterface, sourceId string, name string, tracerProvider trace.TracerProvider, logger *log.Logger) *HeartbeatSubscriber

Description ¶

Build and return a non-started heartbeat subscriber. ¶

Inputs ¶

• bus: Bus which is used to publish events to this subscriber will subscribe to.
• sourceId: ID of the source to subscribe to.
• name: Name of the subscriber
• tracerProvider: Provider to use to get a tracer. If nil, global tracer provider is used.
• logger: Logger to use to publish debug logs. If nil, debug logs will be discarded.

Return ¶

A new, non-started heartbeat subscriber.