mapper

Documentation

Index

• Constants
• func CurrentToRatio(current float64) float64
• func HeightToVolume(height float64, sensorOffset float64, heights []interface{}, ...) (result float64, err error)
• func ListToFloats(input []interface{}) ([]float64, error)
• func MovingAverage(values []message.SingleValueMapped) float64
• func PressureToHeight(pressure float64, density float64) float64
• type AggregateMapper
  • func NewAggregateMapper(c config.MapperConfig, emc []config.ExpressionMappingConfig) (*AggregateMapper, error)
  • func (m *AggregateMapper) DoMap(input *message.Mapped) (*message.Mapped, error)
  • func (m *AggregateMapper) Map(subscriber mangos.Socket, publisher mangos.Socket)
• type CSVMapper
  • func NewCSVMapper(c config.CSVMapperConfig, cmc []config.CSVMappingConfig) (*CSVMapper, error)
  • func (m *CSVMapper) DoMap(r *message.Raw) (*message.Mapped, error)
  • func (m *CSVMapper) Map(subscriber mangos.Socket, publisher mangos.Socket)
• type CanBusMapper
  • func NewCanBusMapper(c config.CanBusMapperConfig, cmc []config.CanBusMappingConfig) (*CanBusMapper, error)
  • func (m *CanBusMapper) DoMap(r *message.Raw) (*message.Mapped, error)
  • func (m *CanBusMapper) Map(subscriber mangos.Socket, publisher mangos.Socket)
• type DBC
• type ExpressionEnvironment
  • func NewExpressionEnvironment() ExpressionEnvironment
• type ExpressionFilter
  • func NewExpressionFilter(emc []config.ExpressionMappingConfig) (*ExpressionFilter, error)
  • func (f *ExpressionFilter) DoMap(delta *message.Mapped) (*message.Mapped, error)
  • func (f *ExpressionFilter) Map(subscriber mangos.Socket, publisher mangos.Socket)
• type JSONMapper
  • func NewJSONMapper(c config.MapperConfig, jmc []config.JSONMappingConfig) (*JSONMapper, error)
  • func (m *JSONMapper) DoMap(r *message.Raw) (*message.Mapped, error)
  • func (m *JSONMapper) Map(subscriber mangos.Socket, publisher mangos.Socket)
• type MappedMapper
• type Mapper
• type ModbusMapper
  • func NewModbusMapper(c config.MapperConfig, mmc []config.ModbusMappingsConfig) (*ModbusMapper, error)
  • func (m *ModbusMapper) DoMap(r *message.Raw) (*message.Mapped, error)
  • func (m *ModbusMapper) Map(subscriber mangos.Socket, publisher mangos.Socket)
• type Nmea0183Mapper
  • func NewNmea0183Mapper(c config.MapperConfig) (*Nmea0183Mapper, error)
  • func (m *Nmea0183Mapper) DoMap(r *message.Raw) (*message.Mapped, error)
  • func (m *Nmea0183Mapper) Map(subscriber mangos.Socket, publisher mangos.Socket)
• type RateLimitFilter
  • func NewRateLimitFilter(c *config.RateLimitFilterConfig) (*RateLimitFilter, error)
  • func (m *RateLimitFilter) DoMap(delta *message.Mapped) (*message.Mapped, error)
  • func (f *RateLimitFilter) Map(subscriber mangos.Socket, publisher mangos.Socket)
• type RealMapper
• type Signal

Constants

const (
	SLAVE_ENV_PREFIX = "slave_"
)

Functions

func CurrentToRatio

func CurrentToRatio(current float64) float64

Returns the 4-20mA input signal to a ratio, 4000uA => 0.0, 8000uA => 0.25, 12000uA => 0.5, 16000uA => 0.75, 20000uA => 1.0 current is in uA (1000000uA is 1A) return value is a ratio (0.0 .. 1.0)

func HeightToVolume

func HeightToVolume(height float64, sensorOffset float64, heights []interface{}, volumes []interface{}) (result float64, err error)

Returns the HeightToVolume corresponding to the measured height. This function is used when a pressure sensor is used in a tank. height is in m sensorOffset is in m (positive means that the sensor is placed above the bottom of the tank, negative value means that the sensor is placed below the tank) heights is in m, list of heights with corresponding volumes volumes is in m3, list of volumes with corresponding heights return value is in m3

func ListToFloats

func ListToFloats(input []interface{}) ([]float64, error)

func MovingAverage

func MovingAverage(values []message.SingleValueMapped) float64

