Skip to main content

Edge

CANCEL_EDGE_CQ​

cancel_edge_cq(Charstring edge, Object id) -> Object
STABLE

No description.

EDGE:GET_MANAGER​

edge:get_manager(Charstring edgeid) -> Charstring
STABLE

Get edge manager for edgeid

EDGE:GROUP_MANAGERS​

edge:group_managers(Vector of Charstring edges)->Bag of (Charstring, Vector of Charstring)
STABLE

No description.

EDGE:MY_ACTUAL_STATE​

edge:my_actual_state( ) -> Record
STABLE

The last updated actual state of this edge device.

EDGE:MY_DESIRED_STATE​

edge:my_desired_state( ) -> Record
STABLE

The current desired state of this edge device.

EDGE:RUN​

edge:run( ) -> Charstring
STABLE

Start an autonomous edge

EDGE_CQ​

edge_cq(Vector of Charstring edges, Charstring cq, Record opts) -> Stream
STABLE

No description.

edge_cq(Charstring manager, Vector of Charstring edges, Charstring query, Record opts) -> Stream
STABLE

No description.

edge_cq(Charstring edge, Charstring cq, Record opts) -> Stream
STABLE

Execute continuous query cq on edge with options opts

Options can contain the following fields:

  • store-and-forward: String - name of store-and-foward stream. Used to enable store and forward and to retrieve forwarded data in a later stage. When store and forward is enabled data is buffered for forward-interval number of seconds before attempting to send it to the requesting server. When store and forward is enabled the options buffer-in-memory and buffer-size will both affect the amount of data to store between forwards.

  • store-and-forward-interval: Number of seconds between each forward attempt.

  • buffer-on-disk: Set to true to buffer intermediate data on disk in log_directory()/snf/<store-and-forward-name> instead of in memory.

  • buffer-size: Number of rows to store in buffer, when buffer is full evict the least recently pushed row - default value: 1000.

edge_cq(Vector of Charstring edges, Charstring cq) -> Stream
STABLE

Broadcast continuous query cq to edges and merge result streams

edge_cq(Charstring edge, Charstring cq) -> Stream
STABLE

Execute continuous query cq on edge

EDGE_CQ0​

edge_cq0(Charstring manager, Vector of Charstring edges, Charstring query, Record opts) -> Stream
STABLE

No description.

EDGE_LISTENER​

edge_listener(Charstring edgespec) -> Charstring
STABLE

Register this peer as edge in edge server where edgespec is

edge or edge@host or edge@host:port or edge@:port

EDGE_LISTENING​

edge_listening(Charstring edgeid) -> Boolean
STABLE

Check if an edge named edgeid is listening

EDGE_MGR​

edge_mgr( ) -> Charstring
STABLE

Set edge mgr status of this sa.engine instance

EDGE_MGR_ASSIGNMENT​

edge_mgr_assignment(Charstring assignment) -> Boolean
STABLE

Alter the edge mgr assignment. Valid input is

basic, manual, scale

EDGE_QUERY​

edge_query(Charstring edge, Charstring query) -> Object
STABLE

No description.

edge_query(Charstring edge, Charstring query, Record opts) -> Object
STABLE

No description.

EDGE_STATUS​

edge_status( ) -> Bag of Record
STABLE

No description.

GET_SNF_FILE​

get_snf_file(Charstring edgeid, Charstring flow) -> Charstring
STABLE

No description.

GET_SNF_FILES​

get_snf_files(Charstring edgeid, Charstring flow) -> Bag of Charstring
STABLE

No description.

GET_SNF_FOLDER​

get_snf_folder(Charstring edgeid) -> Charstring dir
STABLE

No description.

GET_SNF_LOG​

get_snf_log(Charstring edgeid, Charstring snf) -> Stream of Vector
STABLE

No description.

LISTENING_EDGES​

listening_edges( ) -> Vector of Charstring
STABLE

Return names of all listening edge peers

NAME​

name(Edgequery eq) -> Charstring
STABLE

Name of the edge query eq. This is a unique identifier of

this edge query. This name can be used to find this request and also stop it using cancel_edge_cq on a server in the federation.

OPTIONS​

options(Edgequery eq) -> Record
STABLE

Options for the stored edge query eq. This is the same record

that can be used as options in edge_cq. See Store and forward for more details

RUN_STORED_EDGE_QUERIES​

run_stored_edge_queries( ) -> Bag of Charstring
STABLE

Sun all stored edge queries on this peer.

RUN_STORED_EDGE_QUERY​

run_stored_edge_query(Edgequery eq) -> Charstring
STABLE

Start stored edge query eq.

run_stored_edge_query(Charstring name) -> Charstring
STABLE

Start stored edge query named name

SNF_CSV_STORER​

snf_csv_storer(Stream s, Charstring eid, Charstring flow, Record params) -> Boolean
STABLE

No description.

SNF_JSON_STORER​

snf_json_storer(Stream s, Charstring eid, Charstring flow, Record params) -> Charstring
STABLE

No description.

SNF_PUBLISH_STORER​

snf_publish_storer(Stream s, Charstring eid, Charstring flow, Record params) -> Object
STABLE

No description.

START_EDGE​

start_edge(Charstring edgespec) -> Charstring
STABLE

Start edge edgespec on this comuter

START_EDGES​

start_edges(Vector of Charstring edgespecs) -> Vector of Charstring
STABLE

Start edge peers on this computer in parallel

STATEMENT​

statement(Edgequery eq) -> Charstring
STABLE

Statement of the edge query eq. An OSQL statment as a string that

will be run when this EdgeQuery is started. This is the same as the statement argument in a regular edge_cq