models

package

Go to main page

Versions in this module

v0

v0.14.7-rc1

May 10, 2023

v0.14.6

Mar 23, 2023

Changes in this version

type Run

+ FailureOptionsJson string

type RunJob

+ func (rj *RunJob) Finished() bool

v0.14.6-beta0

Nov 24, 2022

v0.14.5

Nov 4, 2022

v0.14.4

Sep 9, 2022

v0.14.3

Sep 1, 2022

Changes in this version

+ const ConcurrencyPolicyReplace

+ const ConcurrencyPolicySkip

+ const ConcurrencyPolicySuspend

+ const ScheduleStatusFailed

+ const ScheduleStatusRunning

+ const ScheduleStatusSuccess

+ const ScheduleStatusTerminated

+ var ConcurrencyPolicyList = []string

+ var ScheduleFinalStatusList = []string

+ var ScheduleNotFinalStatusList = []string

+ var ScheduleStatusList = []string

+ func CountActiveRunsForSchedule(logEntry *log.Entry, scheduleID string) (int64, error)

+ func CountPipelineVersion(pipelineID string) (int64, error)

+ func CountRun(logEntry *log.Entry, pk int64, maxKeys int, ...) (count int64, err error)

+ func CreateOrUpdateQueue(queue *Queue) error

+ func CreateRunDag(logEntry *log.Entry, runDag *RunDag) (int64, error)

+ func CreateRunJob(logEntry *log.Entry, runJob *RunJob) (int64, error)

+ func CreateSchedule(logEntry *log.Entry, schedule Schedule) (scheduleID string, err error)

+ func DeletePipeline(logEntry *log.Entry, id string) error

+ func DeletePipelineVersion(logEntry *log.Entry, pipelineID string, pipelineVersionID string) error

+ func DeleteSchedule(logEntry *log.Entry, scheduleID string) error

+ func GetNextGlobalWakeupTime(logEntry *log.Entry) (*time.Time, error)

+ func IsLastPipelinePk(logEntry *log.Entry, pk int64, userFilter, nameFilter []string) (bool, error)

+ func IsLastPipelineVersionPk(logEntry *log.Entry, pipelineID string, pk int64, fsFilter []string) (bool, error)

+ func IsLastSchedulePk(logEntry *log.Entry, pk int64, ...) (bool, error)

+ func IsScheduleFinalStatus(status string) bool

+ func ScheduleUsedFsIDs() (map[string]bool, error)

+ func UpdatePipeline(logEntry *log.Entry, ppl *Pipeline, pplVersion *PipelineVersion) (pplID string, pplVersionID string, err error)

+ func UpdateQueueInfo(name, status string, max, min *resources.Resource) error

+ func UpdateRunDag(logEntry *log.Entry, pk int64, runDag RunDag) error

+ func UpdateScheduleStatus(logEntry *log.Entry, scheduleID, status string) error

+ func WithTransaction(tdb *gorm.DB, fn Transaction) (err error)

type ArtifactEvent

+ JobID string

+ type FsConfig struct

+ Username string

+ func DecodeFsConfig(strConfig string) (fc FsConfig, err error)

+ func (fc *FsConfig) Encode(logEntry *log.Entry) (string, error)

type Job

+ RuntimeStatus interface{}

+ RuntimeStatusJson string

+ func ListClusterJob(clusterID string, status schema.JobStatus) []Job

+ func ListJobByStatus(status schema.JobStatus) []Job

+ func ListQueueInitJob(queueID string) []Job

type JobTask

+ NodeName string

type Pipeline

+ Desc string

+ func GetPipeline(name, userName string) (Pipeline, error)

+ type PipelineVersion struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ FsID string

+ FsName string

+ ID string

+ PipelineID string

+ PipelineMd5 string

+ PipelineYaml string

+ Pk int64

+ UpdatedAt time.Time

+ UserName string

+ YamlPath string

+ func GetLastPipelineVersion(pipelineID string) (PipelineVersion, error)

+ func GetPipelineVersion(pipelineID string, pipelineVersionID string) (PipelineVersion, error)

+ func GetPipelineVersions(pipelineID string) ([]PipelineVersion, error)

