Versions in this module Expand all Collapse all v1 v1.0.1 Aug 8, 2022 v1.0.0 Aug 4, 2022 Changes in this version + func FrameworkEventEmitTime(ev frameworkevent.Event) interface + func FrameworkEventJobID(ev frameworkevent.Event) interface + func FrameworkEventName(ev frameworkevent.Event) interface + func FrameworkEventPayload(ev frameworkevent.Event) interface + func New(dbURI string, opts ...Opt) (storage.Storage, error) + func TestEventEmitTime(ev testevent.Event) interface + func TestEventJobID(ev testevent.Event) interface + func TestEventName(ev testevent.Event) interface + func TestEventPayload(ev testevent.Event) interface + func TestEventRunID(ev testevent.Event) interface + func TestEventTargetID(ev testevent.Event) interface + func TestEventTestAttempt(ev testevent.Event) interface + func TestEventTestName(ev testevent.Event) interface + func TestEventTestStepLabel(ev testevent.Event) interface + type FrameworkEventField func(ev frameworkevent.Event) interface + type Opt func(rdbms *RDBMS) + func DriverName(name string) Opt + func FrameworkEventsFlushInterval(flushInterval time.Duration) Opt + func FrameworkEventsFlushSize(flushSize int) Opt + func TestEventsFlushInterval(flushInterval time.Duration) Opt + func TestEventsFlushSize(flushSize int) Opt + type RDBMS struct + func (r *RDBMS) BeginTx() (storage.TransactionalStorage, error) + func (r *RDBMS) Close() error + func (r *RDBMS) Commit() error + func (r *RDBMS) GetFrameworkEvent(ctx xcontext.Context, eventQuery *frameworkevent.Query) ([]frameworkevent.Event, error) + func (r *RDBMS) GetJobReport(ctx xcontext.Context, jobID types.JobID) (*job.JobReport, error) + func (r *RDBMS) GetJobRequest(ctx xcontext.Context, jobID types.JobID) (*job.Request, error) + func (r *RDBMS) GetTestEvents(ctx xcontext.Context, eventQuery *testevent.Query) ([]testevent.Event, error) + func (r *RDBMS) ListJobs(_ xcontext.Context, query *storage.JobQuery) ([]types.JobID, error) + func (r *RDBMS) Reset() error + func (r *RDBMS) Rollback() error + func (r *RDBMS) StoreFrameworkEvent(ctx xcontext.Context, event frameworkevent.Event) error + func (r *RDBMS) StoreJobRequest(_ xcontext.Context, request *job.Request) (types.JobID, error) + func (r *RDBMS) StoreReport(_ xcontext.Context, report *job.Report) error + func (r *RDBMS) StoreTestEvent(_ xcontext.Context, event testevent.Event) error + func (r *RDBMS) Version() (uint64, error) + type TestEventField func(ev testevent.Event) interface
Go to main page