mqtt5

Documentation

Index

• Constants
• func Run(conn net.Conn, timeout time.Duration, tls bool, target plugins.Target) (*plugins.Service, error)
• type MQTT5Plugin
  • func (p *MQTT5Plugin) Name() string
  • func (p *MQTT5Plugin) PortPriority(i uint16) bool
  • func (p *MQTT5Plugin) Priority() int
  • func (p *MQTT5Plugin) Run(conn net.Conn, timeout time.Duration, target plugins.Target) (*plugins.Service, error)
  • func (p *MQTT5Plugin) 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, timeout time.Duration, target plugins.Target) (*plugins.Service, error)
  • func (p *TLSPlugin) Type() plugins.Protocol

Constants

const MQTT = "mqtt5"

const MQTTTLS = "mqtt5tls"

Functions

func Run

func Run(conn net.Conn, timeout time.Duration, tls bool, target plugins.Target) (*plugins.Service, error)

Types

type MQTT5Plugin

type MQTT5Plugin struct{}

func (*MQTT5Plugin) Name

func (p *MQTT5Plugin) Name() string

func (*MQTT5Plugin) PortPriority

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

func (*MQTT5Plugin) Priority

func (p *MQTT5Plugin) Priority() int

func (*MQTT5Plugin) Run

func (p *MQTT5Plugin) Run(conn net.Conn, timeout time.Duration, target plugins.Target) (*plugins.Service, error)

func (*MQTT5Plugin) Type

func (p *MQTT5Plugin) 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, timeout time.Duration, target plugins.Target) (*plugins.Service, error)

func (*TLSPlugin) Type

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