bridge

Documentation

Index

• Constants
• func InitKafka() *kafka
• type BridgeMQ
  • func NewBridgeMQ(name string) BridgeMQ
• type Elements

Constants

const (
	//Connect mqtt connect
	Connect = "connect"
	//Publish mqtt publish
	Publish = "publish"
	//Subscribe mqtt sub
	Subscribe = "subscribe"
	//Unsubscribe mqtt sub
	Unsubscribe = "unsubscribe"
	//Disconnect mqtt disconenct
	Disconnect = "disconnect"
)

const (
	//Kafka plugin name
	Kafka = "kafka"
)

Functions

func InitKafka

func InitKafka() *kafka

Init init kafak client

Types

type BridgeMQ

type BridgeMQ interface {
	Publish(e *Elements) error
}

func NewBridgeMQ

func NewBridgeMQ(name string) BridgeMQ

type Elements

type Elements struct {
	ClientID  string `json:"clientid"`
	Username  string `json:"username"`
	Topic     string `json:"topic"`
	Payload   string `json:"payload"`
	Timestamp int64  `json:"ts"`
	Size      int32  `json:"size"`
	Action    string `json:"action"`
}

Elements kafka publish elements