qtypes

Documentation

Index

• type MessageBody
• type MessageData
• type QueueConf
• type QueueData
• type QueueDelayData

Types

type MessageBody

type MessageBody struct {
	// queue body
	Body any `json:"body"`
	// queue type
	Type string `json:"type"`
	// execution count
	Attempt uint16 `json:"attempt"`
}

type MessageData

type MessageData struct {
	// message id
	ID string `json:"id"`
	// queue type
	Type string `json:"type"`
	// queue body
	Body string `json:"body"`
	// queue create time
	CreatedAt int64 `json:"createdAt"`
	// delay time(unit millisecond)
	Delay int32 `json:"delay"`
	// execution count
	Attempt uint16 `json:"attempt"`
}

type QueueConf

type QueueConf struct {
	// queue name
	Name string `json:",optional"`
	// single active consumer,Effective only in RabbitMQ
	SingleActive bool `json:",optional"`
}

QueueConf topic conf

type QueueData

type QueueData struct {
	// queue name
	Name string
	// queue type
	Type string
	// queue body
	Body any
	// execution count
	Attempt uint16
}

QueueData 队列数据

type QueueDelayData

type QueueDelayData struct {
	// queue name
	Name string
	// queue type
	Type string
	// queue body
	Body any
	// delay time(unit millisecond)
	Delay int32
	// execution count
	Attempt uint16
}