avro

package
v0.0.0-...-7e77c86 Latest Latest
Warning

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

 Go to latest Published: Sep 15, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAnalogSensorWriter 

func NewAnalogSensorWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)

func NewLiquidSensorWriter 

func NewLiquidSensorWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)

func NewMeasurementPackageWriter 

func NewMeasurementPackageWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)

Types

type AnalogSensor 

type AnalogSensor struct {

	// Ordinal number of sensor
	SensorNumber int32

	// Value red from sensor. Meaning is this value depends on type of the input. if analog device is connected to the input, value is millivolts. If input is used for counting discrete impulses, value is the number of impulses
	Value int32
}

func DeserializeAnalogSensor 

func DeserializeAnalogSensor(r io.Reader) (*AnalogSensor, error)

func NewAnalogSensor 

func NewAnalogSensor() *AnalogSensor

func (*AnalogSensor) AppendArray 

func (_ *AnalogSensor) AppendArray() types.Field

func (*AnalogSensor) AppendMap 

func (_ *AnalogSensor) AppendMap(key string) types.Field

func (*AnalogSensor) Finalize 

func (_ *AnalogSensor) Finalize()

func (*AnalogSensor) Get 

func (r *AnalogSensor) Get(i int) types.Field

func (*AnalogSensor) Schema 

func (r *AnalogSensor) Schema() string

func (*AnalogSensor) SchemaName 

func (r *AnalogSensor) SchemaName() string

func (*AnalogSensor) Serialize 

func (r *AnalogSensor) Serialize(w io.Writer) error

func (*AnalogSensor) SetBoolean 

func (_ *AnalogSensor) SetBoolean(v bool)

func (*AnalogSensor) SetBytes 

func (_ *AnalogSensor) SetBytes(v []byte)

func (*AnalogSensor) SetDefault 

func (r *AnalogSensor) SetDefault(i int)

func (*AnalogSensor) SetDouble 

func (_ *AnalogSensor) SetDouble(v float64)

func (*AnalogSensor) SetFloat 

func (_ *AnalogSensor) SetFloat(v float32)

func (*AnalogSensor) SetInt 

func (_ *AnalogSensor) SetInt(v int32)

func (*AnalogSensor) SetLong 

func (_ *AnalogSensor) SetLong(v int64)

func (*AnalogSensor) SetString 

func (_ *AnalogSensor) SetString(v string)

func (*AnalogSensor) SetUnionElem 

func (_ *AnalogSensor) SetUnionElem(v int64)

type AnalogSensorReader 

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

func NewAnalogSensorReader 

func NewAnalogSensorReader(r io.Reader) (*AnalogSensorReader, error)

func (*AnalogSensorReader) Read 

func (r *AnalogSensorReader) Read() (*AnalogSensor, error)

type ArrayAnalogSensorWrapper 

type ArrayAnalogSensorWrapper []*AnalogSensor

func (*ArrayAnalogSensorWrapper) AppendArray 

func (r *ArrayAnalogSensorWrapper) AppendArray() types.Field

func (*ArrayAnalogSensorWrapper) AppendMap 

func (_ *ArrayAnalogSensorWrapper) AppendMap(key string) types.Field

func (*ArrayAnalogSensorWrapper) Finalize 

func (_ *ArrayAnalogSensorWrapper) Finalize()

func (*ArrayAnalogSensorWrapper) Get 

func (_ *ArrayAnalogSensorWrapper) Get(i int) types.Field

func (*ArrayAnalogSensorWrapper) SetBoolean 

func (_ *ArrayAnalogSensorWrapper) SetBoolean(v bool)

func (*ArrayAnalogSensorWrapper) SetBytes 

func (_ *ArrayAnalogSensorWrapper) SetBytes(v []byte)

func (*ArrayAnalogSensorWrapper) SetDefault 

func (_ *ArrayAnalogSensorWrapper) SetDefault(i int)

func (*ArrayAnalogSensorWrapper) SetDouble 

func (_ *ArrayAnalogSensorWrapper) SetDouble(v float64)

