Package dev.restate.sdk.core

Class SyscallsImpl

java.lang.Object

dev.restate.sdk.core.SyscallsImpl

All Implemented Interfaces:

Syscalls

public final class SyscallsImpl
extends Object

Method Summary

Modifier and Type	Method	Description
void	awakeable(SyscallCallback<Map.Entry<String,Deferred<ByteBuffer>>> callback)
void	call(Target target, ByteBuffer parameter, SyscallCallback<Deferred<ByteBuffer>> callback)
void	clear(String name, SyscallCallback<Void> callback)
void	clearAll(SyscallCallback<Void> callback)
void	close()
default Deferred<Void>	createAllDeferred(List<Deferred<?>> children)
default Deferred<Integer>	createAnyDeferred(List<Deferred<?>> children)
void	enterSideEffectBlock(String name, EnterSideEffectSyscallCallback callback)
void	exitSideEffectBlock(ByteBuffer toWrite, ExitSideEffectSyscallCallback callback)
void	exitSideEffectBlockWithException(Throwable runException, @Nullable RetryPolicy retryPolicy, ExitSideEffectSyscallCallback callback)
void	exitSideEffectBlockWithTerminalException(TerminalException toWrite, ExitSideEffectSyscallCallback callback)
void	fail(Throwable cause)
void	get(String name, SyscallCallback<Deferred<ByteBuffer>> callback)
String	getFullyQualifiedMethodName()
InvocationState	getInvocationState()
void	getKeys(SyscallCallback<Deferred<Collection<String>>> callback)
boolean	isInsideSideEffect()
String	objectKey()
void	peekPromise(String key, SyscallCallback<Deferred<ByteBuffer>> callback)
void	promise(String key, SyscallCallback<Deferred<ByteBuffer>> callback)
void	rejectAwakeable(String serializedId, String reason, SyscallCallback<Void> callback)
void	rejectPromise(String key, String reason, SyscallCallback<Deferred<Void>> callback)
Request	request()
void	resolveAwakeable(String serializedId, ByteBuffer payload, SyscallCallback<Void> callback)
<T> void	resolveDeferred(Deferred<T> deferredToResolve, SyscallCallback<Void> callback)
void	resolvePromise(String key, ByteBuffer payload, SyscallCallback<Deferred<Void>> callback)
void	send(Target target, ByteBuffer parameter, @Nullable Duration delay, SyscallCallback<Void> callback)
void	set(String name, ByteBuffer value, SyscallCallback<Void> callback)
void	sleep(Duration duration, SyscallCallback<Deferred<Void>> callback)
void	writeOutput(TerminalException throwable, SyscallCallback<Void> callback)
void	writeOutput(ByteBuffer value, SyscallCallback<Void> callback)

Methods inherited from class java.lang.Object

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

Method Details

objectKey

public String objectKey()

Specified by:

objectKey in interface Syscalls

request

public Request request()

Specified by:

request in interface Syscalls

writeOutput

public void writeOutput(ByteBuffer value,
 SyscallCallback<Void> callback)

Specified by:

writeOutput in interface Syscalls

writeOutput

public void writeOutput(TerminalException throwable,
 SyscallCallback<Void> callback)

Specified by:

writeOutput in interface Syscalls

get

public void get(String name,
 SyscallCallback<Deferred<ByteBuffer>> callback)

Specified by:

get in interface Syscalls

getKeys

public void getKeys(SyscallCallback<Deferred<Collection<String>>> callback)

Specified by:

getKeys in interface Syscalls

clear

public void clear(String name,
 SyscallCallback<Void> callback)

Specified by:

clear in interface Syscalls

clearAll

public void clearAll(SyscallCallback<Void> callback)

Specified by:

clearAll in interface Syscalls

set

public void set(String name,
 ByteBuffer value,
 SyscallCallback<Void> callback)

Specified by:

set in interface Syscalls

sleep

public void sleep(Duration duration,
 SyscallCallback<Deferred<Void>> callback)

Specified by:

sleep in interface Syscalls

call

public void call(Target target,
 ByteBuffer parameter,
 SyscallCallback<Deferred<ByteBuffer>> callback)

Specified by:

call in interface Syscalls

send

public void send(Target target,
 ByteBuffer parameter,
 @Nullable Duration delay,
 SyscallCallback<Void> callback)

Specified by:

send in interface Syscalls

enterSideEffectBlock

public void enterSideEffectBlock(String name,
 EnterSideEffectSyscallCallback callback)

Specified by:

enterSideEffectBlock in interface Syscalls

exitSideEffectBlock

public void exitSideEffectBlock(ByteBuffer toWrite,
 ExitSideEffectSyscallCallback callback)

Specified by:

exitSideEffectBlock in interface Syscalls

exitSideEffectBlockWithTerminalException

public void exitSideEffectBlockWithTerminalException(TerminalException toWrite,
 ExitSideEffectSyscallCallback callback)

Specified by:

exitSideEffectBlockWithTerminalException in interface Syscalls

exitSideEffectBlockWithException

public void exitSideEffectBlockWithException(Throwable runException,
 @Nullable RetryPolicy retryPolicy,
 ExitSideEffectSyscallCallback callback)

Specified by:

exitSideEffectBlockWithException in interface Syscalls

awakeable

public void awakeable(SyscallCallback<Map.Entry<String,Deferred<ByteBuffer>>> callback)

Specified by:

awakeable in interface Syscalls

resolveAwakeable

public void resolveAwakeable(String serializedId,
 ByteBuffer payload,
 SyscallCallback<Void> callback)

Specified by:

resolveAwakeable in interface Syscalls

rejectAwakeable

public void rejectAwakeable(String serializedId,
 String reason,
 SyscallCallback<Void> callback)

Specified by:

rejectAwakeable in interface Syscalls

promise

public void promise(String key,
 SyscallCallback<Deferred<ByteBuffer>> callback)

Specified by:

promise in interface Syscalls

peekPromise

public void peekPromise(String key,
 SyscallCallback<Deferred<ByteBuffer>> callback)

Specified by:

peekPromise in interface Syscalls

resolvePromise

public void resolvePromise(String key,
 ByteBuffer payload,
 SyscallCallback<Deferred<Void>> callback)

Specified by:

resolvePromise in interface Syscalls

rejectPromise

public void rejectPromise(String key,
 String reason,
 SyscallCallback<Deferred<Void>> callback)

Specified by:

rejectPromise in interface Syscalls

resolveDeferred

public <T> void resolveDeferred(Deferred<T> deferredToResolve,
 SyscallCallback<Void> callback)

Specified by:

resolveDeferred in interface Syscalls

getFullyQualifiedMethodName

public String getFullyQualifiedMethodName()

getInvocationState

public InvocationState getInvocationState()

isInsideSideEffect

public boolean isInsideSideEffect()

Specified by:

isInsideSideEffect in interface Syscalls

Returns:

true if it's inside a side effect block.

close

public void close()

fail

public void fail(Throwable cause)

Specified by:

fail in interface Syscalls

createAnyDeferred

default Deferred<Integer> createAnyDeferred(List<Deferred<?>> children)

Specified by:

createAnyDeferred in interface Syscalls

createAllDeferred

default Deferred<Void> createAllDeferred(List<Deferred<?>> children)

Specified by:

createAllDeferred in interface Syscalls