agent

Documentation

Index

• func LoadTLSConfig(certFile string) (*tls.Config, error)
• func NewConsumer(addr string, tlsCfg *tls.Config) (*consumer, error)
• func NewProducer(addr string, tlsCfg *tls.Config) (*producer, error)
• type OnMessage
• type Packet

Functions

func LoadTLSConfig

func LoadTLSConfig(certFile string) (*tls.Config, error)

func NewConsumer

func NewConsumer(addr string, tlsCfg *tls.Config) (*consumer, error)

func NewProducer

func NewProducer(addr string, tlsCfg *tls.Config) (*producer, error)

Types

type OnMessage

type OnMessage func(topic, message string)

type Packet

type Packet struct {
	Type    uint8
	Topic   string
	Payload string
}