func (*ArrayAnalogSensorWrapper) SetFloat 

func (_ *ArrayAnalogSensorWrapper) SetFloat(v float32)

func (*ArrayAnalogSensorWrapper) SetInt 

func (_ *ArrayAnalogSensorWrapper) SetInt(v int32)

func (*ArrayAnalogSensorWrapper) SetLong 

func (_ *ArrayAnalogSensorWrapper) SetLong(v int64)

func (*ArrayAnalogSensorWrapper) SetString 

func (_ *ArrayAnalogSensorWrapper) SetString(v string)

func (*ArrayAnalogSensorWrapper) SetUnionElem 

func (_ *ArrayAnalogSensorWrapper) SetUnionElem(v int64)

type ArrayLiquidSensorWrapper 

type ArrayLiquidSensorWrapper []*LiquidSensor

func (*ArrayLiquidSensorWrapper) AppendArray 

func (r *ArrayLiquidSensorWrapper) AppendArray() types.Field

func (*ArrayLiquidSensorWrapper) AppendMap 

func (_ *ArrayLiquidSensorWrapper) AppendMap(key string) types.Field

func (*ArrayLiquidSensorWrapper) Finalize 

func (_ *ArrayLiquidSensorWrapper) Finalize()

func (*ArrayLiquidSensorWrapper) Get 

func (_ *ArrayLiquidSensorWrapper) Get(i int) types.Field

func (*ArrayLiquidSensorWrapper) SetBoolean 

func (_ *ArrayLiquidSensorWrapper) SetBoolean(v bool)

func (*ArrayLiquidSensorWrapper) SetBytes 

func (_ *ArrayLiquidSensorWrapper) SetBytes(v []byte)

func (*ArrayLiquidSensorWrapper) SetDefault 

func (_ *ArrayLiquidSensorWrapper) SetDefault(i int)

func (*ArrayLiquidSensorWrapper) SetDouble 

func (_ *ArrayLiquidSensorWrapper) SetDouble(v float64)

func (*ArrayLiquidSensorWrapper) SetFloat 

func (_ *ArrayLiquidSensorWrapper) SetFloat(v float32)

func (*ArrayLiquidSensorWrapper) SetInt 

func (_ *ArrayLiquidSensorWrapper) SetInt(v int32)

func (*ArrayLiquidSensorWrapper) SetLong 

func (_ *ArrayLiquidSensorWrapper) SetLong(v int64)

func (*ArrayLiquidSensorWrapper) SetString 

func (_ *ArrayLiquidSensorWrapper) SetString(v string)

func (*ArrayLiquidSensorWrapper) SetUnionElem 

func (_ *ArrayLiquidSensorWrapper) SetUnionElem(v int64)

type ByteWriter 

type ByteWriter interface {
	Grow(int)
	WriteByte(byte) error
}

type LiquidSensor 

type LiquidSensor struct {

	// Ordinal number of sensor
	SensorNumber int32

	// Value is set if error occurred during reading value from liquid sensor
	ErrorFlag string

	// This value is set if liquid sensor measures level of the liqid in a vessel. Otherwise value is 0
	ValueMillimeters int32

	// This value is set if liquid sensor measures volume of the liqid in a vessel. Otherwise value is 0
	ValueLitres int32
}

func DeserializeLiquidSensor 

func DeserializeLiquidSensor(r io.Reader) (*LiquidSensor, error)

func NewLiquidSensor 

func NewLiquidSensor() *LiquidSensor

func (*LiquidSensor) AppendArray 

func (_ *LiquidSensor) AppendArray() types.Field

func (*LiquidSensor) AppendMap 

func (_ *LiquidSensor) AppendMap(key string) types.Field

func (*LiquidSensor) Finalize 

func (_ *LiquidSensor) Finalize()

func (*LiquidSensor) Get 

func (r *LiquidSensor) Get(i int) types.Field

func (*LiquidSensor) Schema 

func (r *LiquidSensor) Schema() string

