db

package
v0.0.0-...-7fcfa66 Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package db is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccessToken 

type AccessToken struct {
	ID                 uuid.UUID
	Name               string
	TokenHash          string
	Scopes             []AccessTokenScope
	IssuedAt           sql.NullTime
	ExpiresAt          sql.NullTime
	RevokedAt          sql.NullTime
	NamespaceSelectors []string
}

type AccessTokenScope 

type AccessTokenScope string
const (
	AccessTokenScopeAdmin   AccessTokenScope = "admin"
	AccessTokenScopeControl AccessTokenScope = "control"
	AccessTokenScopeData    AccessTokenScope = "data"
	AccessTokenScopeRunner  AccessTokenScope = "runner"
)

func (*AccessTokenScope) Scan 

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

type AppendLogsToRunParams 

type AppendLogsToRunParams struct {
	Logs pgtype.JSONB
	ID   uuid.UUID
}

type AssignRunParams 

type AssignRunParams struct {
	RunnerID uuid.UUID
	RunIDs   []uuid.UUID
}

type AuthAccessTokenRow 

type AuthAccessTokenRow struct {
	ID                 uuid.UUID
	Name               string
	NamespaceSelectors []string
	Scopes             []string
	IssuedAt           sql.NullTime
	ExpiresAt          sql.NullTime
	RevokedAt          sql.NullTime
}

type DBTX 

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type DeleteTestParams 

type DeleteTestParams struct {
	ID        uuid.UUID
	Namespace string
}

type GetAccessTokenRow 

type GetAccessTokenRow struct {
	ID                 uuid.UUID
	Name               string
	NamespaceSelectors []string
	Scopes             []string
	IssuedAt           sql.NullTime
	ExpiresAt          sql.NullTime
	RevokedAt          sql.NullTime
}

type GetRunParams 

type GetRunParams struct {
	Namespace string
	ID        uuid.UUID
}

type GetTestParams 

type GetTestParams struct {
	ID        uuid.UUID
	Namespace string
}

type IssueAccessTokenParams 

type IssueAccessTokenParams struct {
	Name               string
	TokenHash          string
	NamespaceSelectors []string
	Scopes             []string
	ExpiresAt          sql.NullTime
}

type IssueAccessTokenRow 

type IssueAccessTokenRow struct {
	ID                 uuid.UUID
	Name               string
	NamespaceSelectors []string
	Scopes             []string
	IssuedAt           sql.NullTime
	ExpiresAt          sql.NullTime
}

type ListAccessTokensParams 

type ListAccessTokensParams struct {
	IncludeExpired bool
	IncludeRevoked bool
}

type ListAccessTokensRow 

type ListAccessTokensRow struct {
	ID                 uuid.UUID
	Name               string
	NamespaceSelectors []string
	Scopes             []string
	IssuedAt           sql.NullTime
	ExpiresAt          sql.NullTime
	RevokedAt          sql.NullTime
}

type ListPendingRunsRow 

type ListPendingRunsRow struct {
	ID            uuid.UUID
	TestID        uuid.UUID
	TestRunConfig pgtype.JSONB
	TestMatrixID  uuid.NullUUID
	Labels        pgtype.JSONB
	RunnerID      uuid.NullUUID
	Result        NullRunResult
	Logs          pgtype.JSONB
	ResultData    pgtype.JSONB
	ScheduledAt   sql.NullTime
	StartedAt     sql.NullTime
	FinishedAt    sql.NullTime
	Namespace     string
}

type MockQuerier 

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

MockQuerier is a mock of Querier interface.

func NewMockQuerier 

func NewMockQuerier(ctrl *gomock.Controller) *MockQuerier

NewMockQuerier creates a new mock instance.

func (*MockQuerier) AppendLogsToRun 

func (m *MockQuerier) AppendLogsToRun(ctx context.Context, db DBTX, arg AppendLogsToRunParams) error

AppendLogsToRun mocks base method.

func (*MockQuerier) AssignRun 

func (m *MockQuerier) AssignRun(ctx context.Context, db DBTX, arg AssignRunParams) (Run, error)

AssignRun mocks base method.

func (*MockQuerier) AuthAccessToken 

func (m *MockQuerier) AuthAccessToken(ctx context.Context, db DBTX, tokenHash string) (AuthAccessTokenRow, error)

AuthAccessToken mocks base method.

func (*MockQuerier) DeleteRunsForTest 

func (m *MockQuerier) DeleteRunsForTest(ctx context.Context, db DBTX, testID uuid.UUID) error

DeleteRunsForTest mocks base method.

func (*MockQuerier) DeleteTest 

func (m *MockQuerier) DeleteTest(ctx context.Context, db DBTX, arg DeleteTestParams) (pgconn.CommandTag, error)

DeleteTest mocks base method.

