adk_memory_outbox_processor (erlang_adk v0.7.0)

View Source

Bounded concurrent processor for adk_memory_outbox.

submit/2 waits only for durable local admission. It never waits for the resolver or memory adapter; those calls run in bounded lightweight workers. Multiple processors may share one outbox because claims are lease-fenced.

Summary

Functions

child_spec(Opts)
code_change(OldVersion, State, Extra)
handle_call(Request, From, State)
handle_cast(Message, State)
handle_info(Message, State0)
init(Opts)
kick(Processor)
start_link(Opts)
status(Processor, JobId)
submit(Processor, Request)

Durably enqueue and wake workers. No adapter call is made inline.

terminate(Reason, State)

Functions

child_spec(Opts)

code_change(OldVersion, State, Extra)

handle_call(Request, From, State)

handle_cast(Message, State)

handle_info(Message, State0)

init(Opts)

kick(Processor)

start_link(Opts)

status(Processor, JobId)

submit(Processor, Request)

Durably enqueue and wake workers. No adapter call is made inline.

terminate(Reason, State)