Foundation
@connectum/core
Server lifecycle, service registration, configuration, TLS, and in-process clients.
createServer · defineService · createCatalogClient
gRPC + ConnectRPC for Node.js
Connectum provides a TypeScript service runtime for proto contracts, request middleware, security, observability, and operations.
Start by goal
One service lifecycle
The framework keeps lifecycle and registration predictable while modules remain explicit. Begin with the server; add production behavior as the service grows.
Fits your stack
Use ConnectRPC or gRPC, connect to supported brokers, and choose Node.js or Bun for each service.
The central primitive
Services, protocols, middleware, and shutdown policy meet at createServer(). The full tutorial defines the proto, implements the handler, starts the service, and verifies a real RPC.
import { createServer } from '@connectum/core';
import { Healthcheck } from '@connectum/healthcheck';
import { createDefaultInterceptors } from '@connectum/interceptors';
import { Reflection } from '@connectum/reflection';
import { greeterService } from './services/greeterService.ts';
const server = createServer({
services: [greeterService],
port: 5000,
protocols: [Healthcheck({ httpEnabled: true }), Reflection()],
interceptors: createDefaultInterceptors(),
shutdown: { autoShutdown: true },
});
await server.start();Explore modules
Each module links to its guide, configuration help, and generated API reference.
Foundation
Server lifecycle, service registration, configuration, TLS, and in-process clients.
createServer · defineService · createCatalogClient
Foundation
Error handling, validation, timeouts, resilience, and method-scoped middleware.
createDefaultInterceptors · createMethodFilterInterceptor
Security
JWT, gateway, session, internal-service authentication, and authorization.
createJwtAuthInterceptor · createAuthzInterceptor · requireAuthContext
Communication
Proto-first publish and subscribe with middleware, retries, and dead-letter handling.
createEventBus · MemoryAdapter · createBroadcastSubscribers
Communication
NATS JetStream adapter for the Connectum EventBus.
NatsAdapter · NatsAdapterOptions
Communication
Kafka and Redpanda adapter for the Connectum EventBus.
KafkaAdapter · KafkaAdapterOptions
Communication
Redis Streams and Valkey adapter for the Connectum EventBus.
RedisAdapter · RedisAdapterOptions
Communication
AMQP and RabbitMQ adapter with topology and reliable-publishing controls.
AmqpAdapter · AmqpAdapterOptions
Operations
OpenTelemetry tracing, metrics, logging, providers, and client/server instrumentation.
createOtelInterceptor · initProvider · getLogger
Operations
gRPC health protocol, HTTP probes, readiness state, and Kubernetes integration.
Healthcheck · healthcheckManager · ServingStatus
Operations
gRPC Server Reflection for discovery, inspection, and tooling.
Reflection · collectFileProtos
Tooling and testing
Service scaffolding, service generation, version inspection, and reflection-based proto sync.
connectum init · connectum generate service · connectum proto sync
Tooling and testing
Buf plugin that generates typed service-catalog call and stream mappings.
protoc-gen-catalog
Tooling and testing
Supported test servers, local transports, parity helpers, collectors, and assertions.
createTestServer · withTestServer · createLocalClient
Tooling and testing
Low-level mock factories and protobuf descriptor fixtures for advanced test tooling.
createMockRequest · createFakeService · createMockStream
Keep moving