compute

Documentation

Index

• type CallbackStore
  • func (m *CallbackStore) CreateExecution(ctx context.Context, execution store.Execution) error
  • func (m *CallbackStore) DeleteExecution(ctx context.Context, id string) error
  • func (m *CallbackStore) GetExecution(ctx context.Context, id string) (store.Execution, error)
  • func (m *CallbackStore) GetExecutionCount(ctx context.Context) (uint, error)
  • func (m *CallbackStore) GetExecutionHistory(ctx context.Context, id string) ([]store.ExecutionHistory, error)
  • func (m *CallbackStore) GetExecutions(ctx context.Context, jobID string) ([]store.Execution, error)
  • func (m *CallbackStore) UpdateExecutionState(ctx context.Context, request store.UpdateExecutionStateRequest) error

Types

type CallbackStore

type CallbackStore struct {
	GetExecutionFn         func(ctx context.Context, id string) (store.Execution, error)
	GetExecutionsFn        func(ctx context.Context, id string) ([]store.Execution, error)
	GetExecutionHistoryFn  func(ctx context.Context, id string) ([]store.ExecutionHistory, error)
	CreateExecutionFn      func(ctx context.Context, execution store.Execution) error
	UpdateExecutionStateFn func(ctx context.Context, request store.UpdateExecutionStateRequest) error
	DeleteExecutionFn      func(ctx context.Context, id string) error
	GetExecutionCountFn    func(ctx context.Context) (uint, error)
}

func (*CallbackStore) CreateExecution

func (m *CallbackStore) CreateExecution(ctx context.Context, execution store.Execution) error

func (*CallbackStore) DeleteExecution

func (m *CallbackStore) DeleteExecution(ctx context.Context, id string) error

func (*CallbackStore) GetExecution

func (m *CallbackStore) GetExecution(ctx context.Context, id string) (store.Execution, error)

func (*CallbackStore) GetExecutionCount

func (m *CallbackStore) GetExecutionCount(ctx context.Context) (uint, error)

func (*CallbackStore) GetExecutionHistory

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

func (*CallbackStore) GetExecutions

func (m *CallbackStore) GetExecutions(ctx context.Context, jobID string) ([]store.Execution, error)

func (*CallbackStore) UpdateExecutionState

func (m *CallbackStore) UpdateExecutionState(ctx context.Context, request store.UpdateExecutionStateRequest) error