proxy

Feb 19, 2025

Changes in this version

type EventData

+ Owner string

Jan 26, 2025

Changes in this version

type EventData

+ func (e *EventData) Equals(other *EventData) bool

+ func (e *EventData) FromBinary(data []byte) error

+ func (e *EventData) ToBinary() ([]byte, error)

Jan 5, 2025

Changes in this version

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

+ type DataProxy interface

+ Close func()

+ GetEvent func(sel *commonv1.EventSelector) (*EventData, error)

+ HistorySnapshotData func(sel *commonv1.EventSelector) []*analysisv1.SnapshotData

+ LiveEvents func() []*EventData

+ SubscribeAnalysisData func(sel *commonv1.EventSelector) (dataChan <-chan *analysisv1.Analysis, quitChan chan<- struct{}, err error)

+ SubscribeDriverData func(sel *commonv1.EventSelector) (dataChan <-chan *livedatav1.LiveDriverDataResponse, quitChan chan<- struct{}, ...)

+ SubscribeRaceStateData func(sel *commonv1.EventSelector) (dataChan <-chan *racestatev1.PublishStateRequest, quitChan chan<- struct{}, ...)

+ SubscribeSnapshotData func(sel *commonv1.EventSelector) (dataChan <-chan *analysisv1.SnapshotData, quitChan chan<- struct{}, err error)

+ SubscribeSpeedmapData func(sel *commonv1.EventSelector) (dataChan <-chan *racestatev1.PublishSpeedmapRequest, quitChan chan<- struct{}, ...)

+ type EmptyProxy struct

+ func (e EmptyProxy) Close()

+ func (e EmptyProxy) GetEvent(sel *commonv1.EventSelector) (*EventData, error)

+ func (e EmptyProxy) HistorySnapshotData(sel *commonv1.EventSelector) []*analysisv1.SnapshotData

+ func (e EmptyProxy) LiveEvents() []*EventData

+ func (e EmptyProxy) PublishDriverData(req *racestatev1.PublishDriverDataRequest) error

+ func (e EmptyProxy) PublishEventRegistered(epd *utils.EventProcessingData) error

+ func (e EmptyProxy) PublishEventUnregistered(eventKey string) error

+ func (e EmptyProxy) PublishRaceStateData(req *racestatev1.PublishStateRequest) error

+ func (e EmptyProxy) PublishSpeedmapData(req *racestatev1.PublishSpeedmapRequest) error

+ func (e EmptyProxy) SubscribeAnalysisData(sel *commonv1.EventSelector) (d <-chan *analysisv1.Analysis, q chan<- struct{}, err error)

+ func (e EmptyProxy) SubscribeDriverData(sel *commonv1.EventSelector) (d <-chan *livedatav1.LiveDriverDataResponse, q chan<- struct{}, err error)

+ func (e EmptyProxy) SubscribeRaceStateData(sel *commonv1.EventSelector) (d <-chan *racestatev1.PublishStateRequest, q chan<- struct{}, err error)

+ func (e EmptyProxy) SubscribeSnapshotData(sel *commonv1.EventSelector) (d <-chan *analysisv1.SnapshotData, q chan<- struct{}, err error)

+ func (e EmptyProxy) SubscribeSpeedmapData(sel *commonv1.EventSelector) (d <-chan *racestatev1.PublishSpeedmapRequest, q chan<- struct{}, err error)

+ type EventData struct

+ Event *eventv1.Event

+ Track *trackv1.Track

+ type PublishProxy interface

+ PublishDriverData func(req *racestatev1.PublishDriverDataRequest) error

+ PublishEventRegistered func(epd *utils.EventProcessingData) error

+ PublishEventUnregistered func(eventKey string) error

+ PublishRaceStateData func(req *racestatev1.PublishStateRequest) error

+ PublishSpeedmapData func(req *racestatev1.PublishSpeedmapRequest) error