local

Documentation

Index

• type LocalProxy
  • func NewLocalProxy(lookup *utils.EventLookup, opts ...Option) *LocalProxy
  • func (l *LocalProxy) DeleteEventCallback(eventKey string)
  • func (l *LocalProxy) GetEvent(sel *commonv1.EventSelector) (*proxy.EventData, error)
  • func (l *LocalProxy) HistorySnapshotData(sel *commonv1.EventSelector) []*analysisv1.SnapshotData
  • func (l *LocalProxy) LiveEvents() []*proxy.EventData
  • func (e *LocalProxy) PublishDriverData(req *racestatev1.PublishDriverDataRequest) error
  • func (l *LocalProxy) PublishEventRegistered(epd *utils.EventProcessingData) error
  • func (l *LocalProxy) PublishEventUnregistered(eventKey string) error
  • func (e *LocalProxy) PublishRaceStateData(req *racestatev1.PublishStateRequest) error
  • func (e *LocalProxy) PublishSpeedmapData(req *racestatev1.PublishSpeedmapRequest) error
  • func (l *LocalProxy) SubscribeAnalysisData(sel *commonv1.EventSelector) (d <-chan *analysisv1.Analysis, q chan<- struct{}, err error)
  • func (l *LocalProxy) SubscribeDriverData(sel *commonv1.EventSelector) (d <-chan *livedatav1.LiveDriverDataResponse, q chan<- struct{}, err error)
  • func (l *LocalProxy) SubscribeRaceStateData(sel *commonv1.EventSelector) (a <-chan *racestatev1.PublishStateRequest, b chan<- struct{}, e error)
  • func (l *LocalProxy) SubscribeSnapshotData(sel *commonv1.EventSelector) (d <-chan *analysisv1.SnapshotData, q chan<- struct{}, err error)
  • func (l *LocalProxy) SubscribeSpeedmapData(sel *commonv1.EventSelector) (d <-chan *racestatev1.PublishSpeedmapRequest, q chan<- struct{}, err error)
• type Option
  • func WithLogger(arg *log.Logger) Option

Types

type LocalProxy

type LocalProxy struct {
	proxy.EmptyProxy
	// contains filtered or unexported fields
}

DataProxy implementation based on local EventLookup

func NewLocalProxy

func NewLocalProxy(lookup *utils.EventLookup, opts ...Option) *LocalProxy

NewLocalProxy creates a new LocalPubSub

func (*LocalProxy) DeleteEventCallback

func (l *LocalProxy) DeleteEventCallback(eventKey string)

this method is called when the watchdog detects a stale event and deletes it

func (*LocalProxy) GetEvent

func (l *LocalProxy) GetEvent(sel *commonv1.EventSelector) (*proxy.EventData, error)

func (*LocalProxy) HistorySnapshotData

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

func (*LocalProxy) LiveEvents

func (l *LocalProxy) LiveEvents() []*proxy.EventData

func (*LocalProxy) PublishDriverData

func (e *LocalProxy) PublishDriverData(req *racestatev1.PublishDriverDataRequest) error

func (*LocalProxy) PublishEventRegistered

func (l *LocalProxy) PublishEventRegistered(epd *utils.EventProcessingData) error

func (*LocalProxy) PublishEventUnregistered

func (l *LocalProxy) PublishEventUnregistered(eventKey string) error

func (*LocalProxy) PublishRaceStateData

func (e *LocalProxy) PublishRaceStateData(req *racestatev1.PublishStateRequest) error

func (*LocalProxy) PublishSpeedmapData

func (e *LocalProxy) PublishSpeedmapData(req *racestatev1.PublishSpeedmapRequest) error

func (*LocalProxy) SubscribeAnalysisData

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

func (*LocalProxy) SubscribeDriverData

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

func (*LocalProxy) SubscribeRaceStateData

func (l *LocalProxy) SubscribeRaceStateData(sel *commonv1.EventSelector) (
	a <-chan *racestatev1.PublishStateRequest,
	b chan<- struct{},
	e error,
)

func (*LocalProxy) SubscribeSnapshotData

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

func (*LocalProxy) SubscribeSpeedmapData

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

type Option

type Option func(*LocalProxy)

DataProxy implementation based on local EventLookup

func WithLogger

func WithLogger(arg *log.Logger) Option