func (*LiquidSensor) SchemaName 

func (r *LiquidSensor) SchemaName() string

func (*LiquidSensor) Serialize 

func (r *LiquidSensor) Serialize(w io.Writer) error

func (*LiquidSensor) SetBoolean 

func (_ *LiquidSensor) SetBoolean(v bool)

func (*LiquidSensor) SetBytes 

func (_ *LiquidSensor) SetBytes(v []byte)

func (*LiquidSensor) SetDefault 

func (r *LiquidSensor) SetDefault(i int)

func (*LiquidSensor) SetDouble 

func (_ *LiquidSensor) SetDouble(v float64)

func (*LiquidSensor) SetFloat 

func (_ *LiquidSensor) SetFloat(v float32)

func (*LiquidSensor) SetInt 

func (_ *LiquidSensor) SetInt(v int32)

func (*LiquidSensor) SetLong 

func (_ *LiquidSensor) SetLong(v int64)

func (*LiquidSensor) SetString 

func (_ *LiquidSensor) SetString(v string)

func (*LiquidSensor) SetUnionElem 

func (_ *LiquidSensor) SetUnionElem(v int64)

type LiquidSensorReader 

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

func NewLiquidSensorReader 

func NewLiquidSensorReader(r io.Reader) (*LiquidSensorReader, error)

func (*LiquidSensorReader) Read 

func (r *LiquidSensorReader) Read() (*LiquidSensor, error)

type MeasurementPackage 

type MeasurementPackage struct {

	// IMEI of the device that sent this data
	Imei *UnionNullString

	// Unique record identifier
	Guid string

	// Client ID assigned to receiver device
	ClinetId int64

	// Identifier of the data packet
	PacketID int64

	// Timestamp of the measurement
	MeasurementTimestamp int64

	// Timestamp of receiveing the data from device
	ReceivedTimestamp int64

	// Device's latitude at the moment of measurement
	Latitude *UnionNullDouble

	// Device's longitude at the moment of measurement
	Longitude *UnionNullDouble

	// Device's speed at the moment of measurement
	Speed *UnionNullInt

	// Position dilution of precision
	Pdop *UnionNullInt

	// Horizontal dilution of precision
	Hdop *UnionNullInt

	// Vertical dilution of precision
	Vdop *UnionNullInt

	// Number of satelites that were used to detect device position
	NumOfSatelites   *UnionNullInt
	NavigationSystem NavigationSystem

	// Angle (in degrees) between north meridian and device's moving direction (clockwise). Value is in [0, 359] degrees range
	Direction *UnionNullInt

	// Values red from analog sensors connected to analog inputs at the moment of measurement. Some analog inputs can be used for counting signals from discrete inputs
	AnalogSensors *UnionArrayAnalogSensorNull

	// Values red from liquid sensors connected to liquid sensors inputs at the moment of measurement
	LiquidSensors *UnionArrayLiquidSensorNull
}

func DeserializeMeasurementPackage 

func DeserializeMeasurementPackage(r io.Reader) (*MeasurementPackage, error)

func NewMeasurementPackage 

func NewMeasurementPackage() *MeasurementPackage

func (*MeasurementPackage) AppendArray 

func (_ *MeasurementPackage) AppendArray() types.Field

func (*MeasurementPackage) AppendMap 

func (_ *MeasurementPackage) AppendMap(key string) types.Field

func (*MeasurementPackage) Finalize 

func (_ *MeasurementPackage) Finalize()

func (*MeasurementPackage) Get 

func (r *MeasurementPackage) Get(i int) types.Field

func (*MeasurementPackage) Schema 

func (r *MeasurementPackage) Schema() string

func (*MeasurementPackage) SchemaName 

func (r *MeasurementPackage) SchemaName() string

func (*MeasurementPackage) Serialize 

func (r *MeasurementPackage) Serialize(w io.Writer) error

func (*MeasurementPackage) SetBoolean 

func (_ *MeasurementPackage) SetBoolean(v bool)

func (*MeasurementPackage) SetBytes 

