analysis

Documentation

Index

• Constants
• func NewServer(opts ...Option) *analysisServer
• func RecomputeAnalysis(ctx context.Context, repos api.Repositories, eventData *eventv1.Event) (*analysisv1.Analysis, error)
• type Option
  • func WithPermissionEvaluator(pe permission.PermissionEvaluator) Option
  • func WithRepositories(r api.Repositories) Option
  • func WithTracer(tracer trace.Tracer) Option
  • func WithTransactionManager(txMgr api.TransactionManager) Option
• type ReplayDataProvider
• type ReplayOption
  • func WithDriverDataCallback(cb func(*racestatev1.PublishDriverDataRequest)) ReplayOption
  • func WithStateCallback(cb func(*racestatev1.PublishStateRequest)) ReplayOption
• type ReplayTask
  • func NewReplayTask(dataProvider ReplayDataProvider, opts ...ReplayOption) *ReplayTask
  • func (r *ReplayTask) Replay() error

Constants

const (
	DriverData providerType = "DriverData"
	StateData  providerType = "StateData"
)

Functions

func NewServer

func NewServer(opts ...Option) *analysisServer

func RecomputeAnalysis

func RecomputeAnalysis(
	ctx context.Context,
	repos api.Repositories,
	eventData *eventv1.Event,
) (*analysisv1.Analysis, error)

Types

type Option

type Option func(*analysisServer)

func WithPermissionEvaluator

func WithPermissionEvaluator(pe permission.PermissionEvaluator) Option

func WithRepositories

func WithRepositories(r api.Repositories) Option

func WithTracer

func WithTracer(tracer trace.Tracer) Option

func WithTransactionManager

func WithTransactionManager(txMgr api.TransactionManager) Option

type ReplayDataProvider

type ReplayDataProvider interface {
	NextDriverData() *racestatev1.PublishDriverDataRequest
	NextStateData() *racestatev1.PublishStateRequest
}

type ReplayOption

type ReplayOption func(*ReplayTask)

func WithDriverDataCallback

func WithDriverDataCallback(cb func(*racestatev1.PublishDriverDataRequest)) ReplayOption

func WithStateCallback

func WithStateCallback(cb func(*racestatev1.PublishStateRequest)) ReplayOption

type ReplayTask

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

func NewReplayTask

func NewReplayTask(dataProvider ReplayDataProvider, opts ...ReplayOption) *ReplayTask

func (*ReplayTask) Replay

func (r *ReplayTask) Replay() error