+ func ListPipelineVersion(pipelineID string, pk int64, maxKeys int, fsFilter []string) ([]PipelineVersion, error)

+ func (PipelineVersion) TableName() string

type Queue

+ IdleResources *resources.Resource

+ UsedResources *resources.Resource

type Run

+ FsOptions schema.FsOptions

+ RunOptions schema.RunOptions

+ RunOptionsJson string

+ ScheduleID string

+ ScheduledAt sql.NullTime

+ func (r *Run) InitRuntime(jobs []RunJob, dags []RunDag) error

+ func (r *Run) ProcessRuntimeView(componentViews map[string][]schema.ComponentView, ...) error

+ func (r *Run) RemoveOuterDagView(runtimeView map[string][]schema.ComponentView) map[string][]schema.ComponentView

type RunCache

+ JobID string

+ type RunDag struct

+ ActivateTime string

+ ActivatedAt sql.NullTime

+ Artifacts schema.Artifacts

+ ArtifactsJson string

+ CreateTime string

+ CreatedAt time.Time

+ DagName string

+ DeletedAt gorm.DeletedAt

+ ID string

+ LoopSeq int

+ Message string

+ Name string

+ Parameters map[string]string

+ ParametersJson string

+ ParentDagID string

+ Pk int64

+ RunID string

+ Status schema.JobStatus

+ UpdateTime string

+ UpdatedAt time.Time

+ func GetRunDagsOfRun(logEntry *log.Entry, runID string) ([]RunDag, error)

+ func ParseRunDag(dagView *schema.DagView) RunDag

+ func (rd *RunDag) Encode() error

+ func (rd *RunDag) Trans2DagView() schema.DagView

type RunJob

+ CacheJobID string

+ ExtraFS []schema.FsMount

+ ExtraFSJson string

+ LoopSeq int

+ ParentDagID string

+ func GetRunJob(logEntry *log.Entry, jobID string) (RunJob, error)

+ func (rj *RunJob) Trans2JobView() schema.JobView

+ type Schedule struct

+ CreatedAt time.Time

+ Crontab string

+ DeletedAt gorm.DeletedAt

+ Desc string

+ EndAt sql.NullTime

+ FsConfig string

+ ID string

+ Message string

+ Name string

+ NextRunAt time.Time

+ Options string

+ PipelineID string

+ PipelineVersionID string

+ Pk int64

+ StartAt sql.NullTime

+ Status string

+ UpdatedAt time.Time

+ UserName string

+ func GetSchedule(logEntry *log.Entry, scheduleID string) (Schedule, error)

+ func GetScheduleByName(logEntry *log.Entry, name, userName string) (Schedule, error)

+ func GetSchedulesByStatus(logEntry *log.Entry, status string) (schedules []Schedule, err error)

+ func ListSchedule(logEntry *log.Entry, pk int64, maxKeys int, ...) ([]Schedule, error)

+ func (Schedule) TableName() string

+ type ScheduleOptions struct

+ Catchup bool

+ Concurrency int

+ ConcurrencyPolicy string

+ ExpireInterval int

+ func DecodeScheduleOptions(StrOptions string) (so ScheduleOptions, err error)

+ func NewScheduleOptions(logEntry *log.Entry, catchup bool, expireInterval int, concurrency int, ...) (so ScheduleOptions, err error)

+ func (so *ScheduleOptions) Encode(logEntry *log.Entry) (string, error)

v0.14.2

Jun 1, 2022

Changes in this version

+ const ASC

+ const Address

+ const ClusterStatusOffLine

+ const ClusterStatusOnLine

+ const CreatedAt

+ const DESC

+ const DefaultClusterSource

+ const DefaultClusterStatus

+ const FileSystemTableName

+ const FsCacheID

+ const FsCacheTableName

+ const FsID

+ const FsMountTableName

+ const FsName

+ const FsNameNum

+ const FsPath

+ const FsPrefix

+ const GrantFsType

+ const ID

+ const JobTaskTableName

+ const LinkTableName

+ const MAXListFileSystems

+ const QueryAnd

+ const QueryEqualWithParam

+ const QueryGreater

+ const QueryInWithParam

+ const QueryIsNull

+ const QueryLess

+ const QueryLikeWithParam

