mirror of
https://github.com/onepanelio/onepanel.git
synced 2025-11-01 01:02:32 +08:00
117 lines
2.7 KiB
Go
117 lines
2.7 KiB
Go
package v1
|
|
|
|
import (
|
|
"time"
|
|
|
|
wfv1 "github.com/argoproj/argo/pkg/apis/workflow/v1alpha1"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
)
|
|
|
|
const (
|
|
TypeWorkflowTemplate string = "workflow_template"
|
|
TypeWorkflowTemplateVersion string = "workflow_template_version"
|
|
TypeWorkflowExecution string = "workflow_execution"
|
|
TypeCronWorkflow string = "cron_workflow"
|
|
TypeWorkspaceTemplate string = "workspace_template"
|
|
TypeWorkspaceTemplateVersion string = "workspace_template_version"
|
|
TypeWorkspace string = "workspace"
|
|
)
|
|
|
|
func TypeToTableName(value string) string {
|
|
switch value {
|
|
case TypeWorkflowTemplate:
|
|
return "workflow_templates"
|
|
case TypeWorkflowTemplateVersion:
|
|
return "workflow_template_versions"
|
|
case TypeWorkflowExecution:
|
|
return "workflow_executions"
|
|
case TypeCronWorkflow:
|
|
return "cron_workflows"
|
|
case TypeWorkspaceTemplate:
|
|
return "workspace_templates"
|
|
case TypeWorkspaceTemplateVersion:
|
|
return "workspace_template_versions"
|
|
case TypeWorkspace:
|
|
return "workspaces"
|
|
}
|
|
|
|
return ""
|
|
}
|
|
|
|
type Namespace struct {
|
|
Name string
|
|
Labels map[string]string
|
|
}
|
|
|
|
type Secret struct {
|
|
Name string
|
|
Data map[string]string
|
|
}
|
|
|
|
type ConfigMap struct {
|
|
Name string
|
|
Data map[string]string
|
|
}
|
|
|
|
type LogEntry struct {
|
|
Timestamp time.Time
|
|
Content string
|
|
}
|
|
|
|
type Metric struct {
|
|
Name string
|
|
Value float64
|
|
Format string `json:"omitempty"`
|
|
}
|
|
|
|
type WorkflowExecutionStatisticReport struct {
|
|
WorkflowTemplateId uint64 `db:"workflow_template_id"`
|
|
Total int32
|
|
LastExecuted time.Time `db:"last_executed"`
|
|
Running int32
|
|
Completed int32
|
|
Failed int32
|
|
Terminated int32
|
|
}
|
|
|
|
type CronWorkflowStatisticReport struct {
|
|
WorkflowTemplateId uint64 `db:"workflow_template_id"`
|
|
Total int32
|
|
}
|
|
|
|
type ListOptions = metav1.ListOptions
|
|
|
|
type PodGCStrategy = wfv1.PodGCStrategy
|
|
|
|
func WorkflowTemplatesToIds(workflowTemplates []*WorkflowTemplate) (ids []uint64) {
|
|
mappedIds := make(map[uint64]bool)
|
|
|
|
// This is to make sure we don't have duplicates
|
|
for _, workflowTemplate := range workflowTemplates {
|
|
mappedIds[workflowTemplate.ID] = true
|
|
}
|
|
|
|
for id := range mappedIds {
|
|
ids = append(ids, id)
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
// WorkflowTemplatesToVersionIDs picks out the WorkflowTemplateVersionID from each template and returns
|
|
// it as an array. Duplicates are removed.
|
|
func WorkflowTemplatesToVersionIDs(workflowTemplates []*WorkflowTemplate) (ids []uint64) {
|
|
mappedIds := make(map[uint64]bool)
|
|
|
|
// This is to make sure we don't have duplicates
|
|
for _, workflowTemplate := range workflowTemplates {
|
|
mappedIds[workflowTemplate.WorkflowTemplateVersionID] = true
|
|
}
|
|
|
|
for id := range mappedIds {
|
|
ids = append(ids, id)
|
|
}
|
|
|
|
return
|
|
}
|