sdm630

package module

Go to main page

Versions in this module

v0

v0.7.0

Oct 5, 2018

Changes in this version

+ func GetIecDescription(key string) string

+ func NewRTUClient(rtuDevice string, comset int, verbose bool) *modbus.RTUClientHandler

type MeasurementCache

+ func (mc *MeasurementCache) GetCurrent(deviceId byte) (*Readings, error)

+ func (mc *MeasurementCache) Purge(deviceId byte) error

+ type MeasurementCacheItem struct

type MeterReadings

+ Current Readings

+ Historic ReadingSlice

type MeterScheduler

+ func (q *MeterScheduler) SetCache(mc *MeasurementCache)

+ type MockClient struct

+ func NewMockClient(errorRate int32) *MockClient

+ func (c *MockClient) MaskWriteRegister(address, andMask, orMask uint16) (results []byte, err error)

+ func (c *MockClient) ReadCoils(address, quantity uint16) (results []byte, err error)

+ func (c *MockClient) ReadDiscreteInputs(address, quantity uint16) (results []byte, err error)

+ func (c *MockClient) ReadFIFOQueue(address uint16) (results []byte, err error)

+ func (c *MockClient) ReadHoldingRegisters(address, quantity uint16) (results []byte, err error)

+ func (c *MockClient) ReadInputRegisters(address, quantity uint16) (results []byte, err error)

+ func (c *MockClient) ReadWriteMultipleRegisters(readAddress, readQuantity, writeAddress, writeQuantity uint16, value []byte) (results []byte, err error)

+ func (c *MockClient) WriteMultipleCoils(address, quantity uint16, value []byte) (results []byte, err error)

+ func (c *MockClient) WriteMultipleRegisters(address, quantity uint16, value []byte) (results []byte, err error)

+ func (c *MockClient) WriteSingleCoil(address, value uint16) (results []byte, err error)

+ func (c *MockClient) WriteSingleRegister(address, value uint16) (results []byte, err error)

type ModbusStatus

+ Errors uint64

+ ErrorsPerMinute float64

+ Requests uint64

+ RequestsPerMinute float64

type QuerySnip

+ func NewQuerySnip(deviceId uint8, operation Operation) QuerySnip

type ReadingSlice

+ func (r *ReadingSlice) Average() (*Readings, error)

type Readings

+ DeviceId uint8

type Status

+ func (s *Status) IncreaseReconnectCounter()

+ func (s *Status) IncreaseRequestCounter()

+ func (s *Status) MarshalJSON() ([]byte, error)

v0.6.0

Jul 26, 2018

Changes in this version

+ const CONTROLSNIP_ERROR

+ const CONTROLSNIP_OK

+ const METERSTATE_AVAILABLE

+ const METERSTATE_UNAVAILABLE

+ const METERTYPE_DZG

+ const METERTYPE_JANITZA

+ const METERTYPE_SDM

+ const MaxRetryCount

+ const ModbusComset19200_8E1

+ const ModbusComset19200_8N1

+ const ModbusComset2400_8E1

+ const ModbusComset2400_8N1

+ const ModbusComset9600_8E1

+ const ModbusComset9600_8N1

+ const OpCodeDZGL1Current

+ const OpCodeDZGL1Export

+ const OpCodeDZGL1Import

+ const OpCodeDZGL1Voltage

+ const OpCodeDZGL2Current

+ const OpCodeDZGL2Export

+ const OpCodeDZGL2Import

+ const OpCodeDZGL2Voltage

+ const OpCodeDZGL3Current

+ const OpCodeDZGL3Export

+ const OpCodeDZGL3Import

+ const OpCodeDZGL3Voltage

+ const OpCodeDZGTotalExport

+ const OpCodeDZGTotalExportPower

+ const OpCodeDZGTotalImport

+ const OpCodeDZGTotalImportPower

+ const OpCodeJanitzaL1Cosphi

+ const OpCodeJanitzaL1Current

+ const OpCodeJanitzaL1Export

+ const OpCodeJanitzaL1Import

+ const OpCodeJanitzaL1Power

+ const OpCodeJanitzaL1Voltage

+ const OpCodeJanitzaL2Cosphi

+ const OpCodeJanitzaL2Current

+ const OpCodeJanitzaL2Export

+ const OpCodeJanitzaL2Import

+ const OpCodeJanitzaL2Power

+ const OpCodeJanitzaL2Voltage

+ const OpCodeJanitzaL3Cosphi

+ const OpCodeJanitzaL3Current

+ const OpCodeJanitzaL3Export

+ const OpCodeJanitzaL3Import

+ const OpCodeJanitzaL3Power

+ const OpCodeJanitzaL3Voltage

+ const OpCodeJanitzaTotalExport

+ const OpCodeJanitzaTotalImport

+ const OpCodeSDMAvgTHDVoltageNeutral

+ const OpCodeSDMFrequency

+ const OpCodeSDML1Cosphi

