Module hayata_edge

Behaviours: gen_server.

Data Types

edge_id() = term()

execution_id() = term()

task_fun() = fun(() -> task_result())

task_result() = {ok, term()} | {error, term()}

code_change(OldVersion::term(), Edge_state::#edge_state{}, Extra::term()) -> {ok, #edge_state{}}

execute(EdgePid::pid()) -> ok

handle_call(Request::term(), From::gen_server:from(), Edge_state::#edge_state{}) -> {reply, term(), #edge_state{}}

handle_cast(Request::term(), Edge_state::#edge_state{}) -> {noreply, #edge_state{}}

handle_info(Info::term(), Edge_state::#edge_state{}) -> {noreply, #edge_state{}}

init(X1::{pid(), pid() | undefined, edge_id(), execution_id(), task_fun()}) -> {ok, #edge_state{}}

start(NodePid::pid(), EdgeId::edge_id(), ExecutionId::execution_id(), TaskFun::task_fun()) -> gen_server:start_ret()

start(NodePid::pid(), ReducerPid::pid() | undefined, EdgeId::edge_id(), ExecutionId::execution_id(), TaskFun::task_fun()) -> gen_server:start_ret()

terminate(Reason::term(), Edge_state::#edge_state{}) -> ok

Generated by EDoc