func (_ *MeasurementPackage) SetBytes(v []byte)

func (*MeasurementPackage) SetDefault 

func (r *MeasurementPackage) SetDefault(i int)

func (*MeasurementPackage) SetDouble 

func (_ *MeasurementPackage) SetDouble(v float64)

func (*MeasurementPackage) SetFloat 

func (_ *MeasurementPackage) SetFloat(v float32)

func (*MeasurementPackage) SetInt 

func (_ *MeasurementPackage) SetInt(v int32)

func (*MeasurementPackage) SetLong 

func (_ *MeasurementPackage) SetLong(v int64)

func (*MeasurementPackage) SetString 

func (_ *MeasurementPackage) SetString(v string)

func (*MeasurementPackage) SetUnionElem 

func (_ *MeasurementPackage) SetUnionElem(v int64)

type MeasurementPackageReader 

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

func NewMeasurementPackageReader 

func NewMeasurementPackageReader(r io.Reader) (*MeasurementPackageReader, error)

func (*MeasurementPackageReader) Read 

func (r *MeasurementPackageReader) Read() (*MeasurementPackage, error)
type NavigationSystem int32
const (
	NavigationSystemUknown  NavigationSystem = 0
	NavigationSystemGLONASS NavigationSystem = 1
	NavigationSystemGPS     NavigationSystem = 2
	NavigationSystemGalileo NavigationSystem = 3
	NavigationSystemCompass NavigationSystem = 4
	NavigationSystemBeidou  NavigationSystem = 5
	NavigationSystemDORIS   NavigationSystem = 6
)
func (e NavigationSystem) String() string

type StringWriter 

type StringWriter interface {
	WriteString(string) (int, error)
}

type UnionArrayAnalogSensorNull 

type UnionArrayAnalogSensorNull struct {
	ArrayAnalogSensor []*AnalogSensor
	Null              *types.NullVal
	UnionType         UnionArrayAnalogSensorNullTypeEnum
}

func NewUnionArrayAnalogSensorNull 

func NewUnionArrayAnalogSensorNull() *UnionArrayAnalogSensorNull

func (*UnionArrayAnalogSensorNull) AppendArray 

func (_ *UnionArrayAnalogSensorNull) AppendArray() types.Field

func (*UnionArrayAnalogSensorNull) AppendMap 

func (_ *UnionArrayAnalogSensorNull) AppendMap(key string) types.Field

func (*UnionArrayAnalogSensorNull) Finalize 

func (_ *UnionArrayAnalogSensorNull) Finalize()

func (*UnionArrayAnalogSensorNull) Get 

func (r *UnionArrayAnalogSensorNull) Get(i int) types.Field

func (*UnionArrayAnalogSensorNull) SetBoolean 

func (_ *UnionArrayAnalogSensorNull) SetBoolean(v bool)

func (*UnionArrayAnalogSensorNull) SetBytes 

func (_ *UnionArrayAnalogSensorNull) SetBytes(v []byte)

func (*UnionArrayAnalogSensorNull) SetDefault 

func (_ *UnionArrayAnalogSensorNull) SetDefault(i int)

func (*UnionArrayAnalogSensorNull) SetDouble 

func (_ *UnionArrayAnalogSensorNull) SetDouble(v float64)

func (*UnionArrayAnalogSensorNull) SetFloat 

func (_ *UnionArrayAnalogSensorNull) SetFloat(v float32)

func (*UnionArrayAnalogSensorNull) SetInt 

func (_ *UnionArrayAnalogSensorNull) SetInt(v int32)

func (*UnionArrayAnalogSensorNull) SetLong 

func (r *UnionArrayAnalogSensorNull) SetLong(v int64)

func (*UnionArrayAnalogSensorNull) SetString 

func (_ *UnionArrayAnalogSensorNull) SetString(v string)

type UnionArrayAnalogSensorNullTypeEnum 