+ const OpCodeSDML1Current

+ const OpCodeSDML1Export

+ const OpCodeSDML1Import

+ const OpCodeSDML1Power

+ const OpCodeSDML1THDVoltageNeutral

+ const OpCodeSDML1Voltage

+ const OpCodeSDML2Cosphi

+ const OpCodeSDML2Current

+ const OpCodeSDML2Export

+ const OpCodeSDML2Import

+ const OpCodeSDML2Power

+ const OpCodeSDML2THDVoltageNeutral

+ const OpCodeSDML2Voltage

+ const OpCodeSDML3Cosphi

+ const OpCodeSDML3Current

+ const OpCodeSDML3Export

+ const OpCodeSDML3Import

+ const OpCodeSDML3Power

+ const OpCodeSDML3THDVoltageNeutral

+ const OpCodeSDML3Voltage

+ const OpCodeSDMTotalExport

+ const OpCodeSDMTotalImport

+ const RELEASEVERSION

+ const ReadHoldingReg

+ const ReadInputReg

+ const SECONDS_BETWEEN_STATUSUPDATE

+ var UniqueIdFormat string = "Instrument%d"

+ func F2fp(x float64) *float64

+ func Fp2f(x *float64) float64

+ func MkIndexHandler(hc *MeasurementCache) func(http.ResponseWriter, *http.Request)

+ func MkLastAllValuesHandler(hc *MeasurementCache) func(http.ResponseWriter, *http.Request)

+ func MkLastMinuteAvgAllHandler(hc *MeasurementCache) func(http.ResponseWriter, *http.Request)

+ func MkLastMinuteAvgSingleHandler(hc *MeasurementCache) func(http.ResponseWriter, *http.Request)

+ func MkLastSingleValuesHandler(hc *MeasurementCache) func(http.ResponseWriter, *http.Request)

+ func MkSocketHandler(hub *SocketHub) func(http.ResponseWriter, *http.Request)

+ func MkStatusHandler(s *Status) func(http.ResponseWriter, *http.Request)

+ func Run_httpd(mc *MeasurementCache, firehose *Firehose, hub *SocketHub, s *Status, ...)

+ func ServeWebsocket(hub *SocketHub, w http.ResponseWriter, r *http.Request)

+ func SetupScheduler(meters map[uint8]*Meter, qe *ModbusEngine) (*MeterScheduler, QuerySnipChannel)

+ type ByteSlice []byte

+ func (s ByteSlice) Len() int

+ func (s ByteSlice) Less(i, j int) bool

+ func (s ByteSlice) Swap(i, j int)

+ type Client struct

+ type ControlSnip struct

+ DeviceId uint8

+ Message string

+ Type ControlSnipType

+ type ControlSnipChannel chan ControlSnip

+ type ControlSnipType uint8

+ type DZGRoundRobinScheduler struct

+ func NewDZGRoundRobinScheduler() *DZGRoundRobinScheduler

+ func (s *DZGRoundRobinScheduler) GetProbeSnip(devid uint8) (retval QuerySnip)

+ func (s *DZGRoundRobinScheduler) Produce(devid uint8) (retval []QuerySnip)

+ type Firehose struct

+ func NewFirehose(inChannel QuerySnipChannel, status *Status, verbose bool) *Firehose

+ func (f *Firehose) GetHandler() func(w http.ResponseWriter, r *http.Request)

+ func (f *Firehose) Run()

+ type JanitzaRoundRobinScheduler struct

+ func NewJanitzaRoundRobinScheduler() *JanitzaRoundRobinScheduler

+ func (s *JanitzaRoundRobinScheduler) GetProbeSnip(devid uint8) (retval QuerySnip)

+ func (s *JanitzaRoundRobinScheduler) Produce(devid uint8) (retval []QuerySnip)

+ type MeasurementCache struct

+ func NewMeasurementCache(meters map[uint8]*Meter, ds QuerySnipChannel, secondsToStore time.Duration, ...) *MeasurementCache

+ func (mc *MeasurementCache) Consume()

+ func (mc *MeasurementCache) GetLast(id byte) (*Readings, error)

+ func (mc *MeasurementCache) GetMinuteAvg(id byte) (*Readings, error)

+ func (mc *MeasurementCache) GetSortedIDs() []byte

+ type MemoryStatus struct

+ Alloc uint64

+ HeapAlloc uint64

+ func CurrentMemoryStatus() MemoryStatus

+ type Meter struct

+ DeviceId uint8

+ MeterReadings *MeterReadings

+ Scheduler Scheduler

+ Type MeterType

+ func NewMeter(typeid MeterType, devid uint8, scheduler Scheduler, ...) *Meter

+ func (m *Meter) AddSnip(snip QuerySnip)

+ func (m *Meter) GetMeterType() MeterType

+ func (m *Meter) GetReadableState() string

+ func (m *Meter) GetState() MeterState

+ func (m *Meter) UpdateState(newstate MeterState)

+ type MeterReadings struct

