bridge

Documentation

Index

• Constants
• func NewKafka(config *KafkaConfig) (*kafka, error)
• type Bridge
• type Elements
• type KafkaConfig

Constants

const (
	Connect     = "connect"
	Publish     = "publish"
	Subscribe   = "subscribe"
	Unsubscribe = "unsubscribe"
	Disconnect  = "disconnect"
)

Functions

func NewKafka

func NewKafka(config *KafkaConfig) (*kafka, error)

Types

type Bridge

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

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"`
}

type KafkaConfig

type KafkaConfig struct {
	Addr             []string          `json:"addr"`
	ConnectTopic     string            `json:"onConnect"`
	SubscribeTopic   string            `json:"onSubscribe"`
	PublishTopic     string            `json:"onPublish"`
	UnsubscribeTopic string            `json:"onUnsubscribe"`
	DisconnectTopic  string            `json:"onDisconnect"`
	DeliverMap       map[string]string `json:"deliverMap"`
}