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(opts ...Option) *EventLookup
  • func (e *EventLookup) AddEvent(event *eventv1.Event, track *trackv1.Track, ...) *EventProcessingData
  • func (e *EventLookup) Clear()
  • func (e *EventLookup) Close()
  • func (e *EventLookup) GetEvent(selector *commonv1.EventSelector) (*EventProcessingData, error)
  • func (e *EventLookup) GetEvents() []*EventProcessingData
  • func (e *EventLookup) RemoveEvent(selector *commonv1.EventSelector)
• type EventProcessingData
  • func (epd *EventProcessingData) MarkDataEvent()
• type Option
  • func WithContext(ctx context.Context) Option
  • func WithStaleDuration(d time.Duration) Option

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(opts ...Option) *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()

removes all events from the lookup

func (*EventLookup) Close

func (e *EventLookup) Close()

removes all events and signals shutdown to internal services (for example: watchdogs)

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]
	ReplayInfoBroadcast broadcast.BroadcastServer[*eventv1.ReplayInfo]
	SnapshotBroadcast   broadcast.BroadcastServer[*analysisv1.SnapshotData]
	Mutex               sync.Mutex
	LastDriverData      *racestatev1.PublishDriverDataRequest
	LastAnalysisData    *analysisv1.Analysis
	LastReplayInfo      *eventv1.ReplayInfo
	RecordingMode       providerev1.RecordingMode
	LastRsInfoId        int                        // holds the last rs_info_id for storing state data
	LastDataEvent       time.Time                  // holds the time of the last incoming data event
	SnapshotData        []*analysisv1.SnapshotData // holds the snapshot data for current event
}

func (*EventProcessingData) MarkDataEvent

func (epd *EventProcessingData) MarkDataEvent()

type Option

type Option func(*EventLookup)

func WithContext

func WithContext(ctx context.Context) Option

func WithStaleDuration

func WithStaleDuration(d time.Duration) Option

if staleDuration > 0, a watchdog will be started to remove stale events