proto

Documentation

Index

• func Create(ctx context.Context, conn repository.Querier, rsInfoId int, ...) error
• func DeleteByEventId(ctx context.Context, conn repository.Querier, eventId int) (int, error)
• func LoadLatest(ctx context.Context, conn repository.Querier, eventId int) (*racestatev1.PublishSpeedmapRequest, error)
• func LoadRange(ctx context.Context, conn repository.Querier, eventId int, startTS time.Time, ...) (*util.RangeContainer[racestatev1.PublishSpeedmapRequest], error)
• func LoadRangeBySessionTime(ctx context.Context, conn repository.Querier, eventId int, sessionTime float64, ...) (*util.RangeContainer[racestatev1.PublishSpeedmapRequest], error)
• func LoadSnapshots(ctx context.Context, conn repository.Querier, eventId int, intervalSecs int) ([]*analysisv1.SnapshotData, error)

Functions

func Create

func Create(
	ctx context.Context,
	conn repository.Querier,
	rsInfoId int,
	speedmap *racestatev1.PublishSpeedmapRequest,
) error

func DeleteByEventId

func DeleteByEventId(ctx context.Context, conn repository.Querier, eventId int) (int, error)

deletes an entry from the database, returns number of rows deleted.

func LoadLatest

func LoadLatest(
	ctx context.Context,
	conn repository.Querier,
	eventId int,
) (*racestatev1.PublishSpeedmapRequest, error)

func LoadRange

func LoadRange(
	ctx context.Context,
	conn repository.Querier,
	eventId int,
	startTS time.Time,
	limit int,
) (*util.RangeContainer[racestatev1.PublishSpeedmapRequest], error)

func LoadRangeBySessionTime

func LoadRangeBySessionTime(
	ctx context.Context,
	conn repository.Querier,
	eventId int,
	sessionTime float64,
	limit int,
) (*util.RangeContainer[racestatev1.PublishSpeedmapRequest], error)

func LoadSnapshots

func LoadSnapshots(
	ctx context.Context,
	conn repository.Querier,
	eventId int,
	intervalSecs int,
) ([]*analysisv1.SnapshotData, error)