Buy a PassBuy a VPSHolder VerificationStatusDiscordGitHub

Services

ThorStreamer provides two gRPC services for streaming Solana blockchain data.

Recommended for most use cases: use the EventPublisher service for individual streams with lower throughput requirements. Use ThorStreamer service only if you need a high-throughput unified stream and can meet the infrastructure requirements.

EventPublisher Service

Provides individual streams with lower throughput requirements.

SubscribeToTransactions

Stream real-time transactions matching configured program filters.

protobuf
rpc SubscribeToTransactions(Empty) returns (stream StreamResponse)

Input: None Output: Stream of transactions from supported programs

Use cases:

  • Monitor DeFi protocol interactions

  • Track trading activity

  • Market making strategies

SubscribeToAccountUpdates

Stream account state changes with flexible filtering.

protobuf
rpc SubscribeToAccountUpdates(SubscribeAccountsRequest) returns (stream StreamResponse)

Input:

protobuf
message SubscribeAccountsRequest {
  repeated string account_address = 1;  // Specific accounts (max 100)
  repeated string owner_address = 2;    // Filter by owner program
}

Filtering options:

  • Monitor specific accounts by address

  • Monitor all accounts owned by specific programs

  • Combine both filters

Use cases:

  • Token balance tracking

  • Program state monitoring

  • Portfolio analytics

SubscribeToSlotStatus

Monitor Solana slot progression and confirmations.

protobuf
rpc SubscribeToSlotStatus(Empty) returns (stream StreamResponse)

Input: None Output: Stream of slot status events

Use cases:

  • Transaction confirmation tracking

  • Block finality monitoring

  • Network health checks

SubscribeToWalletTransactions

Stream transactions involving specific wallet addresses.

protobuf
rpc SubscribeToWalletTransactions(SubscribeWalletRequest) returns (stream StreamResponse)

Input:

protobuf
message SubscribeWalletRequest {
  repeated string wallet_address = 1;  // Base58 addresses (max 10)
}

Use cases:

  • Wallet activity monitoring

  • User transaction tracking

  • Portfolio analytics

ThorStreamer Service

High-throughput unified stream combining all event types. This service requires robust infrastructure.

StreamUpdates

Single stream delivering all events through MessageWrapper.

protobuf
rpc StreamUpdates(Empty) returns (stream MessageWrapper)

Output: Stream containing one of:

  • TransactionEventWrapper — Transaction data with stream type

  • SubscribeUpdateAccountInfo — Account state changes

  • SlotStatusEvent — Slot progression

Requirements:

  • 8+ CPU cores

  • 16GB+ RAM

  • Low-latency network

  • Worker pools for parallel processing

Clients that cannot keep up will be automatically disconnected.

PreviousProgram FiltersNextMessage Type