processing

Documentation

Index

• type Processor
  • func NewProcessor(opts ...ProcessorOption) *Processor
  • func (p *Processor) GetCombinedPatchData() *model.AnalysisDataWithPatches
  • func (p *Processor) GetData() *model.AnalysisData
  • func (p *Processor) ProcessAnalysisData(analysisData *model.AnalysisData)
  • func (p *Processor) ProcessCarData(carMsg *model.CarData)
  • func (p *Processor) ProcessState(stateMsg *model.StateData)
• type ProcessorOption
  • func WithCarProcessor(carProcessor *car.CarProcessor) ProcessorOption
  • func WithManifests(manifests *model.Manifests, raceSession int) ProcessorOption

Types

type Processor

type Processor struct {
	Manifests   *model.Manifests
	CurrentData *model.AnalysisData

	ReplayInfo   model.ReplayInfo
	CombinedData model.AnalysisDataWithPatches
	// contains filtered or unexported fields
}

func NewProcessor

func NewProcessor(opts ...ProcessorOption) *Processor

func (*Processor) GetCombinedPatchData

func (p *Processor) GetCombinedPatchData() *model.AnalysisDataWithPatches

func (*Processor) GetData

func (p *Processor) GetData() *model.AnalysisData

func (*Processor) ProcessAnalysisData

func (p *Processor) ProcessAnalysisData(analysisData *model.AnalysisData)

takes analysis data and initializes the carProcessor and raceProcessor with it Note: this is called by webfrontend when connecting to an existing event The processor is already initialized with manifests and CarPayload.

func (*Processor) ProcessCarData

func (p *Processor) ProcessCarData(carMsg *model.CarData)

func (*Processor) ProcessState

func (p *Processor) ProcessState(stateMsg *model.StateData)

ProcessState processes the given stateMsg

type ProcessorOption

type ProcessorOption func(proc *Processor)

func WithCarProcessor

func WithCarProcessor(carProcessor *car.CarProcessor) ProcessorOption

func WithManifests

func WithManifests(manifests *model.Manifests, raceSession int) ProcessorOption

entry point for ism when registering a new event. carProcessor and raceProcessor are created here