Package com.helix.core.stream.disruptor

Class RuleEventHolder

java.lang.Object

com.helix.core.stream.disruptor.RuleEventHolder

public class RuleEventHolder
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RuleEventHolder.MutableRuleEvent	Pre-allocated mutable RuleEvent that avoids heap allocation in steady-state streaming.

Field Summary

Fields

Modifier and Type	Field	Description
protected ExecutionContext	context
protected RuleEvent	event
protected String	eventId
protected CompletableFuture<StreamResult>	future
protected StreamListener	listener
long	p1
long	p10
long	p11
long	p12
long	p13
long	p14
long	p2
long	p3
long	p4
long	p5
long	p6
long	p7
long	p8
long	p9
protected String	ruleName
protected long	sequence
protected long	timestamp
protected String	topic

Constructor Summary

Constructors

Constructor	Description
RuleEventHolder()

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears references after processing to eliminate GC retention in the ring buffer.
ExecutionContext	getContext()
RuleEvent	getEvent()
String	getEventId()
CompletableFuture<StreamResult>	getFuture()
StreamListener	getListener()
String	getRuleName()
long	getSequence()
long	getTimestamp()
String	getTopic()
void	set(String eventId, String topic, String ruleName, ExecutionContext context, RuleEvent event, CompletableFuture<StreamResult> future, StreamListener listener, long timestamp, long sequence)
void	setEvent(RuleEvent ruleEvent, CompletableFuture<StreamResult> future, StreamListener listener, long sequence)

Methods inherited from class java.lang.Object

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

Field Details

p8

public long p8

p9

public long p9

p10

public long p10

p11

public long p11

p12

public long p12

p13

public long p13

p14

public long p14

eventId

protected String eventId

topic

protected String topic

ruleName

protected String ruleName

context

protected ExecutionContext context

event

protected RuleEvent event

future

protected CompletableFuture<StreamResult> future

listener

protected StreamListener listener

timestamp

protected long timestamp

sequence

protected long sequence

p1

public long p1

p2

public long p2

p3

public long p3

p4

public long p4

p5

public long p5

p6

public long p6

p7

public long p7

Constructor Details

RuleEventHolder

public RuleEventHolder()

Method Details

set

public void set(String eventId,
 String topic,
 String ruleName,
 ExecutionContext context,
 RuleEvent event,
 CompletableFuture<StreamResult> future,
 StreamListener listener,
 long timestamp,
 long sequence)

setEvent

public void setEvent(RuleEvent ruleEvent,
 CompletableFuture<StreamResult> future,
 StreamListener listener,
 long sequence)

getEventId

public String getEventId()

getTopic

public String getTopic()

getRuleName

public String getRuleName()

getContext

public ExecutionContext getContext()

getEvent

public RuleEvent getEvent()

getFuture

public CompletableFuture<StreamResult> getFuture()

getListener

public StreamListener getListener()

getTimestamp

public long getTimestamp()

getSequence

public long getSequence()

clear

public void clear()

Clears references after processing to eliminate GC retention in the ring buffer.