rocketmq

Documentation

Index

• func NewRocketMQ(logger logger.Logger) pubsub.PubSub
• type Settings
  • func (s *Settings) Decode(in interface{}) error
  • func (s *Settings) ToRocketMQMetadata() *mqw.Metadata

Functions

func NewRocketMQ

func NewRocketMQ(logger logger.Logger) pubsub.PubSub

NewRocketMQ creates a new RocketMQ pub/sub.

Types

type Settings

type Settings struct {
	// sdk proto (tcp, tcp-cgo，http)
	AccessProto string `mapstructure:"accessProto"`
	// rocketmq Credentials
	AccessKey string `mapstructure:"accessKey"`
	// rocketmq Credentials
	SecretKey string `mapstructure:"secretKey"`
	// rocketmq's name server, optional
	NameServer string `mapstructure:"nameServer"`
	// rocketmq's endpoint, optional, just for http proto
	Endpoint string `mapstructure:"endpoint"`
	// rocketmq's instanceId, optional
	InstanceID string `mapstructure:"instanceId"`
	// consumer group for rocketmq's subscribers, suggested to provide
	ConsumerGroup string `mapstructure:"consumerGroup"`
	// consumer group for rocketmq's subscribers, suggested to provide
	ConsumerBatchSize int `mapstructure:"consumerBatchSize"`
	// consumer group for rocketmq's subscribers, suggested to provide, just for tcp-cgo proto
	ConsumerThreadNums int `mapstructure:"consumerThreadNums"`
	// rocketmq's name server domain, optional
	NameServerDomain string `mapstructure:"nameServerDomain"`
	// retry times to connect rocketmq's broker, optional
	Retries int `mapstructure:"retries"`
	// msg's content-type eg:"application/cloudevents+json; charset=utf-8", application/octet-stream
	ContentType string `mapstructure:"content-type"`
}

func (*Settings) Decode

func (s *Settings) Decode(in interface{}) error

func (*Settings) ToRocketMQMetadata

func (s *Settings) ToRocketMQMetadata() *mqw.Metadata