+ const QueryNotInWithParam

+ const QueryOr

+ const ROOT

+ const ServerAddress

+ const State

+ const TimeFormat

+ const Type

+ const UpdatedAt

+ const UserName

+ func CloseQueue(queueName string) error

+ func CountArtifactEvent(logEntry *log.Entry, fsID, artifactPath string) (int64, error)

+ func CountPipelineByMd5InFs(md5, fsID string) (int64, error)

+ func CountPipelineByNameInFs(name, fsID string) (int64, error)

+ func CreatFileSystem(fs *FileSystem) error

+ func CreateArtifactEvent(logEntry *log.Entry, artifact ArtifactEvent) error

+ func CreateCluster(clusterInfo *ClusterInfo) error

+ func CreateFSCacheConfig(logEntry *log.Entry, fsCacheConfig *FSCacheConfig) error

+ func CreateFlavour(flavour *Flavour) error

+ func CreateGrant(ctx *logger.RequestContext, grant *Grant) error

+ func CreateImage(logEntry *log.Entry, image *Image) error

+ func CreateJob(job *Job) error

+ func CreateLink(link *Link) error

+ func CreatePipeline(logEntry *log.Entry, ppl *Pipeline) (string, error)

+ func CreateQueue(queue *Queue) error

+ func CreateRun(logEntry *log.Entry, run *Run) (string, error)

+ func CreateRunCache(logEntry *log.Entry, cache *RunCache) (string, error)

+ func CreateRunJobs(logEntry *log.Entry, jobs map[string]schema.JobView, runID string) error

+ func CreateUser(ctx *logger.RequestContext, user *User) error

+ func DeepCopyQueue(queueSrc Queue, queueDesc *Queue)

+ func DeleteArtifactEvent(logEntry *log.Entry, username, fsname, runID, artifactPath string) error

+ func DeleteCluster(clusterName string) error

+ func DeleteFSCacheConfig(logEntry *log.Entry, fsID string) error

+ func DeleteFileSystem(id string) error

+ func DeleteFlavour(flavourName string) error

+ func DeleteGrant(ctx *logger.RequestContext, userName, resourceType, resourceID string) error

+ func DeleteGrantByResourceID(ctx *logger.RequestContext, resourceID string) error

+ func DeleteGrantByUserName(ctx *logger.RequestContext, userName string) error

+ func DeleteJob(jobID string) error

+ func DeleteLinkWithFsIDAndFsPath(fsID, fsPath string) error

+ func DeleteQueue(queueName string) error

+ func DeleteRun(logEntry *log.Entry, runID string) error

+ func DeleteRunCache(logEntry *log.Entry, cacheID string) error

+ func DeleteUser(ctx *logger.RequestContext, userName string) error

+ func GetCacheCount(logEntry *log.Entry, runID string) (int64, error)

+ func GetJobStatusByID(jobID string) (schema.JobStatus, error)

+ func GetRunCount(logEntry *log.Entry) (int64, error)

+ func GetUrlByPFImageID(logEntry *log.Entry, PFImageID string) (string, error)

+ func HardDeletePipeline(logEntry *log.Entry, id string) error

+ func HasAccessToResource(ctx *logger.RequestContext, resourceType string, resourceID string) bool

+ func InitMockDB()

+ func IsQueueExist(queueName string) bool

+ func IsQueueInUse(queueID string) (bool, map[string]schema.JobStatus)

+ func ListImageIDsByFsID(logEntry *log.Entry, fsID string) ([]string, error)

+ func ListJobIDByLabels(labels map[string]string) ([]string, error)

+ func ListMountNodesByID(fsID string) ([]string, error)

+ func UpdateArtifactEvent(logEntry *log.Entry, fsID, artifactPath string, artifact ArtifactEvent) error

+ func UpdateCache(logEntry *log.Entry, cacheID string, cache RunCache) error

+ func UpdateCluster(clusterId string, clusterInfo *ClusterInfo) error

+ func UpdateFSCacheConfig(logEntry *log.Entry, fsCacheConfig FSCacheConfig) error

+ func UpdateFlavour(flavour *Flavour) error

+ func UpdateImage(logEntry *log.Entry, PFImageID string, image Image) error

