🤿Data Streaming Node

Solana Data Streaming Node via Yellowstone Geyser and ShredStream

Overview

Rather than directly running a node yourself, we provide you with access to the data stream, helping you monitor real-time activities on the Solana blockchain without the complexity of setting up and managing your own infrastructure.

We offer fast and reliable access to real-time data from the Yellowstone Geyser, streamed through ShredStream protocol, ensuring efficient data transmission with minimal latency.

This service is designed for users who need a truly quick and continuous access to Solana blockchain data for for on-chain analytics and network monitoring at an affordable price!

Key features

• Server location: New York (149.28.44.187:20000 ) and Amsterdam (62.197.45.101:10001 )

• No restrictions on the volume of data you can receive.

• 98-99% uptime, ensuring consistent access to real-time data.

• No RPC (only as an exception if there is a very small number of requests)

Price

$200 per month

How to Access ?

1. Reach us out https://docs.google.com/forms/d/e/1FAIpQLSeuWwsQPBBwWLv1US9L5tlmxM1GqSUJsHCNw4cuAKxTXKi2IQ/viewform?usp=dialog.

2. Provide Your IP Address: Once we receive your request, provide your IP address so we can add it to our whitelist.

3. Start Streaming!

What is Yellowstone geyser?

Yellowstone Geyser is a high-performance plugin for Solana that facilitates real-time blockchain data streaming. It provides efficient access to crucial blockchain data, including transaction details, account states, block information, and more. The plugin is designed to support developers and users by offering low-latency, high-throughput data streams, which are essential for in-depth on-chain analysis, monitoring, and application development.

What is ShredStream?

ShredStream is a mechanism that enables the fastest possible reception of shreds—block fragments—distributed by leaders on the Solana network. This method ensures that users can access transaction data quickly and efficiently, significantly improving the speed and responsiveness of data access.

Yellowstone Geyser and ShredStream provide direct, validator-level data streaming, capturing Solana’s state changes exactly as they occur. By processing block fragments at the leader level, ShredStream ensures near-instant distribution. This combination delivers blockchain data in its purest form—optimized for the most reliable on-chain analysis.

Sample Code using Yellowstone Geyser

import Yellowstone, { CommitmentLevel } from '@triton-one/yellowstone-grpc';
import { PublicKey } from '@solana/web3.js';

const GEYSER_URL   = ''; // <-- See above for the region NewYork / Amsterdam
const AUTH_TOKEN   = ''; // <-- Please reach out https://docs.google.com/forms/d/e/1FAIpQLSeuWwsQPBBwWLv1US9L5tlmxM1GqSUJsHCNw4cuAKxTXKi2IQ/viewform?usp=dialog
const WATCHED_PDA  = '3QMfsPS1P8sSWpqGNMGUfo2FDvoHoY7iZNwBoHSYm4wN';

async function main() {
  const client = new Yellowstone(GEYSER_URL, AUTH_TOKEN, {
    'grpc.max_receive_message_length': 10 * 1024 * 1024, // 10 MB
  });
  const stream = await client.subscribe();
  console.log('🟢 Connected to Geyser');

  // Describe what we want: every confirmed (PROCESSED) txn that
  // includes WATCHED_PDA anywhere in the message-level account keys
  const request = {
    commitment: CommitmentLevel.PROCESSED,
    transactions: {
      my_filter: {
        vote: false,
        failed: false,
        accountInclude: [ ],          // no extra allow-list
        accountExclude: [ ],          // no deny-list
        accountRequired: [ WATCHED_PDA ],
      },
    },
    // Everything else can stay empty for this simple demo
    accounts: {}, slots: {}, entry: {}, blocks: {}, blocksMeta: {},
    accountsDataSlice: [], transactionsStatus: {},
  };

  // Tell the stream what we want
  stream.write(request);
  console.log(`🔎 Subscribed to transactions touching ${WATCHED_PDA}`);

  // Handle pushed events
  stream.on('data', (msg) => {
    console.log(`📜 got update`);
  });

  // Basic error / end handling
  stream.on('error', console.error);
  stream.on('end',   () => console.log('Stream ended'));

  // Close cleanly on Ctrl-C
  process.on('SIGINT', () => {
    console.log('Shutting down…');
    stream.end();
    process.exit(0);
  });
}

main().catch(err => { console.error(err); process.exit(1); });

Support & Inquiries

For trial access, technical support, or troubleshooting inquiries, please contact us via Telegram (@inventandchill) or email ([e-mail]) or https://docs.google.com/forms/d/e/1FAIpQLSeuWwsQPBBwWLv1US9L5tlmxM1GqSUJsHCNw4cuAKxTXKi2IQ/viewform?usp=dialog. We’re here to assist with any questions or issues you may encounter.