envelope

type Message ¶

type Message struct {
	ID        string    `json:"id"`
	Sender    string    `json:"sender"`
	Payload   string    `json:"payload"`
	CreatedAt time.Time `json:"created_at"`
}

Sender is the source handle the message was published *from* — the broadcaster's current source at publish time. Empty string when the publisher had no current source set (e.g. `ppz send <dest>` from a session that never connected). Distinct from the destination handle, which is encoded only in the NATS subject (per WIRE.md §3).

func New(sender, payload string, now time.Time) Message

func Unmarshal(b []byte) (Message, error)

func (m Message) Marshal() ([]byte, error)