v1

Oct 28, 2021

Changes in this version

type ArtifactRepositoryGCSProvider

+ Source string

type ArtifactRepositoryS3Provider

+ Source string

type Client

+ func (c *Client) CreateVirtualService(namespace string, data interface{}) error

+ func (c *Client) GetArtifactRepositorySource(namespace string) (string, error)

type SystemConfig

+ func (s SystemConfig) Provider() *string

type WorkflowTemplate

+ func CreateWorkflowTemplate(name string) (*WorkflowTemplate, error)

type WorkspaceTemplate

+ func CreateWorkspaceTemplate(name string) (*WorkspaceTemplate, error)

Aug 12, 2021

Changes in this version

type ArtifactRepositoryS3Provider

+ PublicEndpoint string

+ PublicInsecure bool

type Client

+ func (c *Client) CreateInferenceService(deployment *InferenceService) error

+ func (c *Client) DeleteModel(namespace, name string) error

+ func (c *Client) GetModelStatus(namespace, name string) (*InferenceServiceStatus, error)

+ func (c *Client) GetNamespace(name string) (namespace *Namespace, err error)

+ func (c *Client) GetObjectPresignedURL(namespace, key string) (download *GetPresignedURLDownload, err error)

+ func (c *Client) GetPublicS3Client(namespace string, config *ArtifactRepositoryS3Provider) (s3Client *s3.Client, err error)

+ func (c *Client) HasService(name string) (bool, error)

+ type Env struct

+ Name string

+ Value string

+ type GetPresignedURLDownload struct

+ Size int64

+ URL string

+ type InferenceService struct

+ Name string

+ Namespace string

+ Predictor *Predictor

+ Transformer *Transformer

+ func (m *InferenceService) ToResource() interface{}

+ type InferenceServiceStatus struct

+ Conditions []inferenceServiceCondition

+ PredictURL string

+ Ready bool

+ type MachineResources struct

+ CPU string

+ Memory string

+ type Predictor struct

+ Name string

+ NodeSelector map[string]string

+ Resources *Resources

+ RuntimeVersion string

+ StorageURI string

+ func (p *Predictor) SetNodeSelector(label, selector string)

+ func (p *Predictor) SetResources(minCPU, maxCPU, minMemory, maxMemory string)

+ type Resources struct

+ Limits *MachineResources

+ Requests *MachineResources

+ type Transformer struct

+ Containers []TransformerContainer

+ type TransformerContainer struct

+ Env []Env

+ Image string

+ Name string

+ Resources *Resources

type WorkflowTemplate

+ Description string

type WorkflowTemplateVersion

+ Description string

type Workspace

+ CaptureNode bool

Apr 1, 2021

Changes in this version

type Client

+ func (c *Client) CountWorkflowExecutionsForWorkflowTemplate(workflowTemplateID uint64) (count int, err error)

+ func (c *Client) GetWorkflowTemplateRaw(namespace, uid string) (workflowTemplate *WorkflowTemplate, err error)

Mar 12, 2021

Changes in this version

type Client

+ func (c *Client) ListWorkflowExecutionsField(namespace, field string) (value []string, err error)

+ func (c *Client) ListWorkflowTemplatesField(namespace, field string, isSystem bool) (value []string, err error)

+ func (c *Client) ListWorkspaceTemplatesField(namespace, field string) (value []string, err error)

+ func (c *Client) ListWorkspacesField(namespace, field string) (value []string, err error)

type SystemConfig

+ func (s SystemConfig) NodePoolOptionsMap() (result map[string]*NodePoolOption, err error)

type WorkflowExecutionOptions

+ WorkflowTemplateUID string

Feb 9, 2021

Changes in this version

+ func GenerateWorkspaceUID(name string) (string, error)

type Client

+ func (c *Client) GetWorkspaceContainerLogs(namespace, uid, containerName string, sinceTime time.Time) (<-chan []*LogEntry, error)

+ type WorkspaceService struct

+ Name string

+ Path string

type WorkspaceTemplate

+ func (wt *WorkspaceTemplate) GetServices() ([]*WorkspaceService, error)

Jan 12, 2021

Changes in this version

type Client

+ func (c *Client) GenerateWorkflowTemplateManifest(manifest string) (string, error)

+ func (c *Client) GetArtifactRepositoryType(namespace string) (string, error)

type LogEntry

+ func LogEntryFromLine(line *string) *LogEntry

+ func (l *LogEntry) IsEmpty() bool

type SystemConfig

+ func (s SystemConfig) NodePoolOptionsAsParameters() (result []*ParameterOption, err error)

type WorkflowTemplateVersion

+ func (wtv *WorkflowTemplateVersion) LoadParametersFromBytes() ([]Parameter, error)

type WorkspaceSpec

