QueueEventSink class abstract

A destination for QueueEvents emitted by producers and workers.

The whole observability layer is opt-in: GisilaQueue defaults to a NoopEventSink, so existing code pays nothing. Pass a real sink (InMemoryEventBus for a single isolate, RedisEventSink for a cluster) to start streaming lifecycle events to a GisilaRose dashboard.

Named QueueEventSink (not EventSink) to avoid clashing with dart:async's EventSink<T> in consumer code.

Implementers

• InMemoryEventBus
• MultiEventSink
• NoopEventSink
• RedisEventSink

Constructors

QueueEventSink()

Properties

hashCode → int

The hash code for this object.

no setter, inherited

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

close() → Future<void>

Releases any resources / connections held by the sink.

emit(QueueEvent event) → Future<void>

Publishes event. Implementations must never throw into the caller — observability must not break task processing; swallow/log transport errors internally instead.

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited