inlocalstore

Documentation

Index

• type JobStats
• type PersistentExecutionStore
  • func NewPersistentExecutionStore(params PersistentJobStoreParams) (*PersistentExecutionStore, error)
  • func (proxy *PersistentExecutionStore) CreateExecution(ctx context.Context, execution store.Execution) error
  • func (proxy *PersistentExecutionStore) DeleteExecution(ctx context.Context, id string) error
  • func (proxy *PersistentExecutionStore) GetExecution(ctx context.Context, id string) (store.Execution, error)
  • func (proxy *PersistentExecutionStore) GetExecutionCount(ctx context.Context) (uint, error)
  • func (proxy *PersistentExecutionStore) GetExecutionHistory(ctx context.Context, id string) ([]store.ExecutionHistory, error)
  • func (proxy *PersistentExecutionStore) GetExecutions(ctx context.Context, sharedID string) ([]store.Execution, error)
  • func (proxy *PersistentExecutionStore) UpdateExecutionState(ctx context.Context, request store.UpdateExecutionStateRequest) error
• type PersistentJobStoreParams

Types

type JobStats

type JobStats struct {
	JobsCompleted uint
}

type PersistentExecutionStore

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

func NewPersistentExecutionStore

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

func (*PersistentExecutionStore) CreateExecution

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

CreateExecution implements store.ExecutionStore

func (*PersistentExecutionStore) DeleteExecution

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

DeleteExecution implements store.ExecutionStore

func (*PersistentExecutionStore) GetExecution

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

GetExecution implements store.ExecutionStore

func (*PersistentExecutionStore) GetExecutionCount

func (proxy *PersistentExecutionStore) GetExecutionCount(ctx context.Context) (uint, error)

GetExecutionCount implements store.ExecutionStore

func (*PersistentExecutionStore) GetExecutionHistory

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

GetExecutionHistory implements store.ExecutionStore

func (*PersistentExecutionStore) GetExecutions

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

GetExecutions implements store.ExecutionStore

func (*PersistentExecutionStore) UpdateExecutionState

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

UpdateExecutionState implements store.ExecutionStore

type PersistentJobStoreParams

type PersistentJobStoreParams struct {
	Store   store.ExecutionStore
	RootDir string
}