iot_writer

Documentation

Index

• Constants
• type IoTWriter
  • func New(client MQTT.Client, topic string) *IoTWriter
  • func (iw *IoTWriter) Flush() error
  • func (iw *IoTWriter) Write(p []byte) (int, error)

Constants

const BUFFER_SIZE = 1024 * 100

Types

type IoTWriter

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

func New

func New(client MQTT.Client, topic string) *IoTWriter

func (*IoTWriter) Flush

func (iw *IoTWriter) Flush() error

func (*IoTWriter) Write

func (iw *IoTWriter) Write(p []byte) (int, error)