utils

Jun 23, 2024

Changes in this version

type EventLookup

+ func (e *EventLookup) Close()

type EventProcessingData

+ LastDataEvent time.Time

+ SnapshotBroadcast broadcast.BroadcastServer[*analysisv1.SnapshotData]

+ SnapshotData []*analysisv1.SnapshotData

+ func (epd *EventProcessingData) MarkDataEvent()

+ type Option func(*EventLookup)

+ func WithContext(ctx context.Context) Option

+ func WithStaleDuration(d time.Duration) Option

Jun 1, 2024

Changes in this version

type EventProcessingData

+ LastReplayInfo *eventv1.ReplayInfo

+ ReplayInfoBroadcast broadcast.BroadcastServer[*eventv1.ReplayInfo]

May 19, 2024

Changes in this version

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

+ type EventLookup struct

+ 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 struct

+ AnalysisBroadcast broadcast.BroadcastServer[*analysisv1.Analysis]

+ DriverDataBroadcast broadcast.BroadcastServer[*racestatev1.PublishDriverDataRequest]

+ Event *eventv1.Event

+ LastAnalysisData *analysisv1.Analysis

+ LastDriverData *racestatev1.PublishDriverDataRequest

+ LastRsInfoId int

+ Mutex sync.Mutex

+ Processor *processing.Processor

+ RacestateBroadcast broadcast.BroadcastServer[*racestatev1.PublishStateRequest]

+ RecordingMode providerev1.RecordingMode

+ SpeedmapBroadcast broadcast.BroadcastServer[*racestatev1.PublishSpeedmapRequest]

+ Track *trackv1.Track

Mar 25, 2023

Changes in this version

+ 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