EventBusBroker class
In-memory grpcdc.events.v1.EventBus broker. Any peer can host it: register() it on a Server next to your own services, or call publishEvent directly in-process.
- Implemented types
Constructors
- EventBusBroker({int queueCapacity = subscriberQueueCapacity})
Properties
- hashCode → int
-
The hash code for this object.
no setterinherited
- queueCapacity → int
-
final
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
Methods
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
publish(
CallContext ctx, PublishRequest req) → Future< PublishReply> -
override
-
publishEvent(
List< TagValue> tags, List<int> payload, [String publisherId = '']) → Event - Accept an event: assign its sequence number and timestamp and fan it out to matching subscribers. Returns the stamped Event.
-
register(
Server server) → EventBusBroker -
stats(
) → Map< String, int> -
subscribe(
SubscribeRequest req, EventBusSubscribeServer stream) → Future< void> -
override
-
subscribeLocal(
List< TagValue> filterTags) → LocalSubscription - In-process subscription: events fan out to it exactly like an RPC subscriber, without a call. Useful embedded and for tests; close() unregisters.
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited