utils

Documentation

Index

• Variables
• func ExtractFromDBUrl(url string) string
• func ExtractFromWebsocketUrl(url string) (addr, proto string)
• func WaitForHttpResponse(url string, timeout time.Duration) error
• func WaitForTCP(addr string, timeout time.Duration) error
• type EventLookup
  • func NewEventLookup() *EventLookup
  • func (e *EventLookup) AddEvent(event *eventv1.Event, track *trackv1.Track, ...) *EventProcessingData
  • func (e *EventLookup) Clear()
  • func (e *EventLookup) GetEvent(selector *commonv1.EventSelector) (*EventProcessingData, error)
  • func (e *EventLookup) GetEvents() []*EventProcessingData
  • func (e *EventLookup) RemoveEvent(selector *commonv1.EventSelector)
• type EventProcessingData

Variables

var ErrEventNotFound = errors.New("event not found")

Functions

func ExtractFromDBUrl

func ExtractFromDBUrl(url string) string

func ExtractFromWebsocketUrl

func ExtractFromWebsocketUrl(url string) (addr, proto string)

func WaitForHttpResponse

func WaitForHttpResponse(url string, timeout time.Duration) error

func WaitForTCP

func WaitForTCP(addr string, timeout time.Duration) error

Types

type EventLookup

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

func NewEventLookup

func NewEventLookup() *EventLookup

func (*EventLookup) AddEvent

func (e *EventLookup) AddEvent(
	event *eventv1.Event,
	track *trackv1.Track,
	recordingMode providerev1.RecordingMode,
) *EventProcessingData

func (*EventLookup) Clear

func (e *EventLookup) Clear()

func (*EventLookup) GetEvent

func (e *EventLookup) GetEvent(selector *commonv1.EventSelector) (
	*EventProcessingData, error,
)

func (*EventLookup) GetEvents

func (e *EventLookup) GetEvents() []*EventProcessingData

func (*EventLookup) RemoveEvent

func (e *EventLookup) RemoveEvent(selector *commonv1.EventSelector)

type EventProcessingData

type EventProcessingData struct {
	Event               *eventv1.Event
	Track               *trackv1.Track
	Processor           *processing.Processor
	AnalysisBroadcast   broadcast.BroadcastServer[*analysisv1.Analysis]
	RacestateBroadcast  broadcast.BroadcastServer[*racestatev1.PublishStateRequest]
	DriverDataBroadcast broadcast.BroadcastServer[*racestatev1.PublishDriverDataRequest]
	SpeedmapBroadcast   broadcast.BroadcastServer[*racestatev1.PublishSpeedmapRequest]
	Mutex               sync.Mutex
	LastDriverData      *racestatev1.PublishDriverDataRequest
	LastAnalysisData    *analysisv1.Analysis
	RecordingMode       providerev1.RecordingMode
	LastRsInfoId        int // holds the last rs_info_id for storing state data
}