+ ImagePullSecrets []corev1.LocalObjectReference

Dec 16, 2020

Changes in this version

type Client

+ func (c *Client) AddWorkflowExecutionMetrics(namespace, uid string, metrics Metrics, override bool) (workflowExecution *WorkflowExecution, err error)

+ func (c *Client) UpdateWorkflowExecutionMetrics(namespace, uid string, metrics Metrics) (workflowExecution *WorkflowExecution, err error)

+ type Metrics []*Metric

+ func (m *Metrics) Add(input *Metric, override bool)

+ func (m *Metrics) Merge(input Metrics, override bool)

+ func (m *Metrics) Scan(src interface{}) error

+ func (m *Metrics) Unmarshal(v interface{}) error

+ func (m Metrics) Value() (driver.Value, error)

type WorkflowExecution

+ Metrics Metrics

type WorkflowTemplateFilter

+ func (wt *WorkflowTemplateFilter) GetLabels() []*Label

Nov 9, 2020

Changes in this version

+ func SelectLabels(query *SelectLabelsQuery) sq.SelectBuilder

+ func SkipKeysFromString(keys string) []string

type Client

+ Token string

+ func (c *Client) ListAvailableLabels(query *SelectLabelsQuery) (result []*Label, err error)

+ type SelectLabelsQuery struct

+ Alias string

+ KeyLike string

+ Namespace string

+ Skip []string

+ Table string

Oct 20, 2020

Changes in this version

type Client

+ func GetDefaultClient() (*Client, error)

+ func GetDefaultClientWithDB(db *DB) (*Client, error)

type SystemConfig

+ func (s SystemConfig) HMACKey() []byte

Oct 6, 2020

Changes in this version

+ const WorkspaceDAGTemplateCreateStatefulSet

+ const WorkspaceDAGTemplateCreateWorkspace

+ const WorkspaceDAGTemplateDeletePVC

+ const WorkspaceDAGTemplateDeleteStatefulSet

+ const WorkspaceDAGTemplateDeleteWorkspace

+ const WorkspaceDAGTemplateGetStatefulSet

+ const WorkspaceDAGTemplateService

+ const WorkspaceDAGTemplateSysSetPhasePaused

+ const WorkspaceDAGTemplateSysSetPhaseRunning

+ const WorkspaceDAGTemplateSysSetPhaseTerminated

+ const WorkspaceDAGTemplateVirtualService

+ const WorkspaceDeletePVCResource

+ const WorkspaceDeleteStatefulSetResource

+ const WorkspaceGetStatefulSetResource

+ const WorkspaceResource

+ const WorkspaceServiceResource

+ const WorkspaceStatefulSetResource

+ const WorkspaceVirtualServiceResource

+ func ApplyLabelSelectQuery(labelSelector string, sb sq.SelectBuilder, filter LabelFilter) (sq.SelectBuilder, error)

type Client

+ func (c *Client) GetWorkflowExecutionStatisticsForNamespace(namespace string) (report *WorkflowExecutionStatisticReport, err error)

+ func (c *Client) GetWorkspaceStatisticsForNamespace(namespace string) (report *WorkspaceStatisticReport, err error)

+ func (c *Client) StartWorkspace(namespace string, workspace *Workspace) (*Workspace, error)

+ func (c *Client) UpdateWorkspaceTemplateManifest(namespace, uid string, manifest string) (*WorkspaceTemplate, error)

+ type LabelFilter interface

+ GetLabels func() []*Label

+ type WorkflowExecutionFilter struct

+ Labels []*Label

+ Phase string

+ func (wf *WorkflowExecutionFilter) GetLabels() []*Label

+ type WorkspaceFilter struct

+ Labels []*Label

+ Phase string

+ func (wf *WorkspaceFilter) GetLabels() []*Label

type WorkspacePhase

+ const WorkspaceFailedToLaunch

+ const WorkspaceFailedToPause

+ const WorkspaceFailedToResume

+ const WorkspaceFailedToTerminate

+ const WorkspaceFailedToUpdate

+ type WorkspaceStatisticReport struct

+ Failed int32

+ FailedToLaunch int32

+ FailedToPause int32

+ FailedToResume int32

+ FailedToTerminate int32

+ FailedToUpdate int32

+ LastCreated *time.Time

+ Launching int32

+ Paused int32

+ Pausing int32

+ Running int32

+ Terminated int32

+ Terminating int32

+ Total int32

+ Updating int32

+ type WorkspaceTemplateFilter struct

+ Labels []*Label

+ UID string

+ func (wt *WorkspaceTemplateFilter) GetLabels() []*Label

Aug 25, 2020

Changes in this version

+ func IsValidParameter(parameter Parameter) error

+ func IsValidParameters(parameters []Parameter) error

+ func LabelsToJSONString(labels []*Label) (string, error)

