message

package

v0.0.0-...-7593c98 Latest Latest Go to latest Published: Aug 27, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type HandlerFunc func(msg *Message) error

func HandleWithPayload[T any](handler HandlerFuncWithPayload[T]) HandlerFunc

type HandlerFuncWithPayload[T any] func(msg *Message, payload T) error

type Message struct {
	ID       string
	Metadata Metadata
	Payload  Payload
	// contains filtered or unexported fields
}

func NewMessage(ctx context.Context, payload Payload) *Message

func (m *Message) Ack() bool

func (m *Message) Context() context.Context

func (m *Message) Copy() *Message

func (m *Message) Destroy()

func (m *Message) Equals(toCompare *Message) bool

Equals compare, that two messages are equal. Acks/Nacks are not compared.

func (m *Message) Nack() bool

func (m *Message) SetContext(ctx context.Context) *Message

func (m *Message) State() State

func (m *Message) StateChange() <-chan State

func (m *Message) WithMetadata(key string, value interface{}) *Message

type Metadata map[string]interface{}

type Payload any

type State int

const (
	Processing State = iota
	Ack
	Nack
)

Path	Synopsis
middleware