WinkComposer is an upcoming open-source framework that makes building streaming intelligence playfully simple. Connect intuitive nodes, experiment freely, perfect it in an iteration or two. From edge-ready AI algorithms to built-in resilience, everything you need for production comes standard. No complexity, no black boxes - just the joy of creating exactly what you need.
🎯 Create What You Need — With composability, you're the inventor: Correlate vibration with weather? Done. Detect micro-trends before they become macro? Built.
💫 Countless Possibilities — Dozens of nodes → Endless pipelines. Like few music notes creating captivating symphonies.
🌱 Evolve Naturally — Start: sensor → threshold → alert. Grow: Add intelligence: sensor → normalize → smooth → detect → confirm → alert. Unconstrained by vendor feature lists.
🔍 Total Transparency — See which node triggered, what threshold crossed, why it alerted. Every decision is explainable.
Build precise analytics for your unique patterns:
// Detect bearing failure in rotating equipment
vibration → isolateSignal → extractPeaks → measureIntensity →
trackChanges → triggerAlert
// Monitor chemical process quality
temperature → removeNoise → smoothFast → smoothSlow → findDivergence →
detectChange → waitForPersistence
// Find correlated sensor behaviors
[sensor1, sensor2] → trackCorrelation → compareToNormal → raiseFlag
// Calculate real-time OEE
machine → trackState → sumTime → countOutput →
checkQuality → calculateScoreEach node is simple:
removeNoise: Median of last few values (removes sensor spikes).smoothFast: Average of last 10 values (recent trend).smoothSlow: Average of last 100 values (baseline trend).findDivergence: Fast trend - slow trend (unusual behavior?).trackCorrelation: Smart correlation (learns relationships between sensors)
Node names and details are illustrative - actual implementations may vary.
Every arrow is a conscious choice. Every node has a purpose. No magic, just simple intuitive math.
Start Simple
sensor → threshold → alert
Evolve Naturally
sensor → validate → normalize → threshold → debounce → alert
Scale Intelligently
sensor → [parallel: statistics | patterns | anomalies] → correlate → decide → act
Your analytics grow with your understanding, and are never limited by any tool's feature list.
From simple threshold monitoring to complex predictive maintenance - compose what fits your equipment, your patterns, your physics. Move intelligence to the edge with analytics that run on industrial Raspberry Pis. Works alongside your existing systems to handle your unique requirements.
Build fraud detection you can explain to auditors. Every decision traceable, every threshold justified.
Energy optimization with transparent logic. See why the system made each decision.
Real streams have noise. Sensors fail. Networks hiccup. WinkComposer handles it all:
- Node-level fault isolation - One bad reading doesn't crash your pipeline
- Automatic state recovery - Snapshot and restore without missing a beat
- Built-in observability - Know what's happening in every node, every partition
- Adaptive execution - Maintains responsiveness under varying load
| Principle | What it means |
|---|---|
| Atomic Operations | Each node does one thing perfectly |
| Pure Functions | Predictable, testable, composable |
| Transparent Logic | Understand every decision |
| Production Ready | Built for high-throughput streaming with microsecond-scale latency |
| AI-Native Intelligence | From statistical learning nodes to LLM reasoning - intelligence at every level |
| Built for Reality | Node-level fault isolation, automatic recovery, and comprehensive observability |
WinkComposer is transitioning to open source development in 2025. Join the early conversation and help shape the future of composable streaming analytics. You can even reach out directly at wink@graype.in.
Together, we're building:
- Rich Node Library: Statistical, filtering, detection, transformation, and control nodes
- Edge-Ready Intelligence: Advanced algorithms like smart correlation, change point detection, and regression inference - AI-like capabilities without heavyweight frameworks
- Pipeline Builder: Define your analytics flows declaratively (visual tools planned)
- Edge-Ready Performance: Process data efficiently, even on resource-constrained devices (tested on Raspberry Pi)
- Knowledge Graph Integration: Build digital twins with Neo4j/ArangoDB for contextual intelligence
- AI-Native Reasoning: When patterns emerge, LLMs explain why. When anomalies occur, get actionable recommendations. Open-source models keep intelligence at the edge.
Finally, build solutions that fit your exact problems, not the other way around.
Every industry has unique patterns. Every process has specific physics. Every business has particular rules. WinkComposer gives you the building blocks to create exactly what you need.
Domain-specific platforms excel at standard use cases. WinkComposer shines when you need something unique, beyond standard use cases. Standard use cases always included - they're just the beginning of what's possible!
WinkComposer joins the winkJS family - production-grade open-source packages for Natural Language Processing, Machine Learning, and Statistical Analysis in JavaScript. Built for reliability with ~100% test coverage.
Wink Composer is copyright 2017-25 GRAYPE Systems Private Limited.
It is licensed under the terms of the MIT License.