+ func MapParametersByName(parameters []Parameter) map[string]Parameter

+ type ArtifactRepositoryGCSProvider struct

+ Bucket string

+ Endpoint string

+ Insecure bool

+ KeyFormat string

+ ServiceAccountJSON string

+ ServiceAccountKey string

+ ServiceAccountKeySecret ArtifactRepositorySecret

+ func (g *ArtifactRepositoryGCSProvider) FormatKey(namespace, workflowName, podName string) string

+ func (g *ArtifactRepositoryGCSProvider) MarshalToYaml() (string, error)

+ type ArtifactRepositoryProvider struct

+ GCS *ArtifactRepositoryGCSProvider

+ S3 *ArtifactRepositoryS3Provider

+ type ArtifactRepositoryS3Provider struct

+ AccessKey string

+ AccessKeySecret ArtifactRepositorySecret

+ Bucket string

+ Endpoint string

+ Insecure bool

+ KeyFormat string

+ Region string

+ SecretKeySecret ArtifactRepositorySecret

+ Secretkey string

+ func (a *ArtifactRepositoryS3Provider) FormatKey(namespace, workflowName, podName string) string

+ func (a *ArtifactRepositoryS3Provider) MarshalToYaml() (string, error)

+ type ArtifactRepositorySecret struct

+ Key string

+ Name string

type Client

+ func (c *Client) DeleteResourceLabels(runner sq.BaseRunner, resource string) error

+ func (c *Client) GetGCSClient(namespace string, config *ArtifactRepositoryGCSProvider) (gcsClient *gcs.Client, err error)

+ func (c *Client) GetService(namespace, name string) (*Service, error)

+ func (c *Client) GetWebRouter() (router.Web, error)

+ func (c *Client) ListAllWorkflowTemplates(namespace string, paginator *pagination.PaginationRequest, ...) (workflowTemplateVersions []*WorkflowTemplate, err error)

+ func (c *Client) ListServices(namespace string) ([]*Service, error)

+ func (c *Client) ListWorkflowTemplateVersionsAll(paginator *pagination.PaginationRequest) (workflowTemplateVersions []*WorkflowTemplateVersion, err error)

+ func (c *Client) ListWorkflowTemplateVersionsModels(namespace, uid string) (workflowTemplateVersions []*WorkflowTemplateVersion, err error)

+ func (c *Client) UpdateWorkflowTemplateVersion(wtv *WorkflowTemplateVersion) error

+ type CronWorkflowManifest struct

+ WorkflowExecutionSpec WorkflowExecutionSpec

type Label

+ func LabelFromString(value string) (label *Label, err error)

+ func LabelsFromString(value string) (labels []*Label, err error)

+ type NodePoolOption struct

+ Resources corev1.ResourceRequirements

type Parameter

+ Visibility *string

+ type Service struct

+ Name string

+ URL string

type SystemConfig

+ func NewSystemConfig(configMap *ConfigMap, secret *Secret) (config SystemConfig, err error)

+ func (s SystemConfig) DatabaseConnection() (driverName, dataSourceName string)

+ func (s SystemConfig) NodePoolOptionByValue(value string) (option *NodePoolOption, err error)

+ func (s SystemConfig) UpdateNodePoolOptions(parameters []Parameter) ([]Parameter, error)

type WorkflowExecution

+ ArgoWorkflow *wfv1.Workflow

+ Namespace string

+ func (we *WorkflowExecution) GenerateUID(name string) error

+ func (we *WorkflowExecution) GetParameterValue(name string) *string

+ type WorkflowExecutionSpec struct

+ Arguments Arguments

type WorkflowTemplate

+ Parameters []Parameter

+ type WorkflowTemplateFilter struct

+ Labels []*Label

+ type WorkflowTemplateManifest struct

+ Arguments Arguments

type WorkflowTemplateVersion

+ Parameters []Parameter

+ ParametersBytes []byte

type Workspace

+ func (w *Workspace) GenerateUID(name string) error

+ func (w *Workspace) GetParameterValue(name string) *string

type WorkspaceTemplate

+ Description string

Jun 30, 2020

Changes in this version

+ func CronWorkflowsToIDs(resources []*CronWorkflow) (ids []uint64)

+ func WorkflowTemplateVersionsToIDs(resources []*WorkflowTemplateVersion) (ids []uint64)

+ func WorkflowTemplatesToVersionIDs(workflowTemplates []*WorkflowTemplate) (ids []uint64)

+ func WorkspaceTemplatesToVersionIDs(resources []*WorkspaceTemplate) (ids []uint64)

+ func WorkspacesToIDs(resources []*Workspace) (ids []uint64)

type Client

+ func (c *Client) ClearSystemConfigCache()

