event

package
v1.5.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 8, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Event

type Event interface {
	Fire(topic string, datas [][]byte) error
	Register(...EventJob)
}

func NewMqttEvent

func NewMqttEvent(service string, mqttConf *mymqtt.MqttConf, l log.Logger) Event

func NewPubSubEvent

func NewPubSubEvent() Event

type EventConf

type EventConf struct {
	Provider string
	Mqtt     *mqtt.MqttConf
}

func (*EventConf) NewEvent

func (ec *EventConf) NewEvent(serviceName string, l log.Logger) Event

type EventDI

type EventDI interface {
	NewEvent(serviceName string, l log.Logger) Event
}

type EventHandler

type EventHandler func(data []byte) error

type EventJob

type EventJob interface {
	GetTopic() string
	GetHandler() EventHandler
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL