message

Documentation

Index

• func EncodeMessage(message Message) ([]byte, error)
• type Message
  • func ExtractMessage(bytes []byte) (Message, error)
  • func (msg Message) String() string

Functions

func EncodeMessage

func EncodeMessage(message Message) ([]byte, error)

Types

type Message

type Message struct {
	Payload interface{}
	Headers map[string]interface{}
}

func ExtractMessage

func ExtractMessage(bytes []byte) (Message, error)

func (Message) String

func (msg Message) String() string