inmemory

Documentation

Index

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

Types

type Store

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

func NewStore

func NewStore() *Store

func (*Store) CreateExecution

func (s *Store) CreateExecution(ctx context.Context, execution store.Execution) error

func (*Store) DeleteExecution

func (s *Store) DeleteExecution(ctx context.Context, id string) error

func (*Store) GetExecution

func (s *Store) GetExecution(ctx context.Context, id string) (store.Execution, error)

func (*Store) GetExecutionCount

func (s *Store) GetExecutionCount(ctx context.Context) (uint, error)

func (*Store) GetExecutionHistory

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

func (*Store) GetExecutions

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

func (*Store) UpdateExecutionState

func (s *Store) UpdateExecutionState(ctx context.Context, request store.UpdateExecutionStateRequest) error