Documentation ¶
Overview ¶
Package result is a generated GoMock package.
Index ¶
- Constants
- type ExecutionOutput
- type Filter
- type FilterImpl
- func (f *FilterImpl) EndDate() time.Time
- func (f *FilterImpl) EndDateDefined() bool
- func (f *FilterImpl) LastNDays() int
- func (f *FilterImpl) LastNDaysDefined() bool
- func (f *FilterImpl) Page() int
- func (f *FilterImpl) PageSize() int
- func (f *FilterImpl) Selector() string
- func (f *FilterImpl) StartDate() time.Time
- func (f *FilterImpl) StartDateDefined() bool
- func (f *FilterImpl) Statuses() testkube.ExecutionStatuses
- func (f *FilterImpl) StatusesDefined() bool
- func (f *FilterImpl) TestName() string
- func (f *FilterImpl) TestNameDefined() bool
- func (f *FilterImpl) TextSearch() string
- func (f *FilterImpl) TextSearchDefined() bool
- func (f *FilterImpl) Type() string
- func (f *FilterImpl) TypeDefined() bool
- func (f *FilterImpl) WithEndDate(date time.Time) *FilterImpl
- func (f *FilterImpl) WithLastNDays(days int) *FilterImpl
- func (f *FilterImpl) WithPage(page int) *FilterImpl
- func (f *FilterImpl) WithPageSize(pageSize int) *FilterImpl
- func (f *FilterImpl) WithSelector(selector string) *FilterImpl
- func (f *FilterImpl) WithStartDate(date time.Time) *FilterImpl
- func (f *FilterImpl) WithStatus(status string) *FilterImpl
- func (f *FilterImpl) WithTestName(testName string) *FilterImpl
- func (f *FilterImpl) WithTextSearch(textSearch string) *FilterImpl
- func (f *FilterImpl) WithType(objectType string) *FilterImpl
- type MinioRepository
- func (m *MinioRepository) DeleteAllOutput(ctx context.Context) error
- func (m *MinioRepository) DeleteOutput(ctx context.Context, id, testName, testSuiteName string) error
- func (m *MinioRepository) DeleteOutputByTest(ctx context.Context, testName string) error
- func (m *MinioRepository) DeleteOutputByTestSuite(ctx context.Context, testSuiteName string) error
- func (m *MinioRepository) DeleteOutputForAllTestSuite(ctx context.Context) error
- func (m *MinioRepository) DeleteOutputForTestSuites(ctx context.Context, testSuiteNames []string) error
- func (m *MinioRepository) DeleteOutputForTests(ctx context.Context, testNames []string) error
- func (m *MinioRepository) GetOutput(ctx context.Context, id, testName, testSuiteName string) (output string, err error)
- func (m *MinioRepository) InsertOutput(ctx context.Context, id, testName, testSuiteName, output string) error
- func (m *MinioRepository) UpdateOutput(ctx context.Context, id, testName, testSuiteName, output string) error
- type MockRepository
- func (m *MockRepository) DeleteAll(arg0 context.Context) error
- func (m *MockRepository) DeleteByTest(arg0 context.Context, arg1 string) error
- func (m *MockRepository) DeleteByTestSuite(arg0 context.Context, arg1 string) error
- func (m *MockRepository) DeleteByTestSuites(arg0 context.Context, arg1 []string) error
- func (m *MockRepository) DeleteByTests(arg0 context.Context, arg1 []string) error
- func (m *MockRepository) DeleteForAllTestSuites(arg0 context.Context) error
- func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder
- func (m *MockRepository) EndExecution(arg0 context.Context, arg1 testkube.Execution) error
- func (m *MockRepository) Get(arg0 context.Context, arg1 string) (testkube.Execution, error)
- func (m *MockRepository) GetByNameAndTest(arg0 context.Context, arg1, arg2 string) (testkube.Execution, error)
- func (m *MockRepository) GetExecutionTotals(arg0 context.Context, arg1 bool, arg2 ...Filter) (testkube.ExecutionsTotals, error)
- func (m *MockRepository) GetExecutions(arg0 context.Context, arg1 Filter) ([]testkube.Execution, error)
- func (m *MockRepository) GetLabels(arg0 context.Context) (map[string][]string, error)
- func (m *MockRepository) GetLatestByTest(arg0 context.Context, arg1, arg2 string) (testkube.Execution, error)
- func (m *MockRepository) GetLatestByTests(arg0 context.Context, arg1 []string, arg2 string) ([]testkube.Execution, error)
- func (m *MockRepository) GetNextExecutionNumber(arg0 context.Context, arg1 string) (int32, error)
- func (m *MockRepository) GetTestMetrics(arg0 context.Context, arg1 string, arg2, arg3 int) (testkube.ExecutionsMetrics, error)
- func (m *MockRepository) Insert(arg0 context.Context, arg1 testkube.Execution) error
- func (m *MockRepository) StartExecution(arg0 context.Context, arg1 string, arg2 time.Time) error
- func (m *MockRepository) Update(arg0 context.Context, arg1 testkube.Execution) error
- func (m *MockRepository) UpdateResult(arg0 context.Context, arg1 string, arg2 testkube.Execution) error
- type MockRepositoryMockRecorder
- func (mr *MockRepositoryMockRecorder) DeleteAll(arg0 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) DeleteByTest(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) DeleteByTestSuite(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) DeleteByTestSuites(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) DeleteByTests(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) DeleteForAllTestSuites(arg0 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) EndExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) GetByNameAndTest(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) GetExecutionTotals(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) GetExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) GetLabels(arg0 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) GetLatestByTest(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) GetLatestByTests(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) GetNextExecutionNumber(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) GetTestMetrics(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) Insert(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) StartExecution(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) Update(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRepositoryMockRecorder) UpdateResult(arg0, arg1, arg2 interface{}) *gomock.Call
- type MongoOutputRepository
- func (r *MongoOutputRepository) DeleteAllOutput(ctx context.Context) error
- func (r *MongoOutputRepository) DeleteOutput(ctx context.Context, id, testName, testSuiteName string) error
- func (r *MongoOutputRepository) DeleteOutputByTest(ctx context.Context, testName string) error
- func (r *MongoOutputRepository) DeleteOutputByTestSuite(ctx context.Context, testSuiteName string) error
- func (r *MongoOutputRepository) DeleteOutputForAllTestSuite(ctx context.Context) error
- func (r *MongoOutputRepository) DeleteOutputForTestSuites(ctx context.Context, testSuiteNames []string) error
- func (r *MongoOutputRepository) DeleteOutputForTests(ctx context.Context, testNames []string) error
- func (r *MongoOutputRepository) GetOutput(ctx context.Context, id, testName, testSuiteName string) (output string, err error)
- func (r *MongoOutputRepository) InsertOutput(ctx context.Context, id, testName, testSuiteName, output string) error
- func (r *MongoOutputRepository) UpdateOutput(ctx context.Context, id, testName, testSuiteName, output string) error
- type MongoOutputRepositoryOpt
- type MongoRepository
- func NewMongoRepository(db *mongo.Database, allowDiskUse bool, opts ...MongoRepositoryOpt) *MongoRepository
- func NewMongoRepositoryWithMinioOutputStorage(db *mongo.Database, allowDiskUse bool, storageClient storage.Client, ...) *MongoRepository
- func NewMongoRepositoryWithOutputRepository(db *mongo.Database, allowDiskUse bool, outputRepository OutputRepository, ...) *MongoRepository
- func (r *MongoRepository) DeleteAll(ctx context.Context) (err error)
- func (r *MongoRepository) DeleteByTest(ctx context.Context, testName string) (err error)
- func (r *MongoRepository) DeleteByTestSuite(ctx context.Context, testSuiteName string) (err error)
- func (r *MongoRepository) DeleteByTestSuites(ctx context.Context, testSuiteNames []string) (err error)
- func (r *MongoRepository) DeleteByTests(ctx context.Context, testNames []string) (err error)
- func (r *MongoRepository) DeleteForAllTestSuites(ctx context.Context) (err error)
- func (r *MongoRepository) EndExecution(ctx context.Context, e testkube.Execution) (err error)
- func (r *MongoRepository) Get(ctx context.Context, id string) (result testkube.Execution, err error)
- func (r *MongoRepository) GetByNameAndTest(ctx context.Context, name, testName string) (result testkube.Execution, err error)
- func (r *MongoRepository) GetExecutionTotals(ctx context.Context, paging bool, filter ...Filter) (totals testkube.ExecutionsTotals, err error)
- func (r *MongoRepository) GetExecutions(ctx context.Context, filter Filter) (result []testkube.Execution, err error)
- func (r *MongoRepository) GetLabels(ctx context.Context) (labels map[string][]string, err error)
- func (r *MongoRepository) GetLatestByTest(ctx context.Context, testName, sortField string) (result testkube.Execution, err error)
- func (r *MongoRepository) GetLatestByTests(ctx context.Context, testNames []string, sortField string) (executions []testkube.Execution, err error)
- func (r *MongoRepository) GetNewestExecutions(ctx context.Context, limit int) (result []testkube.Execution, err error)
- func (r *MongoRepository) GetNextExecutionNumber(ctx context.Context, testName string) (number int32, err error)
- func (r *MongoRepository) GetTestMetrics(ctx context.Context, name string, limit, last int) (metrics testkube.ExecutionsMetrics, err error)
- func (r *MongoRepository) Insert(ctx context.Context, result testkube.Execution) (err error)
- func (r *MongoRepository) StartExecution(ctx context.Context, id string, startTime time.Time) (err error)
- func (r *MongoRepository) Update(ctx context.Context, result testkube.Execution) (err error)
- func (r *MongoRepository) UpdateResult(ctx context.Context, id string, result testkube.Execution) (err error)
- type MongoRepositoryOpt
- type OutputRepository
- type Repository
- type Sequences
Constants ¶
const ( CollectionResults = "results" CollectionSequences = "sequences" OutputMaxSize = 15 * 1024 * 1024 // the maximum document size is 16 megabytes in Mongo, leaving some space for other fields OverflownOutputPrefix = "WARNING: Output was shortened in order to fit into MongoDB.\n" )
const CollectionOutput = "output"
const PageDefaultLimit int = 100
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExecutionOutput ¶
type Filter ¶
type Filter interface { TestName() string TestNameDefined() bool LastNDays() int LastNDaysDefined() bool StartDate() time.Time StartDateDefined() bool EndDate() time.Time EndDateDefined() bool Statuses() testkube.ExecutionStatuses StatusesDefined() bool Page() int PageSize() int TextSearchDefined() bool TextSearch() string Selector() string TypeDefined() bool Type() string }
type FilterImpl ¶
type FilterImpl struct { FTestName string `json:"testName"` FStartDate *time.Time `json:"startDate"` FEndDate *time.Time `json:"endDate"` FLastNDays int `json:"lastNDays"` FStatuses testkube.ExecutionStatuses `json:"statuses"` FPage int `json:"page"` FPageSize int `json:"pageSize"` FTextSearch string `json:"textSearch"` FSelector string `json:"selector"` FObjectType string `json:"objectType"` }
func NewExecutionsFilter ¶
func NewExecutionsFilter() *FilterImpl
func (*FilterImpl) EndDate ¶
func (f *FilterImpl) EndDate() time.Time
func (*FilterImpl) EndDateDefined ¶
func (f *FilterImpl) EndDateDefined() bool
func (*FilterImpl) LastNDays ¶
func (f *FilterImpl) LastNDays() int
func (*FilterImpl) LastNDaysDefined ¶
func (f *FilterImpl) LastNDaysDefined() bool
func (*FilterImpl) Page ¶
func (f *FilterImpl) Page() int
func (*FilterImpl) PageSize ¶
func (f *FilterImpl) PageSize() int
func (*FilterImpl) Selector ¶
func (f *FilterImpl) Selector() string
func (*FilterImpl) StartDate ¶
func (f *FilterImpl) StartDate() time.Time
func (*FilterImpl) StartDateDefined ¶
func (f *FilterImpl) StartDateDefined() bool
func (*FilterImpl) Statuses ¶
func (f *FilterImpl) Statuses() testkube.ExecutionStatuses
func (*FilterImpl) StatusesDefined ¶
func (f *FilterImpl) StatusesDefined() bool
func (*FilterImpl) TestName ¶
func (f *FilterImpl) TestName() string
func (*FilterImpl) TestNameDefined ¶
func (f *FilterImpl) TestNameDefined() bool
func (*FilterImpl) TextSearch ¶
func (f *FilterImpl) TextSearch() string
func (*FilterImpl) TextSearchDefined ¶
func (f *FilterImpl) TextSearchDefined() bool
func (*FilterImpl) Type ¶
func (f *FilterImpl) Type() string
func (*FilterImpl) TypeDefined ¶
func (f *FilterImpl) TypeDefined() bool
func (*FilterImpl) WithEndDate ¶
func (f *FilterImpl) WithEndDate(date time.Time) *FilterImpl
func (*FilterImpl) WithLastNDays ¶
func (f *FilterImpl) WithLastNDays(days int) *FilterImpl
func (*FilterImpl) WithPage ¶
func (f *FilterImpl) WithPage(page int) *FilterImpl
func (*FilterImpl) WithPageSize ¶
func (f *FilterImpl) WithPageSize(pageSize int) *FilterImpl
func (*FilterImpl) WithSelector ¶
func (f *FilterImpl) WithSelector(selector string) *FilterImpl
func (*FilterImpl) WithStartDate ¶
func (f *FilterImpl) WithStartDate(date time.Time) *FilterImpl
func (*FilterImpl) WithStatus ¶
func (f *FilterImpl) WithStatus(status string) *FilterImpl
func (*FilterImpl) WithTestName ¶
func (f *FilterImpl) WithTestName(testName string) *FilterImpl
func (*FilterImpl) WithTextSearch ¶
func (f *FilterImpl) WithTextSearch(textSearch string) *FilterImpl
func (*FilterImpl) WithType ¶
func (f *FilterImpl) WithType(objectType string) *FilterImpl
type MinioRepository ¶
type MinioRepository struct {
// contains filtered or unexported fields
}
func NewMinioOutputRepository ¶
func NewMinioOutputRepository(storageClient storage.Client, executionCollection *mongo.Collection, bucket string) *MinioRepository
func (*MinioRepository) DeleteAllOutput ¶
func (m *MinioRepository) DeleteAllOutput(ctx context.Context) error
func (*MinioRepository) DeleteOutput ¶
func (m *MinioRepository) DeleteOutput(ctx context.Context, id, testName, testSuiteName string) error
func (*MinioRepository) DeleteOutputByTest ¶
func (m *MinioRepository) DeleteOutputByTest(ctx context.Context, testName string) error
func (*MinioRepository) DeleteOutputByTestSuite ¶
func (m *MinioRepository) DeleteOutputByTestSuite(ctx context.Context, testSuiteName string) error
func (*MinioRepository) DeleteOutputForAllTestSuite ¶
func (m *MinioRepository) DeleteOutputForAllTestSuite(ctx context.Context) error
func (*MinioRepository) DeleteOutputForTestSuites ¶
func (m *MinioRepository) DeleteOutputForTestSuites(ctx context.Context, testSuiteNames []string) error
func (*MinioRepository) DeleteOutputForTests ¶
func (m *MinioRepository) DeleteOutputForTests(ctx context.Context, testNames []string) error
func (*MinioRepository) InsertOutput ¶
func (m *MinioRepository) InsertOutput(ctx context.Context, id, testName, testSuiteName, output string) error
func (*MinioRepository) UpdateOutput ¶
func (m *MinioRepository) UpdateOutput(ctx context.Context, id, testName, testSuiteName, output string) error
type MockRepository ¶
type MockRepository struct {
// contains filtered or unexported fields
}
MockRepository is a mock of Repository interface.
func NewMockRepository ¶
func NewMockRepository(ctrl *gomock.Controller) *MockRepository
NewMockRepository creates a new mock instance.
func (*MockRepository) DeleteAll ¶
func (m *MockRepository) DeleteAll(arg0 context.Context) error
DeleteAll mocks base method.
func (*MockRepository) DeleteByTest ¶
func (m *MockRepository) DeleteByTest(arg0 context.Context, arg1 string) error
DeleteByTest mocks base method.
func (*MockRepository) DeleteByTestSuite ¶
func (m *MockRepository) DeleteByTestSuite(arg0 context.Context, arg1 string) error
DeleteByTestSuite mocks base method.
func (*MockRepository) DeleteByTestSuites ¶
func (m *MockRepository) DeleteByTestSuites(arg0 context.Context, arg1 []string) error
DeleteByTestSuites mocks base method.
func (*MockRepository) DeleteByTests ¶
func (m *MockRepository) DeleteByTests(arg0 context.Context, arg1 []string) error
DeleteByTests mocks base method.
func (*MockRepository) DeleteForAllTestSuites ¶
func (m *MockRepository) DeleteForAllTestSuites(arg0 context.Context) error
DeleteForAllTestSuites mocks base method.
func (*MockRepository) EXPECT ¶
func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRepository) EndExecution ¶
EndExecution mocks base method.
func (*MockRepository) GetByNameAndTest ¶
func (m *MockRepository) GetByNameAndTest(arg0 context.Context, arg1, arg2 string) (testkube.Execution, error)
GetByNameAndTest mocks base method.
func (*MockRepository) GetExecutionTotals ¶
func (m *MockRepository) GetExecutionTotals(arg0 context.Context, arg1 bool, arg2 ...Filter) (testkube.ExecutionsTotals, error)
GetExecutionTotals mocks base method.
func (*MockRepository) GetExecutions ¶
func (m *MockRepository) GetExecutions(arg0 context.Context, arg1 Filter) ([]testkube.Execution, error)
GetExecutions mocks base method.
func (*MockRepository) GetLatestByTest ¶
func (m *MockRepository) GetLatestByTest(arg0 context.Context, arg1, arg2 string) (testkube.Execution, error)
GetLatestByTest mocks base method.
func (*MockRepository) GetLatestByTests ¶
func (m *MockRepository) GetLatestByTests(arg0 context.Context, arg1 []string, arg2 string) ([]testkube.Execution, error)
GetLatestByTests mocks base method.
func (*MockRepository) GetNextExecutionNumber ¶
GetNextExecutionNumber mocks base method.
func (*MockRepository) GetTestMetrics ¶
func (m *MockRepository) GetTestMetrics(arg0 context.Context, arg1 string, arg2, arg3 int) (testkube.ExecutionsMetrics, error)
GetTestMetrics mocks base method.
func (*MockRepository) StartExecution ¶
StartExecution mocks base method.
func (*MockRepository) UpdateResult ¶
func (m *MockRepository) UpdateResult(arg0 context.Context, arg1 string, arg2 testkube.Execution) error
UpdateResult mocks base method.
type MockRepositoryMockRecorder ¶
type MockRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockRepositoryMockRecorder is the mock recorder for MockRepository.
func (*MockRepositoryMockRecorder) DeleteAll ¶
func (mr *MockRepositoryMockRecorder) DeleteAll(arg0 interface{}) *gomock.Call
DeleteAll indicates an expected call of DeleteAll.
func (*MockRepositoryMockRecorder) DeleteByTest ¶
func (mr *MockRepositoryMockRecorder) DeleteByTest(arg0, arg1 interface{}) *gomock.Call
DeleteByTest indicates an expected call of DeleteByTest.
func (*MockRepositoryMockRecorder) DeleteByTestSuite ¶
func (mr *MockRepositoryMockRecorder) DeleteByTestSuite(arg0, arg1 interface{}) *gomock.Call
DeleteByTestSuite indicates an expected call of DeleteByTestSuite.
func (*MockRepositoryMockRecorder) DeleteByTestSuites ¶
func (mr *MockRepositoryMockRecorder) DeleteByTestSuites(arg0, arg1 interface{}) *gomock.Call
DeleteByTestSuites indicates an expected call of DeleteByTestSuites.
func (*MockRepositoryMockRecorder) DeleteByTests ¶
func (mr *MockRepositoryMockRecorder) DeleteByTests(arg0, arg1 interface{}) *gomock.Call
DeleteByTests indicates an expected call of DeleteByTests.
func (*MockRepositoryMockRecorder) DeleteForAllTestSuites ¶
func (mr *MockRepositoryMockRecorder) DeleteForAllTestSuites(arg0 interface{}) *gomock.Call
DeleteForAllTestSuites indicates an expected call of DeleteForAllTestSuites.
func (*MockRepositoryMockRecorder) EndExecution ¶
func (mr *MockRepositoryMockRecorder) EndExecution(arg0, arg1 interface{}) *gomock.Call
EndExecution indicates an expected call of EndExecution.
func (*MockRepositoryMockRecorder) Get ¶
func (mr *MockRepositoryMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockRepositoryMockRecorder) GetByNameAndTest ¶
func (mr *MockRepositoryMockRecorder) GetByNameAndTest(arg0, arg1, arg2 interface{}) *gomock.Call
GetByNameAndTest indicates an expected call of GetByNameAndTest.
func (*MockRepositoryMockRecorder) GetExecutionTotals ¶
func (mr *MockRepositoryMockRecorder) GetExecutionTotals(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetExecutionTotals indicates an expected call of GetExecutionTotals.
func (*MockRepositoryMockRecorder) GetExecutions ¶
func (mr *MockRepositoryMockRecorder) GetExecutions(arg0, arg1 interface{}) *gomock.Call
GetExecutions indicates an expected call of GetExecutions.
func (*MockRepositoryMockRecorder) GetLabels ¶
func (mr *MockRepositoryMockRecorder) GetLabels(arg0 interface{}) *gomock.Call
GetLabels indicates an expected call of GetLabels.
func (*MockRepositoryMockRecorder) GetLatestByTest ¶
func (mr *MockRepositoryMockRecorder) GetLatestByTest(arg0, arg1, arg2 interface{}) *gomock.Call
GetLatestByTest indicates an expected call of GetLatestByTest.
func (*MockRepositoryMockRecorder) GetLatestByTests ¶
func (mr *MockRepositoryMockRecorder) GetLatestByTests(arg0, arg1, arg2 interface{}) *gomock.Call
GetLatestByTests indicates an expected call of GetLatestByTests.
func (*MockRepositoryMockRecorder) GetNextExecutionNumber ¶
func (mr *MockRepositoryMockRecorder) GetNextExecutionNumber(arg0, arg1 interface{}) *gomock.Call
GetNextExecutionNumber indicates an expected call of GetNextExecutionNumber.
func (*MockRepositoryMockRecorder) GetTestMetrics ¶
func (mr *MockRepositoryMockRecorder) GetTestMetrics(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
GetTestMetrics indicates an expected call of GetTestMetrics.
func (*MockRepositoryMockRecorder) Insert ¶
func (mr *MockRepositoryMockRecorder) Insert(arg0, arg1 interface{}) *gomock.Call
Insert indicates an expected call of Insert.
func (*MockRepositoryMockRecorder) StartExecution ¶
func (mr *MockRepositoryMockRecorder) StartExecution(arg0, arg1, arg2 interface{}) *gomock.Call
StartExecution indicates an expected call of StartExecution.
func (*MockRepositoryMockRecorder) Update ¶
func (mr *MockRepositoryMockRecorder) Update(arg0, arg1 interface{}) *gomock.Call
Update indicates an expected call of Update.
func (*MockRepositoryMockRecorder) UpdateResult ¶
func (mr *MockRepositoryMockRecorder) UpdateResult(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateResult indicates an expected call of UpdateResult.
type MongoOutputRepository ¶
type MongoOutputRepository struct {
Coll *mongo.Collection
}
func NewMongoOutputRepository ¶
func NewMongoOutputRepository(db *mongo.Database, opts ...MongoOutputRepositoryOpt) *MongoOutputRepository
func (*MongoOutputRepository) DeleteAllOutput ¶
func (r *MongoOutputRepository) DeleteAllOutput(ctx context.Context) error
func (*MongoOutputRepository) DeleteOutput ¶
func (r *MongoOutputRepository) DeleteOutput(ctx context.Context, id, testName, testSuiteName string) error
func (*MongoOutputRepository) DeleteOutputByTest ¶
func (r *MongoOutputRepository) DeleteOutputByTest(ctx context.Context, testName string) error
func (*MongoOutputRepository) DeleteOutputByTestSuite ¶
func (r *MongoOutputRepository) DeleteOutputByTestSuite(ctx context.Context, testSuiteName string) error
func (*MongoOutputRepository) DeleteOutputForAllTestSuite ¶
func (r *MongoOutputRepository) DeleteOutputForAllTestSuite(ctx context.Context) error
func (*MongoOutputRepository) DeleteOutputForTestSuites ¶
func (r *MongoOutputRepository) DeleteOutputForTestSuites(ctx context.Context, testSuiteNames []string) error
func (*MongoOutputRepository) DeleteOutputForTests ¶
func (r *MongoOutputRepository) DeleteOutputForTests(ctx context.Context, testNames []string) error
func (*MongoOutputRepository) InsertOutput ¶
func (r *MongoOutputRepository) InsertOutput(ctx context.Context, id, testName, testSuiteName, output string) error
func (*MongoOutputRepository) UpdateOutput ¶
func (r *MongoOutputRepository) UpdateOutput(ctx context.Context, id, testName, testSuiteName, output string) error
type MongoOutputRepositoryOpt ¶
type MongoOutputRepositoryOpt func(*MongoOutputRepository)
func WithMongoOutputRepositoryCollection ¶
func WithMongoOutputRepositoryCollection(collection *mongo.Collection) MongoOutputRepositoryOpt
type MongoRepository ¶
type MongoRepository struct { ResultsColl *mongo.Collection SequencesColl *mongo.Collection OutputRepository OutputRepository // contains filtered or unexported fields }
func NewMongoRepository ¶
func NewMongoRepository(db *mongo.Database, allowDiskUse bool, opts ...MongoRepositoryOpt) *MongoRepository
func NewMongoRepositoryWithOutputRepository ¶
func NewMongoRepositoryWithOutputRepository( db *mongo.Database, allowDiskUse bool, outputRepository OutputRepository, opts ...MongoRepositoryOpt, ) *MongoRepository
func (*MongoRepository) DeleteAll ¶
func (r *MongoRepository) DeleteAll(ctx context.Context) (err error)
DeleteAll deletes all execution results
func (*MongoRepository) DeleteByTest ¶
func (r *MongoRepository) DeleteByTest(ctx context.Context, testName string) (err error)
DeleteByTest deletes execution results by test
func (*MongoRepository) DeleteByTestSuite ¶
func (r *MongoRepository) DeleteByTestSuite(ctx context.Context, testSuiteName string) (err error)
DeleteByTestSuite deletes execution results by test suite
func (*MongoRepository) DeleteByTestSuites ¶
func (r *MongoRepository) DeleteByTestSuites(ctx context.Context, testSuiteNames []string) (err error)
DeleteByTestSuites deletes execution results by test suites
func (*MongoRepository) DeleteByTests ¶
func (r *MongoRepository) DeleteByTests(ctx context.Context, testNames []string) (err error)
DeleteByTests deletes execution results by tests
func (*MongoRepository) DeleteForAllTestSuites ¶
func (r *MongoRepository) DeleteForAllTestSuites(ctx context.Context) (err error)
DeleteForAllTestSuites deletes execution results for all test suites
func (*MongoRepository) EndExecution ¶
EndExecution updates execution end time
func (*MongoRepository) GetByNameAndTest ¶
func (*MongoRepository) GetExecutionTotals ¶
func (r *MongoRepository) GetExecutionTotals(ctx context.Context, paging bool, filter ...Filter) (totals testkube.ExecutionsTotals, err error)
func (*MongoRepository) GetExecutions ¶
func (*MongoRepository) GetLatestByTest ¶
func (*MongoRepository) GetLatestByTests ¶
func (*MongoRepository) GetNewestExecutions ¶
func (*MongoRepository) GetNextExecutionNumber ¶
func (*MongoRepository) GetTestMetrics ¶
func (r *MongoRepository) GetTestMetrics(ctx context.Context, name string, limit, last int) (metrics testkube.ExecutionsMetrics, err error)
GetTestMetrics returns test executions metrics limited to number of executions or last N days
func (*MongoRepository) StartExecution ¶
func (r *MongoRepository) StartExecution(ctx context.Context, id string, startTime time.Time) (err error)
StartExecution updates execution start time
func (*MongoRepository) UpdateResult ¶
type MongoRepositoryOpt ¶
type MongoRepositoryOpt func(*MongoRepository)
func WithMongoRepositoryResultCollection ¶
func WithMongoRepositoryResultCollection(collection *mongo.Collection) MongoRepositoryOpt
func WithMongoRepositorySequenceCollection ¶
func WithMongoRepositorySequenceCollection(collection *mongo.Collection) MongoRepositoryOpt
type OutputRepository ¶
type OutputRepository interface { // GetOutput gets execution output by id or name GetOutput(ctx context.Context, id, testName, testSuiteName string) (output string, err error) // InsertOutput inserts new execution output InsertOutput(ctx context.Context, id, testName, testSuiteName, output string) error // UpdateOutput updates execution output UpdateOutput(ctx context.Context, id, testName, testSuiteName, output string) error // DeleteOutput deletes execution output DeleteOutput(ctx context.Context, id, testName, testSuiteName string) error // DeleteOutputByTest deletes execution output by test DeleteOutputByTest(ctx context.Context, testName string) error // DeleteOutputForTests deletes execution output for tests DeleteOutputForTests(ctx context.Context, testNames []string) error // DeleteOutputByTestSuite deletes execution output by test suite DeleteOutputByTestSuite(ctx context.Context, testSuiteName string) error // DeleteOutputForTestSuites deletes execution output for test suites DeleteOutputForTestSuites(ctx context.Context, testSuiteNames []string) error // DeleteAllOutput deletes all execution output DeleteAllOutput(ctx context.Context) error // DeleteOutputForAllTestSuite deletes all execution output for test suite DeleteOutputForAllTestSuite(ctx context.Context) error }
type Repository ¶
type Repository interface { Sequences // Get gets execution result by id or name Get(ctx context.Context, id string) (testkube.Execution, error) // GetByNameAndTest gets execution result by name and test name GetByNameAndTest(ctx context.Context, name, testName string) (testkube.Execution, error) // GetLatestByTest gets latest execution result by test GetLatestByTest(ctx context.Context, testName, sortField string) (testkube.Execution, error) // GetLatestByTests gets latest execution results by test names GetLatestByTests(ctx context.Context, testNames []string, sortField string) (executions []testkube.Execution, err error) // GetExecutions gets executions using a filter, use filter with no data for all GetExecutions(ctx context.Context, filter Filter) ([]testkube.Execution, error) // GetExecutionTotals gets the statistics on number of executions using a filter, but without paging GetExecutionTotals(ctx context.Context, paging bool, filter ...Filter) (result testkube.ExecutionsTotals, err error) // Insert inserts new execution result Insert(ctx context.Context, result testkube.Execution) error // Update updates execution result Update(ctx context.Context, result testkube.Execution) error // UpdateResult updates result in execution UpdateResult(ctx context.Context, id string, execution testkube.Execution) error // StartExecution updates execution start time StartExecution(ctx context.Context, id string, startTime time.Time) error // EndExecution updates execution end time EndExecution(ctx context.Context, execution testkube.Execution) error // GetLabels get all available labels GetLabels(ctx context.Context) (labels map[string][]string, err error) // DeleteByTest deletes execution results by test DeleteByTest(ctx context.Context, testName string) error // DeleteByTestSuite deletes execution results by test suite DeleteByTestSuite(ctx context.Context, testSuiteName string) error // DeleteAll deletes all execution results DeleteAll(ctx context.Context) error // DeleteByTests deletes execution results by tests DeleteByTests(ctx context.Context, testNames []string) (err error) // DeleteByTestSuites deletes execution results by test suites DeleteByTestSuites(ctx context.Context, testSuiteNames []string) (err error) // DeleteForAllTestSuites deletes execution results for all test suites DeleteForAllTestSuites(ctx context.Context) (err error) GetTestMetrics(ctx context.Context, name string, limit, last int) (metrics testkube.ExecutionsMetrics, err error) }