inlocalstore

package

v1.1.1 Latest Latest Go to latest Published: Oct 9, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type JobStats struct {
	JobsCompleted uint64
}

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

func NewPersistentExecutionStore(params PersistentJobStoreParams) (*PersistentExecutionStore, error)

func (proxy *PersistentExecutionStore) Close(ctx context.Context) error

func (proxy *PersistentExecutionStore) CreateExecution(ctx context.Context, execution store.LocalExecutionState) error

CreateExecution implements store.ExecutionStore

func (proxy *PersistentExecutionStore) DeleteExecution(ctx context.Context, id string) error

DeleteExecution implements store.ExecutionStore

func (proxy *PersistentExecutionStore) GetExecution(ctx context.Context, id string) (store.LocalExecutionState, error)

GetExecution implements store.ExecutionStore

func (proxy *PersistentExecutionStore) GetExecutionCount(ctx context.Context, _ store.LocalExecutionStateType) (uint64, error)

GetExecutionCount implements store.ExecutionStore

func (proxy *PersistentExecutionStore) GetExecutionHistory(ctx context.Context, id string) ([]store.LocalStateHistory, error)

GetExecutionHistory implements store.ExecutionStore

func (proxy *PersistentExecutionStore) GetExecutions(ctx context.Context, sharedID string) ([]store.LocalExecutionState, error)

GetExecutions implements store.ExecutionStore

func (proxy *PersistentExecutionStore) GetLiveExecutions(ctx context.Context) ([]store.LocalExecutionState, error)

func (proxy *PersistentExecutionStore) UpdateExecutionState(ctx context.Context, request store.UpdateExecutionStateRequest) error

UpdateExecutionState implements store.ExecutionStore

type PersistentJobStoreParams struct {
	Store   store.ExecutionStore
	RootDir string
}