Write Once, Run Everywhere

Read the docs

const jsc8 = require("jsc8");
const url = "https://play.paas.macrometa.io/";
const apiKey = "XXXX"
const collectionName = "employees";

const client = new jsc8({url,apiKey});
(async () => {
  const response = await client.createCollection(collectionName, {
    stream: true,
  });
  console.log("Created collection: ", response);
})();

Read the docs

from c8 import C8Client
fed_url = "play.paas.macrometa.io"
api_key = "XXXX";
collection_name = "employees"

if __name__ == '__main__':
    client = C8Client(protocol='https', host=fed_url, port=443,apikey=api_key)
    response = client.create_collection(name= collection_name,stream=True)    
    print("Created Collection:{}".format(response))

Read the docs

gdnsl collection create employees --stream

Read the docs

const jsc8 = require("jsc8");
const url = "https://play.paas.macrometa.io/";
const apiKey = "XXXX";
const queryWorkerName = "insertRecord";
const queryWorker =
    "INSERT { 'firstname': @firstname, 'lastname': @lastname, 'email': @email, 'zipcode': @zipcode, '_key': @email } IN employees";

const client = new jsc8({ url, apiKey });
(async () => {
  const response = await client.createRestql(queryWorkerName, queryWorker);
  console.log("Created query worker!", response);
})();

Read the docs

from c8 import C8Client
fed_url = "play.paas.macrometa.io"
api_key = "XXXX";
query_name = "insertRecord"
value = "INSERT {'firstname': @firstname, 'lastname': @lastname, 'email': @email, 'zipcode': @zipcode, '_key': @email} IN employees"
insert_data = {"query": {"name": query_name, "value": value}}

if __name__ == '__main__':
    client = C8Client(protocol='https', host=fed_url, port=443,apikey=api_key)
    response = client.create_restql(insert_data)  
    print("Created QueryWorker: {}".format(response))

Read the docs

gdnsl query-worker create insertRecord --value "INSERT {'firstname': @firstname, 'lastname': @lastname, 'email': @email, 'zipcode': @zipcode, '_key': @email} IN employees"

Read the docs

const jsc8 = require("jsc8");
const url = "https://play.paas.macrometa.io/";
const apiKey = "XXXX";
const queryWorkerName = "insertRecord";
const record = {
  firstname: "John",
  lastname: "Doe",
  email: "john.doe@macrometa.io",
  zipcode: "511037",
};
const client = new jsc8({ url, apiKey });
(async () => {
  const response = await client.executeRestql(queryWorkerName, record);
  console.log("Data inserted into query worker!");
})();

Read the docs

from c8 import C8Client
fed_url = "play.paas.macrometa.io"
api_key = "XXXX";
query_name = "insertRecord"
record = {"bindVars": {"firstname": "John", "lastname": "Doe",
                      "email": "john.doe@macrometa.io", "zipcode": "511037"}}

if __name__ == '__main__':
    client = C8Client(protocol='https', host=fed_url, port=443,apikey=api_key)
    response = client.execute_restql(query_name,record)
    print("Created QueryWorker: {}".format(response))

Read the docs

gdnsl query-worker run insertRecord --param "firstname=John" "lastname=Doe" "email=john.doe@macrometa.com" "zipcode=511037"

Read the docs

const jsc8 = require("jsc8");
const url = "https://play.paas.macrometa.io/";
const apiKey = "XXXX";
const collectionName = "employees";
const client = new jsc8({ url, apiKey });
(async () => {
  const listener = await client.onCollectionChange(collectionName);
  listener.on("message", (msg) => {
    console.log("Event =>", msg);
  });
  listener.on("open", () => {
    console.log("Connection open...");
  });
  listener.on("close", () => {
    console.log("Connection closed!");
  });
})();

Read the docs

from c8 import C8Client
fed_url = "play.paas.macrometa.io"
api_key = "XXXX";
collection_name = "employees"

def callback_fn(event):
    print(event)

if __name__ == '__main__':
    client = C8Client(protocol='https', host=fed_url, port=443,apikey=api_key)
    client.on_change(collection_name, callback=callback_fn)