+ func (c *Client) CountWorkflowTemplatesByName(namespace, name string, archived *bool) (count uint64, err error)

+ func (c *Client) GetDBLabelsMapped(resource string, ids ...uint64) (result map[uint64]map[string]string, err error)

+ func (c *Client) GetDefaultConfig() (config *ConfigMap, err error)

+ func (c *Client) GetLatestWorkflowTemplate(namespace, uid string) (workflowTemplate *WorkflowTemplate, err error)

+ func (c *Client) GetLatestWorkflowTemplateVersionDB(namespace, name string) (workflowTemplateVersion *WorkflowTemplateVersion, err error)

+ func (c *Client) GetWorkflowTemplateDB(namespace, name string) (workflowTemplate *WorkflowTemplate, err error)

+ func (c *Client) GetWorkflowTemplateVersionDB(namespace, name, version string) (workflowTemplateVersion *WorkflowTemplateVersion, err error)

+ func (c *Client) InsertLabelsRunner(runner sq.BaseRunner, resource string, resourceID uint64, ...) (sql.Result, error)

type CronWorkflow

+ WorkflowTemplateVersionID uint64

+ func (cw *CronWorkflow) GetParametersFromWorkflowSpecJSON() ([]byte, error)

type DB

+ func NewDB(db *sqlx.DB) *DB

+ func (db *DB) Getx(dest interface{}, builder sq.SelectBuilder) error

+ func (db *DB) Selectx(dest interface{}, builder sq.SelectBuilder) error

type Label

+ ResourceID uint64

+ type SystemConfig map[string]string

+ func (s SystemConfig) APIProtocol() *string

+ func (s SystemConfig) APIURL() *string

+ func (s SystemConfig) DatabaseDriverName() *string

+ func (s SystemConfig) Domain() *string

+ func (s SystemConfig) FQDN() *string

+ func (s SystemConfig) GetValue(name string) *string

+ func (s SystemConfig) NodePoolLabel() (label *string)

+ func (s SystemConfig) NodePoolOptions() (options []*ParameterOption, err error)

type WorkflowExecutionStatistic

+ WorkflowTemplateID uint64

type WorkflowTemplate

+ WorkflowTemplateVersionID uint64

+ func (wt *WorkflowTemplate) ReplaceManifestParameters(params []Parameter) error

type Workspace

+ func (w *Workspace) GetURL(protocol, domain string) string

type WorkspaceSpec

+ VolumeClaimTemplates []corev1.PersistentVolumeClaim

type WorkspaceTemplate

+ func (wt *WorkspaceTemplate) InjectRuntimeParameters(config SystemConfig) error

Jun 5, 2020

Changes in this version

+ func WorkspacesToIds(resources []*Workspace) (ids []uint64)

type ArtifactRepositoryS3Config

+ func (a *ArtifactRepositoryS3Config) FormatKey(namespace, workflowName, podName string) string

type Client

+ func (c *Client) ArchiveWorkspace(namespace, uid string) (err error)

+ func (c *Client) CountWorkflowTemplateVersions(namespace, uid string) (count uint64, err error)

+ func (c *Client) ListWorkspacesByTemplateID(namespace string, templateID uint64) (workspaces []*Workspace, err error)

May 24, 2020

Changes in this version

+ const TypeWorkspace

+ const TypeWorkspaceTemplate

+ const TypeWorkspaceTemplateVersion

+ func WorkspaceTemplatesToVersionIds(resources []*WorkspaceTemplate) (ids []uint64)

+ type ArtifactRepositoryConfig struct

+ S3 *ArtifactRepositoryS3Config

type ArtifactRepositoryS3Config

+ AccessKey string

+ AccessKeySecret corev1.SecretKeySelector

+ Bucket string

+ Endpoint string

+ Insecure bool

+ KeyFormat string

+ Region string

+ SecretKeySecret corev1.SecretKeySelector

+ Secretkey string

type Client

+ func (c *Client) ArchiveCronWorkflow(namespace, uid string) (err error)

+ func (c *Client) ArchiveWorkflowExecution(namespace, uid string) error

+ func (c *Client) ArchiveWorkspaceTemplate(namespace string, uid string) (archived bool, err error)

+ func (c *Client) CountWorkspaces(namespace string) (count int, err error)

+ func (c *Client) InsertLabels(resource string, resourceID uint64, keyValues map[string]string) (sql.Result, error)

+ func (c *Client) ReplaceLabelsUsingKnownID(namespace, resource string, resourceID uint64, uid string, ...) error

+ func (c *Client) ResumeWorkspace(namespace, uid string) (err error)

+ func (c *Client) UpdateWorkflowExecutionStatus(namespace, uid string, status *WorkflowExecutionStatus) (err error)

+ func (c *Client) UpdateWorkspace(namespace, uid string, parameters []Parameter) (err error)

