timeseriesgateway

type DiscreteSensorValue struct {
	// the sensor value
	Value float64

	// the timestamp of the sensor value
	Timestamp time.Time

	// the alias of the sensor value, eg. 1 = ON; 0 = OFF
	Alias string

	// the duration of this sensor value (until the next value)
	LengthInSeconds int64
}

type DiscreteValueQuery struct {
	MachineID string
	SensorID  string
	StartTime time.Time
	EndTime   time.Time
}

type Gateway interface {
	// SensorDiscreteValueQuery returns a slice of Discrete Sensor Values
	SensorDiscreteValueQuery(context.Context, *DiscreteValueQuery) ([]DiscreteSensorValue, error)
	SensorAverageQuery(context.Context, *SensorAverageQuery) ([]SensorAverageResult, error)
}

type SensorAverageQuery struct {
	MachineID            string
	SensorID             string
	StartTime            time.Time
	EndTime              time.Time
	IncludePreviousValue bool
}

type SensorAverageResult struct {
	Timestamp time.Time `json:"t"`
	Value     float64   `json:"v"`
}