bridge

Documentation

Index

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

Constants

const (
	Kafka = "kafka"
)

Functions

func InitKafka

func InitKafka() *kafka

Init init kafak client

Types

type BridgeMQ

type BridgeMQ interface {
	Load(objs map[string]string)
	AddOrUpdateObj(key string, value string)
	RemoveObj(key string)
	GetObj(key string) (string, bool)
	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   interface{} `json:"payload"`
	Timestamp int64       `json:"ts"`
}

Elements kafka publish elements