mgo

Documentation

Index

• func New(uri string) (*mongo.Client, error)
• func NewTelemetryDB(db *mongo.Database, telemetryTable string, enabled bool, logger *zap.Logger) *telemetryDB
• func NewTestCase(c *kmongo.Collection, log *zap.Logger) *testCaseDB
• type RunDB
  • func NewRun(c *kmongo.Collection, test *kmongo.Collection, log *zap.Logger) *RunDB
  • func (r *RunDB) Increment(ctx context.Context, success, failure bool, id string) error
  • func (r *RunDB) PutTest(ctx context.Context, t run.Test) error
  • func (r *RunDB) Read(ctx context.Context, cid string, user, app, id *string, from, to *time.Time, ...) ([]*run.TestRun, error)
  • func (r *RunDB) ReadTest(ctx context.Context, id string) (run.Test, error)
  • func (r *RunDB) ReadTests(ctx context.Context, runID string) ([]run.Test, error)
  • func (r *RunDB) Upsert(ctx context.Context, testRun run.TestRun) error

Functions

func New

func New(uri string) (*mongo.Client, error)

func NewTelemetryDB

func NewTelemetryDB(db *mongo.Database, telemetryTable string, enabled bool, logger *zap.Logger) *telemetryDB

func NewTestCase

func NewTestCase(c *kmongo.Collection, log *zap.Logger) *testCaseDB

Types

type RunDB

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

func NewRun

func NewRun(c *kmongo.Collection, test *kmongo.Collection, log *zap.Logger) *RunDB

func (*RunDB) Increment

func (r *RunDB) Increment(ctx context.Context, success, failure bool, id string) error

func (*RunDB) PutTest

func (r *RunDB) PutTest(ctx context.Context, t run.Test) error

func (*RunDB) Read

func (r *RunDB) Read(ctx context.Context, cid string, user, app, id *string, from, to *time.Time, offset int, limit int) ([]*run.TestRun, error)

func (*RunDB) ReadTest

func (r *RunDB) ReadTest(ctx context.Context, id string) (run.Test, error)

func (*RunDB) ReadTests

func (r *RunDB) ReadTests(ctx context.Context, runID string) ([]run.Test, error)

func (*RunDB) Upsert

func (r *RunDB) Upsert(ctx context.Context, testRun run.TestRun) error