Skip to content

Main Navigation Guide Packages API

Migration & Changelog

Contributing

Examples

Appearance

Sidebar Navigation

@connectum/auth

Modules

proto

Type Aliases

AuthRequirements

MethodAuth

ServiceAuth

Variables

AuthRequirementsSchema

method_auth

MethodAuthSchema

service_auth

ServiceAuthSchema

testing

Variables

TEST_JWT_SECRET

Functions

createMockAuthContext

createTestJwt

withAuthContext

Classes

AuthzDeniedError

LruCache

Interfaces

AuthContext

AuthInterceptorOptions

AuthzDeniedDetails

AuthzInterceptorOptions

AuthzRule

CacheOptions

ClientBearerInterceptorOptions

ClientGatewayInterceptorOptions

GatewayAuthInterceptorOptions

GatewayHeaderMapping

JwtAuthInterceptorOptions

ProtoAuthzInterceptorOptions

ResolvedMethodAuth

SessionAuthInterceptorOptions

Type Aliases

AuthzEffect

InterceptorFactory

Variables

AUTH_HEADERS

authContextStorage

AuthzEffect

Functions

createAuthInterceptor

createAuthzInterceptor

createClientBearerInterceptor

createClientGatewayInterceptor

createGatewayAuthInterceptor

createJwtAuthInterceptor

createProtoAuthzInterceptor

createSessionAuthInterceptor

getAuthContext

getPublicMethods

matchesMethodPattern

parseAuthHeaders

requireAuthContext

resolveMethodAuth

setAuthHeaders

@connectum/cli

commands

proto-sync

Interfaces

ProtoSyncOptions

Variables

protoSyncCommand

Functions

executeProtoSync

utils

reflection

Interfaces

ReflectionResult

Functions

fetchFileDescriptorSetBinary

fetchReflectionData

@connectum/core

Modules

config

types

Interfaces

CreateServerOptions

EventBusLike

ProtocolContext

ProtocolRegistration

Server

ServerClientOptions

ShutdownOptions

TLSOptions

Type Aliases

HttpHandler

LifecycleEvent

NodeRequest

NodeResponse

ServerState

ShutdownHook

TransportServer

Variables

LifecycleEvent

ServerState

Classes

CatalogConfigError

TransportValidationError

Interfaces

BidiStreamHandle

ClientStreamHandle

ConnectumCallMap

ConnectumStreamMap

Context

CreateLocalTransportOptions

DnsResolverOptions

PerServiceEnvResolverOptions

ResolverContext

SanitizableError

ServiceDefinition

StreamingMethodInfo

Type Aliases

CallOptions

ConnectumEnv

ConnectumMethodImpl

ConnectumServiceImpl

EffectiveTransport

RemoteResolver

ServiceCatalog

ServiceOptions

StreamReturn

TransportValidationMode

Variables

BooleanFromStringSchema

ConnectumEnvSchema

defaultPropagateHeaders

EffectiveTransport

LogFormatSchema

LoggerBackendSchema

LogLevelSchema

NodeEnvSchema

tlsPath

TRANSPORT_VALIDATION_ERROR_CODE

TransportValidationMode

Functions

collectStreamingMethods

createLocalTransport

createServer

defineCatalog

defineLazyService

defineService

dnsResolver

getTLSPath

isSanitizableError

mapResolver

matchServicesPattern

mergeCatalogs

mergeEnabledServices

parseEnvConfig

parseServicesEnv

perServiceEnvResolver

readTLSCertificates

resolveEffectiveTransport

safeParseEnvConfig

singleTransportResolver

@connectum/events

Modules

types

Interfaces

AdapterContext

DlqOptions

EventAdapter

EventBus

EventBusOptions

EventContext

EventContextInit

EventHandlerConfig

EventRouteEntry

EventRouter

EventSubscription

MiddlewareConfig

PublishOptions

RawEvent

RawSubscribeOptions

RetryOptions

Type Aliases

EventMiddleware

EventMiddlewareNext

EventRoute

RawEventHandler

ServiceEventHandlers

TypedEventHandler

Classes

