rocketmq

Documentation

Index

• func NewBroker(opts ...broker.Option) broker.Broker
• func WithConsumeFromWhere(fromWhere ConsumeFromWhere) broker.Option
• func WithConsumeMode(mode MessageModel) broker.Option
• func WithCredentials(credentials Credentials) broker.Option
• func WithDelayTimeLevel(delayLevel int) broker.PublishOption
• func WithMaxReconsumeTimes(maxReconsumeTimes int32) broker.Option
• func WithRetry(retry int) broker.Option
• type ConsumeFromWhere
• type Credentials
• type MessageModel

Functions

func NewBroker

func NewBroker(opts ...broker.Option) broker.Broker

func WithConsumeFromWhere

func WithConsumeFromWhere(fromWhere ConsumeFromWhere) broker.Option

func WithConsumeMode

func WithConsumeMode(mode MessageModel) broker.Option

func WithCredentials

func WithCredentials(credentials Credentials) broker.Option

func WithDelayTimeLevel

func WithDelayTimeLevel(delayLevel int) broker.PublishOption

WithDelayTimeLevel set message delay time to consume. reference delay level definition: 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h delay level starts from 1. for example, if we set param level=1, then the delay time is 1s.

func WithMaxReconsumeTimes

func WithMaxReconsumeTimes(maxReconsumeTimes int32) broker.Option

func WithRetry

func WithRetry(retry int) broker.Option

Types

type ConsumeFromWhere

type ConsumeFromWhere int

const (
	ConsumeFromLastOffset ConsumeFromWhere = iota
	ConsumeFromFirstOffset
	ConsumeFromTimestamp
)

type Credentials

type Credentials struct {
	AccessKey string
	SecretKey string
}

type MessageModel

type MessageModel int

const (
	BroadCasting MessageModel = iota
	Clustering
)