utils

Documentation

Index

• func NewStructuredMessage(format format.Format, reader io.Reader) *genericStructuredMessage
• func WriteStructured(ctx context.Context, m binding.Message, writer io.Writer, ...) error

Functions

func NewStructuredMessage

func NewStructuredMessage(format format.Format, reader io.Reader) *genericStructuredMessage

NewStructuredMessage wraps a format and an io.Reader returning an implementation of Message This message *cannot* be read several times safely

func WriteStructured

func WriteStructured(ctx context.Context, m binding.Message, writer io.Writer, transformers ...binding.Transformer) error

WriteStructured fills the provided io.Writer with the binding.Message m in structured mode. Using context you can tweak the encoding processing (more details on binding.Write documentation).