func (*MockQuerier) EXPECT 

func (m *MockQuerier) EXPECT() *MockQuerierMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockQuerier) GetAccessToken 

func (m *MockQuerier) GetAccessToken(ctx context.Context, db DBTX, id uuid.UUID) (GetAccessTokenRow, error)

GetAccessToken mocks base method.

func (*MockQuerier) GetRun 

func (m *MockQuerier) GetRun(ctx context.Context, db DBTX, arg GetRunParams) (Run, error)

GetRun mocks base method.

func (*MockQuerier) GetRunner 

func (m *MockQuerier) GetRunner(ctx context.Context, db DBTX, id uuid.UUID) (Runner, error)

GetRunner mocks base method.

func (*MockQuerier) GetTest 

func (m *MockQuerier) GetTest(ctx context.Context, db DBTX, arg GetTestParams) (Test, error)

GetTest mocks base method.

func (*MockQuerier) IssueAccessToken 

func (m *MockQuerier) IssueAccessToken(ctx context.Context, db DBTX, arg IssueAccessTokenParams) (IssueAccessTokenRow, error)

IssueAccessToken mocks base method.

func (*MockQuerier) ListAccessTokens 

func (m *MockQuerier) ListAccessTokens(ctx context.Context, db DBTX, arg ListAccessTokensParams) ([]ListAccessTokensRow, error)

ListAccessTokens mocks base method.

func (*MockQuerier) ListAllNamespaces 

func (m *MockQuerier) ListAllNamespaces(ctx context.Context, db DBTX) ([]string, error)

ListAllNamespaces mocks base method.

func (*MockQuerier) ListPendingRuns 

func (m *MockQuerier) ListPendingRuns(ctx context.Context, db DBTX) ([]ListPendingRunsRow, error)

ListPendingRuns mocks base method.

func (*MockQuerier) ListRunners 

func (m *MockQuerier) ListRunners(ctx context.Context, db DBTX) ([]Runner, error)

ListRunners mocks base method.

func (*MockQuerier) ListRuns 

func (m *MockQuerier) ListRuns(ctx context.Context, db DBTX, namespace string) ([]Run, error)

ListRuns mocks base method.

func (*MockQuerier) ListTests 

func (m *MockQuerier) ListTests(ctx context.Context, db DBTX, namespace string) ([]Test, error)

ListTests mocks base method.

func (*MockQuerier) ListTestsToSchedule 

func (m *MockQuerier) ListTestsToSchedule(ctx context.Context, db DBTX) ([]Test, error)

ListTestsToSchedule mocks base method.

func (*MockQuerier) QueryRunners 

func (m *MockQuerier) QueryRunners(ctx context.Context, db DBTX, arg QueryRunnersParams) ([]Runner, error)

QueryRunners mocks base method.

func (*MockQuerier) QueryRuns 

func (m *MockQuerier) QueryRuns(ctx context.Context, db DBTX, arg QueryRunsParams) ([]Run, error)

QueryRuns mocks base method.

func (*MockQuerier) QueryTests 

func (m *MockQuerier) QueryTests(ctx context.Context, db DBTX, arg QueryTestsParams) ([]Test, error)

QueryTests mocks base method.

func (*MockQuerier) RegisterRunner 

func (m *MockQuerier) RegisterRunner(ctx context.Context, db DBTX, arg RegisterRunnerParams) (Runner, error)

RegisterRunner mocks base method.

func (*MockQuerier) RegisterTest 

func (m *MockQuerier) RegisterTest(ctx context.Context, db DBTX, arg RegisterTestParams) (Test, error)

RegisterTest mocks base method.

func (*MockQuerier) ResetOrphanedRuns 

func (m *MockQuerier) ResetOrphanedRuns(ctx context.Context, db DBTX, before time.Time) error

ResetOrphanedRuns mocks base method.

func (*MockQuerier) RevokeAccessToken 

func (m *MockQuerier) RevokeAccessToken(ctx context.Context, db DBTX, id uuid.UUID) error

RevokeAccessToken mocks base method.

func (*MockQuerier) RunSummariesForRunner 

func (m *MockQuerier) RunSummariesForRunner(ctx context.Context, db DBTX, arg RunSummariesForRunnerParams) ([]RunSummariesForRunnerRow, error)

RunSummariesForRunner mocks base method.

func (*MockQuerier) RunSummariesForTest 

func (m *MockQuerier) RunSummariesForTest(ctx context.Context, db DBTX, arg RunSummariesForTestParams) ([]RunSummariesForTestRow, error)

RunSummariesForTest mocks base method.

func (*MockQuerier) ScheduleRun 

func (m *MockQuerier) ScheduleRun(ctx context.Context, db DBTX, arg ScheduleRunParams) (Run, error)