type UnionArrayAnalogSensorNullTypeEnum int
const (
	UnionArrayAnalogSensorNullTypeEnumArrayAnalogSensor UnionArrayAnalogSensorNullTypeEnum = 0
	UnionArrayAnalogSensorNullTypeEnumNull              UnionArrayAnalogSensorNullTypeEnum = 1
)

type UnionArrayLiquidSensorNull 

type UnionArrayLiquidSensorNull struct {
	ArrayLiquidSensor []*LiquidSensor
	Null              *types.NullVal
	UnionType         UnionArrayLiquidSensorNullTypeEnum
}

func NewUnionArrayLiquidSensorNull 

func NewUnionArrayLiquidSensorNull() *UnionArrayLiquidSensorNull

func (*UnionArrayLiquidSensorNull) AppendArray 

func (_ *UnionArrayLiquidSensorNull) AppendArray() types.Field

func (*UnionArrayLiquidSensorNull) AppendMap 

func (_ *UnionArrayLiquidSensorNull) AppendMap(key string) types.Field

func (*UnionArrayLiquidSensorNull) Finalize 

func (_ *UnionArrayLiquidSensorNull) Finalize()

func (*UnionArrayLiquidSensorNull) Get 

func (r *UnionArrayLiquidSensorNull) Get(i int) types.Field

func (*UnionArrayLiquidSensorNull) SetBoolean 

func (_ *UnionArrayLiquidSensorNull) SetBoolean(v bool)

func (*UnionArrayLiquidSensorNull) SetBytes 

func (_ *UnionArrayLiquidSensorNull) SetBytes(v []byte)

func (*UnionArrayLiquidSensorNull) SetDefault 

func (_ *UnionArrayLiquidSensorNull) SetDefault(i int)

func (*UnionArrayLiquidSensorNull) SetDouble 

func (_ *UnionArrayLiquidSensorNull) SetDouble(v float64)

func (*UnionArrayLiquidSensorNull) SetFloat 

func (_ *UnionArrayLiquidSensorNull) SetFloat(v float32)

func (*UnionArrayLiquidSensorNull) SetInt 

func (_ *UnionArrayLiquidSensorNull) SetInt(v int32)

func (*UnionArrayLiquidSensorNull) SetLong 

func (r *UnionArrayLiquidSensorNull) SetLong(v int64)

func (*UnionArrayLiquidSensorNull) SetString 

func (_ *UnionArrayLiquidSensorNull) SetString(v string)

type UnionArrayLiquidSensorNullTypeEnum 

type UnionArrayLiquidSensorNullTypeEnum int
const (
	UnionArrayLiquidSensorNullTypeEnumArrayLiquidSensor UnionArrayLiquidSensorNullTypeEnum = 0
	UnionArrayLiquidSensorNullTypeEnumNull              UnionArrayLiquidSensorNullTypeEnum = 1
)

type UnionNullDouble 

type UnionNullDouble struct {
	Null      *types.NullVal
	Double    float64
	UnionType UnionNullDoubleTypeEnum
}

func NewUnionNullDouble 

func NewUnionNullDouble() *UnionNullDouble

func (*UnionNullDouble) AppendArray 

func (_ *UnionNullDouble) AppendArray() types.Field

func (*UnionNullDouble) AppendMap 

func (_ *UnionNullDouble) AppendMap(key string) types.Field

func (*UnionNullDouble) Finalize 

func (_ *UnionNullDouble) Finalize()

func (*UnionNullDouble) Get 

func (r *UnionNullDouble) Get(i int) types.Field

func (*UnionNullDouble) SetBoolean 

func (_ *UnionNullDouble) SetBoolean(v bool)

func (*UnionNullDouble) SetBytes 

func (_ *UnionNullDouble) SetBytes(v []byte)

func (*UnionNullDouble) SetDefault 

func (_ *UnionNullDouble) SetDefault(i int)

func (*UnionNullDouble) SetDouble 

func (_ *UnionNullDouble) SetDouble(v float64)

func (*UnionNullDouble) SetFloat 

func (_ *UnionNullDouble) SetFloat(v float32)

func (*UnionNullDouble) SetInt 

