Class WFTBuffer

java.lang.Object

io.temporal.internal.statemachines.WFTBuffer

public class WFTBuffer
extends Object

This class buffers events between WorkflowTaskStarted events and return them in one chunk so any kinds of look ahead and preloading can be implemented.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	WFTBuffer.EventBatch

Constructor Summary

Constructors

Constructor	Description
WFTBuffer()

Method Summary

Modifier and Type	Method	Description
boolean	addEvent(io.temporal.api.history.v1.HistoryEvent event, boolean hasNextEvent)
WFTBuffer.EventBatch	fetch()

Methods inherited from class java.lang.Object

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

Constructor Details

WFTBuffer

public WFTBuffer()

Method Details

addEvent

public boolean addEvent(io.temporal.api.history.v1.HistoryEvent event,
 boolean hasNextEvent)

Returns:

Should the buffer be fetched. true if a whole history for a workflow task is accumulated or events can't be attributed to a completed workflow task. The whole history includes the unprocessed history events before the WorkflowTaskStarted and the command events after the WorkflowTaskCompleted.

fetch

public WFTBuffer.EventBatch fetch()