Foundation
@connectum/core
Server lifecycle, service registration, configuration, TLS, and in-process clients.
createServer · defineService · createCatalogClient
gRPC + ConnectRPC for Node.js
Connectum gives TypeScript teams a consistent service runtime for contracts, middleware, security, observability, and operations—without hiding the controls.
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
Build on ConnectRPC and gRPC, operate with cloud-native tooling, and choose the brokers and runtimes that fit 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 learning material, focused configuration, and its generated API surface.
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