inmemory

Documentation

Index

• type Store
  • func NewStore() *Store
  • func (s *Store) Close(ctx context.Context) error
  • func (s *Store) CreateExecution(ctx context.Context, localExecutionState store.LocalExecutionState) error
  • func (s *Store) DeleteExecution(ctx context.Context, id string) error
  • func (s *Store) GetExecution(ctx context.Context, id string) (store.LocalExecutionState, error)
  • func (s *Store) GetExecutionCount(ctx context.Context, state store.LocalExecutionStateType) (uint64, error)
  • func (s *Store) GetExecutionHistory(ctx context.Context, id string) ([]store.LocalStateHistory, error)
  • func (s *Store) GetExecutions(ctx context.Context, jobID string) ([]store.LocalExecutionState, error)
  • func (s *Store) GetLiveExecutions(ctx context.Context) ([]store.LocalExecutionState, 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) Close

func (s *Store) Close(ctx context.Context) error

func (*Store) CreateExecution

func (s *Store) CreateExecution(ctx context.Context, localExecutionState store.LocalExecutionState) 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.LocalExecutionState, error)

func (*Store) GetExecutionCount

func (s *Store) GetExecutionCount(ctx context.Context, state store.LocalExecutionStateType) (uint64, error)

func (*Store) GetExecutionHistory

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

func (*Store) GetExecutions

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

func (*Store) GetLiveExecutions

func (s *Store) GetLiveExecutions(ctx context.Context) ([]store.LocalExecutionState, error)

func (*Store) UpdateExecutionState

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