event

Documentation

Index

• Constants
• func NewEvent(c *conf.Event) (mq.IMQ, error)
• type KafkaEvent
  • 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
  • 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 WithDisconnectTime(quiesce uint) MqttEventOption
• type RocketMQEvent
  • 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 WithAwaitDuration(d time.Duration) RocketMQEventOption
  • func WithInvisibleDuration(d time.Duration) RocketMQEventOption
  • func WithMaxMessageNum(n int32) RocketMQEventOption

Constants

const (
	// DisconnectTime 断开重连时间
	DisconnectTime uint = 250
)

Functions

func NewEvent

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

NewEvent 创建消息队列

Types

type KafkaEvent

type KafkaEvent struct {
	// contains filtered or unexported fields
}

KafkaEvent kafka event

func NewKafkaEvent

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

NewKafkaEvent 创建kafka event

func (*KafkaEvent) Close

func (k *KafkaEvent) Close()

Close 关闭

func (*KafkaEvent) Receive

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

Receive 接收

func (*KafkaEvent) RemoveReceiver

func (k *KafkaEvent) RemoveReceiver(topic string)

RemoveReceiver 移除监听

func (*KafkaEvent) Send

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

Send 发送

type MqttEvent

type MqttEvent struct {
	DisconnectTime uint
	// contains filtered or unexported fields
}

MqttEvent MQTT 事件

func NewMqttEvent

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

NewMqttEvent 创建MQTT 事件

func (*MqttEvent) Close

func (m *MqttEvent) Close()

Close 关闭

func (*MqttEvent) Receive

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

Receive 接收消息

func (*MqttEvent) RemoveReceiver

func (m *MqttEvent) RemoveReceiver(topic string)

RemoveReceiver 移除接收者

func (*MqttEvent) Send

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

Send 发送消息

type MqttEventOption

type MqttEventOption func(r *MqttEvent)

MqttEventOption 选项

func WithDisconnectTime

func WithDisconnectTime(quiesce uint) MqttEventOption

WithDisconnectTime 设置断开重连时间

type RocketMQEvent

type RocketMQEvent struct {
	// contains filtered or unexported fields
}

RocketMQEvent RocketMQ事件

func NewRocketMQEvent

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

NewRocketMQEvent 创建RocketMQ事件

func (*RocketMQEvent) Close

func (r *RocketMQEvent) Close()

Close 关闭 mq

func (*RocketMQEvent) ConvertMessageView

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

ConvertMessageView 转换消息视图

func (*RocketMQEvent) Receive

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

Receive 监听topic

func (*RocketMQEvent) RemoveReceiver

func (r *RocketMQEvent) RemoveReceiver(topic string)

RemoveReceiver 移除监听

func (*RocketMQEvent) Send

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

Send 发送消息

type RocketMQEventOption

type RocketMQEventOption func(r *RocketMQEvent)

RocketMQEventOption 选项

func WithAwaitDuration

func WithAwaitDuration(d time.Duration) RocketMQEventOption

WithAwaitDuration 设置等待时间

func WithInvisibleDuration

func WithInvisibleDuration(d time.Duration) RocketMQEventOption

WithInvisibleDuration 设置不可见时间

func WithMaxMessageNum

func WithMaxMessageNum(n int32) RocketMQEventOption

WithMaxMessageNum 设置最大消息数