db

package
v0.0.0-...-c9cfaf6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 5, 2020 License: BSD-3-Clause Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Benchmark 

type Benchmark struct {
	UUID        uuid.UUID
	PackageUUID uuid.UUID
	FullName    string
	Name        string
	Unit        string
	Parameters  json.RawMessage
}

type BenchmarkPointsParams 

type BenchmarkPointsParams struct {
	BenchmarkUUID  uuid.UUID
	CommitIndexMin int32
	CommitIndexMax int32
}

type BenchmarkPointsRow 

type BenchmarkPointsRow struct {
	ResultUUID      uuid.UUID
	EnvironmentUUID uuid.UUID
	CommitSHA       []byte
	CommitIndex     int32
	Value           float64
}

type Change 

type Change struct {
	BenchmarkUUID   uuid.UUID
	EnvironmentUUID uuid.UUID
	CommitIndex     int32
	EffectSize      float64
	PreN            int32
	PreMean         float64
	PreStddev       float64
	PostN           int32
	PostMean        float64
	PostStddev      float64
}

type ChangeSummariesParams 

type ChangeSummariesParams struct {
	EffectSizeMin             float64
	CommitIndexMin            int32
	CommitIndexMax            int32
	RankByEffectSizeMax       int32
	RankByAbsPercentChangeMax int32
}

type ChangeSummariesRow 

type ChangeSummariesRow struct {
	BenchmarkUUID          uuid.UUID
	EnvironmentUUID        uuid.UUID
	CommitIndex            int32
	EffectSize             float64
	PreN                   int32
	PreMean                float64
	PreStddev              float64
	PostN                  int32
	PostMean               float64
	PostStddev             float64
	RankByEffectSize       int32
	RankByAbsPercentChange int32
	CommitSHA              []byte
	CommitSubject          string
	UUID                   uuid.UUID
	PackageUUID            uuid.UUID
	FullName               string
	Name                   string
	Unit                   string
	Parameters             json.RawMessage
	RelativePath           string
	Path                   string
	Version                string
}

type ChangesRanked 

type ChangesRanked struct {
	BenchmarkUUID          uuid.UUID
	EnvironmentUUID        uuid.UUID
	CommitIndex            int32
	EffectSize             float64
	PreN                   int32
	PreMean                float64
	PreStddev              float64
	PostN                  int32
	PostMean               float64
	PostStddev             float64
	RankByEffectSize       int32
	RankByAbsPercentChange int32
}

type Commit 

type Commit struct {
	SHA            []byte
	Tree           []byte
	Parents        pq.ByteaArray
	AuthorName     string
	AuthorEmail    string
	AuthorTime     time.Time
	CommitterName  string
	CommitterEmail string
	CommitTime     time.Time
	Message        string
}

type CommitModuleWorkerErrorsParams 

type CommitModuleWorkerErrorsParams struct {
	Worker            string
	MaxErrors         int32
	LastAttemptBefore time.Time
	Num               int32
}

type CommitModuleWorkerErrorsRow 

type CommitModuleWorkerErrorsRow struct {
	ModuleUUID      uuid.UUID
	CommitSHA       []byte
	NumErrors       int64
	LastAttemptTime time.Time
}

type CommitPosition 

type CommitPosition struct {
	SHA        []byte
	CommitTime time.Time
	Index      int32
}

type CommitRef 

type CommitRef struct {
	SHA []byte
	Ref string
}

type CreateTaskParams 

type CreateTaskParams struct {
	UUID       uuid.UUID
	Worker     string
	CommitSHA  []byte
	Type       TaskType
	TargetUUID uuid.UUID
}

type DBTX 

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type Datafile 

type Datafile struct {
	UUID   uuid.UUID
	Name   string
	SHA256 []byte
}

type DeleteChangesCommitRangeParams 

type DeleteChangesCommitRangeParams struct {
	CommitIndexMin int32
	CommitIndexMax int32
}

type InsertBenchmarkParams 

