data

package
v0.23.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 19, 2026 License: Apache-2.0 Imports: 21 Imported by: 10

Documentation

Overview

Package data contains common data structures that are used throughout the project.

Encode, Decode, MergePoints, and MergeEdgePoints can be used to convert your custom types to/from the NodeEdge type that SIOT uses for its wire and storage format.

Index

Constants

View Source 
const (
	CmdUpdateApp = "updateApp"
	CmdPoll      = "poll"
	CmdFieldMode = "fieldMode"
)

define valid commands

View Source 
const (
	// general point types
	PointTypeChannel      = "channel"
	PointTypeDevice       = "device"
	PointTypeDescription  = "description"
	PointTypeFilePath     = "filePath"
	PointTypeNodeType     = "nodeType"
	PointTypeTombstone    = "tombstone"
	PointTypeScale        = "scale"
	PointTypeOffset       = "offset"
	PointTypeUnits        = "units"
	PointTypeValue        = "value"
	PointTypeValueSet     = "valueSet"
	PointTypeIndex        = "index"
	PointTypeTagPointType = "tagPointType"
	PointTypeTag          = "tag"
	// PointTypeID typically refers to Node ID
	PointTypeID                 = "id"
	PointTypeDebug              = "debug"
	PointTypeInitialized        = "initialized"
	PointTypePollPeriod         = "pollPeriod"
	PointTypeError              = "error"
	PointTypeErrorCount         = "errorCount"
	PointTypeErrorCountReset    = "errorCountReset"
	PointTypeErrorCountEOF      = "errorCountEOF"
	PointTypeErrorCountEOFReset = "errorCountEOFReset"
	PointTypeErrorCountCRC      = "errorCountCRC"
	PointTypeErrorCountCRCReset = "errorCountCRCReset"
	PointTypeErrorCountHR       = "errorCountHR"
	PointTypeErrorCountResetHR  = "errorCountResetHR"
	PointTypeSyncCount          = "syncCount"
	PointTypeSyncCountReset     = "syncCountReset"
	PointTypeReadOnly           = "readOnly"
	PointTypeURI                = "uri"
	PointTypeDisabled           = "disabled"
	PointTypeControlled         = "controlled"

	PointTypePeriod = "period"

	// An device node describes an phyical device -- it may be the
	// cloud server, gateway, etc
	NodeTypeDevice         = "device"
	PointTypeCmdPending    = "cmdPending"
	PointTypeSwUpdateState = "swUpdateState"
	PointTypeStartApp      = "startApp"
	PointTypeStartSystem   = "startSystem"
	PointTypeUpdateOS      = "updateOS"
	PointTypeUpdateApp     = "updateApp"
	PointTypeSysState      = "sysState"

	PointValueSysStateUnknown  = "unknown"
	PointValueSysStatePowerOff = "powerOff"
	PointValueSysStateOffline  = "offline"
	PointValueSysStateOnline   = "online"

	PointTypeSwUpdateRunning      = "swUpdateRunning"
	PointTypeSwUpdateError        = "swUpdateError"
	PointTypeSwUpdatePercComplete = "swUpdatePercComplete"
	PointTypeVersionOS            = "versionOS"
	PointTypeVersionApp           = "versionApp"
	PointTypeVersionHW            = "versionHW"

	// user node describes a system user and is used to control
	// access to the system (typically through web UI)
	NodeTypeUser       = "user"
	PointTypeFirstName = "firstName"
	PointTypeLastName  = "lastName"
	PointTypePhone     = "phone"
	PointTypeEmail     = "email"
	PointTypePass      = "pass"

	// user edge points
	PointTypeRole       = "role"
	PointValueRoleAdmin = "admin"
	PointValueRoleUser  = "user"

	// User Authentication
	NodeTypeJWT    = "jwt"
	PointTypeToken = "token"

	// modbus nodes
	// in modbus land, terminology is a big backwards, client is master,
	// and server is slave.
	NodeTypeModbus = "modbus"

	PointTypeClientServer = "clientServer"
	PointValueClient      = "client"
	PointValueServer      = "server"

	PointTypePort   = "port"
	PointTypeBaud   = "baud"
	PointTypeHRDest = "hrDest"

	PointTypeProtocol = "protocol"
	PointValueRTU     = "RTU"
	PointValueTCP     = "TCP"
	PointTypeTimeout  = "timeout"

	NodeTypeModbusIO = "modbusIo"

	// FIXME, should we change modbusIoType to ioType?
	PointTypeModbusIOType           = "modbusIoType"
	PointValueModbusDiscreteInput   = "modbusDiscreteInput"
	PointValueModbusCoil            = "modbusCoil"
	PointValueModbusInputRegister   = "modbusInputRegister"
	PointValueModbusHoldingRegister = "modbusHoldingRegister"

	PointTypeDataFormat = "dataFormat"
	PointValueUINT16    = "uint16"
	PointValueINT16     = "int16"
	PointValueUINT32    = "uint32"
	PointValueINT32     = "int32"
	PointValueFLOAT32   = "float32"

	NodeTypeOneWire   = "oneWire"
	NodeTypeOneWireIO = "oneWireIO"

	// A group node is used to group users and devices
	// or generally to add structure to the node graph.
	NodeTypeGroup = "group"

	NodeTypeDb = "db"

	PointTypeBucket = "bucket"
	PointTypeOrg    = "org"

	// PointTypeExpandKeyLabels writes each label in a point key that was
	// written as a label set -- name=value pairs joined by commas, which is
	// what a Prometheus scrape produces -- as its own database label, so a
	// scraped series queries the way the Prometheus series it came from did.
	// The parse is strict, so keys from every other client are left alone.
	PointTypeExpandKeyLabels = "expandKeyLabels"

	// PointTypeDbType selects which time series database the db client
	// writes to. An empty value is treated as InfluxDB for backwards
	// compatibility.
	PointTypeDbType           = "dbType"
	PointValueInfluxDb        = "influxdb"
	PointValueVictoriaMetrics = "victoriaMetrics"

	// a rule node describes a rule that may run on the system
	NodeTypeRule = "rule"

	PointTypeActive = "active"

	NodeTypeCondition = "condition"

	PointTypeConditionType = "conditionType"
	PointValuePointValue   = "pointValue"
	PointValueSchedule     = "schedule"

	PointTypeNodeID = "nodeID"

	PointTypeTrigger = "trigger"

	PointTypeStart   = "start"
	PointTypeEnd     = "end"
	PointTypeWeekday = "weekday"
	PointTypeDate    = "date"

	PointTypePointID    = "pointID"
	PointTypePointKey   = "pointKey"
	PointTypePointType  = "pointType"
	PointTypePointIndex = "pointIndex"
	PointTypeValueType  = "valueType"
	PointValueNumber    = "number"
	PointValueOnOff     = "onOff"
	PointValueText      = "text"

	PointTypeOperator     = "operator"
	PointValueGreaterThan = ">"
	PointValueLessThan    = "<"
	PointValueEqual       = "="
	PointValueNotEqual    = "!="
	PointValueOn          = "on"
	PointValueOff         = "off"
	PointValueContains    = "contains"

	PointTypeValueText = "valueText"

	PointTypeMinActive = "minActive"

	NodeTypeAction         = "action"
	NodeTypeActionInactive = "actionInactive"

	PointTypeAction = "action"

	PointValueNotify    = "notify"
	PointValueSetValue  = "setValue"
	PointValuePlayAudio = "playAudio"

	// Transient points that are used for notifications, etc.
	// These points are not stored in the state of any node,
	// but are recorded in the time series database to record history.
	PointMsgAll  = "msgAll"
	PointMsgUser = "msgUser"

	NodeTypeMsgService = "msgService"

	PointTypeService = "service"

	PointValueTwilio = "twilio"
	PointValueSMTP   = "smtp"

	PointTypeSID       = "sid"
	PointTypeAuthToken = "authToken"
	PointTypeFrom      = "from"

	NodeTypeVariable      = "variable"
	PointTypeVariableType = "variableType"

	NodeTypeSync = "sync"

	PointTypeMetricNatsCycleNodePoint          = "metricNatsCycleNodePoint"
	PointTypeMetricNatsCycleNodeEdgePoint      = "metricNatsCycleNodeEdgePoint"
	PointTypeMetricNatsCycleNode               = "metricNatsCycleNode"
	PointTypeMetricNatsCycleNodeChildren       = "metricNatsCycleNodeChildren"
	PointTypeMetricNatsPendingNodePoint        = "metricNatsPendingNodePoint"
	PointTypeMetricNatsPendingNodeEdgePoint    = "metricNatsPendingNodeEdgePoint"
	PointTypeMetricNatsThroughputNodePoint     = "metricNatsThroughputNodePoint"
	PointTypeMetricNatsThroughputNodeEdgePoint = "metricNatsThroughputNodeEdgePoint"

	// serial MCU clients
	NodeTypeSerialDev = "serialDev"
	// PointTypeProtocol on a serialDev node selects the wire protocol.
	// An empty value means PointValueProtocolBinary so existing nodes
	// keep working with no migration.
	PointValueProtocolBinary = "binary" // COBS framed binary packets
	PointValueProtocolShell  = "shell"  // Zephyr console shell, ASCII
	// PointTypeLogConsole mirrors the MCU console to the SIOT server log.
	// Shell protocol only.
	PointTypeLogConsole       = "logConsole"
	PointTypeRx               = "rx"
	PointTypeTx               = "tx"
	PointTypeHrRx             = "hrRx"
	PointTypeRxReset          = "rxReset"
	PointTypeTxReset          = "txReset"
	PointTypeHrRxReset        = "hrRxReset"
	PointTypeLog              = "log"
	PointTypeUptime           = "uptime"
	PointTypeMaxMessageLength = "maxMessageLength"
	PointTypeSyncParent       = "syncParent"

	// CAN bus clients
	NodeTypeCanBus               = "canBus"
	PointTypeBitRate             = "bitRate"
	PointTypeMsgsInDb            = "msgsInDb"
	PointTypeSignalsInDb         = "signalsInDb"
	PointTypeMsgsRecvdDb         = "msgsRecvdDb"
	PointTypeMsgsRecvdDbReset    = "msgsRecvdDbReset"
	PointTypeMsgsRecvdOther      = "msgsRecvdOther"
	PointTypeMsgsRecvdOtherReset = "msgsRecvdOtherReset"

	// Browser
	PointTypeURL              = "url"
	PointTypeRotate           = "rotate"
	PointTypeKeyboardScale    = "keyboardscale"
	PointTypeFullscreen       = "fullscreen"
	PointTypeDefaultDialogs   = "defaultdialogs"
	PointTypeDialogColor      = "dialogcolor"
	PointTypeTouchQuirk       = "touchquirk"
	PointTypeRetryInterval    = "retryinterval"
	PointTypeExceptionURL     = "exceptionurl"
	PointTypeIgnoreCertErr    = "ignorecerterr"
	PointTypeDisableSandbox   = "disablesandbox"
	PointTypeDebugPort        = "debugport"
	PointTypeScreenResolution = "screenresolution"
	PointTypeDisplayCard      = "displaycard"

	NodeTypeSignalGenerator = "signalGenerator"

	PointTypeSignalType   = "signalType"
	PointTypeMinValue     = "minValue"
	PointTypeMaxValue     = "maxValue"
	PointTypeInitialValue = "initialValue"
	PointTypeRoundTo      = "roundTo"
	PointTypeSampleRate   = "sampleRate"
	PointTypeDestination  = "destination"
	PointTypeBatchPeriod  = "batchPeriod"
	PointTypeFrequency    = "frequency"
	PointTypeMinIncrement = "minIncrement"
	PointTypeMaxIncrement = "maxIncrement"

	NodeTypeFile      = "file"
	PointTypeName     = "name"
	PointTypeData     = "data"
	PointTypeBinary   = "binary"
	PointTypeSize     = "size"
	PointTypeHash     = "hash"
	PointTypeDownload = "download"
	PointTypeProgress = "progress"

	// PointTypeCreated is when a node came into existence, written once and
	// never rewritten, which is what orders provisioning files uploaded
	// through the UI.
	PointTypeCreated = "created"

	// provisioning reads files from a directory and from file nodes under the
	// provisioning node, applying each one the way siot import does
	NodeTypeProvisioning     = "provisioning"
	NodeTypeProvisioningFile = "provisioningFile"

	// PointTypeProvisionHash is the SHA-256 of the contents provisioning last
	// applied from a source. It is distinct from PointTypeHash, which the file
	// client maintains to describe the contents themselves.
	PointTypeProvisionHash = "provisionHash"

	PointTypeRate   = "rate"
	PointTypeRateHR = "rateHR"
	NodeTypeMetrics = "metrics"

	PointTypeType          = "type"
	PointValueApp          = "app"
	PointValueProcess      = "process"
	PointValueAllProcesses = "allProcesses"
	PointValueSystem       = "system"
	PointValuePrometheus   = "prometheus"

	// PointTypeCounterDelta enables publishing a per-period delta alongside
	// the raw value of each counter a Prometheus endpoint reports. A counter
	// is monotonic, so the raw value answers "how many since start" while the
	// delta answers "how many this period", which is the reading a rule can
	// act on.
	PointTypeCounterDelta = "counterDelta"

	// PointTypeMaxSeries bounds how many samples a single scrape publishes,
	// so an endpoint with more series than expected cannot grow one node out
	// of proportion to the rest of the tree.
	PointTypeMaxSeries = "maxSeries"

	// CounterDeltaSuffix is appended to a counter's metric name to form the
	// point type its per-period delta is published under. Prometheus reserves
	// _total, _sum, _count, and _bucket, so this cannot be mistaken for one
	// of its conventions.
	CounterDeltaSuffix = "_delta"

	PointTypeCount = "count"

	// Sys Metrics
	PointTypeMetricSysLoad            = "metricSysLoad"
	PointTypeMetricSysCPUPercent      = "metricSysCPUPercent"
	PointTypeMetricSysMem             = "metricSysMem"
	PointTypeMetricSysMemUsedPercent  = "metricSysMemUsedPercent"
	PointTypeMetricSysDiskUsedPercent = "metricSysDiskUsedPercent"
	PointTypeMetricSysNetBytesRecv    = "metricSysNetBytesRecv"
	PointTypeMetricSysNetBytesSent    = "metricSysNetBytesSent"
	PointTypeMetricSysUptime          = "metricSysUptime"
	// current clock of a CPU in MHz, keyed by cpu0, cpu1, and so on
	PointTypeMetricSysCPUFreq = "metricSysCPUFreq"
	// fan tachometer reading in RPM
	PointTypeMetricSysFanSpeed = "metricSysFanSpeed"
	// fan drive level, 0-255, as reported by the hwmon pwm interface
	PointTypeMetricSysFanPWM = "metricSysFanPWM"
	// current state of a thermal cooling device. Anything above zero means
	// the thermal governor is limiting the system, so a rising cpufreq or
	// devfreq state is the system giving up performance to stay cool.
	PointTypeMetricSysCoolingState = "metricSysCoolingState"
	// highest state a cooling device supports, which gives the scale the
	// current state is measured against
	PointTypeMetricSysCoolingStateMax = "metricSysCoolingStateMax"

	// App Metrics
	PointTypeMetricAppAlloc        = "metricAppAlloc"
	PointTypeMetricAppNumGoroutine = "metricAppNumGoroutine"

	// process metrics
	PointTypeMetricProcCPUPercent = "metricProcCPUPercent"
	PointTypeMetricProcMemPercent = "metricProcMemPercent"
	PointTypeMetricProcMemRSS     = "metricProcMemRSS"

	PointTypeHost                = "host"
	PointTypeHostBootTime        = "hostBootTime"
	PointKeyHostname             = "hostname"
	PointKeyOS                   = "os"
	PointKeyPlatform             = "platform"
	PointKeyPlatformFamily       = "platformFamily"
	PointKeyPlatformVersion      = "platformVersion"
	PointKeyKernelVersion        = "kernelVersion"
	PointKeyKernelArch           = "kernelArch"
	PointKeyVirtualizationSystem = "virtualizationSystem"
	PointKeyVirtualizationRole   = "virtualizationRole"

	PointKeyUsedPercent = "usedPercent"
	PointKeyTotal       = "total"
	PointKeyAvailable   = "available"
	PointKeyUsed        = "used"
	PointKeyFree        = "free"

	NodeTypeShelly   = "shelly"
	NodeTypeShellyIo = "shellyIo"

	PointTypeSwitch      = "switch"
	PointTypeSwitchSet   = "switchSet"
	PointTypeInput       = "input"
	PointTypeLight       = "light"
	PointTypeLightSet    = "lightSet"
	PointTypeDeviceID    = "deviceID"
	PointTypeIP          = "ip"
	PointTypeVoltage     = "voltage"
	PointTypeCurrent     = "current"
	PointTypePower       = "power"
	PointTypeTemperature = "temp"
	PointTypeBrightness  = "brightness"
	PointTypeWhite       = "white"
	PointTypeLightTemp   = "lightTemp"
	PointTypeTransition  = "transition"
	PointTypeOffline     = "offline"

	PointValueShellyTypeBulbDuo = "BulbDuo"
	PointValueShellyTypeRGBW2   = "rgbw2"
	PointValueShellyType1PM     = "1pm"
	PointValueShellyTypePlugUS  = "PlugUS"
	PointValueShellyTypePlugUK  = "PlugUK"
	PointValueShellyTypePlugIT  = "PlugIT"
	PointValueShellyTypePlugS   = "PlugS"
	PointValueShellyTypeI4      = "PlusI4"
	PointValueShellyTypePlus1   = "Plus1"
	PointValueShellyTypePlus1PM = "Plus1PM"
	PointValueShellyTypePlus2PM = "Plus2PM"

	PointTypeTimeSync  = "timeSync"
	PointTypeConnected = "connected"

	NodeTypeNetworkManager       = "networkManager"
	NodeTypeNetworkManagerDevice = "networkManagerDevice"
	NodeTypeNetworkManagerConn   = "networkManagerConn"

	NodeTypeNTP             = "ntp"
	PointTypeServer         = "server"
	PointTypeFallbackServer = "fallbackServer"

	NodeTypeUpdate           = "update"
	PointTypeOSUpdate        = "osUpdate"
	PointTypeAppUpdate       = "appUpdate"
	PointTypePrefix          = "prefix"
	PointTypeDownloadOS      = "downloadOS"
	PointTypeOSDownloaded    = "osDownloaded"
	PointTypeDiscardDownload = "discardDownload"
	PointTypeReboot          = "reboot"
	PointTypeAutoReboot      = "autoReboot"
	PointTypeAutoDownload    = "autoDownload"
	PointTypeDirectory       = "directory"
	PointTypeRefresh         = "refresh"

	// points for networking config
	PointTypeStaticIP = "staticIP"
	PointTypeAddress  = "address"
	PointTypeNetmask  = "netmask"
	PointTypeGateway  = "gateway"

	// GPS client
	NodeTypeGPS = "gps"

	PointTypeGPSSource        = "gpsSource"
	PointValueGPSSourceSerial = "serial"
	PointValueGPSSourceGpsd   = "gpsd"
	PointValueGPSSourceSim    = "sim"

	// GPS output points
	PointTypeLatitude  = "latitude"  // degrees, +N
	PointTypeLongitude = "longitude" // degrees, +E
	PointTypeAltitude  = "altitude"  // meters above mean sea level
	PointTypeSpeed     = "speed"     // meters/second over ground
	PointTypeHeading   = "heading"   // degrees true, 0-360
	PointTypeNumSat    = "numSat"    // satellites used in fix
	PointTypeHDOP      = "hdop"      // horizontal dilution of precision
	PointTypeGPSTime   = "gpsTime"   // Unix epoch seconds reported by the source

	// Normalized GPS fix dimensionality, following gpsd's TPV mode encoding.
	// Numeric rather than a string enum so it can be stored in metrics-only
	// databases such as Victoria Metrics, which store strings as 0.
	PointTypeFixType  = "fixType"
	PointValueFixNone = 0 // no fix, or fix status unknown
	PointValueFix2D   = 2
	PointValueFix3D   = 3

	// Normalized GPS fix augmentation quality, following the NMEA GGA fix
	// quality encoding, which covers every case the three sources report.
	PointTypeFixQuality           = "fixQuality"
	PointValueFixQualityNone      = 0
	PointValueFixQualityGPS       = 1
	PointValueFixQualityDGPS      = 2
	PointValueFixQualityPPS       = 3
	PointValueFixQualityRTKFixed  = 4
	PointValueFixQualityRTKFloat  = 5
	PointValueFixQualityEstimated = 6
	PointValueFixQualityManual    = 7
	PointValueFixQualitySimulated = 8

	// GPS gpsd source config
	PointTypeGpsdAddress = "gpsdAddress" // host:port, default localhost:2947

	// GPS simulation config
	PointTypeSimLatitude    = "simLatitude"    // starting latitude
	PointTypeSimLongitude   = "simLongitude"   // starting longitude
	PointTypeSimSpeed       = "simSpeed"       // meters/second
	PointTypeSimHeading     = "simHeading"     // starting heading, degrees true
	PointTypeSimHeadingRate = "simHeadingRate" // max heading change, degrees/second
	PointTypeSimReset       = "simReset"       // move the track back to the start
)

