wattpilot

README

go-wattpilot

Documentation

Index

• Constants
• type PostFunction
• type Pubsub
  • func NewPubsub() *Pubsub
  • func (ps *Pubsub) Close()
  • func (ps *Pubsub) Publish(topic string, msg interface{})
  • func (ps *Pubsub) Subscribe(topic string) <-chan interface{}
• type Wattpilot
  • func New(host string, password string) *Wattpilot
  • func (w *Wattpilot) Alias() []string
  • func (w *Wattpilot) Connect() (bool, error)
  • func (w *Wattpilot) Disconnect()
  • func (w *Wattpilot) GetCurrents() (float64, float64, float64, error)
  • func (w *Wattpilot) GetHost() string
  • func (w *Wattpilot) GetName() string
  • func (w *Wattpilot) GetNotifications(prop string) <-chan interface{}
  • func (w *Wattpilot) GetPower() (float64, error)
  • func (w *Wattpilot) GetProperty(name string) (interface{}, error)
  • func (w *Wattpilot) GetRFID() (string, error)
  • func (w *Wattpilot) GetSerial() string
  • func (w *Wattpilot) GetVoltages() (float64, float64, float64, error)
  • func (w *Wattpilot) IsInitialized() bool
  • func (w *Wattpilot) LookupAlias(name string) string
  • func (w *Wattpilot) Properties() []string
  • func (w *Wattpilot) SetCurrent(current float64) error
  • func (w *Wattpilot) SetProperty(name string, value interface{}) error
  • func (w *Wattpilot) StatusInfo()

Constants

const (
	MAX_RECONNECT_RETRIES = 5  // re-tries
	PING_TIMEOUT          = 10 // seconds
	CONTEXT_TIMEOUT       = 60 // seconds
)

Types

type PostFunction

type PostFunction func(interface{}) (string, error)

type Pubsub

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

func NewPubsub

func NewPubsub() *Pubsub

func (*Pubsub) Close

func (ps *Pubsub) Close()

func (*Pubsub) Publish

func (ps *Pubsub) Publish(topic string, msg interface{})

func (*Pubsub) Subscribe

func (ps *Pubsub) Subscribe(topic string) <-chan interface{}

type Wattpilot

type Wattpilot struct {
	Reconnect bool
	// contains filtered or unexported fields
}

func New

func New(host string, password string) *Wattpilot

func (*Wattpilot) Alias

func (w *Wattpilot) Alias() []string

func (*Wattpilot) Connect

func (w *Wattpilot) Connect() (bool, error)

func (*Wattpilot) Disconnect

func (w *Wattpilot) Disconnect()

func (*Wattpilot) GetCurrents

func (w *Wattpilot) GetCurrents() (float64, float64, float64, error)

func (*Wattpilot) GetHost

func (w *Wattpilot) GetHost() string

func (*Wattpilot) GetName

func (w *Wattpilot) GetName() string

func (*Wattpilot) GetNotifications

func (w *Wattpilot) GetNotifications(prop string) <-chan interface{}

func (*Wattpilot) GetPower

func (w *Wattpilot) GetPower() (float64, error)

func (*Wattpilot) GetProperty

func (w *Wattpilot) GetProperty(name string) (interface{}, error)

func (*Wattpilot) GetRFID

func (w *Wattpilot) GetRFID() (string, error)

func (*Wattpilot) GetSerial

func (w *Wattpilot) GetSerial() string

func (*Wattpilot) GetVoltages

func (w *Wattpilot) GetVoltages() (float64, float64, float64, error)

func (*Wattpilot) IsInitialized

func (w *Wattpilot) IsInitialized() bool

func (*Wattpilot) LookupAlias

func (w *Wattpilot) LookupAlias(name string) string

func (*Wattpilot) Properties

func (w *Wattpilot) Properties() []string

func (*Wattpilot) SetCurrent

func (w *Wattpilot) SetCurrent(current float64) error

func (*Wattpilot) SetProperty

func (w *Wattpilot) SetProperty(name string, value interface{}) error

func (*Wattpilot) StatusInfo

func (w *Wattpilot) StatusInfo()