rocketmq

Documentation

Index

• Constants
• func NewDaprQueueSelector() *daprQueueSelector
• func NewRocketMQ(l logger.Logger) pubsub.PubSub
• type QueueSelectorType

Constants

const (
	KeyConsumeFromWhere string = "consumeFromWhere"
	KeyQueueSelector    string = "queueSelector"
)

Functions

func NewDaprQueueSelector

func NewDaprQueueSelector() *daprQueueSelector

func NewRocketMQ

func NewRocketMQ(l logger.Logger) pubsub.PubSub

Types

type QueueSelectorType

type QueueSelectorType string

const (
	HashQueueSelector       QueueSelectorType = "hash"
	RandomQueueSelector     QueueSelectorType = "random"
	ManualQueueSelector     QueueSelectorType = "manual"
	RoundRobinQueueSelector QueueSelectorType = "roundRobin"
	DaprQueueSelector       QueueSelectorType = "dapr"
)