func PressureToHeight

func PressureToHeight(pressure float64, density float64) float64

Converts a pressure and density to a height pressure is in Pa (1 Bar is 100000 Pascal) density is in kg/m3 (typical value for diesel is 840) return value is in m

Types

type AggregateMapper

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

func NewAggregateMapper

func NewAggregateMapper(c config.MapperConfig, emc []config.ExpressionMappingConfig) (*AggregateMapper, error)

func (*AggregateMapper) DoMap

func (m *AggregateMapper) DoMap(input *message.Mapped) (*message.Mapped, error)

func (*AggregateMapper) Map

func (m *AggregateMapper) Map(subscriber mangos.Socket, publisher mangos.Socket)

type CSVMapper

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

func NewCSVMapper

func NewCSVMapper(c config.CSVMapperConfig, cmc []config.CSVMappingConfig) (*CSVMapper, error)

func (*CSVMapper) DoMap

func (m *CSVMapper) DoMap(r *message.Raw) (*message.Mapped, error)

func (*CSVMapper) Map

func (m *CSVMapper) Map(subscriber mangos.Socket, publisher mangos.Socket)

type CanBusMapper

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

func NewCanBusMapper

func NewCanBusMapper(c config.CanBusMapperConfig, cmc []config.CanBusMappingConfig) (*CanBusMapper, error)

func (*CanBusMapper) DoMap

func (m *CanBusMapper) DoMap(r *message.Raw) (*message.Mapped, error)

func (*CanBusMapper) Map

func (m *CanBusMapper) Map(subscriber mangos.Socket, publisher mangos.Socket)

type DBC

type DBC map[uint32]*dbc.MessageDef

type ExpressionEnvironment

type ExpressionEnvironment map[string]interface{}

func NewExpressionEnvironment

func NewExpressionEnvironment() ExpressionEnvironment

type ExpressionFilter

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

func NewExpressionFilter

func NewExpressionFilter(emc []config.ExpressionMappingConfig) (*ExpressionFilter, error)

func (*ExpressionFilter) DoMap

func (f *ExpressionFilter) DoMap(delta *message.Mapped) (*message.Mapped, error)

func (*ExpressionFilter) Map

func (f *ExpressionFilter) Map(subscriber mangos.Socket, publisher mangos.Socket)

type JSONMapper

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

func NewJSONMapper

func NewJSONMapper(c config.MapperConfig, jmc []config.JSONMappingConfig) (*JSONMapper, error)

func (*JSONMapper) DoMap

func (m *JSONMapper) DoMap(r *message.Raw) (*message.Mapped, error)

func (*JSONMapper) Map

func (m *JSONMapper) Map(subscriber mangos.Socket, publisher mangos.Socket)

type MappedMapper

type MappedMapper interface {
	DoMap(*message.Mapped) (*message.Mapped, error)
}

type Mapper

type Mapper interface {
	Map(subscriber mangos.Socket, publisher mangos.Socket)
}

Mapper interface

type ModbusMapper

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

func NewModbusMapper

func NewModbusMapper(c config.MapperConfig, mmc []config.ModbusMappingsConfig) (*ModbusMapper, error)

func (*ModbusMapper) DoMap

func (m *ModbusMapper) DoMap(r *message.Raw) (*message.Mapped, error)

func (*ModbusMapper) Map

func (m *ModbusMapper) Map(subscriber mangos.Socket, publisher mangos.Socket)

type Nmea0183Mapper

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

func NewNmea0183Mapper

func NewNmea0183Mapper(c config.MapperConfig) (*Nmea0183Mapper, error)

func (*Nmea0183Mapper) DoMap

func (m *Nmea0183Mapper) DoMap(r *message.Raw) (*message.Mapped, error)

func (*Nmea0183Mapper) Map

func (m *Nmea0183Mapper) Map(subscriber mangos.Socket, publisher mangos.Socket)

type RateLimitFilter

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

func NewRateLimitFilter

func NewRateLimitFilter(c *config.RateLimitFilterConfig) (*RateLimitFilter, error)

func (*RateLimitFilter) DoMap

func (m *RateLimitFilter) DoMap(delta *message.Mapped) (*message.Mapped, error)

func (*RateLimitFilter) Map

func (f *RateLimitFilter) Map(subscriber mangos.Socket, publisher mangos.Socket)

type RealMapper

type RealMapper interface {
	DoMap(*message.Raw) (*message.Mapped, error)
}

type Signal

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