RANKIGI CONNECTORS
Your governed data.
Anywhere you need it.
Stream verified hash-chain events directly into your existing infrastructure. One connector. Any destination.
npm
npm install @rankigi/connectorpip
pip install rankigi-connectorOUTPUT MODES
Raw
Pure event data as it flows from RANKIGI. Every hash, every chain index, every flag. For engineers who want full control.
Verified
Chain integrity checked before every write. Your destination only receives cryptographically valid data. Compliance-grade.
Compiled
Human-readable summaries synthesized from event streams. Patterns, anomalies, and agent behavior — ready for Obsidian, Notion, or any document system.
AVAILABLE ADAPTERS
Stream governed events as interlinked markdown notes. Your agents build a living knowledge graph in your vault.
Write to S3 with automatic partitioning. ndjson format ready for Athena, BigQuery, Snowflake, and Spark.
Store events in PostgreSQL with automatic schema management and indexing.
Publish events to Kafka topics for real-time stream processing pipelines.
Document-native storage with automatic collection management.
Sync governance data to Notion databases for team visibility.
Write to GCS buckets with the same partitioning as S3.
Extend BaseAdapter in 10 lines. Point RANKIGI at anything.
DATA POINT SELECTION
Choose exactly what flows through. Filtering happens at the source — your destination only receives what you explicitly request.
Proof Only
Cryptographic proof layer only. event_hash, chain_index, timestamp. For auditors who need to verify authenticity without seeing content.
filter: { preset: 'proof-only' }Anomalies Only
High-risk events and policy violations only. Your SIEM gets a clean feed of exactly what needs attention.
filter: { preset: 'anomalies-only' }Compliance Export
All events with sensitive fields stripped. Ready for regulatory submission.
filter: { preset: 'compliance-export' }Custom
Filter by agent, action type, risk score, date range, or write your own transform function.
filter: { agents: [...], riskScoreMin: 50 }QUICK START
import { RankigiConnector, ObsidianAdapter } from '@rankigi/connector'
const connector = new RankigiConnector({
apiKey: process.env.RANKIGI_API_KEY!,
orgId: process.env.RANKIGI_ORG_ID!,
mode: 'compiled',
adapter: new ObsidianAdapter({
vaultPath: '/Users/you/ObsidianVault',
folderStructure: 'by-agent',
createIndex: true,
createAgentPages: true
}),
onError: (err) => console.error('RANKIGI error:', err)
})
await connector.connect()
console.log('Streaming governed events to Obsidian...')