processing

Documentation

Index

• type Processor
  • func NewProcessor(opts ...ProcessorOption) *Processor
  • func (p *Processor) ProcessCarData(payload *racestatev1.PublishDriverDataRequest)
  • func (p *Processor) ProcessSpeedmap(payload *racestatev1.PublishSpeedmapRequest)
  • func (p *Processor) ProcessState(payload *racestatev1.PublishStateRequest)
• type ProcessorOption
  • func WithCarProcessor(carProcessor *car.CarProcessor) ProcessorOption
  • func WithPublishChannels(analysisChan chan *analysisv1.Analysis, ...) ProcessorOption

Types

type Processor

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

func NewProcessor

func NewProcessor(opts ...ProcessorOption) *Processor

func (*Processor) ProcessCarData

func (p *Processor) ProcessCarData(payload *racestatev1.PublishDriverDataRequest)

func (*Processor) ProcessSpeedmap

func (p *Processor) ProcessSpeedmap(payload *racestatev1.PublishSpeedmapRequest)

actually, there is no real processing here, just forwarding to broadcaster

func (*Processor) ProcessState

func (p *Processor) ProcessState(payload *racestatev1.PublishStateRequest)

type ProcessorOption

type ProcessorOption func(proc *Processor)

func WithCarProcessor

func WithCarProcessor(carProcessor *car.CarProcessor) ProcessorOption

func WithPublishChannels

func WithPublishChannels(
	analysisChan chan *analysisv1.Analysis,
	racestateChan chan *racestatev1.PublishStateRequest,
	driverDataChan chan *racestatev1.PublishDriverDataRequest,
	speedmapChan chan *racestatev1.PublishSpeedmapRequest,
) ProcessorOption