define common node and point types that have special meaning in the system.

View Source 
const NodeFileAPIVersion = 1

NodeFileAPIVersion is the format version this build writes and understands.

Variables

View Source 
var ErrDocumentNotFound = errors.New("document not found")

ErrDocumentNotFound is returned in APIs if document is not found

Functions

func BoolToFloat added in v0.0.16 

func BoolToFloat(v bool) float64

BoolToFloat converts bool to float

func Decode added in v0.3.0 

func Decode(input NodeEdgeChildren, outputStruct any) error

Decode converts a Node to custom struct. output can be a struct type that contains node, point, and edgepoint tags as shown below. It is recommended that id and parent node tags always be included. 

   type exType struct {
	ID          string      `node:"id"`
	Parent      string      `node:"parent"`
	Description string      `point:"description"`
	Count       int         `point:"count"`
	Role        string      `edgepoint:"role"`
	Tombstone   bool        `edgepoint:"tombstone"`
	Conditions  []Condition `child:"condition"`
   }

outputStruct can also be a *reflect.Value

Some consideration is needed when using Decode and MergePoints to decode points into Go slices. Slices are never allocated / copied unless they are being expanded. Instead, deleted points are written to the slice as the zero value. However, for a given Decode call, if points are deleted from the end of the slice, Decode will re-slice it to remove those values from the slice. Thus, there is an important consideration for clients: if they wish to rely on slices being truncated when points are deleted, points must be batched in order such that Decode sees the trailing deleted points first. Put another way, Decode does not care about points deleted from prior calls to Decode, so "holes" of zero values may still appear at the end of a slice under certain circumstances. Consider points with integer values [0, 1, 2, 3, 4]. If tombstone is set on point with Key 3 followed by a point tombstone set on point with Key 4, the resulting slice will be [0, 1, 2] if these points are batched together, but if they are sent separately (thus resulting in multiple Decode calls), the resulting slice will be [0, 1, 2, 0].

