ping

Documentation

Index

• type PingBody
• type PingPlugin
  • func NewPingPlugin(bus *events.Bus, logger *zap.Logger) *PingPlugin
  • func (p *PingPlugin) Handle(ctx context.Context, dev device.Sender, pkt *protocol.Packet) error
  • func (p *PingPlugin) IncomingTypes() []string
  • func (p *PingPlugin) Name() string
  • func (p *PingPlugin) OnConnect(dev device.Sender)
  • func (p *PingPlugin) OnDisconnect(dev device.Sender)
  • func (p *PingPlugin) OutgoingTypes() []string
  • func (p *PingPlugin) Timeout() time.Duration

Types

type PingBody

type PingBody struct {
	Message string `json:"message"`
}

type PingPlugin

type PingPlugin struct {
	// contains filtered or unexported fields
}

func NewPingPlugin

func NewPingPlugin(bus *events.Bus, logger *zap.Logger) *PingPlugin

func (*PingPlugin) Handle

func (p *PingPlugin) Handle(ctx context.Context, dev device.Sender, pkt *protocol.Packet) error

func (*PingPlugin) IncomingTypes

func (p *PingPlugin) IncomingTypes() []string

func (*PingPlugin) Name

func (p *PingPlugin) Name() string

func (*PingPlugin) OnConnect

func (p *PingPlugin) OnConnect(dev device.Sender)

func (*PingPlugin) OnDisconnect

func (p *PingPlugin) OnDisconnect(dev device.Sender)

func (*PingPlugin) OutgoingTypes

func (p *PingPlugin) OutgoingTypes() []string

func (*PingPlugin) Timeout

func (p *PingPlugin) Timeout() time.Duration