tdcp

Documentation

Index

• func AbsDuration(d time.Duration) time.Duration
• func FilterEpochs(epochs []observation.Epoch, config gnssconfig.Config) ([]observation.Epoch, error)
• func Prepare(epochs []observation.Epoch, ephStore *ephemeris.EphemerisStore, ...) ([]state.SatelliteStateMap, error)
• type CartesianDelta
• type GeodeticDelta
• type Input
• type Output
  • func Calculate(epochs []observation.Epoch, ssm []state.SatelliteStateMap, ...) ([]Output, error)
  • func Process(epochs []observation.Epoch, ephStore *ephemeris.EphemerisStore, ...) ([]Output, error)
• type TDCP
  • func NewTDCP(config gnssconfig.Config) *TDCP
  • func (tdcp *TDCP) Close()
  • func (tdcp *TDCP) Run()
• type Velocity
  • func (r *Velocity) Decode(data []byte) (interface{}, error)
  • func (r *Velocity) Encode(value interface{}) ([]byte, error)
  • func (r *Velocity) WriteJSON(w io.Writer) error

Functions

func AbsDuration

func AbsDuration(d time.Duration) time.Duration

Helper function to get the absolute value of a time.Duration

func FilterEpochs

func FilterEpochs(epochs []observation.Epoch, config gnssconfig.Config) ([]observation.Epoch, error)

func Prepare

func Prepare(epochs []observation.Epoch, ephStore *ephemeris.EphemerisStore, config gnssconfig.Config) ([]state.SatelliteStateMap, error)

Types

type CartesianDelta

type CartesianDelta struct {
	X float64 `json:"x"`
	Y float64 `json:"y"`
	Z float64 `json:"z"`
}

type GeodeticDelta

type GeodeticDelta struct {
	E float64 `json:"e"`
	N float64 `json:"n"`
	U float64 `json:"u"`
}

type Input

type Input struct {
	Type    string      `json:"type"`    // "configuration", "ephemeris", "observation"
	Payload interface{} `json:"payload"` // The actual data (Metadata, Ephemeris, Epoch)
}

Input represents the input data structure for the TDCP

type Output

type Output struct {
	Type    string      `json:"type"`    // "velocity", "metrics"
	Payload interface{} `json:"payload"` // The actual velocity or metrics data
}

Output represents the output data structure for the TDCP

func Calculate

func Calculate(epochs []observation.Epoch, ssm []state.SatelliteStateMap, config gnssconfig.Config) ([]Output, error)

CalculateTDCP calculates the TDCP for the two epochs.

func Process

func Process(epochs []observation.Epoch, ephStore *ephemeris.EphemerisStore, config *gnssconfig.Config) ([]Output, error)

Process calculates the TDCP for the two epochs.

type TDCP

type TDCP struct {
	Config         gnssconfig.Config
	InputChan      chan Input
	OutputChan     chan Output
	Epochs         []observation.Epoch
	Ephemeris      *ephemeris.EphemerisStore
	SatelliteState []state.SatelliteStateMap
}

TDCP is a struct that contains the data channels and the metadata, ephemeris, and epochs

func NewTDCP

func NewTDCP(config gnssconfig.Config) *TDCP

NewTDCP creates a new TDCP

func (*TDCP) Close

func (tdcp *TDCP) Close()

Close closes the data and results channels

func (*TDCP) Run

func (tdcp *TDCP) Run()

Run runs the TDCP

type Velocity

type Velocity struct {
	StreamID       string         `json:"stream_id"`
	Timestamp      time.Time      `json:"timestamp"`
	SatelliteCount int            `json:"satellite_count"`
	TimeDelta      time.Duration  `json:"time_delta"`
	ClockOffset    float64        `json:"clock_offset"`
	GeodeticDelta  GeodeticDelta  `json:"geodetic_delta"`
	CartesianDelta CartesianDelta `json:"cartesian_delta"`
}

func (*Velocity) Decode

func (r *Velocity) Decode(data []byte) (interface{}, error)

func (*Velocity) Encode

func (r *Velocity) Encode(value interface{}) ([]byte, error)

func (*Velocity) WriteJSON

func (r *Velocity) WriteJSON(w io.Writer) error