Module: Restate::WorkflowContext

Includes:
ObjectContext
Included in:
Server::Context
Defined in:
lib/restate/context.rb

Overview

Context interface for Workflow main handler (full state + promises). Extends ObjectContext with durable promise operations.

Instance Method Summary collapse

Methods included from ObjectContext

#clear, #clear_all, #set

Methods included from ObjectSharedContext

#get, #get_async, #state_keys, #state_keys_async

Methods included from Context

#awakeable, #cancel_invocation, #generic_call, #generic_send, #key, #object_call, #object_send, #reject_awakeable, #reject_signal, #request, #resolve_awakeable, #resolve_signal, #run, #run_sync, #scope, #service_call, #service_send, #signal, #sleep, #wait_any, #workflow_call, #workflow_send

Instance Method Details

#peek_promise(name, serde: JsonSerde) ⇒ Object

Peek at a durable promise without blocking. Returns nil if not yet resolved.



258
 
# File 'lib/restate/context.rb', line 258

def peek_promise(name, serde: JsonSerde); end

#promise(name, serde: JsonSerde) ⇒ Object

Get a durable promise value, blocking until resolved.



255
 
# File 'lib/restate/context.rb', line 255

def promise(name, serde: JsonSerde); end

#reject_promise(name, message, code: 500) ⇒ Object

Reject a durable promise with a terminal failure.



264
 
# File 'lib/restate/context.rb', line 264

def reject_promise(name, message, code: 500); end

#resolve_promise(name, payload, serde: JsonSerde) ⇒ Object

Resolve a durable promise with a value.



261
 
# File 'lib/restate/context.rb', line 261

def resolve_promise(name, payload, serde: JsonSerde); end