+ func UpdateJob(jobID string, status schema.JobStatus, info interface{}, message string) (schema.JobStatus, error)

+ func UpdateJobConfig(jobId string, conf *schema.Conf) error

+ func UpdateJobStatus(jobId, errMessage string, jobStatus schema.JobStatus) error

+ func UpdateQueue(queue *Queue) error

+ func UpdateQueueStatus(queueName string, queueStatus string) error

+ func UpdateRun(logEntry *log.Entry, runID string, run Run) error

+ func UpdateRunJob(logEntry *log.Entry, runID string, stepName string, runJob RunJob) error

+ func UpdateRunStatus(logEntry *log.Entry, runID, status string) error

+ func UpdateTask(task *JobTask) error

+ func UpdateUser(ctx *logger.RequestContext, userName, password string) error

+ type ArtifactEvent struct

+ ArtifactName string

+ ArtifactPath string

+ CreateTime string

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ FsID string

+ FsName string

+ Md5 string

+ Meta string

+ Pk int64

+ RunID string

+ Step string

+ Type string

+ UpdateTime string

+ UpdatedAt time.Time

+ UserName string

+ func GetArtifactEvent(logEntry *log.Entry, runID, fsID, artifactPath string) (ArtifactEvent, error)

+ func GetLastArtifactEvent(logEntry *log.Entry) (ArtifactEvent, error)

+ func ListArtifactEvent(logEntry *log.Entry, pk int64, maxKeys int, ...) ([]ArtifactEvent, error)

+ func (ArtifactEvent) TableName() string

+ type ClusterInfo struct

+ ClusterType string

+ Credential string

+ DeletedAt string

+ Description string

+ Endpoint string

+ Name string

+ NamespaceList []string

+ Pk int64

+ RawNamespaceList string

+ Setting string

+ Source string

+ Status string

+ Version string

+ func ActiveClusters() []ClusterInfo

+ func GetClusterById(clusterId string) (ClusterInfo, error)

+ func GetClusterByName(clusterName string) (ClusterInfo, error)

+ func GetLastCluster() (ClusterInfo, error)

+ func ListCluster(pk int64, maxKeys int, clusterNameList []string, clusterStatus string) ([]ClusterInfo, error)

+ func (ClusterInfo) TableName() string

+ func (clusterInfo *ClusterInfo) AfterFind(*gorm.DB) error

+ func (clusterInfo *ClusterInfo) BeforeSave(*gorm.DB) error

+ func (clusterInfo ClusterInfo) MarshalJSON() ([]byte, error)

+ type ConcurrentFSCacheMap struct

+ func (cm *ConcurrentFSCacheMap) Delete(key1, key2 string) error

+ func (cm *ConcurrentFSCacheMap) Get(key1, key2 string) *FSCache

+ func (cm *ConcurrentFSCacheMap) GetBatch(key string) []FSCache

+ func (cm *ConcurrentFSCacheMap) Put(key string, value *FSCache)

+ func (cm *ConcurrentFSCacheMap) Update(key, value *FSCache) (has bool, err error)

+ type DBFSCache struct

+ func (f *DBFSCache) Add(value *FSCache) error

+ func (f *DBFSCache) Delete(fsID, cacheID string) error

+ func (f *DBFSCache) Get(fsID string, cacheID string) (*FSCache, error)

+ func (f *DBFSCache) List(fsID, cacheID string) ([]FSCache, error)

+ func (f *DBFSCache) Update(value *FSCache) (int64, error)

+ type FSCache struct

+ CacheDir string

+ CacheHashID string

+ CacheID string

+ ClusterID string

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ FsID string

+ NodeName string

+ PK int64

+ UpdatedAt time.Time

+ UsedSize int

+ func (s *FSCache) TableName() string

+ type FSCacheConfig struct

+ BlockSize int

+ CacheDir string

+ CreatedAt time.Time

+ Debug bool

+ DeletedAt gorm.DeletedAt

+ ExtraConfigJson string

+ ExtraConfigMap map[string]string

+ FsID string

+ MetaDriver string

+ NodeAffinityJson string

+ NodeAffinityMap map[string]interface{}

+ NodeTaintTolerationJson string

+ NodeTaintTolerationMap map[string]interface{}

