Module achlys

Top level module operating the achlys application as well as providing the main API to the underlying components.

Authors: Igor Kopestenski (igor.kopestenski@uclouvain.be) [web site: https://github.com/Laymer/achlys].

Description

Top level module operating the achlys application as well as providing the main API to the underlying components.

Data Types

task()

task() = #{name => atom(), targets => task_targets(), execution_type => task_execution_type(), function => function()}

task_execution_type()

task_execution_type() = bitstring()

task_targets()

task_targets() = [node()] | bitstring()

Function Index

bane/1Returns the aggregates for the given variable as seen by the current node.
bane_all_preys/1Returns the aggregates for the given variable as seen by the current node for all nodes.
bite/1Adds the given task in the replicated task set.
clusterize/0Attempts to discover and join other neighboring nodes.
contagion/0Form Lasp cluster without attempting to ping neighbors beforehand.
get_all_tasks/0Returns current view of all tasks.
get_preys/0Returns a list of known remote hostnames that could be potential neighbors.
pandemia/0Close disterl TCP connections with neighboring nodes.
start/0Start the application.
stop/0Stop the Application.
venom/0Collect data based on sensors available on Pmod modules and store aggregated values in corresponding Lasp variable.
venom/1Collect data based on sensors available on Pmod modules and store aggregated values in corresponding Lasp variable.

Function Details

bane/1

bane(Data::atom()) -> list()

Returns the aggregates for the given variable as seen by the current node.

bane_all_preys/1

bane_all_preys(Data::atom()) -> list()

Returns the aggregates for the given variable as seen by the current node for all nodes.

bite/1

bite(Task::achlys:task()) -> ok

Adds the given task in the replicated task set.

See also: achlys_task_server:add_task/1.

clusterize/0

clusterize() -> [atom()]

Attempts to discover and join other neighboring nodes.

contagion/0

contagion() -> [{error, atom()} | {ok, atom()}]

Form Lasp cluster without attempting to ping neighbors beforehand.

get_all_tasks/0

get_all_tasks() -> [achlys:task()] | []

Returns current view of all tasks.

get_preys/0

get_preys() -> any()

Returns a list of known remote hostnames that could be potential neighbors.

pandemia/0

pandemia() -> ok

Close disterl TCP connections with neighboring nodes.

start/0

start() -> ok

Start the application.

stop/0

stop() -> ok

Stop the Application

venom/0

venom() -> ok

Collect data based on sensors available on Pmod modules and store aggregated values in corresponding Lasp variable.

venom/1

venom(Worker::atom()) -> ok

Collect data based on sensors available on Pmod modules and store aggregated values in corresponding Lasp variable.


Generated by EDoc