storage

type ConsistencyModel int

type EngineType uint32

type EngineVault interface {
	// GetEngine - fetch the engine of selected type from the emitterVault
	GetEngine(EngineType) (Storage, error)
}

type EngineVaultMap map[EngineType]Storage

type ErrJobQueryFieldHasZeroValue struct {
	QueryField JobQueryField
}

type ErrJobQueryFieldIsAlreadySet struct {
	FieldValue interface{}
	QueryField JobQueryField
}

type EventStorage interface {
	// Test events storage interface
	StoreTestEvent(ctx xcontext.Context, event testevent.Event) error
	GetTestEvents(ctx xcontext.Context, eventQuery *testevent.Query) ([]testevent.Event, error)

	// Framework events storage interface
	StoreFrameworkEvent(ctx xcontext.Context, event frameworkevent.Event) error
	GetFrameworkEvent(ctx xcontext.Context, eventQuery *frameworkevent.Query) ([]frameworkevent.Event, error)
}

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

type FrameworkEventEmitterFetcher struct {
	FrameworkEventEmitter
	FrameworkEventFetcher
}

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

type JobQuery struct {
	States   []job.State
	Tags     []string
	ServerID string
}

type JobQueryField interface {
	// contains filtered or unexported methods
}

type JobQueryFields []JobQueryField

type JobStorage interface {
	// Job request interface
	StoreJobRequest(ctx xcontext.Context, request *job.Request) (types.JobID, error)
	GetJobRequest(ctx xcontext.Context, jobID types.JobID) (*job.Request, error)

	// Job report interface
	StoreReport(ctx xcontext.Context, report *job.Report) error
	GetJobReport(ctx xcontext.Context, jobID types.JobID) (*job.JobReport, error)

	// Job enumeration interface
	ListJobs(ctx xcontext.Context, query *JobQuery) ([]types.JobID, error)
}

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

type ResettableStorage interface {
	Storage
	Reset() error
}

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

type Storage interface {
	JobStorage
	EventStorage

	// Close flushes and releases resources associated with the storage engine.
	Close() error

	// Version returns the version of the storage being used
	Version() (uint64, error)
}

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

type TestEventEmitterFetcher struct {
	TestEventEmitter
	TestEventFetcher
}

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

type TransactionalStorage interface {
	Storage
	BeginTx() (TransactionalStorage, error)
	Commit() error
	Rollback() error
}