Package dev.restate.sdk.core.statemachine

Interface StateMachine

All Superinterfaces:

Flow.Processor<Slice,Slice>, Flow.Publisher<Slice>, Flow.Subscriber<Slice>

public interface StateMachine
extends Flow.Processor<Slice,Slice>

More or less same as the VM trait

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final record	StateMachine.Awakeable
static final record	StateMachine.CallHandle
static interface	StateMachine.DoProgressResponse
static final record	StateMachine.Input

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 Collection<Map.Entry<String,String>> headers)
void	cancelInvocation(String targetInvocationId)
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.DoProgressResponse	doProgress(List<Integer> anyHandle)
void	end()
int	getInvocationOutput(String invocationId)
String	getResponseContentType()
static StateMachine	init(HeadersAccessor headersAccessor, EndpointRequestHandler.LoggingContextSetter loggingContextSetter)
@Nullable StateMachine.Input	input()
boolean	isCompleted(int handle)
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, Throwable exception, Duration attemptDuration, RetryPolicy retryPolicy)
int	run(String name)
int	send(Target target, Slice payload, @Nullable String idempotencyKey, @Nullable Collection<Map.Entry<String,String>> headers, @Nullable Duration delay)
int	sleep(Duration duration, String name)
InvocationState	state()
void	stateClear(String key)
void	stateClearAll()
int	stateGet(String key)
int	stateGetKeys()
void	stateSet(String key, Slice bytes)
Optional<NotificationValue>	takeNotification(int handle)
CompletableFuture<Void>	waitForReady()
CompletableFuture<Void>	waitNextInputSignal()
void	writeOutput(Slice value)
void	writeOutput(TerminalException exception)

Methods inherited from interface java.util.concurrent.Flow.Publisher

subscribe

Methods inherited from interface java.util.concurrent.Flow.Subscriber

onComplete, onError, onNext, onSubscribe

Method Details

init

static StateMachine init(HeadersAccessor headersAccessor,
 EndpointRequestHandler.LoggingContextSetter loggingContextSetter)

getResponseContentType

String getResponseContentType()

waitForReady

CompletableFuture<Void> waitForReady()

waitNextInputSignal

CompletableFuture<Void> waitNextInputSignal()

doProgress

StateMachine.DoProgressResponse doProgress(List<Integer> anyHandle)

isCompleted

boolean isCompleted(int handle)

takeNotification

Optional<NotificationValue> takeNotification(int handle)

input

@Nullable StateMachine.Input input()

stateGet

int stateGet(String key)

stateGetKeys

int stateGetKeys()

stateSet

void stateSet(String key,
 Slice bytes)

stateClear

void stateClear(String key)

stateClearAll

void stateClearAll()

sleep

int sleep(Duration duration,
 String name)

call

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

send

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

awakeable

StateMachine.Awakeable awakeable()

completeAwakeable

void completeAwakeable(String awakeableId,
 Slice value)

completeAwakeable

void completeAwakeable(String awakeableId,
 TerminalException exception)

createSignalHandle

int createSignalHandle(String signalName)

completeSignal

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

completeSignal

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

promiseGet

int promiseGet(String key)

promisePeek

int promisePeek(String key)

promiseComplete

int promiseComplete(String key,
 Slice value)

promiseComplete

int promiseComplete(String key,
 TerminalException exception)

run

int run(String name)

proposeRunCompletion

void proposeRunCompletion(int handle,
 Slice value)

proposeRunCompletion

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

cancelInvocation

void cancelInvocation(String targetInvocationId)

attachInvocation

int attachInvocation(String invocationId)

getInvocationOutput

int getInvocationOutput(String invocationId)

writeOutput

void writeOutput(Slice value)

writeOutput

void writeOutput(TerminalException exception)

end

void end()

state

InvocationState state()