ScheduleRun mocks base method.

func (*MockQuerier) SummarizeRunsBreakdownResult 

func (m *MockQuerier) SummarizeRunsBreakdownResult(ctx context.Context, db DBTX, arg SummarizeRunsBreakdownResultParams) ([]SummarizeRunsBreakdownResultRow, error)

SummarizeRunsBreakdownResult mocks base method.

func (*MockQuerier) SummarizeRunsBreakdownTest 

func (m *MockQuerier) SummarizeRunsBreakdownTest(ctx context.Context, db DBTX, arg SummarizeRunsBreakdownTestParams) ([]SummarizeRunsBreakdownTestRow, error)

SummarizeRunsBreakdownTest mocks base method.

func (*MockQuerier) TimeoutRuns 

func (m *MockQuerier) TimeoutRuns(ctx context.Context, db DBTX, arg TimeoutRunsParams) error

TimeoutRuns mocks base method.

func (*MockQuerier) UpdateResultData 

func (m *MockQuerier) UpdateResultData(ctx context.Context, db DBTX, arg UpdateResultDataParams) error

UpdateResultData mocks base method.

func (*MockQuerier) UpdateRun 

func (m *MockQuerier) UpdateRun(ctx context.Context, db DBTX, arg UpdateRunParams) error

UpdateRun mocks base method.

func (*MockQuerier) UpdateRunnerHeartbeat 

func (m *MockQuerier) UpdateRunnerHeartbeat(ctx context.Context, db DBTX, arg UpdateRunnerHeartbeatParams) error

UpdateRunnerHeartbeat mocks base method.

func (*MockQuerier) UpdateTest 

func (m *MockQuerier) UpdateTest(ctx context.Context, db DBTX, arg UpdateTestParams) (pgconn.CommandTag, error)

UpdateTest mocks base method.

type MockQuerierMockRecorder 

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

MockQuerierMockRecorder is the mock recorder for MockQuerier.

func (*MockQuerierMockRecorder) AppendLogsToRun 

func (mr *MockQuerierMockRecorder) AppendLogsToRun(ctx, db, arg interface{}) *gomock.Call

AppendLogsToRun indicates an expected call of AppendLogsToRun.

func (*MockQuerierMockRecorder) AssignRun 

func (mr *MockQuerierMockRecorder) AssignRun(ctx, db, arg interface{}) *gomock.Call

AssignRun indicates an expected call of AssignRun.

func (*MockQuerierMockRecorder) AuthAccessToken 

func (mr *MockQuerierMockRecorder) AuthAccessToken(ctx, db, tokenHash interface{}) *gomock.Call

AuthAccessToken indicates an expected call of AuthAccessToken.

func (*MockQuerierMockRecorder) DeleteRunsForTest 

func (mr *MockQuerierMockRecorder) DeleteRunsForTest(ctx, db, testID interface{}) *gomock.Call

DeleteRunsForTest indicates an expected call of DeleteRunsForTest.

func (*MockQuerierMockRecorder) DeleteTest 

func (mr *MockQuerierMockRecorder) DeleteTest(ctx, db, arg interface{}) *gomock.Call

DeleteTest indicates an expected call of DeleteTest.

func (*MockQuerierMockRecorder) GetAccessToken 

func (mr *MockQuerierMockRecorder) GetAccessToken(ctx, db, id interface{}) *gomock.Call

GetAccessToken indicates an expected call of GetAccessToken.

func (*MockQuerierMockRecorder) GetRun 

func (mr *MockQuerierMockRecorder) GetRun(ctx, db, arg interface{}) *gomock.Call

GetRun indicates an expected call of GetRun.

func (*MockQuerierMockRecorder) GetRunner 

func (mr *MockQuerierMockRecorder) GetRunner(ctx, db, id interface{}) *gomock.Call

GetRunner indicates an expected call of GetRunner.

func (*MockQuerierMockRecorder) GetTest 

func (mr *MockQuerierMockRecorder) GetTest(ctx, db, arg interface{}) *gomock.Call

GetTest indicates an expected call of GetTest.

func (*MockQuerierMockRecorder) IssueAccessToken 

func (mr *MockQuerierMockRecorder) IssueAccessToken(ctx, db, arg interface{}) *gomock.Call

IssueAccessToken indicates an expected call of IssueAccessToken.

func (*MockQuerierMockRecorder) ListAccessTokens 

func (mr *MockQuerierMockRecorder) ListAccessTokens(ctx, db, arg interface{}) *gomock.Call

ListAccessTokens indicates an expected call of ListAccessTokens.

func (*MockQuerierMockRecorder) ListAllNamespaces 

func (mr *MockQuerierMockRecorder) ListAllNamespaces(ctx, db interface{}) *gomock.Call

