edgefarm_network

Documentation

Index

• type MqttConnection
  • func NewMqttConnection() *MqttConnection
  • func (m *MqttConnection) Close()
  • func (m *MqttConnection) Connect(connectTimeoutSeconds time.Duration) error
  • func (m *MqttConnection) Publish(topic string, message []byte) error
  • func (m *MqttConnection) Subscribe(topic string, handlerFunc func(mqtt.Message)) error
• type NatsConnection
  • func NewNatsConnection() *NatsConnection
  • func (n *NatsConnection) Close()
  • func (n *NatsConnection) Connect(connectTimeoutSeconds int) error
  • func (n *NatsConnection) Publish(topic string, message []byte) error
  • func (n *NatsConnection) Subscribe(subject string, handlerFunc interface{}) error

Types

type MqttConnection

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

MqttConnection represents the MQTT connection

func NewMqttConnection

func NewMqttConnection() *MqttConnection

NewMqttConnection creates new MQTT client

func (*MqttConnection) Close

func (m *MqttConnection) Close()

Close mqtt connection

func (*MqttConnection) Connect

func (m *MqttConnection) Connect(connectTimeoutSeconds time.Duration) error

Connect to MQTT server. Server URL can be provided via MQTT_SERVER environment variable.

func (*MqttConnection) Publish

func (m *MqttConnection) Publish(topic string, message []byte) error

Publish message to topic provided

func (*MqttConnection) Subscribe

func (m *MqttConnection) Subscribe(topic string, handlerFunc func(mqtt.Message)) error

Subscribe to topic, required handler function for message receive.

type NatsConnection

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

NatsConnection represents nats connection

func NewNatsConnection

func NewNatsConnection() *NatsConnection

NewNatsConnection creates new nats client

func (*NatsConnection) Close

func (n *NatsConnection) Close()

Close close nats connection

func (*NatsConnection) Connect

func (n *NatsConnection) Connect(connectTimeoutSeconds int) error

Connect to NATS server. Server URL can be provided via NATS_SERVER environment variable. Provide NATS_CREDS_PATH if credentials shall be provided.

func (*NatsConnection) Publish

func (n *NatsConnection) Publish(topic string, message []byte) error

Publish publish message to topic provided

func (*NatsConnection) Subscribe

func (n *NatsConnection) Subscribe(subject string, handlerFunc interface{}) error

Subscribes to subject, required handler function for message receive.