EventRouterImpl

NonRetryableError

RetryableError

Functions

composeMiddleware

createEventBus

createEventContext

deriveServiceName

dlqMiddleware

matchPattern

MemoryAdapter

resolveTopicName

retryMiddleware

@connectum/events-amqp

Modules

types

Interfaces

AmqpAdapterOptions

AmqpBindingDeclaration

AmqpConsumerOptions

AmqpExchangeDeclaration

AmqpExchangeOptions

AmqpLifecycleCallbacks

AmqpPublisherOptions

AmqpQueueDeclaration

AmqpQueueOptions

AmqpQueueOverride

AmqpRecoveryOptions

AmqpSerializationOptions

AmqpTopology

Type Aliases

AmqpTopologyMode

Variables

AmqpTopologyMode

Classes

AmqpAdapterError

AmqpConnectionError

AmqpPublishNackError

AmqpPublishTimeoutError

AmqpSerializationError

AmqpTopologyError

AmqpUnroutableError

Functions

AmqpAdapter

toAmqpPattern

@connectum/events-kafka

Modules

types

Interfaces

KafkaAdapterOptions

Functions

KafkaAdapter

@connectum/events-nats

Modules

types

Interfaces

NatsAdapterOptions

NatsConsumerOptions

Functions

NatsAdapter

@connectum/events-redis

Modules

types

Interfaces

RedisAdapterOptions

RedisBrokerOptions

Functions

RedisAdapter

@connectum/healthcheck

Classes

HealthcheckManager

Variables

healthcheckManager

Functions

createHealthcheckManager

createHttpHealthHandler

Healthcheck

parseServiceFromUrl

@connectum/healthcheck/types

Interfaces

HealthcheckOptions

ServiceStatus

Type Aliases

ServingStatus

Variables

ServingStatus

@connectum/interceptors

Modules

bulkhead

Functions

createBulkheadInterceptor

circuit-breaker

Functions

createCircuitBreakerInterceptor

defaultFailurePredicate

defaults

Interfaces

DefaultInterceptorOptions

Functions

createDefaultInterceptors

errorHandler

Functions

createErrorHandlerInterceptor

fallback

Functions

createFallbackInterceptor

logger

Functions

createLoggerInterceptor

method-filter

Functions

createMethodFilterInterceptor

retry

Functions

createRetryInterceptor

serializer

Functions

createSerializerInterceptor

timeout

Functions

createTimeoutInterceptor

Interfaces

BulkheadOptions

CircuitBreakerOptions

ErrorHandlerOptions

FallbackOptions

LoggerOptions

RetryOptions

SerializerOptions

TimeoutOptions

Type Aliases

InterceptorFactory

MethodFilterMap

@connectum/otel

Modules

attributes

Type Aliases

ConnectErrorCode

Variables

ATTR_CONNECTUM_TRANSPORT

ATTR_CONNECTUM_TRANSPORT_METRIC

ATTR_ERROR_TYPE

ATTR_NETWORK_PEER_ADDRESS

ATTR_NETWORK_PEER_PORT

ATTR_NETWORK_PROTOCOL_NAME

ATTR_NETWORK_TRANSPORT

ATTR_RPC_CONNECT_RPC_STATUS_CODE

ATTR_RPC_MESSAGE_ID

ATTR_RPC_MESSAGE_TYPE

ATTR_RPC_MESSAGE_UNCOMPRESSED_SIZE

ATTR_RPC_METHOD

ATTR_RPC_SERVICE

ATTR_RPC_SYSTEM

ATTR_SERVER_ADDRESS

ATTR_SERVER_PORT

ConnectErrorCode

ConnectErrorCodeName

CONNECTUM_INTERNAL_TRANSPORT_HEADER

CONNECTUM_INTERNAL_TRANSPORT_IN_PROCESS

RPC_MESSAGE_EVENT

RPC_SYSTEM_CONNECT_RPC

client-interceptor

Functions

createOtelClientInterceptor

interceptor

Functions

createOtelInterceptor

logger

Interfaces

Logger

LoggerOptions

Functions

getLogger

meter

Functions

