home/program-streams/raydium_clmm
PROGRAM STREAMSLIVEDEX

Raydium CLMM Streams

Raydium's concentrated liquidity for capital-efficient trading

Stream every Raydium CLMM interaction. Swaps, position management, tick operations, reward claims, and protocol fees. 36 decoded streams covering Raydium's concentrated liquidity pools used by the most active Solana traders.

CAMMCzo5YL8w4VFF8KVHrK22GGUsp5VTaW7grrKgrWqK
View Pricing
36
Total Streams
decoded and live
25
Instructions
every program call
11
Events
program log events
<50ms
Latency
on-chain to your app

Why Stream Raydium CLMM from NoLimitNodes

Decoded, typed, delivered. No parsing, no delays.

Every Instruction Decoded

Every on-chain instruction parsed into typed fields. Accounts, arguments, and metadata, ready to use.

Every Event Captured

Program events (logs) decoded into structured data. No log parsing, no regex, just typed fields.

Sub-50ms Latency

Events arrive at your app within 50 milliseconds of on-chain confirmation. Fast enough for trading.

JSON or Protobuf

Choose JSON for easy debugging or Protobuf for maximum performance. Same data, your choice of format.

No IDL Decoding Needed

We handle the IDL. You get clean, decoded data. No anchor, no borsh, no manual deserialization.

Works With Your Stack

JavaScript, Python, Rust, Go. Any language with gRPC support. Code examples included.

What You Can Build

Concentrated liquidity position management
Tick-level price analytics
Fee and reward optimization
Cross-DEX CL arbitrage (vs Orca Whirlpool)
Automated range rebalancing

Available Streams

Click any stream to see its full schema, accounts, and code examples.

ClosePositioninstruction
solana.raydium_clmm.close_position
CollectFundFeeinstruction
solana.raydium_clmm.collect_fund_fee
CollectProtocolFeeinstruction
solana.raydium_clmm.collect_protocol_fee
CollectRemainingRewardsinstruction
solana.raydium_clmm.collect_remaining_rewards
CreateAmmConfiginstruction
solana.raydium_clmm.create_amm_config
CreateOperationAccountinstruction
solana.raydium_clmm.create_operation_account
CreatePoolinstruction
solana.raydium_clmm.create_pool
CreateSupportMintAssociatedinstruction
solana.raydium_clmm.create_support_mint_associated
DecreaseLiquidityinstruction
solana.raydium_clmm.decrease_liquidity
DecreaseLiquidityV2instruction
solana.raydium_clmm.decrease_liquidity_v2
IncreaseLiquidityinstruction
solana.raydium_clmm.increase_liquidity
IncreaseLiquidityV2instruction
solana.raydium_clmm.increase_liquidity_v2
InitializeRewardinstruction
solana.raydium_clmm.initialize_reward
OpenPositioninstruction
solana.raydium_clmm.open_position
OpenPositionV2instruction
solana.raydium_clmm.open_position_v2
OpenPositionWithToken22Nftinstruction
solana.raydium_clmm.open_position_with_token22_nft
SetRewardParamsinstruction
solana.raydium_clmm.set_reward_params
Swapinstruction
solana.raydium_clmm.swap
SwapRouterBaseIninstruction
solana.raydium_clmm.swap_router_base_in
SwapV2instruction
solana.raydium_clmm.swap_v2
TransferRewardOwnerinstruction
solana.raydium_clmm.transfer_reward_owner
UpdateAmmConfiginstruction
solana.raydium_clmm.update_amm_config
UpdateOperationAccountinstruction
solana.raydium_clmm.update_operation_account
UpdatePoolStatusinstruction
solana.raydium_clmm.update_pool_status
UpdateRewardInfosinstruction
solana.raydium_clmm.update_reward_infos

Start in 30 Seconds

subscribe to any Raydium CLMM stream with a single command

grpcurl
grpcurl -plaintext \
  -H 'x-eventstream-policy: {"version":1,"allowed_programs":"all","allowed_topics":"all"}' \
  -d '{"topic":"solana.raydium_clmm.close_position","format":"JSON"}' \
  events.nln.clr3.org:443 \
  nln.stream.v1.StreamService/Subscribe
Python
import grpc, json
import stream_service_pb2 as pb
import stream_service_pb2_grpc as rpc

channel = grpc.insecure_channel('events.nln.clr3.org:443')
stub = rpc.StreamServiceStub(channel)

policy = json.dumps({"version": 1,
  "allowed_programs": "all",
  "allowed_topics": "all"})

for msg in stub.Subscribe(
    pb.SubscribeRequest(
      topic="solana.raydium_clmm.close_position",
      format=pb.OutputFormat.JSON),
    metadata=[
      ('x-eventstream-policy', policy)]):
    event = json.loads(msg.payload)
    print(f"slot={msg.slot}", event)

Real-Time Raydium CLMM Data for Solana Developers

NoLimitNodes provides 36 decoded real-time streams for the Raydium CLMM program on Solana (CAMMCzo5...). Every instruction call and every emitted event is parsed, typed, and delivered to your app in under 50 milliseconds.

Instead of writing custom deserialization code, decoding Anchor IDLs, or parsing raw transaction logs, you subscribe to a topic like solana.raydium_clmm.close_position and receive structured JSON or Protobuf data instantly. 25 instruction streams and 11 event streams cover every possible interaction with the Raydium CLMM program.

Whether you are building trading bots, analytics dashboards, monitoring tools, or research pipelines, NoLimitNodes program streams give you the decoded on-chain data you need without the infrastructure overhead. Start with our free tier and scale to production.

Start streaming Raydium CLMM data

Get your API key and subscribe to any of 36 decoded streams.

All Programs