ListAllNamespaces indicates an expected call of ListAllNamespaces.

func (*MockQuerierMockRecorder) ListPendingRuns 

func (mr *MockQuerierMockRecorder) ListPendingRuns(ctx, db interface{}) *gomock.Call

ListPendingRuns indicates an expected call of ListPendingRuns.

func (*MockQuerierMockRecorder) ListRunners 

func (mr *MockQuerierMockRecorder) ListRunners(ctx, db interface{}) *gomock.Call

ListRunners indicates an expected call of ListRunners.

func (*MockQuerierMockRecorder) ListRuns 

func (mr *MockQuerierMockRecorder) ListRuns(ctx, db, namespace interface{}) *gomock.Call

ListRuns indicates an expected call of ListRuns.

func (*MockQuerierMockRecorder) ListTests 

func (mr *MockQuerierMockRecorder) ListTests(ctx, db, namespace interface{}) *gomock.Call

ListTests indicates an expected call of ListTests.

func (*MockQuerierMockRecorder) ListTestsToSchedule 

func (mr *MockQuerierMockRecorder) ListTestsToSchedule(ctx, db interface{}) *gomock.Call

ListTestsToSchedule indicates an expected call of ListTestsToSchedule.

func (*MockQuerierMockRecorder) QueryRunners 

func (mr *MockQuerierMockRecorder) QueryRunners(ctx, db, arg interface{}) *gomock.Call

QueryRunners indicates an expected call of QueryRunners.

func (*MockQuerierMockRecorder) QueryRuns 

func (mr *MockQuerierMockRecorder) QueryRuns(ctx, db, arg interface{}) *gomock.Call

QueryRuns indicates an expected call of QueryRuns.

func (*MockQuerierMockRecorder) QueryTests 

func (mr *MockQuerierMockRecorder) QueryTests(ctx, db, arg interface{}) *gomock.Call

QueryTests indicates an expected call of QueryTests.

func (*MockQuerierMockRecorder) RegisterRunner 

func (mr *MockQuerierMockRecorder) RegisterRunner(ctx, db, arg interface{}) *gomock.Call

RegisterRunner indicates an expected call of RegisterRunner.

func (*MockQuerierMockRecorder) RegisterTest 

func (mr *MockQuerierMockRecorder) RegisterTest(ctx, db, arg interface{}) *gomock.Call

RegisterTest indicates an expected call of RegisterTest.

func (*MockQuerierMockRecorder) ResetOrphanedRuns 

func (mr *MockQuerierMockRecorder) ResetOrphanedRuns(ctx, db, before interface{}) *gomock.Call

ResetOrphanedRuns indicates an expected call of ResetOrphanedRuns.

func (*MockQuerierMockRecorder) RevokeAccessToken 

func (mr *MockQuerierMockRecorder) RevokeAccessToken(ctx, db, id interface{}) *gomock.Call

RevokeAccessToken indicates an expected call of RevokeAccessToken.

func (*MockQuerierMockRecorder) RunSummariesForRunner 

func (mr *MockQuerierMockRecorder) RunSummariesForRunner(ctx, db, arg interface{}) *gomock.Call

RunSummariesForRunner indicates an expected call of RunSummariesForRunner.

func (*MockQuerierMockRecorder) RunSummariesForTest 

func (mr *MockQuerierMockRecorder) RunSummariesForTest(ctx, db, arg interface{}) *gomock.Call

RunSummariesForTest indicates an expected call of RunSummariesForTest.

func (*MockQuerierMockRecorder) ScheduleRun 

func (mr *MockQuerierMockRecorder) ScheduleRun(ctx, db, arg interface{}) *gomock.Call

ScheduleRun indicates an expected call of ScheduleRun.

func (*MockQuerierMockRecorder) SummarizeRunsBreakdownResult 

func (mr *MockQuerierMockRecorder) SummarizeRunsBreakdownResult(ctx, db, arg interface{}) *gomock.Call

SummarizeRunsBreakdownResult indicates an expected call of SummarizeRunsBreakdownResult.

func (*MockQuerierMockRecorder) SummarizeRunsBreakdownTest 

func (mr *MockQuerierMockRecorder) SummarizeRunsBreakdownTest(ctx, db, arg interface{}) *gomock.Call

SummarizeRunsBreakdownTest indicates an expected call of SummarizeRunsBreakdownTest.

func (*MockQuerierMockRecorder) TimeoutRuns 

func (mr *MockQuerierMockRecorder) TimeoutRuns(ctx, db, arg interface{}) *gomock.Call

TimeoutRuns indicates an expected call of TimeoutRuns.

func (*MockQuerierMockRecorder) UpdateResultData 

func (mr *MockQuerierMockRecorder) UpdateResultData(ctx, db, arg interface{}) *gomock.Call