+ func (c *Client) WorkspaceTemplateHasRunningWorkspaces(namespace string, uid string) (bool, error)

type CronWorkflow

+ Namespace string

+ type NamespaceConfig struct

+ ArtifactRepository ArtifactRepositoryConfig

type Parameter

+ func ParseParametersFromManifest(manifest []byte) ([]Parameter, error)

type WorkflowExecutionStatisticReport

+ Terminated int32

+ type WorkflowExecutionStatus struct

+ FinishedAt *time.Time

+ Phase wfv1.NodePhase

+ StartedAt *time.Time

type WorkflowTemplate

+ IsSystem bool

+ Resource *string

+ ResourceUID *string

type Workspace

+ URL string

+ WorkflowTemplateVersion *WorkflowTemplateVersion

type WorkspacePhase

+ const WorkspaceLaunching

+ const WorkspaceUpdating

type WorkspaceStatus

+ UpdatedAt *time.Time

type WorkspaceTemplate

+ IsArchived bool

+ Labels map[string]string

+ ModifiedAt *time.Time

+ Namespace string

+ WorkflowTemplateID uint64

+ WorkspaceTemplateVersionID uint64

May 7, 2020

Changes in this version

+ const TypeCronWorkflow

+ const TypeWorkflowExecution

+ const TypeWorkflowTemplate

+ const TypeWorkflowTemplateVersion

+ func CronWorkflowsToIds(resources []*CronWorkflow) (ids []uint64)

+ func FilePathToExtension(path string) string

+ func FilePathToName(path string) string

+ func FilePathToParentPath(path string) string

+ func GetBearerToken(namespace string) (string, error)

+ func GetResourceIdBuilder(resource, uid string) (*sq.SelectBuilder, error)

+ func LabelsToMapping(labels ...*Label) map[string]string

+ func TypeToTableName(value string) string

+ func UnmarshalWorkflows(wfBytes []byte, strict bool) (wfs []wfv1.Workflow, err error)

+ func WorkflowTemplateVersionsToIds(resources []*WorkflowTemplateVersion) (ids []uint64)

+ func WorkflowTemplatesToIds(workflowTemplates []*WorkflowTemplate) (ids []uint64)

+ func WorkflowTemplatesToVersionIds(workflowTemplates []*WorkflowTemplate) (ids []uint64)

+ type Arguments struct

+ Parameters []Parameter

+ type ArtifactRepositoryS3Config struct

+ S3 struct{ ... }

+ type Client struct

+ func NewClient(config *Config, db *sqlx.DB) (client *Client, err error)

+ func (c *Client) AddLabels(namespace, resource, uid string, keyValues map[string]string) error

+ func (c *Client) AddSecretKeyValue(namespace string, secret *Secret) (inserted bool, err error)

+ func (c *Client) ArchiveWorkflowTemplate(namespace, uid string) (archived bool, err error)

+ func (c *Client) ArgoprojV1alpha1() argoprojv1alpha1.ArgoprojV1alpha1Interface

+ func (c *Client) CloneWorkflowExecution(namespace, name string) (*WorkflowExecution, error)

+ func (c *Client) CountCronWorkflows(namespace, workflowTemplateUID string) (count int, err error)

+ func (c *Client) CountWorkflowExecutions(namespace, workflowTemplateUID, workflowTemplateVersion string) (count int, err error)

+ func (c *Client) CountWorkflowTemplates(namespace string) (count int, err error)

+ func (c *Client) CountWorkspaceTemplates(namespace string) (count int, err error)

+ func (c *Client) CreateConfigMap(namespace string, configMap *ConfigMap) (err error)

+ func (c *Client) CreateCronWorkflow(namespace string, cronWorkflow *CronWorkflow) (*CronWorkflow, error)

+ func (c *Client) CreateNamespace(name string) (namespace *Namespace, err error)

+ func (c *Client) CreateSecret(namespace string, secret *Secret) (err error)

+ func (c *Client) CreateWorkflowExecution(namespace string, workflow *WorkflowExecution) (*WorkflowExecution, error)

+ func (c *Client) CreateWorkflowTemplate(namespace string, workflowTemplate *WorkflowTemplate) (*WorkflowTemplate, error)

+ func (c *Client) CreateWorkflowTemplateVersion(namespace string, workflowTemplate *WorkflowTemplate) (*WorkflowTemplate, error)

+ func (c *Client) CreateWorkspace(namespace string, workspace *Workspace) (*Workspace, error)

+ func (c *Client) CreateWorkspaceTemplate(namespace string, workspaceTemplate *WorkspaceTemplate) (*WorkspaceTemplate, error)

+ func (c *Client) CronStartWorkflowExecutionStatisticInsert(namespace, name string, workflowTemplateID int64) (err error)

