message

Documentation

Index

• type Extra
• type Handler
• type Status

Types

type Extra

type Extra struct {
	Attributes map[string]string
	Messages   map[string]types.MessageAttributeValue
	Id         *string
	Handle     *string
}

type Handler

type Handler[T any] interface {
	// Peek 取出一个新的消息
	Peek() T

	// Process 处理消息
	Process(context context.Context, msg T, extra *Extra) (status Status, err error)
}

type Status

type Status int

Status 消费状态

const (
	// StatusUnknown 默认消费状态
	StatusUnknown Status = 0
	// StatusSuccess 消费成功，会从队列中删除消息
	StatusSuccess Status = 1
	// StatusLater 延迟消费，等待下一次消费
	StatusLater Status = 2
)