sqlite_execution_repository

Documentation

Index

• func New(db interfaces.SqlDatabase) repository.Execution
• type ExecutionSqlRecord
  • func (n *ExecutionSqlRecord) ToExecution() *workflow.Execution
• type SqliteExecutionRepository
  • func (r *SqliteExecutionRepository) CloseExecution(ctx context.Context, id workflow.ExecutionIdentifier, result workflow.Status, ...) error
  • func (r *SqliteExecutionRepository) CreateExecution(ctx context.Context, ex *workflow.Execution) error
  • func (r *SqliteExecutionRepository) GetExecution(ctx context.Context, id workflow.ExecutionIdentifier) (*workflow.Execution, error)
  • func (r *SqliteExecutionRepository) Init(ctx context.Context) error

Functions

func New

func New(db interfaces.SqlDatabase) repository.Execution

Types

type ExecutionSqlRecord

type ExecutionSqlRecord struct {
	Identifier string     `db:"identifier"`
	Workflow   string     `db:"workflow"`
	Status     string     `db:"status"`
	CreatedAt  time.Time  `db:"created_at"`
	UpdatedAt  time.Time  `db:"updated_at"`
	FinishedAt *time.Time `db:"finished_at"`
	Results    *string    `db:"results"`
}

func (*ExecutionSqlRecord) ToExecution

func (n *ExecutionSqlRecord) ToExecution() *workflow.Execution

type SqliteExecutionRepository

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

func (*SqliteExecutionRepository) CloseExecution

func (r *SqliteExecutionRepository) CloseExecution(ctx context.Context, id workflow.ExecutionIdentifier, result workflow.Status, output workflow.SerializedExecutionResult) error

func (*SqliteExecutionRepository) CreateExecution

func (r *SqliteExecutionRepository) CreateExecution(ctx context.Context, ex *workflow.Execution) error

func (*SqliteExecutionRepository) GetExecution

func (r *SqliteExecutionRepository) GetExecution(ctx context.Context, id workflow.ExecutionIdentifier) (*workflow.Execution, error)

func (*SqliteExecutionRepository) Init

func (r *SqliteExecutionRepository) Init(ctx context.Context) error