microservices
Entry point exports
Classes
BaseRpcContext
|
|
BaseRpcExceptionFilter
|
|
ClientGrpcProxy
|
|
ClientKafka
|
|
ClientMqtt
|
|
ClientNats
|
|
ClientProxyFactory
|
|
ClientRMQ
|
|
ClientRedis
|
|
ClientTCP
|
|
KafkaContext
|
|
KafkaRetriableException
|
Exception that instructs Kafka driver to instead of introspecting error processing flow and sending serialized error message to the consumer, force bubble it up to the "eachMessage" callback of the underlying "kafkajs" package (even if interceptors are applied, or an observable stream is returned from the message handler). |
MqttContext
|
|
MqttRecord
|
|
MqttRecordBuilder
|
|
NatsContext
|
|
NatsRecord
|
|
NatsRecordBuilder
|
|
RedisContext
|
|
RmqContext
|
|
RmqRecord
|
|
RmqRecordBuilder
|
|
RpcException
|
|
Server
|
|
ServerGrpc
|
|
ServerKafka
|
|
ServerMqtt
|
|
ServerNats
|
|
ServerRMQ
|
|
ServerRedis
|
|
ServerTCP
|
|
TcpContext
|
Decorators
Client
|
Attaches the |
Structures
ClientGrpc
|
|
CustomClientOptions
|
|
CustomStrategy
|
|
CustomTransportStrategy
|
|
Deserializer
|
|
GrpcOptions
|
|
KafkaHeaders
|
|
KafkaOptions
|
|
KafkaParserConfig
|
|
MessageHandler
|
|
MqttOptions
|
|
MqttRecordOptions
|
|
NatsOptions
|
|
RedisOptions
|
|
RmqOptions
|
|
RmqRecordOptions
|
|
Serializer
|
|
TcpClientOptions
|
|
TcpOptions
|
Types
EventPattern
|
Subscribes to incoming events which fulfils chosen pattern. |
MessagePattern
|
Subscribes to incoming messages which fulfils chosen pattern. |