func DecodeSerialHrPayload added in v0.10.0 

func DecodeSerialHrPayload(payload []byte, callback func(Point)) error

DecodeSerialHrPayload decodes a serial high-rate payload. Payload format.

  • type (off:0, 16 bytes) point type
  • key (off:16, 16 bytes) point key
  • starttime (off:32, uint64) starting time of samples in ns since Unix Epoch
  • sampleperiod (off:40, uint32) time between samples in ns
  • data (off:44) packed 32-bit floating point samples

func FindNodeInStruct added in v0.12.4 

func FindNodeInStruct(outputStruct interface{}, nodeID string, parentID string) reflect.Value

FindNodeInStruct recursively scans the `outputStruct` for a struct with a field having a `node:"id"` tag and whose value matches `nodeID`. If `parentID` is provided, the struct must also have a field with a `node:"parent"` tag whose value matches `parentID`. If such a struct is found, the struct is returned as a reflect.Value; otherwise, an invalid reflect.Value is returned whose IsValid method returns false.

func FloatToBool added in v0.0.16 

func FloatToBool(v float64) bool

FloatToBool converts a float to bool

func MergeEdgePoints added in v0.3.0 

func MergeEdgePoints(id, parent string, points []Point, outputStruct interface{}) error

MergeEdgePoints takes edge points and updates a type that matching edgepoint tags. See Decode for an example type.