UpdateResultData indicates an expected call of UpdateResultData.

func (*MockQuerierMockRecorder) UpdateRun 

func (mr *MockQuerierMockRecorder) UpdateRun(ctx, db, arg interface{}) *gomock.Call

UpdateRun indicates an expected call of UpdateRun.

func (*MockQuerierMockRecorder) UpdateRunnerHeartbeat 

func (mr *MockQuerierMockRecorder) UpdateRunnerHeartbeat(ctx, db, arg interface{}) *gomock.Call

UpdateRunnerHeartbeat indicates an expected call of UpdateRunnerHeartbeat.

func (*MockQuerierMockRecorder) UpdateTest 

func (mr *MockQuerierMockRecorder) UpdateTest(ctx, db, arg interface{}) *gomock.Call

UpdateTest indicates an expected call of UpdateTest.

type NullAccessTokenScope 

type NullAccessTokenScope struct {
	AccessTokenScope AccessTokenScope
	Valid            bool // Valid is true if AccessTokenScope is not NULL
}

func (*NullAccessTokenScope) Scan 

func (ns *NullAccessTokenScope) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullAccessTokenScope) Value 

func (ns NullAccessTokenScope) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullRunResult 

type NullRunResult struct {
	RunResult RunResult
	Valid     bool // Valid is true if RunResult is not NULL
}

func (*NullRunResult) Scan 

func (ns *NullRunResult) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullRunResult) Value 

func (ns NullRunResult) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type Querier 

type Querier interface {
	AppendLogsToRun(ctx context.Context, db DBTX, arg AppendLogsToRunParams) error
	AssignRun(ctx context.Context, db DBTX, arg AssignRunParams) (Run, error)
	// TODO re: ::text[] https://github.com/kyleconroy/sqlc/issues/1256
	AuthAccessToken(ctx context.Context, db DBTX, tokenHash string) (AuthAccessTokenRow, error)
	DeleteRunsForTest(ctx context.Context, db DBTX, testID uuid.UUID) error
	DeleteTest(ctx context.Context, db DBTX, arg DeleteTestParams) (pgconn.CommandTag, error)
	// TODO re: ::text[] https://github.com/kyleconroy/sqlc/issues/1256
	GetAccessToken(ctx context.Context, db DBTX, id uuid.UUID) (GetAccessTokenRow, error)
	GetRun(ctx context.Context, db DBTX, arg GetRunParams) (Run, error)
	GetRunner(ctx context.Context, db DBTX, id uuid.UUID) (Runner, error)
	GetTest(ctx context.Context, db DBTX, arg GetTestParams) (Test, error)
	// TODO re: ::text[] https://github.com/kyleconroy/sqlc/issues/1256
	IssueAccessToken(ctx context.Context, db DBTX, arg IssueAccessTokenParams) (IssueAccessTokenRow, error)
	// TODO re: ::text[] https://github.com/kyleconroy/sqlc/issues/1256
	ListAccessTokens(ctx context.Context, db DBTX, arg ListAccessTokensParams) ([]ListAccessTokensRow, error)
	ListAllNamespaces(ctx context.Context, db DBTX) ([]string, error)
	ListPendingRuns(ctx context.Context, db DBTX) ([]ListPendingRunsRow, error)
	ListRunners(ctx context.Context, db DBTX) ([]Runner, error)
	ListRuns(ctx context.Context, db DBTX, namespace string) ([]Run, error)
	ListTests(ctx context.Context, db DBTX, namespace string) ([]Test, error)
	ListTestsToSchedule(ctx context.Context, db DBTX) ([]Test, error)
	QueryRunners(ctx context.Context, db DBTX, arg QueryRunnersParams) ([]Runner, error)
	QueryRuns(ctx context.Context, db DBTX, arg QueryRunsParams) ([]Run, error)
	QueryTests(ctx context.Context, db DBTX, arg QueryTestsParams) ([]Test, error)
	RegisterRunner(ctx context.Context, db DBTX, arg RegisterRunnerParams) (Runner, error)
	RegisterTest(ctx context.Context, db DBTX, arg RegisterTestParams) (Test, error)
	ResetOrphanedRuns(ctx context.Context, db DBTX, before time.Time) error
	RevokeAccessToken(ctx context.Context, db DBTX, id uuid.UUID) error
	RunSummariesForRunner(ctx context.Context, db DBTX, arg RunSummariesForRunnerParams) ([]RunSummariesForRunnerRow, error)
	RunSummariesForTest(ctx context.Context, db DBTX, arg RunSummariesForTestParams) ([]RunSummariesForTestRow, error)
	ScheduleRun(ctx context.Context, db DBTX, arg ScheduleRunParams) (Run, error)
	SummarizeRunsBreakdownResult(ctx context.Context, db DBTX, arg SummarizeRunsBreakdownResultParams) ([]SummarizeRunsBreakdownResultRow, error)
	SummarizeRunsBreakdownTest(ctx context.Context, db DBTX, arg SummarizeRunsBreakdownTestParams) ([]SummarizeRunsBreakdownTestRow, error)
	TimeoutRuns(ctx context.Context, db DBTX, arg TimeoutRunsParams) error
	UpdateResultData(ctx context.Context, db DBTX, arg UpdateResultDataParams) error
	UpdateRun(ctx context.Context, db DBTX, arg UpdateRunParams) error
	UpdateRunnerHeartbeat(ctx context.Context, db DBTX, arg UpdateRunnerHeartbeatParams) error
	UpdateTest(ctx context.Context, db DBTX, arg UpdateTestParams) (pgconn.CommandTag, error)
}

