Versions in this module Expand all Collapse all v3 v3.0.1 Feb 23, 2021 Changes in this version + const MySQL + const OffloadNodeStatusDisabled + 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{} + var OffloadNotSupportedError = fmt.Errorf("offload node status is not supported") + 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 + DeleteExpiredWorkflows func(ttl time.Duration) error + DeleteWorkflow func(uid string) error + GetWorkflow func(uid string) (*wfv1.Workflow, error) + IsEnabled func() bool + ListWorkflows func(namespace string, minStartAt, maxStartAt time.Time, ...) (wfv1.Workflows, error) + var NullWorkflowArchive WorkflowArchive = &nullWorkflowArchive{} + func NewWorkflowArchive(session sqlbuilder.Database, clusterName, managedNamespace string, ...) WorkflowArchive Other modules containing this package github.com/akshayflipkart/argo-workflows