sensors

Documentation

Index

• type Average
  • func (query *Average) Run(ctx context.Context) (*types.QueryResult, error)
• type Current
  • func (query *Current) Run(ctx context.Context) (*types.QueryResult, error)
• type DiscreteSensorChanges
  • func (query *DiscreteSensorChanges) Run(ctx context.Context) (*types.QueryResult, error)
• type DurationCount
  • func (query *DurationCount) Run(ctx context.Context) (*types.QueryResult, error)

Types

type Average

type Average struct {
	Gateway              timeseriesgateway.Gateway
	RefId                string
	MachineID            string
	SensorID             string
	StartTime            time.Time
	EndTime              time.Time
	Name                 string
	IncludePreviousValue bool
	Logger               log.Logger
}

func (*Average) Run

func (query *Average) Run(ctx context.Context) (*types.QueryResult, error)

type Current

type Current struct {
	Gateway   monitoringgateway.Gateway
	RefId     string
	MachineID string
	SensorID  string
	Name      string
	Logger    log.Logger
}

func (*Current) Run

func (query *Current) Run(ctx context.Context) (*types.QueryResult, error)

type DiscreteSensorChanges

type DiscreteSensorChanges struct {
	Gateway   timeseriesgateway.Gateway
	RefId     string
	MachineID string
	SensorID  string
	Name      string
	StartTime time.Time
	EndTime   time.Time
	Logger    log.Logger
}

DiscreteSensorChanges represents a query for sensor value changes From a functional perspective this query is only useful for discrete sensors. A discrete sensor can be seen as an enumeration in code. It has a limited number of fixed values. This query returns all changes within the specified time frame for a sensor

func (*DiscreteSensorChanges) Run

func (query *DiscreteSensorChanges) Run(ctx context.Context) (*types.QueryResult, error)

type DurationCount

type DurationCount struct {
	Gateway   timeseriesgateway.Gateway
	RefId     string
	MachineID string
	SensorID  string
	Name      string
	StartTime time.Time
	EndTime   time.Time
	Logger    log.Logger
}

func (*DurationCount) Run

func (query *DurationCount) Run(ctx context.Context) (*types.QueryResult, error)