+ func (c *Client) DeleteCronWorkflowLabel(namespace, name string, keysToDelete ...string) (labels map[string]string, err error)

+ func (c *Client) DeleteLabels(namespace, resource, uid string, keyValues map[string]string) error

+ func (c *Client) DeleteSecret(namespace string, name string) (deleted bool, err error)

+ func (c *Client) DeleteSecretKey(namespace string, secret *Secret) (deleted bool, err error)

+ func (c *Client) DeleteWorkflowExecutionLabel(namespace, name string, keysToDelete ...string) (labels map[string]string, err error)

+ func (c *Client) DeleteWorkflowTemplateLabel(namespace, name string, keysToDelete ...string) (labels map[string]string, err error)

+ func (c *Client) DeleteWorkspace(namespace, uid string) (err error)

+ func (c *Client) FinishWorkflowExecutionStatisticViaExitHandler(namespace, name string, workflowTemplateID int64, phase wfv1.NodePhase, ...) (err error)

+ func (c *Client) GenerateWorkspaceTemplateWorkflowTemplate(workspaceTemplate *WorkspaceTemplate) (workflowTemplate *WorkflowTemplate, err error)

+ func (c *Client) GetArtifact(namespace, name, key string) (data []byte, err error)

+ func (c *Client) GetConfigMap(namespace, name string) (configMap *ConfigMap, err error)

+ func (c *Client) GetCronWorkflow(namespace, name string) (cronWorkflow *CronWorkflow, err error)

+ func (c *Client) GetCronWorkflowLabels(namespace, name, prefix string) (labels map[string]string, err error)

+ func (c *Client) GetCronWorkflowStatisticsForTemplates(workflowTemplates ...*WorkflowTemplate) (err error)

+ func (c *Client) GetDbLabels(resource string, ids ...uint64) (labels []*Label, err error)

+ func (c *Client) GetDbLabelsMapped(resource string, ids ...uint64) (result map[uint64]map[string]string, err error)

+ func (c *Client) GetK8sLabelResource(namespace, resource, uid string) (source interface{}, result *v1.ObjectMeta, err error)

+ func (c *Client) GetNamespaceConfig(namespace string) (config map[string]string, err error)

+ func (c *Client) GetS3Client(namespace string, config map[string]string) (s3Client *s3.Client, err error)

+ func (c *Client) GetSecret(namespace, name string) (secret *Secret, err error)

+ func (c *Client) GetSystemConfig() (config map[string]string, err error)

+ func (c *Client) GetWorkflowExecution(namespace, name string) (workflow *WorkflowExecution, err error)

+ func (c *Client) GetWorkflowExecutionLabels(namespace, name, prefix string) (labels map[string]string, err error)

+ func (c *Client) GetWorkflowExecutionLogs(namespace, name, podName, containerName string) (<-chan *LogEntry, error)

+ func (c *Client) GetWorkflowExecutionMetrics(namespace, name, podName string) (metrics []*Metric, err error)

+ func (c *Client) GetWorkflowExecutionStatisticsForTemplates(workflowTemplates ...*WorkflowTemplate) (err error)

+ func (c *Client) GetWorkflowTemplate(namespace, uid string, version int64) (workflowTemplate *WorkflowTemplate, err error)

+ func (c *Client) GetWorkflowTemplateByName(namespace, name string, version int64) (workflowTemplate *WorkflowTemplate, err error)

+ func (c *Client) GetWorkflowTemplateDb(namespace, name string) (workflowTemplate *WorkflowTemplate, err error)

+ func (c *Client) GetWorkflowTemplateLabels(namespace, name, prefix string, version int64) (labels map[string]string, err error)

+ func (c *Client) GetWorkflowTemplateVersionDb(namespace, name, version string) (workflowTemplateVersion *WorkflowTemplateVersion, err error)

+ func (c *Client) GetWorkspace(namespace, uid string) (workspace *Workspace, err error)

+ func (c *Client) GetWorkspaceTemplate(namespace, uid string, version int64) (workspaceTemplate *WorkspaceTemplate, err error)

+ func (c *Client) InsertLabelsBuilder(resource string, resourceId uint64, keyValues map[string]string) sq.InsertBuilder

+ func (c *Client) ListCronWorkflows(namespace, workflowTemplateUID string, ...) (cronWorkflows []*CronWorkflow, err error)

+ func (c *Client) ListFiles(namespace, key string) (files []*File, err error)

+ func (c *Client) ListLabels(resource string, uid string) (labels []*Label, err error)

+ func (c *Client) ListNamespaces() (namespaces []*Namespace, err error)

+ func (c *Client) ListOnepanelEnabledNamespaces() (namespaces []*Namespace, err error)

+ func (c *Client) ListSecrets(namespace string) (secrets []*Secret, err error)