type Queries 

type Queries struct {
}

func New 

func New() *Queries

func (*Queries) AppendLogsToRun 

func (q *Queries) AppendLogsToRun(ctx context.Context, db DBTX, arg AppendLogsToRunParams) error

func (*Queries) AssignRun 

func (q *Queries) AssignRun(ctx context.Context, db DBTX, arg AssignRunParams) (Run, error)

func (*Queries) AuthAccessToken 

func (q *Queries) AuthAccessToken(ctx context.Context, db DBTX, tokenHash string) (AuthAccessTokenRow, error)

TODO re: ::text[] https://github.com/kyleconroy/sqlc/issues/1256

func (*Queries) DeleteRunsForTest 

func (q *Queries) DeleteRunsForTest(ctx context.Context, db DBTX, testID uuid.UUID) error

func (*Queries) DeleteTest 

func (q *Queries) DeleteTest(ctx context.Context, db DBTX, arg DeleteTestParams) (pgconn.CommandTag, error)

func (*Queries) GetAccessToken 

func (q *Queries) GetAccessToken(ctx context.Context, db DBTX, id uuid.UUID) (GetAccessTokenRow, error)

TODO re: ::text[] https://github.com/kyleconroy/sqlc/issues/1256

func (*Queries) GetRun 

func (q *Queries) GetRun(ctx context.Context, db DBTX, arg GetRunParams) (Run, error)

func (*Queries) GetRunner 

func (q *Queries) GetRunner(ctx context.Context, db DBTX, id uuid.UUID) (Runner, error)

func (*Queries) GetTest 

func (q *Queries) GetTest(ctx context.Context, db DBTX, arg GetTestParams) (Test, error)

func (*Queries) IssueAccessToken 

func (q *Queries) IssueAccessToken(ctx context.Context, db DBTX, arg IssueAccessTokenParams) (IssueAccessTokenRow, error)

TODO re: ::text[] https://github.com/kyleconroy/sqlc/issues/1256

func (*Queries) ListAccessTokens 

func (q *Queries) ListAccessTokens(ctx context.Context, db DBTX, arg ListAccessTokensParams) ([]ListAccessTokensRow, error)

TODO re: ::text[] https://github.com/kyleconroy/sqlc/issues/1256

func (*Queries) ListAllNamespaces 

func (q *Queries) ListAllNamespaces(ctx context.Context, db DBTX) ([]string, error)

func (*Queries) ListPendingRuns 

func (q *Queries) ListPendingRuns(ctx context.Context, db DBTX) ([]ListPendingRunsRow, error)

func (*Queries) ListRunners 

func (q *Queries) ListRunners(ctx context.Context, db DBTX) ([]Runner, error)

func (*Queries) ListRuns 

func (q *Queries) ListRuns(ctx context.Context, db DBTX, namespace string) ([]Run, error)

func (*Queries) ListTests 

func (q *Queries) ListTests(ctx context.Context, db DBTX, namespace string) ([]Test, error)

func (*Queries) ListTestsToSchedule 

func (q *Queries) ListTestsToSchedule(ctx context.Context, db DBTX) ([]Test, error)

func (*Queries) QueryRunners 

func (q *Queries) QueryRunners(ctx context.Context, db DBTX, arg QueryRunnersParams) ([]Runner, error)

func (*Queries) QueryRuns 

func (q *Queries) QueryRuns(ctx context.Context, db DBTX, arg QueryRunsParams) ([]Run, error)

func (*Queries) QueryTests 

func (q *Queries) QueryTests(ctx context.Context, db DBTX, arg QueryTestsParams) ([]Test, error)

func (*Queries) RegisterRunner 

func (q *Queries) RegisterRunner(ctx context.Context, db DBTX, arg RegisterRunnerParams) (Runner, error)

func (*Queries) RegisterTest 

func (q *Queries) RegisterTest(ctx context.Context, db DBTX, arg RegisterTestParams) (Test, error)