+ PK int64

+ Quota int

+ UpdatedAt time.Time

+ func GetFSCacheConfig(logEntry *log.Entry, fsID string) (FSCacheConfig, error)

+ func (s *FSCacheConfig) AfterFind(*gorm.DB) error

+ func (s *FSCacheConfig) BeforeSave(*gorm.DB) error

+ func (s *FSCacheConfig) TableName() string

+ type FSCacheStore interface

+ Add func(value *FSCache) error

+ Delete func(fsID, cacheID string) error

+ Get func(fsID string, cacheID string) (*FSCache, error)

+ List func(fsID, cacheID string) ([]FSCache, error)

+ Update func(value *FSCache) (int64, error)

+ func GetFSCacheStore() FSCacheStore

+ type FileSystem struct

+ Name string

+ PropertiesJson string

+ PropertiesMap map[string]string

+ ServerAddress string

+ SubPath string

+ Type string

+ UserName string

+ func GetFileSystemWithFsID(fsID string) (FileSystem, error)

+ func GetFileSystemWithFsIDAndUserName(fsID, userName string) (FileSystem, error)

+ func GetFsWithIDs(fsID []string) ([]FileSystem, error)

+ func GetFsWithNameAndUserName(fsName, userName string) (FileSystem, error)

+ func ListFileSystem(limit int, userName, marker, fsName string) ([]FileSystem, error)

+ func (FileSystem) TableName() string

+ func (s *FileSystem) AfterFind(*gorm.DB) error

+ func (s *FileSystem) BeforeSave(*gorm.DB) error

+ type Flavour struct

+ CPU string

+ ClusterID string

+ ClusterName string

+ DeletedAt gorm.DeletedAt

+ Mem string

+ Name string

+ Pk int64

+ RawScalarResources string

+ ScalarResources schema.ScalarResourcesType

+ UserName string

+ func GetFlavour(flavourName string) (Flavour, error)

+ func GetLastFlavour() (Flavour, error)

+ func ListFlavour(pk int64, maxKeys int, clusterID, queryKey string) ([]Flavour, error)

+ func (Flavour) TableName() string

+ func (flavour *Flavour) AfterFind(*gorm.DB) error

+ func (flavour *Flavour) BeforeSave(*gorm.DB) error

+ func (flavour Flavour) MarshalJSON() ([]byte, error)

+ type FsMount struct

+ ClusterID string

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ FsID string

+ MountID string

+ MountPoint string

+ NodeName string

+ PK int64

+ UpdatedAt time.Time

+ func (f *FsMount) Add(value *FsMount) error

+ func (f *FsMount) DeleteMount(mountID string) error

+ func (f *FsMount) ListMount(where *FsMount, limit int, marker string) (fsMounts []FsMount, err error)

+ func (f *FsMount) TableName() string

+ type Grant struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ ID string

+ Pk int64

+ ResourceID string

+ ResourceType string

+ UpdatedAt time.Time

+ UserName string

+ func GetGrant(ctx *logger.RequestContext, userName, resourceType, resourceID string) (*Grant, error)

+ func GetLastGrant(ctx *logger.RequestContext) (Grant, error)

+ func ListGrant(ctx *logger.RequestContext, pk int64, maxKeys int, userName string) ([]Grant, error)

+ func (Grant) TableName() string

+ type Image struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ FsID string

+ ID string

+ ImageID string

+ Pk int64

+ Source string

+ UpdatedAt time.Time

+ Url string

+ func GetImage(logEntry *log.Entry, PFImageID string) (Image, error)

+ func (Image) TableName() string

+ type Job struct

+ ActivatedAt sql.NullTime

+ Config *schema.Conf

+ ConfigJson string

+ CreatedAt time.Time

+ DeletedAt string

+ ExtensionTemplate string

+ Framework schema.Framework

+ ID string

+ Members []Member

+ MembersJson string

+ Message string

+ Name string

+ ParentJob string

+ Pk int64

+ QueueID string

+ Resource *schema.Resource

+ ResourceJson string

+ RuntimeInfo interface{}

+ RuntimeInfoJson string

+ Status schema.JobStatus

+ Type string

+ UpdatedAt time.Time

+ UserName string

