Main server and runtime engine for Event-Integrator platform.
Event-Integrator Core is the heart of the Event-Integrator system. It provides:
- Event Processing Engine: High-performance event queue and processing pipeline
- Event Storage: Persistent storage for event data with query capabilities
- Configuration Management: Dynamic configuration loading and validation
- Scalability: Designed for horizontal scaling with worker pools
- Reliability: Built-in retry logic, circuit breakers, and graceful degradation
- Observability: Comprehensive logging, metrics, and distributed tracing
Events → Queue → Workers → Handlers → Storage
↓
Retry Logic → Dead Letter Queue
- Go 1.21+
- Docker (optional)
- PostgreSQL (for event storage)
- Redis (optional, for distributed queue)
# Clone repository
git clone https://github.com/similigh/event-integrator-core
cd event-integrator-core
# Build
go build -o event-integrator-core ./cmd
# Run
./event-integrator-core --config config.yamldocker build -t event-integrator-core .
docker run -p 8080:8080 event-integrator-coreCreate config.yaml:
server:
port: 8080
host: 0.0.0.0
queue:
backend: memory # or redis
workers: 10
database:
driver: postgres
connection_string: "postgres://user:pass@localhost/events"
logging:
level: info
format: jsonPOST /events- Submit new eventGET /events/{id}- Get event detailsGET /health- Health checkGET /ready- Readiness probe
# Run tests
go test ./...
# Run with race detection
go test -race ./...
# Generate coverage report
go test -cover ./...Event-Integrator Core can process thousands of events per second depending on:
- Handler complexity
- Storage backend
- Worker count
- Event payload size
See performance tuning guide for optimization tips.
See CONTRIBUTING.md for development guidelines.
MIT License - see LICENSE file for details