Package com.helix.core.stream.disruptor

Class DisruptorStreamBridge

java.lang.Object

com.helix.core.stream.disruptor.DisruptorStreamBridge

All Implemented Interfaces:

StreamBridge, AutoCloseable

public class DisruptorStreamBridge
extends Object
implements StreamBridge

Ultra-low latency, zero-allocation in-process streaming engine backed by the LMAX Disruptor ring buffer pattern with cache-line padded events and virtual thread event processing.

Constructor Summary

Constructors

Constructor	Description
DisruptorStreamBridge()
DisruptorStreamBridge(DisruptorConfig config)

Method Summary

Modifier and Type	Method	Description
com.lmax.disruptor.RingBuffer<RuleEventHolder>	getRingBuffer()
boolean	isRunning()	Checks if the stream bridge is active and accepting events.
CompletableFuture<StreamResult>	publish(RuleEvent event)	Publishes a rule evaluation event into the stream and returns a CompletableFuture for the result.
<T> CompletableFuture<StreamResult>	publish(StreamRecord<T> record)	Publishes a generic stream record into the stream and returns a CompletableFuture for the result.
void	publish(String topic, String ruleName, ExecutionContext context, StreamListener listener)	Steady-state zero-allocation publication without intermediate RuleEvent heap allocations.
void	registerRule(String topicOrRuleName, CompiledRule rule)	Registers a pre-compiled rule directly to evaluate events for a given topic or rule name.
void	shutdown(Duration timeout)	Gracefully shuts down the stream bridge within the specified timeout duration.
void	start()
StreamStats	stats()	Retrieves current streaming engine metrics and capacity stats.
void	subscribe(String topic, RuleStreamHandler handler)	Subscribes a functional rule stream handler to a given topic.
void	subscribeListener(String topic, StreamListener listener)	Subscribes an asynchronous result listener to a given topic.
boolean	tryPublish(RuleEvent event, StreamListener listener)	Fast-path non-blocking publish of a rule event with a completion listener, avoiding Future allocation.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.helix.api.stream.StreamBridge

addListener, close, tryPublish

Constructor Details

DisruptorStreamBridge

public DisruptorStreamBridge()

DisruptorStreamBridge

public DisruptorStreamBridge(DisruptorConfig config)

Method Details

start

public void start()

subscribe

public void subscribe(String topic,
 RuleStreamHandler handler)

Description copied from interface: StreamBridge

Subscribes a functional rule stream handler to a given topic.

Specified by:

subscribe in interface StreamBridge

Parameters:

topic - stream topic

handler - handler invoked for incoming events on the topic

subscribeListener

public void subscribeListener(String topic,
 StreamListener listener)

Description copied from interface: StreamBridge

Subscribes an asynchronous result listener to a given topic.

Specified by:

subscribeListener in interface StreamBridge

Parameters:

topic - stream topic

listener - listener invoked when events on the topic complete evaluation

registerRule

public void registerRule(String topicOrRuleName,
 CompiledRule rule)

Registers a pre-compiled rule directly to evaluate events for a given topic or rule name.

Parameters:

topicOrRuleName - topic or rule name identifier

rule - pre-compiled rule instance

publish

public CompletableFuture<StreamResult> publish(RuleEvent event)

Description copied from interface: StreamBridge

Publishes a rule evaluation event into the stream and returns a CompletableFuture for the result.

Specified by:

publish in interface StreamBridge

Parameters:

event - the rule event to publish

Returns:

CompletableFuture completing with the evaluation result

publish

public <T> CompletableFuture<StreamResult> publish(StreamRecord<T> record)

Description copied from interface: StreamBridge

Publishes a generic stream record into the stream and returns a CompletableFuture for the result.

Specified by:

publish in interface StreamBridge

Type Parameters:

T - payload type

Parameters:

record - the stream record to publish

Returns:

CompletableFuture completing with the evaluation result

tryPublish

public boolean tryPublish(RuleEvent event,
 StreamListener listener)

Description copied from interface: StreamBridge

Fast-path non-blocking publish of a rule event with a completion listener, avoiding Future allocation.

Specified by:

tryPublish in interface StreamBridge

Parameters:

event - rule event

listener - optional listener for evaluation result

Returns:

true if published onto the ring buffer, false if saturated

publish

public void publish(String topic,
 String ruleName,
 ExecutionContext context,
 StreamListener listener)

Steady-state zero-allocation publication without intermediate RuleEvent heap allocations.

Parameters:

topic - stream topic

ruleName - rule name

context - execution context

listener - optional result callback listener

stats

public StreamStats stats()

Description copied from interface: StreamBridge

Retrieves current streaming engine metrics and capacity stats.

Specified by:

stats in interface StreamBridge

Returns:

runtime stats snapshot

isRunning

public boolean isRunning()

Description copied from interface: StreamBridge

Checks if the stream bridge is active and accepting events.

Specified by:

isRunning in interface StreamBridge

Returns:

true if running, false if stopped or shut down

shutdown

public void shutdown(Duration timeout)

Description copied from interface: StreamBridge

Gracefully shuts down the stream bridge within the specified timeout duration.

Specified by:

shutdown in interface StreamBridge

Parameters:

timeout - maximum time to await in-flight events draining

getRingBuffer

public com.lmax.disruptor.RingBuffer<RuleEventHolder> getRingBuffer()