Skip to main content

Edge

Functions​

cancel_edge_cq(Charstring edge,Object id)->Object
edge:get_manager(Charstring edgeid)->Charstring

Get edge manager for edgeid

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

The last updated actual state of this edge device.

edge:my_desired_state()->Record

The current desired state of this edge device.

edge:run()->Charstring

Start an autonomous edge

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

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

Broadcast continuous query cq to edges and merge result streams

edge_cq(Charstring edge,Charstring cq)->Stream

Execute continuous query cq on edge

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

Register this peer as edge in edge server where edgespec is edge or edge@host or edge@host:port or edge@:port

edge_listening(Charstring edgeid)->Boolean

Check if an edge named edgeid is listening

edge_mgr()->Charstring

Set edge mgr status of this sa.engine instance

edge_mgr_assignment(Charstring assignment)->Boolean

Alter the edge mgr assignment. Valid input is basic, manual, scale

edge_query(Charstring edge,Charstring query)->Object
edge_query(Charstring edge,Charstring query,Record opts)->Object
edge_status()->Bag of Record
get_snf_file(Charstring edgeid,Charstring flow)->Charstring
get_snf_files(Charstring edgeid,Charstring flow)->Bag of Charstring
get_snf_folder(Charstring edgeid)->Charstring dir
get_snf_log(Charstring edgeid,Charstring snf)->Stream of Vector
listening_edges()->Vector of Charstring

Return names of all listening edge peers

name(Edgequery eq)->Charstring

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(Edgequery eq)->Record

Options for the stored edge query eq. This is the same record that can be used as options in edge_cq. See Topics->Edge or Store and forward for more details

run_stored_edge_queries()->Bag of Charstring

Sun all stored edge queries on this peer.

run_stored_edge_query(Edgequery eq)->Charstring

Start stored edge query eq.

run_stored_edge_query(Charstring name)->Charstring

Start stored edge query named name

snf_csv_storer(Stream s,Charstring eid,Charstring flow,Record params)->Boolean
snf_json_storer(Stream s,Charstring eid,Charstring flow,Record params)
               ->Charstring
snf_publish_storer(Stream s,Charstring eid,Charstring flow,Record params)
                  ->Object
start_edge(Charstring edgespec)->Charstring

Start edge edgespec on this comuter

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

Start edge peers on this computer in parallel

statement(Edgequery eq)->Charstring

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