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 ApplyJobQueryField(fieldPtr interface{}, queryField JobQueryField) error + func NewTestEventEmitter(vault EngineVault, header testevent.Header) testevent.Emitter + func NewTestEventEmitterFetcher(vault EngineVault, header testevent.Header) testevent.EmitterFetcher + func NewTestEventEmitterFetcherWithAllowedEvents(vault EngineVault, header testevent.Header, allowedEvents *map[event.Name]bool) testevent.EmitterFetcher + func NewTestEventEmitterWithAllowedEvents(vault EngineVault, header testevent.Header, allowedEvents *map[event.Name]bool) testevent.Emitter + func NewTestEventFetcher(vault EngineVault) testevent.Fetcher + func WithConsistencyModel(ctx xcontext.Context, model ConsistencyModel) xcontext.Context + type ConsistencyModel int + const ConsistentEventually + const ConsistentReadAfterWrite + type EngineType uint32 + const AsyncEngine + const SyncEngine + const UnknownEngine + type EngineVault interface + GetEngine func(EngineType) (Storage, error) + type EngineVaultMap map[EngineType]Storage + type ErrJobQueryFieldHasZeroValue struct + QueryField JobQueryField + func (err ErrJobQueryFieldHasZeroValue) Error() string + type ErrJobQueryFieldIsAlreadySet struct + FieldValue interface{} + QueryField JobQueryField + func (err ErrJobQueryFieldIsAlreadySet) Error() string + type EventStorage interface + GetFrameworkEvent func(ctx xcontext.Context, eventQuery *frameworkevent.Query) ([]frameworkevent.Event, error) + GetTestEvents func(ctx xcontext.Context, eventQuery *testevent.Query) ([]testevent.Event, error) + StoreFrameworkEvent func(ctx xcontext.Context, event frameworkevent.Event) error + StoreTestEvent func(ctx xcontext.Context, event testevent.Event) error + type FrameworkEventEmitter struct + func NewFrameworkEventEmitter(vault EngineVault) FrameworkEventEmitter + func (ev FrameworkEventEmitter) Emit(ctx xcontext.Context, event frameworkevent.Event) error + type FrameworkEventEmitterFetcher struct + func NewFrameworkEventEmitterFetcher(vault EngineVault) FrameworkEventEmitterFetcher + type FrameworkEventFetcher struct + func NewFrameworkEventFetcher(vault EngineVault) FrameworkEventFetcher + func (ev FrameworkEventFetcher) Fetch(ctx xcontext.Context, queryFields ...frameworkevent.QueryField) ([]frameworkevent.Event, error) + type JobQuery struct + ServerID string + States []job.State + Tags []string + func BuildJobQuery(queryFields ...JobQueryField) (*JobQuery, error) + type JobQueryField interface + func QueryJobServerID(serverID string) JobQueryField + func QueryJobStates(states ...job.State) JobQueryField + func QueryJobTags(tags ...string) JobQueryField + type JobQueryFields []JobQueryField + func (queryFields JobQueryFields) BuildQuery() (*JobQuery, error) + type JobStorage interface + GetJobReport func(ctx xcontext.Context, jobID types.JobID) (*job.JobReport, error) + GetJobRequest func(ctx xcontext.Context, jobID types.JobID) (*job.Request, error) + ListJobs func(ctx xcontext.Context, query *JobQuery) ([]types.JobID, error) + StoreJobRequest func(ctx xcontext.Context, request *job.Request) (types.JobID, error) + StoreReport func(ctx xcontext.Context, report *job.Report) error + type JobStorageManager struct + func NewJobStorageManager(vault EngineVault) JobStorageManager + func (jsm JobStorageManager) GetJobReport(ctx xcontext.Context, jobID types.JobID) (*job.JobReport, error) + func (jsm JobStorageManager) GetJobRequest(ctx xcontext.Context, jobID types.JobID) (*job.Request, error) + func (jsm JobStorageManager) ListJobs(ctx xcontext.Context, query *JobQuery) ([]types.JobID, error) + func (jsm JobStorageManager) StoreJobRequest(ctx xcontext.Context, request *job.Request) (types.JobID, error) + func (jsm JobStorageManager) StoreReport(ctx xcontext.Context, report *job.Report) error + type ResettableStorage interface + Reset func() error + type SimpleEngineVault struct + func NewSimpleEngineVault() *SimpleEngineVault + func (v *SimpleEngineVault) GetEngine(engineType EngineType) (Storage, error) + func (v *SimpleEngineVault) StoreEngine(storageEngine Storage, engineType EngineType) error + type Storage interface + Close func() error + Version func() (uint64, error) + type TestEventEmitter struct + func (e TestEventEmitter) Emit(ctx xcontext.Context, data testevent.Data) error + type TestEventEmitterFetcher struct + type TestEventFetcher struct + func (ev TestEventFetcher) Fetch(ctx xcontext.Context, queryFields ...testevent.QueryField) ([]testevent.Event, error) + type TransactionalStorage interface + BeginTx func() (TransactionalStorage, error) + Commit func() error + Rollback func() error
Go to main page