wattpilot

README

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 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 log.Level)
  • func (w *Wattpilot) SetProperty(name string, value interface{}) error
  • func (w *Wattpilot) StatusInfo()

Constants

const (
	CONTEXT_TIMEOUT   = 30 // seconds
	RECONNECT_TIMEOUT = 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 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 log.Level)

func (*Wattpilot) SetProperty

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

func (*Wattpilot) StatusInfo

func (w *Wattpilot) StatusInfo()