Documentation
¶
Index ¶
- Constants
- func NewExecutionsFilter() *filter
- type Filter
- type MongoRepository
- func (r *MongoRepository) EndExecution(ctx context.Context, id string, endTime time.Time, duration time.Duration) (err error)
- func (r *MongoRepository) Get(ctx context.Context, id string) (result testkube.TestExecution, err error)
- func (r *MongoRepository) GetByNameAndScript(ctx context.Context, name, script string) (result testkube.TestExecution, err error)
- func (r *MongoRepository) GetExecutions(ctx context.Context, filter Filter) (result []testkube.TestExecution, err error)
- func (r *MongoRepository) GetExecutionsTotals(ctx context.Context, filter Filter) (totals testkube.ExecutionsTotals, err error)
- func (r *MongoRepository) GetNewestExecutions(ctx context.Context, limit int) (result []testkube.TestExecution, err error)
- func (r *MongoRepository) Insert(ctx context.Context, result testkube.TestExecution) (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.TestExecution) (err error)
- type Repository
Constants ¶
View Source
const CollectionName = "testresults"
View Source
const PageDefaultLimit int = 1000
TODO: Adjust when it gets too small.
Variables ¶
This section is empty.
Functions ¶
func NewExecutionsFilter ¶
func NewExecutionsFilter() *filter
Types ¶
type MongoRepository ¶
type MongoRepository struct {
Coll *mongo.Collection
}
func NewMongoRespository ¶
func NewMongoRespository(db *mongo.Database) *MongoRepository
func (*MongoRepository) EndExecution ¶
func (r *MongoRepository) EndExecution(ctx context.Context, id string, endTime time.Time, duration time.Duration) (err error)
EndExecution updates execution end time
func (*MongoRepository) Get ¶
func (r *MongoRepository) Get(ctx context.Context, id string) (result testkube.TestExecution, err error)
func (*MongoRepository) GetByNameAndScript ¶
func (r *MongoRepository) GetByNameAndScript(ctx context.Context, name, script string) (result testkube.TestExecution, err error)
func (*MongoRepository) GetExecutions ¶
func (r *MongoRepository) GetExecutions(ctx context.Context, filter Filter) (result []testkube.TestExecution, err error)
func (*MongoRepository) GetExecutionsTotals ¶
func (r *MongoRepository) GetExecutionsTotals(ctx context.Context, filter Filter) (totals testkube.ExecutionsTotals, err error)
func (*MongoRepository) GetNewestExecutions ¶
func (r *MongoRepository) GetNewestExecutions(ctx context.Context, limit int) (result []testkube.TestExecution, err error)
func (*MongoRepository) Insert ¶
func (r *MongoRepository) Insert(ctx context.Context, result testkube.TestExecution) (err error)
func (*MongoRepository) StartExecution ¶
func (r *MongoRepository) StartExecution(ctx context.Context, id string, startTime time.Time) (err error)
StartExecution updates execution start time
func (*MongoRepository) Update ¶
func (r *MongoRepository) Update(ctx context.Context, result testkube.TestExecution) (err error)
type Repository ¶
type Repository interface {
// Get gets execution result by id
Get(ctx context.Context, id string) (testkube.TestExecution, error)
// GetByNameAndScript gets execution result by name
GetByNameAndScript(ctx context.Context, name, script string) (testkube.TestExecution, error)
// GetExecutionsTotals gets executions total stats using a filter, use filter with no data for all
GetExecutionsTotals(ctx context.Context, filter Filter) (totals testkube.ExecutionsTotals, err error)
// GetExecutions gets executions using a filter, use filter with no data for all
GetExecutions(ctx context.Context, filter Filter) ([]testkube.TestExecution, error)
// Insert inserts new execution result
Insert(ctx context.Context, result testkube.TestExecution) error
// Update updates execution result
Update(ctx context.Context, result testkube.TestExecution) 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, id string, endTime time.Time, duration time.Duration) error
}
Click to show internal directories.
Click to hide internal directories.