Operators

Operators are the implementation logic that process messages.

Core Operators

Messaging Endpoints (Client)

HTTP In : Includes Rest, Websocket, and SSE

Message Construction

Messaging Channels

Message Routing

Fan Out : Scatter-Gather; Sends same msg to multiple, waits for responses
Callout : Message Router; Calls an existing Graph

Message Transformation

Buffer to JSON : Message Translator
JSON to Buffer : Message Translator
Message Translator (engine: cel-interpreter)

Messaging Endpoints (Service)

Terminate : Returns a NoOp message
Shell : Supports Req-Reply, Conversation
Passthrough : Does nothing - could delete?
API Call : Includes HTTP, Websocket
Faker

Future

Normalizer (Msg Transformation)
Canonical Data Model (Msg Transformation)
Content Enricher (Msg Transformation)
Content Filter (Msg Transformation)
Splitter (Msg Routing)
Detour (Systems Mgmt)
Content-based Router (engine: regorus (OPA)) (Message Routing)
NATS

Custom Operators

To build your own operator, go to the Software Development Kit.

Messages Settings