wattpilot

README

DEPRECATED Because of the poor implementation of the Wifi stack on the Fronius Wattpilot it is not possible to implement this library reliable.

The library is still available for reference.

go-wattpilot

Wattpilot API for go used primarly on evcc API Implementation is inspired from https://github.com/joscha82/wattpilot

Shell

./shell contains a shell to interact with the wattpilot to test out values

Documentation

Index

• Constants
• Variables
• func Keys[K comparable, V any](m map[K]V) []K
• type CallHook
  • func (hook *CallHook) Fire(entry *log.Entry) error
  • func (hook *CallHook) Levels() []log.Level
• type PostFunction
• type Pubsub
  • func NewPubsub() *Pubsub
  • func (ps *Pubsub) Close()
  • func (ps *Pubsub) IsEmpty() bool
  • 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() error
  • func (w *Wattpilot) Disconnect()
  • func (w *Wattpilot) GetCarIdentifier() (string, error)
  • 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) ParseLogLevel(level string) error
  • func (w *Wattpilot) Properties() []string
  • func (w *Wattpilot) RequestStatusUpdate() error
  • func (w *Wattpilot) SetCurrent(current float64) error
  • func (w *Wattpilot) SetLogLevel(level logrus.Level)
  • func (w *Wattpilot) SetLogger(delegate func(string, string))
  • func (w *Wattpilot) SetProperty(name string, value interface{}) error
  • func (w *Wattpilot) StatusInfo()

Constants

const (
	ContextTimeout   = 30 // seconds
	ReconnectTimeout = 5  // seconds
)

Variables

var PostProcess = map[string]struct {
	key string
	f   PostFunction
}{
	"voltage1": {"nrg", voltage1Process},
	"voltage2": {"nrg", voltage2Process},
	"voltage3": {"nrg", voltage3Process},
	"voltageN": {"nrg", voltageNProcess},
	"amps1":    {"nrg", amps1Process},
	"amps2":    {"nrg", amps2Process},
	"amps3":    {"nrg", amps3Process},
	"power1":   {"nrg", power1Process},
	"power2":   {"nrg", power2Process},
	"power3":   {"nrg", power3Process},
	"powerM":   {"nrg", powerNProcess},
	"power":    {"nrg", powerProcess},
}

Functions

func Keys

func Keys[K comparable, V any](m map[K]V) []K

Types

type CallHook

type CallHook struct {
	Call      func(string, string)
	LogLevels []log.Level
}

func (*CallHook) Fire

func (hook *CallHook) Fire(entry *log.Entry) error

func (*CallHook) Levels

func (hook *CallHook) Levels() []log.Level

Levels define on which log levels this hook would trigger

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) IsEmpty

func (ps *Pubsub) IsEmpty() bool

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 {
	// 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() error

func (*Wattpilot) Disconnect

func (w *Wattpilot) Disconnect()

func (*Wattpilot) GetCarIdentifier

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

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) ParseLogLevel

func (w *Wattpilot) ParseLogLevel(level string) error

func (*Wattpilot) Properties

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

func (*Wattpilot) RequestStatusUpdate

func (w *Wattpilot) RequestStatusUpdate() error

func (*Wattpilot) SetCurrent

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

func (*Wattpilot) SetLogLevel

func (w *Wattpilot) SetLogLevel(level logrus.Level)

func (*Wattpilot) SetLogger

func (w *Wattpilot) SetLogger(delegate func(string, string))

func (*Wattpilot) SetProperty

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

func (*Wattpilot) StatusInfo

func (w *Wattpilot) StatusInfo()