Documentation
¶
Index ¶
- Constants
- func BuildArchivedWorkflowSelector(selector db.Selector, tableName, labelTableName string, t sqldb.DBType, ...) (db.Selector, error)
- func BuildWorkflowSelector(in string, inArgs []any, tableName, labelTableName string, t sqldb.DBType, ...) (out string, outArgs []any, err error)
- func GetTableName(persistConfig *config.PersistConfig) (string, error)
- func Migrate(ctx context.Context, session db.Session, clusterName, tableName string) (err error)
- type OffloadNodeStatusRepo
- type UUIDVersion
- type WorkflowArchive
Constants ¶
View Source
const OffloadNodeStatusDisabled = "Workflow has offloaded nodes, but offloading has been disabled"
Variables ¶
This section is empty.
Functions ¶
func BuildArchivedWorkflowSelector ¶ added in v3.5.7
func BuildWorkflowSelector ¶ added in v3.5.7
func GetTableName ¶ added in v3.4.8
func GetTableName(persistConfig *config.PersistConfig) (string, error)
Types ¶
type OffloadNodeStatusRepo ¶
type OffloadNodeStatusRepo interface { Save(uid, namespace string, nodes wfv1.Nodes) (string, error) Get(uid, version string) (wfv1.Nodes, error) List(namespace string) (map[UUIDVersion]wfv1.Nodes, error) ListOldOffloads(namespace string) (map[string][]string, error) Delete(uid, version string) error IsEnabled() bool }
var ( ExplosiveOffloadNodeStatusRepo OffloadNodeStatusRepo = &explosiveOffloadNodeStatusRepo{} ErrOffloadNotSupported = fmt.Errorf("offload node status is not supported") )
func NewOffloadNodeStatusRepo ¶
func NewOffloadNodeStatusRepo(session db.Session, clusterName, tableName string) (OffloadNodeStatusRepo, error)
type UUIDVersion ¶
type WorkflowArchive ¶
type WorkflowArchive interface { ArchiveWorkflow(wf *wfv1.Workflow) error // list workflows, with the most recently started workflows at the beginning (i.e. index 0 is the most recent) ListWorkflows(options sutils.ListOptions) (wfv1.Workflows, error) CountWorkflows(options sutils.ListOptions) (int64, error) GetWorkflow(uid string, namespace string, name string) (*wfv1.Workflow, error) GetWorkflowForEstimator(namespace string, requirements []labels.Requirement) (*wfv1.Workflow, error) DeleteWorkflow(uid string) error DeleteExpiredWorkflows(ttl time.Duration) error IsEnabled() bool ListWorkflowsLabelKeys() (*wfv1.LabelKeys, error) ListWorkflowsLabelValues(key string) (*wfv1.LabelValues, error) }
var NullWorkflowArchive WorkflowArchive = &nullWorkflowArchive{}
func NewWorkflowArchive ¶
func NewWorkflowArchive(session db.Session, clusterName, managedNamespace string, instanceIDService instanceid.Service) WorkflowArchive
NewWorkflowArchive returns a new workflowArchive
Source Files
¶
Click to show internal directories.
Click to hide internal directories.