publish_subscribe

Documentation

Index

• func CreateConsumer(options ...OptionsConsumer) (*consumer, error)
• func CreateProducer(options ...OptionsProd) (*producer, error)
• type OptionFunc
• type OptionsConsumer
  • func SetConsMsgDelayParams(enableDelayMsgPlugin bool) OptionsConsumer
• type OptionsConsumerFunc
• type OptionsProd
  • func SetProdMsgDelayParams(enableMsgDelayPlugin bool) OptionsProd

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 开发者设置生产者初始化时的参数