+ func GetJobByID(jobID string) (Job, error)

+ func GetJobsByRunID(runID string, jobID string) ([]Job, error)

+ func GetLastJob() (Job, error)

+ func GetUnscopedJobByID(jobID string) (Job, error)

+ func ListJob(pk int64, maxKeys int, queue, status, startTime, timestamp, userFilter string, ...) ([]Job, error)

+ func ListJobByParentID(parentID string) ([]Job, error)

+ func ListJobByUpdateTime(updateTime string) ([]Job, error)

+ func ListQueueJob(queueID string, status []schema.JobStatus) []Job

+ func (Job) TableName() string

+ func (job *Job) AfterFind(tx *gorm.DB) error

+ func (job *Job) BeforeSave(tx *gorm.DB) error

+ type JobLabel struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ ID string

+ JobID string

+ Label string

+ Pk int64

+ func (JobLabel) TableName() string

+ type JobTask struct

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ ExtRuntimeStatus interface{}

+ ExtRuntimeStatusJSON string

+ ID string

+ JobID string

+ LogURL string

+ MemberRole schema.MemberRole

+ Message string

+ Name string

+ Namespace string

+ Pk int64

+ StartedAt sql.NullTime

+ Status schema.TaskStatus

+ UpdatedAt time.Time

+ func GetJobTaskByID(id string) (JobTask, error)

+ func ListByJobID(jobID string) ([]JobTask, error)

+ func (JobTask) TableName() string

+ func (task *JobTask) AfterFind(*gorm.DB) error

+ func (task *JobTask) BeforeSave(*gorm.DB) error

+ type Link struct

+ FsID string

+ FsPath string

+ PropertiesJson string

+ PropertiesMap map[string]string

+ ServerAddress string

+ SubPath string

+ Type string

+ UserName string

+ func FsNameLinks(fsID string) ([]Link, error)

+ func GetLinkWithFsIDAndPath(fsID, fsPath string) ([]Link, error)

+ func LinkWithFsIDAndFsPath(fsID, fsPath string) (Link, error)

+ func ListLink(limit int, marker, fsID string) ([]Link, error)

+ func (Link) TableName() string

+ func (s *Link) AfterFind(*gorm.DB) error

+ func (s *Link) BeforeSave(*gorm.DB) error

+ type MemFSCache struct

+ func (mem *MemFSCache) Add(value *FSCache) error

+ func (mem *MemFSCache) Delete(fsID, cacheID string) error

+ func (mem *MemFSCache) Get(fsID string, cacheID string) (*FSCache, error)

+ func (mem *MemFSCache) List(fsID, cacheID string) ([]FSCache, error)

+ func (mem *MemFSCache) Update(value *FSCache) (int64, error)

+ type Member struct

+ ID string

+ Replicas int

+ Role schema.MemberRole

+ type Model struct

+ CreatedAt time.Time

+ ID string

+ UpdatedAt time.Time

+ func (m *Model) BeforeCreate(tx *gorm.DB) error

+ type Pipeline struct

+ CreateTime string

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ FsID string

+ FsName string

+ ID string

+ Name string

+ PipelineMd5 string

+ PipelineYaml string

+ Pk int64

+ UpdateTime string

+ UpdatedAt time.Time

+ UserName string

+ func GetLastPipeline(logEntry *log.Entry) (Pipeline, error)

+ func GetPipelineByID(id string) (Pipeline, error)

+ func GetPipelineByMd5AndFs(md5, fsID string) (Pipeline, error)

+ func GetPipelineByNameAndFs(fsID, name string) (Pipeline, error)

+ func ListPipeline(pk int64, maxKeys int, userFilter, fsFilter, nameFilter []string) ([]Pipeline, error)

+ func (Pipeline) TableName() string

+ func (p *Pipeline) Decode() error

+ type Queue struct

+ ClusterId string

+ ClusterName string

+ DeletedAt gorm.DeletedAt

+ Location map[string]string

+ MaxResources schema.ResourceInfo

+ MinResources schema.ResourceInfo

+ Name string

+ Namespace string

+ Pk int64

+ QuotaType string

+ RawLocation string

+ RawMaxResources string

+ RawMinResources string

+ RawSchedulingPolicy string

