Class LegacyStateMachine

java.lang.Object

dev.restate.sdk.core.legacy.LegacyStateMachine

All Implemented Interfaces:

StateMachine, AutoCloseable

public final class LegacyStateMachine
extends Object
implements StateMachine

Legacy pure-Java StateMachine, used on JDK < 23 or when the native shared-core library is unavailable/disabled. This is a deprecated fallback that will be removed in a future release; the native (FFM) state machine is the path that supports the latest Restate features.

Nested Class Summary

Nested classes/interfaces inherited from interface StateMachine

StateMachine.AwaitResult, StateMachine.Awakeable, StateMachine.CallHandle, StateMachine.Input, StateMachine.InvocationState, StateMachine.NotificationValue, StateMachine.RunResultHandle

Constructor Summary

Constructors

Constructor	Description
LegacyStateMachine(HeadersAccessor headersAccessor, EndpointRequestHandler.LoggingContextSetter loggingContextSetter)

Method Summary

Modifier and Type	Method	Description
int	attachInvocation(String invocationId)
StateMachine.Awakeable	awakeable()
StateMachine.CallHandle	call(Target target, Slice payload, @Nullable String idempotencyKey, @Nullable String scope, @Nullable String limitKey, @Nullable Collection<Map.Entry<String,String>> headers)
void	cancelInvocation(String targetInvocationId)
void	close()
void	completeAwakeable(String awakeableId, Slice value)
void	completeAwakeable(String awakeableId, TerminalException exception)
void	completeSignal(String targetInvocationId, String signalName, Slice value)
void	completeSignal(String targetInvocationId, String signalName, TerminalException exception)
int	createSignalHandle(String signalName)
StateMachine.AwaitResult	doAwait(UnresolvedFuture future)	Make progress on the still-uncompleted await tree rooted at future, or return null when nothing is left to await (every node already resolved).
void	end()
int	getInvocationOutput(String invocationId)
String	getResponseContentType()
StateMachine.Input	input()
boolean	isReadyToExecute()
void	notifyError(Throwable throwable)
void	notifyInput(Slice bytes)	Feed the next chunk of wire input.
void	notifyInputClosed()
int	promiseComplete(String key, Slice value)
int	promiseComplete(String key, TerminalException exception)
int	promiseGet(String key)
int	promisePeek(String key)
void	proposeRunCompletion(int handle, Slice value)
void	proposeRunCompletion(int handle, TerminalException terminalException)
void	proposeRunCompletion(int handle, Throwable exception, Duration attemptDuration, @Nullable RetryPolicy retryPolicy)
StateMachine.RunResultHandle	run(String name)
int	send(Target target, Slice payload, @Nullable String idempotencyKey, @Nullable String scope, @Nullable String limitKey, @Nullable Collection<Map.Entry<String,String>> headers, @Nullable Duration delay)
int	sleep(Duration duration, @Nullable String name)
StateMachine.InvocationState	state()
void	stateClear(String key)
void	stateClearAll()
int	stateGet(String key)
int	stateGetKeys()
void	stateSet(String key, Slice bytes)
@Nullable StateMachine.NotificationValue	takeNotification(int handle)
Slice	takeOutput()	Drain the next chunk of serialized output ready for the wire, or Slice.EMPTY when nothing is buffered.
void	writeOutput(Slice value)
void	writeOutput(TerminalException exception)

Methods inherited from class Object

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

Constructor Details

LegacyStateMachine

public LegacyStateMachine(HeadersAccessor headersAccessor,
 EndpointRequestHandler.LoggingContextSetter loggingContextSetter)

Method Details

notifyInput

public void notifyInput(Slice bytes)

Description copied from interface: StateMachine

Feed the next chunk of wire input.

Specified by:

notifyInput in interface StateMachine

notifyInputClosed

public void notifyInputClosed()

Specified by:

notifyInputClosed in interface StateMachine

notifyError

public void notifyError(Throwable throwable)

Specified by:

notifyError in interface StateMachine

takeOutput

public Slice takeOutput()

Description copied from interface: StateMachine

Drain the next chunk of serialized output ready for the wire, or Slice.EMPTY when nothing is buffered.

Specified by:

takeOutput in interface StateMachine

getResponseContentType

public String getResponseContentType()

Specified by:

getResponseContentType in interface StateMachine

isReadyToExecute

public boolean isReadyToExecute()

Specified by:

isReadyToExecute in interface StateMachine