func (*Queries) ResetOrphanedRuns 

func (q *Queries) ResetOrphanedRuns(ctx context.Context, db DBTX, before time.Time) error

func (*Queries) RevokeAccessToken 

func (q *Queries) RevokeAccessToken(ctx context.Context, db DBTX, id uuid.UUID) error

func (*Queries) RunSummariesForRunner 

func (q *Queries) RunSummariesForRunner(ctx context.Context, db DBTX, arg RunSummariesForRunnerParams) ([]RunSummariesForRunnerRow, error)

func (*Queries) RunSummariesForTest 

func (q *Queries) RunSummariesForTest(ctx context.Context, db DBTX, arg RunSummariesForTestParams) ([]RunSummariesForTestRow, error)

func (*Queries) ScheduleRun 

func (q *Queries) ScheduleRun(ctx context.Context, db DBTX, arg ScheduleRunParams) (Run, error)

func (*Queries) SummarizeRunsBreakdownResult 

func (q *Queries) SummarizeRunsBreakdownResult(ctx context.Context, db DBTX, arg SummarizeRunsBreakdownResultParams) ([]SummarizeRunsBreakdownResultRow, error)

func (*Queries) SummarizeRunsBreakdownTest 

func (q *Queries) SummarizeRunsBreakdownTest(ctx context.Context, db DBTX, arg SummarizeRunsBreakdownTestParams) ([]SummarizeRunsBreakdownTestRow, error)

func (*Queries) TimeoutRuns 

func (q *Queries) TimeoutRuns(ctx context.Context, db DBTX, arg TimeoutRunsParams) error

func (*Queries) UpdateResultData 

func (q *Queries) UpdateResultData(ctx context.Context, db DBTX, arg UpdateResultDataParams) error

func (*Queries) UpdateRun 

func (q *Queries) UpdateRun(ctx context.Context, db DBTX, arg UpdateRunParams) error

func (*Queries) UpdateRunnerHeartbeat 

func (q *Queries) UpdateRunnerHeartbeat(ctx context.Context, db DBTX, arg UpdateRunnerHeartbeatParams) error

func (*Queries) UpdateTest 

func (q *Queries) UpdateTest(ctx context.Context, db DBTX, arg UpdateTestParams) (pgconn.CommandTag, error)

type QueryRunnersParams 

type QueryRunnersParams struct {
	Ids                []uuid.UUID
	LastHeartbeatSince sql.NullTime
}

type QueryRunsParams 

type QueryRunsParams struct {
	Namespace       string
	Ids             []uuid.UUID
	TestIds         []uuid.UUID
	RunnerIds       []uuid.UUID
	Results         []string
	ScheduledBefore sql.NullTime
	ScheduledAfter  sql.NullTime
	StartedBefore   sql.NullTime
	StartedAfter    sql.NullTime
	FinishedBefore  sql.NullTime
	FinishedAfter   sql.NullTime
}

type QueryTestsParams 

type QueryTestsParams struct {
	Namespace string
	Ids       []uuid.UUID
	Labels    pgtype.JSONB
}

type RegisterRunnerParams 

type RegisterRunnerParams struct {
	Name                     string
	NamespaceSelectors       []string
	AcceptTestLabelSelectors pgtype.JSONB
	RejectTestLabelSelectors pgtype.JSONB
}

type RegisterTestParams 

type RegisterTestParams struct {
	Namespace    string
	Name         string
	RunConfig    pgtype.JSONB
	Labels       pgtype.JSONB
	Matrix       pgtype.JSONB
	CronSchedule sql.NullString
	NextRunAt    sql.NullTime
}

type Run 

type Run struct {
	ID            uuid.UUID
	TestID        uuid.UUID
	TestRunConfig pgtype.JSONB
	TestMatrixID  uuid.NullUUID
	Labels        pgtype.JSONB
	RunnerID      uuid.NullUUID
	Result        NullRunResult
	Logs          pgtype.JSONB
	ResultData    pgtype.JSONB
	ScheduledAt   sql.NullTime
	StartedAt     sql.NullTime
	FinishedAt    sql.NullTime
}

type RunLog 

type RunLog struct {
	Type string `json:"type"`
	Time string `json:"time"`
	Data []byte `json:"data"`
}

type RunResult 

type RunResult string
const (
	RunResultUnknown RunResult = "unknown"
	RunResultPass    RunResult = "pass"
	RunResultFail    RunResult = "fail"
	RunResultError   RunResult = "error"
)

func (*RunResult) Scan 

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

type RunResults 

type RunResults []RunResult

func (*RunResults) DecodeText 

func (r *RunResults) DecodeText(ci *pgtype.ConnInfo, src []byte) error

func (RunResults) EncodeText 

func (r RunResults) EncodeText(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)

type RunSummariesForRunnerParams 

