rocketmq

Documentation

Index

• Constants
• func NewNormalPublisher(producerOptions []mqp.Option, opts ...PubOption) (*normalPublisher, error)
• func NewNormalRocketMQ(producerOptions []mqp.Option, consumerOptions []mqc.Option, opts ...PubOption) (*normalRocket, error)
• func NewPubOptions() *pubOptions
• func NewSubscriber(opts ...mqc.Option) (*subscriber, error)
• func NewTransactionPublisher(producerOptions []mqp.Option, ...) (*transactionPublisher, error)
• func NewTransactionRocketMQ(producerOptions []mqp.Option, consumerOptions []mqc.Option, ...) (*transactionRocket, error)
• func PrintPubOptions(packageName string)
• type Metadata
• type Producer
• type PubOption
  • func SkipPubOption() PubOption
  • func WithPubGetMetadata(getMetadata func(e *pb.Event) Metadata) PubOption
  • func WithPubOptions(o *pubOptions) PubOption

Constants

const (
	MetadataRocketmqTag         = "rocketmq-tag"
	MetadataRocketmqKey         = "rocketmq-key"
	MetadataRocketmqShardingKey = "rocketmq-shardingkey"
)

Functions

func NewNormalPublisher

func NewNormalPublisher(producerOptions []mqp.Option, opts ...PubOption) (*normalPublisher, error)

NewNormalPublisher 函数用于创建一个 normalPublisher 结构体实例

func NewNormalRocketMQ

func NewNormalRocketMQ(producerOptions []mqp.Option, consumerOptions []mqc.Option, opts ...PubOption) (*normalRocket, error)

NewNormalRocketMQ 函数用于创建一个 rocketMQ 结构体实例

func NewPubOptions

func NewPubOptions() *pubOptions

NewPubOptions new options struct

func NewSubscriber

func NewSubscriber(opts ...mqc.Option) (*subscriber, error)

func NewTransactionPublisher

func NewTransactionPublisher(
	producerOptions []mqp.Option,
	checkLocalTransaction func(ext *primitive.MessageExt) primitive.LocalTransactionState,
	opts ...PubOption,
) (*transactionPublisher, error)

func NewTransactionRocketMQ

func NewTransactionRocketMQ(
	producerOptions []mqp.Option,
	consumerOptions []mqc.Option,
	checkLocalTransaction func(ext *primitive.MessageExt) primitive.LocalTransactionState,
	opts ...PubOption,
) (*transactionRocket, error)

func PrintPubOptions

func PrintPubOptions(packageName string)

Types

type Metadata

type Metadata map[string]string

type Producer

type Producer interface {
	Start() error
	Shutdown() error
}

type PubOption

type PubOption interface {
	// contains filtered or unexported methods
}

PubOption option interface

func SkipPubOption

func SkipPubOption() PubOption

func WithPubGetMetadata

func WithPubGetMetadata(getMetadata func(e *pb.Event) Metadata) PubOption

WithPubGetMetadata getMetadata option of pubConfig

func WithPubOptions

func WithPubOptions(o *pubOptions) PubOption