func (_ *UnionNullDouble) SetInt(v int32)

func (*UnionNullDouble) SetLong 

func (r *UnionNullDouble) SetLong(v int64)

func (*UnionNullDouble) SetString 

func (_ *UnionNullDouble) SetString(v string)

type UnionNullDoubleTypeEnum 

type UnionNullDoubleTypeEnum int
const (
	UnionNullDoubleTypeEnumNull   UnionNullDoubleTypeEnum = 0
	UnionNullDoubleTypeEnumDouble UnionNullDoubleTypeEnum = 1
)

type UnionNullInt 

type UnionNullInt struct {
	Null      *types.NullVal
	Int       int32
	UnionType UnionNullIntTypeEnum
}

func NewUnionNullInt 

func NewUnionNullInt() *UnionNullInt

func (*UnionNullInt) AppendArray 

func (_ *UnionNullInt) AppendArray() types.Field

func (*UnionNullInt) AppendMap 

func (_ *UnionNullInt) AppendMap(key string) types.Field

func (*UnionNullInt) Finalize 

func (_ *UnionNullInt) Finalize()

func (*UnionNullInt) Get 

func (r *UnionNullInt) Get(i int) types.Field

func (*UnionNullInt) SetBoolean 

func (_ *UnionNullInt) SetBoolean(v bool)

func (*UnionNullInt) SetBytes 

func (_ *UnionNullInt) SetBytes(v []byte)

func (*UnionNullInt) SetDefault 

func (_ *UnionNullInt) SetDefault(i int)

func (*UnionNullInt) SetDouble 

func (_ *UnionNullInt) SetDouble(v float64)

func (*UnionNullInt) SetFloat 

func (_ *UnionNullInt) SetFloat(v float32)

func (*UnionNullInt) SetInt 

func (_ *UnionNullInt) SetInt(v int32)

func (*UnionNullInt) SetLong 

func (r *UnionNullInt) SetLong(v int64)

func (*UnionNullInt) SetString 

func (_ *UnionNullInt) SetString(v string)

type UnionNullIntTypeEnum 

type UnionNullIntTypeEnum int
const (
	UnionNullIntTypeEnumNull UnionNullIntTypeEnum = 0
	UnionNullIntTypeEnumInt  UnionNullIntTypeEnum = 1
)

type UnionNullString 

type UnionNullString struct {
	Null      *types.NullVal
	String    string
	UnionType UnionNullStringTypeEnum
}

func NewUnionNullString 

func NewUnionNullString() *UnionNullString

func (*UnionNullString) AppendArray 

func (_ *UnionNullString) AppendArray() types.Field

func (*UnionNullString) AppendMap 

func (_ *UnionNullString) AppendMap(key string) types.Field

func (*UnionNullString) Finalize 

func (_ *UnionNullString) Finalize()

func (*UnionNullString) Get 

func (r *UnionNullString) Get(i int) types.Field

func (*UnionNullString) SetBoolean 

func (_ *UnionNullString) SetBoolean(v bool)

func (*UnionNullString) SetBytes 

func (_ *UnionNullString) SetBytes(v []byte)

func (*UnionNullString) SetDefault 

func (_ *UnionNullString) SetDefault(i int)

func (*UnionNullString) SetDouble 

func (_ *UnionNullString) SetDouble(v float64)

func (*UnionNullString) SetFloat 

func (_ *UnionNullString) SetFloat(v float32)

func (*UnionNullString) SetInt 

func (_ *UnionNullString) SetInt(v int32)

func (*UnionNullString) SetLong 

func (r *UnionNullString) SetLong(v int64)

func (*UnionNullString) SetString 

func (_ *UnionNullString) SetString(v string)

type UnionNullStringTypeEnum 

type UnionNullStringTypeEnum int
const (
	UnionNullStringTypeEnumNull   UnionNullStringTypeEnum = 0
	UnionNullStringTypeEnumString UnionNullStringTypeEnum = 1
)

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.
JackTT - Gopher 🇻🇳