communication

Documentation

Index

• Constants
• type PublishSession
• type Session
  • func NewSession(address, token string, log logger.ILog) (Session, error)
• type SubscribeSession

Constants

const ClearLevelAlarmMessage = "ClearLevelAlarm"

ClearLevelAlarmMessage name

const FeedPauseMessage = "FeedPause"

FeedPauseMessage name

const MaintenanceMessage = "Maintenance"

MaintenanceMessage name

const ResetReminderMessage = "ResetReminder"

ResetReminderMessage name

const ThunderstormMessage = "Thunderstorm"

ThunderstormMessage name

const UpdateMessage = "Update"

UpdateMessage name

const WaterChangeMessage = "WaterChange"

WaterChangeMessage name

Types

type PublishSession

type PublishSession interface {
	Publish(message string, data string) error
	PublishData(message string, data []byte) error
}

type Session

type Session interface {
	SubscribeSession
	PublishSession
	Close()
}

Session interface

func NewSession

func NewSession(address, token string, log logger.ILog) (Session, error)

NewSession creates a new session

type SubscribeSession

type SubscribeSession interface {
	QueueSubscribe(message string, queue string) (chan string, error)
}