> ## Documentation Index
> Fetch the complete documentation index at: https://docs.slate-labs.com/llms.txt
> Use this file to discover all available pages before exploring further.

# Stream Activity

> Global CRM activity firehose (SSE), 4Hz wall-clock-aligned.

Subscribes to Redis channel 'crm:activity:firehose'. The workflow engine
(same service) is the sole producer — it publishes slim events for
customer.registered, transaction.approved, order.opened/closed,
stopout.triggered.

Cadence: aligned to the 4Hz wall-clock metronome (250ms boundaries),
matching the rest of the JumpTech tick pipeline (PnL flush, OHLC flush,
last_ticks flush). Every metronome boundary the buffered events are
drained and emitted as a single SSE frame containing a JSON array.
Two clients connected to the same broker tick on the same boundary —
no phase drift between subsystems.

Buffer cap: 250 events per cycle (oldest dropped on overflow). At 4Hz
that's 1000 events/sec sustainable per client.

Heartbeat: empty array on each metronome boundary keeps proxies alive,
so no separate keepalive timer needed.



## OpenAPI

````yaml /openapi.json get /stream/activity
openapi: 3.1.0
info:
  title: Slate API
  version: 1.0.0
  description: Trading infrastructure API.
servers:
  - url: https://api.{your-broker}.slate-labs.com
    variables:
      your-broker:
        default: broker
security: []
tags:
  - name: Authentication
  - name: API Tokens
  - name: Customers
  - name: Accounts
  - name: Orders
  - name: Instruments & Groups
  - name: Transactions
  - name: Payments
  - name: Transfers
  - name: Risk
  - name: Workflow & CRM
  - name: Messaging
  - name: Integrations
  - name: Webhooks
  - name: Compliance
  - name: Promo codes
  - name: Reporting
  - name: Audit
  - name: Fraud & moderation
  - name: Broker settings
  - name: Users
  - name: Roles & Teams
  - name: Streams (SSE)
  - name: Simulator
  - name: Observability
  - name: Prop trading
paths:
  /stream/activity:
    get:
      tags:
        - Streams (SSE)
      summary: Stream Activity
      description: |-
        Global CRM activity firehose (SSE), 4Hz wall-clock-aligned.

        Subscribes to Redis channel 'crm:activity:firehose'. The workflow engine
        (same service) is the sole producer — it publishes slim events for
        customer.registered, transaction.approved, order.opened/closed,
        stopout.triggered.

        Cadence: aligned to the 4Hz wall-clock metronome (250ms boundaries),
        matching the rest of the JumpTech tick pipeline (PnL flush, OHLC flush,
        last_ticks flush). Every metronome boundary the buffered events are
        drained and emitted as a single SSE frame containing a JSON array.
        Two clients connected to the same broker tick on the same boundary —
        no phase drift between subsystems.

        Buffer cap: 250 events per cycle (oldest dropped on overflow). At 4Hz
        that's 1000 events/sec sustainable per client.

        Heartbeat: empty array on each metronome boundary keeps proxies alive,
        so no separate keepalive timer needed.
      operationId: stream_activity_stream_activity_get
      responses:
        '200':
          description: Successful Response
          content:
            application/json:
              schema: {}

````