@numaproj/numaflow-js - v0.0.0-alpha.4
    Preparing search index...

    Class Message

    Represents an output message from a map handler.

    // Simple message
    const msg = new map.Message(Buffer.from('hello'));

    // Message with routing keys
    const routed = new map.Message(Buffer.from('data'), {
    keys: ['partition-1'],
    tags: ['output-a']
    });
    Index

    Constructors

    Properties

    Methods

    Constructors

    Properties

    keys?: string[]

    Optional keys for routing

    tags?: string[]

    Optional tags for conditional forwarding

    userMetadata?: map.UserMetadata

    Optional user metadata

    value: Buffer

    The message payload

    Methods