getMeter

metrics

Interfaces

RpcClientMetrics

RpcServerMetrics

Functions

createRpcClientMetrics

createRpcServerMetrics

provider

Interfaces

ProviderOptions

ResourceAttributeInputs

Functions

buildResourceAttributes

getProvider

initProvider

parseOtelResourceAttributesEnv

shutdownProvider

shared

Interfaces

BaseAttributeParams

Functions

applyAttributeFilter

buildBaseAttributes

buildErrorAttributes

detectConnectumTransport

estimateMessageSize

wrapAsyncIterable

traceAll

Functions

traceAll

traced

Functions

traced

tracer

Functions

getTracer

Interfaces

BatchSpanProcessorOptions

CollectorOptions

Meter

OtelBaseOptions

OtelClientInterceptorOptions

OtelInterceptorOptions

OTLPSettings

TraceAllOptions

TracedOptions

Tracer

Type Aliases

ArgsFilter

ExporterType

MethodArgsFilter

OtelAttributeFilter

OtelFilter

Variables

ExporterType

Functions

getBatchSpanProcessorOptions

getCollectorOptions

getOTLPSettings

getServiceMetadata

@connectum/reflection

Functions

collectFileProtos

Reflection

@connectum/test-fixtures

index

Interfaces

MockCall

MockFn

Functions

assertConnectError

createFakeMethod

createFakeService

createMockDescField

createMockDescMessage

createMockDescMethod

createMockFn

createMockNext

createMockNextError

createMockNextSlow

createMockRequest

createMockStream

types

Interfaces

FakeMethodOptions

FakeServiceOptions

MockDescFieldOptions

MockDescMessageOptions

MockDescMethodOptions

MockNextOptions

MockRequestOptions

MockStreamOptions

@connectum/testing

index

Classes

InMemoryMetricCollector

InMemorySpanCollector

Interfaces

CreateMockContextOptions

FakeMethodOptions

FakeServiceOptions

MockCall

MockDescFieldOptions

MockDescMessageOptions

MockDescMethodOptions

MockFn

MockNextOptions

MockRequestOptions

MockService

MockStreamOptions

NormalizedMetric

NormalizedSpan

Variables

MOCK_RESPONSE_HEADER

TRANSPORT_METRIC_ATTRIBUTE

TRANSPORT_SPAN_ATTRIBUTE

Functions

assertConnectError

createFakeMethod

createFakeService

createLocalClient

createMockContext

createMockDescField

createMockDescMessage

createMockDescMethod

createMockFn

createMockNext

createMockNextError

createMockNextSlow

createMockRequest

createMockStream

createTestServer

mockResolver

mockService

withTestServer

types

Interfaces

CreateTestServerOptions

TestServer

On this page

Are you an LLM? You can read better optimized documentation at /en/api/@connectum/test-fixtures.md for this page in Markdown format

Connectum API Reference / @connectum/test-fixtures

@connectum/test-fixtures

Modules

index
types

Edit this page on GitHub

Pager

Previous pageReflection

Next pageindex

Released under the Apache License 2.0. · llms.txt · llms-full.txt

Copyright Highload.Zone

proto

Type Aliases

Variables

testing

Variables

Functions

proto-sync

Interfaces

Variables

Functions

reflection

Interfaces

Functions

types

Interfaces

Type Aliases

Variables

types

Interfaces

Type Aliases

types

Interfaces

Type Aliases

Variables

types

Interfaces

types

Interfaces

types

Interfaces

bulkhead

Functions

circuit-breaker

Functions

defaults

Interfaces

Functions

errorHandler

Functions

fallback

Functions

logger

Functions

method-filter

Functions

retry

Functions

serializer

Functions

timeout

Functions

attributes

Type Aliases

Variables

client-interceptor

Functions

interceptor

Functions

logger

Interfaces

Functions

meter

Functions

metrics

Interfaces

Functions

provider

Interfaces

Functions

shared

Interfaces

Functions

traceAll

Functions

traced

Functions

tracer

Functions

@connectum/test-fixtures ​

Modules ​

@connectum/test-fixtures

Modules