metadata

package

v0.3.3 Latest Latest Go to latest Published: Nov 24, 2025 License: MIT Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

func ToWatermill(metadata Metadata) message.Metadata

ToWatermill converts Protoflow metadata into a Watermill map.

type Metadata map[string]string

Metadata represents the headers carried alongside an event.

func FromWatermill(md message.Metadata) Metadata

FromWatermill converts Watermill metadata into Protoflow metadata.

func New(pairs ...string) Metadata

New constructs a Metadata map from alternating key/value pairs.

func (m Metadata) Clone() Metadata

Clone returns a shallow copy of the metadata map.

func (m Metadata) With(key, value string) Metadata

With returns a cloned metadata map containing the provided key/value pair.

func (m Metadata) WithAll(entries Metadata) Metadata

WithAll returns a cloned metadata map containing the supplied entries.