Module: RubyKpi

Defined in:
lib/TCPConnection.rb,
lib/ruby_kpi.rb,
lib/ReplyMessage.rb,
lib/DataStructures.rb,
lib/SSAP_templates.rb,
lib/ruby_kpi/version.rb

Overview

The TCPConnection class

Defined Under Namespace

Classes: Handler, KP, Literal, ReplyMessage, SIBError, TCPConnection, Triple, URI

Constant Summary collapse

JOIN_REQUEST_TEMPLATE =

JOIN

%{<SSAP_message>
<node_id>%s</node_id>
<space_id>%s</space_id>
<transaction_type>JOIN</transaction_type>
<message_type>REQUEST</message_type>
<transaction_id>%s</transaction_id>
<parameter name = "credentials">XXYYZZ</parameter>
</SSAP_message>}
LEAVE_REQUEST_TEMPLATE =

LEAVE

%{<SSAP_message>
<node_id>%s</node_id>
<space_id>%s</space_id>
<transaction_type>LEAVE</transaction_type>
<message_type>REQUEST</message_type>
<transaction_id>%s</transaction_id>
</SSAP_message>}
INSERT_REQUEST_TEMPLATE =

INSERT

%{<SSAP_message>
<node_id>%s</node_id>
<space_id>%s</space_id>
<transaction_type>INSERT</transaction_type>
<message_type>REQUEST</message_type>
<transaction_id>%s</transaction_id>
<parameter name = "insert_graph" encoding = "RDF-M3">
<triple_list>%s</triple_list></parameter>
<parameter name = "confirm">TRUE</parameter>
</SSAP_message>}
REMOVE_REQUEST_TEMPLATE =

REMOVE

%{<SSAP_message>
<message_type>REQUEST</message_type>
<transaction_type>REMOVE</transaction_type>
<transaction_id>%s</transaction_id>
<node_id>%s</node_id>
<space_id>%s</space_id>
<parameter name="confirm">TRUE</parameter>
<parameter name="remove_graph"  encoding="RDF-M3">
<triple_list>%s</triple_list></parameter>
</SSAP_message>}
UPDATE_REQUEST_TEMPLATE =

UPDATE

%{<SSAP_message>
<node_id>%s</node_id>
<space_id>%s</space_id>
<transaction_type>UPDATE</transaction_type>
<message_type>REQUEST</message_type>
<transaction_id>%s</transaction_id>

<parameter name = "insert_graph" encoding = "RDF-M3">
<triple_list>%s</triple_list>
</parameter>

<parameter name = "remove_graph" encoding = "RDF-M3">
<triple_list>%s</triple_list>
</parameter>

<parameter name = "confirm">TRUE</parameter>
</SSAP_message>}
RDF_QUERY_REQUEST_TEMPLATE =

RDF QUERY

%{<SSAP_message>
<node_id>%s</node_id>
<space_id>%s</space_id>
<transaction_type>QUERY</transaction_type>
<message_type>REQUEST</message_type>
<transaction_id>%s</transaction_id>
<parameter name = "type">RDF-M3</parameter>
<parameter name = "query">
<triple_list>%s</triple_list></parameter>
</SSAP_message>}
SPARQL_QUERY_REQUEST_TEMPLATE =

SPARQL QUERY

%{<SSAP_message>
<node_id>%s</node_id>
<space_id>%s</space_id>
<transaction_type>QUERY</transaction_type>
<message_type>REQUEST</message_type>
<transaction_id>%s</transaction_id>
<parameter name = "type">sparql</parameter>
<parameter name = "query">%s</parameter>
</SSAP_message>}
RDF_SUBSCRIBE_REQUEST_TEMPLATE =

RDF SUBSCRIBE

%{<SSAP_message>
<node_id>%s</node_id>
<space_id>%s</space_id>
<transaction_type>SUBSCRIBE</transaction_type>
<message_type>REQUEST</message_type>
<transaction_id>%s</transaction_id>
<parameter name = "type">RDF-M3</parameter>
<parameter name = "query">
<triple_list>%s</triple_list></parameter>
</SSAP_message>}
SPARQL_SUBSCRIBE_REQUEST_TEMPLATE =

SPARQL SUBSCRIBE

%{<SSAP_message>
<node_id>%s</node_id>
<space_id>%s</space_id>
<transaction_type>SUBSCRIBE</transaction_type>
<message_type>REQUEST</message_type>
<transaction_id>%s</transaction_id>
<parameter name = "type">sparql</parameter>
<parameter name = "query">%s</parameter>
</SSAP_message>}
UNSUBSCRIBE_REQUEST_TEMPLATE =

UNSUBSCRIBE

%{<SSAP_message>
<node_id>%s</node_id>
<space_id>%s</space_id>
<transaction_type>UNSUBSCRIBE</transaction_type>
<message_type>REQUEST</message_type>
<transaction_id>%s</transaction_id>
<parameter name = "subscription_id">%s</parameter>
</SSAP_message>}
TRIPLE_TEMPLATE =

OTHER TEMPLATES

%{<triple>
<subject type = "%s">%s</subject>
<predicate>%s</predicate>
<object type = "%s">%s</object>
</triple>}
VERSION =
"0.0.2"