+ Lastminutereadings ReadingSlice

+ Lastreading Readings

+ func NewMeterReadings(devid uint8, secondsToStore time.Duration) (retval *MeterReadings)

+ func (mr *MeterReadings) AddSnip(snip QuerySnip)

+ func (mr *MeterReadings) Purge(devid uint8)

+ type MeterScheduler struct

+ func NewMeterScheduler(out QuerySnipChannel, control ControlSnipChannel, devices map[uint8]*Meter) *MeterScheduler

+ func (q *MeterScheduler) Run()

+ type MeterState uint8

+ type MeterStatus struct

+ Id uint8

+ Status string

+ Type MeterType

+ type MeterType string

+ type ModbusEngine struct

+ func NewModbusEngine(rtuDevice string, comset int, verbose bool, status *Status) *ModbusEngine

+ func (q *ModbusEngine) Scan()

+ func (q *ModbusEngine) Transform(inputStream QuerySnipChannel, controlStream ControlSnipChannel, ...)

+ type ModbusStatus struct

+ ModbusErrorRatePerMinute float64

+ ModbusRequestRatePerMinute float64

+ TotalModbusErrors uint64

+ TotalModbusRequests uint64

+ type MqttClient struct

+ func NewMqttClient(in QuerySnipChannel, mqttBroker string, mqttTopic string, mqttUser string, ...) *MqttClient

+ func (mqttClient *MqttClient) Run()

+ type QuerySnip struct

+ Description string

+ DeviceId uint8

+ FuncCode uint8

+ IEC61850 string

+ OpCode uint16

+ ReadTimestamp time.Time

+ Transform RTUTransform

+ Value float64

+ func (q *QuerySnip) MarshalJSON() ([]byte, error)

+ func (q QuerySnip) String() string

+ type QuerySnipBroadcaster struct

+ func NewQuerySnipBroadcaster(in QuerySnipChannel) *QuerySnipBroadcaster

+ func (b *QuerySnipBroadcaster) Attach() QuerySnipChannel

+ func (b *QuerySnipBroadcaster) Run()

+ type QuerySnipChannel chan QuerySnip

+ type RTUTransform func([]byte) float64

+ func MkRTUScaledIntToFloat64(scalar float64) RTUTransform

+ type ReadingChannel chan Readings

+ type ReadingSlice []Readings

+ func (r ReadingSlice) JSON(w io.Writer) error

+ func (r ReadingSlice) NotOlderThan(ts time.Time) (retval ReadingSlice)

+ type Readings struct

+ Cosphi ThreePhaseReadings

+ Current ThreePhaseReadings

+ Export ThreePhaseReadings

+ Frequency *float64

+ Import ThreePhaseReadings

+ ModbusDeviceId uint8

+ Power ThreePhaseReadings

+ THD THDInfo

+ Timestamp time.Time

+ TotalExport *float64

+ TotalImport *float64

+ UniqueId string

+ Unix int64

+ Voltage ThreePhaseReadings

+ func (r *Readings) IsOlderThan(ts time.Time) (retval bool)

+ func (r *Readings) JSON(w io.Writer) error

+ func (r *Readings) MergeSnip(q QuerySnip)

+ func (r *Readings) String() string

+ type SDMRoundRobinScheduler struct

+ func NewSDMRoundRobinScheduler() *SDMRoundRobinScheduler

+ func (s *SDMRoundRobinScheduler) GetProbeSnip(devid uint8) (retval QuerySnip)

+ func (s *SDMRoundRobinScheduler) Produce(devid uint8) (retval []QuerySnip)

+ type Scheduler interface

+ GetProbeSnip func(devid uint8) QuerySnip

+ Produce func(devid uint8) []QuerySnip

+ type SocketHub struct

+ func NewSocketHub(inChannel QuerySnipChannel, status *Status) *SocketHub

+ func (h *SocketHub) Broadcast(message []byte)

+ func (h *SocketHub) Run()

+ type Status struct

+ ConfiguredMeters []MeterStatus

+ Goroutines int

+ Memory MemoryStatus

+ Modbus ModbusStatus

+ Starttime time.Time

+ UptimeSeconds float64

+ func NewStatus(metermap map[uint8]*Meter) *Status

+ func (s *Status) IncreaseModbusReconnectCounter()

+ func (s *Status) IncreaseModbusRequestCounter()

+ func (s *Status) Update()

+ func (s *Status) UpdateAndJSON(w io.Writer) error

+ type THDInfo struct

+ AvgVoltageNeutral *float64

+ VoltageNeutral ThreePhaseReadings

+ type ThreePhaseReadings struct

+ L1 *float64

+ L2 *float64

+ L3 *float64

v0.5.1

Aug 17, 2017

v0.5.0

Jul 28, 2017

v0.4.0

Jun 21, 2017

v0.3.1

Mar 27, 2017

v0.3.0

Feb 6, 2017

v0.2.0

Jan 25, 2017

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL