Module hayata_node

cancel_execution(Node::gen_server:server_ref(), ExecutionId::term()) -> ok | {error, term()}

code_change(OldVersion::term(), Node_state::#node_state{}, Extra::term()) -> {ok, #node_state{}}

get_info(Server::gen_server:server_ref()) -> map()

get_state(Server::gen_server:server_ref()) -> local_state()

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

handle_cast(Request::term(), Node_state::#node_state{}) -> {noreply, #node_state{}}

handle_info(Info::term(), Node_state::#node_state{}) -> {noreply, #node_state{}}

init(X1::{agent_id(), node_id(), node_name(), local_state(), edge_definitions()}) -> {ok, #node_state{}}

replace_state(Server::gen_server:server_ref(), NewState::local_state()) -> ok

set_edges(Server::gen_server:server_ref(), Edges::edge_definitions()) -> ok

start_edge(Node::gen_server:server_ref(), EdgeId::edge_id(), ExecutionId::term(), TaskFun::fun(() -> term())) -> {ok, pid()} | {error, term()}

start_execution(Node::gen_server:server_ref(), ExecutionId::term(), EdgeTasks::[edge_task()], TimeoutMs::non_neg_integer()) -> {ok, term()} | {error, term()}

start_execution(Node::gen_server:server_ref(), ExecutionId::term(), EdgeTasks::[edge_task()], TimeoutMs::non_neg_integer(), RecipientPid::pid()) -> {ok, term()} | {error, term()}

start_link(AgentId::agent_id(), NodeId::node_id(), Name::node_name(), InitialState::local_state(), Edges::edge_definitions()) -> gen_server:start_ret()

terminate(Reason::term(), Node_state::#node_state{}) -> ok

track_edge(Server::gen_server:server_ref(), EdgeId::edge_id(), EdgePid::pid()) -> {ok, reference()} | {error, term()}

update_state(Server::gen_server:server_ref(), Updates::local_state()) -> ok

whereis(AgentId::agent_id(), Name::node_name()) -> pid() | undefined