func MergePoints added in v0.3.0 

func MergePoints(id string, points []Point, outputStruct interface{}) error

MergePoints takes points and updates fields in a type that have matching point tags. See Decode for an example type. When deleting points from arrays, the point key (index) is ignored and the last entry from the array is removed. Normally, it is recommended to send all points for an array when doing complex modifications to an array.

func SameValue added in v0.22.0 

func SameValue(a, b Point) bool

SameValue reports whether two points say the same thing. Numbers are compared by value and text by string, rather than by their stored bytes, so that an integer 5 and a float 5 are one value and a file does not fight a client that writes its points with PutInt.

func SubjectSafeToken added in v0.23.2 

func SubjectSafeToken(s string) string

SubjectSafeToken replaces every character that is not allowed in a point type or key with an underscore. It is for callers that generate keys from names they do not control, such as sysfs device names or network interface names. Data a device sends is never rewritten -- that is rejected instead, so the sender can be fixed.

func ToCamelCase added in v0.10.0 

func ToCamelCase(s string) string

ToCamelCase naively converts a string to camelCase. This function does not consider common initialisms.

Types

type Auth added in v0.0.5 

type Auth struct {
	Token string `json:"token"`
	Email string `json:"email"`
}

Auth is an authentication response.

type ByEdgeID added in v0.0.30 

