Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterTaskQueueServer(s grpc.ServiceRegistrar, srv TaskQueueServer)
- type Accum
- func (*Accum) Descriptor() ([]byte, []int)deprecated
- func (x *Accum) GetCount() int32
- func (x *Accum) GetMax() float32
- func (x *Accum) GetMin() float32
- func (x *Accum) GetSum() float32
- func (*Accum) ProtoMessage()
- func (x *Accum) ProtoReflect() protoreflect.Message
- func (x *Accum) Reset()
- func (x *Accum) String() string
- type Ack
- type Certificate
- type ChangePasswordRequest
- func (*ChangePasswordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangePasswordRequest) GetNewPassword() string
- func (x *ChangePasswordRequest) GetOldPassword() string
- func (x *ChangePasswordRequest) GetUsername() string
- func (*ChangePasswordRequest) ProtoMessage()
- func (x *ChangePasswordRequest) ProtoReflect() protoreflect.Message
- func (x *ChangePasswordRequest) Reset()
- func (x *ChangePasswordRequest) String() string
- type CreateUserRequest
- func (*CreateUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateUserRequest) GetEmail() string
- func (x *CreateUserRequest) GetIsAdmin() bool
- func (x *CreateUserRequest) GetPassword() string
- func (x *CreateUserRequest) GetUsername() string
- func (*CreateUserRequest) ProtoMessage()
- func (x *CreateUserRequest) ProtoReflect() protoreflect.Message
- func (x *CreateUserRequest) Reset()
- func (x *CreateUserRequest) String() string
- type DebugAssignRequest
- func (*DebugAssignRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DebugAssignRequest) GetTaskId() int32
- func (x *DebugAssignRequest) GetWorkflowId() int32
- func (*DebugAssignRequest) ProtoMessage()
- func (x *DebugAssignRequest) ProtoReflect() protoreflect.Message
- func (x *DebugAssignRequest) Reset()
- func (x *DebugAssignRequest) String() string
- type DebugRecruitRequest
- func (*DebugRecruitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DebugRecruitRequest) GetStepId() int32
- func (x *DebugRecruitRequest) GetWorkflowId() int32
- func (*DebugRecruitRequest) ProtoMessage()
- func (x *DebugRecruitRequest) ProtoReflect() protoreflect.Message
- func (x *DebugRecruitRequest) Reset()
- func (x *DebugRecruitRequest) String() string
- type DeleteTemplateRunRequest
- func (*DeleteTemplateRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteTemplateRunRequest) GetTemplateRunId() int32
- func (*DeleteTemplateRunRequest) ProtoMessage()
- func (x *DeleteTemplateRunRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteTemplateRunRequest) Reset()
- func (x *DeleteTemplateRunRequest) String() string
- type DiskIOStats
- func (*DiskIOStats) Descriptor() ([]byte, []int)deprecated
- func (x *DiskIOStats) GetReadBytesRate() float32
- func (x *DiskIOStats) GetReadBytesTotal() int64
- func (x *DiskIOStats) GetWriteBytesRate() float32
- func (x *DiskIOStats) GetWriteBytesTotal() int64
- func (*DiskIOStats) ProtoMessage()
- func (x *DiskIOStats) ProtoReflect() protoreflect.Message
- func (x *DiskIOStats) Reset()
- func (x *DiskIOStats) String() string
- type DiskUsage
- type DockerCredential
- func (*DockerCredential) Descriptor() ([]byte, []int)deprecated
- func (x *DockerCredential) GetAuth() string
- func (x *DockerCredential) GetRegistry() string
- func (*DockerCredential) ProtoMessage()
- func (x *DockerCredential) ProtoReflect() protoreflect.Message
- func (x *DockerCredential) Reset()
- func (x *DockerCredential) String() string
- type DockerCredentials
- func (*DockerCredentials) Descriptor() ([]byte, []int)deprecated
- func (x *DockerCredentials) GetCredentials() []*DockerCredential
- func (*DockerCredentials) ProtoMessage()
- func (x *DockerCredentials) ProtoReflect() protoreflect.Message
- func (x *DockerCredentials) Reset()
- func (x *DockerCredentials) String() string
- type FetchInfoResponse
- func (*FetchInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FetchInfoResponse) GetDescription() string
- func (x *FetchInfoResponse) GetFilename() string
- func (x *FetchInfoResponse) GetIsDir() bool
- func (x *FetchInfoResponse) GetIsFile() bool
- func (x *FetchInfoResponse) GetSize() int64
- func (x *FetchInfoResponse) GetUri() string
- func (*FetchInfoResponse) ProtoMessage()
- func (x *FetchInfoResponse) ProtoReflect() protoreflect.Message
- func (x *FetchInfoResponse) Reset()
- func (x *FetchInfoResponse) String() string
- type FetchListRequest
- type FetchListResponse
- type Flavor
- func (*Flavor) Descriptor() ([]byte, []int)deprecated
- func (x *Flavor) GetBandwidth() int32
- func (x *Flavor) GetCost() float32
- func (x *Flavor) GetCpu() int32
- func (x *Flavor) GetDisk() float32
- func (x *Flavor) GetEviction() float32
- func (x *Flavor) GetFlavorId() int32
- func (x *Flavor) GetFlavorName() string
- func (x *Flavor) GetGpu() string
- func (x *Flavor) GetGpumem() int32
- func (x *Flavor) GetHasGpu() bool
- func (x *Flavor) GetHasQuickDisks() bool
- func (x *Flavor) GetMem() float32
- func (x *Flavor) GetProvider() string
- func (x *Flavor) GetProviderId() int32
- func (x *Flavor) GetRegion() string
- func (x *Flavor) GetRegionId() int32
- func (*Flavor) ProtoMessage()
- func (x *Flavor) ProtoReflect() protoreflect.Message
- func (x *Flavor) Reset()
- func (x *Flavor) String() string
- type FlavorCreateRequest
- func (*FlavorCreateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FlavorCreateRequest) GetBandwidth() int32
- func (x *FlavorCreateRequest) GetConfigName() string
- func (x *FlavorCreateRequest) GetCosts() []float32
- func (x *FlavorCreateRequest) GetCpu() int32
- func (x *FlavorCreateRequest) GetDisk() float32
- func (x *FlavorCreateRequest) GetEvictions() []float32
- func (x *FlavorCreateRequest) GetFlavorName() string
- func (x *FlavorCreateRequest) GetGpu() string
- func (x *FlavorCreateRequest) GetGpumem() int32
- func (x *FlavorCreateRequest) GetHasGpu() bool
- func (x *FlavorCreateRequest) GetHasQuickDisks() bool
- func (x *FlavorCreateRequest) GetMemory() float32
- func (x *FlavorCreateRequest) GetProviderName() string
- func (x *FlavorCreateRequest) GetRegionNames() []string
- func (*FlavorCreateRequest) ProtoMessage()
- func (x *FlavorCreateRequest) ProtoReflect() protoreflect.Message
- func (x *FlavorCreateRequest) Reset()
- func (x *FlavorCreateRequest) String() string
- type FlavorId
- type FlavorsList
- type GetLogsRequest
- func (*GetLogsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetLogsRequest) GetChunkSize() int32
- func (x *GetLogsRequest) GetLogType() string
- func (x *GetLogsRequest) GetSkipFromEnd() int32
- func (x *GetLogsRequest) GetTaskIds() []int32
- func (*GetLogsRequest) ProtoMessage()
- func (x *GetLogsRequest) ProtoReflect() protoreflect.Message
- func (x *GetLogsRequest) Reset()
- func (x *GetLogsRequest) String() string
- type GetWorkerStatsRequest
- func (*GetWorkerStatsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkerStatsRequest) GetWorkerIds() []int32
- func (*GetWorkerStatsRequest) ProtoMessage()
- func (x *GetWorkerStatsRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkerStatsRequest) Reset()
- func (x *GetWorkerStatsRequest) String() string
- type GetWorkerStatsResponse
- func (*GetWorkerStatsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkerStatsResponse) GetWorkerStats() map[int32]*WorkerStats
- func (*GetWorkerStatsResponse) ProtoMessage()
- func (x *GetWorkerStatsResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkerStatsResponse) Reset()
- func (x *GetWorkerStatsResponse) String() string
- type Job
- func (*Job) Descriptor() ([]byte, []int)deprecated
- func (x *Job) GetAction() string
- func (x *Job) GetCreatedAt() string
- func (x *Job) GetFlavorId() int32
- func (x *Job) GetJobId() int32
- func (x *Job) GetLog() string
- func (x *Job) GetModifiedAt() string
- func (x *Job) GetProgression() int32
- func (x *Job) GetRetry() int32
- func (x *Job) GetStatus() string
- func (x *Job) GetWorkerId() int32
- func (*Job) ProtoMessage()
- func (x *Job) ProtoReflect() protoreflect.Message
- func (x *Job) Reset()
- func (x *Job) String() string
- type JobId
- type JobStatus
- func (*JobStatus) Descriptor() ([]byte, []int)deprecated
- func (x *JobStatus) GetJobId() int32
- func (x *JobStatus) GetProgression() int32
- func (x *JobStatus) GetStatus() string
- func (*JobStatus) ProtoMessage()
- func (x *JobStatus) ProtoReflect() protoreflect.Message
- func (x *JobStatus) Reset()
- func (x *JobStatus) String() string
- type JobStatusRequest
- type JobStatusResponse
- func (*JobStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *JobStatusResponse) GetStatuses() []*JobStatus
- func (*JobStatusResponse) ProtoMessage()
- func (x *JobStatusResponse) ProtoReflect() protoreflect.Message
- func (x *JobStatusResponse) Reset()
- func (x *JobStatusResponse) String() string
- type JobUpdate
- func (*JobUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *JobUpdate) GetAppendLog() string
- func (x *JobUpdate) GetJobId() int32
- func (x *JobUpdate) GetProgression() int32
- func (x *JobUpdate) GetStatus() string
- func (*JobUpdate) ProtoMessage()
- func (x *JobUpdate) ProtoReflect() protoreflect.Message
- func (x *JobUpdate) Reset()
- func (x *JobUpdate) String() string
- type JobsList
- type ListFlavorsRequest
- func (*ListFlavorsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListFlavorsRequest) GetFilter() string
- func (x *ListFlavorsRequest) GetLimit() int32
- func (*ListFlavorsRequest) ProtoMessage()
- func (x *ListFlavorsRequest) ProtoReflect() protoreflect.Message
- func (x *ListFlavorsRequest) Reset()
- func (x *ListFlavorsRequest) String() string
- type ListJobsRequest
- func (*ListJobsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListJobsRequest) GetLimit() int32
- func (x *ListJobsRequest) GetOffset() int32
- func (*ListJobsRequest) ProtoMessage()
- func (x *ListJobsRequest) ProtoReflect() protoreflect.Message
- func (x *ListJobsRequest) Reset()
- func (x *ListJobsRequest) String() string
- type ListTasksRequest
- func (*ListTasksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListTasksRequest) GetCommandFilter() string
- func (x *ListTasksRequest) GetLimit() int32
- func (x *ListTasksRequest) GetOffset() int32
- func (x *ListTasksRequest) GetShowHidden() bool
- func (x *ListTasksRequest) GetStatusFilter() string
- func (x *ListTasksRequest) GetStepIdFilter() int32
- func (x *ListTasksRequest) GetWorkerIdFilter() int32
- func (x *ListTasksRequest) GetWorkflowIdFilter() int32
- func (*ListTasksRequest) ProtoMessage()
- func (x *ListTasksRequest) ProtoReflect() protoreflect.Message
- func (x *ListTasksRequest) Reset()
- func (x *ListTasksRequest) String() string
- type ListWorkersRequest
- func (*ListWorkersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkersRequest) GetWorkflowId() int32
- func (*ListWorkersRequest) ProtoMessage()
- func (x *ListWorkersRequest) ProtoReflect() protoreflect.Message
- func (x *ListWorkersRequest) Reset()
- func (x *ListWorkersRequest) String() string
- type LogChunk
- func (*LogChunk) Descriptor() ([]byte, []int)deprecated
- func (x *LogChunk) GetStderr() []string
- func (x *LogChunk) GetStdout() []string
- func (x *LogChunk) GetTaskId() int32
- func (*LogChunk) ProtoMessage()
- func (x *LogChunk) ProtoReflect() protoreflect.Message
- func (x *LogChunk) Reset()
- func (x *LogChunk) String() string
- type LogChunkList
- type LoginRequest
- func (*LoginRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LoginRequest) GetPassword() string
- func (x *LoginRequest) GetUsername() string
- func (*LoginRequest) ProtoMessage()
- func (x *LoginRequest) ProtoReflect() protoreflect.Message
- func (x *LoginRequest) Reset()
- func (x *LoginRequest) String() string
- type LoginResponse
- type NetIOStats
- func (*NetIOStats) Descriptor() ([]byte, []int)deprecated
- func (x *NetIOStats) GetRecvBytesRate() float32
- func (x *NetIOStats) GetRecvBytesTotal() int64
- func (x *NetIOStats) GetSentBytesRate() float32
- func (x *NetIOStats) GetSentBytesTotal() int64
- func (*NetIOStats) ProtoMessage()
- func (x *NetIOStats) ProtoReflect() protoreflect.Message
- func (x *NetIOStats) Reset()
- func (x *NetIOStats) String() string
- type PingAndGetNewTasksRequest
- func (*PingAndGetNewTasksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PingAndGetNewTasksRequest) GetStats() *WorkerStats
- func (x *PingAndGetNewTasksRequest) GetWorkerId() int32
- func (*PingAndGetNewTasksRequest) ProtoMessage()
- func (x *PingAndGetNewTasksRequest) ProtoReflect() protoreflect.Message
- func (x *PingAndGetNewTasksRequest) Reset()
- func (x *PingAndGetNewTasksRequest) String() string
- type Provider
- func (*Provider) Descriptor() ([]byte, []int)deprecated
- func (x *Provider) GetConfigName() string
- func (x *Provider) GetProviderId() int32
- func (x *Provider) GetProviderName() string
- func (*Provider) ProtoMessage()
- func (x *Provider) ProtoReflect() protoreflect.Message
- func (x *Provider) Reset()
- func (x *Provider) String() string
- type ProviderList
- type RcloneRemote
- type RcloneRemotes
- type Recruiter
- func (*Recruiter) Descriptor() ([]byte, []int)deprecated
- func (x *Recruiter) GetConcurrency() int32
- func (x *Recruiter) GetConcurrencyMax() int32
- func (x *Recruiter) GetConcurrencyMin() int32
- func (x *Recruiter) GetCpuPerTask() int32
- func (x *Recruiter) GetDiskPerTask() float32
- func (x *Recruiter) GetMaxWorkers() int32
- func (x *Recruiter) GetMemoryPerTask() float32
- func (x *Recruiter) GetPrefetch() int32
- func (x *Recruiter) GetPrefetchPercent() int32
- func (x *Recruiter) GetProtofilter() string
- func (x *Recruiter) GetRank() int32
- func (x *Recruiter) GetRounds() int32
- func (x *Recruiter) GetStepId() int32
- func (x *Recruiter) GetTimeout() int32
- func (*Recruiter) ProtoMessage()
- func (x *Recruiter) ProtoReflect() protoreflect.Message
- func (x *Recruiter) Reset()
- func (x *Recruiter) String() string
- type RecruiterFilter
- type RecruiterId
- type RecruiterList
- type RecruiterUpdate
- func (*RecruiterUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *RecruiterUpdate) GetConcurrency() int32
- func (x *RecruiterUpdate) GetConcurrencyMax() int32
- func (x *RecruiterUpdate) GetConcurrencyMin() int32
- func (x *RecruiterUpdate) GetCpuPerTask() int32
- func (x *RecruiterUpdate) GetDiskPerTask() float32
- func (x *RecruiterUpdate) GetMaxWorkers() int32
- func (x *RecruiterUpdate) GetMemoryPerTask() float32
- func (x *RecruiterUpdate) GetPrefetch() int32
- func (x *RecruiterUpdate) GetPrefetchPercent() int32
- func (x *RecruiterUpdate) GetProtofilter() string
- func (x *RecruiterUpdate) GetRank() int32
- func (x *RecruiterUpdate) GetRounds() int32
- func (x *RecruiterUpdate) GetStepId() int32
- func (x *RecruiterUpdate) GetTimeout() int32
- func (*RecruiterUpdate) ProtoMessage()
- func (x *RecruiterUpdate) ProtoReflect() protoreflect.Message
- func (x *RecruiterUpdate) Reset()
- func (x *RecruiterUpdate) String() string
- type Region
- func (*Region) Descriptor() ([]byte, []int)deprecated
- func (x *Region) GetIsDefault() bool
- func (x *Region) GetProviderId() int32
- func (x *Region) GetRegionId() int32
- func (x *Region) GetRegionName() string
- func (*Region) ProtoMessage()
- func (x *Region) ProtoReflect() protoreflect.Message
- func (x *Region) Reset()
- func (x *Region) String() string
- type RegionList
- type ResourceSpec
- func (*ResourceSpec) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceSpec) GetCpu() int32
- func (x *ResourceSpec) GetDisk() float32
- func (x *ResourceSpec) GetMem() float32
- func (x *ResourceSpec) GetWorkerId() string
- func (*ResourceSpec) ProtoMessage()
- func (x *ResourceSpec) ProtoReflect() protoreflect.Message
- func (x *ResourceSpec) Reset()
- func (x *ResourceSpec) String() string
- type RetryTaskRequest
- func (*RetryTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RetryTaskRequest) GetRetry() int32
- func (x *RetryTaskRequest) GetTaskId() int32
- func (*RetryTaskRequest) ProtoMessage()
- func (x *RetryTaskRequest) ProtoReflect() protoreflect.Message
- func (x *RetryTaskRequest) Reset()
- func (x *RetryTaskRequest) String() string
- type RunTemplateRequest
- func (*RunTemplateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RunTemplateRequest) GetParamValuesJson() string
- func (x *RunTemplateRequest) GetWorkflowTemplateId() int32
- func (*RunTemplateRequest) ProtoMessage()
- func (x *RunTemplateRequest) ProtoReflect() protoreflect.Message
- func (x *RunTemplateRequest) Reset()
- func (x *RunTemplateRequest) String() string
- type StatusCountEntry
- func (*StatusCountEntry) Descriptor() ([]byte, []int)deprecated
- func (x *StatusCountEntry) GetCount() int32
- func (x *StatusCountEntry) GetStatus() string
- func (x *StatusCountEntry) GetWorkerId() int32
- func (*StatusCountEntry) ProtoMessage()
- func (x *StatusCountEntry) ProtoReflect() protoreflect.Message
- func (x *StatusCountEntry) Reset()
- func (x *StatusCountEntry) String() string
- type Step
- func (*Step) Descriptor() ([]byte, []int)deprecated
- func (x *Step) GetName() string
- func (x *Step) GetStepId() int32
- func (x *Step) GetWorkflowId() int32
- func (x *Step) GetWorkflowName() string
- func (*Step) ProtoMessage()
- func (x *Step) ProtoReflect() protoreflect.Message
- func (x *Step) Reset()
- func (x *Step) String() string
- type StepFilter
- func (*StepFilter) Descriptor() ([]byte, []int)deprecated
- func (x *StepFilter) GetLimit() int32
- func (x *StepFilter) GetOffset() int32
- func (x *StepFilter) GetWorkflowId() int32
- func (*StepFilter) ProtoMessage()
- func (x *StepFilter) ProtoReflect() protoreflect.Message
- func (x *StepFilter) Reset()
- func (x *StepFilter) String() string
- type StepId
- type StepList
- type StepRequest
- func (*StepRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StepRequest) GetName() string
- func (x *StepRequest) GetWorkflowId() int32
- func (x *StepRequest) GetWorkflowName() string
- func (*StepRequest) ProtoMessage()
- func (x *StepRequest) ProtoReflect() protoreflect.Message
- func (x *StepRequest) Reset()
- func (x *StepRequest) String() string
- type StepStats
- func (*StepStats) Descriptor() ([]byte, []int)deprecated
- func (x *StepStats) GetAcceptedTasks() int32
- func (x *StepStats) GetDownload() *Accum
- func (x *StepStats) GetEndTime() int64
- func (x *StepStats) GetFailedRun() *Accum
- func (x *StepStats) GetFailedTasks() int32
- func (x *StepStats) GetPendingTasks() int32
- func (x *StepStats) GetReallyFailedTasks() int32
- func (x *StepStats) GetRunningRun() *Accum
- func (x *StepStats) GetRunningTasks() int32
- func (x *StepStats) GetStartTime() int64
- func (x *StepStats) GetStatsEvalTime() int32
- func (x *StepStats) GetStepId() int32
- func (x *StepStats) GetStepName() string
- func (x *StepStats) GetSuccessRun() *Accum
- func (x *StepStats) GetSuccessfulTasks() int32
- func (x *StepStats) GetTotalTasks() int32
- func (x *StepStats) GetUpload() *Accum
- func (x *StepStats) GetUploadingTasks() int32
- func (x *StepStats) GetWaitingTasks() int32
- func (*StepStats) ProtoMessage()
- func (x *StepStats) ProtoReflect() protoreflect.Message
- func (x *StepStats) Reset()
- func (x *StepStats) String() string
- type StepStatsRequest
- func (*StepStatsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StepStatsRequest) GetStepIds() []int32
- func (x *StepStatsRequest) GetWorkflowId() int32
- func (*StepStatsRequest) ProtoMessage()
- func (x *StepStatsRequest) ProtoReflect() protoreflect.Message
- func (x *StepStatsRequest) Reset()
- func (x *StepStatsRequest) String() string
- type StepStatsResponse
- func (*StepStatsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StepStatsResponse) GetStats() []*StepStats
- func (*StepStatsResponse) ProtoMessage()
- func (x *StepStatsResponse) ProtoReflect() protoreflect.Message
- func (x *StepStatsResponse) Reset()
- func (x *StepStatsResponse) String() string
- type Task
- func (*Task) Descriptor() ([]byte, []int)deprecated
- func (x *Task) GetCommand() string
- func (x *Task) GetContainer() string
- func (x *Task) GetContainerOptions() string
- func (x *Task) GetDownloadTimeout() float32
- func (x *Task) GetHidden() bool
- func (x *Task) GetInput() []string
- func (x *Task) GetIsFinal() bool
- func (x *Task) GetOutput() string
- func (x *Task) GetPreviousTaskId() int32
- func (x *Task) GetResource() []string
- func (x *Task) GetRetry() int32
- func (x *Task) GetRetryCount() int32
- func (x *Task) GetRunStartTime() int64
- func (x *Task) GetRunningTimeout() float32
- func (x *Task) GetShell() string
- func (x *Task) GetStatus() string
- func (x *Task) GetStepId() int32
- func (x *Task) GetTaskId() int32
- func (x *Task) GetTaskName() string
- func (x *Task) GetUploadTimeout() float32
- func (x *Task) GetUsesCache() bool
- func (x *Task) GetWeight() float64
- func (x *Task) GetWorkerId() int32
- func (x *Task) GetWorkflowId() int32
- func (*Task) ProtoMessage()
- func (x *Task) ProtoReflect() protoreflect.Message
- func (x *Task) Reset()
- func (x *Task) String() string
- type TaskId
- type TaskIds
- type TaskList
- type TaskListAndOther
- func (*TaskListAndOther) Descriptor() ([]byte, []int)deprecated
- func (x *TaskListAndOther) GetActiveTasks() []int32
- func (x *TaskListAndOther) GetConcurrency() int32
- func (x *TaskListAndOther) GetTasks() []*Task
- func (x *TaskListAndOther) GetUpdates() *TaskUpdateList
- func (*TaskListAndOther) ProtoMessage()
- func (x *TaskListAndOther) ProtoReflect() protoreflect.Message
- func (x *TaskListAndOther) Reset()
- func (x *TaskListAndOther) String() string
- type TaskLog
- func (*TaskLog) Descriptor() ([]byte, []int)deprecated
- func (x *TaskLog) GetLogText() string
- func (x *TaskLog) GetLogType() string
- func (x *TaskLog) GetTaskId() int32
- func (*TaskLog) ProtoMessage()
- func (x *TaskLog) ProtoReflect() protoreflect.Message
- func (x *TaskLog) Reset()
- func (x *TaskLog) String() string
- type TaskQueueClient
- type TaskQueueServer
- type TaskQueue_SendTaskLogsClient
- type TaskQueue_SendTaskLogsServer
- type TaskQueue_StreamTaskLogsErrClient
- type TaskQueue_StreamTaskLogsErrServer
- type TaskQueue_StreamTaskLogsOutputClient
- type TaskQueue_StreamTaskLogsOutputServer
- type TaskRequest
- func (*TaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TaskRequest) GetCommand() string
- func (x *TaskRequest) GetContainer() string
- func (x *TaskRequest) GetContainerOptions() string
- func (x *TaskRequest) GetDependency() []int32
- func (x *TaskRequest) GetDownloadTimeout() float32
- func (x *TaskRequest) GetInput() []string
- func (x *TaskRequest) GetIsFinal() bool
- func (x *TaskRequest) GetOutput() string
- func (x *TaskRequest) GetResource() []string
- func (x *TaskRequest) GetRetry() int32
- func (x *TaskRequest) GetRunningTimeout() float32
- func (x *TaskRequest) GetShell() string
- func (x *TaskRequest) GetStatus() string
- func (x *TaskRequest) GetStepId() int32
- func (x *TaskRequest) GetTaskName() string
- func (x *TaskRequest) GetUploadTimeout() float32
- func (x *TaskRequest) GetUsesCache() bool
- func (*TaskRequest) ProtoMessage()
- func (x *TaskRequest) ProtoReflect() protoreflect.Message
- func (x *TaskRequest) Reset()
- func (x *TaskRequest) String() string
- type TaskResponse
- type TaskStatusCountsRequest
- func (*TaskStatusCountsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TaskStatusCountsRequest) GetShowHidden() bool
- func (*TaskStatusCountsRequest) ProtoMessage()
- func (x *TaskStatusCountsRequest) ProtoReflect() protoreflect.Message
- func (x *TaskStatusCountsRequest) Reset()
- func (x *TaskStatusCountsRequest) String() string
- type TaskStatusCountsResponse
- func (*TaskStatusCountsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TaskStatusCountsResponse) GetGlobalCounts() []*StatusCountEntry
- func (x *TaskStatusCountsResponse) GetPerWorkerCounts() []*StatusCountEntry
- func (x *TaskStatusCountsResponse) GetTotalCount() int32
- func (*TaskStatusCountsResponse) ProtoMessage()
- func (x *TaskStatusCountsResponse) ProtoReflect() protoreflect.Message
- func (x *TaskStatusCountsResponse) Reset()
- func (x *TaskStatusCountsResponse) String() string
- type TaskStatusUpdate
- func (*TaskStatusUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *TaskStatusUpdate) GetDuration() int32
- func (x *TaskStatusUpdate) GetFreeRetry() bool
- func (x *TaskStatusUpdate) GetNewStatus() string
- func (x *TaskStatusUpdate) GetTaskId() int32
- func (*TaskStatusUpdate) ProtoMessage()
- func (x *TaskStatusUpdate) ProtoReflect() protoreflect.Message
- func (x *TaskStatusUpdate) Reset()
- func (x *TaskStatusUpdate) String() string
- type TaskUpdate
- type TaskUpdateList
- type Template
- func (*Template) Descriptor() ([]byte, []int)deprecated
- func (x *Template) GetDescription() string
- func (x *Template) GetName() string
- func (x *Template) GetParamJson() string
- func (x *Template) GetUploadedAt() string
- func (x *Template) GetUploadedBy() int32
- func (x *Template) GetVersion() string
- func (x *Template) GetWorkflowTemplateId() int32
- func (*Template) ProtoMessage()
- func (x *Template) ProtoReflect() protoreflect.Message
- func (x *Template) Reset()
- func (x *Template) String() string
- type TemplateFilter
- func (*TemplateFilter) Descriptor() ([]byte, []int)deprecated
- func (x *TemplateFilter) GetName() string
- func (x *TemplateFilter) GetVersion() string
- func (x *TemplateFilter) GetWorkflowTemplateId() int32
- func (*TemplateFilter) ProtoMessage()
- func (x *TemplateFilter) ProtoReflect() protoreflect.Message
- func (x *TemplateFilter) Reset()
- func (x *TemplateFilter) String() string
- type TemplateList
- type TemplateRun
- func (*TemplateRun) Descriptor() ([]byte, []int)deprecated
- func (x *TemplateRun) GetCreatedAt() string
- func (x *TemplateRun) GetErrorMessage() string
- func (x *TemplateRun) GetParamValuesJson() string
- func (x *TemplateRun) GetRunBy() int32
- func (x *TemplateRun) GetRunByUsername() string
- func (x *TemplateRun) GetStatus() string
- func (x *TemplateRun) GetTemplateName() string
- func (x *TemplateRun) GetTemplateRunId() int32
- func (x *TemplateRun) GetTemplateVersion() string
- func (x *TemplateRun) GetWorkflowId() int32
- func (x *TemplateRun) GetWorkflowName() string
- func (x *TemplateRun) GetWorkflowTemplateId() int32
- func (*TemplateRun) ProtoMessage()
- func (x *TemplateRun) ProtoReflect() protoreflect.Message
- func (x *TemplateRun) Reset()
- func (x *TemplateRun) String() string
- type TemplateRunFilter
- func (*TemplateRunFilter) Descriptor() ([]byte, []int)deprecated
- func (x *TemplateRunFilter) GetWorkflowTemplateId() int32
- func (*TemplateRunFilter) ProtoMessage()
- func (x *TemplateRunFilter) ProtoReflect() protoreflect.Message
- func (x *TemplateRunFilter) Reset()
- func (x *TemplateRunFilter) String() string
- type TemplateRunList
- type Token
- type UnimplementedTaskQueueServer
- func (UnimplementedTaskQueueServer) ChangePassword(context.Context, *ChangePasswordRequest) (*Ack, error)
- func (UnimplementedTaskQueueServer) CreateFlavor(context.Context, *FlavorCreateRequest) (*FlavorId, error)
- func (UnimplementedTaskQueueServer) CreateRecruiter(context.Context, *Recruiter) (*Ack, error)
- func (UnimplementedTaskQueueServer) CreateStep(context.Context, *StepRequest) (*StepId, error)
- func (UnimplementedTaskQueueServer) CreateUser(context.Context, *CreateUserRequest) (*UserId, error)
- func (UnimplementedTaskQueueServer) CreateWorker(context.Context, *WorkerRequest) (*WorkerIds, error)
- func (UnimplementedTaskQueueServer) CreateWorkflow(context.Context, *WorkflowRequest) (*WorkflowId, error)
- func (UnimplementedTaskQueueServer) DebugAssignTask(context.Context, *DebugAssignRequest) (*Ack, error)
- func (UnimplementedTaskQueueServer) DebugRecruitStep(context.Context, *DebugRecruitRequest) (*Ack, error)
- func (UnimplementedTaskQueueServer) DebugRetryTask(context.Context, *RetryTaskRequest) (*TaskResponse, error)
- func (UnimplementedTaskQueueServer) DeleteJob(context.Context, *JobId) (*Ack, error)
- func (UnimplementedTaskQueueServer) DeleteRecruiter(context.Context, *RecruiterId) (*Ack, error)
- func (UnimplementedTaskQueueServer) DeleteStep(context.Context, *StepId) (*Ack, error)
- func (UnimplementedTaskQueueServer) DeleteTemplateRun(context.Context, *DeleteTemplateRunRequest) (*Ack, error)
- func (UnimplementedTaskQueueServer) DeleteUser(context.Context, *UserId) (*Ack, error)
- func (UnimplementedTaskQueueServer) DeleteWorker(context.Context, *WorkerDeletion) (*JobId, error)
- func (UnimplementedTaskQueueServer) DeleteWorkerEvent(context.Context, *WorkerEventId) (*Ack, error)
- func (UnimplementedTaskQueueServer) DeleteWorkflow(context.Context, *WorkflowId) (*Ack, error)
- func (UnimplementedTaskQueueServer) FetchInfo(context.Context, *FetchListRequest) (*FetchInfoResponse, error)
- func (UnimplementedTaskQueueServer) FetchList(context.Context, *FetchListRequest) (*FetchListResponse, error)
- func (UnimplementedTaskQueueServer) GetCertificate(context.Context, *emptypb.Empty) (*Certificate, error)
- func (UnimplementedTaskQueueServer) GetDockerCredentials(context.Context, *emptypb.Empty) (*DockerCredentials, error)
- func (UnimplementedTaskQueueServer) GetJobStatuses(context.Context, *JobStatusRequest) (*JobStatusResponse, error)
- func (UnimplementedTaskQueueServer) GetLogsChunk(context.Context, *GetLogsRequest) (*LogChunkList, error)
- func (UnimplementedTaskQueueServer) GetRcloneConfig(context.Context, *emptypb.Empty) (*RcloneRemotes, error)
- func (UnimplementedTaskQueueServer) GetStepStats(context.Context, *StepStatsRequest) (*StepStatsResponse, error)
- func (UnimplementedTaskQueueServer) GetTaskStatusCounts(context.Context, *TaskStatusCountsRequest) (*TaskStatusCountsResponse, error)
- func (UnimplementedTaskQueueServer) GetWorkerStats(context.Context, *GetWorkerStatsRequest) (*GetWorkerStatsResponse, error)
- func (UnimplementedTaskQueueServer) GetWorkerStatuses(context.Context, *WorkerStatusRequest) (*WorkerStatusResponse, error)
- func (UnimplementedTaskQueueServer) GetWorkspaceRoot(context.Context, *WorkspaceRootRequest) (*WorkspaceRootResponse, error)
- func (UnimplementedTaskQueueServer) ListDependentPendingTasks(context.Context, *TaskId) (*TaskIds, error)
- func (UnimplementedTaskQueueServer) ListFlavors(context.Context, *ListFlavorsRequest) (*FlavorsList, error)
- func (UnimplementedTaskQueueServer) ListJobs(context.Context, *ListJobsRequest) (*JobsList, error)
- func (UnimplementedTaskQueueServer) ListProviders(context.Context, *emptypb.Empty) (*ProviderList, error)
- func (UnimplementedTaskQueueServer) ListRecruiters(context.Context, *RecruiterFilter) (*RecruiterList, error)
- func (UnimplementedTaskQueueServer) ListRegions(context.Context, *emptypb.Empty) (*RegionList, error)
- func (UnimplementedTaskQueueServer) ListSteps(context.Context, *StepFilter) (*StepList, error)
- func (UnimplementedTaskQueueServer) ListTasks(context.Context, *ListTasksRequest) (*TaskList, error)
- func (UnimplementedTaskQueueServer) ListTemplateRuns(context.Context, *TemplateRunFilter) (*TemplateRunList, error)
- func (UnimplementedTaskQueueServer) ListTemplates(context.Context, *TemplateFilter) (*TemplateList, error)
- func (UnimplementedTaskQueueServer) ListUsers(context.Context, *emptypb.Empty) (*UsersList, error)
- func (UnimplementedTaskQueueServer) ListWorkerEvents(context.Context, *WorkerEventFilter) (*WorkerEventList, error)
- func (UnimplementedTaskQueueServer) ListWorkers(context.Context, *ListWorkersRequest) (*WorkersList, error)
- func (UnimplementedTaskQueueServer) ListWorkflows(context.Context, *WorkflowFilter) (*WorkflowList, error)
- func (UnimplementedTaskQueueServer) Login(context.Context, *LoginRequest) (*LoginResponse, error)
- func (UnimplementedTaskQueueServer) Logout(context.Context, *Token) (*Ack, error)
- func (UnimplementedTaskQueueServer) PingAndTakeNewTasks(context.Context, *PingAndGetNewTasksRequest) (*TaskListAndOther, error)
- func (UnimplementedTaskQueueServer) PruneWorkerEvents(context.Context, *WorkerEventPruneFilter) (*WorkerEventPruneResult, error)
- func (UnimplementedTaskQueueServer) RegisterSpecifications(context.Context, *ResourceSpec) (*Ack, error)
- func (UnimplementedTaskQueueServer) RegisterWorker(context.Context, *WorkerInfo) (*WorkerId, error)
- func (UnimplementedTaskQueueServer) ReportWorkerEvent(context.Context, *WorkerEvent) (*Ack, error)
- func (UnimplementedTaskQueueServer) RetryTask(context.Context, *RetryTaskRequest) (*TaskResponse, error)
- func (UnimplementedTaskQueueServer) RunTemplate(context.Context, *RunTemplateRequest) (*TemplateRun, error)
- func (UnimplementedTaskQueueServer) SendTaskLogs(grpc.ClientStreamingServer[TaskLog, Ack]) error
- func (UnimplementedTaskQueueServer) StreamTaskLogsErr(*TaskId, grpc.ServerStreamingServer[TaskLog]) error
- func (UnimplementedTaskQueueServer) StreamTaskLogsOutput(*TaskId, grpc.ServerStreamingServer[TaskLog]) error
- func (UnimplementedTaskQueueServer) SubmitTask(context.Context, *TaskRequest) (*TaskResponse, error)
- func (UnimplementedTaskQueueServer) UpdateJob(context.Context, *JobUpdate) (*Ack, error)
- func (UnimplementedTaskQueueServer) UpdateRecruiter(context.Context, *RecruiterUpdate) (*Ack, error)
- func (UnimplementedTaskQueueServer) UpdateTaskStatus(context.Context, *TaskStatusUpdate) (*Ack, error)
- func (UnimplementedTaskQueueServer) UpdateTemplateRun(context.Context, *UpdateTemplateRunRequest) (*Ack, error)
- func (UnimplementedTaskQueueServer) UpdateUser(context.Context, *User) (*Ack, error)
- func (UnimplementedTaskQueueServer) UpdateWorker(context.Context, *WorkerUpdateRequest) (*Ack, error)
- func (UnimplementedTaskQueueServer) UpdateWorkerStatus(context.Context, *WorkerStatus) (*Ack, error)
- func (UnimplementedTaskQueueServer) UpdateWorkflowStatus(context.Context, *WorkflowStatusUpdate) (*Ack, error)
- func (UnimplementedTaskQueueServer) UploadTemplate(context.Context, *UploadTemplateRequest) (*UploadTemplateResponse, error)
- func (UnimplementedTaskQueueServer) UserUpdateWorker(context.Context, *WorkerUpdateRequest) (*Ack, error)
- type UnsafeTaskQueueServer
- type UpdateTemplateRunRequest
- func (*UpdateTemplateRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateTemplateRunRequest) GetErrorMessage() string
- func (x *UpdateTemplateRunRequest) GetTemplateRunId() int32
- func (x *UpdateTemplateRunRequest) GetWorkflowId() int32
- func (*UpdateTemplateRunRequest) ProtoMessage()
- func (x *UpdateTemplateRunRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateTemplateRunRequest) Reset()
- func (x *UpdateTemplateRunRequest) String() string
- type UploadTemplateRequest
- func (*UploadTemplateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UploadTemplateRequest) GetForce() bool
- func (x *UploadTemplateRequest) GetScript() []byte
- func (*UploadTemplateRequest) ProtoMessage()
- func (x *UploadTemplateRequest) ProtoReflect() protoreflect.Message
- func (x *UploadTemplateRequest) Reset()
- func (x *UploadTemplateRequest) String() string
- type UploadTemplateResponse
- func (*UploadTemplateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UploadTemplateResponse) GetDescription() string
- func (x *UploadTemplateResponse) GetMessage() string
- func (x *UploadTemplateResponse) GetName() string
- func (x *UploadTemplateResponse) GetParamJson() string
- func (x *UploadTemplateResponse) GetSuccess() bool
- func (x *UploadTemplateResponse) GetVersion() string
- func (x *UploadTemplateResponse) GetWorkflowTemplateId() int32
- func (*UploadTemplateResponse) ProtoMessage()
- func (x *UploadTemplateResponse) ProtoReflect() protoreflect.Message
- func (x *UploadTemplateResponse) Reset()
- func (x *UploadTemplateResponse) String() string
- type User
- func (*User) Descriptor() ([]byte, []int)deprecated
- func (x *User) GetEmail() string
- func (x *User) GetIsAdmin() bool
- func (x *User) GetUserId() int32
- func (x *User) GetUsername() string
- func (*User) ProtoMessage()
- func (x *User) ProtoReflect() protoreflect.Message
- func (x *User) Reset()
- func (x *User) String() string
- type UserId
- type UsersList
- type Worker
- func (*Worker) Descriptor() ([]byte, []int)deprecated
- func (x *Worker) GetConcurrency() int32
- func (x *Worker) GetFlavor() string
- func (x *Worker) GetIpv4() string
- func (x *Worker) GetIpv6() string
- func (x *Worker) GetIsPermanent() bool
- func (x *Worker) GetName() string
- func (x *Worker) GetPrefetch() int32
- func (x *Worker) GetProvider() string
- func (x *Worker) GetRecyclableScope() string
- func (x *Worker) GetRegion() string
- func (x *Worker) GetStatus() string
- func (x *Worker) GetStepId() int32
- func (x *Worker) GetStepName() string
- func (x *Worker) GetWorkerId() int32
- func (x *Worker) GetWorkflowId() int32
- func (x *Worker) GetWorkflowName() string
- func (*Worker) ProtoMessage()
- func (x *Worker) ProtoReflect() protoreflect.Message
- func (x *Worker) Reset()
- func (x *Worker) String() string
- type WorkerDeletion
- func (*WorkerDeletion) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerDeletion) GetUndeployed() bool
- func (x *WorkerDeletion) GetWorkerId() int32
- func (*WorkerDeletion) ProtoMessage()
- func (x *WorkerDeletion) ProtoReflect() protoreflect.Message
- func (x *WorkerDeletion) Reset()
- func (x *WorkerDeletion) String() string
- type WorkerDetails
- func (*WorkerDetails) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerDetails) GetJobId() int32
- func (x *WorkerDetails) GetWorkerId() int32
- func (x *WorkerDetails) GetWorkerName() string
- func (*WorkerDetails) ProtoMessage()
- func (x *WorkerDetails) ProtoReflect() protoreflect.Message
- func (x *WorkerDetails) Reset()
- func (x *WorkerDetails) String() string
- type WorkerEvent
- func (*WorkerEvent) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerEvent) GetDetailsJson() string
- func (x *WorkerEvent) GetEventClass() string
- func (x *WorkerEvent) GetLevel() string
- func (x *WorkerEvent) GetMessage() string
- func (x *WorkerEvent) GetWorkerId() int32
- func (x *WorkerEvent) GetWorkerName() string
- func (*WorkerEvent) ProtoMessage()
- func (x *WorkerEvent) ProtoReflect() protoreflect.Message
- func (x *WorkerEvent) Reset()
- func (x *WorkerEvent) String() string
- type WorkerEventFilter
- func (*WorkerEventFilter) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerEventFilter) GetClass() string
- func (x *WorkerEventFilter) GetLevel() string
- func (x *WorkerEventFilter) GetLimit() int32
- func (x *WorkerEventFilter) GetWorkerId() int32
- func (*WorkerEventFilter) ProtoMessage()
- func (x *WorkerEventFilter) ProtoReflect() protoreflect.Message
- func (x *WorkerEventFilter) Reset()
- func (x *WorkerEventFilter) String() string
- type WorkerEventId
- type WorkerEventList
- type WorkerEventPruneFilter
- func (*WorkerEventPruneFilter) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerEventPruneFilter) GetBefore() string
- func (x *WorkerEventPruneFilter) GetClass() string
- func (x *WorkerEventPruneFilter) GetDryRun() bool
- func (x *WorkerEventPruneFilter) GetLevel() string
- func (x *WorkerEventPruneFilter) GetWorkerId() int32
- func (*WorkerEventPruneFilter) ProtoMessage()
- func (x *WorkerEventPruneFilter) ProtoReflect() protoreflect.Message
- func (x *WorkerEventPruneFilter) Reset()
- func (x *WorkerEventPruneFilter) String() string
- type WorkerEventPruneResult
- func (*WorkerEventPruneResult) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerEventPruneResult) GetDeleted() int32
- func (x *WorkerEventPruneResult) GetMatched() int32
- func (*WorkerEventPruneResult) ProtoMessage()
- func (x *WorkerEventPruneResult) ProtoReflect() protoreflect.Message
- func (x *WorkerEventPruneResult) Reset()
- func (x *WorkerEventPruneResult) String() string
- type WorkerEventRecord
- func (*WorkerEventRecord) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerEventRecord) GetCreatedAt() string
- func (x *WorkerEventRecord) GetDetailsJson() string
- func (x *WorkerEventRecord) GetEventClass() string
- func (x *WorkerEventRecord) GetEventId() int32
- func (x *WorkerEventRecord) GetLevel() string
- func (x *WorkerEventRecord) GetMessage() string
- func (x *WorkerEventRecord) GetWorkerId() int32
- func (x *WorkerEventRecord) GetWorkerName() string
- func (*WorkerEventRecord) ProtoMessage()
- func (x *WorkerEventRecord) ProtoReflect() protoreflect.Message
- func (x *WorkerEventRecord) Reset()
- func (x *WorkerEventRecord) String() string
- type WorkerId
- type WorkerIds
- type WorkerInfo
- func (*WorkerInfo) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerInfo) GetConcurrency() int32
- func (x *WorkerInfo) GetIsPermanent() bool
- func (x *WorkerInfo) GetName() string
- func (x *WorkerInfo) GetProvider() string
- func (x *WorkerInfo) GetRegion() string
- func (*WorkerInfo) ProtoMessage()
- func (x *WorkerInfo) ProtoReflect() protoreflect.Message
- func (x *WorkerInfo) Reset()
- func (x *WorkerInfo) String() string
- type WorkerRequest
- func (*WorkerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerRequest) GetConcurrency() int32
- func (x *WorkerRequest) GetFlavorId() int32
- func (x *WorkerRequest) GetNumber() int32
- func (x *WorkerRequest) GetPrefetch() int32
- func (x *WorkerRequest) GetProviderId() int32
- func (x *WorkerRequest) GetRegionId() int32
- func (x *WorkerRequest) GetStepId() int32
- func (*WorkerRequest) ProtoMessage()
- func (x *WorkerRequest) ProtoReflect() protoreflect.Message
- func (x *WorkerRequest) Reset()
- func (x *WorkerRequest) String() string
- type WorkerStats
- func (*WorkerStats) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerStats) GetCpuUsagePercent() float32
- func (x *WorkerStats) GetDiskIo() *DiskIOStats
- func (x *WorkerStats) GetDisks() []*DiskUsage
- func (x *WorkerStats) GetIowaitPercent() float32
- func (x *WorkerStats) GetLoad_1Min() float32
- func (x *WorkerStats) GetMemUsagePercent() float32
- func (x *WorkerStats) GetNetIo() *NetIOStats
- func (*WorkerStats) ProtoMessage()
- func (x *WorkerStats) ProtoReflect() protoreflect.Message
- func (x *WorkerStats) Reset()
- func (x *WorkerStats) String() string
- type WorkerStatus
- func (*WorkerStatus) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerStatus) GetStatus() string
- func (x *WorkerStatus) GetWorkerId() int32
- func (*WorkerStatus) ProtoMessage()
- func (x *WorkerStatus) ProtoReflect() protoreflect.Message
- func (x *WorkerStatus) Reset()
- func (x *WorkerStatus) String() string
- type WorkerStatusRequest
- func (*WorkerStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerStatusRequest) GetWorkerIds() []int32
- func (*WorkerStatusRequest) ProtoMessage()
- func (x *WorkerStatusRequest) ProtoReflect() protoreflect.Message
- func (x *WorkerStatusRequest) Reset()
- func (x *WorkerStatusRequest) String() string
- type WorkerStatusResponse
- func (*WorkerStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerStatusResponse) GetStatuses() []*WorkerStatus
- func (*WorkerStatusResponse) ProtoMessage()
- func (x *WorkerStatusResponse) ProtoReflect() protoreflect.Message
- func (x *WorkerStatusResponse) Reset()
- func (x *WorkerStatusResponse) String() string
- type WorkerUpdateRequest
- func (*WorkerUpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerUpdateRequest) GetConcurrency() int32
- func (x *WorkerUpdateRequest) GetFlavorId() int32
- func (x *WorkerUpdateRequest) GetIsPermanent() bool
- func (x *WorkerUpdateRequest) GetPrefetch() int32
- func (x *WorkerUpdateRequest) GetProviderId() int32
- func (x *WorkerUpdateRequest) GetRecyclableScope() string
- func (x *WorkerUpdateRequest) GetRegionId() int32
- func (x *WorkerUpdateRequest) GetStepId() int32
- func (x *WorkerUpdateRequest) GetStepName() string
- func (x *WorkerUpdateRequest) GetWorkerId() int32
- func (x *WorkerUpdateRequest) GetWorkflowName() string
- func (*WorkerUpdateRequest) ProtoMessage()
- func (x *WorkerUpdateRequest) ProtoReflect() protoreflect.Message
- func (x *WorkerUpdateRequest) Reset()
- func (x *WorkerUpdateRequest) String() string
- type WorkersList
- type Workflow
- func (*Workflow) Descriptor() ([]byte, []int)deprecated
- func (x *Workflow) GetMaximumWorkers() int32
- func (x *Workflow) GetName() string
- func (x *Workflow) GetRunStrategy() string
- func (x *Workflow) GetStatus() string
- func (x *Workflow) GetWorkflowId() int32
- func (*Workflow) ProtoMessage()
- func (x *Workflow) ProtoReflect() protoreflect.Message
- func (x *Workflow) Reset()
- func (x *Workflow) String() string
- type WorkflowFilter
- func (*WorkflowFilter) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowFilter) GetLimit() int32
- func (x *WorkflowFilter) GetNameLike() string
- func (x *WorkflowFilter) GetOffset() int32
- func (*WorkflowFilter) ProtoMessage()
- func (x *WorkflowFilter) ProtoReflect() protoreflect.Message
- func (x *WorkflowFilter) Reset()
- func (x *WorkflowFilter) String() string
- type WorkflowId
- type WorkflowList
- type WorkflowRequest
- func (*WorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowRequest) GetMaximumWorkers() int32
- func (x *WorkflowRequest) GetName() string
- func (x *WorkflowRequest) GetRunStrategy() string
- func (x *WorkflowRequest) GetStatus() string
- func (*WorkflowRequest) ProtoMessage()
- func (x *WorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *WorkflowRequest) Reset()
- func (x *WorkflowRequest) String() string
- type WorkflowStatusUpdate
- func (*WorkflowStatusUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowStatusUpdate) GetStatus() string
- func (x *WorkflowStatusUpdate) GetWorkflowId() int32
- func (*WorkflowStatusUpdate) ProtoMessage()
- func (x *WorkflowStatusUpdate) ProtoReflect() protoreflect.Message
- func (x *WorkflowStatusUpdate) Reset()
- func (x *WorkflowStatusUpdate) String() string
- type WorkspaceRootRequest
- func (*WorkspaceRootRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkspaceRootRequest) GetProvider() string
- func (x *WorkspaceRootRequest) GetRegion() string
- func (*WorkspaceRootRequest) ProtoMessage()
- func (x *WorkspaceRootRequest) ProtoReflect() protoreflect.Message
- func (x *WorkspaceRootRequest) Reset()
- func (x *WorkspaceRootRequest) String() string
- type WorkspaceRootResponse
- func (*WorkspaceRootResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkspaceRootResponse) GetRootUri() string
- func (*WorkspaceRootResponse) ProtoMessage()
- func (x *WorkspaceRootResponse) ProtoReflect() protoreflect.Message
- func (x *WorkspaceRootResponse) Reset()
- func (x *WorkspaceRootResponse) String() string
Constants ¶
const ( TaskQueue_SubmitTask_FullMethodName = "/taskqueue.TaskQueue/SubmitTask" TaskQueue_RegisterWorker_FullMethodName = "/taskqueue.TaskQueue/RegisterWorker" TaskQueue_PingAndTakeNewTasks_FullMethodName = "/taskqueue.TaskQueue/PingAndTakeNewTasks" TaskQueue_UpdateTaskStatus_FullMethodName = "/taskqueue.TaskQueue/UpdateTaskStatus" TaskQueue_SendTaskLogs_FullMethodName = "/taskqueue.TaskQueue/SendTaskLogs" TaskQueue_StreamTaskLogsOutput_FullMethodName = "/taskqueue.TaskQueue/StreamTaskLogsOutput" TaskQueue_StreamTaskLogsErr_FullMethodName = "/taskqueue.TaskQueue/StreamTaskLogsErr" TaskQueue_GetLogsChunk_FullMethodName = "/taskqueue.TaskQueue/GetLogsChunk" TaskQueue_ListTasks_FullMethodName = "/taskqueue.TaskQueue/ListTasks" TaskQueue_RetryTask_FullMethodName = "/taskqueue.TaskQueue/RetryTask" TaskQueue_ListWorkers_FullMethodName = "/taskqueue.TaskQueue/ListWorkers" TaskQueue_CreateWorker_FullMethodName = "/taskqueue.TaskQueue/CreateWorker" TaskQueue_UpdateWorkerStatus_FullMethodName = "/taskqueue.TaskQueue/UpdateWorkerStatus" TaskQueue_DeleteWorker_FullMethodName = "/taskqueue.TaskQueue/DeleteWorker" TaskQueue_UpdateWorker_FullMethodName = "/taskqueue.TaskQueue/UpdateWorker" TaskQueue_UserUpdateWorker_FullMethodName = "/taskqueue.TaskQueue/UserUpdateWorker" TaskQueue_GetWorkerStatuses_FullMethodName = "/taskqueue.TaskQueue/GetWorkerStatuses" TaskQueue_ListJobs_FullMethodName = "/taskqueue.TaskQueue/ListJobs" TaskQueue_GetJobStatuses_FullMethodName = "/taskqueue.TaskQueue/GetJobStatuses" TaskQueue_DeleteJob_FullMethodName = "/taskqueue.TaskQueue/DeleteJob" TaskQueue_UpdateJob_FullMethodName = "/taskqueue.TaskQueue/UpdateJob" TaskQueue_ListFlavors_FullMethodName = "/taskqueue.TaskQueue/ListFlavors" TaskQueue_ListProviders_FullMethodName = "/taskqueue.TaskQueue/ListProviders" TaskQueue_ListRegions_FullMethodName = "/taskqueue.TaskQueue/ListRegions" TaskQueue_CreateFlavor_FullMethodName = "/taskqueue.TaskQueue/CreateFlavor" TaskQueue_GetRcloneConfig_FullMethodName = "/taskqueue.TaskQueue/GetRcloneConfig" TaskQueue_GetDockerCredentials_FullMethodName = "/taskqueue.TaskQueue/GetDockerCredentials" TaskQueue_Login_FullMethodName = "/taskqueue.TaskQueue/Login" TaskQueue_GetCertificate_FullMethodName = "/taskqueue.TaskQueue/GetCertificate" TaskQueue_Logout_FullMethodName = "/taskqueue.TaskQueue/Logout" TaskQueue_CreateUser_FullMethodName = "/taskqueue.TaskQueue/CreateUser" TaskQueue_ListUsers_FullMethodName = "/taskqueue.TaskQueue/ListUsers" TaskQueue_DeleteUser_FullMethodName = "/taskqueue.TaskQueue/DeleteUser" TaskQueue_UpdateUser_FullMethodName = "/taskqueue.TaskQueue/UpdateUser" TaskQueue_ChangePassword_FullMethodName = "/taskqueue.TaskQueue/ChangePassword" TaskQueue_ListRecruiters_FullMethodName = "/taskqueue.TaskQueue/ListRecruiters" TaskQueue_CreateRecruiter_FullMethodName = "/taskqueue.TaskQueue/CreateRecruiter" TaskQueue_UpdateRecruiter_FullMethodName = "/taskqueue.TaskQueue/UpdateRecruiter" TaskQueue_DeleteRecruiter_FullMethodName = "/taskqueue.TaskQueue/DeleteRecruiter" TaskQueue_ListWorkflows_FullMethodName = "/taskqueue.TaskQueue/ListWorkflows" TaskQueue_CreateWorkflow_FullMethodName = "/taskqueue.TaskQueue/CreateWorkflow" TaskQueue_UpdateWorkflowStatus_FullMethodName = "/taskqueue.TaskQueue/UpdateWorkflowStatus" TaskQueue_DeleteWorkflow_FullMethodName = "/taskqueue.TaskQueue/DeleteWorkflow" TaskQueue_DebugAssignTask_FullMethodName = "/taskqueue.TaskQueue/DebugAssignTask" TaskQueue_DebugRecruitStep_FullMethodName = "/taskqueue.TaskQueue/DebugRecruitStep" TaskQueue_DebugRetryTask_FullMethodName = "/taskqueue.TaskQueue/DebugRetryTask" TaskQueue_ListDependentPendingTasks_FullMethodName = "/taskqueue.TaskQueue/ListDependentPendingTasks" TaskQueue_ListSteps_FullMethodName = "/taskqueue.TaskQueue/ListSteps" TaskQueue_CreateStep_FullMethodName = "/taskqueue.TaskQueue/CreateStep" TaskQueue_DeleteStep_FullMethodName = "/taskqueue.TaskQueue/DeleteStep" TaskQueue_GetStepStats_FullMethodName = "/taskqueue.TaskQueue/GetStepStats" TaskQueue_GetWorkerStats_FullMethodName = "/taskqueue.TaskQueue/GetWorkerStats" TaskQueue_FetchList_FullMethodName = "/taskqueue.TaskQueue/FetchList" TaskQueue_FetchInfo_FullMethodName = "/taskqueue.TaskQueue/FetchInfo" TaskQueue_UploadTemplate_FullMethodName = "/taskqueue.TaskQueue/UploadTemplate" TaskQueue_RunTemplate_FullMethodName = "/taskqueue.TaskQueue/RunTemplate" TaskQueue_ListTemplates_FullMethodName = "/taskqueue.TaskQueue/ListTemplates" TaskQueue_ListTemplateRuns_FullMethodName = "/taskqueue.TaskQueue/ListTemplateRuns" TaskQueue_UpdateTemplateRun_FullMethodName = "/taskqueue.TaskQueue/UpdateTemplateRun" TaskQueue_DeleteTemplateRun_FullMethodName = "/taskqueue.TaskQueue/DeleteTemplateRun" TaskQueue_GetWorkspaceRoot_FullMethodName = "/taskqueue.TaskQueue/GetWorkspaceRoot" TaskQueue_RegisterSpecifications_FullMethodName = "/taskqueue.TaskQueue/RegisterSpecifications" TaskQueue_ReportWorkerEvent_FullMethodName = "/taskqueue.TaskQueue/ReportWorkerEvent" TaskQueue_ListWorkerEvents_FullMethodName = "/taskqueue.TaskQueue/ListWorkerEvents" TaskQueue_DeleteWorkerEvent_FullMethodName = "/taskqueue.TaskQueue/DeleteWorkerEvent" TaskQueue_PruneWorkerEvents_FullMethodName = "/taskqueue.TaskQueue/PruneWorkerEvents" TaskQueue_GetTaskStatusCounts_FullMethodName = "/taskqueue.TaskQueue/GetTaskStatusCounts" )
Variables ¶
var File_taskqueue_proto protoreflect.FileDescriptor
var TaskQueue_ServiceDesc = grpc.ServiceDesc{ ServiceName: "taskqueue.TaskQueue", HandlerType: (*TaskQueueServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SubmitTask", Handler: _TaskQueue_SubmitTask_Handler, }, { MethodName: "RegisterWorker", Handler: _TaskQueue_RegisterWorker_Handler, }, { MethodName: "PingAndTakeNewTasks", Handler: _TaskQueue_PingAndTakeNewTasks_Handler, }, { MethodName: "UpdateTaskStatus", Handler: _TaskQueue_UpdateTaskStatus_Handler, }, { MethodName: "GetLogsChunk", Handler: _TaskQueue_GetLogsChunk_Handler, }, { MethodName: "ListTasks", Handler: _TaskQueue_ListTasks_Handler, }, { MethodName: "RetryTask", Handler: _TaskQueue_RetryTask_Handler, }, { MethodName: "ListWorkers", Handler: _TaskQueue_ListWorkers_Handler, }, { MethodName: "CreateWorker", Handler: _TaskQueue_CreateWorker_Handler, }, { MethodName: "UpdateWorkerStatus", Handler: _TaskQueue_UpdateWorkerStatus_Handler, }, { MethodName: "DeleteWorker", Handler: _TaskQueue_DeleteWorker_Handler, }, { MethodName: "UpdateWorker", Handler: _TaskQueue_UpdateWorker_Handler, }, { MethodName: "UserUpdateWorker", Handler: _TaskQueue_UserUpdateWorker_Handler, }, { MethodName: "GetWorkerStatuses", Handler: _TaskQueue_GetWorkerStatuses_Handler, }, { MethodName: "ListJobs", Handler: _TaskQueue_ListJobs_Handler, }, { MethodName: "GetJobStatuses", Handler: _TaskQueue_GetJobStatuses_Handler, }, { MethodName: "DeleteJob", Handler: _TaskQueue_DeleteJob_Handler, }, { MethodName: "UpdateJob", Handler: _TaskQueue_UpdateJob_Handler, }, { MethodName: "ListFlavors", Handler: _TaskQueue_ListFlavors_Handler, }, { MethodName: "ListProviders", Handler: _TaskQueue_ListProviders_Handler, }, { MethodName: "ListRegions", Handler: _TaskQueue_ListRegions_Handler, }, { MethodName: "CreateFlavor", Handler: _TaskQueue_CreateFlavor_Handler, }, { MethodName: "GetRcloneConfig", Handler: _TaskQueue_GetRcloneConfig_Handler, }, { MethodName: "GetDockerCredentials", Handler: _TaskQueue_GetDockerCredentials_Handler, }, { MethodName: "Login", Handler: _TaskQueue_Login_Handler, }, { MethodName: "GetCertificate", Handler: _TaskQueue_GetCertificate_Handler, }, { MethodName: "Logout", Handler: _TaskQueue_Logout_Handler, }, { MethodName: "CreateUser", Handler: _TaskQueue_CreateUser_Handler, }, { MethodName: "ListUsers", Handler: _TaskQueue_ListUsers_Handler, }, { MethodName: "DeleteUser", Handler: _TaskQueue_DeleteUser_Handler, }, { MethodName: "UpdateUser", Handler: _TaskQueue_UpdateUser_Handler, }, { MethodName: "ChangePassword", Handler: _TaskQueue_ChangePassword_Handler, }, { MethodName: "ListRecruiters", Handler: _TaskQueue_ListRecruiters_Handler, }, { MethodName: "CreateRecruiter", Handler: _TaskQueue_CreateRecruiter_Handler, }, { MethodName: "UpdateRecruiter", Handler: _TaskQueue_UpdateRecruiter_Handler, }, { MethodName: "DeleteRecruiter", Handler: _TaskQueue_DeleteRecruiter_Handler, }, { MethodName: "ListWorkflows", Handler: _TaskQueue_ListWorkflows_Handler, }, { MethodName: "CreateWorkflow", Handler: _TaskQueue_CreateWorkflow_Handler, }, { MethodName: "UpdateWorkflowStatus", Handler: _TaskQueue_UpdateWorkflowStatus_Handler, }, { MethodName: "DeleteWorkflow", Handler: _TaskQueue_DeleteWorkflow_Handler, }, { MethodName: "DebugAssignTask", Handler: _TaskQueue_DebugAssignTask_Handler, }, { MethodName: "DebugRecruitStep", Handler: _TaskQueue_DebugRecruitStep_Handler, }, { MethodName: "DebugRetryTask", Handler: _TaskQueue_DebugRetryTask_Handler, }, { MethodName: "ListDependentPendingTasks", Handler: _TaskQueue_ListDependentPendingTasks_Handler, }, { MethodName: "ListSteps", Handler: _TaskQueue_ListSteps_Handler, }, { MethodName: "CreateStep", Handler: _TaskQueue_CreateStep_Handler, }, { MethodName: "DeleteStep", Handler: _TaskQueue_DeleteStep_Handler, }, { MethodName: "GetStepStats", Handler: _TaskQueue_GetStepStats_Handler, }, { MethodName: "GetWorkerStats", Handler: _TaskQueue_GetWorkerStats_Handler, }, { MethodName: "FetchList", Handler: _TaskQueue_FetchList_Handler, }, { MethodName: "FetchInfo", Handler: _TaskQueue_FetchInfo_Handler, }, { MethodName: "UploadTemplate", Handler: _TaskQueue_UploadTemplate_Handler, }, { MethodName: "RunTemplate", Handler: _TaskQueue_RunTemplate_Handler, }, { MethodName: "ListTemplates", Handler: _TaskQueue_ListTemplates_Handler, }, { MethodName: "ListTemplateRuns", Handler: _TaskQueue_ListTemplateRuns_Handler, }, { MethodName: "UpdateTemplateRun", Handler: _TaskQueue_UpdateTemplateRun_Handler, }, { MethodName: "DeleteTemplateRun", Handler: _TaskQueue_DeleteTemplateRun_Handler, }, { MethodName: "GetWorkspaceRoot", Handler: _TaskQueue_GetWorkspaceRoot_Handler, }, { MethodName: "RegisterSpecifications", Handler: _TaskQueue_RegisterSpecifications_Handler, }, { MethodName: "ReportWorkerEvent", Handler: _TaskQueue_ReportWorkerEvent_Handler, }, { MethodName: "ListWorkerEvents", Handler: _TaskQueue_ListWorkerEvents_Handler, }, { MethodName: "DeleteWorkerEvent", Handler: _TaskQueue_DeleteWorkerEvent_Handler, }, { MethodName: "PruneWorkerEvents", Handler: _TaskQueue_PruneWorkerEvents_Handler, }, { MethodName: "GetTaskStatusCounts", Handler: _TaskQueue_GetTaskStatusCounts_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "SendTaskLogs", Handler: _TaskQueue_SendTaskLogs_Handler, ClientStreams: true, }, { StreamName: "StreamTaskLogsOutput", Handler: _TaskQueue_StreamTaskLogsOutput_Handler, ServerStreams: true, }, { StreamName: "StreamTaskLogsErr", Handler: _TaskQueue_StreamTaskLogsErr_Handler, ServerStreams: true, }, }, Metadata: "taskqueue.proto", }
TaskQueue_ServiceDesc is the grpc.ServiceDesc for TaskQueue service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterTaskQueueServer ¶
func RegisterTaskQueueServer(s grpc.ServiceRegistrar, srv TaskQueueServer)
Types ¶
type Accum ¶
type Accum struct {
Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` // number of observations
Sum float32 `protobuf:"fixed32,2,opt,name=sum,proto3" json:"sum,omitempty"` // total seconds
Min float32 `protobuf:"fixed32,3,opt,name=min,proto3" json:"min,omitempty"` // minimum seconds
Max float32 `protobuf:"fixed32,4,opt,name=max,proto3" json:"max,omitempty"` // maximum seconds
// contains filtered or unexported fields
}
func (*Accum) Descriptor
deprecated
func (*Accum) ProtoMessage ¶
func (*Accum) ProtoMessage()
func (*Accum) ProtoReflect ¶
func (x *Accum) ProtoReflect() protoreflect.Message
type Ack ¶
type Ack struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
// contains filtered or unexported fields
}
func (*Ack) Descriptor
deprecated
func (*Ack) GetSuccess ¶
func (*Ack) ProtoMessage ¶
func (*Ack) ProtoMessage()
func (*Ack) ProtoReflect ¶
func (x *Ack) ProtoReflect() protoreflect.Message
type Certificate ¶
type Certificate struct {
Pem string `protobuf:"bytes,1,opt,name=pem,proto3" json:"pem,omitempty"`
// contains filtered or unexported fields
}
func (*Certificate) Descriptor
deprecated
func (*Certificate) Descriptor() ([]byte, []int)
Deprecated: Use Certificate.ProtoReflect.Descriptor instead.
func (*Certificate) GetPem ¶
func (x *Certificate) GetPem() string
func (*Certificate) ProtoMessage ¶
func (*Certificate) ProtoMessage()
func (*Certificate) ProtoReflect ¶
func (x *Certificate) ProtoReflect() protoreflect.Message
func (*Certificate) Reset ¶
func (x *Certificate) Reset()
func (*Certificate) String ¶
func (x *Certificate) String() string
type ChangePasswordRequest ¶
type ChangePasswordRequest struct {
Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
OldPassword string `protobuf:"bytes,2,opt,name=old_password,json=oldPassword,proto3" json:"old_password,omitempty"`
NewPassword string `protobuf:"bytes,3,opt,name=new_password,json=newPassword,proto3" json:"new_password,omitempty"`
// contains filtered or unexported fields
}
func (*ChangePasswordRequest) Descriptor
deprecated
func (*ChangePasswordRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangePasswordRequest.ProtoReflect.Descriptor instead.
func (*ChangePasswordRequest) GetNewPassword ¶
func (x *ChangePasswordRequest) GetNewPassword() string
func (*ChangePasswordRequest) GetOldPassword ¶
func (x *ChangePasswordRequest) GetOldPassword() string
func (*ChangePasswordRequest) GetUsername ¶
func (x *ChangePasswordRequest) GetUsername() string
func (*ChangePasswordRequest) ProtoMessage ¶
func (*ChangePasswordRequest) ProtoMessage()
func (*ChangePasswordRequest) ProtoReflect ¶
func (x *ChangePasswordRequest) ProtoReflect() protoreflect.Message
func (*ChangePasswordRequest) Reset ¶
func (x *ChangePasswordRequest) Reset()
func (*ChangePasswordRequest) String ¶
func (x *ChangePasswordRequest) String() string
type CreateUserRequest ¶
type CreateUserRequest struct {
Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
Email string `protobuf:"bytes,3,opt,name=email,proto3" json:"email,omitempty"`
IsAdmin bool `protobuf:"varint,4,opt,name=is_admin,json=isAdmin,proto3" json:"is_admin,omitempty"`
// contains filtered or unexported fields
}
func (*CreateUserRequest) Descriptor
deprecated
func (*CreateUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateUserRequest.ProtoReflect.Descriptor instead.
func (*CreateUserRequest) GetEmail ¶
func (x *CreateUserRequest) GetEmail() string
func (*CreateUserRequest) GetIsAdmin ¶
func (x *CreateUserRequest) GetIsAdmin() bool
func (*CreateUserRequest) GetPassword ¶
func (x *CreateUserRequest) GetPassword() string
func (*CreateUserRequest) GetUsername ¶
func (x *CreateUserRequest) GetUsername() string
func (*CreateUserRequest) ProtoMessage ¶
func (*CreateUserRequest) ProtoMessage()
func (*CreateUserRequest) ProtoReflect ¶
func (x *CreateUserRequest) ProtoReflect() protoreflect.Message
func (*CreateUserRequest) Reset ¶
func (x *CreateUserRequest) Reset()
func (*CreateUserRequest) String ¶
func (x *CreateUserRequest) String() string
type DebugAssignRequest ¶
type DebugAssignRequest struct {
WorkflowId int32 `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
TaskId int32 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
// contains filtered or unexported fields
}
func (*DebugAssignRequest) Descriptor
deprecated
func (*DebugAssignRequest) Descriptor() ([]byte, []int)
Deprecated: Use DebugAssignRequest.ProtoReflect.Descriptor instead.
func (*DebugAssignRequest) GetTaskId ¶
func (x *DebugAssignRequest) GetTaskId() int32
func (*DebugAssignRequest) GetWorkflowId ¶
func (x *DebugAssignRequest) GetWorkflowId() int32
func (*DebugAssignRequest) ProtoMessage ¶
func (*DebugAssignRequest) ProtoMessage()
func (*DebugAssignRequest) ProtoReflect ¶
func (x *DebugAssignRequest) ProtoReflect() protoreflect.Message
func (*DebugAssignRequest) Reset ¶
func (x *DebugAssignRequest) Reset()
func (*DebugAssignRequest) String ¶
func (x *DebugAssignRequest) String() string
type DebugRecruitRequest ¶
type DebugRecruitRequest struct {
WorkflowId int32 `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
StepId int32 `protobuf:"varint,2,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
// contains filtered or unexported fields
}
func (*DebugRecruitRequest) Descriptor
deprecated
func (*DebugRecruitRequest) Descriptor() ([]byte, []int)
Deprecated: Use DebugRecruitRequest.ProtoReflect.Descriptor instead.
func (*DebugRecruitRequest) GetStepId ¶
func (x *DebugRecruitRequest) GetStepId() int32
func (*DebugRecruitRequest) GetWorkflowId ¶
func (x *DebugRecruitRequest) GetWorkflowId() int32
func (*DebugRecruitRequest) ProtoMessage ¶
func (*DebugRecruitRequest) ProtoMessage()
func (*DebugRecruitRequest) ProtoReflect ¶
func (x *DebugRecruitRequest) ProtoReflect() protoreflect.Message
func (*DebugRecruitRequest) Reset ¶
func (x *DebugRecruitRequest) Reset()
func (*DebugRecruitRequest) String ¶
func (x *DebugRecruitRequest) String() string
type DeleteTemplateRunRequest ¶
type DeleteTemplateRunRequest struct {
TemplateRunId int32 `protobuf:"varint,1,opt,name=template_run_id,json=templateRunId,proto3" json:"template_run_id,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteTemplateRunRequest) Descriptor
deprecated
func (*DeleteTemplateRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteTemplateRunRequest.ProtoReflect.Descriptor instead.
func (*DeleteTemplateRunRequest) GetTemplateRunId ¶
func (x *DeleteTemplateRunRequest) GetTemplateRunId() int32
func (*DeleteTemplateRunRequest) ProtoMessage ¶
func (*DeleteTemplateRunRequest) ProtoMessage()
func (*DeleteTemplateRunRequest) ProtoReflect ¶
func (x *DeleteTemplateRunRequest) ProtoReflect() protoreflect.Message
func (*DeleteTemplateRunRequest) Reset ¶
func (x *DeleteTemplateRunRequest) Reset()
func (*DeleteTemplateRunRequest) String ¶
func (x *DeleteTemplateRunRequest) String() string
type DiskIOStats ¶
type DiskIOStats struct {
ReadBytesTotal int64 `protobuf:"varint,1,opt,name=read_bytes_total,json=readBytesTotal,proto3" json:"read_bytes_total,omitempty"` // Total bytes read
WriteBytesTotal int64 `protobuf:"varint,2,opt,name=write_bytes_total,json=writeBytesTotal,proto3" json:"write_bytes_total,omitempty"` // Total bytes written
ReadBytesRate float32 `protobuf:"fixed32,3,opt,name=read_bytes_rate,json=readBytesRate,proto3" json:"read_bytes_rate,omitempty"` // Bytes per second
WriteBytesRate float32 `protobuf:"fixed32,4,opt,name=write_bytes_rate,json=writeBytesRate,proto3" json:"write_bytes_rate,omitempty"` // Bytes per second
// contains filtered or unexported fields
}
func (*DiskIOStats) Descriptor
deprecated
func (*DiskIOStats) Descriptor() ([]byte, []int)
Deprecated: Use DiskIOStats.ProtoReflect.Descriptor instead.
func (*DiskIOStats) GetReadBytesRate ¶
func (x *DiskIOStats) GetReadBytesRate() float32
func (*DiskIOStats) GetReadBytesTotal ¶
func (x *DiskIOStats) GetReadBytesTotal() int64
func (*DiskIOStats) GetWriteBytesRate ¶
func (x *DiskIOStats) GetWriteBytesRate() float32
func (*DiskIOStats) GetWriteBytesTotal ¶
func (x *DiskIOStats) GetWriteBytesTotal() int64
func (*DiskIOStats) ProtoMessage ¶
func (*DiskIOStats) ProtoMessage()
func (*DiskIOStats) ProtoReflect ¶
func (x *DiskIOStats) ProtoReflect() protoreflect.Message
func (*DiskIOStats) Reset ¶
func (x *DiskIOStats) Reset()
func (*DiskIOStats) String ¶
func (x *DiskIOStats) String() string
type DiskUsage ¶
type DiskUsage struct {
DeviceName string `protobuf:"bytes,1,opt,name=device_name,json=deviceName,proto3" json:"device_name,omitempty"` // E.g., "/dev/sda1"
UsagePercent float32 `protobuf:"fixed32,2,opt,name=usage_percent,json=usagePercent,proto3" json:"usage_percent,omitempty"` // 0-100, float
// contains filtered or unexported fields
}
func (*DiskUsage) Descriptor
deprecated
func (*DiskUsage) GetDeviceName ¶
func (*DiskUsage) GetUsagePercent ¶
func (*DiskUsage) ProtoMessage ¶
func (*DiskUsage) ProtoMessage()
func (*DiskUsage) ProtoReflect ¶
func (x *DiskUsage) ProtoReflect() protoreflect.Message
type DockerCredential ¶
type DockerCredential struct {
Registry string `protobuf:"bytes,1,opt,name=registry,proto3" json:"registry,omitempty"` // e.g., "3jfz1gy8.gra7.container-registry.ovh.net"
Auth string `protobuf:"bytes,2,opt,name=auth,proto3" json:"auth,omitempty"` // auth string as found in .docker/config.json
// contains filtered or unexported fields
}
func (*DockerCredential) Descriptor
deprecated
func (*DockerCredential) Descriptor() ([]byte, []int)
Deprecated: Use DockerCredential.ProtoReflect.Descriptor instead.
func (*DockerCredential) GetAuth ¶
func (x *DockerCredential) GetAuth() string
func (*DockerCredential) GetRegistry ¶
func (x *DockerCredential) GetRegistry() string
func (*DockerCredential) ProtoMessage ¶
func (*DockerCredential) ProtoMessage()
func (*DockerCredential) ProtoReflect ¶
func (x *DockerCredential) ProtoReflect() protoreflect.Message
func (*DockerCredential) Reset ¶
func (x *DockerCredential) Reset()
func (*DockerCredential) String ¶
func (x *DockerCredential) String() string
type DockerCredentials ¶
type DockerCredentials struct {
Credentials []*DockerCredential `protobuf:"bytes,1,rep,name=credentials,proto3" json:"credentials,omitempty"`
// contains filtered or unexported fields
}
func (*DockerCredentials) Descriptor
deprecated
func (*DockerCredentials) Descriptor() ([]byte, []int)
Deprecated: Use DockerCredentials.ProtoReflect.Descriptor instead.
func (*DockerCredentials) GetCredentials ¶
func (x *DockerCredentials) GetCredentials() []*DockerCredential
func (*DockerCredentials) ProtoMessage ¶
func (*DockerCredentials) ProtoMessage()
func (*DockerCredentials) ProtoReflect ¶
func (x *DockerCredentials) ProtoReflect() protoreflect.Message
func (*DockerCredentials) Reset ¶
func (x *DockerCredentials) Reset()
func (*DockerCredentials) String ¶
func (x *DockerCredentials) String() string
type FetchInfoResponse ¶
type FetchInfoResponse struct {
Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
Filename string `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`
Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
Size int64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
IsFile bool `protobuf:"varint,5,opt,name=is_file,json=isFile,proto3" json:"is_file,omitempty"`
IsDir bool `protobuf:"varint,6,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
// contains filtered or unexported fields
}
func (*FetchInfoResponse) Descriptor
deprecated
func (*FetchInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchInfoResponse.ProtoReflect.Descriptor instead.
func (*FetchInfoResponse) GetDescription ¶
func (x *FetchInfoResponse) GetDescription() string
func (*FetchInfoResponse) GetFilename ¶
func (x *FetchInfoResponse) GetFilename() string
func (*FetchInfoResponse) GetIsDir ¶
func (x *FetchInfoResponse) GetIsDir() bool
func (*FetchInfoResponse) GetIsFile ¶
func (x *FetchInfoResponse) GetIsFile() bool
func (*FetchInfoResponse) GetSize ¶
func (x *FetchInfoResponse) GetSize() int64
func (*FetchInfoResponse) GetUri ¶
func (x *FetchInfoResponse) GetUri() string
func (*FetchInfoResponse) ProtoMessage ¶
func (*FetchInfoResponse) ProtoMessage()
func (*FetchInfoResponse) ProtoReflect ¶
func (x *FetchInfoResponse) ProtoReflect() protoreflect.Message
func (*FetchInfoResponse) Reset ¶
func (x *FetchInfoResponse) Reset()
func (*FetchInfoResponse) String ¶
func (x *FetchInfoResponse) String() string
type FetchListRequest ¶
type FetchListRequest struct {
Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"` // URI to fetch the list from (can include glob patterns)
// contains filtered or unexported fields
}
func (*FetchListRequest) Descriptor
deprecated
func (*FetchListRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchListRequest.ProtoReflect.Descriptor instead.
func (*FetchListRequest) GetUri ¶
func (x *FetchListRequest) GetUri() string
func (*FetchListRequest) ProtoMessage ¶
func (*FetchListRequest) ProtoMessage()
func (*FetchListRequest) ProtoReflect ¶
func (x *FetchListRequest) ProtoReflect() protoreflect.Message
func (*FetchListRequest) Reset ¶
func (x *FetchListRequest) Reset()
func (*FetchListRequest) String ¶
func (x *FetchListRequest) String() string
type FetchListResponse ¶
type FetchListResponse struct {
Files []string `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"` // Absolute paths from the given URI
// contains filtered or unexported fields
}
func (*FetchListResponse) Descriptor
deprecated
func (*FetchListResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchListResponse.ProtoReflect.Descriptor instead.
func (*FetchListResponse) GetFiles ¶
func (x *FetchListResponse) GetFiles() []string
func (*FetchListResponse) ProtoMessage ¶
func (*FetchListResponse) ProtoMessage()
func (*FetchListResponse) ProtoReflect ¶
func (x *FetchListResponse) ProtoReflect() protoreflect.Message
func (*FetchListResponse) Reset ¶
func (x *FetchListResponse) Reset()
func (*FetchListResponse) String ¶
func (x *FetchListResponse) String() string
type Flavor ¶
type Flavor struct {
// Fields from the "flavor" table
FlavorId int32 `protobuf:"varint,1,opt,name=flavor_id,json=flavorId,proto3" json:"flavor_id,omitempty"` // PRIMARY KEY
FlavorName string `protobuf:"bytes,2,opt,name=flavor_name,json=flavorName,proto3" json:"flavor_name,omitempty"` // Name of the flavor
ProviderId int32 `protobuf:"varint,3,opt,name=provider_id,json=providerId,proto3" json:"provider_id,omitempty"` // Foreign key to provider table
Provider string `protobuf:"bytes,4,opt,name=provider,proto3" json:"provider,omitempty"` // Name of the provider (provider_name.config_name)
Cpu int32 `protobuf:"varint,5,opt,name=cpu,proto3" json:"cpu,omitempty"` // Number of CPU cores
Mem float32 `protobuf:"fixed32,6,opt,name=mem,proto3" json:"mem,omitempty"` // Memory in GB (or as needed)
Disk float32 `protobuf:"fixed32,7,opt,name=disk,proto3" json:"disk,omitempty"` // Disk size in GB (or as needed)
Bandwidth int32 `protobuf:"varint,8,opt,name=bandwidth,proto3" json:"bandwidth,omitempty"` // Bandwidth (if applicable)
Gpu string `protobuf:"bytes,9,opt,name=gpu,proto3" json:"gpu,omitempty"` // GPU description
Gpumem int32 `protobuf:"varint,10,opt,name=gpumem,proto3" json:"gpumem,omitempty"` // GPU memory (in GB, for example)
HasGpu bool `protobuf:"varint,11,opt,name=has_gpu,json=hasGpu,proto3" json:"has_gpu,omitempty"` // Whether a GPU is present
HasQuickDisks bool `protobuf:"varint,12,opt,name=has_quick_disks,json=hasQuickDisks,proto3" json:"has_quick_disks,omitempty"` // Whether quick disks are supported
// Fields from the "flavor_region" table
RegionId int32 `protobuf:"varint,13,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"` // Foreign key to region table
Region string `protobuf:"bytes,14,opt,name=region,proto3" json:"region,omitempty"` // (Optional) Region name
Eviction float32 `protobuf:"fixed32,15,opt,name=eviction,proto3" json:"eviction,omitempty"` // Eviction rate value
Cost float32 `protobuf:"fixed32,16,opt,name=cost,proto3" json:"cost,omitempty"` // Cost value
// contains filtered or unexported fields
}
func (*Flavor) Descriptor
deprecated
func (*Flavor) GetBandwidth ¶
func (*Flavor) GetEviction ¶
func (*Flavor) GetFlavorId ¶
func (*Flavor) GetFlavorName ¶
func (*Flavor) GetHasQuickDisks ¶
func (*Flavor) GetProvider ¶
func (*Flavor) GetProviderId ¶
func (*Flavor) GetRegionId ¶
func (*Flavor) ProtoMessage ¶
func (*Flavor) ProtoMessage()
func (*Flavor) ProtoReflect ¶
func (x *Flavor) ProtoReflect() protoreflect.Message
type FlavorCreateRequest ¶
type FlavorCreateRequest struct {
ProviderName string `protobuf:"bytes,1,opt,name=provider_name,json=providerName,proto3" json:"provider_name,omitempty"`
ConfigName string `protobuf:"bytes,2,opt,name=config_name,json=configName,proto3" json:"config_name,omitempty"`
FlavorName string `protobuf:"bytes,3,opt,name=flavor_name,json=flavorName,proto3" json:"flavor_name,omitempty"`
Cpu int32 `protobuf:"varint,4,opt,name=cpu,proto3" json:"cpu,omitempty"`
Memory float32 `protobuf:"fixed32,5,opt,name=memory,proto3" json:"memory,omitempty"`
Disk float32 `protobuf:"fixed32,6,opt,name=disk,proto3" json:"disk,omitempty"`
Bandwidth *int32 `protobuf:"varint,7,opt,name=bandwidth,proto3,oneof" json:"bandwidth,omitempty"`
Gpu *string `protobuf:"bytes,8,opt,name=gpu,proto3,oneof" json:"gpu,omitempty"`
Gpumem *int32 `protobuf:"varint,9,opt,name=gpumem,proto3,oneof" json:"gpumem,omitempty"`
HasGpu *bool `protobuf:"varint,10,opt,name=has_gpu,json=hasGpu,proto3,oneof" json:"has_gpu,omitempty"`
HasQuickDisks *bool `protobuf:"varint,11,opt,name=has_quick_disks,json=hasQuickDisks,proto3,oneof" json:"has_quick_disks,omitempty"`
RegionNames []string `protobuf:"bytes,12,rep,name=region_names,json=regionNames,proto3" json:"region_names,omitempty"`
Costs []float32 `protobuf:"fixed32,13,rep,packed,name=costs,proto3" json:"costs,omitempty"`
Evictions []float32 `protobuf:"fixed32,14,rep,packed,name=evictions,proto3" json:"evictions,omitempty"`
// contains filtered or unexported fields
}
func (*FlavorCreateRequest) Descriptor
deprecated
func (*FlavorCreateRequest) Descriptor() ([]byte, []int)
Deprecated: Use FlavorCreateRequest.ProtoReflect.Descriptor instead.
func (*FlavorCreateRequest) GetBandwidth ¶
func (x *FlavorCreateRequest) GetBandwidth() int32
func (*FlavorCreateRequest) GetConfigName ¶
func (x *FlavorCreateRequest) GetConfigName() string
func (*FlavorCreateRequest) GetCosts ¶
func (x *FlavorCreateRequest) GetCosts() []float32
func (*FlavorCreateRequest) GetCpu ¶
func (x *FlavorCreateRequest) GetCpu() int32
func (*FlavorCreateRequest) GetDisk ¶
func (x *FlavorCreateRequest) GetDisk() float32
func (*FlavorCreateRequest) GetEvictions ¶
func (x *FlavorCreateRequest) GetEvictions() []float32
func (*FlavorCreateRequest) GetFlavorName ¶
func (x *FlavorCreateRequest) GetFlavorName() string
func (*FlavorCreateRequest) GetGpu ¶
func (x *FlavorCreateRequest) GetGpu() string
func (*FlavorCreateRequest) GetGpumem ¶
func (x *FlavorCreateRequest) GetGpumem() int32
func (*FlavorCreateRequest) GetHasGpu ¶
func (x *FlavorCreateRequest) GetHasGpu() bool
func (*FlavorCreateRequest) GetHasQuickDisks ¶
func (x *FlavorCreateRequest) GetHasQuickDisks() bool
func (*FlavorCreateRequest) GetMemory ¶
func (x *FlavorCreateRequest) GetMemory() float32
func (*FlavorCreateRequest) GetProviderName ¶
func (x *FlavorCreateRequest) GetProviderName() string
func (*FlavorCreateRequest) GetRegionNames ¶
func (x *FlavorCreateRequest) GetRegionNames() []string
func (*FlavorCreateRequest) ProtoMessage ¶
func (*FlavorCreateRequest) ProtoMessage()
func (*FlavorCreateRequest) ProtoReflect ¶
func (x *FlavorCreateRequest) ProtoReflect() protoreflect.Message
func (*FlavorCreateRequest) Reset ¶
func (x *FlavorCreateRequest) Reset()
func (*FlavorCreateRequest) String ¶
func (x *FlavorCreateRequest) String() string
type FlavorId ¶
type FlavorId struct {
FlavorId int32 `protobuf:"varint,1,opt,name=flavor_id,json=flavorId,proto3" json:"flavor_id,omitempty"`
// contains filtered or unexported fields
}
func (*FlavorId) Descriptor
deprecated
func (*FlavorId) GetFlavorId ¶
func (*FlavorId) ProtoMessage ¶
func (*FlavorId) ProtoMessage()
func (*FlavorId) ProtoReflect ¶
func (x *FlavorId) ProtoReflect() protoreflect.Message
type FlavorsList ¶
type FlavorsList struct {
Flavors []*Flavor `protobuf:"bytes,1,rep,name=flavors,proto3" json:"flavors,omitempty"`
// contains filtered or unexported fields
}
func (*FlavorsList) Descriptor
deprecated
func (*FlavorsList) Descriptor() ([]byte, []int)
Deprecated: Use FlavorsList.ProtoReflect.Descriptor instead.
func (*FlavorsList) GetFlavors ¶
func (x *FlavorsList) GetFlavors() []*Flavor
func (*FlavorsList) ProtoMessage ¶
func (*FlavorsList) ProtoMessage()
func (*FlavorsList) ProtoReflect ¶
func (x *FlavorsList) ProtoReflect() protoreflect.Message
func (*FlavorsList) Reset ¶
func (x *FlavorsList) Reset()
func (*FlavorsList) String ¶
func (x *FlavorsList) String() string
type GetLogsRequest ¶
type GetLogsRequest struct {
TaskIds []int32 `protobuf:"varint,1,rep,packed,name=taskIds,proto3" json:"taskIds,omitempty"`
ChunkSize int32 `protobuf:"varint,2,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"`
SkipFromEnd *int32 `protobuf:"varint,3,opt,name=skipFromEnd,proto3,oneof" json:"skipFromEnd,omitempty"`
LogType *string `protobuf:"bytes,4,opt,name=log_type,json=logType,proto3,oneof" json:"log_type,omitempty"`
// contains filtered or unexported fields
}
func (*GetLogsRequest) Descriptor
deprecated
func (*GetLogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLogsRequest.ProtoReflect.Descriptor instead.
func (*GetLogsRequest) GetChunkSize ¶
func (x *GetLogsRequest) GetChunkSize() int32
func (*GetLogsRequest) GetLogType ¶
func (x *GetLogsRequest) GetLogType() string
func (*GetLogsRequest) GetSkipFromEnd ¶
func (x *GetLogsRequest) GetSkipFromEnd() int32
func (*GetLogsRequest) GetTaskIds ¶
func (x *GetLogsRequest) GetTaskIds() []int32
func (*GetLogsRequest) ProtoMessage ¶
func (*GetLogsRequest) ProtoMessage()
func (*GetLogsRequest) ProtoReflect ¶
func (x *GetLogsRequest) ProtoReflect() protoreflect.Message
func (*GetLogsRequest) Reset ¶
func (x *GetLogsRequest) Reset()
func (*GetLogsRequest) String ¶
func (x *GetLogsRequest) String() string
type GetWorkerStatsRequest ¶
type GetWorkerStatsRequest struct {
WorkerIds []int32 `protobuf:"varint,1,rep,packed,name=worker_ids,json=workerIds,proto3" json:"worker_ids,omitempty"`
// contains filtered or unexported fields
}
func (*GetWorkerStatsRequest) Descriptor
deprecated
func (*GetWorkerStatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkerStatsRequest.ProtoReflect.Descriptor instead.
func (*GetWorkerStatsRequest) GetWorkerIds ¶
func (x *GetWorkerStatsRequest) GetWorkerIds() []int32
func (*GetWorkerStatsRequest) ProtoMessage ¶
func (*GetWorkerStatsRequest) ProtoMessage()
func (*GetWorkerStatsRequest) ProtoReflect ¶
func (x *GetWorkerStatsRequest) ProtoReflect() protoreflect.Message
func (*GetWorkerStatsRequest) Reset ¶
func (x *GetWorkerStatsRequest) Reset()
func (*GetWorkerStatsRequest) String ¶
func (x *GetWorkerStatsRequest) String() string
type GetWorkerStatsResponse ¶
type GetWorkerStatsResponse struct {
WorkerStats map[int32]*WorkerStats `` /* 169-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GetWorkerStatsResponse) Descriptor
deprecated
func (*GetWorkerStatsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkerStatsResponse.ProtoReflect.Descriptor instead.
func (*GetWorkerStatsResponse) GetWorkerStats ¶
func (x *GetWorkerStatsResponse) GetWorkerStats() map[int32]*WorkerStats
func (*GetWorkerStatsResponse) ProtoMessage ¶
func (*GetWorkerStatsResponse) ProtoMessage()
func (*GetWorkerStatsResponse) ProtoReflect ¶
func (x *GetWorkerStatsResponse) ProtoReflect() protoreflect.Message
func (*GetWorkerStatsResponse) Reset ¶
func (x *GetWorkerStatsResponse) Reset()
func (*GetWorkerStatsResponse) String ¶
func (x *GetWorkerStatsResponse) String() string
type Job ¶
type Job struct {
JobId int32 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
FlavorId int32 `protobuf:"varint,3,opt,name=flavor_id,json=flavorId,proto3" json:"flavor_id,omitempty"`
Retry int32 `protobuf:"varint,4,opt,name=retry,proto3" json:"retry,omitempty"`
WorkerId int32 `protobuf:"varint,5,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
Action string `protobuf:"bytes,6,opt,name=action,proto3" json:"action,omitempty"`
CreatedAt string `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
ModifiedAt string `protobuf:"bytes,8,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
Progression int32 `protobuf:"varint,9,opt,name=progression,proto3" json:"progression,omitempty"`
Log string `protobuf:"bytes,10,opt,name=log,proto3" json:"log,omitempty"`
// contains filtered or unexported fields
}
func (*Job) Descriptor
deprecated
func (*Job) GetCreatedAt ¶
func (*Job) GetFlavorId ¶
func (*Job) GetModifiedAt ¶
func (*Job) GetProgression ¶
func (*Job) GetWorkerId ¶
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) ProtoReflect ¶
func (x *Job) ProtoReflect() protoreflect.Message
type JobId ¶
type JobId struct {
JobId int32 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
// contains filtered or unexported fields
}
func (*JobId) Descriptor
deprecated
func (*JobId) ProtoMessage ¶
func (*JobId) ProtoMessage()
func (*JobId) ProtoReflect ¶
func (x *JobId) ProtoReflect() protoreflect.Message
type JobStatus ¶
type JobStatus struct {
JobId int32 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
Progression int32 `protobuf:"varint,3,opt,name=progression,proto3" json:"progression,omitempty"`
// contains filtered or unexported fields
}
func (*JobStatus) Descriptor
deprecated
func (*JobStatus) GetProgression ¶
func (*JobStatus) ProtoMessage ¶
func (*JobStatus) ProtoMessage()
func (*JobStatus) ProtoReflect ¶
func (x *JobStatus) ProtoReflect() protoreflect.Message
type JobStatusRequest ¶
type JobStatusRequest struct {
JobIds []int32 `protobuf:"varint,1,rep,packed,name=job_ids,json=jobIds,proto3" json:"job_ids,omitempty"`
// contains filtered or unexported fields
}
func (*JobStatusRequest) Descriptor
deprecated
func (*JobStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use JobStatusRequest.ProtoReflect.Descriptor instead.
func (*JobStatusRequest) GetJobIds ¶
func (x *JobStatusRequest) GetJobIds() []int32
func (*JobStatusRequest) ProtoMessage ¶
func (*JobStatusRequest) ProtoMessage()
func (*JobStatusRequest) ProtoReflect ¶
func (x *JobStatusRequest) ProtoReflect() protoreflect.Message
func (*JobStatusRequest) Reset ¶
func (x *JobStatusRequest) Reset()
func (*JobStatusRequest) String ¶
func (x *JobStatusRequest) String() string
type JobStatusResponse ¶
type JobStatusResponse struct {
Statuses []*JobStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
// contains filtered or unexported fields
}
func (*JobStatusResponse) Descriptor
deprecated
func (*JobStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use JobStatusResponse.ProtoReflect.Descriptor instead.
func (*JobStatusResponse) GetStatuses ¶
func (x *JobStatusResponse) GetStatuses() []*JobStatus
func (*JobStatusResponse) ProtoMessage ¶
func (*JobStatusResponse) ProtoMessage()
func (*JobStatusResponse) ProtoReflect ¶
func (x *JobStatusResponse) ProtoReflect() protoreflect.Message
func (*JobStatusResponse) Reset ¶
func (x *JobStatusResponse) Reset()
func (*JobStatusResponse) String ¶
func (x *JobStatusResponse) String() string
type JobUpdate ¶
type JobUpdate struct {
JobId int32 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // which job to update
Status *string `protobuf:"bytes,2,opt,name=status,proto3,oneof" json:"status,omitempty"` // 'P'|'R'|'S'|'F'|'X' (only if you want to set it)
AppendLog *string `protobuf:"bytes,3,opt,name=append_log,json=appendLog,proto3,oneof" json:"append_log,omitempty"` // text appended to job.log (server prepends timestamp)
Progression *int32 `protobuf:"varint,4,opt,name=progression,proto3,oneof" json:"progression,omitempty"` // 0..100 (server clamps)
// contains filtered or unexported fields
}
func (*JobUpdate) Descriptor
deprecated
func (*JobUpdate) GetAppendLog ¶
func (*JobUpdate) GetProgression ¶
func (*JobUpdate) ProtoMessage ¶
func (*JobUpdate) ProtoMessage()
func (*JobUpdate) ProtoReflect ¶
func (x *JobUpdate) ProtoReflect() protoreflect.Message
type JobsList ¶
type JobsList struct {
Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
// contains filtered or unexported fields
}
func (*JobsList) Descriptor
deprecated
func (*JobsList) ProtoMessage ¶
func (*JobsList) ProtoMessage()
func (*JobsList) ProtoReflect ¶
func (x *JobsList) ProtoReflect() protoreflect.Message
type ListFlavorsRequest ¶
type ListFlavorsRequest struct {
Limit int32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
// contains filtered or unexported fields
}
func (*ListFlavorsRequest) Descriptor
deprecated
func (*ListFlavorsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListFlavorsRequest.ProtoReflect.Descriptor instead.
func (*ListFlavorsRequest) GetFilter ¶
func (x *ListFlavorsRequest) GetFilter() string
func (*ListFlavorsRequest) GetLimit ¶
func (x *ListFlavorsRequest) GetLimit() int32
func (*ListFlavorsRequest) ProtoMessage ¶
func (*ListFlavorsRequest) ProtoMessage()
func (*ListFlavorsRequest) ProtoReflect ¶
func (x *ListFlavorsRequest) ProtoReflect() protoreflect.Message
func (*ListFlavorsRequest) Reset ¶
func (x *ListFlavorsRequest) Reset()
func (*ListFlavorsRequest) String ¶
func (x *ListFlavorsRequest) String() string
type ListJobsRequest ¶
type ListJobsRequest struct {
Limit *int32 `protobuf:"varint,1,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
Offset *int32 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
// contains filtered or unexported fields
}
func (*ListJobsRequest) Descriptor
deprecated
func (*ListJobsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.
func (*ListJobsRequest) GetLimit ¶
func (x *ListJobsRequest) GetLimit() int32
func (*ListJobsRequest) GetOffset ¶
func (x *ListJobsRequest) GetOffset() int32
func (*ListJobsRequest) ProtoMessage ¶
func (*ListJobsRequest) ProtoMessage()
func (*ListJobsRequest) ProtoReflect ¶
func (x *ListJobsRequest) ProtoReflect() protoreflect.Message
func (*ListJobsRequest) Reset ¶
func (x *ListJobsRequest) Reset()
func (*ListJobsRequest) String ¶
func (x *ListJobsRequest) String() string
type ListTasksRequest ¶
type ListTasksRequest struct {
StatusFilter *string `protobuf:"bytes,1,opt,name=status_filter,json=statusFilter,proto3,oneof" json:"status_filter,omitempty"`
WorkerIdFilter *int32 `protobuf:"varint,2,opt,name=worker_id_filter,json=workerIdFilter,proto3,oneof" json:"worker_id_filter,omitempty"`
WorkflowIdFilter *int32 `protobuf:"varint,3,opt,name=workflow_id_filter,json=workflowIdFilter,proto3,oneof" json:"workflow_id_filter,omitempty"`
StepIdFilter *int32 `protobuf:"varint,4,opt,name=step_id_filter,json=stepIdFilter,proto3,oneof" json:"step_id_filter,omitempty"`
CommandFilter *string `protobuf:"bytes,5,opt,name=command_filter,json=commandFilter,proto3,oneof" json:"command_filter,omitempty"`
Limit *int32 `protobuf:"varint,6,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
Offset *int32 `protobuf:"varint,7,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
ShowHidden *bool `protobuf:"varint,8,opt,name=show_hidden,json=showHidden,proto3,oneof" json:"show_hidden,omitempty"`
// contains filtered or unexported fields
}
func (*ListTasksRequest) Descriptor
deprecated
func (*ListTasksRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.
func (*ListTasksRequest) GetCommandFilter ¶
func (x *ListTasksRequest) GetCommandFilter() string
func (*ListTasksRequest) GetLimit ¶
func (x *ListTasksRequest) GetLimit() int32
func (*ListTasksRequest) GetOffset ¶
func (x *ListTasksRequest) GetOffset() int32
func (*ListTasksRequest) GetShowHidden ¶
func (x *ListTasksRequest) GetShowHidden() bool
func (*ListTasksRequest) GetStatusFilter ¶
func (x *ListTasksRequest) GetStatusFilter() string
func (*ListTasksRequest) GetStepIdFilter ¶
func (x *ListTasksRequest) GetStepIdFilter() int32
func (*ListTasksRequest) GetWorkerIdFilter ¶
func (x *ListTasksRequest) GetWorkerIdFilter() int32
func (*ListTasksRequest) GetWorkflowIdFilter ¶
func (x *ListTasksRequest) GetWorkflowIdFilter() int32
func (*ListTasksRequest) ProtoMessage ¶
func (*ListTasksRequest) ProtoMessage()
func (*ListTasksRequest) ProtoReflect ¶
func (x *ListTasksRequest) ProtoReflect() protoreflect.Message
func (*ListTasksRequest) Reset ¶
func (x *ListTasksRequest) Reset()
func (*ListTasksRequest) String ¶
func (x *ListTasksRequest) String() string
type ListWorkersRequest ¶
type ListWorkersRequest struct {
WorkflowId *int32 `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
// contains filtered or unexported fields
}
func (*ListWorkersRequest) Descriptor
deprecated
func (*ListWorkersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkersRequest.ProtoReflect.Descriptor instead.
func (*ListWorkersRequest) GetWorkflowId ¶
func (x *ListWorkersRequest) GetWorkflowId() int32
func (*ListWorkersRequest) ProtoMessage ¶
func (*ListWorkersRequest) ProtoMessage()
func (*ListWorkersRequest) ProtoReflect ¶
func (x *ListWorkersRequest) ProtoReflect() protoreflect.Message
func (*ListWorkersRequest) Reset ¶
func (x *ListWorkersRequest) Reset()
func (*ListWorkersRequest) String ¶
func (x *ListWorkersRequest) String() string
type LogChunk ¶
type LogChunk struct {
TaskId int32 `protobuf:"varint,1,opt,name=taskId,proto3" json:"taskId,omitempty"`
Stdout []string `protobuf:"bytes,2,rep,name=stdout,proto3" json:"stdout,omitempty"`
Stderr []string `protobuf:"bytes,3,rep,name=stderr,proto3" json:"stderr,omitempty"`
// contains filtered or unexported fields
}
func (*LogChunk) Descriptor
deprecated
func (*LogChunk) ProtoMessage ¶
func (*LogChunk) ProtoMessage()
func (*LogChunk) ProtoReflect ¶
func (x *LogChunk) ProtoReflect() protoreflect.Message
type LogChunkList ¶
type LogChunkList struct {
Logs []*LogChunk `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
// contains filtered or unexported fields
}
func (*LogChunkList) Descriptor
deprecated
func (*LogChunkList) Descriptor() ([]byte, []int)
Deprecated: Use LogChunkList.ProtoReflect.Descriptor instead.
func (*LogChunkList) GetLogs ¶
func (x *LogChunkList) GetLogs() []*LogChunk
func (*LogChunkList) ProtoMessage ¶
func (*LogChunkList) ProtoMessage()
func (*LogChunkList) ProtoReflect ¶
func (x *LogChunkList) ProtoReflect() protoreflect.Message
func (*LogChunkList) Reset ¶
func (x *LogChunkList) Reset()
func (*LogChunkList) String ¶
func (x *LogChunkList) String() string
type LoginRequest ¶
type LoginRequest struct {
Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
// contains filtered or unexported fields
}
func (*LoginRequest) Descriptor
deprecated
func (*LoginRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.
func (*LoginRequest) GetPassword ¶
func (x *LoginRequest) GetPassword() string
func (*LoginRequest) GetUsername ¶
func (x *LoginRequest) GetUsername() string
func (*LoginRequest) ProtoMessage ¶
func (*LoginRequest) ProtoMessage()
func (*LoginRequest) ProtoReflect ¶
func (x *LoginRequest) ProtoReflect() protoreflect.Message
func (*LoginRequest) Reset ¶
func (x *LoginRequest) Reset()
func (*LoginRequest) String ¶
func (x *LoginRequest) String() string
type LoginResponse ¶
type LoginResponse struct {
Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
// contains filtered or unexported fields
}
func (*LoginResponse) Descriptor
deprecated
func (*LoginResponse) Descriptor() ([]byte, []int)
Deprecated: Use LoginResponse.ProtoReflect.Descriptor instead.
func (*LoginResponse) GetToken ¶
func (x *LoginResponse) GetToken() string
func (*LoginResponse) ProtoMessage ¶
func (*LoginResponse) ProtoMessage()
func (*LoginResponse) ProtoReflect ¶
func (x *LoginResponse) ProtoReflect() protoreflect.Message
func (*LoginResponse) Reset ¶
func (x *LoginResponse) Reset()
func (*LoginResponse) String ¶
func (x *LoginResponse) String() string
type NetIOStats ¶
type NetIOStats struct {
RecvBytesTotal int64 `protobuf:"varint,1,opt,name=recv_bytes_total,json=recvBytesTotal,proto3" json:"recv_bytes_total,omitempty"` // Total bytes received
SentBytesTotal int64 `protobuf:"varint,2,opt,name=sent_bytes_total,json=sentBytesTotal,proto3" json:"sent_bytes_total,omitempty"` // Total bytes sent
RecvBytesRate float32 `protobuf:"fixed32,3,opt,name=recv_bytes_rate,json=recvBytesRate,proto3" json:"recv_bytes_rate,omitempty"` // Bytes per second
SentBytesRate float32 `protobuf:"fixed32,4,opt,name=sent_bytes_rate,json=sentBytesRate,proto3" json:"sent_bytes_rate,omitempty"` // Bytes per second
// contains filtered or unexported fields
}
func (*NetIOStats) Descriptor
deprecated
func (*NetIOStats) Descriptor() ([]byte, []int)
Deprecated: Use NetIOStats.ProtoReflect.Descriptor instead.
func (*NetIOStats) GetRecvBytesRate ¶
func (x *NetIOStats) GetRecvBytesRate() float32
func (*NetIOStats) GetRecvBytesTotal ¶
func (x *NetIOStats) GetRecvBytesTotal() int64
func (*NetIOStats) GetSentBytesRate ¶
func (x *NetIOStats) GetSentBytesRate() float32
func (*NetIOStats) GetSentBytesTotal ¶
func (x *NetIOStats) GetSentBytesTotal() int64
func (*NetIOStats) ProtoMessage ¶
func (*NetIOStats) ProtoMessage()
func (*NetIOStats) ProtoReflect ¶
func (x *NetIOStats) ProtoReflect() protoreflect.Message
func (*NetIOStats) Reset ¶
func (x *NetIOStats) Reset()
func (*NetIOStats) String ¶
func (x *NetIOStats) String() string
type PingAndGetNewTasksRequest ¶
type PingAndGetNewTasksRequest struct {
WorkerId int32 `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
Stats *WorkerStats `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"` // Optional
// contains filtered or unexported fields
}
func (*PingAndGetNewTasksRequest) Descriptor
deprecated
func (*PingAndGetNewTasksRequest) Descriptor() ([]byte, []int)
Deprecated: Use PingAndGetNewTasksRequest.ProtoReflect.Descriptor instead.
func (*PingAndGetNewTasksRequest) GetStats ¶
func (x *PingAndGetNewTasksRequest) GetStats() *WorkerStats
func (*PingAndGetNewTasksRequest) GetWorkerId ¶
func (x *PingAndGetNewTasksRequest) GetWorkerId() int32
func (*PingAndGetNewTasksRequest) ProtoMessage ¶
func (*PingAndGetNewTasksRequest) ProtoMessage()
func (*PingAndGetNewTasksRequest) ProtoReflect ¶
func (x *PingAndGetNewTasksRequest) ProtoReflect() protoreflect.Message
func (*PingAndGetNewTasksRequest) Reset ¶
func (x *PingAndGetNewTasksRequest) Reset()
func (*PingAndGetNewTasksRequest) String ¶
func (x *PingAndGetNewTasksRequest) String() string
type Provider ¶
type Provider struct {
ProviderId int32 `protobuf:"varint,1,opt,name=provider_id,json=providerId,proto3" json:"provider_id,omitempty"`
ProviderName string `protobuf:"bytes,2,opt,name=provider_name,json=providerName,proto3" json:"provider_name,omitempty"`
ConfigName string `protobuf:"bytes,3,opt,name=config_name,json=configName,proto3" json:"config_name,omitempty"`
// contains filtered or unexported fields
}
func (*Provider) Descriptor
deprecated
func (*Provider) GetConfigName ¶
func (*Provider) GetProviderId ¶
func (*Provider) GetProviderName ¶
func (*Provider) ProtoMessage ¶
func (*Provider) ProtoMessage()
func (*Provider) ProtoReflect ¶
func (x *Provider) ProtoReflect() protoreflect.Message
type ProviderList ¶
type ProviderList struct {
Providers []*Provider `protobuf:"bytes,1,rep,name=providers,proto3" json:"providers,omitempty"`
// contains filtered or unexported fields
}
func (*ProviderList) Descriptor
deprecated
func (*ProviderList) Descriptor() ([]byte, []int)
Deprecated: Use ProviderList.ProtoReflect.Descriptor instead.
func (*ProviderList) GetProviders ¶
func (x *ProviderList) GetProviders() []*Provider
func (*ProviderList) ProtoMessage ¶
func (*ProviderList) ProtoMessage()
func (*ProviderList) ProtoReflect ¶
func (x *ProviderList) ProtoReflect() protoreflect.Message
func (*ProviderList) Reset ¶
func (x *ProviderList) Reset()
func (*ProviderList) String ¶
func (x *ProviderList) String() string
type RcloneRemote ¶
type RcloneRemote struct {
Options map[string]string `` /* 141-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*RcloneRemote) Descriptor
deprecated
func (*RcloneRemote) Descriptor() ([]byte, []int)
Deprecated: Use RcloneRemote.ProtoReflect.Descriptor instead.
func (*RcloneRemote) GetOptions ¶
func (x *RcloneRemote) GetOptions() map[string]string
func (*RcloneRemote) ProtoMessage ¶
func (*RcloneRemote) ProtoMessage()
func (*RcloneRemote) ProtoReflect ¶
func (x *RcloneRemote) ProtoReflect() protoreflect.Message
func (*RcloneRemote) Reset ¶
func (x *RcloneRemote) Reset()
func (*RcloneRemote) String ¶
func (x *RcloneRemote) String() string
type RcloneRemotes ¶
type RcloneRemotes struct {
Remotes map[string]*RcloneRemote `` /* 141-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*RcloneRemotes) Descriptor
deprecated
func (*RcloneRemotes) Descriptor() ([]byte, []int)
Deprecated: Use RcloneRemotes.ProtoReflect.Descriptor instead.
func (*RcloneRemotes) GetRemotes ¶
func (x *RcloneRemotes) GetRemotes() map[string]*RcloneRemote
func (*RcloneRemotes) ProtoMessage ¶
func (*RcloneRemotes) ProtoMessage()
func (*RcloneRemotes) ProtoReflect ¶
func (x *RcloneRemotes) ProtoReflect() protoreflect.Message
func (*RcloneRemotes) Reset ¶
func (x *RcloneRemotes) Reset()
func (*RcloneRemotes) String ¶
func (x *RcloneRemotes) String() string
type Recruiter ¶
type Recruiter struct {
StepId int32 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
Rank int32 `protobuf:"varint,2,opt,name=rank,proto3" json:"rank,omitempty"`
Protofilter string `protobuf:"bytes,3,opt,name=protofilter,proto3" json:"protofilter,omitempty"`
Concurrency *int32 `protobuf:"varint,4,opt,name=concurrency,proto3,oneof" json:"concurrency,omitempty"`
Prefetch *int32 `protobuf:"varint,5,opt,name=prefetch,proto3,oneof" json:"prefetch,omitempty"`
MaxWorkers *int32 `protobuf:"varint,6,opt,name=max_workers,json=maxWorkers,proto3,oneof" json:"max_workers,omitempty"`
Rounds int32 `protobuf:"varint,7,opt,name=rounds,proto3" json:"rounds,omitempty"`
Timeout int32 `protobuf:"varint,8,opt,name=timeout,proto3" json:"timeout,omitempty"`
CpuPerTask *int32 `protobuf:"varint,9,opt,name=cpu_per_task,json=cpuPerTask,proto3,oneof" json:"cpu_per_task,omitempty"`
MemoryPerTask *float32 `protobuf:"fixed32,10,opt,name=memory_per_task,json=memoryPerTask,proto3,oneof" json:"memory_per_task,omitempty"`
DiskPerTask *float32 `protobuf:"fixed32,11,opt,name=disk_per_task,json=diskPerTask,proto3,oneof" json:"disk_per_task,omitempty"`
PrefetchPercent *int32 `protobuf:"varint,12,opt,name=prefetch_percent,json=prefetchPercent,proto3,oneof" json:"prefetch_percent,omitempty"`
ConcurrencyMin *int32 `protobuf:"varint,13,opt,name=concurrency_min,json=concurrencyMin,proto3,oneof" json:"concurrency_min,omitempty"`
ConcurrencyMax *int32 `protobuf:"varint,14,opt,name=concurrency_max,json=concurrencyMax,proto3,oneof" json:"concurrency_max,omitempty"`
// contains filtered or unexported fields
}
func (*Recruiter) Descriptor
deprecated
func (*Recruiter) GetConcurrency ¶
func (*Recruiter) GetConcurrencyMax ¶
func (*Recruiter) GetConcurrencyMin ¶
func (*Recruiter) GetCpuPerTask ¶
func (*Recruiter) GetDiskPerTask ¶
func (*Recruiter) GetMaxWorkers ¶
func (*Recruiter) GetMemoryPerTask ¶
func (*Recruiter) GetPrefetch ¶
func (*Recruiter) GetPrefetchPercent ¶
func (*Recruiter) GetProtofilter ¶
func (*Recruiter) GetTimeout ¶
func (*Recruiter) ProtoMessage ¶
func (*Recruiter) ProtoMessage()
func (*Recruiter) ProtoReflect ¶
func (x *Recruiter) ProtoReflect() protoreflect.Message
type RecruiterFilter ¶
type RecruiterFilter struct {
StepId *int32 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
// contains filtered or unexported fields
}
func (*RecruiterFilter) Descriptor
deprecated
func (*RecruiterFilter) Descriptor() ([]byte, []int)
Deprecated: Use RecruiterFilter.ProtoReflect.Descriptor instead.
func (*RecruiterFilter) GetStepId ¶
func (x *RecruiterFilter) GetStepId() int32
func (*RecruiterFilter) ProtoMessage ¶
func (*RecruiterFilter) ProtoMessage()
func (*RecruiterFilter) ProtoReflect ¶
func (x *RecruiterFilter) ProtoReflect() protoreflect.Message
func (*RecruiterFilter) Reset ¶
func (x *RecruiterFilter) Reset()
func (*RecruiterFilter) String ¶
func (x *RecruiterFilter) String() string
type RecruiterId ¶
type RecruiterId struct {
StepId int32 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
Rank int32 `protobuf:"varint,2,opt,name=rank,proto3" json:"rank,omitempty"`
// contains filtered or unexported fields
}
func (*RecruiterId) Descriptor
deprecated
func (*RecruiterId) Descriptor() ([]byte, []int)
Deprecated: Use RecruiterId.ProtoReflect.Descriptor instead.
func (*RecruiterId) GetRank ¶
func (x *RecruiterId) GetRank() int32
func (*RecruiterId) GetStepId ¶
func (x *RecruiterId) GetStepId() int32
func (*RecruiterId) ProtoMessage ¶
func (*RecruiterId) ProtoMessage()
func (*RecruiterId) ProtoReflect ¶
func (x *RecruiterId) ProtoReflect() protoreflect.Message
func (*RecruiterId) Reset ¶
func (x *RecruiterId) Reset()
func (*RecruiterId) String ¶
func (x *RecruiterId) String() string
type RecruiterList ¶
type RecruiterList struct {
Recruiters []*Recruiter `protobuf:"bytes,1,rep,name=recruiters,proto3" json:"recruiters,omitempty"`
// contains filtered or unexported fields
}
func (*RecruiterList) Descriptor
deprecated
func (*RecruiterList) Descriptor() ([]byte, []int)
Deprecated: Use RecruiterList.ProtoReflect.Descriptor instead.
func (*RecruiterList) GetRecruiters ¶
func (x *RecruiterList) GetRecruiters() []*Recruiter
func (*RecruiterList) ProtoMessage ¶
func (*RecruiterList) ProtoMessage()
func (*RecruiterList) ProtoReflect ¶
func (x *RecruiterList) ProtoReflect() protoreflect.Message
func (*RecruiterList) Reset ¶
func (x *RecruiterList) Reset()
func (*RecruiterList) String ¶
func (x *RecruiterList) String() string
type RecruiterUpdate ¶
type RecruiterUpdate struct {
StepId int32 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
Rank int32 `protobuf:"varint,2,opt,name=rank,proto3" json:"rank,omitempty"`
Protofilter *string `protobuf:"bytes,3,opt,name=protofilter,proto3,oneof" json:"protofilter,omitempty"`
Concurrency *int32 `protobuf:"varint,4,opt,name=concurrency,proto3,oneof" json:"concurrency,omitempty"`
Prefetch *int32 `protobuf:"varint,5,opt,name=prefetch,proto3,oneof" json:"prefetch,omitempty"`
MaxWorkers *int32 `protobuf:"varint,6,opt,name=max_workers,json=maxWorkers,proto3,oneof" json:"max_workers,omitempty"`
Rounds *int32 `protobuf:"varint,7,opt,name=rounds,proto3,oneof" json:"rounds,omitempty"`
Timeout *int32 `protobuf:"varint,8,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
CpuPerTask *int32 `protobuf:"varint,9,opt,name=cpu_per_task,json=cpuPerTask,proto3,oneof" json:"cpu_per_task,omitempty"`
MemoryPerTask *float32 `protobuf:"fixed32,10,opt,name=memory_per_task,json=memoryPerTask,proto3,oneof" json:"memory_per_task,omitempty"`
DiskPerTask *float32 `protobuf:"fixed32,11,opt,name=disk_per_task,json=diskPerTask,proto3,oneof" json:"disk_per_task,omitempty"`
PrefetchPercent *int32 `protobuf:"varint,12,opt,name=prefetch_percent,json=prefetchPercent,proto3,oneof" json:"prefetch_percent,omitempty"`
ConcurrencyMin *int32 `protobuf:"varint,13,opt,name=concurrency_min,json=concurrencyMin,proto3,oneof" json:"concurrency_min,omitempty"`
ConcurrencyMax *int32 `protobuf:"varint,14,opt,name=concurrency_max,json=concurrencyMax,proto3,oneof" json:"concurrency_max,omitempty"`
// contains filtered or unexported fields
}
func (*RecruiterUpdate) Descriptor
deprecated
func (*RecruiterUpdate) Descriptor() ([]byte, []int)
Deprecated: Use RecruiterUpdate.ProtoReflect.Descriptor instead.
func (*RecruiterUpdate) GetConcurrency ¶
func (x *RecruiterUpdate) GetConcurrency() int32
func (*RecruiterUpdate) GetConcurrencyMax ¶
func (x *RecruiterUpdate) GetConcurrencyMax() int32
func (*RecruiterUpdate) GetConcurrencyMin ¶
func (x *RecruiterUpdate) GetConcurrencyMin() int32
func (*RecruiterUpdate) GetCpuPerTask ¶
func (x *RecruiterUpdate) GetCpuPerTask() int32
func (*RecruiterUpdate) GetDiskPerTask ¶
func (x *RecruiterUpdate) GetDiskPerTask() float32
func (*RecruiterUpdate) GetMaxWorkers ¶
func (x *RecruiterUpdate) GetMaxWorkers() int32
func (*RecruiterUpdate) GetMemoryPerTask ¶
func (x *RecruiterUpdate) GetMemoryPerTask() float32
func (*RecruiterUpdate) GetPrefetch ¶
func (x *RecruiterUpdate) GetPrefetch() int32
func (*RecruiterUpdate) GetPrefetchPercent ¶
func (x *RecruiterUpdate) GetPrefetchPercent() int32
func (*RecruiterUpdate) GetProtofilter ¶
func (x *RecruiterUpdate) GetProtofilter() string
func (*RecruiterUpdate) GetRank ¶
func (x *RecruiterUpdate) GetRank() int32
func (*RecruiterUpdate) GetRounds ¶
func (x *RecruiterUpdate) GetRounds() int32
func (*RecruiterUpdate) GetStepId ¶
func (x *RecruiterUpdate) GetStepId() int32
func (*RecruiterUpdate) GetTimeout ¶
func (x *RecruiterUpdate) GetTimeout() int32
func (*RecruiterUpdate) ProtoMessage ¶
func (*RecruiterUpdate) ProtoMessage()
func (*RecruiterUpdate) ProtoReflect ¶
func (x *RecruiterUpdate) ProtoReflect() protoreflect.Message
func (*RecruiterUpdate) Reset ¶
func (x *RecruiterUpdate) Reset()
func (*RecruiterUpdate) String ¶
func (x *RecruiterUpdate) String() string
type Region ¶
type Region struct {
RegionId int32 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
ProviderId int32 `protobuf:"varint,2,opt,name=provider_id,json=providerId,proto3" json:"provider_id,omitempty"`
RegionName string `protobuf:"bytes,3,opt,name=region_name,json=regionName,proto3" json:"region_name,omitempty"`
IsDefault bool `protobuf:"varint,4,opt,name=is_default,json=isDefault,proto3" json:"is_default,omitempty"`
// contains filtered or unexported fields
}
func (*Region) Descriptor
deprecated
func (*Region) GetIsDefault ¶
func (*Region) GetProviderId ¶
func (*Region) GetRegionId ¶
func (*Region) GetRegionName ¶
func (*Region) ProtoMessage ¶
func (*Region) ProtoMessage()
func (*Region) ProtoReflect ¶
func (x *Region) ProtoReflect() protoreflect.Message
type RegionList ¶
type RegionList struct {
Regions []*Region `protobuf:"bytes,1,rep,name=regions,proto3" json:"regions,omitempty"`
// contains filtered or unexported fields
}
func (*RegionList) Descriptor
deprecated
func (*RegionList) Descriptor() ([]byte, []int)
Deprecated: Use RegionList.ProtoReflect.Descriptor instead.
func (*RegionList) GetRegions ¶
func (x *RegionList) GetRegions() []*Region
func (*RegionList) ProtoMessage ¶
func (*RegionList) ProtoMessage()
func (*RegionList) ProtoReflect ¶
func (x *RegionList) ProtoReflect() protoreflect.Message
func (*RegionList) Reset ¶
func (x *RegionList) Reset()
func (*RegionList) String ¶
func (x *RegionList) String() string
type ResourceSpec ¶
type ResourceSpec struct {
WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
Cpu int32 `protobuf:"varint,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
Mem float32 `protobuf:"fixed32,3,opt,name=mem,proto3" json:"mem,omitempty"`
Disk float32 `protobuf:"fixed32,4,opt,name=disk,proto3" json:"disk,omitempty"`
// contains filtered or unexported fields
}
func (*ResourceSpec) Descriptor
deprecated
func (*ResourceSpec) Descriptor() ([]byte, []int)
Deprecated: Use ResourceSpec.ProtoReflect.Descriptor instead.
func (*ResourceSpec) GetCpu ¶
func (x *ResourceSpec) GetCpu() int32
func (*ResourceSpec) GetDisk ¶
func (x *ResourceSpec) GetDisk() float32
func (*ResourceSpec) GetMem ¶
func (x *ResourceSpec) GetMem() float32
func (*ResourceSpec) GetWorkerId ¶
func (x *ResourceSpec) GetWorkerId() string
func (*ResourceSpec) ProtoMessage ¶
func (*ResourceSpec) ProtoMessage()
func (*ResourceSpec) ProtoReflect ¶
func (x *ResourceSpec) ProtoReflect() protoreflect.Message
func (*ResourceSpec) Reset ¶
func (x *ResourceSpec) Reset()
func (*ResourceSpec) String ¶
func (x *ResourceSpec) String() string
type RetryTaskRequest ¶
type RetryTaskRequest struct {
TaskId int32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
Retry *int32 `protobuf:"varint,2,opt,name=retry,proto3,oneof" json:"retry,omitempty"`
// contains filtered or unexported fields
}
func (*RetryTaskRequest) Descriptor
deprecated
func (*RetryTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use RetryTaskRequest.ProtoReflect.Descriptor instead.
func (*RetryTaskRequest) GetRetry ¶
func (x *RetryTaskRequest) GetRetry() int32
func (*RetryTaskRequest) GetTaskId ¶
func (x *RetryTaskRequest) GetTaskId() int32
func (*RetryTaskRequest) ProtoMessage ¶
func (*RetryTaskRequest) ProtoMessage()
func (*RetryTaskRequest) ProtoReflect ¶
func (x *RetryTaskRequest) ProtoReflect() protoreflect.Message
func (*RetryTaskRequest) Reset ¶
func (x *RetryTaskRequest) Reset()
func (*RetryTaskRequest) String ¶
func (x *RetryTaskRequest) String() string
type RunTemplateRequest ¶
type RunTemplateRequest struct {
WorkflowTemplateId int32 `protobuf:"varint,1,opt,name=workflow_template_id,json=workflowTemplateId,proto3" json:"workflow_template_id,omitempty"`
ParamValuesJson string `protobuf:"bytes,2,opt,name=param_values_json,json=paramValuesJson,proto3" json:"param_values_json,omitempty"`
// contains filtered or unexported fields
}
func (*RunTemplateRequest) Descriptor
deprecated
func (*RunTemplateRequest) Descriptor() ([]byte, []int)
Deprecated: Use RunTemplateRequest.ProtoReflect.Descriptor instead.
func (*RunTemplateRequest) GetParamValuesJson ¶
func (x *RunTemplateRequest) GetParamValuesJson() string
func (*RunTemplateRequest) GetWorkflowTemplateId ¶
func (x *RunTemplateRequest) GetWorkflowTemplateId() int32
func (*RunTemplateRequest) ProtoMessage ¶
func (*RunTemplateRequest) ProtoMessage()
func (*RunTemplateRequest) ProtoReflect ¶
func (x *RunTemplateRequest) ProtoReflect() protoreflect.Message
func (*RunTemplateRequest) Reset ¶
func (x *RunTemplateRequest) Reset()
func (*RunTemplateRequest) String ¶
func (x *RunTemplateRequest) String() string
type StatusCountEntry ¶ added in v0.6.1
type StatusCountEntry struct {
Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
Count int32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
WorkerId *int32 `protobuf:"varint,3,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
// contains filtered or unexported fields
}
func (*StatusCountEntry) Descriptor
deprecated
added in
v0.6.1
func (*StatusCountEntry) Descriptor() ([]byte, []int)
Deprecated: Use StatusCountEntry.ProtoReflect.Descriptor instead.
func (*StatusCountEntry) GetCount ¶ added in v0.6.1
func (x *StatusCountEntry) GetCount() int32
func (*StatusCountEntry) GetStatus ¶ added in v0.6.1
func (x *StatusCountEntry) GetStatus() string
func (*StatusCountEntry) GetWorkerId ¶ added in v0.6.1
func (x *StatusCountEntry) GetWorkerId() int32
func (*StatusCountEntry) ProtoMessage ¶ added in v0.6.1
func (*StatusCountEntry) ProtoMessage()
func (*StatusCountEntry) ProtoReflect ¶ added in v0.6.1
func (x *StatusCountEntry) ProtoReflect() protoreflect.Message
func (*StatusCountEntry) Reset ¶ added in v0.6.1
func (x *StatusCountEntry) Reset()
func (*StatusCountEntry) String ¶ added in v0.6.1
func (x *StatusCountEntry) String() string
type Step ¶
type Step struct {
StepId int32 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
WorkflowName string `protobuf:"bytes,2,opt,name=workflow_name,json=workflowName,proto3" json:"workflow_name,omitempty"`
WorkflowId int32 `protobuf:"varint,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*Step) Descriptor
deprecated
func (*Step) GetWorkflowId ¶
func (*Step) GetWorkflowName ¶
func (*Step) ProtoMessage ¶
func (*Step) ProtoMessage()
func (*Step) ProtoReflect ¶
func (x *Step) ProtoReflect() protoreflect.Message
type StepFilter ¶
type StepFilter struct {
WorkflowId int32 `protobuf:"varint,1,opt,name=WorkflowId,proto3" json:"WorkflowId,omitempty"`
Limit *int32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
Offset *int32 `protobuf:"varint,3,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
// contains filtered or unexported fields
}
func (*StepFilter) Descriptor
deprecated
func (*StepFilter) Descriptor() ([]byte, []int)
Deprecated: Use StepFilter.ProtoReflect.Descriptor instead.
func (*StepFilter) GetLimit ¶
func (x *StepFilter) GetLimit() int32
func (*StepFilter) GetOffset ¶
func (x *StepFilter) GetOffset() int32
func (*StepFilter) GetWorkflowId ¶
func (x *StepFilter) GetWorkflowId() int32
func (*StepFilter) ProtoMessage ¶
func (*StepFilter) ProtoMessage()
func (*StepFilter) ProtoReflect ¶
func (x *StepFilter) ProtoReflect() protoreflect.Message
func (*StepFilter) Reset ¶
func (x *StepFilter) Reset()
func (*StepFilter) String ¶
func (x *StepFilter) String() string
type StepId ¶
type StepId struct {
StepId int32 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
// contains filtered or unexported fields
}
func (*StepId) Descriptor
deprecated
func (*StepId) ProtoMessage ¶
func (*StepId) ProtoMessage()
func (*StepId) ProtoReflect ¶
func (x *StepId) ProtoReflect() protoreflect.Message
type StepList ¶
type StepList struct {
Steps []*Step `protobuf:"bytes,1,rep,name=steps,proto3" json:"steps,omitempty"`
// contains filtered or unexported fields
}
func (*StepList) Descriptor
deprecated
func (*StepList) ProtoMessage ¶
func (*StepList) ProtoMessage()
func (*StepList) ProtoReflect ¶
func (x *StepList) ProtoReflect() protoreflect.Message
type StepRequest ¶
type StepRequest struct {
WorkflowName *string `protobuf:"bytes,1,opt,name=workflow_name,json=workflowName,proto3,oneof" json:"workflow_name,omitempty"`
WorkflowId *int32 `protobuf:"varint,2,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*StepRequest) Descriptor
deprecated
func (*StepRequest) Descriptor() ([]byte, []int)
Deprecated: Use StepRequest.ProtoReflect.Descriptor instead.
func (*StepRequest) GetName ¶
func (x *StepRequest) GetName() string
func (*StepRequest) GetWorkflowId ¶
func (x *StepRequest) GetWorkflowId() int32
func (*StepRequest) GetWorkflowName ¶
func (x *StepRequest) GetWorkflowName() string
func (*StepRequest) ProtoMessage ¶
func (*StepRequest) ProtoMessage()
func (*StepRequest) ProtoReflect ¶
func (x *StepRequest) ProtoReflect() protoreflect.Message
func (*StepRequest) Reset ¶
func (x *StepRequest) Reset()
func (*StepRequest) String ¶
func (x *StepRequest) String() string
type StepStats ¶
type StepStats struct {
StepId int32 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
StepName string `protobuf:"bytes,2,opt,name=step_name,json=stepName,proto3" json:"step_name,omitempty"`
TotalTasks int32 `protobuf:"varint,3,opt,name=total_tasks,json=totalTasks,proto3" json:"total_tasks,omitempty"`
WaitingTasks int32 `protobuf:"varint,4,opt,name=waiting_tasks,json=waitingTasks,proto3" json:"waiting_tasks,omitempty"`
PendingTasks int32 `protobuf:"varint,5,opt,name=pending_tasks,json=pendingTasks,proto3" json:"pending_tasks,omitempty"`
AcceptedTasks int32 `protobuf:"varint,6,opt,name=accepted_tasks,json=acceptedTasks,proto3" json:"accepted_tasks,omitempty"`
RunningTasks int32 `protobuf:"varint,7,opt,name=running_tasks,json=runningTasks,proto3" json:"running_tasks,omitempty"`
UploadingTasks int32 `protobuf:"varint,8,opt,name=uploading_tasks,json=uploadingTasks,proto3" json:"uploading_tasks,omitempty"`
SuccessfulTasks int32 `protobuf:"varint,9,opt,name=successful_tasks,json=successfulTasks,proto3" json:"successful_tasks,omitempty"`
FailedTasks int32 `protobuf:"varint,10,opt,name=failed_tasks,json=failedTasks,proto3" json:"failed_tasks,omitempty"`
ReallyFailedTasks int32 `protobuf:"varint,11,opt,name=really_failed_tasks,json=reallyFailedTasks,proto3" json:"really_failed_tasks,omitempty"` // tasks that have exhausted all retries and are failed
SuccessRun *Accum `protobuf:"bytes,12,opt,name=success_run,json=successRun,proto3" json:"success_run,omitempty"` // succeeded tasks' run durations
FailedRun *Accum `protobuf:"bytes,13,opt,name=failed_run,json=failedRun,proto3" json:"failed_run,omitempty"` // failed tasks' run durations
RunningRun *Accum `protobuf:"bytes,14,opt,name=running_run,json=runningRun,proto3" json:"running_run,omitempty"` // running tasks' elapsed durations (at eval time)
Download *Accum `protobuf:"bytes,15,opt,name=download,proto3" json:"download,omitempty"` // download durations
Upload *Accum `protobuf:"bytes,16,opt,name=upload,proto3" json:"upload,omitempty"` // upload durations
StartTime *int64 `protobuf:"varint,17,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"` // epoch timestamp of the first task start time
EndTime *int64 `protobuf:"varint,18,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"` // epoch timestamp of the last task end time
StatsEvalTime int32 `protobuf:"varint,19,opt,name=stats_eval_time,json=statsEvalTime,proto3" json:"stats_eval_time,omitempty"` // epoch seconds when these stats were computed
// contains filtered or unexported fields
}
func (*StepStats) Descriptor
deprecated
func (*StepStats) GetAcceptedTasks ¶
func (*StepStats) GetDownload ¶
func (*StepStats) GetEndTime ¶
func (*StepStats) GetFailedRun ¶
func (*StepStats) GetFailedTasks ¶
func (*StepStats) GetPendingTasks ¶
func (*StepStats) GetReallyFailedTasks ¶
func (*StepStats) GetRunningRun ¶
func (*StepStats) GetRunningTasks ¶
func (*StepStats) GetStartTime ¶
func (*StepStats) GetStatsEvalTime ¶
func (*StepStats) GetStepName ¶
func (*StepStats) GetSuccessRun ¶
func (*StepStats) GetSuccessfulTasks ¶
func (*StepStats) GetTotalTasks ¶
func (*StepStats) GetUploadingTasks ¶
func (*StepStats) GetWaitingTasks ¶
func (*StepStats) ProtoMessage ¶
func (*StepStats) ProtoMessage()
func (*StepStats) ProtoReflect ¶
func (x *StepStats) ProtoReflect() protoreflect.Message
type StepStatsRequest ¶
type StepStatsRequest struct {
WorkflowId *int32 `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
StepIds []int32 `protobuf:"varint,2,rep,packed,name=step_ids,json=stepIds,proto3" json:"step_ids,omitempty"`
// contains filtered or unexported fields
}
func (*StepStatsRequest) Descriptor
deprecated
func (*StepStatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StepStatsRequest.ProtoReflect.Descriptor instead.
func (*StepStatsRequest) GetStepIds ¶
func (x *StepStatsRequest) GetStepIds() []int32
func (*StepStatsRequest) GetWorkflowId ¶
func (x *StepStatsRequest) GetWorkflowId() int32
func (*StepStatsRequest) ProtoMessage ¶
func (*StepStatsRequest) ProtoMessage()
func (*StepStatsRequest) ProtoReflect ¶
func (x *StepStatsRequest) ProtoReflect() protoreflect.Message
func (*StepStatsRequest) Reset ¶
func (x *StepStatsRequest) Reset()
func (*StepStatsRequest) String ¶
func (x *StepStatsRequest) String() string
type StepStatsResponse ¶
type StepStatsResponse struct {
Stats []*StepStats `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
// contains filtered or unexported fields
}
func (*StepStatsResponse) Descriptor
deprecated
func (*StepStatsResponse) Descriptor() ([]byte, []int)
Deprecated: Use StepStatsResponse.ProtoReflect.Descriptor instead.
func (*StepStatsResponse) GetStats ¶
func (x *StepStatsResponse) GetStats() []*StepStats
func (*StepStatsResponse) ProtoMessage ¶
func (*StepStatsResponse) ProtoMessage()
func (*StepStatsResponse) ProtoReflect ¶
func (x *StepStatsResponse) ProtoReflect() protoreflect.Message
func (*StepStatsResponse) Reset ¶
func (x *StepStatsResponse) Reset()
func (*StepStatsResponse) String ¶
func (x *StepStatsResponse) String() string
type Task ¶
type Task struct {
TaskId int32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
Shell *string `protobuf:"bytes,3,opt,name=shell,proto3,oneof" json:"shell,omitempty"`
Container string `protobuf:"bytes,4,opt,name=container,proto3" json:"container,omitempty"`
ContainerOptions *string `protobuf:"bytes,5,opt,name=container_options,json=containerOptions,proto3,oneof" json:"container_options,omitempty"`
StepId *int32 `protobuf:"varint,6,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
Input []string `protobuf:"bytes,7,rep,name=input,proto3" json:"input,omitempty"`
Resource []string `protobuf:"bytes,8,rep,name=resource,proto3" json:"resource,omitempty"`
Output *string `protobuf:"bytes,9,opt,name=output,proto3,oneof" json:"output,omitempty"`
Retry *int32 `protobuf:"varint,10,opt,name=retry,proto3,oneof" json:"retry,omitempty"`
IsFinal *bool `protobuf:"varint,11,opt,name=is_final,json=isFinal,proto3,oneof" json:"is_final,omitempty"`
UsesCache *bool `protobuf:"varint,12,opt,name=uses_cache,json=usesCache,proto3,oneof" json:"uses_cache,omitempty"`
DownloadTimeout *float32 `protobuf:"fixed32,13,opt,name=download_timeout,json=downloadTimeout,proto3,oneof" json:"download_timeout,omitempty"`
RunningTimeout *float32 `protobuf:"fixed32,14,opt,name=running_timeout,json=runningTimeout,proto3,oneof" json:"running_timeout,omitempty"`
UploadTimeout *float32 `protobuf:"fixed32,15,opt,name=upload_timeout,json=uploadTimeout,proto3,oneof" json:"upload_timeout,omitempty"`
Status string `protobuf:"bytes,16,opt,name=status,proto3" json:"status,omitempty"`
WorkerId *int32 `protobuf:"varint,17,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
WorkflowId *int32 `protobuf:"varint,18,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
TaskName *string `protobuf:"bytes,19,opt,name=task_name,json=taskName,proto3,oneof" json:"task_name,omitempty"`
RetryCount int32 `protobuf:"varint,20,opt,name=retry_count,json=retryCount,proto3" json:"retry_count,omitempty"`
Hidden bool `protobuf:"varint,21,opt,name=hidden,proto3" json:"hidden,omitempty"`
PreviousTaskId *int32 `protobuf:"varint,22,opt,name=previous_task_id,json=previousTaskId,proto3,oneof" json:"previous_task_id,omitempty"`
Weight *float64 `protobuf:"fixed64,23,opt,name=weight,proto3,oneof" json:"weight,omitempty"` // Fraction of the assigned worker's concurrency consumed by this task (default 1.0)
RunStartTime *int64 `protobuf:"varint,24,opt,name=run_start_time,json=runStartTime,proto3,oneof" json:"run_start_time,omitempty"` // epoch timestamp of the first task start time
// contains filtered or unexported fields
}
func (*Task) Descriptor
deprecated
func (*Task) GetCommand ¶
func (*Task) GetContainer ¶
func (*Task) GetContainerOptions ¶
func (*Task) GetDownloadTimeout ¶
func (*Task) GetIsFinal ¶
func (*Task) GetPreviousTaskId ¶
func (*Task) GetResource ¶
func (*Task) GetRetryCount ¶
func (*Task) GetRunStartTime ¶
func (*Task) GetRunningTimeout ¶
func (*Task) GetTaskName ¶
func (*Task) GetUploadTimeout ¶
func (*Task) GetUsesCache ¶
func (*Task) GetWorkerId ¶
func (*Task) GetWorkflowId ¶
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) ProtoReflect ¶
func (x *Task) ProtoReflect() protoreflect.Message
type TaskId ¶
type TaskId struct {
TaskId int32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
// contains filtered or unexported fields
}
func (*TaskId) Descriptor
deprecated
func (*TaskId) ProtoMessage ¶
func (*TaskId) ProtoMessage()
func (*TaskId) ProtoReflect ¶
func (x *TaskId) ProtoReflect() protoreflect.Message
type TaskIds ¶
type TaskIds struct {
TaskIds []int32 `protobuf:"varint,1,rep,packed,name=task_ids,json=taskIds,proto3" json:"task_ids,omitempty"`
// contains filtered or unexported fields
}
func (*TaskIds) Descriptor
deprecated
func (*TaskIds) GetTaskIds ¶
func (*TaskIds) ProtoMessage ¶
func (*TaskIds) ProtoMessage()
func (*TaskIds) ProtoReflect ¶
func (x *TaskIds) ProtoReflect() protoreflect.Message
type TaskList ¶
type TaskList struct {
Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
// contains filtered or unexported fields
}
func (*TaskList) Descriptor
deprecated
func (*TaskList) ProtoMessage ¶
func (*TaskList) ProtoMessage()
func (*TaskList) ProtoReflect ¶
func (x *TaskList) ProtoReflect() protoreflect.Message
type TaskListAndOther ¶
type TaskListAndOther struct {
Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
Concurrency int32 `protobuf:"varint,2,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
Updates *TaskUpdateList `protobuf:"bytes,3,opt,name=updates,proto3" json:"updates,omitempty"`
ActiveTasks []int32 `protobuf:"varint,4,rep,packed,name=active_tasks,json=activeTasks,proto3" json:"active_tasks,omitempty"`
// contains filtered or unexported fields
}
func (*TaskListAndOther) Descriptor
deprecated
func (*TaskListAndOther) Descriptor() ([]byte, []int)
Deprecated: Use TaskListAndOther.ProtoReflect.Descriptor instead.
func (*TaskListAndOther) GetActiveTasks ¶
func (x *TaskListAndOther) GetActiveTasks() []int32
func (*TaskListAndOther) GetConcurrency ¶
func (x *TaskListAndOther) GetConcurrency() int32
func (*TaskListAndOther) GetTasks ¶
func (x *TaskListAndOther) GetTasks() []*Task
func (*TaskListAndOther) GetUpdates ¶
func (x *TaskListAndOther) GetUpdates() *TaskUpdateList
func (*TaskListAndOther) ProtoMessage ¶
func (*TaskListAndOther) ProtoMessage()
func (*TaskListAndOther) ProtoReflect ¶
func (x *TaskListAndOther) ProtoReflect() protoreflect.Message
func (*TaskListAndOther) Reset ¶
func (x *TaskListAndOther) Reset()
func (*TaskListAndOther) String ¶
func (x *TaskListAndOther) String() string
type TaskLog ¶
type TaskLog struct {
TaskId int32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
LogType string `protobuf:"bytes,2,opt,name=log_type,json=logType,proto3" json:"log_type,omitempty"` // 'O' for stdout, 'E' for stderr
LogText string `protobuf:"bytes,3,opt,name=log_text,json=logText,proto3" json:"log_text,omitempty"`
// contains filtered or unexported fields
}
func (*TaskLog) Descriptor
deprecated
func (*TaskLog) GetLogText ¶
func (*TaskLog) GetLogType ¶
func (*TaskLog) ProtoMessage ¶
func (*TaskLog) ProtoMessage()
func (*TaskLog) ProtoReflect ¶
func (x *TaskLog) ProtoReflect() protoreflect.Message
type TaskQueueClient ¶
type TaskQueueClient interface {
SubmitTask(ctx context.Context, in *TaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)
RegisterWorker(ctx context.Context, in *WorkerInfo, opts ...grpc.CallOption) (*WorkerId, error)
PingAndTakeNewTasks(ctx context.Context, in *PingAndGetNewTasksRequest, opts ...grpc.CallOption) (*TaskListAndOther, error)
UpdateTaskStatus(ctx context.Context, in *TaskStatusUpdate, opts ...grpc.CallOption) (*Ack, error)
SendTaskLogs(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[TaskLog, Ack], error)
StreamTaskLogsOutput(ctx context.Context, in *TaskId, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TaskLog], error)
StreamTaskLogsErr(ctx context.Context, in *TaskId, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TaskLog], error)
GetLogsChunk(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*LogChunkList, error)
ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*TaskList, error)
RetryTask(ctx context.Context, in *RetryTaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)
ListWorkers(ctx context.Context, in *ListWorkersRequest, opts ...grpc.CallOption) (*WorkersList, error)
CreateWorker(ctx context.Context, in *WorkerRequest, opts ...grpc.CallOption) (*WorkerIds, error)
UpdateWorkerStatus(ctx context.Context, in *WorkerStatus, opts ...grpc.CallOption) (*Ack, error)
DeleteWorker(ctx context.Context, in *WorkerDeletion, opts ...grpc.CallOption) (*JobId, error)
UpdateWorker(ctx context.Context, in *WorkerUpdateRequest, opts ...grpc.CallOption) (*Ack, error)
UserUpdateWorker(ctx context.Context, in *WorkerUpdateRequest, opts ...grpc.CallOption) (*Ack, error)
GetWorkerStatuses(ctx context.Context, in *WorkerStatusRequest, opts ...grpc.CallOption) (*WorkerStatusResponse, error)
ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*JobsList, error)
GetJobStatuses(ctx context.Context, in *JobStatusRequest, opts ...grpc.CallOption) (*JobStatusResponse, error)
DeleteJob(ctx context.Context, in *JobId, opts ...grpc.CallOption) (*Ack, error)
UpdateJob(ctx context.Context, in *JobUpdate, opts ...grpc.CallOption) (*Ack, error)
ListFlavors(ctx context.Context, in *ListFlavorsRequest, opts ...grpc.CallOption) (*FlavorsList, error)
ListProviders(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ProviderList, error)
ListRegions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RegionList, error)
CreateFlavor(ctx context.Context, in *FlavorCreateRequest, opts ...grpc.CallOption) (*FlavorId, error)
GetRcloneConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RcloneRemotes, error)
GetDockerCredentials(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DockerCredentials, error)
Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error)
GetCertificate(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Certificate, error)
Logout(ctx context.Context, in *Token, opts ...grpc.CallOption) (*Ack, error)
CreateUser(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*UserId, error)
ListUsers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*UsersList, error)
DeleteUser(ctx context.Context, in *UserId, opts ...grpc.CallOption) (*Ack, error)
UpdateUser(ctx context.Context, in *User, opts ...grpc.CallOption) (*Ack, error)
ChangePassword(ctx context.Context, in *ChangePasswordRequest, opts ...grpc.CallOption) (*Ack, error)
ListRecruiters(ctx context.Context, in *RecruiterFilter, opts ...grpc.CallOption) (*RecruiterList, error)
CreateRecruiter(ctx context.Context, in *Recruiter, opts ...grpc.CallOption) (*Ack, error)
UpdateRecruiter(ctx context.Context, in *RecruiterUpdate, opts ...grpc.CallOption) (*Ack, error)
DeleteRecruiter(ctx context.Context, in *RecruiterId, opts ...grpc.CallOption) (*Ack, error)
ListWorkflows(ctx context.Context, in *WorkflowFilter, opts ...grpc.CallOption) (*WorkflowList, error)
CreateWorkflow(ctx context.Context, in *WorkflowRequest, opts ...grpc.CallOption) (*WorkflowId, error)
UpdateWorkflowStatus(ctx context.Context, in *WorkflowStatusUpdate, opts ...grpc.CallOption) (*Ack, error)
DeleteWorkflow(ctx context.Context, in *WorkflowId, opts ...grpc.CallOption) (*Ack, error)
DebugAssignTask(ctx context.Context, in *DebugAssignRequest, opts ...grpc.CallOption) (*Ack, error)
DebugRecruitStep(ctx context.Context, in *DebugRecruitRequest, opts ...grpc.CallOption) (*Ack, error)
DebugRetryTask(ctx context.Context, in *RetryTaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)
ListDependentPendingTasks(ctx context.Context, in *TaskId, opts ...grpc.CallOption) (*TaskIds, error)
ListSteps(ctx context.Context, in *StepFilter, opts ...grpc.CallOption) (*StepList, error)
CreateStep(ctx context.Context, in *StepRequest, opts ...grpc.CallOption) (*StepId, error)
DeleteStep(ctx context.Context, in *StepId, opts ...grpc.CallOption) (*Ack, error)
GetStepStats(ctx context.Context, in *StepStatsRequest, opts ...grpc.CallOption) (*StepStatsResponse, error)
GetWorkerStats(ctx context.Context, in *GetWorkerStatsRequest, opts ...grpc.CallOption) (*GetWorkerStatsResponse, error)
FetchList(ctx context.Context, in *FetchListRequest, opts ...grpc.CallOption) (*FetchListResponse, error)
FetchInfo(ctx context.Context, in *FetchListRequest, opts ...grpc.CallOption) (*FetchInfoResponse, error)
// Template system
UploadTemplate(ctx context.Context, in *UploadTemplateRequest, opts ...grpc.CallOption) (*UploadTemplateResponse, error)
RunTemplate(ctx context.Context, in *RunTemplateRequest, opts ...grpc.CallOption) (*TemplateRun, error)
ListTemplates(ctx context.Context, in *TemplateFilter, opts ...grpc.CallOption) (*TemplateList, error)
ListTemplateRuns(ctx context.Context, in *TemplateRunFilter, opts ...grpc.CallOption) (*TemplateRunList, error)
UpdateTemplateRun(ctx context.Context, in *UpdateTemplateRunRequest, opts ...grpc.CallOption) (*Ack, error)
DeleteTemplateRun(ctx context.Context, in *DeleteTemplateRunRequest, opts ...grpc.CallOption) (*Ack, error)
GetWorkspaceRoot(ctx context.Context, in *WorkspaceRootRequest, opts ...grpc.CallOption) (*WorkspaceRootResponse, error)
RegisterSpecifications(ctx context.Context, in *ResourceSpec, opts ...grpc.CallOption) (*Ack, error)
// Worker events
ReportWorkerEvent(ctx context.Context, in *WorkerEvent, opts ...grpc.CallOption) (*Ack, error)
ListWorkerEvents(ctx context.Context, in *WorkerEventFilter, opts ...grpc.CallOption) (*WorkerEventList, error)
DeleteWorkerEvent(ctx context.Context, in *WorkerEventId, opts ...grpc.CallOption) (*Ack, error)
PruneWorkerEvents(ctx context.Context, in *WorkerEventPruneFilter, opts ...grpc.CallOption) (*WorkerEventPruneResult, error)
GetTaskStatusCounts(ctx context.Context, in *TaskStatusCountsRequest, opts ...grpc.CallOption) (*TaskStatusCountsResponse, error)
}
TaskQueueClient is the client API for TaskQueue service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewTaskQueueClient ¶
func NewTaskQueueClient(cc grpc.ClientConnInterface) TaskQueueClient
type TaskQueueServer ¶
type TaskQueueServer interface {
SubmitTask(context.Context, *TaskRequest) (*TaskResponse, error)
RegisterWorker(context.Context, *WorkerInfo) (*WorkerId, error)
PingAndTakeNewTasks(context.Context, *PingAndGetNewTasksRequest) (*TaskListAndOther, error)
UpdateTaskStatus(context.Context, *TaskStatusUpdate) (*Ack, error)
SendTaskLogs(grpc.ClientStreamingServer[TaskLog, Ack]) error
StreamTaskLogsOutput(*TaskId, grpc.ServerStreamingServer[TaskLog]) error
StreamTaskLogsErr(*TaskId, grpc.ServerStreamingServer[TaskLog]) error
GetLogsChunk(context.Context, *GetLogsRequest) (*LogChunkList, error)
ListTasks(context.Context, *ListTasksRequest) (*TaskList, error)
RetryTask(context.Context, *RetryTaskRequest) (*TaskResponse, error)
ListWorkers(context.Context, *ListWorkersRequest) (*WorkersList, error)
CreateWorker(context.Context, *WorkerRequest) (*WorkerIds, error)
UpdateWorkerStatus(context.Context, *WorkerStatus) (*Ack, error)
DeleteWorker(context.Context, *WorkerDeletion) (*JobId, error)
UpdateWorker(context.Context, *WorkerUpdateRequest) (*Ack, error)
UserUpdateWorker(context.Context, *WorkerUpdateRequest) (*Ack, error)
GetWorkerStatuses(context.Context, *WorkerStatusRequest) (*WorkerStatusResponse, error)
ListJobs(context.Context, *ListJobsRequest) (*JobsList, error)
GetJobStatuses(context.Context, *JobStatusRequest) (*JobStatusResponse, error)
DeleteJob(context.Context, *JobId) (*Ack, error)
UpdateJob(context.Context, *JobUpdate) (*Ack, error)
ListFlavors(context.Context, *ListFlavorsRequest) (*FlavorsList, error)
ListProviders(context.Context, *emptypb.Empty) (*ProviderList, error)
ListRegions(context.Context, *emptypb.Empty) (*RegionList, error)
CreateFlavor(context.Context, *FlavorCreateRequest) (*FlavorId, error)
GetRcloneConfig(context.Context, *emptypb.Empty) (*RcloneRemotes, error)
GetDockerCredentials(context.Context, *emptypb.Empty) (*DockerCredentials, error)
Login(context.Context, *LoginRequest) (*LoginResponse, error)
GetCertificate(context.Context, *emptypb.Empty) (*Certificate, error)
Logout(context.Context, *Token) (*Ack, error)
CreateUser(context.Context, *CreateUserRequest) (*UserId, error)
ListUsers(context.Context, *emptypb.Empty) (*UsersList, error)
DeleteUser(context.Context, *UserId) (*Ack, error)
UpdateUser(context.Context, *User) (*Ack, error)
ChangePassword(context.Context, *ChangePasswordRequest) (*Ack, error)
ListRecruiters(context.Context, *RecruiterFilter) (*RecruiterList, error)
CreateRecruiter(context.Context, *Recruiter) (*Ack, error)
UpdateRecruiter(context.Context, *RecruiterUpdate) (*Ack, error)
DeleteRecruiter(context.Context, *RecruiterId) (*Ack, error)
ListWorkflows(context.Context, *WorkflowFilter) (*WorkflowList, error)
CreateWorkflow(context.Context, *WorkflowRequest) (*WorkflowId, error)
UpdateWorkflowStatus(context.Context, *WorkflowStatusUpdate) (*Ack, error)
DeleteWorkflow(context.Context, *WorkflowId) (*Ack, error)
DebugAssignTask(context.Context, *DebugAssignRequest) (*Ack, error)
DebugRecruitStep(context.Context, *DebugRecruitRequest) (*Ack, error)
DebugRetryTask(context.Context, *RetryTaskRequest) (*TaskResponse, error)
ListDependentPendingTasks(context.Context, *TaskId) (*TaskIds, error)
ListSteps(context.Context, *StepFilter) (*StepList, error)
CreateStep(context.Context, *StepRequest) (*StepId, error)
DeleteStep(context.Context, *StepId) (*Ack, error)
GetStepStats(context.Context, *StepStatsRequest) (*StepStatsResponse, error)
GetWorkerStats(context.Context, *GetWorkerStatsRequest) (*GetWorkerStatsResponse, error)
FetchList(context.Context, *FetchListRequest) (*FetchListResponse, error)
FetchInfo(context.Context, *FetchListRequest) (*FetchInfoResponse, error)
// Template system
UploadTemplate(context.Context, *UploadTemplateRequest) (*UploadTemplateResponse, error)
RunTemplate(context.Context, *RunTemplateRequest) (*TemplateRun, error)
ListTemplates(context.Context, *TemplateFilter) (*TemplateList, error)
ListTemplateRuns(context.Context, *TemplateRunFilter) (*TemplateRunList, error)
UpdateTemplateRun(context.Context, *UpdateTemplateRunRequest) (*Ack, error)
DeleteTemplateRun(context.Context, *DeleteTemplateRunRequest) (*Ack, error)
GetWorkspaceRoot(context.Context, *WorkspaceRootRequest) (*WorkspaceRootResponse, error)
RegisterSpecifications(context.Context, *ResourceSpec) (*Ack, error)
// Worker events
ReportWorkerEvent(context.Context, *WorkerEvent) (*Ack, error)
ListWorkerEvents(context.Context, *WorkerEventFilter) (*WorkerEventList, error)
DeleteWorkerEvent(context.Context, *WorkerEventId) (*Ack, error)
PruneWorkerEvents(context.Context, *WorkerEventPruneFilter) (*WorkerEventPruneResult, error)
GetTaskStatusCounts(context.Context, *TaskStatusCountsRequest) (*TaskStatusCountsResponse, error)
// contains filtered or unexported methods
}
TaskQueueServer is the server API for TaskQueue service. All implementations must embed UnimplementedTaskQueueServer for forward compatibility.
type TaskQueue_SendTaskLogsClient ¶
type TaskQueue_SendTaskLogsClient = grpc.ClientStreamingClient[TaskLog, Ack]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TaskQueue_SendTaskLogsServer ¶
type TaskQueue_SendTaskLogsServer = grpc.ClientStreamingServer[TaskLog, Ack]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TaskQueue_StreamTaskLogsErrClient ¶
type TaskQueue_StreamTaskLogsErrClient = grpc.ServerStreamingClient[TaskLog]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TaskQueue_StreamTaskLogsErrServer ¶
type TaskQueue_StreamTaskLogsErrServer = grpc.ServerStreamingServer[TaskLog]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TaskQueue_StreamTaskLogsOutputClient ¶
type TaskQueue_StreamTaskLogsOutputClient = grpc.ServerStreamingClient[TaskLog]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TaskQueue_StreamTaskLogsOutputServer ¶
type TaskQueue_StreamTaskLogsOutputServer = grpc.ServerStreamingServer[TaskLog]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TaskRequest ¶
type TaskRequest struct {
Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
Shell *string `protobuf:"bytes,2,opt,name=shell,proto3,oneof" json:"shell,omitempty"`
Container string `protobuf:"bytes,3,opt,name=container,proto3" json:"container,omitempty"`
ContainerOptions *string `protobuf:"bytes,4,opt,name=container_options,json=containerOptions,proto3,oneof" json:"container_options,omitempty"`
StepId *int32 `protobuf:"varint,5,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
Input []string `protobuf:"bytes,6,rep,name=input,proto3" json:"input,omitempty"`
Resource []string `protobuf:"bytes,7,rep,name=resource,proto3" json:"resource,omitempty"`
Output *string `protobuf:"bytes,8,opt,name=output,proto3,oneof" json:"output,omitempty"`
Retry *int32 `protobuf:"varint,9,opt,name=retry,proto3,oneof" json:"retry,omitempty"`
IsFinal *bool `protobuf:"varint,10,opt,name=is_final,json=isFinal,proto3,oneof" json:"is_final,omitempty"`
UsesCache *bool `protobuf:"varint,11,opt,name=uses_cache,json=usesCache,proto3,oneof" json:"uses_cache,omitempty"`
DownloadTimeout *float32 `protobuf:"fixed32,12,opt,name=download_timeout,json=downloadTimeout,proto3,oneof" json:"download_timeout,omitempty"`
RunningTimeout *float32 `protobuf:"fixed32,13,opt,name=running_timeout,json=runningTimeout,proto3,oneof" json:"running_timeout,omitempty"`
UploadTimeout *float32 `protobuf:"fixed32,14,opt,name=upload_timeout,json=uploadTimeout,proto3,oneof" json:"upload_timeout,omitempty"`
Status string `protobuf:"bytes,15,opt,name=status,proto3" json:"status,omitempty"`
Dependency []int32 `protobuf:"varint,16,rep,packed,name=dependency,proto3" json:"dependency,omitempty"` // IDs of tasks that this task depends on
TaskName *string `protobuf:"bytes,17,opt,name=task_name,json=taskName,proto3,oneof" json:"task_name,omitempty"`
// contains filtered or unexported fields
}
func (*TaskRequest) Descriptor
deprecated
func (*TaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use TaskRequest.ProtoReflect.Descriptor instead.
func (*TaskRequest) GetCommand ¶
func (x *TaskRequest) GetCommand() string
func (*TaskRequest) GetContainer ¶
func (x *TaskRequest) GetContainer() string
func (*TaskRequest) GetContainerOptions ¶
func (x *TaskRequest) GetContainerOptions() string
func (*TaskRequest) GetDependency ¶
func (x *TaskRequest) GetDependency() []int32
func (*TaskRequest) GetDownloadTimeout ¶
func (x *TaskRequest) GetDownloadTimeout() float32
func (*TaskRequest) GetInput ¶
func (x *TaskRequest) GetInput() []string
func (*TaskRequest) GetIsFinal ¶
func (x *TaskRequest) GetIsFinal() bool
func (*TaskRequest) GetOutput ¶
func (x *TaskRequest) GetOutput() string
func (*TaskRequest) GetResource ¶
func (x *TaskRequest) GetResource() []string
func (*TaskRequest) GetRetry ¶
func (x *TaskRequest) GetRetry() int32
func (*TaskRequest) GetRunningTimeout ¶
func (x *TaskRequest) GetRunningTimeout() float32
func (*TaskRequest) GetShell ¶
func (x *TaskRequest) GetShell() string
func (*TaskRequest) GetStatus ¶
func (x *TaskRequest) GetStatus() string
func (*TaskRequest) GetStepId ¶
func (x *TaskRequest) GetStepId() int32
func (*TaskRequest) GetTaskName ¶
func (x *TaskRequest) GetTaskName() string
func (*TaskRequest) GetUploadTimeout ¶
func (x *TaskRequest) GetUploadTimeout() float32
func (*TaskRequest) GetUsesCache ¶
func (x *TaskRequest) GetUsesCache() bool
func (*TaskRequest) ProtoMessage ¶
func (*TaskRequest) ProtoMessage()
func (*TaskRequest) ProtoReflect ¶
func (x *TaskRequest) ProtoReflect() protoreflect.Message
func (*TaskRequest) Reset ¶
func (x *TaskRequest) Reset()
func (*TaskRequest) String ¶
func (x *TaskRequest) String() string
type TaskResponse ¶
type TaskResponse struct {
TaskId int32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
// contains filtered or unexported fields
}
func (*TaskResponse) Descriptor
deprecated
func (*TaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use TaskResponse.ProtoReflect.Descriptor instead.
func (*TaskResponse) GetTaskId ¶
func (x *TaskResponse) GetTaskId() int32
func (*TaskResponse) ProtoMessage ¶
func (*TaskResponse) ProtoMessage()
func (*TaskResponse) ProtoReflect ¶
func (x *TaskResponse) ProtoReflect() protoreflect.Message
func (*TaskResponse) Reset ¶
func (x *TaskResponse) Reset()
func (*TaskResponse) String ¶
func (x *TaskResponse) String() string
type TaskStatusCountsRequest ¶ added in v0.6.1
type TaskStatusCountsRequest struct {
ShowHidden *bool `protobuf:"varint,1,opt,name=show_hidden,json=showHidden,proto3,oneof" json:"show_hidden,omitempty"`
// contains filtered or unexported fields
}
func (*TaskStatusCountsRequest) Descriptor
deprecated
added in
v0.6.1
func (*TaskStatusCountsRequest) Descriptor() ([]byte, []int)
Deprecated: Use TaskStatusCountsRequest.ProtoReflect.Descriptor instead.
func (*TaskStatusCountsRequest) GetShowHidden ¶ added in v0.6.1
func (x *TaskStatusCountsRequest) GetShowHidden() bool
func (*TaskStatusCountsRequest) ProtoMessage ¶ added in v0.6.1
func (*TaskStatusCountsRequest) ProtoMessage()
func (*TaskStatusCountsRequest) ProtoReflect ¶ added in v0.6.1
func (x *TaskStatusCountsRequest) ProtoReflect() protoreflect.Message
func (*TaskStatusCountsRequest) Reset ¶ added in v0.6.1
func (x *TaskStatusCountsRequest) Reset()
func (*TaskStatusCountsRequest) String ¶ added in v0.6.1
func (x *TaskStatusCountsRequest) String() string
type TaskStatusCountsResponse ¶ added in v0.6.1
type TaskStatusCountsResponse struct {
GlobalCounts []*StatusCountEntry `protobuf:"bytes,1,rep,name=global_counts,json=globalCounts,proto3" json:"global_counts,omitempty"`
PerWorkerCounts []*StatusCountEntry `protobuf:"bytes,2,rep,name=per_worker_counts,json=perWorkerCounts,proto3" json:"per_worker_counts,omitempty"`
TotalCount int32 `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
// contains filtered or unexported fields
}
func (*TaskStatusCountsResponse) Descriptor
deprecated
added in
v0.6.1
func (*TaskStatusCountsResponse) Descriptor() ([]byte, []int)
Deprecated: Use TaskStatusCountsResponse.ProtoReflect.Descriptor instead.
func (*TaskStatusCountsResponse) GetGlobalCounts ¶ added in v0.6.1
func (x *TaskStatusCountsResponse) GetGlobalCounts() []*StatusCountEntry
func (*TaskStatusCountsResponse) GetPerWorkerCounts ¶ added in v0.6.1
func (x *TaskStatusCountsResponse) GetPerWorkerCounts() []*StatusCountEntry
func (*TaskStatusCountsResponse) GetTotalCount ¶ added in v0.6.1
func (x *TaskStatusCountsResponse) GetTotalCount() int32
func (*TaskStatusCountsResponse) ProtoMessage ¶ added in v0.6.1
func (*TaskStatusCountsResponse) ProtoMessage()
func (*TaskStatusCountsResponse) ProtoReflect ¶ added in v0.6.1
func (x *TaskStatusCountsResponse) ProtoReflect() protoreflect.Message
func (*TaskStatusCountsResponse) Reset ¶ added in v0.6.1
func (x *TaskStatusCountsResponse) Reset()
func (*TaskStatusCountsResponse) String ¶ added in v0.6.1
func (x *TaskStatusCountsResponse) String() string
type TaskStatusUpdate ¶
type TaskStatusUpdate struct {
TaskId int32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
NewStatus string `protobuf:"bytes,2,opt,name=new_status,json=newStatus,proto3" json:"new_status,omitempty"`
Duration *int32 `protobuf:"varint,3,opt,name=duration,proto3,oneof" json:"duration,omitempty"` // in seconds
FreeRetry *bool `protobuf:"varint,4,opt,name=free_retry,json=freeRetry,proto3,oneof" json:"free_retry,omitempty"` // if new_status is F and this is true, then retry is increased by 1 before setting status to F
// contains filtered or unexported fields
}
func (*TaskStatusUpdate) Descriptor
deprecated
func (*TaskStatusUpdate) Descriptor() ([]byte, []int)
Deprecated: Use TaskStatusUpdate.ProtoReflect.Descriptor instead.
func (*TaskStatusUpdate) GetDuration ¶
func (x *TaskStatusUpdate) GetDuration() int32
func (*TaskStatusUpdate) GetFreeRetry ¶
func (x *TaskStatusUpdate) GetFreeRetry() bool
func (*TaskStatusUpdate) GetNewStatus ¶
func (x *TaskStatusUpdate) GetNewStatus() string
func (*TaskStatusUpdate) GetTaskId ¶
func (x *TaskStatusUpdate) GetTaskId() int32
func (*TaskStatusUpdate) ProtoMessage ¶
func (*TaskStatusUpdate) ProtoMessage()
func (*TaskStatusUpdate) ProtoReflect ¶
func (x *TaskStatusUpdate) ProtoReflect() protoreflect.Message
func (*TaskStatusUpdate) Reset ¶
func (x *TaskStatusUpdate) Reset()
func (*TaskStatusUpdate) String ¶
func (x *TaskStatusUpdate) String() string
type TaskUpdate ¶
type TaskUpdate struct {
Weight float64 `protobuf:"fixed64,1,opt,name=weight,proto3" json:"weight,omitempty"`
// contains filtered or unexported fields
}
func (*TaskUpdate) Descriptor
deprecated
func (*TaskUpdate) Descriptor() ([]byte, []int)
Deprecated: Use TaskUpdate.ProtoReflect.Descriptor instead.
func (*TaskUpdate) GetWeight ¶
func (x *TaskUpdate) GetWeight() float64
func (*TaskUpdate) ProtoMessage ¶
func (*TaskUpdate) ProtoMessage()
func (*TaskUpdate) ProtoReflect ¶
func (x *TaskUpdate) ProtoReflect() protoreflect.Message
func (*TaskUpdate) Reset ¶
func (x *TaskUpdate) Reset()
func (*TaskUpdate) String ¶
func (x *TaskUpdate) String() string
type TaskUpdateList ¶
type TaskUpdateList struct {
Updates map[int32]*TaskUpdate `` // optional — can be empty
/* 142-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*TaskUpdateList) Descriptor
deprecated
func (*TaskUpdateList) Descriptor() ([]byte, []int)
Deprecated: Use TaskUpdateList.ProtoReflect.Descriptor instead.
func (*TaskUpdateList) GetUpdates ¶
func (x *TaskUpdateList) GetUpdates() map[int32]*TaskUpdate
func (*TaskUpdateList) ProtoMessage ¶
func (*TaskUpdateList) ProtoMessage()
func (*TaskUpdateList) ProtoReflect ¶
func (x *TaskUpdateList) ProtoReflect() protoreflect.Message
func (*TaskUpdateList) Reset ¶
func (x *TaskUpdateList) Reset()
func (*TaskUpdateList) String ¶
func (x *TaskUpdateList) String() string
type Template ¶
type Template struct {
WorkflowTemplateId int32 `protobuf:"varint,1,opt,name=workflow_template_id,json=workflowTemplateId,proto3" json:"workflow_template_id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
ParamJson string `protobuf:"bytes,5,opt,name=param_json,json=paramJson,proto3" json:"param_json,omitempty"`
UploadedAt string `protobuf:"bytes,6,opt,name=uploaded_at,json=uploadedAt,proto3" json:"uploaded_at,omitempty"`
UploadedBy *int32 `protobuf:"varint,7,opt,name=uploaded_by,json=uploadedBy,proto3,oneof" json:"uploaded_by,omitempty"`
// contains filtered or unexported fields
}
func (*Template) Descriptor
deprecated
func (*Template) GetDescription ¶
func (*Template) GetParamJson ¶
func (*Template) GetUploadedAt ¶
func (*Template) GetUploadedBy ¶
func (*Template) GetVersion ¶
func (*Template) GetWorkflowTemplateId ¶
func (*Template) ProtoMessage ¶
func (*Template) ProtoMessage()
func (*Template) ProtoReflect ¶
func (x *Template) ProtoReflect() protoreflect.Message
type TemplateFilter ¶
type TemplateFilter struct {
WorkflowTemplateId *int32 `protobuf:"varint,1,opt,name=workflow_template_id,json=workflowTemplateId,proto3,oneof" json:"workflow_template_id,omitempty"`
Name *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
Version *string `protobuf:"bytes,3,opt,name=version,proto3,oneof" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*TemplateFilter) Descriptor
deprecated
func (*TemplateFilter) Descriptor() ([]byte, []int)
Deprecated: Use TemplateFilter.ProtoReflect.Descriptor instead.
func (*TemplateFilter) GetName ¶
func (x *TemplateFilter) GetName() string
func (*TemplateFilter) GetVersion ¶
func (x *TemplateFilter) GetVersion() string
func (*TemplateFilter) GetWorkflowTemplateId ¶
func (x *TemplateFilter) GetWorkflowTemplateId() int32
func (*TemplateFilter) ProtoMessage ¶
func (*TemplateFilter) ProtoMessage()
func (*TemplateFilter) ProtoReflect ¶
func (x *TemplateFilter) ProtoReflect() protoreflect.Message
func (*TemplateFilter) Reset ¶
func (x *TemplateFilter) Reset()
func (*TemplateFilter) String ¶
func (x *TemplateFilter) String() string
type TemplateList ¶
type TemplateList struct {
Templates []*Template `protobuf:"bytes,1,rep,name=templates,proto3" json:"templates,omitempty"`
// contains filtered or unexported fields
}
func (*TemplateList) Descriptor
deprecated
func (*TemplateList) Descriptor() ([]byte, []int)
Deprecated: Use TemplateList.ProtoReflect.Descriptor instead.
func (*TemplateList) GetTemplates ¶
func (x *TemplateList) GetTemplates() []*Template
func (*TemplateList) ProtoMessage ¶
func (*TemplateList) ProtoMessage()
func (*TemplateList) ProtoReflect ¶
func (x *TemplateList) ProtoReflect() protoreflect.Message
func (*TemplateList) Reset ¶
func (x *TemplateList) Reset()
func (*TemplateList) String ¶
func (x *TemplateList) String() string
type TemplateRun ¶
type TemplateRun struct {
TemplateRunId int32 `protobuf:"varint,1,opt,name=template_run_id,json=templateRunId,proto3" json:"template_run_id,omitempty"`
WorkflowTemplateId int32 `protobuf:"varint,2,opt,name=workflow_template_id,json=workflowTemplateId,proto3" json:"workflow_template_id,omitempty"`
TemplateName *string `protobuf:"bytes,3,opt,name=template_name,json=templateName,proto3,oneof" json:"template_name,omitempty"`
TemplateVersion *string `protobuf:"bytes,4,opt,name=template_version,json=templateVersion,proto3,oneof" json:"template_version,omitempty"`
WorkflowName *string `protobuf:"bytes,5,opt,name=workflow_name,json=workflowName,proto3,oneof" json:"workflow_name,omitempty"`
RunBy *int32 `protobuf:"varint,6,opt,name=run_by,json=runBy,proto3,oneof" json:"run_by,omitempty"`
Status string `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"`
WorkflowId *int32 `protobuf:"varint,8,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
CreatedAt string `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
ParamValuesJson string `protobuf:"bytes,10,opt,name=param_values_json,json=paramValuesJson,proto3" json:"param_values_json,omitempty"`
ErrorMessage *string `protobuf:"bytes,11,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"`
RunByUsername *string `protobuf:"bytes,12,opt,name=run_by_username,json=runByUsername,proto3,oneof" json:"run_by_username,omitempty"`
// contains filtered or unexported fields
}
func (*TemplateRun) Descriptor
deprecated
func (*TemplateRun) Descriptor() ([]byte, []int)
Deprecated: Use TemplateRun.ProtoReflect.Descriptor instead.
func (*TemplateRun) GetCreatedAt ¶
func (x *TemplateRun) GetCreatedAt() string
func (*TemplateRun) GetErrorMessage ¶
func (x *TemplateRun) GetErrorMessage() string
func (*TemplateRun) GetParamValuesJson ¶
func (x *TemplateRun) GetParamValuesJson() string
func (*TemplateRun) GetRunBy ¶
func (x *TemplateRun) GetRunBy() int32
func (*TemplateRun) GetRunByUsername ¶
func (x *TemplateRun) GetRunByUsername() string
func (*TemplateRun) GetStatus ¶
func (x *TemplateRun) GetStatus() string
func (*TemplateRun) GetTemplateName ¶
func (x *TemplateRun) GetTemplateName() string
func (*TemplateRun) GetTemplateRunId ¶
func (x *TemplateRun) GetTemplateRunId() int32
func (*TemplateRun) GetTemplateVersion ¶
func (x *TemplateRun) GetTemplateVersion() string
func (*TemplateRun) GetWorkflowId ¶
func (x *TemplateRun) GetWorkflowId() int32
func (*TemplateRun) GetWorkflowName ¶
func (x *TemplateRun) GetWorkflowName() string
func (*TemplateRun) GetWorkflowTemplateId ¶
func (x *TemplateRun) GetWorkflowTemplateId() int32
func (*TemplateRun) ProtoMessage ¶
func (*TemplateRun) ProtoMessage()
func (*TemplateRun) ProtoReflect ¶
func (x *TemplateRun) ProtoReflect() protoreflect.Message
func (*TemplateRun) Reset ¶
func (x *TemplateRun) Reset()
func (*TemplateRun) String ¶
func (x *TemplateRun) String() string
type TemplateRunFilter ¶
type TemplateRunFilter struct {
WorkflowTemplateId *int32 `protobuf:"varint,1,opt,name=workflow_template_id,json=workflowTemplateId,proto3,oneof" json:"workflow_template_id,omitempty"`
// contains filtered or unexported fields
}
func (*TemplateRunFilter) Descriptor
deprecated
func (*TemplateRunFilter) Descriptor() ([]byte, []int)
Deprecated: Use TemplateRunFilter.ProtoReflect.Descriptor instead.
func (*TemplateRunFilter) GetWorkflowTemplateId ¶
func (x *TemplateRunFilter) GetWorkflowTemplateId() int32
func (*TemplateRunFilter) ProtoMessage ¶
func (*TemplateRunFilter) ProtoMessage()
func (*TemplateRunFilter) ProtoReflect ¶
func (x *TemplateRunFilter) ProtoReflect() protoreflect.Message
func (*TemplateRunFilter) Reset ¶
func (x *TemplateRunFilter) Reset()
func (*TemplateRunFilter) String ¶
func (x *TemplateRunFilter) String() string
type TemplateRunList ¶
type TemplateRunList struct {
Runs []*TemplateRun `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
// contains filtered or unexported fields
}
func (*TemplateRunList) Descriptor
deprecated
func (*TemplateRunList) Descriptor() ([]byte, []int)
Deprecated: Use TemplateRunList.ProtoReflect.Descriptor instead.
func (*TemplateRunList) GetRuns ¶
func (x *TemplateRunList) GetRuns() []*TemplateRun
func (*TemplateRunList) ProtoMessage ¶
func (*TemplateRunList) ProtoMessage()
func (*TemplateRunList) ProtoReflect ¶
func (x *TemplateRunList) ProtoReflect() protoreflect.Message
func (*TemplateRunList) Reset ¶
func (x *TemplateRunList) Reset()
func (*TemplateRunList) String ¶
func (x *TemplateRunList) String() string
type Token ¶
type Token struct {
Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
// contains filtered or unexported fields
}
func (*Token) Descriptor
deprecated
func (*Token) ProtoMessage ¶
func (*Token) ProtoMessage()
func (*Token) ProtoReflect ¶
func (x *Token) ProtoReflect() protoreflect.Message
type UnimplementedTaskQueueServer ¶
type UnimplementedTaskQueueServer struct{}
UnimplementedTaskQueueServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedTaskQueueServer) ChangePassword ¶
func (UnimplementedTaskQueueServer) ChangePassword(context.Context, *ChangePasswordRequest) (*Ack, error)
func (UnimplementedTaskQueueServer) CreateFlavor ¶
func (UnimplementedTaskQueueServer) CreateFlavor(context.Context, *FlavorCreateRequest) (*FlavorId, error)
func (UnimplementedTaskQueueServer) CreateRecruiter ¶
func (UnimplementedTaskQueueServer) CreateStep ¶
func (UnimplementedTaskQueueServer) CreateStep(context.Context, *StepRequest) (*StepId, error)
func (UnimplementedTaskQueueServer) CreateUser ¶
func (UnimplementedTaskQueueServer) CreateUser(context.Context, *CreateUserRequest) (*UserId, error)
func (UnimplementedTaskQueueServer) CreateWorker ¶
func (UnimplementedTaskQueueServer) CreateWorker(context.Context, *WorkerRequest) (*WorkerIds, error)
func (UnimplementedTaskQueueServer) CreateWorkflow ¶
func (UnimplementedTaskQueueServer) CreateWorkflow(context.Context, *WorkflowRequest) (*WorkflowId, error)
func (UnimplementedTaskQueueServer) DebugAssignTask ¶
func (UnimplementedTaskQueueServer) DebugAssignTask(context.Context, *DebugAssignRequest) (*Ack, error)
func (UnimplementedTaskQueueServer) DebugRecruitStep ¶
func (UnimplementedTaskQueueServer) DebugRecruitStep(context.Context, *DebugRecruitRequest) (*Ack, error)
func (UnimplementedTaskQueueServer) DebugRetryTask ¶
func (UnimplementedTaskQueueServer) DebugRetryTask(context.Context, *RetryTaskRequest) (*TaskResponse, error)
func (UnimplementedTaskQueueServer) DeleteRecruiter ¶
func (UnimplementedTaskQueueServer) DeleteRecruiter(context.Context, *RecruiterId) (*Ack, error)
func (UnimplementedTaskQueueServer) DeleteStep ¶
func (UnimplementedTaskQueueServer) DeleteTemplateRun ¶
func (UnimplementedTaskQueueServer) DeleteTemplateRun(context.Context, *DeleteTemplateRunRequest) (*Ack, error)
func (UnimplementedTaskQueueServer) DeleteUser ¶
func (UnimplementedTaskQueueServer) DeleteWorker ¶
func (UnimplementedTaskQueueServer) DeleteWorker(context.Context, *WorkerDeletion) (*JobId, error)
func (UnimplementedTaskQueueServer) DeleteWorkerEvent ¶
func (UnimplementedTaskQueueServer) DeleteWorkerEvent(context.Context, *WorkerEventId) (*Ack, error)
func (UnimplementedTaskQueueServer) DeleteWorkflow ¶
func (UnimplementedTaskQueueServer) DeleteWorkflow(context.Context, *WorkflowId) (*Ack, error)
func (UnimplementedTaskQueueServer) FetchInfo ¶
func (UnimplementedTaskQueueServer) FetchInfo(context.Context, *FetchListRequest) (*FetchInfoResponse, error)
func (UnimplementedTaskQueueServer) FetchList ¶
func (UnimplementedTaskQueueServer) FetchList(context.Context, *FetchListRequest) (*FetchListResponse, error)
func (UnimplementedTaskQueueServer) GetCertificate ¶
func (UnimplementedTaskQueueServer) GetCertificate(context.Context, *emptypb.Empty) (*Certificate, error)
func (UnimplementedTaskQueueServer) GetDockerCredentials ¶
func (UnimplementedTaskQueueServer) GetDockerCredentials(context.Context, *emptypb.Empty) (*DockerCredentials, error)
func (UnimplementedTaskQueueServer) GetJobStatuses ¶
func (UnimplementedTaskQueueServer) GetJobStatuses(context.Context, *JobStatusRequest) (*JobStatusResponse, error)
func (UnimplementedTaskQueueServer) GetLogsChunk ¶
func (UnimplementedTaskQueueServer) GetLogsChunk(context.Context, *GetLogsRequest) (*LogChunkList, error)
func (UnimplementedTaskQueueServer) GetRcloneConfig ¶
func (UnimplementedTaskQueueServer) GetRcloneConfig(context.Context, *emptypb.Empty) (*RcloneRemotes, error)
func (UnimplementedTaskQueueServer) GetStepStats ¶
func (UnimplementedTaskQueueServer) GetStepStats(context.Context, *StepStatsRequest) (*StepStatsResponse, error)
func (UnimplementedTaskQueueServer) GetTaskStatusCounts ¶ added in v0.6.1
func (UnimplementedTaskQueueServer) GetTaskStatusCounts(context.Context, *TaskStatusCountsRequest) (*TaskStatusCountsResponse, error)
func (UnimplementedTaskQueueServer) GetWorkerStats ¶
func (UnimplementedTaskQueueServer) GetWorkerStats(context.Context, *GetWorkerStatsRequest) (*GetWorkerStatsResponse, error)
func (UnimplementedTaskQueueServer) GetWorkerStatuses ¶
func (UnimplementedTaskQueueServer) GetWorkerStatuses(context.Context, *WorkerStatusRequest) (*WorkerStatusResponse, error)
func (UnimplementedTaskQueueServer) GetWorkspaceRoot ¶
func (UnimplementedTaskQueueServer) GetWorkspaceRoot(context.Context, *WorkspaceRootRequest) (*WorkspaceRootResponse, error)
func (UnimplementedTaskQueueServer) ListDependentPendingTasks ¶
func (UnimplementedTaskQueueServer) ListFlavors ¶
func (UnimplementedTaskQueueServer) ListFlavors(context.Context, *ListFlavorsRequest) (*FlavorsList, error)
func (UnimplementedTaskQueueServer) ListJobs ¶
func (UnimplementedTaskQueueServer) ListJobs(context.Context, *ListJobsRequest) (*JobsList, error)
func (UnimplementedTaskQueueServer) ListProviders ¶
func (UnimplementedTaskQueueServer) ListProviders(context.Context, *emptypb.Empty) (*ProviderList, error)
func (UnimplementedTaskQueueServer) ListRecruiters ¶
func (UnimplementedTaskQueueServer) ListRecruiters(context.Context, *RecruiterFilter) (*RecruiterList, error)
func (UnimplementedTaskQueueServer) ListRegions ¶
func (UnimplementedTaskQueueServer) ListRegions(context.Context, *emptypb.Empty) (*RegionList, error)
func (UnimplementedTaskQueueServer) ListSteps ¶
func (UnimplementedTaskQueueServer) ListSteps(context.Context, *StepFilter) (*StepList, error)
func (UnimplementedTaskQueueServer) ListTasks ¶
func (UnimplementedTaskQueueServer) ListTasks(context.Context, *ListTasksRequest) (*TaskList, error)
func (UnimplementedTaskQueueServer) ListTemplateRuns ¶
func (UnimplementedTaskQueueServer) ListTemplateRuns(context.Context, *TemplateRunFilter) (*TemplateRunList, error)
func (UnimplementedTaskQueueServer) ListTemplates ¶
func (UnimplementedTaskQueueServer) ListTemplates(context.Context, *TemplateFilter) (*TemplateList, error)
func (UnimplementedTaskQueueServer) ListWorkerEvents ¶
func (UnimplementedTaskQueueServer) ListWorkerEvents(context.Context, *WorkerEventFilter) (*WorkerEventList, error)
func (UnimplementedTaskQueueServer) ListWorkers ¶
func (UnimplementedTaskQueueServer) ListWorkers(context.Context, *ListWorkersRequest) (*WorkersList, error)
func (UnimplementedTaskQueueServer) ListWorkflows ¶
func (UnimplementedTaskQueueServer) ListWorkflows(context.Context, *WorkflowFilter) (*WorkflowList, error)
func (UnimplementedTaskQueueServer) Login ¶
func (UnimplementedTaskQueueServer) Login(context.Context, *LoginRequest) (*LoginResponse, error)
func (UnimplementedTaskQueueServer) PingAndTakeNewTasks ¶
func (UnimplementedTaskQueueServer) PingAndTakeNewTasks(context.Context, *PingAndGetNewTasksRequest) (*TaskListAndOther, error)
func (UnimplementedTaskQueueServer) PruneWorkerEvents ¶
func (UnimplementedTaskQueueServer) PruneWorkerEvents(context.Context, *WorkerEventPruneFilter) (*WorkerEventPruneResult, error)
func (UnimplementedTaskQueueServer) RegisterSpecifications ¶
func (UnimplementedTaskQueueServer) RegisterSpecifications(context.Context, *ResourceSpec) (*Ack, error)
func (UnimplementedTaskQueueServer) RegisterWorker ¶
func (UnimplementedTaskQueueServer) RegisterWorker(context.Context, *WorkerInfo) (*WorkerId, error)
func (UnimplementedTaskQueueServer) ReportWorkerEvent ¶
func (UnimplementedTaskQueueServer) ReportWorkerEvent(context.Context, *WorkerEvent) (*Ack, error)
func (UnimplementedTaskQueueServer) RetryTask ¶
func (UnimplementedTaskQueueServer) RetryTask(context.Context, *RetryTaskRequest) (*TaskResponse, error)
func (UnimplementedTaskQueueServer) RunTemplate ¶
func (UnimplementedTaskQueueServer) RunTemplate(context.Context, *RunTemplateRequest) (*TemplateRun, error)
func (UnimplementedTaskQueueServer) SendTaskLogs ¶
func (UnimplementedTaskQueueServer) SendTaskLogs(grpc.ClientStreamingServer[TaskLog, Ack]) error
func (UnimplementedTaskQueueServer) StreamTaskLogsErr ¶
func (UnimplementedTaskQueueServer) StreamTaskLogsErr(*TaskId, grpc.ServerStreamingServer[TaskLog]) error
func (UnimplementedTaskQueueServer) StreamTaskLogsOutput ¶
func (UnimplementedTaskQueueServer) StreamTaskLogsOutput(*TaskId, grpc.ServerStreamingServer[TaskLog]) error
func (UnimplementedTaskQueueServer) SubmitTask ¶
func (UnimplementedTaskQueueServer) SubmitTask(context.Context, *TaskRequest) (*TaskResponse, error)
func (UnimplementedTaskQueueServer) UpdateRecruiter ¶
func (UnimplementedTaskQueueServer) UpdateRecruiter(context.Context, *RecruiterUpdate) (*Ack, error)
func (UnimplementedTaskQueueServer) UpdateTaskStatus ¶
func (UnimplementedTaskQueueServer) UpdateTaskStatus(context.Context, *TaskStatusUpdate) (*Ack, error)
func (UnimplementedTaskQueueServer) UpdateTemplateRun ¶
func (UnimplementedTaskQueueServer) UpdateTemplateRun(context.Context, *UpdateTemplateRunRequest) (*Ack, error)
func (UnimplementedTaskQueueServer) UpdateUser ¶
func (UnimplementedTaskQueueServer) UpdateWorker ¶
func (UnimplementedTaskQueueServer) UpdateWorker(context.Context, *WorkerUpdateRequest) (*Ack, error)
func (UnimplementedTaskQueueServer) UpdateWorkerStatus ¶
func (UnimplementedTaskQueueServer) UpdateWorkerStatus(context.Context, *WorkerStatus) (*Ack, error)
func (UnimplementedTaskQueueServer) UpdateWorkflowStatus ¶
func (UnimplementedTaskQueueServer) UpdateWorkflowStatus(context.Context, *WorkflowStatusUpdate) (*Ack, error)
func (UnimplementedTaskQueueServer) UploadTemplate ¶
func (UnimplementedTaskQueueServer) UploadTemplate(context.Context, *UploadTemplateRequest) (*UploadTemplateResponse, error)
func (UnimplementedTaskQueueServer) UserUpdateWorker ¶
func (UnimplementedTaskQueueServer) UserUpdateWorker(context.Context, *WorkerUpdateRequest) (*Ack, error)
type UnsafeTaskQueueServer ¶
type UnsafeTaskQueueServer interface {
// contains filtered or unexported methods
}
UnsafeTaskQueueServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskQueueServer will result in compilation errors.
type UpdateTemplateRunRequest ¶
type UpdateTemplateRunRequest struct {
TemplateRunId int32 `protobuf:"varint,1,opt,name=template_run_id,json=templateRunId,proto3" json:"template_run_id,omitempty"`
WorkflowId *int32 `protobuf:"varint,2,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
ErrorMessage *string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateTemplateRunRequest) Descriptor
deprecated
func (*UpdateTemplateRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateTemplateRunRequest.ProtoReflect.Descriptor instead.
func (*UpdateTemplateRunRequest) GetErrorMessage ¶
func (x *UpdateTemplateRunRequest) GetErrorMessage() string
func (*UpdateTemplateRunRequest) GetTemplateRunId ¶
func (x *UpdateTemplateRunRequest) GetTemplateRunId() int32
func (*UpdateTemplateRunRequest) GetWorkflowId ¶
func (x *UpdateTemplateRunRequest) GetWorkflowId() int32
func (*UpdateTemplateRunRequest) ProtoMessage ¶
func (*UpdateTemplateRunRequest) ProtoMessage()
func (*UpdateTemplateRunRequest) ProtoReflect ¶
func (x *UpdateTemplateRunRequest) ProtoReflect() protoreflect.Message
func (*UpdateTemplateRunRequest) Reset ¶
func (x *UpdateTemplateRunRequest) Reset()
func (*UpdateTemplateRunRequest) String ¶
func (x *UpdateTemplateRunRequest) String() string
type UploadTemplateRequest ¶
type UploadTemplateRequest struct {
Script []byte `protobuf:"bytes,1,opt,name=script,proto3" json:"script,omitempty"`
Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
// contains filtered or unexported fields
}
func (*UploadTemplateRequest) Descriptor
deprecated
func (*UploadTemplateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UploadTemplateRequest.ProtoReflect.Descriptor instead.
func (*UploadTemplateRequest) GetForce ¶
func (x *UploadTemplateRequest) GetForce() bool
func (*UploadTemplateRequest) GetScript ¶
func (x *UploadTemplateRequest) GetScript() []byte
func (*UploadTemplateRequest) ProtoMessage ¶
func (*UploadTemplateRequest) ProtoMessage()
func (*UploadTemplateRequest) ProtoReflect ¶
func (x *UploadTemplateRequest) ProtoReflect() protoreflect.Message
func (*UploadTemplateRequest) Reset ¶
func (x *UploadTemplateRequest) Reset()
func (*UploadTemplateRequest) String ¶
func (x *UploadTemplateRequest) String() string
type UploadTemplateResponse ¶
type UploadTemplateResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
WorkflowTemplateId *int32 `protobuf:"varint,3,opt,name=workflow_template_id,json=workflowTemplateId,proto3,oneof" json:"workflow_template_id,omitempty"`
Name *string `protobuf:"bytes,4,opt,name=name,proto3,oneof" json:"name,omitempty"`
Version *string `protobuf:"bytes,5,opt,name=version,proto3,oneof" json:"version,omitempty"`
Description *string `protobuf:"bytes,6,opt,name=description,proto3,oneof" json:"description,omitempty"`
ParamJson *string `protobuf:"bytes,7,opt,name=param_json,json=paramJson,proto3,oneof" json:"param_json,omitempty"`
// contains filtered or unexported fields
}
func (*UploadTemplateResponse) Descriptor
deprecated
func (*UploadTemplateResponse) Descriptor() ([]byte, []int)
Deprecated: Use UploadTemplateResponse.ProtoReflect.Descriptor instead.
func (*UploadTemplateResponse) GetDescription ¶
func (x *UploadTemplateResponse) GetDescription() string
func (*UploadTemplateResponse) GetMessage ¶
func (x *UploadTemplateResponse) GetMessage() string
func (*UploadTemplateResponse) GetName ¶
func (x *UploadTemplateResponse) GetName() string
func (*UploadTemplateResponse) GetParamJson ¶
func (x *UploadTemplateResponse) GetParamJson() string
func (*UploadTemplateResponse) GetSuccess ¶
func (x *UploadTemplateResponse) GetSuccess() bool
func (*UploadTemplateResponse) GetVersion ¶
func (x *UploadTemplateResponse) GetVersion() string
func (*UploadTemplateResponse) GetWorkflowTemplateId ¶
func (x *UploadTemplateResponse) GetWorkflowTemplateId() int32
func (*UploadTemplateResponse) ProtoMessage ¶
func (*UploadTemplateResponse) ProtoMessage()
func (*UploadTemplateResponse) ProtoReflect ¶
func (x *UploadTemplateResponse) ProtoReflect() protoreflect.Message
func (*UploadTemplateResponse) Reset ¶
func (x *UploadTemplateResponse) Reset()
func (*UploadTemplateResponse) String ¶
func (x *UploadTemplateResponse) String() string
type User ¶
type User struct {
UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
Username *string `protobuf:"bytes,2,opt,name=username,proto3,oneof" json:"username,omitempty"`
Email *string `protobuf:"bytes,3,opt,name=email,proto3,oneof" json:"email,omitempty"`
IsAdmin *bool `protobuf:"varint,4,opt,name=is_admin,json=isAdmin,proto3,oneof" json:"is_admin,omitempty"`
// contains filtered or unexported fields
}
func (*User) Descriptor
deprecated
func (*User) GetIsAdmin ¶
func (*User) GetUsername ¶
func (*User) ProtoMessage ¶
func (*User) ProtoMessage()
func (*User) ProtoReflect ¶
func (x *User) ProtoReflect() protoreflect.Message
type UserId ¶
type UserId struct {
UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
// contains filtered or unexported fields
}
func (*UserId) Descriptor
deprecated
func (*UserId) ProtoMessage ¶
func (*UserId) ProtoMessage()
func (*UserId) ProtoReflect ¶
func (x *UserId) ProtoReflect() protoreflect.Message
type UsersList ¶
type UsersList struct {
Users []*User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
// contains filtered or unexported fields
}
func (*UsersList) Descriptor
deprecated
func (*UsersList) ProtoMessage ¶
func (*UsersList) ProtoMessage()
func (*UsersList) ProtoReflect ¶
func (x *UsersList) ProtoReflect() protoreflect.Message
type Worker ¶
type Worker struct {
WorkerId int32 `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Concurrency int32 `protobuf:"varint,3,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
Prefetch int32 `protobuf:"varint,4,opt,name=prefetch,proto3" json:"prefetch,omitempty"`
Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
Ipv4 string `protobuf:"bytes,6,opt,name=ipv4,proto3" json:"ipv4,omitempty"`
Ipv6 string `protobuf:"bytes,7,opt,name=ipv6,proto3" json:"ipv6,omitempty"`
Flavor string `protobuf:"bytes,8,opt,name=flavor,proto3" json:"flavor,omitempty"`
Provider string `protobuf:"bytes,9,opt,name=provider,proto3" json:"provider,omitempty"`
Region string `protobuf:"bytes,10,opt,name=region,proto3" json:"region,omitempty"`
StepId *int32 `protobuf:"varint,11,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
StepName *string `protobuf:"bytes,12,opt,name=step_name,json=stepName,proto3,oneof" json:"step_name,omitempty"`
IsPermanent bool `protobuf:"varint,13,opt,name=is_permanent,json=isPermanent,proto3" json:"is_permanent,omitempty"`
RecyclableScope string `protobuf:"bytes,14,opt,name=recyclable_scope,json=recyclableScope,proto3" json:"recyclable_scope,omitempty"`
WorkflowId *int32 `protobuf:"varint,15,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
WorkflowName *string `protobuf:"bytes,16,opt,name=workflow_name,json=workflowName,proto3,oneof" json:"workflow_name,omitempty"`
// contains filtered or unexported fields
}
func (*Worker) Descriptor
deprecated
func (*Worker) GetConcurrency ¶
func (*Worker) GetIsPermanent ¶
func (*Worker) GetPrefetch ¶
func (*Worker) GetProvider ¶
func (*Worker) GetRecyclableScope ¶
func (*Worker) GetStepName ¶
func (*Worker) GetWorkerId ¶
func (*Worker) GetWorkflowId ¶
func (*Worker) GetWorkflowName ¶
func (*Worker) ProtoMessage ¶
func (*Worker) ProtoMessage()
func (*Worker) ProtoReflect ¶
func (x *Worker) ProtoReflect() protoreflect.Message
type WorkerDeletion ¶
type WorkerDeletion struct {
WorkerId int32 `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
Undeployed *bool `protobuf:"varint,2,opt,name=undeployed,proto3,oneof" json:"undeployed,omitempty"` // if true, the worker is already undeployed so deletion can proceed
// contains filtered or unexported fields
}
func (*WorkerDeletion) Descriptor
deprecated
func (*WorkerDeletion) Descriptor() ([]byte, []int)
Deprecated: Use WorkerDeletion.ProtoReflect.Descriptor instead.
func (*WorkerDeletion) GetUndeployed ¶
func (x *WorkerDeletion) GetUndeployed() bool
func (*WorkerDeletion) GetWorkerId ¶
func (x *WorkerDeletion) GetWorkerId() int32
func (*WorkerDeletion) ProtoMessage ¶
func (*WorkerDeletion) ProtoMessage()
func (*WorkerDeletion) ProtoReflect ¶
func (x *WorkerDeletion) ProtoReflect() protoreflect.Message
func (*WorkerDeletion) Reset ¶
func (x *WorkerDeletion) Reset()
func (*WorkerDeletion) String ¶
func (x *WorkerDeletion) String() string
type WorkerDetails ¶
type WorkerDetails struct {
WorkerId int32 `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
WorkerName string `protobuf:"bytes,2,opt,name=worker_name,json=workerName,proto3" json:"worker_name,omitempty"`
JobId int32 `protobuf:"varint,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerDetails) Descriptor
deprecated
func (*WorkerDetails) Descriptor() ([]byte, []int)
Deprecated: Use WorkerDetails.ProtoReflect.Descriptor instead.
func (*WorkerDetails) GetJobId ¶
func (x *WorkerDetails) GetJobId() int32
func (*WorkerDetails) GetWorkerId ¶
func (x *WorkerDetails) GetWorkerId() int32
func (*WorkerDetails) GetWorkerName ¶
func (x *WorkerDetails) GetWorkerName() string
func (*WorkerDetails) ProtoMessage ¶
func (*WorkerDetails) ProtoMessage()
func (*WorkerDetails) ProtoReflect ¶
func (x *WorkerDetails) ProtoReflect() protoreflect.Message
func (*WorkerDetails) Reset ¶
func (x *WorkerDetails) Reset()
func (*WorkerDetails) String ¶
func (x *WorkerDetails) String() string
type WorkerEvent ¶
type WorkerEvent struct {
// optional because a worker may fail before registration
WorkerId *int32 `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
WorkerName string `protobuf:"bytes,2,opt,name=worker_name,json=workerName,proto3" json:"worker_name,omitempty"` // free text (hostname or generated name)
Level string `protobuf:"bytes,3,opt,name=level,proto3" json:"level,omitempty"` // single letter: D/I/W/E
EventClass string `protobuf:"bytes,4,opt,name=event_class,json=eventClass,proto3" json:"event_class,omitempty"` // e.g. "install", "bootstrap", "runtime", "network"
Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"` // short human description
DetailsJson string `protobuf:"bytes,6,opt,name=details_json,json=detailsJson,proto3" json:"details_json,omitempty"` // raw JSON string (optional)
// contains filtered or unexported fields
}
func (*WorkerEvent) Descriptor
deprecated
func (*WorkerEvent) Descriptor() ([]byte, []int)
Deprecated: Use WorkerEvent.ProtoReflect.Descriptor instead.
func (*WorkerEvent) GetDetailsJson ¶
func (x *WorkerEvent) GetDetailsJson() string
func (*WorkerEvent) GetEventClass ¶
func (x *WorkerEvent) GetEventClass() string
func (*WorkerEvent) GetLevel ¶
func (x *WorkerEvent) GetLevel() string
func (*WorkerEvent) GetMessage ¶
func (x *WorkerEvent) GetMessage() string
func (*WorkerEvent) GetWorkerId ¶
func (x *WorkerEvent) GetWorkerId() int32
func (*WorkerEvent) GetWorkerName ¶
func (x *WorkerEvent) GetWorkerName() string
func (*WorkerEvent) ProtoMessage ¶
func (*WorkerEvent) ProtoMessage()
func (*WorkerEvent) ProtoReflect ¶
func (x *WorkerEvent) ProtoReflect() protoreflect.Message
func (*WorkerEvent) Reset ¶
func (x *WorkerEvent) Reset()
func (*WorkerEvent) String ¶
func (x *WorkerEvent) String() string
type WorkerEventFilter ¶
type WorkerEventFilter struct {
WorkerId *int32 `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
Level *string `protobuf:"bytes,2,opt,name=level,proto3,oneof" json:"level,omitempty"` // 'D','I','W','E'
Class *string `protobuf:"bytes,3,opt,name=class,proto3,oneof" json:"class,omitempty"` // event_class filter
Limit *int32 `protobuf:"varint,4,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // max number of events (default 50)
// contains filtered or unexported fields
}
func (*WorkerEventFilter) Descriptor
deprecated
func (*WorkerEventFilter) Descriptor() ([]byte, []int)
Deprecated: Use WorkerEventFilter.ProtoReflect.Descriptor instead.
func (*WorkerEventFilter) GetClass ¶
func (x *WorkerEventFilter) GetClass() string
func (*WorkerEventFilter) GetLevel ¶
func (x *WorkerEventFilter) GetLevel() string
func (*WorkerEventFilter) GetLimit ¶
func (x *WorkerEventFilter) GetLimit() int32
func (*WorkerEventFilter) GetWorkerId ¶
func (x *WorkerEventFilter) GetWorkerId() int32
func (*WorkerEventFilter) ProtoMessage ¶
func (*WorkerEventFilter) ProtoMessage()
func (*WorkerEventFilter) ProtoReflect ¶
func (x *WorkerEventFilter) ProtoReflect() protoreflect.Message
func (*WorkerEventFilter) Reset ¶
func (x *WorkerEventFilter) Reset()
func (*WorkerEventFilter) String ¶
func (x *WorkerEventFilter) String() string
type WorkerEventId ¶
type WorkerEventId struct {
EventId int32 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerEventId) Descriptor
deprecated
func (*WorkerEventId) Descriptor() ([]byte, []int)
Deprecated: Use WorkerEventId.ProtoReflect.Descriptor instead.
func (*WorkerEventId) GetEventId ¶
func (x *WorkerEventId) GetEventId() int32
func (*WorkerEventId) ProtoMessage ¶
func (*WorkerEventId) ProtoMessage()
func (*WorkerEventId) ProtoReflect ¶
func (x *WorkerEventId) ProtoReflect() protoreflect.Message
func (*WorkerEventId) Reset ¶
func (x *WorkerEventId) Reset()
func (*WorkerEventId) String ¶
func (x *WorkerEventId) String() string
type WorkerEventList ¶
type WorkerEventList struct {
Events []*WorkerEventRecord `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerEventList) Descriptor
deprecated
func (*WorkerEventList) Descriptor() ([]byte, []int)
Deprecated: Use WorkerEventList.ProtoReflect.Descriptor instead.
func (*WorkerEventList) GetEvents ¶
func (x *WorkerEventList) GetEvents() []*WorkerEventRecord
func (*WorkerEventList) ProtoMessage ¶
func (*WorkerEventList) ProtoMessage()
func (*WorkerEventList) ProtoReflect ¶
func (x *WorkerEventList) ProtoReflect() protoreflect.Message
func (*WorkerEventList) Reset ¶
func (x *WorkerEventList) Reset()
func (*WorkerEventList) String ¶
func (x *WorkerEventList) String() string
type WorkerEventPruneFilter ¶
type WorkerEventPruneFilter struct {
Before *string `protobuf:"bytes,1,opt,name=before,proto3,oneof" json:"before,omitempty"` // RFC3339 UTC, e.g. "2025-08-19T00:00:00Z"
Level *string `protobuf:"bytes,2,opt,name=level,proto3,oneof" json:"level,omitempty"` // 'D'|'I'|'W'|'E'
Class *string `protobuf:"bytes,3,opt,name=class,proto3,oneof" json:"class,omitempty"` // event_class exact match
WorkerId *int32 `protobuf:"varint,4,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
DryRun bool `protobuf:"varint,5,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"` // if true, count only; no deletion
// contains filtered or unexported fields
}
func (*WorkerEventPruneFilter) Descriptor
deprecated
func (*WorkerEventPruneFilter) Descriptor() ([]byte, []int)
Deprecated: Use WorkerEventPruneFilter.ProtoReflect.Descriptor instead.
func (*WorkerEventPruneFilter) GetBefore ¶
func (x *WorkerEventPruneFilter) GetBefore() string
func (*WorkerEventPruneFilter) GetClass ¶
func (x *WorkerEventPruneFilter) GetClass() string
func (*WorkerEventPruneFilter) GetDryRun ¶
func (x *WorkerEventPruneFilter) GetDryRun() bool
func (*WorkerEventPruneFilter) GetLevel ¶
func (x *WorkerEventPruneFilter) GetLevel() string
func (*WorkerEventPruneFilter) GetWorkerId ¶
func (x *WorkerEventPruneFilter) GetWorkerId() int32
func (*WorkerEventPruneFilter) ProtoMessage ¶
func (*WorkerEventPruneFilter) ProtoMessage()
func (*WorkerEventPruneFilter) ProtoReflect ¶
func (x *WorkerEventPruneFilter) ProtoReflect() protoreflect.Message
func (*WorkerEventPruneFilter) Reset ¶
func (x *WorkerEventPruneFilter) Reset()
func (*WorkerEventPruneFilter) String ¶
func (x *WorkerEventPruneFilter) String() string
type WorkerEventPruneResult ¶
type WorkerEventPruneResult struct {
Matched int32 `protobuf:"varint,1,opt,name=matched,proto3" json:"matched,omitempty"`
Deleted int32 `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerEventPruneResult) Descriptor
deprecated
func (*WorkerEventPruneResult) Descriptor() ([]byte, []int)
Deprecated: Use WorkerEventPruneResult.ProtoReflect.Descriptor instead.
func (*WorkerEventPruneResult) GetDeleted ¶
func (x *WorkerEventPruneResult) GetDeleted() int32
func (*WorkerEventPruneResult) GetMatched ¶
func (x *WorkerEventPruneResult) GetMatched() int32
func (*WorkerEventPruneResult) ProtoMessage ¶
func (*WorkerEventPruneResult) ProtoMessage()
func (*WorkerEventPruneResult) ProtoReflect ¶
func (x *WorkerEventPruneResult) ProtoReflect() protoreflect.Message
func (*WorkerEventPruneResult) Reset ¶
func (x *WorkerEventPruneResult) Reset()
func (*WorkerEventPruneResult) String ¶
func (x *WorkerEventPruneResult) String() string
type WorkerEventRecord ¶
type WorkerEventRecord struct {
EventId int32 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
CreatedAt string `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
WorkerId *int32 `protobuf:"varint,3,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
WorkerName string `protobuf:"bytes,4,opt,name=worker_name,json=workerName,proto3" json:"worker_name,omitempty"`
Level string `protobuf:"bytes,5,opt,name=level,proto3" json:"level,omitempty"`
EventClass string `protobuf:"bytes,6,opt,name=event_class,json=eventClass,proto3" json:"event_class,omitempty"`
Message string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`
DetailsJson string `protobuf:"bytes,8,opt,name=details_json,json=detailsJson,proto3" json:"details_json,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerEventRecord) Descriptor
deprecated
func (*WorkerEventRecord) Descriptor() ([]byte, []int)
Deprecated: Use WorkerEventRecord.ProtoReflect.Descriptor instead.
func (*WorkerEventRecord) GetCreatedAt ¶
func (x *WorkerEventRecord) GetCreatedAt() string
func (*WorkerEventRecord) GetDetailsJson ¶
func (x *WorkerEventRecord) GetDetailsJson() string
func (*WorkerEventRecord) GetEventClass ¶
func (x *WorkerEventRecord) GetEventClass() string
func (*WorkerEventRecord) GetEventId ¶
func (x *WorkerEventRecord) GetEventId() int32
func (*WorkerEventRecord) GetLevel ¶
func (x *WorkerEventRecord) GetLevel() string
func (*WorkerEventRecord) GetMessage ¶
func (x *WorkerEventRecord) GetMessage() string
func (*WorkerEventRecord) GetWorkerId ¶
func (x *WorkerEventRecord) GetWorkerId() int32
func (*WorkerEventRecord) GetWorkerName ¶
func (x *WorkerEventRecord) GetWorkerName() string
func (*WorkerEventRecord) ProtoMessage ¶
func (*WorkerEventRecord) ProtoMessage()
func (*WorkerEventRecord) ProtoReflect ¶
func (x *WorkerEventRecord) ProtoReflect() protoreflect.Message
func (*WorkerEventRecord) Reset ¶
func (x *WorkerEventRecord) Reset()
func (*WorkerEventRecord) String ¶
func (x *WorkerEventRecord) String() string
type WorkerId ¶
type WorkerId struct {
WorkerId int32 `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerId) Descriptor
deprecated
func (*WorkerId) GetWorkerId ¶
func (*WorkerId) ProtoMessage ¶
func (*WorkerId) ProtoMessage()
func (*WorkerId) ProtoReflect ¶
func (x *WorkerId) ProtoReflect() protoreflect.Message
type WorkerIds ¶
type WorkerIds struct {
WorkersDetails []*WorkerDetails `protobuf:"bytes,1,rep,name=workers_details,json=workersDetails,proto3" json:"workers_details,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerIds) Descriptor
deprecated
func (*WorkerIds) GetWorkersDetails ¶
func (x *WorkerIds) GetWorkersDetails() []*WorkerDetails
func (*WorkerIds) ProtoMessage ¶
func (*WorkerIds) ProtoMessage()
func (*WorkerIds) ProtoReflect ¶
func (x *WorkerIds) ProtoReflect() protoreflect.Message
type WorkerInfo ¶
type WorkerInfo struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Concurrency *int32 `protobuf:"varint,2,opt,name=concurrency,proto3,oneof" json:"concurrency,omitempty"`
IsPermanent *bool `protobuf:"varint,3,opt,name=is_permanent,json=isPermanent,proto3,oneof" json:"is_permanent,omitempty"`
Provider *string `protobuf:"bytes,4,opt,name=provider,proto3,oneof" json:"provider,omitempty"`
Region *string `protobuf:"bytes,5,opt,name=region,proto3,oneof" json:"region,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerInfo) Descriptor
deprecated
func (*WorkerInfo) Descriptor() ([]byte, []int)
Deprecated: Use WorkerInfo.ProtoReflect.Descriptor instead.
func (*WorkerInfo) GetConcurrency ¶
func (x *WorkerInfo) GetConcurrency() int32
func (*WorkerInfo) GetIsPermanent ¶
func (x *WorkerInfo) GetIsPermanent() bool
func (*WorkerInfo) GetName ¶
func (x *WorkerInfo) GetName() string
func (*WorkerInfo) GetProvider ¶
func (x *WorkerInfo) GetProvider() string
func (*WorkerInfo) GetRegion ¶
func (x *WorkerInfo) GetRegion() string
func (*WorkerInfo) ProtoMessage ¶
func (*WorkerInfo) ProtoMessage()
func (*WorkerInfo) ProtoReflect ¶
func (x *WorkerInfo) ProtoReflect() protoreflect.Message
func (*WorkerInfo) Reset ¶
func (x *WorkerInfo) Reset()
func (*WorkerInfo) String ¶
func (x *WorkerInfo) String() string
type WorkerRequest ¶
type WorkerRequest struct {
ProviderId int32 `protobuf:"varint,1,opt,name=provider_id,json=providerId,proto3" json:"provider_id,omitempty"`
FlavorId int32 `protobuf:"varint,2,opt,name=flavor_id,json=flavorId,proto3" json:"flavor_id,omitempty"`
RegionId int32 `protobuf:"varint,3,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
Number int32 `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"`
Concurrency int32 `protobuf:"varint,5,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
Prefetch int32 `protobuf:"varint,6,opt,name=prefetch,proto3" json:"prefetch,omitempty"`
StepId *int32 `protobuf:"varint,7,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerRequest) Descriptor
deprecated
func (*WorkerRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkerRequest.ProtoReflect.Descriptor instead.
func (*WorkerRequest) GetConcurrency ¶
func (x *WorkerRequest) GetConcurrency() int32
func (*WorkerRequest) GetFlavorId ¶
func (x *WorkerRequest) GetFlavorId() int32
func (*WorkerRequest) GetNumber ¶
func (x *WorkerRequest) GetNumber() int32
func (*WorkerRequest) GetPrefetch ¶
func (x *WorkerRequest) GetPrefetch() int32
func (*WorkerRequest) GetProviderId ¶
func (x *WorkerRequest) GetProviderId() int32
func (*WorkerRequest) GetRegionId ¶
func (x *WorkerRequest) GetRegionId() int32
func (*WorkerRequest) GetStepId ¶
func (x *WorkerRequest) GetStepId() int32
func (*WorkerRequest) ProtoMessage ¶
func (*WorkerRequest) ProtoMessage()
func (*WorkerRequest) ProtoReflect ¶
func (x *WorkerRequest) ProtoReflect() protoreflect.Message
func (*WorkerRequest) Reset ¶
func (x *WorkerRequest) Reset()
func (*WorkerRequest) String ¶
func (x *WorkerRequest) String() string
type WorkerStats ¶
type WorkerStats struct {
CpuUsagePercent float32 `protobuf:"fixed32,1,opt,name=cpu_usage_percent,json=cpuUsagePercent,proto3" json:"cpu_usage_percent,omitempty"` // 0-100, float
MemUsagePercent float32 `protobuf:"fixed32,2,opt,name=mem_usage_percent,json=memUsagePercent,proto3" json:"mem_usage_percent,omitempty"` // 0-100, float
Load_1Min float32 `protobuf:"fixed32,3,opt,name=load_1min,json=load1min,proto3" json:"load_1min,omitempty"` // e.g., 0.58, float
IowaitPercent float32 `protobuf:"fixed32,4,opt,name=iowait_percent,json=iowaitPercent,proto3" json:"iowait_percent,omitempty"` // 0-100 float
Disks []*DiskUsage `protobuf:"bytes,5,rep,name=disks,proto3" json:"disks,omitempty"` // Per-disk usage
DiskIo *DiskIOStats `protobuf:"bytes,6,opt,name=disk_io,json=diskIo,proto3" json:"disk_io,omitempty"` // Global disk IO (aggregated)
NetIo *NetIOStats `protobuf:"bytes,7,opt,name=net_io,json=netIo,proto3" json:"net_io,omitempty"` // Global network IO (aggregated)
// contains filtered or unexported fields
}
func (*WorkerStats) Descriptor
deprecated
func (*WorkerStats) Descriptor() ([]byte, []int)
Deprecated: Use WorkerStats.ProtoReflect.Descriptor instead.
func (*WorkerStats) GetCpuUsagePercent ¶
func (x *WorkerStats) GetCpuUsagePercent() float32
func (*WorkerStats) GetDiskIo ¶
func (x *WorkerStats) GetDiskIo() *DiskIOStats
func (*WorkerStats) GetDisks ¶
func (x *WorkerStats) GetDisks() []*DiskUsage
func (*WorkerStats) GetIowaitPercent ¶
func (x *WorkerStats) GetIowaitPercent() float32
func (*WorkerStats) GetLoad_1Min ¶
func (x *WorkerStats) GetLoad_1Min() float32
func (*WorkerStats) GetMemUsagePercent ¶
func (x *WorkerStats) GetMemUsagePercent() float32
func (*WorkerStats) GetNetIo ¶
func (x *WorkerStats) GetNetIo() *NetIOStats
func (*WorkerStats) ProtoMessage ¶
func (*WorkerStats) ProtoMessage()
func (*WorkerStats) ProtoReflect ¶
func (x *WorkerStats) ProtoReflect() protoreflect.Message
func (*WorkerStats) Reset ¶
func (x *WorkerStats) Reset()
func (*WorkerStats) String ¶
func (x *WorkerStats) String() string
type WorkerStatus ¶
type WorkerStatus struct {
WorkerId int32 `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerStatus) Descriptor
deprecated
func (*WorkerStatus) Descriptor() ([]byte, []int)
Deprecated: Use WorkerStatus.ProtoReflect.Descriptor instead.
func (*WorkerStatus) GetStatus ¶
func (x *WorkerStatus) GetStatus() string
func (*WorkerStatus) GetWorkerId ¶
func (x *WorkerStatus) GetWorkerId() int32
func (*WorkerStatus) ProtoMessage ¶
func (*WorkerStatus) ProtoMessage()
func (*WorkerStatus) ProtoReflect ¶
func (x *WorkerStatus) ProtoReflect() protoreflect.Message
func (*WorkerStatus) Reset ¶
func (x *WorkerStatus) Reset()
func (*WorkerStatus) String ¶
func (x *WorkerStatus) String() string
type WorkerStatusRequest ¶
type WorkerStatusRequest struct {
WorkerIds []int32 `protobuf:"varint,1,rep,packed,name=worker_ids,json=workerIds,proto3" json:"worker_ids,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerStatusRequest) Descriptor
deprecated
func (*WorkerStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkerStatusRequest.ProtoReflect.Descriptor instead.
func (*WorkerStatusRequest) GetWorkerIds ¶
func (x *WorkerStatusRequest) GetWorkerIds() []int32
func (*WorkerStatusRequest) ProtoMessage ¶
func (*WorkerStatusRequest) ProtoMessage()
func (*WorkerStatusRequest) ProtoReflect ¶
func (x *WorkerStatusRequest) ProtoReflect() protoreflect.Message
func (*WorkerStatusRequest) Reset ¶
func (x *WorkerStatusRequest) Reset()
func (*WorkerStatusRequest) String ¶
func (x *WorkerStatusRequest) String() string
type WorkerStatusResponse ¶
type WorkerStatusResponse struct {
Statuses []*WorkerStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerStatusResponse) Descriptor
deprecated
func (*WorkerStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use WorkerStatusResponse.ProtoReflect.Descriptor instead.
func (*WorkerStatusResponse) GetStatuses ¶
func (x *WorkerStatusResponse) GetStatuses() []*WorkerStatus
func (*WorkerStatusResponse) ProtoMessage ¶
func (*WorkerStatusResponse) ProtoMessage()
func (*WorkerStatusResponse) ProtoReflect ¶
func (x *WorkerStatusResponse) ProtoReflect() protoreflect.Message
func (*WorkerStatusResponse) Reset ¶
func (x *WorkerStatusResponse) Reset()
func (*WorkerStatusResponse) String ¶
func (x *WorkerStatusResponse) String() string
type WorkerUpdateRequest ¶
type WorkerUpdateRequest struct {
WorkerId int32 `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
ProviderId *int32 `protobuf:"varint,2,opt,name=provider_id,json=providerId,proto3,oneof" json:"provider_id,omitempty"`
FlavorId *int32 `protobuf:"varint,3,opt,name=flavor_id,json=flavorId,proto3,oneof" json:"flavor_id,omitempty"`
RegionId *int32 `protobuf:"varint,4,opt,name=region_id,json=regionId,proto3,oneof" json:"region_id,omitempty"`
Concurrency *int32 `protobuf:"varint,5,opt,name=concurrency,proto3,oneof" json:"concurrency,omitempty"`
Prefetch *int32 `protobuf:"varint,6,opt,name=prefetch,proto3,oneof" json:"prefetch,omitempty"`
StepId *int32 `protobuf:"varint,7,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
IsPermanent *bool `protobuf:"varint,8,opt,name=is_permanent,json=isPermanent,proto3,oneof" json:"is_permanent,omitempty"`
RecyclableScope *string `protobuf:"bytes,9,opt,name=recyclable_scope,json=recyclableScope,proto3,oneof" json:"recyclable_scope,omitempty"`
WorkflowName *string `protobuf:"bytes,10,opt,name=workflow_name,json=workflowName,proto3,oneof" json:"workflow_name,omitempty"`
StepName *string `protobuf:"bytes,11,opt,name=step_name,json=stepName,proto3,oneof" json:"step_name,omitempty"`
// contains filtered or unexported fields
}
func (*WorkerUpdateRequest) Descriptor
deprecated
func (*WorkerUpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkerUpdateRequest.ProtoReflect.Descriptor instead.
func (*WorkerUpdateRequest) GetConcurrency ¶
func (x *WorkerUpdateRequest) GetConcurrency() int32
func (*WorkerUpdateRequest) GetFlavorId ¶
func (x *WorkerUpdateRequest) GetFlavorId() int32
func (*WorkerUpdateRequest) GetIsPermanent ¶
func (x *WorkerUpdateRequest) GetIsPermanent() bool
func (*WorkerUpdateRequest) GetPrefetch ¶
func (x *WorkerUpdateRequest) GetPrefetch() int32
func (*WorkerUpdateRequest) GetProviderId ¶
func (x *WorkerUpdateRequest) GetProviderId() int32
func (*WorkerUpdateRequest) GetRecyclableScope ¶
func (x *WorkerUpdateRequest) GetRecyclableScope() string
func (*WorkerUpdateRequest) GetRegionId ¶
func (x *WorkerUpdateRequest) GetRegionId() int32
func (*WorkerUpdateRequest) GetStepId ¶
func (x *WorkerUpdateRequest) GetStepId() int32
func (*WorkerUpdateRequest) GetStepName ¶
func (x *WorkerUpdateRequest) GetStepName() string
func (*WorkerUpdateRequest) GetWorkerId ¶
func (x *WorkerUpdateRequest) GetWorkerId() int32
func (*WorkerUpdateRequest) GetWorkflowName ¶
func (x *WorkerUpdateRequest) GetWorkflowName() string
func (*WorkerUpdateRequest) ProtoMessage ¶
func (*WorkerUpdateRequest) ProtoMessage()
func (*WorkerUpdateRequest) ProtoReflect ¶
func (x *WorkerUpdateRequest) ProtoReflect() protoreflect.Message
func (*WorkerUpdateRequest) Reset ¶
func (x *WorkerUpdateRequest) Reset()
func (*WorkerUpdateRequest) String ¶
func (x *WorkerUpdateRequest) String() string
type WorkersList ¶
type WorkersList struct {
Workers []*Worker `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
// contains filtered or unexported fields
}
func (*WorkersList) Descriptor
deprecated
func (*WorkersList) Descriptor() ([]byte, []int)
Deprecated: Use WorkersList.ProtoReflect.Descriptor instead.
func (*WorkersList) GetWorkers ¶
func (x *WorkersList) GetWorkers() []*Worker
func (*WorkersList) ProtoMessage ¶
func (*WorkersList) ProtoMessage()
func (*WorkersList) ProtoReflect ¶
func (x *WorkersList) ProtoReflect() protoreflect.Message
func (*WorkersList) Reset ¶
func (x *WorkersList) Reset()
func (*WorkersList) String ¶
func (x *WorkersList) String() string
type Workflow ¶
type Workflow struct {
WorkflowId int32 `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
RunStrategy string `protobuf:"bytes,4,opt,name=run_strategy,json=runStrategy,proto3" json:"run_strategy,omitempty"`
MaximumWorkers *int32 `protobuf:"varint,5,opt,name=maximum_workers,json=maximumWorkers,proto3,oneof" json:"maximum_workers,omitempty"`
// contains filtered or unexported fields
}
func (*Workflow) Descriptor
deprecated
func (*Workflow) GetMaximumWorkers ¶
func (*Workflow) GetRunStrategy ¶
func (*Workflow) GetWorkflowId ¶
func (*Workflow) ProtoMessage ¶
func (*Workflow) ProtoMessage()
func (*Workflow) ProtoReflect ¶
func (x *Workflow) ProtoReflect() protoreflect.Message
type WorkflowFilter ¶
type WorkflowFilter struct {
NameLike *string `protobuf:"bytes,1,opt,name=name_like,json=nameLike,proto3,oneof" json:"name_like,omitempty"`
Limit *int32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
Offset *int32 `protobuf:"varint,3,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowFilter) Descriptor
deprecated
func (*WorkflowFilter) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowFilter.ProtoReflect.Descriptor instead.
func (*WorkflowFilter) GetLimit ¶
func (x *WorkflowFilter) GetLimit() int32
func (*WorkflowFilter) GetNameLike ¶
func (x *WorkflowFilter) GetNameLike() string
func (*WorkflowFilter) GetOffset ¶
func (x *WorkflowFilter) GetOffset() int32
func (*WorkflowFilter) ProtoMessage ¶
func (*WorkflowFilter) ProtoMessage()
func (*WorkflowFilter) ProtoReflect ¶
func (x *WorkflowFilter) ProtoReflect() protoreflect.Message
func (*WorkflowFilter) Reset ¶
func (x *WorkflowFilter) Reset()
func (*WorkflowFilter) String ¶
func (x *WorkflowFilter) String() string
type WorkflowId ¶
type WorkflowId struct {
WorkflowId int32 `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowId) Descriptor
deprecated
func (*WorkflowId) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowId.ProtoReflect.Descriptor instead.
func (*WorkflowId) GetWorkflowId ¶
func (x *WorkflowId) GetWorkflowId() int32
func (*WorkflowId) ProtoMessage ¶
func (*WorkflowId) ProtoMessage()
func (*WorkflowId) ProtoReflect ¶
func (x *WorkflowId) ProtoReflect() protoreflect.Message
func (*WorkflowId) Reset ¶
func (x *WorkflowId) Reset()
func (*WorkflowId) String ¶
func (x *WorkflowId) String() string
type WorkflowList ¶
type WorkflowList struct {
Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowList) Descriptor
deprecated
func (*WorkflowList) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowList.ProtoReflect.Descriptor instead.
func (*WorkflowList) GetWorkflows ¶
func (x *WorkflowList) GetWorkflows() []*Workflow
func (*WorkflowList) ProtoMessage ¶
func (*WorkflowList) ProtoMessage()
func (*WorkflowList) ProtoReflect ¶
func (x *WorkflowList) ProtoReflect() protoreflect.Message
func (*WorkflowList) Reset ¶
func (x *WorkflowList) Reset()
func (*WorkflowList) String ¶
func (x *WorkflowList) String() string
type WorkflowRequest ¶
type WorkflowRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
RunStrategy *string `protobuf:"bytes,2,opt,name=run_strategy,json=runStrategy,proto3,oneof" json:"run_strategy,omitempty"`
MaximumWorkers *int32 `protobuf:"varint,3,opt,name=maximum_workers,json=maximumWorkers,proto3,oneof" json:"maximum_workers,omitempty"`
Status *string `protobuf:"bytes,4,opt,name=status,proto3,oneof" json:"status,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowRequest) Descriptor
deprecated
func (*WorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowRequest.ProtoReflect.Descriptor instead.
func (*WorkflowRequest) GetMaximumWorkers ¶
func (x *WorkflowRequest) GetMaximumWorkers() int32
func (*WorkflowRequest) GetName ¶
func (x *WorkflowRequest) GetName() string
func (*WorkflowRequest) GetRunStrategy ¶
func (x *WorkflowRequest) GetRunStrategy() string
func (*WorkflowRequest) GetStatus ¶
func (x *WorkflowRequest) GetStatus() string
func (*WorkflowRequest) ProtoMessage ¶
func (*WorkflowRequest) ProtoMessage()
func (*WorkflowRequest) ProtoReflect ¶
func (x *WorkflowRequest) ProtoReflect() protoreflect.Message
func (*WorkflowRequest) Reset ¶
func (x *WorkflowRequest) Reset()
func (*WorkflowRequest) String ¶
func (x *WorkflowRequest) String() string
type WorkflowStatusUpdate ¶
type WorkflowStatusUpdate struct {
WorkflowId int32 `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowStatusUpdate) Descriptor
deprecated
func (*WorkflowStatusUpdate) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowStatusUpdate.ProtoReflect.Descriptor instead.
func (*WorkflowStatusUpdate) GetStatus ¶
func (x *WorkflowStatusUpdate) GetStatus() string
func (*WorkflowStatusUpdate) GetWorkflowId ¶
func (x *WorkflowStatusUpdate) GetWorkflowId() int32
func (*WorkflowStatusUpdate) ProtoMessage ¶
func (*WorkflowStatusUpdate) ProtoMessage()
func (*WorkflowStatusUpdate) ProtoReflect ¶
func (x *WorkflowStatusUpdate) ProtoReflect() protoreflect.Message
func (*WorkflowStatusUpdate) Reset ¶
func (x *WorkflowStatusUpdate) Reset()
func (*WorkflowStatusUpdate) String ¶
func (x *WorkflowStatusUpdate) String() string
type WorkspaceRootRequest ¶
type WorkspaceRootRequest struct {
Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"` // e.g., "azure.default" or "openstack.ovh"
Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"` // e.g., "northeurope"
// contains filtered or unexported fields
}
func (*WorkspaceRootRequest) Descriptor
deprecated
func (*WorkspaceRootRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkspaceRootRequest.ProtoReflect.Descriptor instead.
func (*WorkspaceRootRequest) GetProvider ¶
func (x *WorkspaceRootRequest) GetProvider() string
func (*WorkspaceRootRequest) GetRegion ¶
func (x *WorkspaceRootRequest) GetRegion() string
func (*WorkspaceRootRequest) ProtoMessage ¶
func (*WorkspaceRootRequest) ProtoMessage()
func (*WorkspaceRootRequest) ProtoReflect ¶
func (x *WorkspaceRootRequest) ProtoReflect() protoreflect.Message
func (*WorkspaceRootRequest) Reset ¶
func (x *WorkspaceRootRequest) Reset()
func (*WorkspaceRootRequest) String ¶
func (x *WorkspaceRootRequest) String() string
type WorkspaceRootResponse ¶
type WorkspaceRootResponse struct {
RootUri string `protobuf:"bytes,1,opt,name=root_uri,json=rootUri,proto3" json:"root_uri,omitempty"` // e.g., "aznorth://workspace"
// contains filtered or unexported fields
}
func (*WorkspaceRootResponse) Descriptor
deprecated
func (*WorkspaceRootResponse) Descriptor() ([]byte, []int)
Deprecated: Use WorkspaceRootResponse.ProtoReflect.Descriptor instead.
func (*WorkspaceRootResponse) GetRootUri ¶
func (x *WorkspaceRootResponse) GetRootUri() string
func (*WorkspaceRootResponse) ProtoMessage ¶
func (*WorkspaceRootResponse) ProtoMessage()
func (*WorkspaceRootResponse) ProtoReflect ¶
func (x *WorkspaceRootResponse) ProtoReflect() protoreflect.Message
func (*WorkspaceRootResponse) Reset ¶
func (x *WorkspaceRootResponse) Reset()
func (*WorkspaceRootResponse) String ¶
func (x *WorkspaceRootResponse) String() string