microservices

Entry point exports

Classes

BaseRpcContext
BaseRpcExceptionFilter
ClientGrpcProxy
ClientKafka
ClientMqtt
ClientNats
ClientProxy
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 ClientProxy instance to the given property

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.

MqttEvents

MQTT events map for the MQTT client. Key is the event name and value is the corresponding callback function.

NatsEvents

Nats events map for the Nats client. Key is the event name and value is the corresponding callback function.

RedisEvents

Redis events map for the Redis client. Key is the event name and value is the corresponding callback function.

RmqEvents

RabbitMQ events map for the ampqlip client. Key is the event name and value is the corresponding callback function.

TcpEvents

TCP events map for the net TCP socket. Key is the event name and value is the corresponding callback function.