type ByEdgeID []*Edge

ByEdgeID implements sort interface for NodeEdge by ID

func (ByEdgeID) Len added in v0.0.30 

func (a ByEdgeID) Len() int

func (ByEdgeID) Less added in v0.0.30 

func (a ByEdgeID) Less(i, j int) bool

func (ByEdgeID) Swap added in v0.0.30 

func (a ByEdgeID) Swap(i, j int)

type ByTypeKey added in v0.14.0 

type ByTypeKey []Point

ByTypeKey can be used to sort points by type then key

func (ByTypeKey) Len added in v0.14.0 

func (b ByTypeKey) Len() int

func (ByTypeKey) Less added in v0.14.0 

func (b ByTypeKey) Less(i, j int) bool

func (ByTypeKey) Swap added in v0.14.0 

func (b ByTypeKey) Swap(i, j int)

type Edge added in v0.0.15 

type Edge struct {
	ID     string `json:"id"`
	Up     string `json:"up"`
	Down   string `json:"down"`
	Points Points `json:"points"`
	Hash   uint32 `json:"hash"`
	Type   string `json:"type"`
}

Edge is used to describe the relationship between two nodes

func (*Edge) IsTombstone added in v0.0.30 

func (e *Edge) IsTombstone() bool

IsTombstone returns true of edge points to a deleted node

func (Edge) String added in v0.0.30 

func (e Edge) String() string

type Event 

type Event struct {
	Time    time.Time
	Type    EventType
	Level   EventLevel
	Message string
}

Event describes something that happened and might be displayed to user in a a sequential log format.

type EventLevel 

type EventLevel int

EventLevel is used to describe the "severity" of the event and can be used to quickly filter the type of events 

const (
	EventLevelFault EventLevel = 3
	EventLevelInfo
	EventLevelDebug
)

define valid events

type EventType 

type EventType int

EventType describes an event. Custom applications that build on top of Simple IoT should custom event types at high number above 10,000 to ensure there is not a collision between type IDs. Note, these enums should never change. 

const (
	EventTypeStartSystem EventType = 10
	EventTypeStartApp
	EventTypeSystemUpdate
	EventTypeAppUpdate
)

define valid events

type GpsPos 

type GpsPos struct {
	Lat    float64 `json:"lat"`
	Long   float64 `json:"long"`
	Fix    string  `json:"fix"`
	NumSat int64   `json:"numSat"`
}

GpsPos describes location and fix information from a GPS

func (*GpsPos) FromGPGGA 

func (p *GpsPos) FromGPGGA(gpgga nmea.GPGGA)

FromGPGGA converts a GPGGA string to a position/fix

type GroupedPoints added in v0.10.0 

type GroupedPoints struct {
	// KeyNotIndex is set to a Point's `Key` field if it *cannot* be parsed as a
	// positive integer
	// Note: If `Key` is empty string (""), it is treated as "0"
	KeyNotIndex string
	// KeyMaxInt is the largest `Point.Key` value in Points
	KeyMaxInt int
	// Points is the list of Points for this group
	Points []Point
}

GroupedPoints are Points grouped by their `Point.Type`. While scanning through the list of points, we also keep track of whether or not the points are keyed with positive integer values (for decoding into arrays)

func (GroupedPoints) SetValue added in v0.10.0 

func (g GroupedPoints) SetValue(v reflect.Value) error

SetValue populates v with the Points in the group

type Message added in v0.0.23 

type Message struct {
	ID             string
	UserID         string
	ParentID       string
	NotificationID string
	Email          string
	Phone          string
	Subject        string
	Message        string
}

Message describes a notification that is sent to a particular user

func PbDecodeMessage added in v0.0.23 

func PbDecodeMessage(data []byte) (Message, error)

PbDecodeMessage converts a protobuf to a message data structure

func (*Message) ToPb added in v0.0.23 

func (m *Message) ToPb() ([]byte, error)

ToPb converts to protobuf data

type MsgService added in v0.0.23 

type MsgService struct {
	ID        string
	Service   string
	SID       string
	AuthToken string
	From      string
}

MsgService is used to represent message services such as Twilio, SMTP, etc

func NodeToMsgService added in v0.0.23 

func NodeToMsgService(node Node) (MsgService, error)

NodeToMsgService converts a node to message service

type Node added in v0.0.12 

type Node struct {
	ID     string `json:"id"`
	Type   string `json:"type"`
	Points Points `json:"points"`
}

Node represents the state of a device. UUID is recommended for ID to prevent collisions is distributed instances.

func (*Node) Desc added in v0.0.12 

func (n *Node) Desc() string

Desc returns Description if set, otherwise ID

func (*Node) GetState added in v0.0.30 

func (n *Node) GetState() (string, bool)

GetState checks state of node and returns true if state was updated. We originally considered offline to be when we did not receive data from a remote device for X minutes. However, with points that could represent a config change as well. Eventually we may want to improve this to look at point types (perhaps Sample).

func (*Node) State added in v0.0.12 

func (n *Node) State() string

State returns the current state of a device

func (Node) String added in v0.0.30 

func (n Node) String() string

func (*Node) ToNodeEdge added in v0.0.15 

func (n *Node) ToNodeEdge(edge Edge) NodeEdge

ToNodeEdge converts to data structure used in API requests

func (*Node) ToUser added in v0.0.15 

func (n *Node) ToUser() User

ToUser converts a node to user struct

type NodeCmd added in v0.0.12 

type NodeCmd struct {
	ID     string `json:"id,omitempty"`
	Cmd    string `json:"cmd"`
	Detail string `json:"detail,omitempty"`
}

NodeCmd represents a command to be sent to a device

type NodeEdge added in v0.0.15 

type NodeEdge struct {
	ID         string `json:"id"`
	Type       string `json:"type"`
	Hash       uint32 `json:"hash" yaml:"-"`
	Parent     string `json:"parent"`
	Points     Points `json:"points,omitempty"`
	EdgePoints Points `json:"edgePoints,omitempty"`
}

NodeEdge combines node and edge data, used for APIs

func Encode added in v0.3.0 

func Encode(in any) (NodeEdge, error)

