mapper

Mar 29, 2024

Changes in this version

+ func BitwiseAnd(left, right uint16) uint16

+ func BitwiseContains(input, pattern uint16) bool

+ func BitwiseNot(left uint16) uint16

+ func BitwiseOr(left, right uint16) uint16

+ func BitwiseXor(left, right uint16) uint16

+ func IsBitSet(input uint16, position int) bool

+ func Notify(s bool, m string) message.Notification

Dec 22, 2023

Changes in this version

+ func ToFloat(mostSignificant, leastSignificant uint16) float32

Sep 29, 2023

Changes in this version

+ func CopySign(f float64, sign float64) float64

+ func PowerW(rotations float64, torque float64) float64

Aug 24, 2023

Changes in this version

+ func MovingAverage(values []message.SingleValueMapped) float64

Jun 27, 2023

Changes in this version

+ const SLAVE_ENV_PREFIX

Apr 17, 2023

Changes in this version

+ type ExpressionFilter struct

+ 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 RateLimitFilter struct

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

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

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

Jan 13, 2023

Changes in this version

+ func CurrentToRatio(current float64) float64

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

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

+ func PressureToHeight(pressure float64, density float64) float64

Oct 24, 2022

Changes in this version

+ type ExpressionEnvironment map[string]interface

+ func NewExpressionEnvironment() ExpressionEnvironment

Sep 20, 2022

Changes in this version

+ type AggregateMapper struct

+ func NewAggregateMapper(c config.MapperConfig, amc []config.AggregateMappingConfig) (*AggregateMapper, error)

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

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

Sep 16, 2022

Changes in this version

+ type AggegrateMapper struct

+ func NewAggegrateMapper(c config.MapperConfig, amc []config.AggegrateMappingConfig) (*AggegrateMapper, error)

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

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

+ type MappedMapper interface

+ DoMap func(*message.Mapped) (*message.Mapped, error)

Jul 8, 2022

Changes in this version

+ type CanBusMapper struct

+ 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 map[uint32]*dbc.MessageDef

+ type Signal struct

Mar 12, 2022

Changes in this version

+ type SendOnChangeMapper struct

+ func NewSendOnChangeMapper(c config.CacheConfig) *SendOnChangeMapper

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

Mar 5, 2022

Changes in this version

+ type JSONMapper struct

+ 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)

Feb 21, 2022

Changes in this version

+ func RegistersToCoils(registers []uint16) []bool

type CSVMapper

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

type ModbusMapper

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

type Nmea0183Mapper

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

+ type RealMapper interface

+ DoMap func(*message.Raw) (*message.Mapped, error)

Feb 20, 2022

Changes in this version

+ type CSVMapper struct

+ func NewCSVMapper(c config.MapperConfig, cmc []config.CsvMappingConfig) (*CSVMapper, error)

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

Feb 20, 2022

Changes in this version

+ type CacheMapper struct

+ func NewCacheMapper(c config.CacheConfig) (*CacheMapper, error)

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

+ type CsvMapper struct

+ func NewCsvMapper(c config.MapperConfig, cmc []config.CsvMappingConfig) (*CsvMapper, error)

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

+ type Mapper interface

+ Map func(subscriber mangos.Socket, publisher mangos.Socket)

+ type ModbusMapper struct

+ func NewModbusMapper(c config.MapperConfig, rmc []config.RegisterMappingConfig) (*ModbusMapper, error)

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

+ type Nmea0183Mapper struct

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

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

+ type VirtualMapper struct

+ func NewVirtualMapper(c config.MapperConfig) (*VirtualMapper, error)

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