service

Documentation

Index

• type AdminService
  • func InitAdminService(pool *pgxpool.Pool) *AdminService
  • func (s *AdminService) DeleteEvent(id int) error
• type CarService
  • func InitCarService(pool *pgxpool.Pool) *CarService
  • func (s *CarService) AddCar(entry *model.DbCar) error
• type Client
• type MetricRecorder
• type ProviderData
• type ProviderLookup
• type ProviderService
  • func InitProviderService(pool *pgxpool.Pool) *ProviderService
  • func (s *ProviderService) RegisterEvent(ctx context.Context, req *RegisterEventRequest) (*ProviderData, error)
  • func (s *ProviderService) StoreEventExtra(ctx context.Context, entry *model.DbEventExtra) error
  • func (s *ProviderService) UpdateAnalysisData(ctx context.Context, eventKey string) error
  • func (s *ProviderService) UpdateReplayInfo(ctx context.Context, eventKey string) error
• type RegisterEventRequest
• type SpeedmapService
  • func InitSpeedmapService(pool *pgxpool.Pool) *SpeedmapService
  • func (s *SpeedmapService) AddSpeedmap(ctx context.Context, entry *model.DbSpeedmap) error
• type StateService
  • func InitStateService(pool *pgxpool.Pool) *StateService
  • func (s *StateService) AddState(ctx context.Context, entry *model.DbState) error

Types

type AdminService

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

func InitAdminService

func InitAdminService(pool *pgxpool.Pool) *AdminService

func (*AdminService) DeleteEvent

func (s *AdminService) DeleteEvent(id int) error

type CarService

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

func InitCarService

func InitCarService(pool *pgxpool.Pool) *CarService

func (*CarService) AddCar

func (s *CarService) AddCar(entry *model.DbCar) error

type Client

type Client struct {
	WampClient *client.Client
	CancelFunc context.CancelFunc
}

contains informations about the connected Provider Client

type MetricRecorder

type MetricRecorder struct {
	Recorder   metric.Float64Histogram
	MsgCounter int
}

type ProviderData

type ProviderData struct {
	Event            *model.DbEvent
	Analysis         *model.DbAnalysis
	Registered       time.Time
	Clients          []*Client // currently not used
	ActiveClient     *Client
	Processor        *processing.Processor
	StopChan         chan struct{} // used to stop background tasks
	StateRecorder    MetricRecorder
	SpeedmapRecorder MetricRecorder
	AnalysisRecorder MetricRecorder
}

type ProviderLookup

type ProviderLookup map[string]*ProviderData

type ProviderService

type ProviderService struct {
	Lookup ProviderLookup
	// contains filtered or unexported fields
}

func InitProviderService

func InitProviderService(pool *pgxpool.Pool) *ProviderService

func (*ProviderService) RegisterEvent

func (s *ProviderService) RegisterEvent(
	ctx context.Context,
	req *RegisterEventRequest) (
	*ProviderData, error,
)

func (*ProviderService) StoreEventExtra

func (s *ProviderService) StoreEventExtra(
	ctx context.Context,
	entry *model.DbEventExtra,
) error

func (*ProviderService) UpdateAnalysisData

func (s *ProviderService) UpdateAnalysisData(
	ctx context.Context,
	eventKey string,
) error

func (*ProviderService) UpdateReplayInfo

func (s *ProviderService) UpdateReplayInfo(ctx context.Context, eventKey string) error

type RegisterEventRequest

type RegisterEventRequest struct {
	EventKey  string              `json:"eventKey"`
	Manifests model.Manifests     `json:"manifests"`
	EventInfo model.EventDataInfo `json:"info"`
	TrackInfo model.TrackInfo     `json:"trackInfo"`
}

type SpeedmapService

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

func InitSpeedmapService

func InitSpeedmapService(pool *pgxpool.Pool) *SpeedmapService

func (*SpeedmapService) AddSpeedmap

func (s *SpeedmapService) AddSpeedmap(
	ctx context.Context,
	entry *model.DbSpeedmap,
) error

type StateService

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

func InitStateService

func InitStateService(pool *pgxpool.Pool) *StateService

func (*StateService) AddState

func (s *StateService) AddState(ctx context.Context, entry *model.DbState) error