sql_execution_repository

Documentation

Index

• func New(db interfaces.SqlDatabase) repository.Execution
• type ExecutionSqlRecord
  • func (n *ExecutionSqlRecord) ToExecution() *workflow.Execution
• type SqlExecutionRepository
  • func (r *SqlExecutionRepository) Close()
  • func (r *SqlExecutionRepository) CloseExecution(ctx context.Context, id workflow.ExecutionIdentifier, result workflow.Status, ...) error
  • func (r *SqlExecutionRepository) CreateExecution(ctx context.Context, ex *workflow.Execution) error
  • func (r *SqlExecutionRepository) GetExecution(ctx context.Context, id workflow.ExecutionIdentifier) (*workflow.Execution, error)
  • func (r *SqlExecutionRepository) 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 SqlExecutionRepository

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

func (*SqlExecutionRepository) Close

func (r *SqlExecutionRepository) Close()

func (*SqlExecutionRepository) CloseExecution

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

func (*SqlExecutionRepository) CreateExecution

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

func (*SqlExecutionRepository) GetExecution

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

func (*SqlExecutionRepository) Init

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