repository

Documentation

Index

• type WorkflowConfigSnapshot
• type WorkflowConfigSnapshotRepository
• type WorkflowConfigSnapshotRepositoryImpl
  • func NewWorkflowConfigSnapshotRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger, ...) *WorkflowConfigSnapshotRepositoryImpl
  • func (impl *WorkflowConfigSnapshotRepositoryImpl) FindLatestFailedWorkflowSnapshot(workflowId int, workflowType types.WorkflowType) (*WorkflowConfigSnapshot, error)
  • func (impl *WorkflowConfigSnapshotRepositoryImpl) SaveWithTx(tx *pg.Tx, snapshot *WorkflowConfigSnapshot) (*WorkflowConfigSnapshot, error)

Types

type WorkflowConfigSnapshot

type WorkflowConfigSnapshot struct {
	Id                           int                `sql:"id,pk"`
	WorkflowId                   int                `sql:"workflow_id,notnull"`
	WorkflowType                 types.WorkflowType `sql:"workflow_type,notnull"`
	PipelineId                   int                `sql:"pipeline_id,notnull"`
	WorkflowRequestJson          string             `sql:"workflow_request_json,notnull"`
	WorkflowRequestSchemaVersion string             `sql:"workflow_request_schema_version"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type WorkflowConfigSnapshotRepository

type WorkflowConfigSnapshotRepository interface {
	SaveWithTx(tx *pg.Tx, snapshot *WorkflowConfigSnapshot) (*WorkflowConfigSnapshot, error)
	// New methods for retrigger functionality
	FindLatestFailedWorkflowSnapshot(workflowId int, workflowType types.WorkflowType) (*WorkflowConfigSnapshot, error)
	sql.TransactionWrapper
}

type WorkflowConfigSnapshotRepositoryImpl

type WorkflowConfigSnapshotRepositoryImpl struct {
	*sql.TransactionUtilImpl
	// contains filtered or unexported fields
}

func NewWorkflowConfigSnapshotRepositoryImpl

func NewWorkflowConfigSnapshotRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger, transactionUtilImpl *sql.TransactionUtilImpl) *WorkflowConfigSnapshotRepositoryImpl

func (*WorkflowConfigSnapshotRepositoryImpl) FindLatestFailedWorkflowSnapshot

func (impl *WorkflowConfigSnapshotRepositoryImpl) FindLatestFailedWorkflowSnapshot(workflowId int, workflowType types.WorkflowType) (*WorkflowConfigSnapshot, error)

FindLatestFailedWorkflowSnapshot finds the latest failed workflow snapshot for retrigger This method looks for the original workflow that failed, not the retrigger attempts

func (*WorkflowConfigSnapshotRepositoryImpl) SaveWithTx

func (impl *WorkflowConfigSnapshotRepositoryImpl) SaveWithTx(tx *pg.Tx, snapshot *WorkflowConfigSnapshot) (*WorkflowConfigSnapshot, error)