Encode is used to convert a user struct to a node. in must be a struct type that contains node, point, and edgepoint tags as shown below. It is recommended that id and parent node tags always be included. 

   type exType struct {
	ID          string  `node:"id"`
	Parent      string  `node:"parent"`
	Description string  `point:"description"`
	Count       int     `point:"count"`
	Role        string  `edgepoint:"role"`
	Tombstone   bool    `edgepoint:"tombstone"`
   }

func PbDecodeNode added in v0.0.22 

func PbDecodeNode(data []byte) (NodeEdge, error)

PbDecodeNode converts a protobuf to node data structure

func PbDecodeNodeRequest added in v0.0.30 

func PbDecodeNodeRequest(buf []byte) (NodeEdge, error)

PbDecodeNodeRequest converts a protobuf to node data structure

func PbDecodeNodes added in v0.0.30 

func PbDecodeNodes(data []byte) ([]NodeEdge, error)

PbDecodeNodes decode probuf encoded nodes

func PbDecodeNodesRequest added in v0.0.30 

func PbDecodeNodesRequest(data []byte) ([]NodeEdge, error)

PbDecodeNodesRequest decode probuf encoded nodes

func PbToNode added in v0.0.30 

func PbToNode(pbNode *pb.Node) (NodeEdge, error)

PbToNode converts pb node to node

func RemoveDuplicateNodesID added in v0.0.23 

func RemoveDuplicateNodesID(nodes []NodeEdge) []NodeEdge

RemoveDuplicateNodesID removes duplicate nodes in list with the same ID (can have different parents)

func RemoveDuplicateNodesIDParent added in v0.0.23 

func RemoveDuplicateNodesIDParent(nodes []NodeEdge) []NodeEdge

RemoveDuplicateNodesIDParent removes duplicate nodes in list with the same ID and parent

func (*NodeEdge) AddPoint added in v0.0.44 

func (n *NodeEdge) AddPoint(pIn Point)

AddPoint takes a point for a device and adds/updates its array of points

func (NodeEdge) Desc added in v0.0.30 

func (n NodeEdge) Desc() string

Desc returns Description if set, otherwise ID

func (NodeEdge) IsTombstone added in v0.0.30 

func (n NodeEdge) IsTombstone() (bool, time.Time)

IsTombstone returns Tombstone value and timestamp

func (NodeEdge) String added in v0.0.30 

func (n NodeEdge) String() string

func (*NodeEdge) ToNode added in v0.0.15 

func (n *NodeEdge) ToNode() Node

ToNode converts to structure stored in db

func (*NodeEdge) ToPb added in v0.0.30 

func (n *NodeEdge) ToPb() ([]byte, error)

ToPb encodes a node to a protobuf

func (*NodeEdge) ToPbNode added in v0.0.30 

func (n *NodeEdge) ToPbNode() (*pb.Node, error)

ToPbNode converts a node to pb.Node type

type NodeEdgeChildren added in v0.5.0 

type NodeEdgeChildren struct {
	NodeEdge `yaml:",inline"`
	Children []NodeEdgeChildren `yaml:",omitempty"`
}

NodeEdgeChildren is used to pass a tree node structure into the decoder

func (NodeEdgeChildren) String added in v0.14.0 

func (ne NodeEdgeChildren) String() string

type NodeFile added in v0.22.0 

type NodeFile struct {
	APIVersion int        `yaml:"apiVersion,omitempty"`
	Nodes      []NodeYAML `yaml:"nodes,omitempty"`
	Delete     []NodeYAML `yaml:"delete,omitempty"`
}

NodeFile is a file of nodes: what siot export writes, and what siot import and provisioning read.

type NodeVersion added in v0.0.12 

type NodeVersion struct {
	OS  string `json:"os"`
	App string `json:"app"`
	HW  string `json:"hw"`
}

NodeVersion represents the device SW version

type NodeYAML added in v0.22.0 

type NodeYAML struct {
	// Type is the node type, which is the key the rest of the body hangs from.
	Type string
	// Parent is the match key of the node this one attaches to, and is only
	// meaningful on a top level entry.
	Parent     string
	Points     Points
	EdgePoints Points
	Children   []NodeYAML
}

NodeYAML is one node in a node file. The node type is the key and each point type is a key of its own: 

nodes:
  - modbus:
      description: Modbus sensors
      port: /dev/ttyS1
      baud: 9600

A file carries configuration and nothing else: no node IDs, no origins, and no points that carry no value.

func (NodeYAML) MarshalYAML added in v0.22.0 

func (n NodeYAML) MarshalYAML() (any, error)

MarshalYAML implements the goccy/go-yaml InterfaceMarshaler.

func (NodeYAML) ToNodeEdge added in v0.22.0 

func (n NodeYAML) ToNodeEdge(id, parent string) NodeEdge

ToNodeEdge converts to the structure the rest of the system passes around.

func (*NodeYAML) UnmarshalYAML added in v0.22.0 

func (n *NodeYAML) UnmarshalYAML(b []byte) error

UnmarshalYAML implements the goccy/go-yaml BytesUnmarshaler. It works from the AST rather than decoding into Go values so that how a value is written decides what it becomes: 9600 is a numeric point, "9600" is a text one, and 1 and 1.5 are an integer and a float.

type Nodes added in v0.0.30 

type Nodes []NodeEdge

Nodes defines a list of nodes

func (*Nodes) ToPb added in v0.0.30 

func (nodes *Nodes) ToPb() ([]byte, error)

ToPb converts a list of nodes to protobuf

func (*Nodes) ToPbNodes added in v0.0.30 

func (nodes *Nodes) ToPbNodes() ([]*pb.Node, error)

ToPbNodes converts a list of nodes to protobuf nodes

type Notification added in v0.0.23 

type Notification struct {
	ID         string `json:"id"`
	Parent     string `json:"parent"`
	SourceNode string `json:"sourceNode"`
	Subject    string `json:"subject"`
	Message    string `json:"message"`
}

Notification represents a message sent by a node

func PbDecodeNotification added in v0.0.23 

func PbDecodeNotification(data []byte) (Notification, error)

PbDecodeNotification converts a protobuf to notification data structure

func (*Notification) ToPb added in v0.0.23 

func (n *Notification) ToPb() ([]byte, error)

ToPb converts to protobuf data

type Point added in v0.0.11 

