LogoLogo
  • INTUE Documentation
  • Getting Started
  • Architecture Overview
  • INTUE m0
  • INTUE ARB
  • INTUE m3
  • Model Context Protocols (MCPs) - Overview
  • Correlation MCPs
  • Category MCPs
  • Metric MCPs
  • Analysis MCPs
  • Exchange Integration - Binance Adapter
  • Exchange Integration - Hyperliquid Adapter
  • Developer Resources - Creating Custom Agents
  • Agent Marketplace
  • Creating Custom MCPs
  • API Reference - Agent API
  • Error Handling
  • Pagination
  • Risk Management
  • Advanced Topics - Swarm Intelligence
  • Multi-Agent Coordination
  • Consensus Mechanisms
  • Swarm Learning
  • Performance Optimization
  • Implementation Best Practices
  • Conclusion
Powered by GitBook
On this page

Pagination

For endpoints returning large result sets, pagination is supported:

// Get paginated signal history
const signalHistoryPage1 = await agent.getSignalHistory({
  timeframe: '90d',
  limit: 50,
  offset: 0
});

const signalHistoryPage2 = await agent.getSignalHistory({
  timeframe: '90d',
  limit: 50,
  offset: 50
});

// Alternative cursor-based pagination
const signalHistoryNext = await agent.getSignalHistory({
  timeframe: '90d',
  limit: 50,
  cursor: signalHistoryPage1.nextCursor
});

Websocket Streams

For real-time updates, use WebSocket connections:

// Subscribe to real-time signal updates
const signalStream = agent.subscribeToSignals({
  assets: ['BTC', 'ETH', 'SOL'],
  minimumConfidence: 0.7
});

signalStream.on('signal', (signal) => {
  console.log('New signal received:', signal);
});

// Subscribe to position updates
const positionStream = agent.subscribeToPositions();

positionStream.on('position', (position) => {
  console.log('Position update:', position);
});

// Handle connection issues
signalStream.on('error', (error) => {
  console.error('Signal stream error:', error);
});

// Close streams when done
signalStream.close();
positionStream.close();
PreviousError HandlingNextRisk Management

Last updated 3 days ago