message

Documentation

Index

• Constants
• func Unserialize(data []byte, target interface{})
• type Handler
• type Message
  • func NewMessage(topic string, content any) Message
  • func NewMessageFromFrames(frames []string) (Message, error)
• type SerializedValue
  • func Serialize(data any) SerializedValue
  • func (d SerializedValue) To(target interface{})
  • func (d SerializedValue) ToInt() int
  • func (d SerializedValue) ToString() string

Constants

const (
	IndexTopic       = 0
	IndexContentType = 1
	IndexContent     = 2
)

Functions

func Unserialize

func Unserialize(data []byte, target interface{})

Types

type Handler

type Handler func(msg Message)

type Message

type Message struct {
	Topic       string
	ContentType string
	Content     SerializedValue
}

func NewMessage

func NewMessage(topic string, content any) Message

func NewMessageFromFrames

func NewMessageFromFrames(frames []string) (Message, error)

type SerializedValue

type SerializedValue []byte

func Serialize

func Serialize(data any) SerializedValue

func (SerializedValue) To

func (d SerializedValue) To(target interface{})

func (SerializedValue) ToInt

func (d SerializedValue) ToInt() int

func (SerializedValue) ToString

func (d SerializedValue) ToString() string