type Point struct {

	// Type of point (voltage, current, key, etc)
	Type string `json:"type,omitempty"`

	// Key is used to allow a group of points to represent a map or array
	Key string `json:"key,omitempty"`

	// Time the point was taken
	Time time.Time `json:"time,omitempty" yaml:"-"`

	// DataType describes what type of data we have
	DataType PointDataType `json:"dataType,omitempty"`

	// catchall field for data that does not fit into float or string --
	// should be used sparingly
	Data []byte `json:"data,omitempty"`

	// Used to indicate a point has been deleted. This value is only
	// ever incremented. Odd values mean point is deleted.
	Tombstone int `json:"tombstone,omitempty"`

	// Where did this point come from. If from the owning node, it may be blank.
	Origin string `json:"origin,omitempty"`
}

Point is a flexible data structure that can be used to represent a sensor value or a configuration parameter. Type, and Key uniquely identify a point in a node. Using the Key field, maps and arrays can be represented. Array would have key values like: "0", "1", "2", "3", ... A map might have key values like "min", "max", "average", etc.

func DecodePoint added in v0.19.0 

func DecodePoint(data []byte, off int) (Point, int, error)

DecodePoint deserializes a Point from binary data at offset.

func NewPointFloat added in v0.19.0 

func NewPointFloat(typ, key string, value float64) Point

NewPointFloat creates a new Point with a float64 value

func NewPointInt added in v0.19.0 

func NewPointInt(typ, key string, value int64) Point

NewPointInt creates a new Point with an int value

func NewPointString added in v0.19.0 

func NewPointString(typ, key string, value string) Point

NewPointString creates a new Point with a string value

func PbToPoint added in v0.0.11 

func PbToPoint(sPb *pb.Point) (Point, error)

PbToPoint converts pb point to point

func (*Point) Bool added in v0.0.11 

func (p *Point) Bool() bool

Bool returns a bool representation of value

func (Point) CRC added in v0.5.2 

func (p Point) CRC() uint32

CRC returns a CRC for the point

func (Point) CheckSubjectTokens added in v0.23.2 

func (p Point) CheckSubjectTokens() error

CheckSubjectTokens returns an error if the point type or key contains a character that is not allowed in a NATS subject token.

Points travel on subjects built from their type and key -- see client.SendPoints -- and listeners read the node ID and other routing information from fixed positions in the subject. A period in a type or key adds a token and shifts everything after it, so the point is delivered to the wrong handler. The store rejects such points on the way in, which keeps every subject the system publishes well formed.

func (Point) Encode added in v0.19.0 

func (p Point) Encode(buf *bytes.Buffer)

Encode serializes a Point to binary format.

func (Point) IsMatch added in v0.0.30 

func (p Point) IsMatch(typ, key string) bool

IsMatch returns true if the point matches the params passed in

func (Point) MarshalJSON added in v0.19.0 

func (p Point) MarshalJSON() ([]byte, error)

MarshalJSON encodes Point to JSON, including legacy value/text fields for backward compatibility.

func (Point) MarshalYAML added in v0.19.0 

func (p Point) MarshalYAML() (interface{}, error)

MarshalYAML encodes Point to YAML with legacy value/text fields for human readability. Implements goccy/go-yaml InterfaceMarshaler.

func (Point) Numeric added in v0.23.0 

func (p Point) Numeric() bool

Numeric returns true if the point carries a numeric value. Points that hold strings or JSON return false, as does a point with an unknown data type.

func (*Point) PutFloat added in v0.19.0 

func (p *Point) PutFloat(v float64)

PutFloat populates a float in a point

func (*Point) PutInt added in v0.19.0 

func (p *Point) PutInt(v int64)

PutInt populates an int in a point

func (*Point) PutString added in v0.19.0 

func (p *Point) PutString(v string)

PutString populates a string in a point

func (Point) String added in v0.0.30 

func (p Point) String() string

func (Point) ToPb added in v0.0.11 

func (p Point) ToPb() (pb.Point, error)

ToPb encodes point in protobuf format

func (Point) Txt added in v0.19.0 

func (p Point) Txt() string

Txt returns the string value of the point. Returns "" for non-string types. This is a convenience method that mirrors the old Point.Text field access semantics.

func (*Point) UnmarshalJSON added in v0.19.0 

func (p *Point) UnmarshalJSON(b []byte) error

UnmarshalJSON decodes Point from JSON, supporting both new (dataType/data) and legacy (value/text) fields.

func (*Point) UnmarshalYAML added in v0.19.0 

func (p *Point) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML decodes Point from YAML, supporting both new (dataType/data) and legacy (value/text) fields. Implements goccy/go-yaml InterfaceUnmarshaler.

func (Point) Val added in v0.19.0 

func (p Point) Val() float64

Val returns the float64 value of the point, converting from int if needed. Returns 0 for non-numeric types. This is a convenience method that mirrors the old Point.Value field access semantics.

func (*Point) ValueFloat added in v0.19.0 

func (p *Point) ValueFloat() (float64, error)

ValueFloat decodes a float value from the point

func (*Point) ValueInt added in v0.19.0 

func (p *Point) ValueInt() (int64, error)

ValueInt decodes an int value from the point

func (*Point) ValueString added in v0.19.0 

func (p *Point) ValueString() (string, error)

ValueString returns a string value from the point

type PointAverager added in v0.0.23 

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

PointAverager accumulates points, and averages them. The average can be reset.

func NewPointAverager added in v0.0.23 

func NewPointAverager(pointType string) *PointAverager

NewPointAverager initializes and returns an averager

func (*PointAverager) AddPoint added in v0.0.23 

func (pa *PointAverager) AddPoint(s Point)

AddPoint takes a point, and adds it to the total

func (*PointAverager) GetAverage added in v0.0.23 

func (pa *PointAverager) GetAverage() Point

GetAverage returns the average of the accumulated points

func (*PointAverager) ResetAverage added in v0.0.23 

func (pa *PointAverager) ResetAverage()

ResetAverage sets the accumulated total to zero

type PointDataType added in v0.19.0 

type PointDataType byte

PointDataType is the data sent over the wire 

const (
	PointDataTypeUnknown PointDataType = 0
	PointDataTypeFloat   PointDataType = 1
	PointDataTypeInt     PointDataType = 2
	PointDataTypeString  PointDataType = 3
	PointDataTypeJSON    PointDataType = 4
)

PointDataType defines

type PointFilter added in v0.0.11 

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

PointFilter is used to send points upstream. It only sends the data has changed, and at a max frequency

func NewPointFilter added in v0.0.11 

func NewPointFilter(minSend, periodicSend time.Duration) *PointFilter

