car

Documentation

Index

• Constants
• type CarProcessor
  • func NewCarProcessor(opts ...CarProcessorOption) *CarProcessor
  • func (p *CarProcessor) ProcessCarPayload(payload *racestatev1.PublishDriverDataRequest)
  • func (p *CarProcessor) ProcessStatePayload(payload *racestatev1.PublishStateRequest)
  • func (p *CarProcessor) ProcessStatePayloads(payloads []*racestatev1.PublishStateRequest)
• type CarProcessorOption

Constants

const OUT_THRESHOLD = 60.0

Types

type CarProcessor

type CarProcessor struct {
	ByCarIdx           map[uint32]*carv1.CarEntry
	ByCarNum           map[string]*carv1.CarEntry
	ComputeState       map[string]*analysisv1.CarComputeState
	StintLookup        map[string]*analysisv1.CarStint
	PitLookup          map[string]*analysisv1.CarPit
	CarOccupancyLookup map[string]*analysisv1.CarOccupancy
	NumByIdx           map[uint32]string
	CurrentDrivers     map[uint32]string
	CarClasses         []*carv1.CarClass
}

func NewCarProcessor

func NewCarProcessor(opts ...CarProcessorOption) *CarProcessor

func (*CarProcessor) ProcessCarPayload

func (p *CarProcessor) ProcessCarPayload(payload *racestatev1.PublishDriverDataRequest)

gets called when a new car state is arrived via grpc

func (*CarProcessor) ProcessStatePayload

func (p *CarProcessor) ProcessStatePayload(payload *racestatev1.PublishStateRequest)

gets called when a state message is received via "...live.state" topic

func (*CarProcessor) ProcessStatePayloads

func (p *CarProcessor) ProcessStatePayloads(payloads []*racestatev1.PublishStateRequest)

gets called when multiple state message are available and needs to be processed (mainly in tests)

type CarProcessorOption

type CarProcessorOption func(cp *CarProcessor)