topics

package
v0.0.53 Latest Latest
Warning

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

Go to latest
Published: Nov 5, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateConsumer

func CreateConsumer(options ...OptionsConsumer) (*consumer, error)

func CreateProducer

func CreateProducer(options ...OptionsProd) (*producer, error)

CreateProducer 创建一个生产者

Types

type OptionFunc

type OptionFunc func(*producer)

OptionFunc 以函数形式实现上面的接口

type OptionsConsumer

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

OptionsConsumer 定义动态设置参数接口

func SetConsMsgDelayParams

func SetConsMsgDelayParams(enableDelayMsgPlugin bool) OptionsConsumer

SetConsMsgDelayParams 开发者设置消费者端初始化时的参数

type OptionsConsumerFunc

type OptionsConsumerFunc func(*consumer)

OptionsConsumerFunc 以函数形式实现上面的接口

type OptionsProd

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

OptionsProd 定义动态设置参数接口

func SetProdMsgDelayParams

func SetProdMsgDelayParams(enableMsgDelayPlugin bool) OptionsProd

SetProdMsgDelayParams 开发者设置生产者初始化时的参数

Jump to

Keyboard shortcuts

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