NewPointFilter is used to creat a new point filter If points have changed that get sent out at a minSend interval frequency of minSend. All points are periodically sent at lastPeriodicSend interval. Set minSend to 0 for things like config settings where you want them to be sent whenever anything changes.

func (*PointFilter) Add added in v0.0.11 

func (sf *PointFilter) Add(points []Point) []Point

Add adds points and returns points that meet the filter criteria

type PointOld added in v0.19.0 

type PointOld struct {

	// Type of point (voltage, current, key, etc)
	Type string `json:"type,omitempty"`

	// Key is used to allow a group of points to represent a map or array
	Key string `json:"key,omitempty"`

	// Time the point was taken
	Time time.Time `json:"time,omitempty" yaml:"-"`

	// Instantaneous analog or digital value of the point.
	// 0 and 1 are used to represent digital values
	Value float64 `json:"value,omitempty"`

	// Optional text value of the point for data that is best represented
	// as a string rather than a number.
	Text string `json:"text,omitempty"`

	// catchall field for data that does not fit into float or string --
	// should be used sparingly
	Data []byte `json:"data,omitempty"`

	// Used to indicate a point has been deleted. This value is only
	// ever incremented. Odd values mean point is deleted.
	Tombstone int `json:"tombstone,omitempty"`

	// Where did this point come from. If from the owning node, it may be blank.
	Origin string `json:"origin,omitempty"`
}

PointOld old point struct

type Points added in v0.0.11 

type Points []Point

Points is an array of Point

func DecodePoints added in v0.19.0 

func DecodePoints(data []byte) (Points, error)

DecodePoints deserializes a Points array from binary data.

func DiffPoints added in v0.12.6 

func DiffPoints[T any](before, after T) (Points, error)

DiffPoints compares a before and after struct and generates the set of Points that represent their differences.

func (*Points) Add added in v0.0.44 

func (ps *Points) Add(pIn Point)

Add takes a point and updates an existing array of points. Existing points are replaced if the Timestamp in pIn is > than the existing timestamp. If the pIn timestamp is zero, the current time is used.

func (*Points) Collapse added in v0.14.0 

func (ps *Points) Collapse()

Collapse is used to merge any common points and keep the latest

func (Points) Desc added in v0.0.30 

func (ps Points) Desc() string

Desc returns a Description of a set of points

func (*Points) Encode added in v0.19.0 

func (ps *Points) Encode() []byte

Encode serializes a Points array to binary format: uint32 count + repeated Point.

func (Points) Find added in v0.0.30 

func (ps Points) Find(typ, key string) (Point, bool)

Find fetches a point given ID, Type, and Index and true of found, or false if not found

func (*Points) Hash added in v0.0.30 

func (ps *Points) Hash() uint32

Hash returns the hash of points

func (*Points) LatestTime added in v0.0.11 

func (ps *Points) LatestTime() time.Time

LatestTime returns the latest timestamp of a devices points

func (Points) Len added in v0.0.30 

func (ps Points) Len() int

Len returns the number of points

func (Points) Less added in v0.0.30 

func (ps Points) Less(i, j int) bool

Less is required by sort.Interface

func (Points) MatchKey added in v0.22.0 

func (ps Points) MatchKey() string

MatchKey returns the value that identifies a node when a file describes it by name rather than by ID, used by siot import and provisioning. Most nodes are identified by their description; a user has none, so an email address is used, and a name if there is no email.

This is deliberately separate from Desc, which prefers a name over a description for display.

func (*Points) Merge added in v0.10.0 

func (ps *Points) Merge(in Points, maxTime time.Duration) Points

Merge is used to update points. Any points that are changed are returned. maxDuration can be used to return points if they have not been updated in maxDuration -- this can be used to send out points every X duration even if they are not changing which is useful for making graphs look nice. Set maxTime to zero to disable.

func (Points) String added in v0.5.0 

func (ps Points) String() string

func (Points) Swap added in v0.0.30 

func (ps Points) Swap(i, j int)

Swap is required by sort.Interface

func (*Points) Text added in v0.0.11 

func (ps *Points) Text(typ, key string) (string, bool)

Text fetches a text value from an array of points given Type and Key. If ID or Type are set to "", they are ignored.

func (*Points) Value added in v0.0.11 

func (ps *Points) Value(typ, key string) (float64, bool)

Value fetches a value from an array of points given ID, Type, and Index. If ID or Type are set to "", they are ignored.

func (*Points) ValueBool added in v0.0.16 

func (ps *Points) ValueBool(typ, key string) (bool, bool)

ValueBool returns value as bool

func (*Points) ValueInt added in v0.0.16 

func (ps *Points) ValueInt(typ, key string) (int, bool)

ValueInt returns value as integer

type StandardResponse 

type StandardResponse struct {
	Success bool   `json:"success"`
	Error   string `json:"error,omitempty"`
	ID      string `json:"id,omitempty"`
}

StandardResponse is the standard response to any request

type SwUpdateState added in v0.0.9 

type SwUpdateState struct {
	Running     bool   `json:"running"`
	Error       string `json:"error"`
	PercentDone int    `json:"percentDone"`
}

SwUpdateState represents the state of an update

func (*SwUpdateState) Points added in v0.0.30 

func (sws *SwUpdateState) Points() Points

Points converts SW update state to node points

type TimeWindowAverager 

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

TimeWindowAverager accumulates points, and averages them on a fixed time period and outputs the average/min/max, etc as a point

func NewTimeWindowAverager 

func NewTimeWindowAverager(windowLen time.Duration, callBack func(Point), pointType string) *TimeWindowAverager

NewTimeWindowAverager initializes and returns an averager

func (*TimeWindowAverager) NewPoint added in v0.0.23 

func (twa *TimeWindowAverager) NewPoint(s Point)

NewPoint takes a point, and if the time window expired, it calls the callback function with the a new point which is avg of all points since start time.

type User 

type User struct {
	ID        string `json:"id"`
	FirstName string `json:"firstName"`
	LastName  string `json:"lastName"`
	Phone     string `json:"phone"`
	Email     string `json:"email"`
	Pass      string `json:"pass"`
}

User represents a user of the system

func NodeToUser added in v0.0.23 

func NodeToUser(node Node) (User, error)

NodeToUser converts a node to a user

func (*User) ToNode added in v0.0.15 

func (u *User) ToNode() Node

ToNode converts a user structure into a node

func (*User) ToPoints added in v0.0.15 

func (u *User) ToPoints() Points

ToPoints converts a user structure into points

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.