type InsertBenchmarkParams struct {
	UUID        uuid.UUID
	PackageUUID uuid.UUID
	FullName    string
	Name        string
	Unit        string
	Parameters  json.RawMessage
}

type InsertCommitParams 

type InsertCommitParams struct {
	SHA            []byte
	Tree           []byte
	Parents        pq.ByteaArray
	AuthorName     string
	AuthorEmail    string
	AuthorTime     time.Time
	CommitterName  string
	CommitterEmail string
	CommitTime     time.Time
	Message        string
}

type InsertCommitPositionParams 

type InsertCommitPositionParams struct {
	SHA        []byte
	CommitTime time.Time
	Index      int32
}

type InsertCommitRefParams 

type InsertCommitRefParams struct {
	SHA []byte
	Ref string
}

type InsertDataFileParams 

type InsertDataFileParams struct {
	UUID   uuid.UUID
	Name   string
	SHA256 []byte
}

type InsertModuleParams 

type InsertModuleParams struct {
	UUID    uuid.UUID
	Path    string
	Version string
}

type InsertPkgParams 

type InsertPkgParams struct {
	UUID         uuid.UUID
	ModuleUUID   uuid.UUID
	RelativePath string
}

type InsertPropertiesParams 

type InsertPropertiesParams struct {
	UUID   uuid.UUID
	Fields json.RawMessage
}

type InsertResultParams 

type InsertResultParams struct {
	UUID            uuid.UUID
	DatafileUUID    uuid.UUID
	Line            int32
	BenchmarkUUID   uuid.UUID
	CommitSHA       []byte
	EnvironmentUUID uuid.UUID
	MetadataUUID    uuid.UUID
	Iterations      int64
	Value           float64
}

type Module 

type Module struct {
	UUID    uuid.UUID
	Path    string
	Version string
}

type Package 

type Package struct {
	UUID         uuid.UUID
	ModuleUUID   uuid.UUID
	RelativePath string
}

type Point 

type Point struct {
	ResultUUID      uuid.UUID
	BenchmarkUUID   uuid.UUID
	EnvironmentUUID uuid.UUID
	CommitSHA       []byte
	CommitIndex     int32
	Value           float64
}

type Property 