state

public StateMachine.InvocationState state()

Specified by:

state in interface StateMachine

doAwait

public StateMachine.AwaitResult doAwait(UnresolvedFuture future)

Description copied from interface: StateMachine

Make progress on the still-uncompleted await tree rooted at future, or return null when nothing is left to await (every node already resolved).

On suspension this does not return a value: it sneaky-throws AbortedExecutionException, which should be treated as a clean abort of the user code, not a failure to re-report.

Specified by:

doAwait in interface StateMachine

takeNotification

public @Nullable StateMachine.NotificationValue takeNotification(int handle)

Specified by:

takeNotification in interface StateMachine

input

public StateMachine.Input input()

Specified by:

input in interface StateMachine

stateGet

public int stateGet(String key)

Specified by:

stateGet in interface StateMachine

stateGetKeys

public int stateGetKeys()

Specified by:

stateGetKeys in interface StateMachine

stateSet

public void stateSet(String key,
 Slice bytes)

Specified by:

stateSet in interface StateMachine

stateClear

public void stateClear(String key)

Specified by:

stateClear in interface StateMachine

stateClearAll

public void stateClearAll()

Specified by:

stateClearAll in interface StateMachine

sleep

public int sleep(Duration duration,
 @Nullable String name)

Specified by:

sleep in interface StateMachine

call

public StateMachine.CallHandle call(Target target,
 Slice payload,
 @Nullable String idempotencyKey,
 @Nullable String scope,
 @Nullable String limitKey,
 @Nullable Collection<Map.Entry<String,String>> headers)

Specified by:

call in interface StateMachine

send

public int send(Target target,
 Slice payload,
 @Nullable String idempotencyKey,
 @Nullable String scope,
 @Nullable String limitKey,
 @Nullable Collection<Map.Entry<String,String>> headers,
 @Nullable Duration delay)

Specified by:

send in interface StateMachine

awakeable

public StateMachine.Awakeable awakeable()

Specified by:

awakeable in interface StateMachine

completeAwakeable

public void completeAwakeable(String awakeableId,
 Slice value)

Specified by:

completeAwakeable in interface StateMachine

completeAwakeable

public void completeAwakeable(String awakeableId,
 TerminalException exception)

Specified by:

completeAwakeable in interface StateMachine

createSignalHandle

public int createSignalHandle(String signalName)

Specified by:

createSignalHandle in interface StateMachine

completeSignal

public void completeSignal(String targetInvocationId,
 String signalName,
 Slice value)

Specified by:

completeSignal in interface StateMachine

completeSignal

public void completeSignal(String targetInvocationId,
 String signalName,
 TerminalException exception)

Specified by:

completeSignal in interface StateMachine

promiseGet

public int promiseGet(String key)

Specified by:

promiseGet in interface StateMachine

promisePeek

public int promisePeek(String key)

Specified by:

promisePeek in interface StateMachine

promiseComplete

public int promiseComplete(String key,
 Slice value)

Specified by:

promiseComplete in interface StateMachine

promiseComplete

public int promiseComplete(String key,
 TerminalException exception)

Specified by:

promiseComplete in interface StateMachine

run

public StateMachine.RunResultHandle run(String name)

Specified by:

run in interface StateMachine

proposeRunCompletion

public void proposeRunCompletion(int handle,
 Slice value)

Specified by:

proposeRunCompletion in interface StateMachine

proposeRunCompletion

public void proposeRunCompletion(int handle,
 TerminalException terminalException)

Specified by:

proposeRunCompletion in interface StateMachine

proposeRunCompletion

public void proposeRunCompletion(int handle,
 Throwable exception,
 Duration attemptDuration,
 @Nullable RetryPolicy retryPolicy)

Specified by:

proposeRunCompletion in interface StateMachine

cancelInvocation

public void cancelInvocation(String targetInvocationId)

Specified by:

cancelInvocation in interface StateMachine

attachInvocation

public int attachInvocation(String invocationId)

Specified by:

attachInvocation in interface StateMachine

getInvocationOutput

public int getInvocationOutput(String invocationId)

Specified by:

getInvocationOutput in interface StateMachine

writeOutput

public void writeOutput(Slice value)

Specified by:

writeOutput in interface StateMachine

writeOutput

public void writeOutput(TerminalException exception)

Specified by:

writeOutput in interface StateMachine

end

public void end()

Specified by:

end in interface StateMachine

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface StateMachine