adk_trigger_schedule (erlang_adk v0.7.0)

View Source

Fixed-delay periodic adapter for the ambient runtime.

The adapter owns exactly one timer. Every tick is submitted through the bounded ambient queue and receives an idempotency key based on the schedule identity and wall-clock interval slot. Slow or full runtimes therefore do not create overlapping timer processes or an internal delivery backlog.

Summary

Functions

child_spec(Options)
code_change(OldVersion, State, Extra)
handle_call(Request, From, State)
handle_cast(Message, State)
handle_info(Info, State)
init(Options)
start(Trigger, ScheduleId, IntervalMs, EventTemplate)
start(Trigger, ScheduleId, IntervalMs, EventTemplate, Options)
start_link(Options)
status(Pid)
stop(Pid)
terminate(Reason, State)

Functions

child_spec(Options)

-spec child_spec(map()) -> supervisor:child_spec().

code_change(OldVersion, State, Extra)

handle_call(Request, From, State)

handle_cast(Message, State)

handle_info(Info, State)

init(Options)

start(Trigger, ScheduleId, IntervalMs, EventTemplate)

-spec start(binary(), binary(), pos_integer(), map()) -> {ok, pid()} | {error, term()}.

start(Trigger, ScheduleId, IntervalMs, EventTemplate, Options)

-spec start(binary(), binary(), pos_integer(), map(), map()) -> {ok, pid()} | {error, term()}.

start_link(Options)

-spec start_link(map()) -> gen_server:start_ret().

status(Pid)

-spec status(pid()) -> {ok, map()} | {error, term()}.

stop(Pid)

-spec stop(pid()) -> ok | {error, term()}.

terminate(Reason, State)