type Property struct {
	UUID   uuid.UUID
	Fields json.RawMessage
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func Prepare 

func Prepare(ctx context.Context, db DBTX) (*Queries, error)

func (*Queries) Benchmark 

func (q *Queries) Benchmark(ctx context.Context, uuid uuid.UUID) (Benchmark, error)

func (*Queries) BenchmarkPoints 

func (q *Queries) BenchmarkPoints(ctx context.Context, arg BenchmarkPointsParams) ([]BenchmarkPointsRow, error)

func (*Queries) BenchmarkResults 

func (q *Queries) BenchmarkResults(ctx context.Context, benchmarkUuid uuid.UUID) ([]Result, error)

func (*Queries) BuildChangesRanked 

func (q *Queries) BuildChangesRanked(ctx context.Context) error

func (*Queries) BuildCommitPositions 

func (q *Queries) BuildCommitPositions(ctx context.Context) error

func (*Queries) ChangeSummaries 

func (q *Queries) ChangeSummaries(ctx context.Context, arg ChangeSummariesParams) ([]ChangeSummariesRow, error)

func (*Queries) Close 

func (q *Queries) Close() error

func (*Queries) Commit 

func (q *Queries) Commit(ctx context.Context, sha []byte) (Commit, error)

func (*Queries) CommitIndexForSHA 

func (q *Queries) CommitIndexForSHA(ctx context.Context, sha []byte) (int32, error)

func (*Queries) CommitModuleWorkerErrors 

func (q *Queries) CommitModuleWorkerErrors(ctx context.Context, arg CommitModuleWorkerErrorsParams) ([]CommitModuleWorkerErrorsRow, error)

func (*Queries) CreateTask 

func (q *Queries) CreateTask(ctx context.Context, arg CreateTaskParams) (Task, error)

func (*Queries) DataFile 

func (q *Queries) DataFile(ctx context.Context, uuid uuid.UUID) (Datafile, error)

func (*Queries) DeleteChangesCommitRange 

func (q *Queries) DeleteChangesCommitRange(ctx context.Context, arg DeleteChangesCommitRangeParams) error

func (*Queries) InsertBenchmark 

func (q *Queries) InsertBenchmark(ctx context.Context, arg InsertBenchmarkParams) error

func (*Queries) InsertCommit 

func (q *Queries) InsertCommit(ctx context.Context, arg InsertCommitParams) error

func (*Queries) InsertCommitPosition 

func (q *Queries) InsertCommitPosition(ctx context.Context, arg InsertCommitPositionParams) error

func (*Queries) InsertCommitRef 

func (q *Queries) InsertCommitRef(ctx context.Context, arg InsertCommitRefParams) error

func (*Queries) InsertDataFile 

func (q *Queries) InsertDataFile(ctx context.Context, arg InsertDataFileParams) error

func (*Queries) InsertModule 

func (q *Queries) InsertModule(ctx context.Context, arg InsertModuleParams) error

func (*Queries) InsertPkg 

func (q *Queries) InsertPkg(ctx context.Context, arg InsertPkgParams) error

func (*Queries) InsertProperties 

func (q *Queries) InsertProperties(ctx context.Context, arg InsertPropertiesParams) error

func (*Queries) InsertResult 

func (q *Queries) InsertResult(ctx context.Context, arg InsertResultParams) error

func (*Queries) Module 

func (q *Queries) Module(ctx context.Context, uuid uuid.UUID) (Module, error)

func (*Queries) ModulePkgs 

func (q *Queries) ModulePkgs(ctx context.Context, moduleUuid uuid.UUID) ([]Package, error)

func (*Queries) Modules 

func (q *Queries) Modules(ctx context.Context) ([]Module, error)

func (*Queries) MostRecentCommit 

func (q *Queries) MostRecentCommit(ctx context.Context) (Commit, error)

func (*Queries) MostRecentCommitIndex 

func (q *Queries) MostRecentCommitIndex(ctx context.Context) (int32, error)

func (*Queries) MostRecentCommitWithRef 

func (q *Queries) MostRecentCommitWithRef(ctx context.Context, ref string) (Commit, error)

func (*Queries) PackageBenchmarks 

func (q *Queries) PackageBenchmarks(ctx context.Context, packageUuid uuid.UUID) ([]Benchmark, error)

func (*Queries) Pkg 

func (q *Queries) Pkg(ctx context.Context, uuid uuid.UUID) (Package, error)

func (*Queries) Properties 

func (q *Queries) Properties(ctx context.Context, uuid uuid.UUID) (Property, error)

func (*Queries) RecentCommitModulePairsWithoutWorkerTasks 

func (q *Queries) RecentCommitModulePairsWithoutWorkerTasks(ctx context.Context, arg RecentCommitModulePairsWithoutWorkerTasksParams) ([]RecentCommitModulePairsWithoutWorkerTasksRow, error)

func (*Queries) Result 

func (q *Queries) Result(ctx context.Context, uuid uuid.UUID) (Result, error)

func (*Queries) SetTaskDataFile 

func (q *Queries) SetTaskDataFile(ctx context.Context, arg SetTaskDataFileParams) error

func (*Queries) Task 

func (q *Queries) Task(ctx context.Context, uuid uuid.UUID) (Task, error)

func (*Queries) TasksWithStatus 

func (q *Queries) TasksWithStatus(ctx context.Context, statuses []TaskStatus) ([]Task, error)

func (*Queries) Trace 

func (q *Queries) Trace(ctx context.Context, arg TraceParams) ([]TraceRow, error)

func (*Queries) TracePoints 

func (q *Queries) TracePoints(ctx context.Context, arg TracePointsParams) ([]TracePointsRow, error)

func (*Queries) TransitionTaskStatus 

func (q *Queries) TransitionTaskStatus(ctx context.Context, arg TransitionTaskStatusParams) (TaskStatus, error)

func (*Queries) TransitionTaskStatusesBefore 

func (q *Queries) TransitionTaskStatusesBefore(ctx context.Context, arg TransitionTaskStatusesBeforeParams) error

func (*Queries) TruncateAll 

func (q *Queries) TruncateAll(ctx context.Context) error

func (*Queries) WithTx 

func (q *Queries) WithTx(tx *sql.Tx) *Queries

func (*Queries) WorkerTasksWithStatus 

func (q *Queries) WorkerTasksWithStatus(ctx context.Context, arg WorkerTasksWithStatusParams) ([]Task, error)

type RecentCommitModulePairsWithoutWorkerTasksParams 

type RecentCommitModulePairsWithoutWorkerTasksParams struct {
	Statuses []TaskStatus
	Worker   string
	Num      int32
}

type RecentCommitModulePairsWithoutWorkerTasksRow 

type RecentCommitModulePairsWithoutWorkerTasksRow struct {
	CommitSHA  []byte
	CommitTime time.Time
	ModuleUUID uuid.UUID
}

type Result 

type Result struct {
	UUID            uuid.UUID
	DatafileUUID    uuid.UUID
	Line            int32
	BenchmarkUUID   uuid.UUID
	CommitSHA       []byte
	EnvironmentUUID uuid.UUID
	MetadataUUID    uuid.UUID
	Iterations      int64
	Value           float64
}

type SetTaskDataFileParams 

type SetTaskDataFileParams struct {
	DatafileUUID uuid.UUID
	UUID         uuid.UUID
}

type Task 

type Task struct {
	UUID             uuid.UUID
	Worker           string
	CommitSHA        []byte
	Type             TaskType
	TargetUUID       uuid.UUID
	Status           TaskStatus
	LastStatusUpdate time.Time
	DatafileUUID     uuid.UUID
}

type TaskStatus 

type TaskStatus string
const (
	TaskStatusCreated             TaskStatus = "created"
	TaskStatusInProgress          TaskStatus = "in_progress"
	TaskStatusCompleteSuccess     TaskStatus = "complete_success"
	TaskStatusCompleteError       TaskStatus = "complete_error"
	TaskStatusResultUploadStarted TaskStatus = "result_upload_started"
	TaskStatusResultUploaded      TaskStatus = "result_uploaded"
	TaskStatusHalted              TaskStatus = "halted"
	TaskStatusStaleTimeout        TaskStatus = "stale_timeout"
)

func (*TaskStatus) Scan 

func (e *TaskStatus) Scan(src interface{}) error

type TaskType 

type TaskType string
const (
	TaskTypeModule TaskType = "module"
)

func (*TaskType) Scan 

func (e *TaskType) Scan(src interface{}) error

type TraceParams 

type TraceParams struct {
	BenchmarkUUID   uuid.UUID
	EnvironmentUUID uuid.UUID
	CommitIndexMin  int32
	CommitIndexMax  int32
}

type TracePointsParams 

type TracePointsParams struct {
	CommitIndexMin int32
	CommitIndexMax int32
}

type TracePointsRow 

type TracePointsRow struct {
	BenchmarkUUID   uuid.UUID
	EnvironmentUUID uuid.UUID
	CommitIndex     int32
	Value           float64
}

type TraceRow 

type TraceRow struct {
	CommitIndex int32
	Value       float64
}

type TransitionTaskStatusParams 

type TransitionTaskStatusParams struct {
	FromStatuses []TaskStatus
	ToStatus     TaskStatus
	UUID         uuid.UUID
}

type TransitionTaskStatusesBeforeParams 

type TransitionTaskStatusesBeforeParams struct {
	ToStatus     TaskStatus
	FromStatuses []TaskStatus
	Until        time.Time
}

type WorkerTasksWithStatusParams 

type WorkerTasksWithStatusParams struct {
	Worker   string
	Statuses []TaskStatus
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.