📨Main topics

Carbon Router Topics

This document defines topics produced by the Carbon Router.

There are two classes of topics:

Raw topics: high-frequency deltas used by the UI for realtime rendering.
Wasm topics: low-TPS, semantically meaningful events for WASM functions to follow.

Throughput and batching

When WASM topics can get high TPS, batch by 2 consecutive slots.
Do not have WASM functions follow high-TPS raw topics; it can overload memory.
Prefer whitelisting only WASM topics when creating a function.

WASM Topics

This section summarizes what each topic does and when it emits. Values and schemas are intentionally omitted for simplicity.

Token-driven pulses

📤 wasm.token.holder-pulse
- Purpose: detect meaningful changes in token holders over a short window.
- Emits when: holder count changes by at least ±10 and ≥ 5% across a 2-slot window.
- Filters: tokens created after system start; liquidity < 1M.
- Batch: 2 slots.

struct Message {
  _meta: {
    ts: u64,               // timestamp
    type: "holder_pulse", // common format
  },
  mint: String,
  slots: (u64, u64),
  after: usize,
  before: usize,
}

📤 wasm.token.liquidity-pulse
- Purpose: detect meaningful liquidity changes.
- Emits when: liquidity changes by ±5% and by ≥ 5 SOL across a 2-slot window.
- Filters: tokens created after system start.
- Batch: 2 slots.

struct Message {
  _meta: {
    ts: u64,                   // timestamp
    type: "liquidity_pulse",  // common format
  },
  mint: String,
  slots: (u64, u64),
  after: usize,
  before: usize,
}

📤 wasm.token.trade-in-slot
- Purpose: per-slot trade summary for a token.
- Emits when: total traded volume in the slot ≥ 5 SOL.
- Filters: tokens created after system start; only while not bonded and up to 5 minutes after bonding.
- Frequency: per slot.

struct Message {
  _meta: {
    ts: u64,
    type: "trade_in_slot", // common format
  },
  mint: String,
  count: u64,
  total_volume: f64,       // total SOL volume in slot
  last_updated_slot: u64,
  signature_logs: Vec<SignatureLog>,
  bonded: bool,            // token migrated / not migrated
}

pub struct SignatureLog {
  pub signature: String,         // tx signature
  pub signers: HashSet<String>,  // list of signers
  pub instructions: Vec<String>, // actions in transaction (buy, sell, create)
  pub buy_amt: f64,          // total buy amount of tx
  pub sell_amt: f64,         // total sell amount of tx
}

User-driven actions

📤 wasm.trader.trade-half-sol
- Purpose: capture individual trades with size ≥ 0.5 SOL.
- Emits when: a qualifying trade occurs.
- Filters: tokens created after system start; only while not migrated and up to 5 minutes after migration.

struct Message {
  _meta: {
    ts: u64,              // timestamp
    type: "trade",        // common format
  },
  signature: String,
  mint: String,
  payer: String,
  timestamp: i64,
  slot: u64,
  amount_in: f64,
  amount_out: f64,
  is_buy: bool,
}

📤 wasm.trader.just-funded
- Purpose: flag addresses that traded ≥ 0.5 SOL and received SOL deposits in the last 24 hours.
- Emits when: an address satisfies both conditions above.
- Model:

struct Message {
  _meta: {
    ts: i64,
    type: "just_funded",  // common format
  },
  recipient: String,
  amt_sol: f64,                  // total sol
  details: HashMap<String, f64>, // payer -> amount sol
  payers: Vec<String>,           // list of payers
  exchange: Option<String>,      // e.g. OKX, Upbit, Coinbase, Bithumb, Kucoin, Bitfinex, Kraken, Crypto.com
  label: Option<String>,        // e.g. OKX: Hot Wallet, Binance 1
}

Launchpad events

📤 wasm.launchpad.pumpfun.created and 📤 wasm.launchpad.bonk.created
- Purpose: token creation events from respective launchpads.
- Emits when: a new token is created on the launchpad.
- Filters: tokens created after system start.

struct Message {
  _meta: {
    ts: u64,              // timestamp
    type: "create",       // common format
  },
  mint: String,
  name: String,
  symbol: String,
  uri: String,
  creator: String,
  creator_balance: f64, // creator sol balance
  tokens_migrated_count: usize, // Count of migrated tokens assigned to the creator
  creation_time: i64,
  total_supply: f64,
  decimals: u8,
}

📤 wasm.launchpad.pumpfun.completed and 📤 wasm.launchpad.bonk.completed
- Purpose: token completion/migration events with finalization context.
- Emits when: token completes/migrates on the launchpad.
- Filters: tokens created after system start.

struct Message {
  _meta: {
    ts: u64,              // timestamp
    type: "completed",    // common format
  },
  mint: String,
  migrated_at: Option<i64>,
}

Raw Topics

raw.token-state-changed
- Purpose: realtime deltas for UI rendering.
- Emits when: any token field changes; only changed fields are sent.

struct Message {
  _meta: {
    ts: u64,                 // timestamp
    type: "token_state_changed", // common format
  },
  mint: String,
  last_updated_slot: u64,
  total_supply: f64,
  price: f64,
  liquidity: f64,
  token_liquidity: f64,
  market_cap: f64,
  bonding_progress: f64,
  migrated: bool,
  migrated_at: Option<i64>,
  holders_count: usize,
  trades: u64,                // total trades (buys/sells)
  half_sol_trades: u64,       // total trades > 0.5 SOL
  top10_holder_percent: f64,  // top 10 holders percentage
  top100_holder_percent: f64, // top 100 holders percentage
  creator_tokens_created: usize,
  creator_tokens_migrated: usize,
}

raw.token_created Merge wasm.launchpad.pumpfun.created and wasm.launchpad.bonk.created for a unified creation feed.

PreviousRocksdb states

Last updated 9 days ago