Rclex.Executor (Rclex v0.5.1) View Source

T.B.A

Link to this section Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

create_nodes(context, node_name, num_node)

create_nodes(context, node_name, namespace, num_node)

複数ノード生成
create_nodes/4ではcreate_nodes/3に加えて名前空間の指定が可能
返り値:
    node_identifier_list :: Enumerable.t()
    作成したノードプロセスのnameのリストを返す

create_singlenode(context, node_name)

create_singlenode(context, node_name, node_namespace)

ノードをひとつだけ作成
名前空間の有無を設定可能
返り値:
    node_identifier :: string()
    作成したノードプロセスのnameを返す

create_timer(call_back, args, time)

create_timer(call_back, args, time, limit)

finish_node(node_identifier)

ノードプロセスを削除する
入力
    node_identifier :: string()
    削除するnodeのプロセス名

finish_nodes(node_identifier_list)

init(_)

Executorプロセスの初期化
下位プロセスとしてJobQueue, JobExecutorプロセスを生成する
状態:
    supervisor_ids :: map()
    keyがnode_identifer、valueがnode情報。現在はnodeプロセスのsupervisorのidを格納している

start_link(_)

stop_timer(timer_id)

タイマープロセスを削除する
入力
    timer_id :: pid()
    削除するタイマープロセスのid

Link to this section Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

create_nodes(context, node_name, num_node)

create_nodes(context, node_name, namespace, num_node)

複数ノード生成
create_nodes/4ではcreate_nodes/3に加えて名前空間の指定が可能
返り値:
    node_identifier_list :: Enumerable.t()
    作成したノードプロセスのnameのリストを返す

create_singlenode(context, node_name)

create_singlenode(context, node_name, node_namespace)

ノードをひとつだけ作成
名前空間の有無を設定可能
返り値:
    node_identifier :: string()
    作成したノードプロセスのnameを返す

create_timer(call_back, args, time)

create_timer(call_back, args, time, limit)

finish_node(node_identifier)

ノードプロセスを削除する
入力
    node_identifier :: string()
    削除するnodeのプロセス名

finish_nodes(node_identifier_list)

init(_)

Executorプロセスの初期化
下位プロセスとしてJobQueue, JobExecutorプロセスを生成する
状態:
    supervisor_ids :: map()
    keyがnode_identifer、valueがnode情報。現在はnodeプロセスのsupervisorのidを格納している

start_link(_)

stop_timer(timer_id)

タイマープロセスを削除する
入力
    timer_id :: pid()
    削除するタイマープロセスのid