+ func (c *Client) ListWorkflowExecutions(namespace, workflowTemplateUID, workflowTemplateVersion string, ...) (workflows []*WorkflowExecution, err error)

+ func (c *Client) ListWorkflowTemplateVersions(namespace, uid string) (workflowTemplateVersions []*WorkflowTemplate, err error)

+ func (c *Client) ListWorkflowTemplates(namespace string, paginator *pagination.PaginationRequest) (workflowTemplateVersions []*WorkflowTemplate, err error)

+ func (c *Client) ListWorkspaceTemplateVersions(namespace, uid string) (workspaceTemplates []*WorkspaceTemplate, err error)

+ func (c *Client) ListWorkspaceTemplates(namespace string, paginator *pagination.PaginationRequest) (workspaceTemplates []*WorkspaceTemplate, err error)

+ func (c *Client) ListWorkspaces(namespace string, paginator *pagination.PaginationRequest) (workspaces []*Workspace, err error)

+ func (c *Client) PauseWorkspace(namespace, uid string) (err error)

+ func (c *Client) ReplaceLabels(namespace, resource, uid string, keyValues map[string]string) error

+ func (c *Client) ResubmitWorkflowExecution(namespace, name string) (workflow *WorkflowExecution, err error)

+ func (c *Client) ResumeWorkflowExecution(namespace, name string) (workflow *WorkflowExecution, err error)

+ func (c *Client) RetryWorkflowExecution(namespace, name string) (workflow *WorkflowExecution, err error)

+ func (c *Client) SecretExists(namespace string, name string) (exists bool, err error)

+ func (c *Client) SetCronWorkflowLabels(namespace, name, prefix string, keyValues map[string]string, deleteOld bool) (workflowLabels map[string]string, err error)

+ func (c *Client) SetWorkflowExecutionLabels(namespace, name, prefix string, keyValues map[string]string, deleteOld bool) (workflowLabels map[string]string, err error)

+ func (c *Client) SetWorkflowTemplateLabels(namespace, name, prefix string, keyValues map[string]string, deleteOld bool) (workflowLabels map[string]string, err error)

+ func (c *Client) SuspendWorkflowExecution(namespace, name string) (err error)

+ func (c *Client) TerminateCronWorkflow(namespace, name string) (err error)

+ func (c *Client) TerminateWorkflowExecution(namespace, name string) (err error)

+ func (c *Client) UpdateCronWorkflow(namespace string, name string, cronWorkflow *CronWorkflow) (*CronWorkflow, error)

+ func (c *Client) UpdateK8sLabelResource(namespace, resource string, obj interface{}) error

+ func (c *Client) UpdateSecretKeyValue(namespace string, secret *Secret) (updated bool, err error)

+ func (c *Client) UpdateWorkspaceStatus(namespace, uid string, status *WorkspaceStatus) (err error)

+ func (c *Client) UpdateWorkspaceTemplate(namespace string, workspaceTemplate *WorkspaceTemplate) (*WorkspaceTemplate, error)

+ func (c *Client) ValidateWorkflowExecution(namespace string, manifest []byte) (err error)

+ func (c *Client) WatchWorkflowExecution(namespace, name string) (<-chan *WorkflowExecution, error)

+ type Config = rest.Config

+ func NewConfig() (config *Config)

+ type ConfigMap struct

+ Data map[string]string

+ Name string

+ type CronWorkflow struct

+ CreatedAt time.Time

+ GenerateName string

+ ID uint64

+ Labels map[string]string

+ Manifest string

+ ModifiedAt *time.Time

+ Name string

+ UID string

+ Version int64

+ WorkflowExecution *WorkflowExecution

+ WorkflowTemplateVersionId uint64

+ func (cw *CronWorkflow) AddToManifestSpec(key, manifest string) error

+ func (cw *CronWorkflow) GetParametersFromWorkflowSpec() ([]Parameter, error)

+ func (cw *CronWorkflow) GetParametersFromWorkflowSpecJson() ([]byte, error)

+ type CronWorkflowStatisticReport struct

+ Total int32

+ WorkflowTemplateId uint64

+ type DB = sqlx.DB

+ type File struct

+ ContentType string

+ Directory bool

+ Extension string

+ LastModified time.Time

+ Name string

+ Path string

+ Size int64

+ type Label struct

+ CreatedAt time.Time

+ ID uint64

+ Key string

+ Resource string

+ ResourceId uint64

+ Value string

+ type ListOptions = metav1.ListOptions

+ type LogEntry struct

+ Content string

+ Timestamp time.Time

+ type Metric struct

+ Format string

+ Name string

+ Value float64

+ type Namespace struct

+ Labels map[string]string

+ Name string

+ type Parameter struct

+ DisplayName *string