type RunSummariesForRunnerParams struct {
	Namespace      string
	RunnerID       uuid.NullUUID
	ScheduledAfter sql.NullTime
}

type RunSummariesForRunnerRow 

type RunSummariesForRunnerRow struct {
	ID            uuid.UUID
	TestNamespace string
	TestID        uuid.UUID
	TestName      string
	TestRunConfig pgtype.JSONB
	Labels        pgtype.JSONB
	RunnerID      uuid.NullUUID
	Result        NullRunResult
	ScheduledAt   sql.NullTime
	StartedAt     sql.NullTime
	FinishedAt    sql.NullTime
	ResultData    pgtype.JSONB
}

type RunSummariesForTestParams 

type RunSummariesForTestParams struct {
	Namespace      string
	TestID         uuid.UUID
	ScheduledAfter sql.NullTime
}

type RunSummariesForTestRow 

type RunSummariesForTestRow struct {
	ID            uuid.UUID
	TestNamespace string
	TestID        uuid.UUID
	TestName      string
	TestRunConfig pgtype.JSONB
	Labels        pgtype.JSONB
	RunnerID      uuid.NullUUID
	Result        NullRunResult
	ScheduledAt   sql.NullTime
	StartedAt     sql.NullTime
	FinishedAt    sql.NullTime
	ResultData    pgtype.JSONB
}

type Runner 

type Runner struct {
	ID                       uuid.UUID
	Name                     string
	AcceptTestLabelSelectors pgtype.JSONB
	RejectTestLabelSelectors pgtype.JSONB
	RegisteredAt             sql.NullTime
	LastHeartbeatAt          sql.NullTime
	NamespaceSelectors       []string
}

type ScheduleRunParams 

type ScheduleRunParams struct {
	Labels       pgtype.JSONB
	TestMatrixID uuid.NullUUID
	TestID       uuid.UUID
	Namespace    string
}

type SchemaMigration 

type SchemaMigration struct {
	Version string
}

type SummarizeRunsBreakdownResultParams 

type SummarizeRunsBreakdownResultParams struct {
	Precision string
	StartTime sql.NullTime
	EndTime   sql.NullTime
	Namespace string
	TestIds   []uuid.UUID
	Interval  float64
}

type SummarizeRunsBreakdownResultRow 

type SummarizeRunsBreakdownResultRow struct {
	IntervalsStart time.Time
	Pass           int64
	Fail           int64
	Error          int64
	Unknown        int64
}

type SummarizeRunsBreakdownTestParams 

type SummarizeRunsBreakdownTestParams struct {
	Precision string
	StartTime sql.NullTime
	EndTime   sql.NullTime
	Namespace string
	TestIds   []uuid.UUID
	Interval  float64
}

type SummarizeRunsBreakdownTestRow 

type SummarizeRunsBreakdownTestRow struct {
	IntervalsStart time.Time
	ID             uuid.UUID
	Name           string
	Pass           int64
	Fail           int64
	Error          int64
	Unknown        int64
}

type Test 

type Test struct {
	ID           uuid.UUID
	Name         string
	RunConfig    pgtype.JSONB
	Labels       pgtype.JSONB
	Matrix       pgtype.JSONB
	CronSchedule sql.NullString
	NextRunAt    sql.NullTime
	RegisteredAt sql.NullTime
	UpdatedAt    sql.NullTime
	Namespace    string
}

type TestMatrix 

type TestMatrix struct {
	Labels map[string][]string `json:"labels"`
}

type TestRunConfig 

type TestRunConfig struct {
	ContainerImage string            `json:"container_image"`
	Command        string            `json:"command"`
	Args           []string          `json:"args"`
	Env            map[string]string `json:"env"`
	TimeoutSeconds uint              `json:"timeout_seconds"`
}

type TimeoutRunsParams 

type TimeoutRunsParams struct {
	TimeoutLog     pgtype.JSONB
	DefaultTimeout int32
}

type UpdateResultDataParams 

type UpdateResultDataParams struct {
	ResultData pgtype.JSONB
	ID         uuid.UUID
}

type UpdateRunParams 

type UpdateRunParams struct {
	Result     NullRunResult
	StartedAt  sql.NullTime
	FinishedAt sql.NullTime
	ID         uuid.UUID
}

type UpdateRunnerHeartbeatParams 

type UpdateRunnerHeartbeatParams struct {
	Timestamp sql.NullTime
	ID        uuid.UUID
}

type UpdateTestParams 

type UpdateTestParams struct {
	Name         string
	RunConfig    pgtype.JSONB
	Labels       pgtype.JSONB
	Matrix       pgtype.JSONB
	CronSchedule sql.NullString
	NextRunAt    sql.NullTime
	ID           uuid.UUID
	Namespace    string
}

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.