PipeStream Connector for AI agents.
4 live capabilities
Manage real-time event streaming and data pipelines from your chat interface.
Waiting for input…
Why people use PipeStream
PipeStream for Real-Time Event Stream Management
PipeStream changes that by bringing your event streams directly into your conversation with your AI agent. You can ask your agent to show you the logs or spin up a new stream, getting a direct line to your data pipelines without the friction.
What Vinkius changes
You get a chat-based command center for your entire event streaming infrastructure.
Use it from Claude, ChatGPT, Cursor or another AI client you already have.
One account · 5,900+ Connectors
- Real-world use case 01
Incident Response
A DevOps engineer asks the agent to fetch the last 50 events from a failing payment stream to find the error.
- Real-world use case 02
Data Analysis
A scientist asks the agent to create a stream for experimental results and then pull the first 100 entries.
- Real-world use case 03
QA Testing
A developer asks the agent to create a temporary test stream and publish a batch of dummy user signups.
Complete set · 4capabilities
The complete PipeStream capability set.
These are the exact actions your AI can choose when you ask it to work with PipeStream.
01—04
4 capabilities in this set.
Part of 4 available through PipeStream.
- 01 Capability
Create stream
Set up a new data stream with custom retention policies for your project. Use this to build out your pipeline architecture on the fly.
- 02 Capability
List streams
View all your active data channels to see what's currently running. This helps you maintain a clear overview of your infrastructure.
- 03 Capability
Fetch events
Pull a list of events from a stream using time filters or pagination. This lets you inspect specific historical data points quickly.
- 04 Capability
Publish event
Send a JSON payload to a specific stream to trigger actions or log data. It's the quickest way to inject test data into your flow.
Set up in minutes
One URL. Then ask PipeStream to work.
Claude and ChatGPT only need the Connector URL. Copy it once, add it in settings, and use PipeStream from the conversation.
Choose your client
Live previewAdvanced clients IDE · CLI
Claude · Web + desktop
Connector URL · ready to paste
Streamable HTTPhttps://edge.vinkius.com/vk_preview_jDneWqNf0y6klnjmvBtb8xcp1NrmOfetRftWEg97/mcp - Step 01
Open Connectors
In Claude Web or Claude Desktop, open Settings and choose Connectors.
- Step 02
Add the URL
Choose Add custom connector, name it PipeStream, and paste the URL above.
- Step 03
Turn it on in chat
Select +, open Connectors, and enable PipeStream for the conversation.
ChatGPT · Web + desktop
Connector URL · ready to paste
Streamable HTTPhttps://edge.vinkius.com/vk_preview_jDneWqNf0y6klnjmvBtb8xcp1NrmOfetRftWEg97/mcp - Step 01
Open MCP settings
On desktop, open Settings and MCP servers. On web, open your workspace app or connector settings.
- Step 02
Add the URL
Choose Add server with Streamable HTTP, or create a custom MCP app, then paste the PipeStream URL.
- Step 03
Save and start
Save the connection and enable PipeStream in your conversation. Desktop may ask you to restart once.
Cursor · IDE configuration
Advanced setup
{
"mcpServers": {
"pipestream": {
"url": "https://edge.vinkius.com/vk_preview_jDneWqNf0y6klnjmvBtb8xcp1NrmOfetRftWEg97/mcp"
}
}
} - Step 01
Open MCP Settings
Press Cmd+Shift+P (macOS) or Ctrl+Shift+P (Windows/Linux) → search "MCP Settings"
- Step 02
Add the server config
Paste the JSON configuration above into the mcp.json file that opens
- Step 03
Save the file
Cursor will automatically detect the new Connector
- Step 04
Start using PipeStream
Open Agent mode in chat and ask: "Using PipeStream, help me...". 4 tools available
VS Code Copilot · IDE configuration
Advanced setup
{
"mcpServers": {
"pipestream": {
"url": "https://edge.vinkius.com/vk_preview_jDneWqNf0y6klnjmvBtb8xcp1NrmOfetRftWEg97/mcp"
}
}
} - Step 01
Create MCP config
Create a .vscode/mcp.json file in your project root
- Step 02
Add the server config
Paste the JSON configuration above
- Step 03
Enable Agent mode
Open GitHub Copilot Chat and switch to Agent mode using the dropdown
- Step 04
Start using PipeStream
Ask Copilot: "Using PipeStream, help me...". 4 tools available
Windsurf · IDE configuration
Advanced setup
{
"mcpServers": {
"pipestream": {
"url": "https://edge.vinkius.com/vk_preview_jDneWqNf0y6klnjmvBtb8xcp1NrmOfetRftWEg97/mcp"
}
}
} - Step 01
Open MCP Settings
Go to Settings → MCP Configuration or press Cmd+Shift+P and search "MCP"
- Step 02
Add the server
Paste the JSON configuration above into mcp_config.json
- Step 03
Save and reload
Windsurf will detect the new server automatically
- Step 04
Start using PipeStream
Open Cascade and ask: "Using PipeStream, help me...". 4 tools available
Cline · IDE configuration
Advanced setup
{
"mcpServers": {
"pipestream": {
"url": "https://edge.vinkius.com/vk_preview_jDneWqNf0y6klnjmvBtb8xcp1NrmOfetRftWEg97/mcp"
}
}
} - Step 01
Open Cline MCP Settings
Click the Connectors icon in the Cline sidebar panel
- Step 02
Add remote server
Click "Add Connector" and paste the configuration above
- Step 03
Enable the server
Toggle the server switch to ON
- Step 04
Start using PipeStream
Ask Cline: "Using PipeStream, help me...". 4 tools available
Claude Code · Terminal command
Advanced setup
claude mcp add pipestream --transport http "https://edge.vinkius.com/vk_preview_jDneWqNf0y6klnjmvBtb8xcp1NrmOfetRftWEg97/mcp" - Step 01
Install Claude Code
Run npm install -g @anthropic-ai/claude-code if not already installed
- Step 02
Add the Connector
Run the command above in your terminal
- Step 03
Verify the connection
Run claude mcp to list connected servers, or type /mcp inside a session
- Step 04
Start using PipeStream
Ask Claude: "Using PipeStream, show me...". 4 tools are ready
Where the request belongs
Work PipeStream can move forward.
This is for the engineer who's tired of hunting through terminal outputs and log aggregators during a production incident or late-night debugging session.
DevOps Engineer
Checking event logs and stream statuses during high-pressure incident responses.
Data Scientist
Pushing experimental results or pulling sample data for immediate analysis in-context.
Backend Developer
Verifying event delivery and creating temporary testing channels without leaving the IDE.
Build the capability set
Add more capabilities.
Each Connector adds new actions and data without changing how you work.
Browse ConnectorsConduit
Equip your AI agent to observe data streams, manage integration pipelines, and monitor nodes on the Conduit platform.
Tinybird Data Platform
Analyze real-time data via Tinybird. manage Data Sources, inspect Pipes, and query endpoints directly.
Axiom
Manage logs and observability data via Axiom. ingest data, run APL queries, and manage datasets or monitors directly from any AI agent.
RisingWave (Streaming Database)
Manage your RisingWave streaming database. execute SQL, ingest events, and monitor tables, materialized views, sources, and sinks directly from any AI agent.
Unstructured
Process and transform complex unstructured data into AI-ready inputs by managing sources, destinations, and workflows directly from your AI agent.
Vercel AI SDK Stream Parser
Deterministic parser for Vercel AI SDK 3.0 Data Stream protocol chunks.
Bring your own AI
Change the model, client or framework. Keep PipeStream connected.
-
Claude -
ChatGPT -
Gemini -
Cursor -
VS Code -
Windsurf -
ZCode -
Cline -
Zed -
Continue -
Kiro -
Roo Code -
Zencoder -
Goose -
Void -
Augment Code -
Amp -
Qodo -
Tabnine -
Pieces -
Sourcegraph Cody -
JetBrains -
Warp -
Amazon Q -
Antigravity -
BoltAI -
Raycast -
Jan -
LM Studio -
AnythingLLM -
Open WebUI -
Msty -
Cherry Studio -
LibreChat -
TypingMind -
Chorus -
5ire -
n8n -
LangChain -
LlamaIndex -
CrewAI -
Vercel AI SDK
Before you connect
Questions about PipeStream.
The practical details behind the request, access and result.
Can PipeStream MCP help me debug production issues?
Yes, you can use it to pull live event logs and check stream statuses instantly without leaving your chat.
How do I create a new data stream using this?
Just tell your agent to create a new stream and specify any retention rules you want to apply.
Can I use PipeStream to see my active data channels?
Yes, it can list every active stream you have so you can monitor your infrastructure in one place.
Is it possible to send test data to a stream?
You can use the capability to publish JSON events to any active stream for testing or verification.
Does PipeStream MCP support historical data?
Yes, it allows you to fetch past events from your streams with specific filters.
How does this work with my current data pipelines?
It connects directly to your PipeStream account so your agent can manage the data flow for you.
Can I create a new data stream with a specific retention period?
Yes! Use the create_stream capability. You can specify the name and the retention_hours to define how long data should be stored in that logical channel.
How do I send a JSON payload to an existing stream?
Use the publish_event capability. Provide the stream_id and your JSON payload. You can also optionally include a custom ISO8601 timestamp.
Is it possible to filter events by time when fetching data?
Absolutely. The fetch_events capability allows you to provide a from_timestamp to retrieve only the events recorded after a specific point in time.
One connection away
Give your agent a direct line to PipeStream.
Connect PipeStream once. Keep it beside 5,900+ managed Connectors when the next task needs more.
Explore every Connector No credit card required · Free tier available