+ Hint *string

+ Name string

+ Options []*ParameterOption

+ Required bool

+ Type string

+ Value *string

+ func ParameterFromMap(paramMap map[interface{}]interface{}) *Parameter

+ type ParameterOption struct

+ Name string

+ Value string

+ type PodGCStrategy = wfv1.PodGCStrategy

+ type Secret struct

+ Data map[string]string

+ Name string

+ type WorkflowExecution struct

+ CreatedAt time.Time

+ FinishedAt *time.Time

+ GenerateName string

+ ID uint64

+ Labels map[string]string

+ Manifest string

+ Name string

+ Parameters []Parameter

+ ParametersBytes []byte

+ Phase wfv1.NodePhase

+ StartedAt *time.Time

+ UID string

+ WorkflowTemplate *WorkflowTemplate

+ func (we *WorkflowExecution) LoadParametersFromBytes() ([]Parameter, error)

+ type WorkflowExecutionOptions struct

+ Entrypoint string

+ GenerateName string

+ Labels *map[string]string

+ ListOptions *ListOptions

+ Name string

+ Parameters []Parameter

+ PodGCStrategy *PodGCStrategy

+ ServiceAccount string

+ type WorkflowExecutionStatistic struct

+ CreatedAt *time.Time

+ FailedAt *time.Time

+ FinishedAt *time.Time

+ ID uint64

+ Name string

+ Namespace string

+ WorkflowTemplateId uint64

+ type WorkflowExecutionStatisticReport struct

+ Completed int32

+ Failed int32

+ LastExecuted time.Time

+ Running int32

+ Total int32

+ WorkflowTemplateId uint64

+ type WorkflowTemplate struct

+ ArgoWorkflowTemplate *wfv1.WorkflowTemplate

+ CreatedAt time.Time

+ CronWorkflowsStatisticsReport *CronWorkflowStatisticReport

+ ID uint64

+ IsArchived bool

+ IsLatest bool

+ Labels map[string]string

+ Manifest string

+ ModifiedAt *time.Time

+ Name string

+ Namespace string

+ UID string

+ Version int64

+ Versions int64

+ WorkflowExecutionStatisticReport *WorkflowExecutionStatisticReport

+ WorkflowTemplateVersionId uint64

+ func (wt *WorkflowTemplate) AddWorkflowTemplateParametersFromAnnotations(spec mapping.Mapping)

+ func (wt *WorkflowTemplate) FormatManifest() (string, error)

+ func (wt *WorkflowTemplate) GenerateUID() (string, error)

+ func (wt *WorkflowTemplate) GetManifestBytes() []byte

+ func (wt *WorkflowTemplate) GetParametersKeyString() (map[string]string, error)

+ func (wt *WorkflowTemplate) GetWorkflowManifestBytes() ([]byte, error)

+ func (wt *WorkflowTemplate) UpdateManifestParameters(params []Parameter) error

+ func (wt *WorkflowTemplate) WrapSpec() ([]byte, error)

+ type WorkflowTemplateVersion struct

+ CreatedAt time.Time

+ ID uint64

+ IsLatest bool

+ Labels map[string]string

+ Manifest string

+ UID string

+ Version int64

+ WorkflowTemplate *WorkflowTemplate

+ type Workspace struct

+ CreatedAt time.Time

+ ID uint64

+ Labels map[string]string

+ ModifiedAt *time.Time

+ Name string

+ Namespace string

+ Parameters []Parameter

+ ParametersBytes []byte

+ PausedAt *time.Time

+ Phase string

+ StartedAt *time.Time

+ Status WorkspaceStatus

+ TerminatedAt *time.Time

+ UID string

+ WorkspaceTemplate *WorkspaceTemplate

+ WorkspaceTemplateID uint64

+ WorkspaceTemplateVersion uint64

+ type WorkspacePhase string

+ const WorkspacePaused

+ const WorkspacePausing

+ const WorkspaceRunning

+ const WorkspaceStarted

+ const WorkspaceTerminated

+ const WorkspaceTerminating

+ type WorkspaceSpec struct

+ Arguments *Arguments

+ Containers []corev1.Container

+ Ports []corev1.ServicePort

+ PostExecutionWorkflow *wfv1.WorkflowTemplateSpec

+ Routes []*networking.HTTPRoute

+ type WorkspaceStatus struct

+ PausedAt *time.Time

+ Phase WorkspacePhase

+ StartedAt *time.Time

+ TerminatedAt *time.Time

+ type WorkspaceTemplate struct

+ CreatedAt time.Time

+ ID uint64

+ IsLatest bool

+ Manifest string

+ Name string

+ UID string

+ Version int64

+ WorkflowTemplate *WorkflowTemplate

+ func (wt *WorkspaceTemplate) GenerateUID() (string, error)