mq

package
v0.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 7, 2023 License: BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Conf

type Conf struct {
	NamesrvAddr   string `yaml:"namesrv_addr"`
	BrokerAddr    string `yaml:"broker_addr"`
	RetryTimes    int    `yaml:"retry_times"`
	ProducerGroup string `yaml:"producer_group"`
}

func FromEnv

func FromEnv() Conf

type RocketMQ

type RocketMQ struct {
	Conf     Conf
	Producer rocketmq.Producer
}

func NewRocketMQ

func NewRocketMQ(conf Conf) RocketMQ

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL