queue

Documentation

Index

• func ToPayload(m any) []byte
• type Message
• type QueueHandler

Functions

func ToPayload

func ToPayload(m any) []byte

Types

type Message

type Message struct {
	ID       string
	Metadata map[string]string
	Data     []byte
}

type QueueHandler

type QueueHandler interface {
	io.Closer
	Add(context.Context, string, *Message) error
	Start(context.Context)
}