Versions in this module Expand all Collapse all v0 v0.1.2 Jun 3, 2020 Changes in this version + const MySQL + const Postgres + func CreateDBSession(kubectlConfig kubernetes.Interface, namespace string, ...) (sqlbuilder.Database, string, error) + func CreateMySQLDBSession(kubectlConfig kubernetes.Interface, namespace string, cfg *config.MySQLConfig, ...) (sqlbuilder.Database, string, error) + func CreatePostGresDBSession(kubectlConfig kubernetes.Interface, namespace string, ...) (sqlbuilder.Database, string, error) + type Migrate interface + Exec func(ctx context.Context) error + func NewMigrate(session sqlbuilder.Database, clusterName string, tableName string) Migrate + type OffloadNodeStatusRepo interface + Delete func(uid, version string) error + Get func(uid, version string) (wfv1.Nodes, error) + IsEnabled func() bool + List func(namespace string) (map[UUIDVersion]wfv1.Nodes, error) + ListOldOffloads func(namespace string) ([]UUIDVersion, error) + Save func(uid, namespace string, nodes wfv1.Nodes) (string, error) + var ExplosiveOffloadNodeStatusRepo OffloadNodeStatusRepo = &explosiveOffloadNodeStatusRepo{} + func NewOffloadNodeStatusRepo(session sqlbuilder.Database, clusterName, tableName string) (OffloadNodeStatusRepo, error) + type UUIDVersion struct + UID string + Version string + type WorkflowArchive interface + ArchiveWorkflow func(wf *wfv1.Workflow) error + DeleteWorkflow func(uid string) error + GetWorkflow func(uid string) (*wfv1.Workflow, error) + ListWorkflows func(namespace string, labelRequirements labels.Requirements, limit, offset int) (wfv1.Workflows, error) + var NullWorkflowArchive WorkflowArchive = &nullWorkflowArchive{} + func NewWorkflowArchive(session sqlbuilder.Database, clusterName string) WorkflowArchive