+ SchedulingPolicy []string

+ Status string

+ func GetLastQueue() (Queue, error)

+ func GetQueueByID(queueID string) (Queue, error)

+ func GetQueueByName(queueName string) (Queue, error)

+ func ListQueue(pk int64, maxKeys int, queueName string, userName string) ([]Queue, error)

+ func ListQueuesByCluster(clusterID string) []Queue

+ func (Queue) TableName() string

+ func (queue *Queue) AfterFind(*gorm.DB) error

+ func (queue *Queue) BeforeSave(*gorm.DB) error

+ func (queue Queue) MarshalJSON() ([]byte, error)

+ type Run struct

+ ActivateTime string

+ ActivatedAt sql.NullTime

+ CreateTime string

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ Description string

+ Disabled string

+ DockerEnv string

+ Entry string

+ FailureOptions schema.FailureOptions

+ FsID string

+ FsName string

+ ID string

+ Message string

+ Name string

+ Parameters map[string]interface{}

+ ParametersJson string

+ Pk int64

+ PostProcess schema.PostProcessView

+ RunCachedIDs string

+ RunYaml string

+ Runtime schema.RuntimeView

+ Source string

+ Status string

+ UpdateTime string

+ UpdatedAt time.Time

+ UserName string

+ WorkflowSource schema.WorkflowSource

+ func GetLastRun(logEntry *log.Entry) (Run, error)

+ func GetRunByID(logEntry *log.Entry, runID string) (Run, error)

+ func ListRun(logEntry *log.Entry, pk int64, maxKeys int, ...) ([]Run, error)

+ func ListRunsByStatus(logEntry *log.Entry, statusList []string) ([]Run, error)

+ func (Run) TableName() string

+ func (r *Run) Encode() error

+ func (r *Run) GetRunCacheIDList() []string

+ type RunCache struct

+ CreateTime string

+ CreatedAt time.Time

+ Custom string

+ DeletedAt gorm.DeletedAt

+ ExpiredTime string

+ FirstFp string

+ FsID string

+ FsName string

+ ID string

+ Pk int64

+ RunID string

+ SecondFp string

+ Source string

+ Step string

+ Strategy string

+ UpdateTime string

+ UpdatedAt time.Time

+ UserName string

+ func GetLastCacheForRun(logEntry *log.Entry, runID string) (RunCache, error)

+ func GetLastRunCache(logEntry *log.Entry) (RunCache, error)

+ func GetRunCache(logEntry *log.Entry, cacheID string) (RunCache, error)

+ func ListRunCache(logEntry *log.Entry, pk int64, maxKeys int, ...) ([]RunCache, error)

+ func ListRunCacheByFirstFp(logEntry *log.Entry, firstFp, fsID, step, source string) ([]RunCache, error)

+ func (RunCache) TableName() string

+ type RunJob struct

+ ActivateTime string

+ ActivatedAt sql.NullTime

+ Artifacts schema.Artifacts

+ ArtifactsJson string

+ Cache schema.Cache

+ CacheJson string

+ CacheRunID string

+ Command string

+ CreateTime string

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ DockerEnv string

+ Env map[string]string

+ EnvJson string

+ ID string

+ Message string

+ Name string

+ Parameters map[string]string

+ ParametersJson string

+ Pk int64

+ RunID string

+ Status schema.JobStatus

+ StepName string

+ UpdateTime string

+ UpdatedAt time.Time

+ func GetRunJobsOfRun(logEntry *log.Entry, runID string) ([]RunJob, error)

+ func ParseRunJob(jobView *schema.JobView) RunJob

+ func (rj *RunJob) Encode() error

+ func (rj *RunJob) ParseJobView(step *schema.WorkflowSourceStep) schema.JobView

+ type Transaction func(db *gorm.DB) error

+ type User struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ Pk int64

+ UpdatedAt time.Time

+ func GetLastUser(ctx *logger.RequestContext) (User, error)

+ func GetUserByName(ctx *logger.RequestContext, userName string) (User, error)

+ func ListUser(ctx *logger.RequestContext, pk int64, maxKey int) ([]User, error)

+ func (User) TableName() string

+ type UserInfo struct

+ Name string

+ Password string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL