message

Documentation

Overview

Package message provides everything related to messages.

Index

• type Message
  • func MustNew(topic string, data any) *Message
  • func New(topic string, data any) (*Message, error)
  • func (m *Message) Process(b any, v any) error

Types

type Message

type Message struct {
	common.Common

	// Data to be published.
	Data any `json:"data"`
}

Message definition.

func MustNew

func MustNew(topic string, data any) *Message

MustNew creates a new message, panicking if there's an error.

func New

func New(topic string, data any) (*Message, error)

New creates a new message.

func (*Message) Process

func (m *Message) Process(b any, v any) error

Process the content of the message `b` into `v`.