mqtt3

Documentation

Index

• Constants
• func Run(conn net.Conn, timeout time.Duration) (*plugins.PluginResults, error)
• type MQTT3Plugin
  • func (p *MQTT3Plugin) Name() string
  • func (p *MQTT3Plugin) PortPriority(i uint16) bool
  • func (p *MQTT3Plugin) Priority() int
  • func (p *MQTT3Plugin) Run(conn net.Conn, config plugins.PluginConfig) (*plugins.PluginResults, error)
  • func (p *MQTT3Plugin) Type() plugins.Protocol
• type TLSPlugin
  • func (p *TLSPlugin) Name() string
  • func (p *TLSPlugin) PortPriority(i uint16) bool
  • func (p *TLSPlugin) Priority() int
  • func (p *TLSPlugin) Run(conn net.Conn, config plugins.PluginConfig) (*plugins.PluginResults, error)
  • func (p *TLSPlugin) Type() plugins.Protocol

Constants

const MQTT = "mqtt3"

const MQTTTLS = "mqtt3tls"

Functions

func Run

func Run(conn net.Conn, timeout time.Duration) (*plugins.PluginResults, error)

Types

type MQTT3Plugin

type MQTT3Plugin struct{}

func (*MQTT3Plugin) Name

func (p *MQTT3Plugin) Name() string

func (*MQTT3Plugin) PortPriority

func (p *MQTT3Plugin) PortPriority(i uint16) bool

func (*MQTT3Plugin) Priority

func (p *MQTT3Plugin) Priority() int

func (*MQTT3Plugin) Run

func (p *MQTT3Plugin) Run(conn net.Conn, config plugins.PluginConfig) (*plugins.PluginResults, error)

func (*MQTT3Plugin) Type

func (p *MQTT3Plugin) Type() plugins.Protocol

type TLSPlugin

type TLSPlugin struct{}

func (*TLSPlugin) Name

func (p *TLSPlugin) Name() string

func (*TLSPlugin) PortPriority

func (p *TLSPlugin) PortPriority(i uint16) bool

func (*TLSPlugin) Priority

func (p *TLSPlugin) Priority() int

func (*TLSPlugin) Run

func (p *TLSPlugin) Run(conn net.Conn, config plugins.PluginConfig) (*plugins.PluginResults, error)

func (*TLSPlugin) Type

func (p *TLSPlugin) Type() plugins.Protocol