Streaming & Transparency Log

StreamingClient.watch is a live, ACL-filtered SSE change feed; query_arrow_raw streams Arrow IPC. LogClient is the hash-chained transparency log (append + leaf/head reads) — the tamper-evident audit spine.

8 methods across this domain. Signatures, parameters (incl. keyword-only tunable defaults), and the three SDK spellings are ported from the live SDK source; flagship methods carry a hand-written When to use + example.

LogClient

append(data)

append(data)`

  • Python — client.logclient.append(data)
  • TypeScript — append(data)
  • Go — Append(data)

Parameters: data

head()`

  • Python — client.logclient.head()
  • TypeScript — head()
  • Go — Head()

load_leaves(since=0, limit=1000)

load_leaves(since=0, limit=1000)`

  • Python — client.logclient.load_leaves(since=0, limit=1000)
  • TypeScript — loadLeaves(opts)
  • Go — LoadLeaves()

Parameters: since=0, limit=1000

StreamingClient

watch(sql, purpose, reconnect=True)

When to use. Live, ACL-filtered SSE change feed on a type — reactive pipelines.

  • Python — client.streamingclient.watch(sql, purpose, reconnect=True)
  • TypeScript — watch(sql, purpose, opts)
  • Go — Watch(sql)

Parameters: sql, purpose, reconnect=True

Example

for evt in StreamingClient.from_client(relata).watch("Person"):
    print(evt)
for await (const evt of relata.streaming.watch("Person")) { console.log(evt); }

alerts(reconnect=True)

alerts(reconnect=True)`

  • Python — client.streamingclient.alerts(reconnect=True)
  • TypeScript — alerts(opts)
  • Go — Alerts()

Parameters: reconnect=True

query_arrow_raw(sql, purpose=None)

query_arrow_raw(sql, purpose=None)`

  • Python — client.streamingclient.query_arrow_raw(sql, purpose=None)
  • TypeScript — queryArrowRaw(sql, opts)
  • Go — QueryArrowRaw(sql)

Parameters: sql, purpose=None

query_rows(sql, purpose=None)

query_rows(sql, purpose=None)`

  • Python — client.streamingclient.query_rows(sql, purpose=None)
  • TypeScript — queryRows(sql, opts)
  • Go — QueryRows(sql)

Parameters: sql, purpose=None

watch_stream(type, since=None, reconnect=True)

watch_stream(type, since=None, reconnect=True)`

  • Python — client.streamingclient.watch_stream(type, since=None, reconnect=True)

Parameters: type, since=None, reconnect=True