Streaming the Indexer

This section covers how to stream real-time data from the Injective Indexer API using StreamManagerV2.

StreamManagerV2

StreamManagerV2 provides an event-based architecture for managing gRPC streams with automatic retry, exponential backoff, and comprehensive error handling.

Key Features

• Event-based lifecycle - Listen to connect, disconnect, error, and data events
• Automatic retry - Configurable exponential backoff with retry limits
• Error handling - Distinguishes retryable vs non-retryable errors
• Persistent mode - Continue retrying indefinitely after max attempts
• Fine-grained control - Start, stop, and manage stream lifecycle

Basic Usage

import { getNetworkEndpoints, Network } from '@injectivelabs/networks'
import { 
  StreamManagerV2,
  IndexerGrpcSpotStreamV2 
} from '@injectivelabs/sdk-ts/client/indexer'

const endpoints = getNetworkEndpoints(Network.Testnet)
const stream = new IndexerGrpcSpotStreamV2(endpoints.indexer)

const streamManager = new StreamManagerV2({
  id: 'my-stream',
  streamFactory: () => stream.streamOrders({ 
    marketId: '0x...',
    callback: (response) => {
      streamManager.emit('data', response)
    }
  }),
  onData: (data) => {
    console.log(data)
  },
  retryConfig: {
    enabled: true,
    maxAttempts: 5,
    initialDelayMs: 1000,
    maxDelayMs: 30000,
    backoffMultiplier: 2,
    persistent: true
  }
})

// Event listeners
streamManager.on('connect', () => console.log('Connected'))
streamManager.on('disconnect', (reason) => console.log('Disconnected:', reason))
streamManager.on('error', (error) => console.error('Error:', error))
streamManager.on('stateChange', ({ from, to }) => console.log(`State: ${from} -> ${to}`))

// Start/stop
streamManager.start()
streamManager.stop()

Available Stream Classes

• IndexerGrpcAccountStreamV2 - Account balance and transaction streams
• IndexerGrpcAccountPortfolioStreamV2 - Portfolio value streams
• IndexerGrpcArchiverStreamV2 - Archiver data streams
• IndexerGrpcAuctionStreamV2 - Auction bid streams
• IndexerGrpcDerivativesStreamV2 - Derivatives market streams
• IndexerGrpcExplorerStreamV2 - Blockchain explorer streams
• IndexerGrpcMitoStreamV2 - Mito vault streams
• IndexerGrpcOracleStreamV2 - Oracle price feed streams
• IndexerGrpcSpotStreamV2 - Spot market streams
• IndexerGrpcTradingStreamV2 - Trading automation streams

Retry Configuration

retryConfig: {
  enabled: true,           // Enable/disable retry
  maxAttempts: 5,          // Max retry attempts (0 = unlimited)
  initialDelayMs: 1000,    // Initial backoff delay
  maxDelayMs: 30000,       // Maximum backoff delay
  backoffMultiplier: 2,    // Exponential backoff multiplier
  persistent: true         // Continue with max delay after maxAttempts
}

Event Types

• connect - Stream successfully connected
• disconnect - Stream disconnected with reason
• error - Stream error occurred
• data - New data received
• stateChange - Stream state changed
• retry - Retry attempt started
• warn - Warning message

Stream Examples

• Account - Stream account updates
• Archiver - Stream archiver data
• Auction - Stream auction updates
• Derivatives - Stream derivatives market updates
• Explorer - Stream explorer updates
• Mito - Stream Mito vault updates
• Oracle - Stream oracle price updates
• Portfolio - Stream portfolio updates
• Spot - Stream spot market updates
• Trading - Stream trading automation updates