push

Documentation

Index

• type MQTTPusher
  • func NewMQTTPusher(client *mqtt.MQTTClient, topic string, ...) *MQTTPusher
  • func (m *MQTTPusher) Close() error
  • func (m *MQTTPusher) Push() error
• type Pusher

Types

type MQTTPusher

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

func NewMQTTPusher

func NewMQTTPusher(client *mqtt.MQTTClient, topic string, inChan chan gorenogymodbus.DynamicControllerInformation) *MQTTPusher

func (*MQTTPusher) Close

func (m *MQTTPusher) Close() error

func (*MQTTPusher) Push

func (m *MQTTPusher) Push() error

type Pusher

type Pusher interface {
	Push() error
	Close() error
}