event

Documentation

Index

• Constants
• Variables
• func Boot()
• func ReceivedTopicPublishEventName(topic string) events.EventName
• func TopicMessageStoredEventName(topic string) events.EventName
• func WithEventPrefix(name, s string) events.EventName
• type Event
  • func (e *Event) CreateListenMessageStoreEvent(topic string, handler func(...interface{}))
  • func (e *Event) CreatePublishEvent(topic string, handler func(...interface{}))
  • func (e *Event) DeleteListenMessageStoreEvent(topic string, handler func(i ...interface{}))
  • func (e *Event) DeletePublishEvent(topic string, handler func(i ...interface{}))
  • func (e *Event) EmitClientPublish(topic string, publish *packet.PublishMessage)
  • func (e *Event) EmitStoreMessage(topic, messageID string)

Constants

const (
	Connect               = "event.connect"
	Disconnect            = "event.disconnect"
	Ping                  = "event.ping"
	Pong                  = "event.pong"
	Subscribe             = "event.subscribe"
	Unsubscribe           = "event.unsubscribe"
	ClientPublish         = "event.client.publish"
	ClientPublishTopic    = "event.client.publish_topic"
	BrokerPublish         = "event.store.publish"
	BrokerPublishToClient = "event.store.publish_to_client"
	ClientPublishAck      = "event.client.publish_ack"
	BrokerPublishAck      = "event.store.publish_ack"
	ClientAuth            = "event.client.auth"
	BrokerAuth            = "event.store.auth"
)

const (
	MessageStored = "event.store.message_stored"
)

Variables

var (
	Driver = events.New()
)

Functions

func Boot

func Boot()

func ReceivedTopicPublishEventName

func ReceivedTopicPublishEventName(topic string) events.EventName

func TopicMessageStoredEventName

func TopicMessageStoredEventName(topic string) events.EventName

func WithEventPrefix

func WithEventPrefix(name, s string) events.EventName

Types

type Event

type Event struct {
}

var GlobalEvent *Event

func (*Event) CreateListenMessageStoreEvent

func (e *Event) CreateListenMessageStoreEvent(topic string, handler func(...interface{}))

func (*Event) CreatePublishEvent

func (e *Event) CreatePublishEvent(topic string, handler func(...interface{}))

func (*Event) DeleteListenMessageStoreEvent

func (e *Event) DeleteListenMessageStoreEvent(topic string, handler func(i ...interface{}))

func (*Event) DeletePublishEvent

func (e *Event) DeletePublishEvent(topic string, handler func(i ...interface{}))

func (*Event) EmitClientPublish

func (e *Event) EmitClientPublish(topic string, publish *packet.PublishMessage)

func (*Event) EmitStoreMessage

func (e *Event) EmitStoreMessage(topic, messageID string)