event

Dec 26, 2024

Changes in this version

+ const DisconnectTime

+ type KafkaEvent struct

+ func NewKafkaEvent(c *conf.Kafka) (*KafkaEvent, error)

+ func (k *KafkaEvent) Close()

+ func (k *KafkaEvent) Receive(topic string) <-chan *mq.Msg

+ func (k *KafkaEvent) RemoveReceiver(topic string)

+ func (k *KafkaEvent) Send(_ string, _ []byte) error

+ type MqttEvent struct

+ DisconnectTime uint

+ func NewMqttEvent(c *conf.MQTT, opts ...MqttEventOption) (*MqttEvent, error)

+ func (m *MqttEvent) Close()

+ func (m *MqttEvent) Receive(topic string) <-chan *mq.Msg

+ func (m *MqttEvent) RemoveReceiver(topic string)

+ func (m *MqttEvent) Send(_ string, _ []byte) error

+ type MqttEventOption func(r *MqttEvent)

+ func WithDisconnectTime(quiesce uint) MqttEventOption

Dec 5, 2024

Changes in this version

+ func NewEvent(c *conf.MQ) (mq.IMQ, error)

+ type RocketMQEvent struct

+ func NewRocketMQEvent(c *conf.RocketMQ, opts ...RocketMQEventOption) (*RocketMQEvent, error)

+ func (r *RocketMQEvent) Close()

+ func (r *RocketMQEvent) ConvertMessageView(ctx context.Context, topic string, messages []*golang.MessageView) []*mq.Msg

+ func (r *RocketMQEvent) Receive(topic string) <-chan *mq.Msg

+ func (r *RocketMQEvent) RemoveReceiver(topic string)

+ func (r *RocketMQEvent) Send(_ string, _ []byte) error

+ type RocketMQEventOption func(r *RocketMQEvent)

+ func WithAwaitDuration(d time.Duration) RocketMQEventOption

+ func WithInvisibleDuration(d time.Duration) RocketMQEventOption

+ func WithMaxMessageNum(n int32) RocketMQEventOption