sqldb

type DBRepository interface {
	Save(wf *wfv1.Workflow) error
	Get(uid string) (*wfv1.Workflow, error)
	List() ([]wfv1.Workflow, error)
	Query(condition interface{}) ([]wfv1.Workflow, error)
	Close() error
	IsNodeStatusOffload() bool
}

type WorkflowDB struct {
	Id         string         `db:"id"`
	Name       string         `db:"name"`
	Phase      wfv1.NodePhase `db:"phase"`
	Namespace  string         `db:"namespace"`
	Workflow   string         `db:"workflow"`
	StartedAt  time.Time      `db:"startedat"`
	FinishedAt time.Time      `db:"finishedat"`
}

type WorkflowDBContext struct {
	TableName         string
	NodeStatusOffload bool
	Session           sqlbuilder.Database
}