taskqueuepb

package

Go to main page

Versions in this module

v0

v0.10.1

Oct 23, 2026

Changes in this version

type Template

+ Folder string

+ func (x *Template) GetFolder() string

type TemplateFilter

+ Folder *string

+ func (x *TemplateFilter) GetFolder() string

type UpdateTemplateRequest

+ Folder *string

+ func (x *UpdateTemplateRequest) GetFolder() string

type UploadTemplateRequest

+ Folder *string

+ func (x *UploadTemplateRequest) GetFolder() string

type UploadTemplateResponse

+ Folder *string

+ func (x *UploadTemplateResponse) GetFolder() string

v0.10.0

Oct 12, 2026

Changes in this version

type Recruiter

+ ExtraStorageGb *int32

+ ExtraStorageType *string

+ SwapProportion *float32

+ func (x *Recruiter) GetExtraStorageGb() int32

+ func (x *Recruiter) GetExtraStorageType() string

+ func (x *Recruiter) GetSwapProportion() float32

type RecruiterUpdate

+ ExtraStorageGb *int32

+ ExtraStorageType *string

+ SwapProportion *float32

+ func (x *RecruiterUpdate) GetExtraStorageGb() int32

+ func (x *RecruiterUpdate) GetExtraStorageType() string

+ func (x *RecruiterUpdate) GetSwapProportion() float32

type Step

+ DefinitiveExitCodes []int32

+ DefinitivePattern *string

+ func (x *Step) GetDefinitiveExitCodes() []int32

+ func (x *Step) GetDefinitivePattern() string

type StepRequest

+ DefinitiveExitCodes []int32

+ DefinitivePattern *string

+ func (x *StepRequest) GetDefinitiveExitCodes() []int32

+ func (x *StepRequest) GetDefinitivePattern() string

type Task

+ DefinitiveExitCodes []int32

+ DefinitivePattern *string

+ func (x *Task) GetDefinitiveExitCodes() []int32

+ func (x *Task) GetDefinitivePattern() string

type Worker

+ ExtraStorageGb *int32

+ ExtraStorageType *string

+ ExtraStorageVolumeId *string

+ SwapProportion *float32

+ func (x *Worker) GetExtraStorageGb() int32

+ func (x *Worker) GetExtraStorageType() string

+ func (x *Worker) GetExtraStorageVolumeId() string

+ func (x *Worker) GetSwapProportion() float32

type WorkerRequest

+ ExtraStorageGb *int32

+ ExtraStorageType *string

+ SwapProportion *float32

+ func (x *WorkerRequest) GetExtraStorageGb() int32

+ func (x *WorkerRequest) GetExtraStorageType() string

+ func (x *WorkerRequest) GetSwapProportion() float32

v0.9.3

Sep 24, 2026

Changes in this version

+ const TaskQueue_GetWorkerStatsSummary_FullMethodName

+ const TaskQueue_ListWorkerStatsHistory_FullMethodName

type Recruiter

+ DiskSharedPerTask *float32

+ MemorySharedPerTask *float32

+ PrefetchPercentCeil *bool

+ func (x *Recruiter) GetDiskSharedPerTask() float32

+ func (x *Recruiter) GetMemorySharedPerTask() float32

+ func (x *Recruiter) GetPrefetchPercentCeil() bool

type RecruiterUpdate

+ DiskSharedPerTask *float32

+ MemorySharedPerTask *float32

+ PrefetchPercentCeil *bool

+ func (x *RecruiterUpdate) GetDiskSharedPerTask() float32

+ func (x *RecruiterUpdate) GetMemorySharedPerTask() float32

+ func (x *RecruiterUpdate) GetPrefetchPercentCeil() bool

type StepRequest

+ OutputLifetime *string

+ func (x *StepRequest) GetOutputLifetime() string

type Task

+ DiskSharedCurve []float32

+ MemSharedCurve []float32

+ MinDiskShared *float32

+ MinMemShared *float32

+ PeakMemMb *int32

+ func (x *Task) GetDiskSharedCurve() []float32

+ func (x *Task) GetMemSharedCurve() []float32

+ func (x *Task) GetMinDiskShared() float32

+ func (x *Task) GetMinMemShared() float32

+ func (x *Task) GetPeakMemMb() int32

type TaskQueueClient

+ GetWorkerStatsSummary func(ctx context.Context, in *WorkerStatsHistoryFilter, opts ...grpc.CallOption) (*WorkerStatsSummary, error)

+ ListWorkerStatsHistory func(ctx context.Context, in *WorkerStatsHistoryFilter, opts ...grpc.CallOption) (*WorkerStatsHistoryList, error)

type TaskQueueServer

+ GetWorkerStatsSummary func(context.Context, *WorkerStatsHistoryFilter) (*WorkerStatsSummary, error)

+ ListWorkerStatsHistory func(context.Context, *WorkerStatsHistoryFilter) (*WorkerStatsHistoryList, error)

type TaskRequest

+ DiskSharedCurve []float32

+ MemSharedCurve []float32

+ MinDiskShared *float32

+ MinMemShared *float32

+ func (x *TaskRequest) GetDiskSharedCurve() []float32

+ func (x *TaskRequest) GetMemSharedCurve() []float32

+ func (x *TaskRequest) GetMinDiskShared() float32

+ func (x *TaskRequest) GetMinMemShared() float32

type TaskStatusUpdate

+ PeakMemMb *int32

+ func (x *TaskStatusUpdate) GetPeakMemMb() int32

type UnimplementedTaskQueueServer

+ func (UnimplementedTaskQueueServer) GetWorkerStatsSummary(context.Context, *WorkerStatsHistoryFilter) (*WorkerStatsSummary, error)

+ func (UnimplementedTaskQueueServer) ListWorkerStatsHistory(context.Context, *WorkerStatsHistoryFilter) (*WorkerStatsHistoryList, error)

type WorkerStats

+ PeakCpuPercent *float32

+ PeakDiskPercent *float32

+ PeakIowaitPercent *float32

+ PeakMemPercent *float32

+ func (x *WorkerStats) GetPeakCpuPercent() float32

+ func (x *WorkerStats) GetPeakDiskPercent() float32

+ func (x *WorkerStats) GetPeakIowaitPercent() float32

+ func (x *WorkerStats) GetPeakMemPercent() float32

+ type WorkerStatsHistoryFilter struct

+ BucketSeconds *int32

+ EndEpoch *int64

+ Fields []string

+ Limit *int32

+ StartEpoch *int64

+ StepId *int32

+ WorkerId *int32

+ WorkflowId *int32

+ func (*WorkerStatsHistoryFilter) Descriptor() ([]byte, []int)

+ func (*WorkerStatsHistoryFilter) ProtoMessage()

+ func (x *WorkerStatsHistoryFilter) GetBucketSeconds() int32

+ func (x *WorkerStatsHistoryFilter) GetEndEpoch() int64

+ func (x *WorkerStatsHistoryFilter) GetFields() []string

+ func (x *WorkerStatsHistoryFilter) GetLimit() int32

+ func (x *WorkerStatsHistoryFilter) GetStartEpoch() int64

+ func (x *WorkerStatsHistoryFilter) GetStepId() int32

+ func (x *WorkerStatsHistoryFilter) GetWorkerId() int32

+ func (x *WorkerStatsHistoryFilter) GetWorkflowId() int32

+ func (x *WorkerStatsHistoryFilter) ProtoReflect() protoreflect.Message

+ func (x *WorkerStatsHistoryFilter) Reset()

+ func (x *WorkerStatsHistoryFilter) String() string

+ type WorkerStatsHistoryList struct

+ Dropped int32

+ Reason *string

+ Samples []*WorkerStatsHistorySample

+ func (*WorkerStatsHistoryList) Descriptor() ([]byte, []int)

+ func (*WorkerStatsHistoryList) ProtoMessage()

+ func (x *WorkerStatsHistoryList) GetDropped() int32

+ func (x *WorkerStatsHistoryList) GetReason() string

+ func (x *WorkerStatsHistoryList) GetSamples() []*WorkerStatsHistorySample

+ func (x *WorkerStatsHistoryList) ProtoReflect() protoreflect.Message

+ func (x *WorkerStatsHistoryList) Reset()

+ func (x *WorkerStatsHistoryList) String() string

+ type WorkerStatsHistorySample struct

+ CpuPercent *float32

+ EffectiveConcurrency *int32

+ IowaitPercent *float32

+ LastThrottleAt *int64

+ MemPercent *float32

+ PeakCpuPercent *float32

+ PeakDiskPercent *float32

+ PeakIowaitPercent *float32

+ PeakMemPercent *float32

+ RunningTasks *int32

+ SampledAt int64

+ StepId *int32

+ WorkerId int32

+ WorkerName string

+ func (*WorkerStatsHistorySample) Descriptor() ([]byte, []int)

+ func (*WorkerStatsHistorySample) ProtoMessage()

+ func (x *WorkerStatsHistorySample) GetCpuPercent() float32

+ func (x *WorkerStatsHistorySample) GetEffectiveConcurrency() int32

+ func (x *WorkerStatsHistorySample) GetIowaitPercent() float32

+ func (x *WorkerStatsHistorySample) GetLastThrottleAt() int64

+ func (x *WorkerStatsHistorySample) GetMemPercent() float32

+ func (x *WorkerStatsHistorySample) GetPeakCpuPercent() float32

+ func (x *WorkerStatsHistorySample) GetPeakDiskPercent() float32

+ func (x *WorkerStatsHistorySample) GetPeakIowaitPercent() float32

+ func (x *WorkerStatsHistorySample) GetPeakMemPercent() float32

+ func (x *WorkerStatsHistorySample) GetRunningTasks() int32

+ func (x *WorkerStatsHistorySample) GetSampledAt() int64

+ func (x *WorkerStatsHistorySample) GetStepId() int32

+ func (x *WorkerStatsHistorySample) GetWorkerId() int32

+ func (x *WorkerStatsHistorySample) GetWorkerName() string

+ func (x *WorkerStatsHistorySample) ProtoReflect() protoreflect.Message

+ func (x *WorkerStatsHistorySample) Reset()

+ func (x *WorkerStatsHistorySample) String() string

+ type WorkerStatsSummary struct

+ Entries []*WorkerStatsSummaryEntry

+ Reason *string

+ func (*WorkerStatsSummary) Descriptor() ([]byte, []int)

+ func (*WorkerStatsSummary) ProtoMessage()

+ func (x *WorkerStatsSummary) GetEntries() []*WorkerStatsSummaryEntry

+ func (x *WorkerStatsSummary) GetReason() string

+ func (x *WorkerStatsSummary) ProtoReflect() protoreflect.Message

+ func (x *WorkerStatsSummary) Reset()

+ func (x *WorkerStatsSummary) String() string

+ type WorkerStatsSummaryEntry struct

+ AvgCpuPercent *float32

+ AvgIowaitPercent *float32

+ AvgMemPercent *float32

+ FirstSampleAt int64

+ LastSampleAt int64

+ MaxCpuPercent *float32

+ MaxDiskPercent *float32

+ MaxIowaitPercent *float32

+ MaxMemPercent *float32

+ MaxRunningTasks *int32

+ SampleCount int32

+ WorkerId int32

+ WorkerName string

+ func (*WorkerStatsSummaryEntry) Descriptor() ([]byte, []int)

+ func (*WorkerStatsSummaryEntry) ProtoMessage()

+ func (x *WorkerStatsSummaryEntry) GetAvgCpuPercent() float32

+ func (x *WorkerStatsSummaryEntry) GetAvgIowaitPercent() float32

+ func (x *WorkerStatsSummaryEntry) GetAvgMemPercent() float32

+ func (x *WorkerStatsSummaryEntry) GetFirstSampleAt() int64

+ func (x *WorkerStatsSummaryEntry) GetLastSampleAt() int64

+ func (x *WorkerStatsSummaryEntry) GetMaxCpuPercent() float32

+ func (x *WorkerStatsSummaryEntry) GetMaxDiskPercent() float32

+ func (x *WorkerStatsSummaryEntry) GetMaxIowaitPercent() float32

+ func (x *WorkerStatsSummaryEntry) GetMaxMemPercent() float32

+ func (x *WorkerStatsSummaryEntry) GetMaxRunningTasks() int32

+ func (x *WorkerStatsSummaryEntry) GetSampleCount() int32

+ func (x *WorkerStatsSummaryEntry) GetWorkerId() int32

+ func (x *WorkerStatsSummaryEntry) GetWorkerName() string

+ func (x *WorkerStatsSummaryEntry) ProtoReflect() protoreflect.Message

+ func (x *WorkerStatsSummaryEntry) Reset()

+ func (x *WorkerStatsSummaryEntry) String() string

v0.9.2

Sep 10, 2026

Changes in this version

type WorkerStats

+ EffectiveConcurrency int32

+ LastThrottleAt int64

+ RunningTasks int32

+ func (x *WorkerStats) GetEffectiveConcurrency() int32

+ func (x *WorkerStats) GetLastThrottleAt() int64

+ func (x *WorkerStats) GetRunningTasks() int32

v0.9.1

Jul 8, 2026

Changes in this version

type EditAndRetryTaskRequest

+ Shell *string

+ func (x *EditAndRetryTaskRequest) GetShell() string

v0.8.9

Jul 3, 2026

Changes in this version

+ const TaskQueue_ResetWorkerCounters_FullMethodName

+ const TaskQueue_RetryJob_FullMethodName

type EditAndRetryTaskRequest

+ Publish *string

+ func (x *EditAndRetryTaskRequest) GetPublish() string

type EditStepCommandRequest

+ Container *string

+ Inputs *StringList

+ Resources *StringList

+ func (x *EditStepCommandRequest) GetContainer() string

+ func (x *EditStepCommandRequest) GetInputs() *StringList

+ func (x *EditStepCommandRequest) GetResources() *StringList

type EditTaskRequest

+ GpuAll *bool

+ MinCpu *float32

+ MinDisk *float32

+ MinGpu *int32

+ MinMem *float32

+ func (x *EditTaskRequest) GetGpuAll() bool

+ func (x *EditTaskRequest) GetMinCpu() float32

+ func (x *EditTaskRequest) GetMinDisk() float32

+ func (x *EditTaskRequest) GetMinGpu() int32

+ func (x *EditTaskRequest) GetMinMem() float32

type Flavor

+ GpuCount int32

+ func (x *Flavor) GetGpuCount() int32

type Recruiter

+ GpuImage *string

+ GpuPerTask *int32

+ Image *string

+ func (x *Recruiter) GetGpuImage() string

+ func (x *Recruiter) GetGpuPerTask() int32

+ func (x *Recruiter) GetImage() string

type RecruiterUpdate

+ GpuImage *string

+ GpuPerTask *int32

+ Image *string

+ func (x *RecruiterUpdate) GetGpuImage() string

+ func (x *RecruiterUpdate) GetGpuPerTask() int32

+ func (x *RecruiterUpdate) GetImage() string

+ type ResetWorkerCountersRequest struct

+ ClearFailures bool

+ ClearSuccesses bool

+ ClearWarnings bool

+ WorkerId int32

+ func (*ResetWorkerCountersRequest) Descriptor() ([]byte, []int)

+ func (*ResetWorkerCountersRequest) ProtoMessage()

+ func (x *ResetWorkerCountersRequest) GetClearFailures() bool

+ func (x *ResetWorkerCountersRequest) GetClearSuccesses() bool

+ func (x *ResetWorkerCountersRequest) GetClearWarnings() bool

+ func (x *ResetWorkerCountersRequest) GetWorkerId() int32

+ func (x *ResetWorkerCountersRequest) ProtoReflect() protoreflect.Message

+ func (x *ResetWorkerCountersRequest) Reset()

+ func (x *ResetWorkerCountersRequest) String() string

type Task

+ CreatedAt int64

+ GpuAll *bool

+ MinGpu *int32

+ ModifiedAt int64

+ func (x *Task) GetCreatedAt() int64

+ func (x *Task) GetGpuAll() bool

+ func (x *Task) GetMinGpu() int32

+ func (x *Task) GetModifiedAt() int64

type TaskQueueClient

+ ResetWorkerCounters func(ctx context.Context, in *ResetWorkerCountersRequest, opts ...grpc.CallOption) (*Ack, error)

+ RetryJob func(ctx context.Context, in *JobId, opts ...grpc.CallOption) (*Ack, error)

type TaskQueueServer

+ ResetWorkerCounters func(context.Context, *ResetWorkerCountersRequest) (*Ack, error)

+ RetryJob func(context.Context, *JobId) (*Ack, error)

type TaskRequest

+ GpuAll *bool

+ MinGpu *int32

+ func (x *TaskRequest) GetGpuAll() bool

+ func (x *TaskRequest) GetMinGpu() int32

type UnimplementedTaskQueueServer

+ func (UnimplementedTaskQueueServer) ResetWorkerCounters(context.Context, *ResetWorkerCountersRequest) (*Ack, error)

+ func (UnimplementedTaskQueueServer) RetryJob(context.Context, *JobId) (*Ack, error)

type Worker

+ FlavorGpuCount *int32

+ PendingWarnings *int32

+ func (x *Worker) GetFlavorGpuCount() int32

+ func (x *Worker) GetPendingWarnings() int32

type WorkerInfo

+ GpuCount *int32

+ func (x *WorkerInfo) GetGpuCount() int32

type WorkerRequest

+ GpuImage *string

+ Image *string

+ func (x *WorkerRequest) GetGpuImage() string

+ func (x *WorkerRequest) GetImage() string

type Workflow

+ EligibleWorkerCount int32

+ func (x *Workflow) GetEligibleWorkerCount() int32

v0.8.8

Jun 18, 2026

Changes in this version

+ const TaskQueue_DeleteTask_FullMethodName

type EditAndRetryTaskRequest

+ Container *string

+ func (x *EditAndRetryTaskRequest) GetContainer() string

type TaskQueueClient

+ DeleteTask func(ctx context.Context, in *TaskId, opts ...grpc.CallOption) (*Ack, error)

type TaskQueueServer

+ DeleteTask func(context.Context, *TaskId) (*Ack, error)

type UnimplementedTaskQueueServer

+ func (UnimplementedTaskQueueServer) DeleteTask(context.Context, *TaskId) (*Ack, error)

v0.8.7

Jun 16, 2026

Changes in this version

type EditAndRetryTaskRequest

+ Depends *Int32List

+ Inputs *StringList

+ Resources *StringList

+ func (x *EditAndRetryTaskRequest) GetDepends() *Int32List

+ func (x *EditAndRetryTaskRequest) GetInputs() *StringList

+ func (x *EditAndRetryTaskRequest) GetResources() *StringList

+ type Int32List struct

+ Values []int32

+ func (*Int32List) Descriptor() ([]byte, []int)

+ func (*Int32List) ProtoMessage()

+ func (x *Int32List) GetValues() []int32

+ func (x *Int32List) ProtoReflect() protoreflect.Message

+ func (x *Int32List) Reset()

+ func (x *Int32List) String() string

v0.8.6

Jun 16, 2026

v0.8.5

Jun 15, 2026

Changes in this version

+ const TaskQueue_CancelChainEntry_FullMethodName

+ const TaskQueue_CreateChainEntries_FullMethodName

+ const TaskQueue_DeleteModule_FullMethodName

+ const TaskQueue_EditChainEntry_FullMethodName

+ const TaskQueue_GetChainEntry_FullMethodName

+ const TaskQueue_GetTask_FullMethodName

+ const TaskQueue_ListChainEntries_FullMethodName

+ const TaskQueue_ResumeChainEntry_FullMethodName

+ const TaskQueue_SuspendChainEntry_FullMethodName

+ type ChainEntry struct

+ AlwaysNew bool

+ ChainEntryId int32

+ ChildWorkflowId *int32

+ CreatedAt string

+ ErrorMessage *string

+ FiredAt *string

+ Idx int32

+ LastFiredAt *string

+ OnStatus string

+ ParamsTemplateJson string

+ ParentWorkflowId int32

+ Status string

+ TemplateName string

+ TemplateVersion *string

+ WhenExpr string

+ func (*ChainEntry) Descriptor() ([]byte, []int)

+ func (*ChainEntry) ProtoMessage()

+ func (x *ChainEntry) GetAlwaysNew() bool

+ func (x *ChainEntry) GetChainEntryId() int32

+ func (x *ChainEntry) GetChildWorkflowId() int32

+ func (x *ChainEntry) GetCreatedAt() string

+ func (x *ChainEntry) GetErrorMessage() string

+ func (x *ChainEntry) GetFiredAt() string

+ func (x *ChainEntry) GetIdx() int32

+ func (x *ChainEntry) GetLastFiredAt() string

+ func (x *ChainEntry) GetOnStatus() string

+ func (x *ChainEntry) GetParamsTemplateJson() string

+ func (x *ChainEntry) GetParentWorkflowId() int32

+ func (x *ChainEntry) GetStatus() string

+ func (x *ChainEntry) GetTemplateName() string

+ func (x *ChainEntry) GetTemplateVersion() string

+ func (x *ChainEntry) GetWhenExpr() string

+ func (x *ChainEntry) ProtoReflect() protoreflect.Message

+ func (x *ChainEntry) Reset()

+ func (x *ChainEntry) String() string

+ type ChainEntryDraft struct

+ AlwaysNew bool

+ OnStatus string

+ ParamsTemplateJson string

+ TemplateName string

+ TemplateVersion *string

+ WhenExpr string

+ func (*ChainEntryDraft) Descriptor() ([]byte, []int)

+ func (*ChainEntryDraft) ProtoMessage()

+ func (x *ChainEntryDraft) GetAlwaysNew() bool

+ func (x *ChainEntryDraft) GetOnStatus() string

+ func (x *ChainEntryDraft) GetParamsTemplateJson() string

+ func (x *ChainEntryDraft) GetTemplateName() string

+ func (x *ChainEntryDraft) GetTemplateVersion() string

+ func (x *ChainEntryDraft) GetWhenExpr() string

+ func (x *ChainEntryDraft) ProtoReflect() protoreflect.Message

+ func (x *ChainEntryDraft) Reset()

+ func (x *ChainEntryDraft) String() string

+ type ChainEntryId struct

+ ChainEntryId int32

+ func (*ChainEntryId) Descriptor() ([]byte, []int)

+ func (*ChainEntryId) ProtoMessage()

+ func (x *ChainEntryId) GetChainEntryId() int32

+ func (x *ChainEntryId) ProtoReflect() protoreflect.Message

+ func (x *ChainEntryId) Reset()

+ func (x *ChainEntryId) String() string

+ type ChainEntryList struct

+ Entries []*ChainEntry

+ func (*ChainEntryList) Descriptor() ([]byte, []int)

+ func (*ChainEntryList) ProtoMessage()

+ func (x *ChainEntryList) GetEntries() []*ChainEntry

+ func (x *ChainEntryList) ProtoReflect() protoreflect.Message

+ func (x *ChainEntryList) Reset()

+ func (x *ChainEntryList) String() string

type ClientUpgradeInfo

+ CliBinaryUrl string

+ CliInstallPath string

+ CliSha256Url string

+ func (x *ClientUpgradeInfo) GetCliBinaryUrl() string

+ func (x *ClientUpgradeInfo) GetCliInstallPath() string

+ func (x *ClientUpgradeInfo) GetCliSha256Url() string

+ type CreateChainEntriesRequest struct

+ Entries []*ChainEntryDraft

+ WorkflowId int32

+ func (*CreateChainEntriesRequest) Descriptor() ([]byte, []int)

+ func (*CreateChainEntriesRequest) ProtoMessage()

+ func (x *CreateChainEntriesRequest) GetEntries() []*ChainEntryDraft

+ func (x *CreateChainEntriesRequest) GetWorkflowId() int32

+ func (x *CreateChainEntriesRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateChainEntriesRequest) Reset()

+ func (x *CreateChainEntriesRequest) String() string

+ type DeleteModuleRequest struct

+ Path string

+ Version string

+ func (*DeleteModuleRequest) Descriptor() ([]byte, []int)

+ func (*DeleteModuleRequest) ProtoMessage()

+ func (x *DeleteModuleRequest) GetPath() string

+ func (x *DeleteModuleRequest) GetVersion() string

+ func (x *DeleteModuleRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteModuleRequest) Reset()

+ func (x *DeleteModuleRequest) String() string

+ type EditChainEntryRequest struct

+ AlwaysNew *bool

+ ChainEntryId int32

+ OnStatus *string

+ ParamsTemplateJson *string

+ TemplateName *string

+ TemplateVersion *string

+ WhenExpr *string

+ func (*EditChainEntryRequest) Descriptor() ([]byte, []int)

+ func (*EditChainEntryRequest) ProtoMessage()

+ func (x *EditChainEntryRequest) GetAlwaysNew() bool

+ func (x *EditChainEntryRequest) GetChainEntryId() int32

+ func (x *EditChainEntryRequest) GetOnStatus() string

+ func (x *EditChainEntryRequest) GetParamsTemplateJson() string

+ func (x *EditChainEntryRequest) GetTemplateName() string

+ func (x *EditChainEntryRequest) GetTemplateVersion() string

+ func (x *EditChainEntryRequest) GetWhenExpr() string

+ func (x *EditChainEntryRequest) ProtoReflect() protoreflect.Message

+ func (x *EditChainEntryRequest) Reset()

+ func (x *EditChainEntryRequest) String() string

+ type ListChainEntriesRequest struct

+ ParentWorkflowId *int32

+ StatusFilter *string

+ func (*ListChainEntriesRequest) Descriptor() ([]byte, []int)

+ func (*ListChainEntriesRequest) ProtoMessage()

+ func (x *ListChainEntriesRequest) GetParentWorkflowId() int32

+ func (x *ListChainEntriesRequest) GetStatusFilter() string

+ func (x *ListChainEntriesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListChainEntriesRequest) Reset()

+ func (x *ListChainEntriesRequest) String() string

type ModuleListFilter

+ ConflictsOnly *bool

+ func (x *ModuleListFilter) GetConflictsOnly() bool

type PingAndGetNewTasksRequest

+ KnownTaskIds []int32

+ ReportsKnownTasks bool

+ func (x *PingAndGetNewTasksRequest) GetKnownTaskIds() []int32

+ func (x *PingAndGetNewTasksRequest) GetReportsKnownTasks() bool

type RunTemplateRequest

+ ContinueLast bool

+ ExtendWorkflowId *int32

+ RetryFailedOnly bool

+ func (x *RunTemplateRequest) GetContinueLast() bool

+ func (x *RunTemplateRequest) GetExtendWorkflowId() int32

+ func (x *RunTemplateRequest) GetRetryFailedOnly() bool

type Task

+ CpuCurve []float32

+ DiskCurve []float32

+ FailureClass *string

+ MemCurve []float32

+ MinCpu *float32

+ MinDisk *float32

+ MinMem *float32

+ Numa *int32

+ PublishMode *string

+ ScitqAuth *bool

+ func (x *Task) GetCpuCurve() []float32

+ func (x *Task) GetDiskCurve() []float32

+ func (x *Task) GetFailureClass() string

+ func (x *Task) GetMemCurve() []float32

+ func (x *Task) GetMinCpu() float32

+ func (x *Task) GetMinDisk() float32

+ func (x *Task) GetMinMem() float32

+ func (x *Task) GetNuma() int32

+ func (x *Task) GetPublishMode() string

+ func (x *Task) GetScitqAuth() bool

type TaskListAndOther

+ MaxCpu *int32

+ MaxMem *float32

+ func (x *TaskListAndOther) GetMaxCpu() int32

+ func (x *TaskListAndOther) GetMaxMem() float32

type TaskQueueClient

+ CancelChainEntry func(ctx context.Context, in *ChainEntryId, opts ...grpc.CallOption) (*ChainEntry, error)

+ CreateChainEntries func(ctx context.Context, in *CreateChainEntriesRequest, opts ...grpc.CallOption) (*ChainEntryList, error)

+ DeleteModule func(ctx context.Context, in *DeleteModuleRequest, opts ...grpc.CallOption) (*Ack, error)

+ EditChainEntry func(ctx context.Context, in *EditChainEntryRequest, opts ...grpc.CallOption) (*ChainEntry, error)

+ GetChainEntry func(ctx context.Context, in *ChainEntryId, opts ...grpc.CallOption) (*ChainEntry, error)

+ GetTask func(ctx context.Context, in *TaskId, opts ...grpc.CallOption) (*Task, error)

+ ListChainEntries func(ctx context.Context, in *ListChainEntriesRequest, opts ...grpc.CallOption) (*ChainEntryList, error)

+ ResumeChainEntry func(ctx context.Context, in *ChainEntryId, opts ...grpc.CallOption) (*ChainEntry, error)

+ SuspendChainEntry func(ctx context.Context, in *ChainEntryId, opts ...grpc.CallOption) (*ChainEntry, error)

type TaskQueueServer

+ CancelChainEntry func(context.Context, *ChainEntryId) (*ChainEntry, error)

+ CreateChainEntries func(context.Context, *CreateChainEntriesRequest) (*ChainEntryList, error)

+ DeleteModule func(context.Context, *DeleteModuleRequest) (*Ack, error)

+ EditChainEntry func(context.Context, *EditChainEntryRequest) (*ChainEntry, error)

+ GetChainEntry func(context.Context, *ChainEntryId) (*ChainEntry, error)

+ GetTask func(context.Context, *TaskId) (*Task, error)

+ ListChainEntries func(context.Context, *ListChainEntriesRequest) (*ChainEntryList, error)

+ ResumeChainEntry func(context.Context, *ChainEntryId) (*ChainEntry, error)

+ SuspendChainEntry func(context.Context, *ChainEntryId) (*ChainEntry, error)

type TaskRequest

+ CpuCurve []float32

+ DiskCurve []float32

+ MemCurve []float32

+ MinCpu *float32

+ MinDisk *float32

+ MinMem *float32

+ Numa *int32

+ PublishMode *string

+ ScitqAuth *bool

+ func (x *TaskRequest) GetCpuCurve() []float32

+ func (x *TaskRequest) GetDiskCurve() []float32

+ func (x *TaskRequest) GetMemCurve() []float32

+ func (x *TaskRequest) GetMinCpu() float32

+ func (x *TaskRequest) GetMinDisk() float32

+ func (x *TaskRequest) GetMinMem() float32

+ func (x *TaskRequest) GetNuma() int32

+ func (x *TaskRequest) GetPublishMode() string

+ func (x *TaskRequest) GetScitqAuth() bool

type TaskStatusUpdate

+ FailureClass *string

+ func (x *TaskStatusUpdate) GetFailureClass() string

type TemplateRun

+ ParentTemplateRunId *int32

+ func (x *TemplateRun) GetParentTemplateRunId() int32

type UnimplementedTaskQueueServer

+ func (UnimplementedTaskQueueServer) CancelChainEntry(context.Context, *ChainEntryId) (*ChainEntry, error)

+ func (UnimplementedTaskQueueServer) CreateChainEntries(context.Context, *CreateChainEntriesRequest) (*ChainEntryList, error)

+ func (UnimplementedTaskQueueServer) DeleteModule(context.Context, *DeleteModuleRequest) (*Ack, error)

+ func (UnimplementedTaskQueueServer) EditChainEntry(context.Context, *EditChainEntryRequest) (*ChainEntry, error)

+ func (UnimplementedTaskQueueServer) GetChainEntry(context.Context, *ChainEntryId) (*ChainEntry, error)

+ func (UnimplementedTaskQueueServer) GetTask(context.Context, *TaskId) (*Task, error)

+ func (UnimplementedTaskQueueServer) ListChainEntries(context.Context, *ListChainEntriesRequest) (*ChainEntryList, error)

+ func (UnimplementedTaskQueueServer) ResumeChainEntry(context.Context, *ChainEntryId) (*ChainEntry, error)

+ func (UnimplementedTaskQueueServer) SuspendChainEntry(context.Context, *ChainEntryId) (*ChainEntry, error)

type Worker

+ RecentFailures *int32

+ func (x *Worker) GetRecentFailures() int32

type WorkerUpdateRequest

+ ClearStep *bool

+ MaxCpu *int32

+ MaxMem *float32

+ func (x *WorkerUpdateRequest) GetClearStep() bool

+ func (x *WorkerUpdateRequest) GetMaxCpu() int32

+ func (x *WorkerUpdateRequest) GetMaxMem() float32

type Workflow

+ ParentWorkflowId *int32

+ func (x *Workflow) GetParentWorkflowId() int32

type WorkflowFilter

+ UsernameFilter *string

+ func (x *WorkflowFilter) GetUsernameFilter() string

v0.8.2

May 10, 2026

Changes in this version

type TemplateRunFilter

+ TemplateRunId *int32

+ func (x *TemplateRunFilter) GetTemplateRunId() int32

v0.8.1

May 5, 2026

Changes in this version

+ const TaskQueue_GetClientUpgradeInfo_FullMethodName

+ const TaskQueue_RequestWorkerUpgrade_FullMethodName

+ const TaskQueue_ServerVersion_FullMethodName

+ const TaskQueue_SetFlavorAvailability_FullMethodName

+ type ClientUpgradeInfo struct

+ BinaryUrl string

+ InsecureSkipVerify bool

+ Sha256Url string

+ func (*ClientUpgradeInfo) Descriptor() ([]byte, []int)

+ func (*ClientUpgradeInfo) ProtoMessage()

+ func (x *ClientUpgradeInfo) GetBinaryUrl() string

+ func (x *ClientUpgradeInfo) GetInsecureSkipVerify() bool

+ func (x *ClientUpgradeInfo) GetSha256Url() string

+ func (x *ClientUpgradeInfo) ProtoReflect() protoreflect.Message

+ func (x *ClientUpgradeInfo) Reset()

+ func (x *ClientUpgradeInfo) String() string

+ type FlavorAvailability struct

+ Available bool

+ FlavorName string

+ Provider string

+ Region *string

+ func (*FlavorAvailability) Descriptor() ([]byte, []int)

+ func (*FlavorAvailability) ProtoMessage()

+ func (x *FlavorAvailability) GetAvailable() bool

+ func (x *FlavorAvailability) GetFlavorName() string

+ func (x *FlavorAvailability) GetProvider() string

+ func (x *FlavorAvailability) GetRegion() string

+ func (x *FlavorAvailability) ProtoReflect() protoreflect.Message

+ func (x *FlavorAvailability) Reset()

+ func (x *FlavorAvailability) String() string

+ type FlavorAvailabilityReply struct

+ AffectedRows int32

+ func (*FlavorAvailabilityReply) Descriptor() ([]byte, []int)

+ func (*FlavorAvailabilityReply) ProtoMessage()

+ func (x *FlavorAvailabilityReply) GetAffectedRows() int32

+ func (x *FlavorAvailabilityReply) ProtoReflect() protoreflect.Message

+ func (x *FlavorAvailabilityReply) Reset()

+ func (x *FlavorAvailabilityReply) String() string

type Job

+ ErrorClass *string

+ ErrorMessage *string

+ func (x *Job) GetErrorClass() string

+ func (x *Job) GetErrorMessage() string

+ type ServerVersionResponse struct

+ BuildArch string

+ Commit string

+ Version string

+ func (*ServerVersionResponse) Descriptor() ([]byte, []int)

+ func (*ServerVersionResponse) ProtoMessage()

+ func (x *ServerVersionResponse) GetBuildArch() string

+ func (x *ServerVersionResponse) GetCommit() string

+ func (x *ServerVersionResponse) GetVersion() string

+ func (x *ServerVersionResponse) ProtoReflect() protoreflect.Message

+ func (x *ServerVersionResponse) Reset()

+ func (x *ServerVersionResponse) String() string

type TaskListAndOther

+ ServerUpgradeInProgress bool

+ UpgradeRequested string

+ func (x *TaskListAndOther) GetServerUpgradeInProgress() bool

+ func (x *TaskListAndOther) GetUpgradeRequested() string

type TaskQueueClient

+ GetClientUpgradeInfo func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ClientUpgradeInfo, error)

+ RequestWorkerUpgrade func(ctx context.Context, in *WorkerUpgradeRequest, opts ...grpc.CallOption) (*WorkerUpgradeReply, error)

+ ServerVersion func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ServerVersionResponse, error)

+ SetFlavorAvailability func(ctx context.Context, in *FlavorAvailability, opts ...grpc.CallOption) (*FlavorAvailabilityReply, error)

type TaskQueueServer

+ GetClientUpgradeInfo func(context.Context, *emptypb.Empty) (*ClientUpgradeInfo, error)

+ RequestWorkerUpgrade func(context.Context, *WorkerUpgradeRequest) (*WorkerUpgradeReply, error)

+ ServerVersion func(context.Context, *emptypb.Empty) (*ServerVersionResponse, error)

+ SetFlavorAvailability func(context.Context, *FlavorAvailability) (*FlavorAvailabilityReply, error)

type UnimplementedTaskQueueServer

+ func (UnimplementedTaskQueueServer) GetClientUpgradeInfo(context.Context, *emptypb.Empty) (*ClientUpgradeInfo, error)

+ func (UnimplementedTaskQueueServer) RequestWorkerUpgrade(context.Context, *WorkerUpgradeRequest) (*WorkerUpgradeReply, error)

+ func (UnimplementedTaskQueueServer) ServerVersion(context.Context, *emptypb.Empty) (*ServerVersionResponse, error)

+ func (UnimplementedTaskQueueServer) SetFlavorAvailability(context.Context, *FlavorAvailability) (*FlavorAvailabilityReply, error)

type Worker

+ BuildArch *string

+ Commit *string

+ UpgradeRequested *string

+ UpgradeStatus *string

+ Version *string

+ func (x *Worker) GetBuildArch() string

+ func (x *Worker) GetCommit() string

+ func (x *Worker) GetUpgradeRequested() string

+ func (x *Worker) GetUpgradeStatus() string

+ func (x *Worker) GetVersion() string

type WorkerInfo

+ BuildArch *string

+ Commit *string

+ Version *string

+ func (x *WorkerInfo) GetBuildArch() string

+ func (x *WorkerInfo) GetCommit() string

+ func (x *WorkerInfo) GetVersion() string

+ type WorkerUpgradeReply struct

+ AffectedWorkerIds []int32

+ func (*WorkerUpgradeReply) Descriptor() ([]byte, []int)

+ func (*WorkerUpgradeReply) ProtoMessage()

+ func (x *WorkerUpgradeReply) GetAffectedWorkerIds() []int32

+ func (x *WorkerUpgradeReply) ProtoReflect() protoreflect.Message

+ func (x *WorkerUpgradeReply) Reset()

+ func (x *WorkerUpgradeReply) String() string

+ type WorkerUpgradeRequest struct

+ All bool

+ Mode string

+ WorkerIds []int32

+ func (*WorkerUpgradeRequest) Descriptor() ([]byte, []int)

+ func (*WorkerUpgradeRequest) ProtoMessage()

+ func (x *WorkerUpgradeRequest) GetAll() bool

+ func (x *WorkerUpgradeRequest) GetMode() string

+ func (x *WorkerUpgradeRequest) GetWorkerIds() []int32

+ func (x *WorkerUpgradeRequest) ProtoReflect() protoreflect.Message

+ func (x *WorkerUpgradeRequest) Reset()

+ func (x *WorkerUpgradeRequest) String() string

v0.7.8

May 1, 2026

Changes in this version

type TaskRequest

+ ConsumeReuse *bool

+ func (x *TaskRequest) GetConsumeReuse() bool

v0.7.7

Apr 26, 2026

Changes in this version

+ const TaskQueue_EditTask_FullMethodName

+ const TaskQueue_UpdateTemplate_FullMethodName

+ type EditTaskRequest struct

+ Command *string

+ Container *string

+ ContainerOptions *string

+ Input *StringList

+ Output *string

+ Publish *string

+ Resource *StringList

+ Retry *int32

+ Shell *string

+ Status *string

+ TaskId int32

+ func (*EditTaskRequest) Descriptor() ([]byte, []int)

+ func (*EditTaskRequest) ProtoMessage()

+ func (x *EditTaskRequest) GetCommand() string

+ func (x *EditTaskRequest) GetContainer() string

+ func (x *EditTaskRequest) GetContainerOptions() string

+ func (x *EditTaskRequest) GetInput() *StringList

+ func (x *EditTaskRequest) GetOutput() string

+ func (x *EditTaskRequest) GetPublish() string

+ func (x *EditTaskRequest) GetResource() *StringList

+ func (x *EditTaskRequest) GetRetry() int32

+ func (x *EditTaskRequest) GetShell() string

+ func (x *EditTaskRequest) GetStatus() string

+ func (x *EditTaskRequest) GetTaskId() int32

+ func (x *EditTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *EditTaskRequest) Reset()

+ func (x *EditTaskRequest) String() string

type ListTasksRequest

+ CompactCommand *bool

+ CompactCommandMax *int32

+ func (x *ListTasksRequest) GetCompactCommand() bool

+ func (x *ListTasksRequest) GetCompactCommandMax() int32

+ type StringList struct

+ Values []string

+ func (*StringList) Descriptor() ([]byte, []int)

+ func (*StringList) ProtoMessage()

+ func (x *StringList) GetValues() []string

+ func (x *StringList) ProtoReflect() protoreflect.Message

+ func (x *StringList) Reset()

+ func (x *StringList) String() string

type TaskQueueClient

+ EditTask func(ctx context.Context, in *EditTaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)

+ UpdateTemplate func(ctx context.Context, in *UpdateTemplateRequest, opts ...grpc.CallOption) (*Template, error)

type TaskQueueServer

+ EditTask func(context.Context, *EditTaskRequest) (*TaskResponse, error)

+ UpdateTemplate func(context.Context, *UpdateTemplateRequest) (*Template, error)

type Template

+ Hidden bool

+ VersionCount int32

+ func (x *Template) GetHidden() bool

+ func (x *Template) GetVersionCount() int32

type TemplateFilter

+ AllVersions *bool

+ ShowHidden *bool

+ func (x *TemplateFilter) GetAllVersions() bool

+ func (x *TemplateFilter) GetShowHidden() bool

type UnimplementedTaskQueueServer

+ func (UnimplementedTaskQueueServer) EditTask(context.Context, *EditTaskRequest) (*TaskResponse, error)

+ func (UnimplementedTaskQueueServer) UpdateTemplate(context.Context, *UpdateTemplateRequest) (*Template, error)

+ type UpdateTemplateRequest struct

+ Hidden *bool

+ WorkflowTemplateId int32

+ func (*UpdateTemplateRequest) Descriptor() ([]byte, []int)

+ func (*UpdateTemplateRequest) ProtoMessage()

+ func (x *UpdateTemplateRequest) GetHidden() bool

+ func (x *UpdateTemplateRequest) GetWorkflowTemplateId() int32

+ func (x *UpdateTemplateRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateTemplateRequest) Reset()

+ func (x *UpdateTemplateRequest) String() string

v0.7.6

Apr 26, 2026

v0.7.5

Apr 23, 2026

Changes in this version

+ const TaskQueue_ForkModule_FullMethodName

+ const TaskQueue_GetModuleOrigin_FullMethodName

+ const TaskQueue_ListModulesFiltered_FullMethodName

+ const TaskQueue_RegisterAdhocRun_FullMethodName

+ const TaskQueue_UpgradeBundledModules_FullMethodName

+ type ForkModuleRequest struct

+ NewVersion string

+ SourcePath string

+ SourceVersion string

+ func (*ForkModuleRequest) Descriptor() ([]byte, []int)

+ func (*ForkModuleRequest) ProtoMessage()

+ func (x *ForkModuleRequest) GetNewVersion() string

+ func (x *ForkModuleRequest) GetSourcePath() string

+ func (x *ForkModuleRequest) GetSourceVersion() string

+ func (x *ForkModuleRequest) ProtoReflect() protoreflect.Message

+ func (x *ForkModuleRequest) Reset()

+ func (x *ForkModuleRequest) String() string

+ type ModuleEntry struct

+ Description string

+ Origin string

+ Path string

+ Version string

+ func (*ModuleEntry) Descriptor() ([]byte, []int)

+ func (*ModuleEntry) ProtoMessage()

+ func (x *ModuleEntry) GetDescription() string

+ func (x *ModuleEntry) GetOrigin() string

+ func (x *ModuleEntry) GetPath() string

+ func (x *ModuleEntry) GetVersion() string

+ func (x *ModuleEntry) ProtoReflect() protoreflect.Message

+ func (x *ModuleEntry) Reset()

+ func (x *ModuleEntry) String() string

type ModuleList

+ Entries []*ModuleEntry

+ func (x *ModuleList) GetEntries() []*ModuleEntry

+ type ModuleListFilter struct

+ LatestOnly *bool

+ Origin *string

+ Path *string

+ func (*ModuleListFilter) Descriptor() ([]byte, []int)

+ func (*ModuleListFilter) ProtoMessage()

+ func (x *ModuleListFilter) GetLatestOnly() bool

+ func (x *ModuleListFilter) GetOrigin() string

+ func (x *ModuleListFilter) GetPath() string

+ func (x *ModuleListFilter) ProtoReflect() protoreflect.Message

+ func (x *ModuleListFilter) Reset()

+ func (x *ModuleListFilter) String() string

+ type ModuleOriginRequest struct

+ Path string

+ Version string

+ func (*ModuleOriginRequest) Descriptor() ([]byte, []int)

+ func (*ModuleOriginRequest) ProtoMessage()

+ func (x *ModuleOriginRequest) GetPath() string

+ func (x *ModuleOriginRequest) GetVersion() string

+ func (x *ModuleOriginRequest) ProtoReflect() protoreflect.Message

+ func (x *ModuleOriginRequest) Reset()

+ func (x *ModuleOriginRequest) String() string

+ type ModuleOriginResponse struct

+ BundledSha256 string

+ ContentSha256 string

+ Description string

+ ForkIsOutdated bool

+ Origin string

+ Path string

+ UploadedAt string

+ UploadedBy string

+ Version string

+ func (*ModuleOriginResponse) Descriptor() ([]byte, []int)

+ func (*ModuleOriginResponse) ProtoMessage()

+ func (x *ModuleOriginResponse) GetBundledSha256() string

+ func (x *ModuleOriginResponse) GetContentSha256() string

+ func (x *ModuleOriginResponse) GetDescription() string

+ func (x *ModuleOriginResponse) GetForkIsOutdated() bool

+ func (x *ModuleOriginResponse) GetOrigin() string

+ func (x *ModuleOriginResponse) GetPath() string

+ func (x *ModuleOriginResponse) GetUploadedAt() string

+ func (x *ModuleOriginResponse) GetUploadedBy() string

+ func (x *ModuleOriginResponse) GetVersion() string

+ func (x *ModuleOriginResponse) ProtoReflect() protoreflect.Message

+ func (x *ModuleOriginResponse) Reset()

+ func (x *ModuleOriginResponse) String() string

+ type RegisterAdhocRunRequest struct

+ ModulePinsJson string

+ ParamValuesJson string

+ ScriptName string

+ ScriptSha256 string

+ func (*RegisterAdhocRunRequest) Descriptor() ([]byte, []int)

+ func (*RegisterAdhocRunRequest) ProtoMessage()

+ func (x *RegisterAdhocRunRequest) GetModulePinsJson() string

+ func (x *RegisterAdhocRunRequest) GetParamValuesJson() string

+ func (x *RegisterAdhocRunRequest) GetScriptName() string

+ func (x *RegisterAdhocRunRequest) GetScriptSha256() string

+ func (x *RegisterAdhocRunRequest) ProtoReflect() protoreflect.Message

+ func (x *RegisterAdhocRunRequest) Reset()

+ func (x *RegisterAdhocRunRequest) String() string

type TaskQueueClient

+ ForkModule func(ctx context.Context, in *ForkModuleRequest, opts ...grpc.CallOption) (*Ack, error)

+ GetModuleOrigin func(ctx context.Context, in *ModuleOriginRequest, opts ...grpc.CallOption) (*ModuleOriginResponse, error)

+ ListModulesFiltered func(ctx context.Context, in *ModuleListFilter, opts ...grpc.CallOption) (*ModuleList, error)

+ RegisterAdhocRun func(ctx context.Context, in *RegisterAdhocRunRequest, opts ...grpc.CallOption) (*TemplateRun, error)

+ UpgradeBundledModules func(ctx context.Context, in *UpgradeBundledModulesRequest, opts ...grpc.CallOption) (*UpgradeBundledModulesResponse, error)

type TaskQueueServer

+ ForkModule func(context.Context, *ForkModuleRequest) (*Ack, error)

+ GetModuleOrigin func(context.Context, *ModuleOriginRequest) (*ModuleOriginResponse, error)

+ ListModulesFiltered func(context.Context, *ModuleListFilter) (*ModuleList, error)

+ RegisterAdhocRun func(context.Context, *RegisterAdhocRunRequest) (*TemplateRun, error)

+ UpgradeBundledModules func(context.Context, *UpgradeBundledModulesRequest) (*UpgradeBundledModulesResponse, error)

type TemplateRun

+ ScriptName *string

+ ScriptSha256 *string

+ func (x *TemplateRun) GetScriptName() string

+ func (x *TemplateRun) GetScriptSha256() string

type UnimplementedTaskQueueServer

+ func (UnimplementedTaskQueueServer) ForkModule(context.Context, *ForkModuleRequest) (*Ack, error)

+ func (UnimplementedTaskQueueServer) GetModuleOrigin(context.Context, *ModuleOriginRequest) (*ModuleOriginResponse, error)

+ func (UnimplementedTaskQueueServer) ListModulesFiltered(context.Context, *ModuleListFilter) (*ModuleList, error)

+ func (UnimplementedTaskQueueServer) RegisterAdhocRun(context.Context, *RegisterAdhocRunRequest) (*TemplateRun, error)

+ func (UnimplementedTaskQueueServer) UpgradeBundledModules(context.Context, *UpgradeBundledModulesRequest) (*UpgradeBundledModulesResponse, error)

type UpdateTemplateRunRequest

+ ModulePins *string

+ func (x *UpdateTemplateRunRequest) GetModulePins() string

+ type UpgradeBundledModulesRequest struct

+ Apply bool

+ func (*UpgradeBundledModulesRequest) Descriptor() ([]byte, []int)

+ func (*UpgradeBundledModulesRequest) ProtoMessage()

+ func (x *UpgradeBundledModulesRequest) GetApply() bool

+ func (x *UpgradeBundledModulesRequest) ProtoReflect() protoreflect.Message

+ func (x *UpgradeBundledModulesRequest) Reset()

+ func (x *UpgradeBundledModulesRequest) String() string

+ type UpgradeBundledModulesResponse struct

+ Conflicts int32

+ ForksPreserved int32

+ Inserted int32

+ Report string

+ Skipped int32

+ UpToDate int32

+ func (*UpgradeBundledModulesResponse) Descriptor() ([]byte, []int)

+ func (*UpgradeBundledModulesResponse) ProtoMessage()

+ func (x *UpgradeBundledModulesResponse) GetConflicts() int32

+ func (x *UpgradeBundledModulesResponse) GetForksPreserved() int32

+ func (x *UpgradeBundledModulesResponse) GetInserted() int32

+ func (x *UpgradeBundledModulesResponse) GetReport() string

+ func (x *UpgradeBundledModulesResponse) GetSkipped() int32

+ func (x *UpgradeBundledModulesResponse) GetUpToDate() int32

+ func (x *UpgradeBundledModulesResponse) ProtoReflect() protoreflect.Message

+ func (x *UpgradeBundledModulesResponse) Reset()

+ func (x *UpgradeBundledModulesResponse) String() string

type Workflow

+ ScriptName *string

+ ScriptSha256 *string

+ TemplateName *string

+ TemplateRunId *int32

+ TemplateVersion *string

+ func (x *Workflow) GetScriptName() string

+ func (x *Workflow) GetScriptSha256() string

+ func (x *Workflow) GetTemplateName() string

+ func (x *Workflow) GetTemplateRunId() int32

+ func (x *Workflow) GetTemplateVersion() string

v0.7.4

Apr 15, 2026

v0.7.3

Apr 12, 2026

v0.7.2

Apr 11, 2026

Changes in this version

+ const TaskQueue_SignalTask_FullMethodName

type Job

+ FlavorInfo *string

+ WorkerName *string

+ func (x *Job) GetFlavorInfo() string

+ func (x *Job) GetWorkerName() string

type Step

+ QualityDefinition *string

+ func (x *Step) GetQualityDefinition() string

type StepRequest

+ QualityDefinition *string

+ func (x *StepRequest) GetQualityDefinition() string

type Task

+ DownloadDuration *int32

+ QualityScore *float64

+ QualityVars *string

+ ReuseKey *string

+ RunDuration *int32

+ UploadDuration *int32

+ func (x *Task) GetDownloadDuration() int32

+ func (x *Task) GetQualityScore() float64

+ func (x *Task) GetQualityVars() string

+ func (x *Task) GetReuseKey() string

+ func (x *Task) GetRunDuration() int32

+ func (x *Task) GetUploadDuration() int32

type TaskListAndOther

+ Signals []*TaskSignal

+ func (x *TaskListAndOther) GetSignals() []*TaskSignal

type TaskQueueClient

+ SignalTask func(ctx context.Context, in *TaskSignalRequest, opts ...grpc.CallOption) (*Ack, error)

type TaskQueueServer

+ SignalTask func(context.Context, *TaskSignalRequest) (*Ack, error)

type TaskRequest

+ ReuseKey *string

+ func (x *TaskRequest) GetReuseKey() string

+ type TaskSignal struct

+ GracePeriod *int32

+ Signal string

+ TaskId int32

+ func (*TaskSignal) Descriptor() ([]byte, []int)

+ func (*TaskSignal) ProtoMessage()

+ func (x *TaskSignal) GetGracePeriod() int32

+ func (x *TaskSignal) GetSignal() string

+ func (x *TaskSignal) GetTaskId() int32

+ func (x *TaskSignal) ProtoReflect() protoreflect.Message

+ func (x *TaskSignal) Reset()

+ func (x *TaskSignal) String() string

+ type TaskSignalRequest struct

+ GracePeriod *int32

+ Signal string

+ TaskId int32

+ func (*TaskSignalRequest) Descriptor() ([]byte, []int)

+ func (*TaskSignalRequest) ProtoMessage()

+ func (x *TaskSignalRequest) GetGracePeriod() int32

+ func (x *TaskSignalRequest) GetSignal() string

+ func (x *TaskSignalRequest) GetTaskId() int32

+ func (x *TaskSignalRequest) ProtoReflect() protoreflect.Message

+ func (x *TaskSignalRequest) Reset()

+ func (x *TaskSignalRequest) String() string

type UnimplementedTaskQueueServer

+ func (UnimplementedTaskQueueServer) SignalTask(context.Context, *TaskSignalRequest) (*Ack, error)

type Worker

+ FlavorCpu *int32

+ FlavorDisk *float32

+ FlavorMem *float32

+ func (x *Worker) GetFlavorCpu() int32

+ func (x *Worker) GetFlavorDisk() float32

+ func (x *Worker) GetFlavorMem() float32

type Workflow

+ Live bool

+ func (x *Workflow) GetLive() bool

type WorkflowRequest

+ Live *bool

+ func (x *WorkflowRequest) GetLive() bool

v0.7.1

Apr 1, 2026

Changes in this version

+ const TaskQueue_AdminResetPassword_FullMethodName

+ const TaskQueue_CreateWorkerByName_FullMethodName

+ const TaskQueue_DownloadModule_FullMethodName

+ const TaskQueue_DownloadTemplate_FullMethodName

+ const TaskQueue_EditAndRetryTask_FullMethodName

+ const TaskQueue_EditStepCommand_FullMethodName

+ const TaskQueue_ForceRunTask_FullMethodName

+ const TaskQueue_GetResourceRoot_FullMethodName

+ const TaskQueue_ListModules_FullMethodName

+ const TaskQueue_UploadModule_FullMethodName

+ type AdminResetPasswordRequest struct

+ NewPassword string

+ UserId int32

+ func (*AdminResetPasswordRequest) Descriptor() ([]byte, []int)

+ func (*AdminResetPasswordRequest) ProtoMessage()

+ func (x *AdminResetPasswordRequest) GetNewPassword() string

+ func (x *AdminResetPasswordRequest) GetUserId() int32

+ func (x *AdminResetPasswordRequest) ProtoReflect() protoreflect.Message

+ func (x *AdminResetPasswordRequest) Reset()

+ func (x *AdminResetPasswordRequest) String() string

+ type CreateWorkerByNameRequest struct

+ Concurrency int32

+ Count int32

+ Flavor string

+ Prefetch int32

+ Provider string

+ Region string

+ StepId *int32

+ func (*CreateWorkerByNameRequest) Descriptor() ([]byte, []int)

+ func (*CreateWorkerByNameRequest) ProtoMessage()

+ func (x *CreateWorkerByNameRequest) GetConcurrency() int32

+ func (x *CreateWorkerByNameRequest) GetCount() int32

+ func (x *CreateWorkerByNameRequest) GetFlavor() string

+ func (x *CreateWorkerByNameRequest) GetPrefetch() int32

+ func (x *CreateWorkerByNameRequest) GetProvider() string

+ func (x *CreateWorkerByNameRequest) GetRegion() string

+ func (x *CreateWorkerByNameRequest) GetStepId() int32

+ func (x *CreateWorkerByNameRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateWorkerByNameRequest) Reset()

+ func (x *CreateWorkerByNameRequest) String() string

+ type DownloadModuleRequest struct

+ Filename string

+ func (*DownloadModuleRequest) Descriptor() ([]byte, []int)

+ func (*DownloadModuleRequest) ProtoMessage()

+ func (x *DownloadModuleRequest) GetFilename() string

+ func (x *DownloadModuleRequest) ProtoReflect() protoreflect.Message

+ func (x *DownloadModuleRequest) Reset()

+ func (x *DownloadModuleRequest) String() string

+ type DownloadTemplateRequest struct

+ Name *string

+ Version *string

+ WorkflowTemplateId *int32

+ func (*DownloadTemplateRequest) Descriptor() ([]byte, []int)

+ func (*DownloadTemplateRequest) ProtoMessage()

+ func (x *DownloadTemplateRequest) GetName() string

+ func (x *DownloadTemplateRequest) GetVersion() string

+ func (x *DownloadTemplateRequest) GetWorkflowTemplateId() int32

+ func (x *DownloadTemplateRequest) ProtoReflect() protoreflect.Message

+ func (x *DownloadTemplateRequest) Reset()

+ func (x *DownloadTemplateRequest) String() string

+ type EditAndRetryTaskRequest struct

+ Command string

+ TaskId int32

+ func (*EditAndRetryTaskRequest) Descriptor() ([]byte, []int)

+ func (*EditAndRetryTaskRequest) ProtoMessage()

+ func (x *EditAndRetryTaskRequest) GetCommand() string

+ func (x *EditAndRetryTaskRequest) GetTaskId() int32

+ func (x *EditAndRetryTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *EditAndRetryTaskRequest) Reset()

+ func (x *EditAndRetryTaskRequest) String() string

+ type EditStepCommandRequest struct

+ Find string

+ IsRegexp bool

+ Replace string

+ StepId int32

+ func (*EditStepCommandRequest) Descriptor() ([]byte, []int)

+ func (*EditStepCommandRequest) ProtoMessage()

+ func (x *EditStepCommandRequest) GetFind() string

+ func (x *EditStepCommandRequest) GetIsRegexp() bool

+ func (x *EditStepCommandRequest) GetReplace() string

+ func (x *EditStepCommandRequest) GetStepId() int32

+ func (x *EditStepCommandRequest) ProtoReflect() protoreflect.Message

+ func (x *EditStepCommandRequest) Reset()

+ func (x *EditStepCommandRequest) String() string

+ type EditStepCommandResponse struct

+ EditedCount int32

+ NewTaskIds []int32

+ func (*EditStepCommandResponse) Descriptor() ([]byte, []int)

+ func (*EditStepCommandResponse) ProtoMessage()

+ func (x *EditStepCommandResponse) GetEditedCount() int32

+ func (x *EditStepCommandResponse) GetNewTaskIds() []int32

+ func (x *EditStepCommandResponse) ProtoReflect() protoreflect.Message

+ func (x *EditStepCommandResponse) Reset()

+ func (x *EditStepCommandResponse) String() string

+ type FileContent struct

+ Content []byte

+ Filename string

+ func (*FileContent) Descriptor() ([]byte, []int)

+ func (*FileContent) ProtoMessage()

+ func (x *FileContent) GetContent() []byte

+ func (x *FileContent) GetFilename() string

+ func (x *FileContent) ProtoReflect() protoreflect.Message

+ func (x *FileContent) Reset()

+ func (x *FileContent) String() string

+ type ForceRunTaskRequest struct

+ TaskId int32

+ func (*ForceRunTaskRequest) Descriptor() ([]byte, []int)

+ func (*ForceRunTaskRequest) ProtoMessage()

+ func (x *ForceRunTaskRequest) GetTaskId() int32

+ func (x *ForceRunTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *ForceRunTaskRequest) Reset()

+ func (x *ForceRunTaskRequest) String() string

+ type ModuleList struct

+ Modules []string

+ func (*ModuleList) Descriptor() ([]byte, []int)

+ func (*ModuleList) ProtoMessage()

+ func (x *ModuleList) GetModules() []string

+ func (x *ModuleList) ProtoReflect() protoreflect.Message

+ func (x *ModuleList) Reset()

+ func (x *ModuleList) String() string

type RunTemplateRequest

+ NoRecruiters bool

+ func (x *RunTemplateRequest) GetNoRecruiters() bool

type Task

+ Publish *string

+ SkipIfExists bool

+ func (x *Task) GetPublish() string

+ func (x *Task) GetSkipIfExists() bool

type TaskQueueClient

+ AdminResetPassword func(ctx context.Context, in *AdminResetPasswordRequest, opts ...grpc.CallOption) (*Ack, error)

+ CreateWorkerByName func(ctx context.Context, in *CreateWorkerByNameRequest, opts ...grpc.CallOption) (*WorkerIds, error)

+ DownloadModule func(ctx context.Context, in *DownloadModuleRequest, opts ...grpc.CallOption) (*FileContent, error)

+ DownloadTemplate func(ctx context.Context, in *DownloadTemplateRequest, opts ...grpc.CallOption) (*FileContent, error)

+ EditAndRetryTask func(ctx context.Context, in *EditAndRetryTaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)

+ EditStepCommand func(ctx context.Context, in *EditStepCommandRequest, opts ...grpc.CallOption) (*EditStepCommandResponse, error)

+ ForceRunTask func(ctx context.Context, in *ForceRunTaskRequest, opts ...grpc.CallOption) (*Ack, error)

+ GetResourceRoot func(ctx context.Context, in *WorkspaceRootRequest, opts ...grpc.CallOption) (*WorkspaceRootResponse, error)

+ ListModules func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ModuleList, error)

+ UploadModule func(ctx context.Context, in *UploadModuleRequest, opts ...grpc.CallOption) (*Ack, error)

type TaskQueueServer

+ AdminResetPassword func(context.Context, *AdminResetPasswordRequest) (*Ack, error)

+ CreateWorkerByName func(context.Context, *CreateWorkerByNameRequest) (*WorkerIds, error)

+ DownloadModule func(context.Context, *DownloadModuleRequest) (*FileContent, error)

+ DownloadTemplate func(context.Context, *DownloadTemplateRequest) (*FileContent, error)

+ EditAndRetryTask func(context.Context, *EditAndRetryTaskRequest) (*TaskResponse, error)

+ EditStepCommand func(context.Context, *EditStepCommandRequest) (*EditStepCommandResponse, error)

+ ForceRunTask func(context.Context, *ForceRunTaskRequest) (*Ack, error)

+ GetResourceRoot func(context.Context, *WorkspaceRootRequest) (*WorkspaceRootResponse, error)

+ ListModules func(context.Context, *emptypb.Empty) (*ModuleList, error)

+ UploadModule func(context.Context, *UploadModuleRequest) (*Ack, error)

type TaskRequest

+ AcceptFailure bool

+ Publish *string

+ SkipIfExists bool

+ func (x *TaskRequest) GetAcceptFailure() bool

+ func (x *TaskRequest) GetPublish() string

+ func (x *TaskRequest) GetSkipIfExists() bool

type UnimplementedTaskQueueServer

+ func (UnimplementedTaskQueueServer) AdminResetPassword(context.Context, *AdminResetPasswordRequest) (*Ack, error)

+ func (UnimplementedTaskQueueServer) CreateWorkerByName(context.Context, *CreateWorkerByNameRequest) (*WorkerIds, error)

+ func (UnimplementedTaskQueueServer) DownloadModule(context.Context, *DownloadModuleRequest) (*FileContent, error)

+ func (UnimplementedTaskQueueServer) DownloadTemplate(context.Context, *DownloadTemplateRequest) (*FileContent, error)

+ func (UnimplementedTaskQueueServer) EditAndRetryTask(context.Context, *EditAndRetryTaskRequest) (*TaskResponse, error)

+ func (UnimplementedTaskQueueServer) EditStepCommand(context.Context, *EditStepCommandRequest) (*EditStepCommandResponse, error)

+ func (UnimplementedTaskQueueServer) ForceRunTask(context.Context, *ForceRunTaskRequest) (*Ack, error)

+ func (UnimplementedTaskQueueServer) GetResourceRoot(context.Context, *WorkspaceRootRequest) (*WorkspaceRootResponse, error)

+ func (UnimplementedTaskQueueServer) ListModules(context.Context, *emptypb.Empty) (*ModuleList, error)

+ func (UnimplementedTaskQueueServer) UploadModule(context.Context, *UploadModuleRequest) (*Ack, error)

+ type UploadModuleRequest struct

+ Content []byte

+ Filename string

+ Force bool

+ func (*UploadModuleRequest) Descriptor() ([]byte, []int)

+ func (*UploadModuleRequest) ProtoMessage()

+ func (x *UploadModuleRequest) GetContent() []byte

+ func (x *UploadModuleRequest) GetFilename() string

+ func (x *UploadModuleRequest) GetForce() bool

+ func (x *UploadModuleRequest) ProtoReflect() protoreflect.Message

+ func (x *UploadModuleRequest) Reset()

+ func (x *UploadModuleRequest) String() string

type UploadTemplateRequest

+ Filename *string

+ func (x *UploadTemplateRequest) GetFilename() string

type WorkerStats

+ NumCpus int32

+ func (x *WorkerStats) GetNumCpus() int32

type Workflow

+ FailedTasks int32

+ RetryingTasks int32

+ RunningTasks int32

+ SucceededTasks int32

+ TotalTasks int32

+ func (x *Workflow) GetFailedTasks() int32

+ func (x *Workflow) GetRetryingTasks() int32

+ func (x *Workflow) GetRunningTasks() int32

+ func (x *Workflow) GetSucceededTasks() int32

+ func (x *Workflow) GetTotalTasks() int32

v0.6.2

Mar 22, 2026

Changes in this version

type WorkflowStatusUpdate

+ MaximumWorkers *int32

+ func (x *WorkflowStatusUpdate) GetMaximumWorkers() int32

v0.6.1

Mar 11, 2026

Changes in this version

+ const TaskQueue_GetTaskStatusCounts_FullMethodName

+ type StatusCountEntry struct

+ Count int32

+ Status string

+ WorkerId *int32

+ func (*StatusCountEntry) Descriptor() ([]byte, []int)

+ func (*StatusCountEntry) ProtoMessage()

+ func (x *StatusCountEntry) GetCount() int32

+ func (x *StatusCountEntry) GetStatus() string

+ func (x *StatusCountEntry) GetWorkerId() int32

+ func (x *StatusCountEntry) ProtoReflect() protoreflect.Message

+ func (x *StatusCountEntry) Reset()

+ func (x *StatusCountEntry) String() string

type TaskQueueClient

+ GetTaskStatusCounts func(ctx context.Context, in *TaskStatusCountsRequest, opts ...grpc.CallOption) (*TaskStatusCountsResponse, error)

type TaskQueueServer

+ GetTaskStatusCounts func(context.Context, *TaskStatusCountsRequest) (*TaskStatusCountsResponse, error)

+ type TaskStatusCountsRequest struct

+ ShowHidden *bool

+ func (*TaskStatusCountsRequest) Descriptor() ([]byte, []int)

+ func (*TaskStatusCountsRequest) ProtoMessage()

+ func (x *TaskStatusCountsRequest) GetShowHidden() bool

+ func (x *TaskStatusCountsRequest) ProtoReflect() protoreflect.Message

+ func (x *TaskStatusCountsRequest) Reset()

+ func (x *TaskStatusCountsRequest) String() string

+ type TaskStatusCountsResponse struct

+ GlobalCounts []*StatusCountEntry

+ PerWorkerCounts []*StatusCountEntry

+ TotalCount int32

+ func (*TaskStatusCountsResponse) Descriptor() ([]byte, []int)

+ func (*TaskStatusCountsResponse) ProtoMessage()

+ func (x *TaskStatusCountsResponse) GetGlobalCounts() []*StatusCountEntry

+ func (x *TaskStatusCountsResponse) GetPerWorkerCounts() []*StatusCountEntry

+ func (x *TaskStatusCountsResponse) GetTotalCount() int32

+ func (x *TaskStatusCountsResponse) ProtoReflect() protoreflect.Message

+ func (x *TaskStatusCountsResponse) Reset()

+ func (x *TaskStatusCountsResponse) String() string

type UnimplementedTaskQueueServer

+ func (UnimplementedTaskQueueServer) GetTaskStatusCounts(context.Context, *TaskStatusCountsRequest) (*TaskStatusCountsResponse, error)

v0.5.1

Feb 7, 2026

Changes in this version

+ const TaskQueue_ChangePassword_FullMethodName

+ const TaskQueue_CreateFlavor_FullMethodName

+ const TaskQueue_CreateRecruiter_FullMethodName

+ const TaskQueue_CreateStep_FullMethodName

+ const TaskQueue_CreateUser_FullMethodName

+ const TaskQueue_CreateWorker_FullMethodName

+ const TaskQueue_CreateWorkflow_FullMethodName

+ const TaskQueue_DebugAssignTask_FullMethodName

+ const TaskQueue_DebugRecruitStep_FullMethodName

+ const TaskQueue_DebugRetryTask_FullMethodName

+ const TaskQueue_DeleteJob_FullMethodName

+ const TaskQueue_DeleteRecruiter_FullMethodName

+ const TaskQueue_DeleteStep_FullMethodName

+ const TaskQueue_DeleteTemplateRun_FullMethodName

+ const TaskQueue_DeleteUser_FullMethodName

+ const TaskQueue_DeleteWorkerEvent_FullMethodName

+ const TaskQueue_DeleteWorker_FullMethodName

+ const TaskQueue_DeleteWorkflow_FullMethodName

+ const TaskQueue_FetchInfo_FullMethodName

+ const TaskQueue_FetchList_FullMethodName

+ const TaskQueue_GetCertificate_FullMethodName

+ const TaskQueue_GetDockerCredentials_FullMethodName

+ const TaskQueue_GetJobStatuses_FullMethodName

+ const TaskQueue_GetLogsChunk_FullMethodName

+ const TaskQueue_GetRcloneConfig_FullMethodName

+ const TaskQueue_GetStepStats_FullMethodName

+ const TaskQueue_GetWorkerStats_FullMethodName

+ const TaskQueue_GetWorkerStatuses_FullMethodName

+ const TaskQueue_GetWorkspaceRoot_FullMethodName

+ const TaskQueue_ListDependentPendingTasks_FullMethodName

+ const TaskQueue_ListFlavors_FullMethodName

+ const TaskQueue_ListJobs_FullMethodName

+ const TaskQueue_ListProviders_FullMethodName

+ const TaskQueue_ListRecruiters_FullMethodName

+ const TaskQueue_ListRegions_FullMethodName

+ const TaskQueue_ListSteps_FullMethodName

+ const TaskQueue_ListTasks_FullMethodName

+ const TaskQueue_ListTemplateRuns_FullMethodName

+ const TaskQueue_ListTemplates_FullMethodName

+ const TaskQueue_ListUsers_FullMethodName

+ const TaskQueue_ListWorkerEvents_FullMethodName

+ const TaskQueue_ListWorkers_FullMethodName

+ const TaskQueue_ListWorkflows_FullMethodName

+ const TaskQueue_Login_FullMethodName

+ const TaskQueue_Logout_FullMethodName

+ const TaskQueue_PingAndTakeNewTasks_FullMethodName

+ const TaskQueue_PruneWorkerEvents_FullMethodName

+ const TaskQueue_RegisterSpecifications_FullMethodName

+ const TaskQueue_RegisterWorker_FullMethodName

+ const TaskQueue_ReportWorkerEvent_FullMethodName

+ const TaskQueue_RetryTask_FullMethodName

+ const TaskQueue_RunTemplate_FullMethodName

+ const TaskQueue_SendTaskLogs_FullMethodName

+ const TaskQueue_StreamTaskLogsErr_FullMethodName

+ const TaskQueue_StreamTaskLogsOutput_FullMethodName

+ const TaskQueue_SubmitTask_FullMethodName

+ const TaskQueue_UpdateJob_FullMethodName

+ const TaskQueue_UpdateRecruiter_FullMethodName

+ const TaskQueue_UpdateTaskStatus_FullMethodName

+ const TaskQueue_UpdateTemplateRun_FullMethodName

+ const TaskQueue_UpdateUser_FullMethodName

+ const TaskQueue_UpdateWorkerStatus_FullMethodName

+ const TaskQueue_UpdateWorker_FullMethodName

+ const TaskQueue_UpdateWorkflowStatus_FullMethodName

+ const TaskQueue_UploadTemplate_FullMethodName

+ const TaskQueue_UserUpdateWorker_FullMethodName

+ var File_taskqueue_proto protoreflect.FileDescriptor

+ var TaskQueue_ServiceDesc = grpc.ServiceDesc

+ func RegisterTaskQueueServer(s grpc.ServiceRegistrar, srv TaskQueueServer)

+ type Accum struct

+ Count int32

+ Max float32

+ Min float32

+ Sum float32

+ func (*Accum) Descriptor() ([]byte, []int)

+ func (*Accum) ProtoMessage()

+ func (x *Accum) GetCount() int32

+ func (x *Accum) GetMax() float32

+ func (x *Accum) GetMin() float32

+ func (x *Accum) GetSum() float32

+ func (x *Accum) ProtoReflect() protoreflect.Message

+ func (x *Accum) Reset()

+ func (x *Accum) String() string

+ type Ack struct

+ Success bool

+ func (*Ack) Descriptor() ([]byte, []int)

+ func (*Ack) ProtoMessage()

+ func (x *Ack) GetSuccess() bool

+ func (x *Ack) ProtoReflect() protoreflect.Message

+ func (x *Ack) Reset()

+ func (x *Ack) String() string

+ type Certificate struct

+ Pem string

+ func (*Certificate) Descriptor() ([]byte, []int)

+ func (*Certificate) ProtoMessage()

+ func (x *Certificate) GetPem() string

+ func (x *Certificate) ProtoReflect() protoreflect.Message

+ func (x *Certificate) Reset()

+ func (x *Certificate) String() string

+ type ChangePasswordRequest struct

+ NewPassword string

+ OldPassword string

+ Username string

+ func (*ChangePasswordRequest) Descriptor() ([]byte, []int)

+ func (*ChangePasswordRequest) ProtoMessage()

+ func (x *ChangePasswordRequest) GetNewPassword() string

+ func (x *ChangePasswordRequest) GetOldPassword() string

+ func (x *ChangePasswordRequest) GetUsername() string

+ func (x *ChangePasswordRequest) ProtoReflect() protoreflect.Message

+ func (x *ChangePasswordRequest) Reset()

+ func (x *ChangePasswordRequest) String() string

+ type CreateUserRequest struct

+ Email string

+ IsAdmin bool

+ Password string

+ Username string

+ func (*CreateUserRequest) Descriptor() ([]byte, []int)

+ func (*CreateUserRequest) ProtoMessage()

+ func (x *CreateUserRequest) GetEmail() string

+ func (x *CreateUserRequest) GetIsAdmin() bool

+ func (x *CreateUserRequest) GetPassword() string

+ func (x *CreateUserRequest) GetUsername() string

+ func (x *CreateUserRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateUserRequest) Reset()

+ func (x *CreateUserRequest) String() string

+ type DebugAssignRequest struct

+ TaskId int32

+ WorkflowId int32

+ func (*DebugAssignRequest) Descriptor() ([]byte, []int)

+ func (*DebugAssignRequest) ProtoMessage()

+ func (x *DebugAssignRequest) GetTaskId() int32

+ func (x *DebugAssignRequest) GetWorkflowId() int32

+ func (x *DebugAssignRequest) ProtoReflect() protoreflect.Message

+ func (x *DebugAssignRequest) Reset()

+ func (x *DebugAssignRequest) String() string

+ type DebugRecruitRequest struct

+ StepId int32

+ WorkflowId int32

+ func (*DebugRecruitRequest) Descriptor() ([]byte, []int)

+ func (*DebugRecruitRequest) ProtoMessage()

+ func (x *DebugRecruitRequest) GetStepId() int32

+ func (x *DebugRecruitRequest) GetWorkflowId() int32

+ func (x *DebugRecruitRequest) ProtoReflect() protoreflect.Message

+ func (x *DebugRecruitRequest) Reset()

+ func (x *DebugRecruitRequest) String() string

+ type DeleteTemplateRunRequest struct

+ TemplateRunId int32

+ func (*DeleteTemplateRunRequest) Descriptor() ([]byte, []int)

+ func (*DeleteTemplateRunRequest) ProtoMessage()

+ func (x *DeleteTemplateRunRequest) GetTemplateRunId() int32

+ func (x *DeleteTemplateRunRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteTemplateRunRequest) Reset()

+ func (x *DeleteTemplateRunRequest) String() string

+ type DiskIOStats struct

+ ReadBytesRate float32

+ ReadBytesTotal int64

+ WriteBytesRate float32

+ WriteBytesTotal int64

+ func (*DiskIOStats) Descriptor() ([]byte, []int)

+ func (*DiskIOStats) ProtoMessage()

+ func (x *DiskIOStats) GetReadBytesRate() float32

+ func (x *DiskIOStats) GetReadBytesTotal() int64

+ func (x *DiskIOStats) GetWriteBytesRate() float32

+ func (x *DiskIOStats) GetWriteBytesTotal() int64

+ func (x *DiskIOStats) ProtoReflect() protoreflect.Message

+ func (x *DiskIOStats) Reset()

+ func (x *DiskIOStats) String() string

+ type DiskUsage struct

+ DeviceName string

+ UsagePercent float32

+ func (*DiskUsage) Descriptor() ([]byte, []int)

+ func (*DiskUsage) ProtoMessage()

+ func (x *DiskUsage) GetDeviceName() string

+ func (x *DiskUsage) GetUsagePercent() float32

+ func (x *DiskUsage) ProtoReflect() protoreflect.Message

+ func (x *DiskUsage) Reset()

+ func (x *DiskUsage) String() string

+ type DockerCredential struct

+ Auth string

+ Registry string

+ func (*DockerCredential) Descriptor() ([]byte, []int)

+ func (*DockerCredential) ProtoMessage()

+ func (x *DockerCredential) GetAuth() string

+ func (x *DockerCredential) GetRegistry() string

+ func (x *DockerCredential) ProtoReflect() protoreflect.Message

+ func (x *DockerCredential) Reset()

+ func (x *DockerCredential) String() string

+ type DockerCredentials struct

+ Credentials []*DockerCredential

+ func (*DockerCredentials) Descriptor() ([]byte, []int)

+ func (*DockerCredentials) ProtoMessage()

+ func (x *DockerCredentials) GetCredentials() []*DockerCredential

+ func (x *DockerCredentials) ProtoReflect() protoreflect.Message

+ func (x *DockerCredentials) Reset()

+ func (x *DockerCredentials) String() string

+ type FetchInfoResponse struct

+ Description string

+ Filename string

+ IsDir bool

+ IsFile bool

+ Size int64

+ Uri string

+ func (*FetchInfoResponse) Descriptor() ([]byte, []int)

+ func (*FetchInfoResponse) ProtoMessage()

+ 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 (x *FetchInfoResponse) ProtoReflect() protoreflect.Message

+ func (x *FetchInfoResponse) Reset()

+ func (x *FetchInfoResponse) String() string

+ type FetchListRequest struct

+ Uri string

+ func (*FetchListRequest) Descriptor() ([]byte, []int)

+ func (*FetchListRequest) ProtoMessage()

+ func (x *FetchListRequest) GetUri() string

+ func (x *FetchListRequest) ProtoReflect() protoreflect.Message

+ func (x *FetchListRequest) Reset()

+ func (x *FetchListRequest) String() string

+ type FetchListResponse struct

+ Files []string

+ func (*FetchListResponse) Descriptor() ([]byte, []int)

+ func (*FetchListResponse) ProtoMessage()

+ func (x *FetchListResponse) GetFiles() []string

+ func (x *FetchListResponse) ProtoReflect() protoreflect.Message

+ func (x *FetchListResponse) Reset()

+ func (x *FetchListResponse) String() string

+ type Flavor struct

+ Bandwidth int32

+ Cost float32

+ Cpu int32

+ Disk float32

+ Eviction float32

+ FlavorId int32

+ FlavorName string

+ Gpu string

+ Gpumem int32

+ HasGpu bool

+ HasQuickDisks bool

+ Mem float32

+ Provider string

+ ProviderId int32

+ Region string

+ RegionId int32

+ func (*Flavor) Descriptor() ([]byte, []int)

+ func (*Flavor) ProtoMessage()

+ 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 (x *Flavor) ProtoReflect() protoreflect.Message

+ func (x *Flavor) Reset()

+ func (x *Flavor) String() string

+ type FlavorCreateRequest struct

+ Bandwidth *int32

+ ConfigName string

+ Costs []float32

+ Cpu int32

+ Disk float32

+ Evictions []float32

+ FlavorName string

+ Gpu *string

+ Gpumem *int32

+ HasGpu *bool

+ HasQuickDisks *bool

+ Memory float32

+ ProviderName string

+ RegionNames []string

+ func (*FlavorCreateRequest) Descriptor() ([]byte, []int)

+ func (*FlavorCreateRequest) ProtoMessage()

+ 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 (x *FlavorCreateRequest) ProtoReflect() protoreflect.Message

+ func (x *FlavorCreateRequest) Reset()

+ func (x *FlavorCreateRequest) String() string

+ type FlavorId struct

+ FlavorId int32

+ func (*FlavorId) Descriptor() ([]byte, []int)

+ func (*FlavorId) ProtoMessage()

+ func (x *FlavorId) GetFlavorId() int32

+ func (x *FlavorId) ProtoReflect() protoreflect.Message

+ func (x *FlavorId) Reset()

+ func (x *FlavorId) String() string

+ type FlavorsList struct

+ Flavors []*Flavor

+ func (*FlavorsList) Descriptor() ([]byte, []int)

+ func (*FlavorsList) ProtoMessage()

+ func (x *FlavorsList) GetFlavors() []*Flavor

+ func (x *FlavorsList) ProtoReflect() protoreflect.Message

+ func (x *FlavorsList) Reset()

+ func (x *FlavorsList) String() string

+ type GetLogsRequest struct

+ ChunkSize int32

+ LogType *string

+ SkipFromEnd *int32

+ TaskIds []int32

+ func (*GetLogsRequest) Descriptor() ([]byte, []int)

+ func (*GetLogsRequest) ProtoMessage()

+ func (x *GetLogsRequest) GetChunkSize() int32

+ func (x *GetLogsRequest) GetLogType() string

+ func (x *GetLogsRequest) GetSkipFromEnd() int32

+ func (x *GetLogsRequest) GetTaskIds() []int32

+ func (x *GetLogsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetLogsRequest) Reset()

+ func (x *GetLogsRequest) String() string

+ type GetWorkerStatsRequest struct

+ WorkerIds []int32

+ func (*GetWorkerStatsRequest) Descriptor() ([]byte, []int)

+ func (*GetWorkerStatsRequest) ProtoMessage()

+ func (x *GetWorkerStatsRequest) GetWorkerIds() []int32

+ func (x *GetWorkerStatsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetWorkerStatsRequest) Reset()

+ func (x *GetWorkerStatsRequest) String() string

+ type GetWorkerStatsResponse struct

+ WorkerStats map[int32]*WorkerStats

+ func (*GetWorkerStatsResponse) Descriptor() ([]byte, []int)

+ func (*GetWorkerStatsResponse) ProtoMessage()

+ func (x *GetWorkerStatsResponse) GetWorkerStats() map[int32]*WorkerStats

+ func (x *GetWorkerStatsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetWorkerStatsResponse) Reset()

+ func (x *GetWorkerStatsResponse) String() string

+ type Job struct

+ Action string

+ CreatedAt string

+ FlavorId int32

+ JobId int32

+ Log string

+ ModifiedAt string

+ Progression int32

+ Retry int32

+ Status string

+ WorkerId int32

+ func (*Job) Descriptor() ([]byte, []int)

+ func (*Job) ProtoMessage()

+ 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 (x *Job) ProtoReflect() protoreflect.Message

+ func (x *Job) Reset()

+ func (x *Job) String() string

+ type JobId struct

+ JobId int32

+ func (*JobId) Descriptor() ([]byte, []int)

+ func (*JobId) ProtoMessage()

+ func (x *JobId) GetJobId() int32

+ func (x *JobId) ProtoReflect() protoreflect.Message

+ func (x *JobId) Reset()

+ func (x *JobId) String() string

+ type JobStatus struct

+ JobId int32

+ Progression int32

+ Status string

+ func (*JobStatus) Descriptor() ([]byte, []int)

+ func (*JobStatus) ProtoMessage()

+ func (x *JobStatus) GetJobId() int32

+ func (x *JobStatus) GetProgression() int32

+ func (x *JobStatus) GetStatus() string

+ func (x *JobStatus) ProtoReflect() protoreflect.Message

+ func (x *JobStatus) Reset()

+ func (x *JobStatus) String() string

+ type JobStatusRequest struct

+ JobIds []int32

+ func (*JobStatusRequest) Descriptor() ([]byte, []int)

+ func (*JobStatusRequest) ProtoMessage()

+ func (x *JobStatusRequest) GetJobIds() []int32

+ func (x *JobStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *JobStatusRequest) Reset()

+ func (x *JobStatusRequest) String() string

+ type JobStatusResponse struct

+ Statuses []*JobStatus

+ func (*JobStatusResponse) Descriptor() ([]byte, []int)

+ func (*JobStatusResponse) ProtoMessage()

+ func (x *JobStatusResponse) GetStatuses() []*JobStatus

+ func (x *JobStatusResponse) ProtoReflect() protoreflect.Message

+ func (x *JobStatusResponse) Reset()

+ func (x *JobStatusResponse) String() string

+ type JobUpdate struct

+ AppendLog *string

+ JobId int32

+ Progression *int32

+ Status *string

+ func (*JobUpdate) Descriptor() ([]byte, []int)

+ func (*JobUpdate) ProtoMessage()

+ func (x *JobUpdate) GetAppendLog() string

+ func (x *JobUpdate) GetJobId() int32

+ func (x *JobUpdate) GetProgression() int32

+ func (x *JobUpdate) GetStatus() string

+ func (x *JobUpdate) ProtoReflect() protoreflect.Message

+ func (x *JobUpdate) Reset()

+ func (x *JobUpdate) String() string

+ type JobsList struct

+ Jobs []*Job

+ func (*JobsList) Descriptor() ([]byte, []int)

+ func (*JobsList) ProtoMessage()

+ func (x *JobsList) GetJobs() []*Job

+ func (x *JobsList) ProtoReflect() protoreflect.Message

+ func (x *JobsList) Reset()

+ func (x *JobsList) String() string

+ type ListFlavorsRequest struct

+ Filter string

+ Limit int32

+ func (*ListFlavorsRequest) Descriptor() ([]byte, []int)

+ func (*ListFlavorsRequest) ProtoMessage()

+ func (x *ListFlavorsRequest) GetFilter() string

+ func (x *ListFlavorsRequest) GetLimit() int32

+ func (x *ListFlavorsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListFlavorsRequest) Reset()

+ func (x *ListFlavorsRequest) String() string

+ type ListJobsRequest struct

+ Limit *int32

+ Offset *int32

+ func (*ListJobsRequest) Descriptor() ([]byte, []int)

+ func (*ListJobsRequest) ProtoMessage()

+ func (x *ListJobsRequest) GetLimit() int32

+ func (x *ListJobsRequest) GetOffset() int32

+ func (x *ListJobsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListJobsRequest) Reset()

+ func (x *ListJobsRequest) String() string

+ type ListTasksRequest struct

+ CommandFilter *string

+ Limit *int32

+ Offset *int32

+ ShowHidden *bool

+ StatusFilter *string

+ StepIdFilter *int32

+ WorkerIdFilter *int32

+ WorkflowIdFilter *int32

+ func (*ListTasksRequest) Descriptor() ([]byte, []int)

+ func (*ListTasksRequest) ProtoMessage()

+ 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 (x *ListTasksRequest) ProtoReflect() protoreflect.Message

+ func (x *ListTasksRequest) Reset()

+ func (x *ListTasksRequest) String() string

+ type ListWorkersRequest struct

+ WorkflowId *int32

+ func (*ListWorkersRequest) Descriptor() ([]byte, []int)

+ func (*ListWorkersRequest) ProtoMessage()

+ func (x *ListWorkersRequest) GetWorkflowId() int32

+ func (x *ListWorkersRequest) ProtoReflect() protoreflect.Message

+ func (x *ListWorkersRequest) Reset()

+ func (x *ListWorkersRequest) String() string

+ type LogChunk struct

+ Stderr []string

+ Stdout []string

+ TaskId int32

+ func (*LogChunk) Descriptor() ([]byte, []int)

+ func (*LogChunk) ProtoMessage()

+ func (x *LogChunk) GetStderr() []string

+ func (x *LogChunk) GetStdout() []string

+ func (x *LogChunk) GetTaskId() int32

+ func (x *LogChunk) ProtoReflect() protoreflect.Message

+ func (x *LogChunk) Reset()

+ func (x *LogChunk) String() string

+ type LogChunkList struct

+ Logs []*LogChunk

+ func (*LogChunkList) Descriptor() ([]byte, []int)

+ func (*LogChunkList) ProtoMessage()

+ func (x *LogChunkList) GetLogs() []*LogChunk

+ func (x *LogChunkList) ProtoReflect() protoreflect.Message

+ func (x *LogChunkList) Reset()

+ func (x *LogChunkList) String() string

+ type LoginRequest struct

+ Password string

+ Username string

+ func (*LoginRequest) Descriptor() ([]byte, []int)

+ func (*LoginRequest) ProtoMessage()

+ func (x *LoginRequest) GetPassword() string

+ func (x *LoginRequest) GetUsername() string

+ func (x *LoginRequest) ProtoReflect() protoreflect.Message

+ func (x *LoginRequest) Reset()

+ func (x *LoginRequest) String() string

+ type LoginResponse struct

+ Token string

+ func (*LoginResponse) Descriptor() ([]byte, []int)

+ func (*LoginResponse) ProtoMessage()

+ func (x *LoginResponse) GetToken() string

+ func (x *LoginResponse) ProtoReflect() protoreflect.Message

+ func (x *LoginResponse) Reset()

+ func (x *LoginResponse) String() string

+ type NetIOStats struct

+ RecvBytesRate float32

+ RecvBytesTotal int64

+ SentBytesRate float32

+ SentBytesTotal int64

+ func (*NetIOStats) Descriptor() ([]byte, []int)

+ func (*NetIOStats) ProtoMessage()

+ func (x *NetIOStats) GetRecvBytesRate() float32

+ func (x *NetIOStats) GetRecvBytesTotal() int64

+ func (x *NetIOStats) GetSentBytesRate() float32

+ func (x *NetIOStats) GetSentBytesTotal() int64

+ func (x *NetIOStats) ProtoReflect() protoreflect.Message

+ func (x *NetIOStats) Reset()

+ func (x *NetIOStats) String() string

+ type PingAndGetNewTasksRequest struct

+ Stats *WorkerStats

+ WorkerId int32

+ func (*PingAndGetNewTasksRequest) Descriptor() ([]byte, []int)

+ func (*PingAndGetNewTasksRequest) ProtoMessage()

+ func (x *PingAndGetNewTasksRequest) GetStats() *WorkerStats

+ func (x *PingAndGetNewTasksRequest) GetWorkerId() int32

+ func (x *PingAndGetNewTasksRequest) ProtoReflect() protoreflect.Message

+ func (x *PingAndGetNewTasksRequest) Reset()

+ func (x *PingAndGetNewTasksRequest) String() string

+ type Provider struct

+ ConfigName string

+ ProviderId int32

+ ProviderName string

+ func (*Provider) Descriptor() ([]byte, []int)

+ func (*Provider) ProtoMessage()

+ func (x *Provider) GetConfigName() string

+ func (x *Provider) GetProviderId() int32

+ func (x *Provider) GetProviderName() string

+ func (x *Provider) ProtoReflect() protoreflect.Message

+ func (x *Provider) Reset()

+ func (x *Provider) String() string

+ type ProviderList struct

+ Providers []*Provider

+ func (*ProviderList) Descriptor() ([]byte, []int)

+ func (*ProviderList) ProtoMessage()

+ func (x *ProviderList) GetProviders() []*Provider

+ func (x *ProviderList) ProtoReflect() protoreflect.Message

+ func (x *ProviderList) Reset()

+ func (x *ProviderList) String() string

+ type RcloneRemote struct

+ Options map[string]string

+ func (*RcloneRemote) Descriptor() ([]byte, []int)

+ func (*RcloneRemote) ProtoMessage()

+ func (x *RcloneRemote) GetOptions() map[string]string

+ func (x *RcloneRemote) ProtoReflect() protoreflect.Message

+ func (x *RcloneRemote) Reset()

+ func (x *RcloneRemote) String() string

+ type RcloneRemotes struct

+ Remotes map[string]*RcloneRemote

+ func (*RcloneRemotes) Descriptor() ([]byte, []int)

+ func (*RcloneRemotes) ProtoMessage()

+ func (x *RcloneRemotes) GetRemotes() map[string]*RcloneRemote

+ func (x *RcloneRemotes) ProtoReflect() protoreflect.Message

+ func (x *RcloneRemotes) Reset()

+ func (x *RcloneRemotes) String() string

+ type Recruiter struct

+ Concurrency *int32

+ ConcurrencyMax *int32

+ ConcurrencyMin *int32

+ CpuPerTask *int32

+ DiskPerTask *float32

+ MaxWorkers *int32

+ MemoryPerTask *float32

+ Prefetch *int32

+ PrefetchPercent *int32

+ Protofilter string

+ Rank int32

+ Rounds int32

+ StepId int32

+ Timeout int32

+ func (*Recruiter) Descriptor() ([]byte, []int)

+ func (*Recruiter) ProtoMessage()

+ 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 (x *Recruiter) ProtoReflect() protoreflect.Message

+ func (x *Recruiter) Reset()

+ func (x *Recruiter) String() string

+ type RecruiterFilter struct

+ StepId *int32

+ func (*RecruiterFilter) Descriptor() ([]byte, []int)

+ func (*RecruiterFilter) ProtoMessage()

+ func (x *RecruiterFilter) GetStepId() int32

+ func (x *RecruiterFilter) ProtoReflect() protoreflect.Message

+ func (x *RecruiterFilter) Reset()

+ func (x *RecruiterFilter) String() string

+ type RecruiterId struct

+ Rank int32

+ StepId int32

+ func (*RecruiterId) Descriptor() ([]byte, []int)

+ func (*RecruiterId) ProtoMessage()

+ func (x *RecruiterId) GetRank() int32

+ func (x *RecruiterId) GetStepId() int32

+ func (x *RecruiterId) ProtoReflect() protoreflect.Message

+ func (x *RecruiterId) Reset()

+ func (x *RecruiterId) String() string

+ type RecruiterList struct

+ Recruiters []*Recruiter

+ func (*RecruiterList) Descriptor() ([]byte, []int)

+ func (*RecruiterList) ProtoMessage()

+ func (x *RecruiterList) GetRecruiters() []*Recruiter

+ func (x *RecruiterList) ProtoReflect() protoreflect.Message

+ func (x *RecruiterList) Reset()

+ func (x *RecruiterList) String() string

+ type RecruiterUpdate struct

+ Concurrency *int32

+ ConcurrencyMax *int32

+ ConcurrencyMin *int32

+ CpuPerTask *int32

+ DiskPerTask *float32

+ MaxWorkers *int32

+ MemoryPerTask *float32

+ Prefetch *int32

+ PrefetchPercent *int32

+ Protofilter *string

+ Rank int32

+ Rounds *int32

+ StepId int32

+ Timeout *int32

+ func (*RecruiterUpdate) Descriptor() ([]byte, []int)

+ func (*RecruiterUpdate) ProtoMessage()

+ 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 (x *RecruiterUpdate) ProtoReflect() protoreflect.Message

+ func (x *RecruiterUpdate) Reset()

+ func (x *RecruiterUpdate) String() string

+ type Region struct

+ IsDefault bool

+ ProviderId int32

+ RegionId int32

+ RegionName string

+ func (*Region) Descriptor() ([]byte, []int)

+ func (*Region) ProtoMessage()

+ func (x *Region) GetIsDefault() bool

+ func (x *Region) GetProviderId() int32

+ func (x *Region) GetRegionId() int32

+ func (x *Region) GetRegionName() string

+ func (x *Region) ProtoReflect() protoreflect.Message

+ func (x *Region) Reset()

+ func (x *Region) String() string

+ type RegionList struct

+ Regions []*Region

+ func (*RegionList) Descriptor() ([]byte, []int)

+ func (*RegionList) ProtoMessage()

+ func (x *RegionList) GetRegions() []*Region

+ func (x *RegionList) ProtoReflect() protoreflect.Message

+ func (x *RegionList) Reset()

+ func (x *RegionList) String() string

+ type ResourceSpec struct

+ Cpu int32

+ Disk float32

+ Mem float32

+ WorkerId string

+ func (*ResourceSpec) Descriptor() ([]byte, []int)

+ func (*ResourceSpec) ProtoMessage()

+ func (x *ResourceSpec) GetCpu() int32

+ func (x *ResourceSpec) GetDisk() float32

+ func (x *ResourceSpec) GetMem() float32

+ func (x *ResourceSpec) GetWorkerId() string

+ func (x *ResourceSpec) ProtoReflect() protoreflect.Message

+ func (x *ResourceSpec) Reset()

+ func (x *ResourceSpec) String() string

+ type RetryTaskRequest struct

+ Retry *int32

+ TaskId int32

+ func (*RetryTaskRequest) Descriptor() ([]byte, []int)

+ func (*RetryTaskRequest) ProtoMessage()

+ func (x *RetryTaskRequest) GetRetry() int32

+ func (x *RetryTaskRequest) GetTaskId() int32

+ func (x *RetryTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *RetryTaskRequest) Reset()

+ func (x *RetryTaskRequest) String() string

+ type RunTemplateRequest struct

+ ParamValuesJson string

+ WorkflowTemplateId int32

+ func (*RunTemplateRequest) Descriptor() ([]byte, []int)

+ func (*RunTemplateRequest) ProtoMessage()

+ func (x *RunTemplateRequest) GetParamValuesJson() string

+ func (x *RunTemplateRequest) GetWorkflowTemplateId() int32

+ func (x *RunTemplateRequest) ProtoReflect() protoreflect.Message

+ func (x *RunTemplateRequest) Reset()

+ func (x *RunTemplateRequest) String() string

+ type Step struct

+ Name string

+ StepId int32

+ WorkflowId int32

+ WorkflowName string

+ func (*Step) Descriptor() ([]byte, []int)

+ func (*Step) ProtoMessage()

+ func (x *Step) GetName() string

+ func (x *Step) GetStepId() int32

+ func (x *Step) GetWorkflowId() int32

+ func (x *Step) GetWorkflowName() string

+ func (x *Step) ProtoReflect() protoreflect.Message

+ func (x *Step) Reset()

+ func (x *Step) String() string

+ type StepFilter struct

+ Limit *int32

+ Offset *int32

+ WorkflowId int32

+ func (*StepFilter) Descriptor() ([]byte, []int)

+ func (*StepFilter) ProtoMessage()

+ func (x *StepFilter) GetLimit() int32

+ func (x *StepFilter) GetOffset() int32

+ func (x *StepFilter) GetWorkflowId() int32

+ func (x *StepFilter) ProtoReflect() protoreflect.Message

+ func (x *StepFilter) Reset()

+ func (x *StepFilter) String() string

+ type StepId struct

+ StepId int32

+ func (*StepId) Descriptor() ([]byte, []int)

+ func (*StepId) ProtoMessage()

+ func (x *StepId) GetStepId() int32

+ func (x *StepId) ProtoReflect() protoreflect.Message

+ func (x *StepId) Reset()

+ func (x *StepId) String() string

+ type StepList struct

+ Steps []*Step

+ func (*StepList) Descriptor() ([]byte, []int)

+ func (*StepList) ProtoMessage()

+ func (x *StepList) GetSteps() []*Step

+ func (x *StepList) ProtoReflect() protoreflect.Message

+ func (x *StepList) Reset()

+ func (x *StepList) String() string

+ type StepRequest struct

+ Name string

+ WorkflowId *int32

+ WorkflowName *string

+ func (*StepRequest) Descriptor() ([]byte, []int)

+ func (*StepRequest) ProtoMessage()

+ func (x *StepRequest) GetName() string

+ func (x *StepRequest) GetWorkflowId() int32

+ func (x *StepRequest) GetWorkflowName() string

+ func (x *StepRequest) ProtoReflect() protoreflect.Message

+ func (x *StepRequest) Reset()

+ func (x *StepRequest) String() string

+ type StepStats struct

+ AcceptedTasks int32

+ Download *Accum

+ EndTime *int64

+ FailedRun *Accum

+ FailedTasks int32

+ PendingTasks int32

+ ReallyFailedTasks int32

+ RunningRun *Accum

+ RunningTasks int32

+ StartTime *int64

+ StatsEvalTime int32

+ StepId int32

+ StepName string

+ SuccessRun *Accum

+ SuccessfulTasks int32

+ TotalTasks int32

+ Upload *Accum

+ UploadingTasks int32

+ WaitingTasks int32

+ func (*StepStats) Descriptor() ([]byte, []int)

+ func (*StepStats) ProtoMessage()

+ 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 (x *StepStats) ProtoReflect() protoreflect.Message

+ func (x *StepStats) Reset()

+ func (x *StepStats) String() string

+ type StepStatsRequest struct

+ StepIds []int32

+ WorkflowId *int32

+ func (*StepStatsRequest) Descriptor() ([]byte, []int)

+ func (*StepStatsRequest) ProtoMessage()

+ func (x *StepStatsRequest) GetStepIds() []int32

+ func (x *StepStatsRequest) GetWorkflowId() int32

+ func (x *StepStatsRequest) ProtoReflect() protoreflect.Message

+ func (x *StepStatsRequest) Reset()

+ func (x *StepStatsRequest) String() string

+ type StepStatsResponse struct

+ Stats []*StepStats

+ func (*StepStatsResponse) Descriptor() ([]byte, []int)

+ func (*StepStatsResponse) ProtoMessage()

+ func (x *StepStatsResponse) GetStats() []*StepStats

+ func (x *StepStatsResponse) ProtoReflect() protoreflect.Message

+ func (x *StepStatsResponse) Reset()

+ func (x *StepStatsResponse) String() string

+ type Task struct

+ Command string

+ Container string

+ ContainerOptions *string

+ DownloadTimeout *float32

+ Hidden bool

+ Input []string

+ IsFinal *bool

+ Output *string

+ PreviousTaskId *int32

+ Resource []string

+ Retry *int32

+ RetryCount int32

+ RunStartTime *int64

+ RunningTimeout *float32

+ Shell *string

+ Status string

+ StepId *int32

+ TaskId int32

+ TaskName *string

+ UploadTimeout *float32

+ UsesCache *bool

+ Weight *float64

+ WorkerId *int32

+ WorkflowId *int32

+ func (*Task) Descriptor() ([]byte, []int)

+ func (*Task) ProtoMessage()

+ 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 (x *Task) ProtoReflect() protoreflect.Message

+ func (x *Task) Reset()

+ func (x *Task) String() string

+ type TaskId struct

+ TaskId int32

+ func (*TaskId) Descriptor() ([]byte, []int)

+ func (*TaskId) ProtoMessage()

+ func (x *TaskId) GetTaskId() int32

+ func (x *TaskId) ProtoReflect() protoreflect.Message

+ func (x *TaskId) Reset()

+ func (x *TaskId) String() string

+ type TaskIds struct

+ TaskIds []int32

+ func (*TaskIds) Descriptor() ([]byte, []int)

+ func (*TaskIds) ProtoMessage()

+ func (x *TaskIds) GetTaskIds() []int32

+ func (x *TaskIds) ProtoReflect() protoreflect.Message

+ func (x *TaskIds) Reset()

+ func (x *TaskIds) String() string

+ type TaskList struct

+ Tasks []*Task

+ func (*TaskList) Descriptor() ([]byte, []int)

+ func (*TaskList) ProtoMessage()

+ func (x *TaskList) GetTasks() []*Task

+ func (x *TaskList) ProtoReflect() protoreflect.Message

+ func (x *TaskList) Reset()

+ func (x *TaskList) String() string

+ type TaskListAndOther struct

+ ActiveTasks []int32

+ Concurrency int32

+ Tasks []*Task

+ Updates *TaskUpdateList

+ func (*TaskListAndOther) Descriptor() ([]byte, []int)

+ func (*TaskListAndOther) ProtoMessage()

+ func (x *TaskListAndOther) GetActiveTasks() []int32

+ func (x *TaskListAndOther) GetConcurrency() int32

+ func (x *TaskListAndOther) GetTasks() []*Task

+ func (x *TaskListAndOther) GetUpdates() *TaskUpdateList

+ func (x *TaskListAndOther) ProtoReflect() protoreflect.Message

+ func (x *TaskListAndOther) Reset()

+ func (x *TaskListAndOther) String() string

+ type TaskLog struct

+ LogText string

+ LogType string

+ TaskId int32

+ func (*TaskLog) Descriptor() ([]byte, []int)

+ func (*TaskLog) ProtoMessage()

+ func (x *TaskLog) GetLogText() string

+ func (x *TaskLog) GetLogType() string

+ func (x *TaskLog) GetTaskId() int32

+ func (x *TaskLog) ProtoReflect() protoreflect.Message

+ func (x *TaskLog) Reset()

+ func (x *TaskLog) String() string

+ type TaskQueueClient interface

+ ChangePassword func(ctx context.Context, in *ChangePasswordRequest, opts ...grpc.CallOption) (*Ack, error)

+ CreateFlavor func(ctx context.Context, in *FlavorCreateRequest, opts ...grpc.CallOption) (*FlavorId, error)

+ CreateRecruiter func(ctx context.Context, in *Recruiter, opts ...grpc.CallOption) (*Ack, error)

+ CreateStep func(ctx context.Context, in *StepRequest, opts ...grpc.CallOption) (*StepId, error)

+ CreateUser func(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*UserId, error)

+ CreateWorker func(ctx context.Context, in *WorkerRequest, opts ...grpc.CallOption) (*WorkerIds, error)

+ CreateWorkflow func(ctx context.Context, in *WorkflowRequest, opts ...grpc.CallOption) (*WorkflowId, error)

+ DebugAssignTask func(ctx context.Context, in *DebugAssignRequest, opts ...grpc.CallOption) (*Ack, error)

+ DebugRecruitStep func(ctx context.Context, in *DebugRecruitRequest, opts ...grpc.CallOption) (*Ack, error)

+ DebugRetryTask func(ctx context.Context, in *RetryTaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)

+ DeleteJob func(ctx context.Context, in *JobId, opts ...grpc.CallOption) (*Ack, error)

+ DeleteRecruiter func(ctx context.Context, in *RecruiterId, opts ...grpc.CallOption) (*Ack, error)

+ DeleteStep func(ctx context.Context, in *StepId, opts ...grpc.CallOption) (*Ack, error)

+ DeleteTemplateRun func(ctx context.Context, in *DeleteTemplateRunRequest, opts ...grpc.CallOption) (*Ack, error)

+ DeleteUser func(ctx context.Context, in *UserId, opts ...grpc.CallOption) (*Ack, error)

+ DeleteWorker func(ctx context.Context, in *WorkerDeletion, opts ...grpc.CallOption) (*JobId, error)

+ DeleteWorkerEvent func(ctx context.Context, in *WorkerEventId, opts ...grpc.CallOption) (*Ack, error)

+ DeleteWorkflow func(ctx context.Context, in *WorkflowId, opts ...grpc.CallOption) (*Ack, error)

+ FetchInfo func(ctx context.Context, in *FetchListRequest, opts ...grpc.CallOption) (*FetchInfoResponse, error)

+ FetchList func(ctx context.Context, in *FetchListRequest, opts ...grpc.CallOption) (*FetchListResponse, error)

+ GetCertificate func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Certificate, error)

+ GetDockerCredentials func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DockerCredentials, error)

+ GetJobStatuses func(ctx context.Context, in *JobStatusRequest, opts ...grpc.CallOption) (*JobStatusResponse, error)

+ GetLogsChunk func(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*LogChunkList, error)

+ GetRcloneConfig func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RcloneRemotes, error)

+ GetStepStats func(ctx context.Context, in *StepStatsRequest, opts ...grpc.CallOption) (*StepStatsResponse, error)

+ GetWorkerStats func(ctx context.Context, in *GetWorkerStatsRequest, opts ...grpc.CallOption) (*GetWorkerStatsResponse, error)

+ GetWorkerStatuses func(ctx context.Context, in *WorkerStatusRequest, opts ...grpc.CallOption) (*WorkerStatusResponse, error)

+ GetWorkspaceRoot func(ctx context.Context, in *WorkspaceRootRequest, opts ...grpc.CallOption) (*WorkspaceRootResponse, error)

+ ListDependentPendingTasks func(ctx context.Context, in *TaskId, opts ...grpc.CallOption) (*TaskIds, error)

+ ListFlavors func(ctx context.Context, in *ListFlavorsRequest, opts ...grpc.CallOption) (*FlavorsList, error)

+ ListJobs func(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*JobsList, error)

+ ListProviders func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ProviderList, error)

+ ListRecruiters func(ctx context.Context, in *RecruiterFilter, opts ...grpc.CallOption) (*RecruiterList, error)

+ ListRegions func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RegionList, error)

+ ListSteps func(ctx context.Context, in *StepFilter, opts ...grpc.CallOption) (*StepList, error)

+ ListTasks func(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*TaskList, error)

+ ListTemplateRuns func(ctx context.Context, in *TemplateRunFilter, opts ...grpc.CallOption) (*TemplateRunList, error)

+ ListTemplates func(ctx context.Context, in *TemplateFilter, opts ...grpc.CallOption) (*TemplateList, error)

+ ListUsers func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*UsersList, error)

+ ListWorkerEvents func(ctx context.Context, in *WorkerEventFilter, opts ...grpc.CallOption) (*WorkerEventList, error)

+ ListWorkers func(ctx context.Context, in *ListWorkersRequest, opts ...grpc.CallOption) (*WorkersList, error)

+ ListWorkflows func(ctx context.Context, in *WorkflowFilter, opts ...grpc.CallOption) (*WorkflowList, error)

+ Login func(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error)

+ Logout func(ctx context.Context, in *Token, opts ...grpc.CallOption) (*Ack, error)

+ PingAndTakeNewTasks func(ctx context.Context, in *PingAndGetNewTasksRequest, opts ...grpc.CallOption) (*TaskListAndOther, error)

+ PruneWorkerEvents func(ctx context.Context, in *WorkerEventPruneFilter, opts ...grpc.CallOption) (*WorkerEventPruneResult, error)

+ RegisterSpecifications func(ctx context.Context, in *ResourceSpec, opts ...grpc.CallOption) (*Ack, error)

+ RegisterWorker func(ctx context.Context, in *WorkerInfo, opts ...grpc.CallOption) (*WorkerId, error)

+ ReportWorkerEvent func(ctx context.Context, in *WorkerEvent, opts ...grpc.CallOption) (*Ack, error)

+ RetryTask func(ctx context.Context, in *RetryTaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)

+ RunTemplate func(ctx context.Context, in *RunTemplateRequest, opts ...grpc.CallOption) (*TemplateRun, error)

+ SendTaskLogs func(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[TaskLog, Ack], error)

+ StreamTaskLogsErr func(ctx context.Context, in *TaskId, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TaskLog], error)

+ StreamTaskLogsOutput func(ctx context.Context, in *TaskId, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TaskLog], error)

+ SubmitTask func(ctx context.Context, in *TaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)

+ UpdateJob func(ctx context.Context, in *JobUpdate, opts ...grpc.CallOption) (*Ack, error)

+ UpdateRecruiter func(ctx context.Context, in *RecruiterUpdate, opts ...grpc.CallOption) (*Ack, error)

+ UpdateTaskStatus func(ctx context.Context, in *TaskStatusUpdate, opts ...grpc.CallOption) (*Ack, error)

+ UpdateTemplateRun func(ctx context.Context, in *UpdateTemplateRunRequest, opts ...grpc.CallOption) (*Ack, error)

+ UpdateUser func(ctx context.Context, in *User, opts ...grpc.CallOption) (*Ack, error)

+ UpdateWorker func(ctx context.Context, in *WorkerUpdateRequest, opts ...grpc.CallOption) (*Ack, error)

+ UpdateWorkerStatus func(ctx context.Context, in *WorkerStatus, opts ...grpc.CallOption) (*Ack, error)

+ UpdateWorkflowStatus func(ctx context.Context, in *WorkflowStatusUpdate, opts ...grpc.CallOption) (*Ack, error)

+ UploadTemplate func(ctx context.Context, in *UploadTemplateRequest, opts ...grpc.CallOption) (*UploadTemplateResponse, error)

+ UserUpdateWorker func(ctx context.Context, in *WorkerUpdateRequest, opts ...grpc.CallOption) (*Ack, error)

+ func NewTaskQueueClient(cc grpc.ClientConnInterface) TaskQueueClient

+ type TaskQueueServer interface

+ ChangePassword func(context.Context, *ChangePasswordRequest) (*Ack, error)

+ CreateFlavor func(context.Context, *FlavorCreateRequest) (*FlavorId, error)

+ CreateRecruiter func(context.Context, *Recruiter) (*Ack, error)

+ CreateStep func(context.Context, *StepRequest) (*StepId, error)

+ CreateUser func(context.Context, *CreateUserRequest) (*UserId, error)

+ CreateWorker func(context.Context, *WorkerRequest) (*WorkerIds, error)

+ CreateWorkflow func(context.Context, *WorkflowRequest) (*WorkflowId, error)

+ DebugAssignTask func(context.Context, *DebugAssignRequest) (*Ack, error)

+ DebugRecruitStep func(context.Context, *DebugRecruitRequest) (*Ack, error)

+ DebugRetryTask func(context.Context, *RetryTaskRequest) (*TaskResponse, error)

+ DeleteJob func(context.Context, *JobId) (*Ack, error)

+ DeleteRecruiter func(context.Context, *RecruiterId) (*Ack, error)

+ DeleteStep func(context.Context, *StepId) (*Ack, error)

+ DeleteTemplateRun func(context.Context, *DeleteTemplateRunRequest) (*Ack, error)

+ DeleteUser func(context.Context, *UserId) (*Ack, error)

+ DeleteWorker func(context.Context, *WorkerDeletion) (*JobId, error)

+ DeleteWorkerEvent func(context.Context, *WorkerEventId) (*Ack, error)

+ DeleteWorkflow func(context.Context, *WorkflowId) (*Ack, error)

+ FetchInfo func(context.Context, *FetchListRequest) (*FetchInfoResponse, error)

+ FetchList func(context.Context, *FetchListRequest) (*FetchListResponse, error)

+ GetCertificate func(context.Context, *emptypb.Empty) (*Certificate, error)

+ GetDockerCredentials func(context.Context, *emptypb.Empty) (*DockerCredentials, error)

+ GetJobStatuses func(context.Context, *JobStatusRequest) (*JobStatusResponse, error)

+ GetLogsChunk func(context.Context, *GetLogsRequest) (*LogChunkList, error)

+ GetRcloneConfig func(context.Context, *emptypb.Empty) (*RcloneRemotes, error)

+ GetStepStats func(context.Context, *StepStatsRequest) (*StepStatsResponse, error)

+ GetWorkerStats func(context.Context, *GetWorkerStatsRequest) (*GetWorkerStatsResponse, error)

+ GetWorkerStatuses func(context.Context, *WorkerStatusRequest) (*WorkerStatusResponse, error)

+ GetWorkspaceRoot func(context.Context, *WorkspaceRootRequest) (*WorkspaceRootResponse, error)

+ ListDependentPendingTasks func(context.Context, *TaskId) (*TaskIds, error)

+ ListFlavors func(context.Context, *ListFlavorsRequest) (*FlavorsList, error)

+ ListJobs func(context.Context, *ListJobsRequest) (*JobsList, error)

+ ListProviders func(context.Context, *emptypb.Empty) (*ProviderList, error)

+ ListRecruiters func(context.Context, *RecruiterFilter) (*RecruiterList, error)

+ ListRegions func(context.Context, *emptypb.Empty) (*RegionList, error)

+ ListSteps func(context.Context, *StepFilter) (*StepList, error)

+ ListTasks func(context.Context, *ListTasksRequest) (*TaskList, error)

+ ListTemplateRuns func(context.Context, *TemplateRunFilter) (*TemplateRunList, error)

+ ListTemplates func(context.Context, *TemplateFilter) (*TemplateList, error)

+ ListUsers func(context.Context, *emptypb.Empty) (*UsersList, error)

+ ListWorkerEvents func(context.Context, *WorkerEventFilter) (*WorkerEventList, error)

+ ListWorkers func(context.Context, *ListWorkersRequest) (*WorkersList, error)

+ ListWorkflows func(context.Context, *WorkflowFilter) (*WorkflowList, error)

+ Login func(context.Context, *LoginRequest) (*LoginResponse, error)

+ Logout func(context.Context, *Token) (*Ack, error)

+ PingAndTakeNewTasks func(context.Context, *PingAndGetNewTasksRequest) (*TaskListAndOther, error)

+ PruneWorkerEvents func(context.Context, *WorkerEventPruneFilter) (*WorkerEventPruneResult, error)

+ RegisterSpecifications func(context.Context, *ResourceSpec) (*Ack, error)

+ RegisterWorker func(context.Context, *WorkerInfo) (*WorkerId, error)

+ ReportWorkerEvent func(context.Context, *WorkerEvent) (*Ack, error)

+ RetryTask func(context.Context, *RetryTaskRequest) (*TaskResponse, error)

+ RunTemplate func(context.Context, *RunTemplateRequest) (*TemplateRun, error)

+ SendTaskLogs func(grpc.ClientStreamingServer[TaskLog, Ack]) error

+ StreamTaskLogsErr func(*TaskId, grpc.ServerStreamingServer[TaskLog]) error

+ StreamTaskLogsOutput func(*TaskId, grpc.ServerStreamingServer[TaskLog]) error

+ SubmitTask func(context.Context, *TaskRequest) (*TaskResponse, error)

+ UpdateJob func(context.Context, *JobUpdate) (*Ack, error)

+ UpdateRecruiter func(context.Context, *RecruiterUpdate) (*Ack, error)

+ UpdateTaskStatus func(context.Context, *TaskStatusUpdate) (*Ack, error)

+ UpdateTemplateRun func(context.Context, *UpdateTemplateRunRequest) (*Ack, error)

+ UpdateUser func(context.Context, *User) (*Ack, error)

+ UpdateWorker func(context.Context, *WorkerUpdateRequest) (*Ack, error)

+ UpdateWorkerStatus func(context.Context, *WorkerStatus) (*Ack, error)

+ UpdateWorkflowStatus func(context.Context, *WorkflowStatusUpdate) (*Ack, error)

+ UploadTemplate func(context.Context, *UploadTemplateRequest) (*UploadTemplateResponse, error)

+ UserUpdateWorker func(context.Context, *WorkerUpdateRequest) (*Ack, error)

+ type TaskQueue_SendTaskLogsClient = grpc.ClientStreamingClient[TaskLog, Ack]

+ type TaskQueue_SendTaskLogsServer = grpc.ClientStreamingServer[TaskLog, Ack]

+ type TaskQueue_StreamTaskLogsErrClient = grpc.ServerStreamingClient[TaskLog]

+ type TaskQueue_StreamTaskLogsErrServer = grpc.ServerStreamingServer[TaskLog]

+ type TaskQueue_StreamTaskLogsOutputClient = grpc.ServerStreamingClient[TaskLog]

+ type TaskQueue_StreamTaskLogsOutputServer = grpc.ServerStreamingServer[TaskLog]

+ type TaskRequest struct

+ Command string

+ Container string

+ ContainerOptions *string

+ Dependency []int32

+ DownloadTimeout *float32

+ Input []string

+ IsFinal *bool

+ Output *string

+ Resource []string

+ Retry *int32

+ RunningTimeout *float32

+ Shell *string

+ Status string

+ StepId *int32

+ TaskName *string

+ UploadTimeout *float32

+ UsesCache *bool

+ func (*TaskRequest) Descriptor() ([]byte, []int)

+ func (*TaskRequest) ProtoMessage()

+ 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 (x *TaskRequest) ProtoReflect() protoreflect.Message

+ func (x *TaskRequest) Reset()

+ func (x *TaskRequest) String() string

+ type TaskResponse struct

+ TaskId int32

+ func (*TaskResponse) Descriptor() ([]byte, []int)

+ func (*TaskResponse) ProtoMessage()

+ func (x *TaskResponse) GetTaskId() int32

+ func (x *TaskResponse) ProtoReflect() protoreflect.Message

+ func (x *TaskResponse) Reset()

+ func (x *TaskResponse) String() string

+ type TaskStatusUpdate struct

+ Duration *int32

+ FreeRetry *bool

+ NewStatus string

+ TaskId int32

+ func (*TaskStatusUpdate) Descriptor() ([]byte, []int)

+ func (*TaskStatusUpdate) ProtoMessage()

+ func (x *TaskStatusUpdate) GetDuration() int32

+ func (x *TaskStatusUpdate) GetFreeRetry() bool

+ func (x *TaskStatusUpdate) GetNewStatus() string

+ func (x *TaskStatusUpdate) GetTaskId() int32

+ func (x *TaskStatusUpdate) ProtoReflect() protoreflect.Message

+ func (x *TaskStatusUpdate) Reset()

+ func (x *TaskStatusUpdate) String() string

+ type TaskUpdate struct

+ Weight float64

+ func (*TaskUpdate) Descriptor() ([]byte, []int)

+ func (*TaskUpdate) ProtoMessage()

+ func (x *TaskUpdate) GetWeight() float64

+ func (x *TaskUpdate) ProtoReflect() protoreflect.Message

+ func (x *TaskUpdate) Reset()

+ func (x *TaskUpdate) String() string

+ type TaskUpdateList struct

+ Updates map[int32]*TaskUpdate

+ func (*TaskUpdateList) Descriptor() ([]byte, []int)

+ func (*TaskUpdateList) ProtoMessage()

+ func (x *TaskUpdateList) GetUpdates() map[int32]*TaskUpdate

+ func (x *TaskUpdateList) ProtoReflect() protoreflect.Message

+ func (x *TaskUpdateList) Reset()

+ func (x *TaskUpdateList) String() string

+ type Template struct

+ Description string

+ Name string

+ ParamJson string

+ UploadedAt string

+ UploadedBy *int32

+ Version string

+ WorkflowTemplateId int32

+ func (*Template) Descriptor() ([]byte, []int)

+ func (*Template) ProtoMessage()

+ 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 (x *Template) ProtoReflect() protoreflect.Message

+ func (x *Template) Reset()

+ func (x *Template) String() string

+ type TemplateFilter struct

+ Name *string

+ Version *string

+ WorkflowTemplateId *int32

+ func (*TemplateFilter) Descriptor() ([]byte, []int)

+ func (*TemplateFilter) ProtoMessage()

+ func (x *TemplateFilter) GetName() string

+ func (x *TemplateFilter) GetVersion() string

+ func (x *TemplateFilter) GetWorkflowTemplateId() int32

+ func (x *TemplateFilter) ProtoReflect() protoreflect.Message

+ func (x *TemplateFilter) Reset()

+ func (x *TemplateFilter) String() string

+ type TemplateList struct

+ Templates []*Template

+ func (*TemplateList) Descriptor() ([]byte, []int)

+ func (*TemplateList) ProtoMessage()

+ func (x *TemplateList) GetTemplates() []*Template

+ func (x *TemplateList) ProtoReflect() protoreflect.Message

+ func (x *TemplateList) Reset()

+ func (x *TemplateList) String() string

+ type TemplateRun struct

+ CreatedAt string

+ ErrorMessage *string

+ ParamValuesJson string

+ RunBy *int32

+ RunByUsername *string

+ Status string

+ TemplateName *string

+ TemplateRunId int32

+ TemplateVersion *string

+ WorkflowId *int32

+ WorkflowName *string

+ WorkflowTemplateId int32

+ func (*TemplateRun) Descriptor() ([]byte, []int)

+ func (*TemplateRun) ProtoMessage()

+ 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 (x *TemplateRun) ProtoReflect() protoreflect.Message

+ func (x *TemplateRun) Reset()

+ func (x *TemplateRun) String() string

+ type TemplateRunFilter struct

+ WorkflowTemplateId *int32

+ func (*TemplateRunFilter) Descriptor() ([]byte, []int)

+ func (*TemplateRunFilter) ProtoMessage()

+ func (x *TemplateRunFilter) GetWorkflowTemplateId() int32

+ func (x *TemplateRunFilter) ProtoReflect() protoreflect.Message

+ func (x *TemplateRunFilter) Reset()

+ func (x *TemplateRunFilter) String() string

+ type TemplateRunList struct

+ Runs []*TemplateRun

+ func (*TemplateRunList) Descriptor() ([]byte, []int)

+ func (*TemplateRunList) ProtoMessage()

+ func (x *TemplateRunList) GetRuns() []*TemplateRun

+ func (x *TemplateRunList) ProtoReflect() protoreflect.Message

+ func (x *TemplateRunList) Reset()

+ func (x *TemplateRunList) String() string

+ type Token struct

+ Token string

+ func (*Token) Descriptor() ([]byte, []int)

+ func (*Token) ProtoMessage()

+ func (x *Token) GetToken() string

+ func (x *Token) ProtoReflect() protoreflect.Message

+ func (x *Token) Reset()

+ func (x *Token) String() string

+ type UnimplementedTaskQueueServer struct

+ 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) 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 interface

+ type UpdateTemplateRunRequest struct

+ ErrorMessage *string

+ TemplateRunId int32

+ WorkflowId *int32

+ func (*UpdateTemplateRunRequest) Descriptor() ([]byte, []int)

+ func (*UpdateTemplateRunRequest) ProtoMessage()

+ func (x *UpdateTemplateRunRequest) GetErrorMessage() string

+ func (x *UpdateTemplateRunRequest) GetTemplateRunId() int32

+ func (x *UpdateTemplateRunRequest) GetWorkflowId() int32

+ func (x *UpdateTemplateRunRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateTemplateRunRequest) Reset()

+ func (x *UpdateTemplateRunRequest) String() string

+ type UploadTemplateRequest struct

+ Force bool

+ Script []byte

+ func (*UploadTemplateRequest) Descriptor() ([]byte, []int)

+ func (*UploadTemplateRequest) ProtoMessage()

+ func (x *UploadTemplateRequest) GetForce() bool

+ func (x *UploadTemplateRequest) GetScript() []byte

+ func (x *UploadTemplateRequest) ProtoReflect() protoreflect.Message

+ func (x *UploadTemplateRequest) Reset()

+ func (x *UploadTemplateRequest) String() string

+ type UploadTemplateResponse struct

+ Description *string

+ Message string

+ Name *string

+ ParamJson *string

+ Success bool

+ Version *string

+ WorkflowTemplateId *int32

+ func (*UploadTemplateResponse) Descriptor() ([]byte, []int)

+ func (*UploadTemplateResponse) ProtoMessage()

+ 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 (x *UploadTemplateResponse) ProtoReflect() protoreflect.Message

+ func (x *UploadTemplateResponse) Reset()

+ func (x *UploadTemplateResponse) String() string

+ type User struct

+ Email *string

+ IsAdmin *bool

+ UserId int32

+ Username *string

+ func (*User) Descriptor() ([]byte, []int)

+ func (*User) ProtoMessage()

+ func (x *User) GetEmail() string

+ func (x *User) GetIsAdmin() bool

+ func (x *User) GetUserId() int32

+ func (x *User) GetUsername() string

+ func (x *User) ProtoReflect() protoreflect.Message

+ func (x *User) Reset()

+ func (x *User) String() string

+ type UserId struct

+ UserId int32

+ func (*UserId) Descriptor() ([]byte, []int)

+ func (*UserId) ProtoMessage()

+ func (x *UserId) GetUserId() int32

+ func (x *UserId) ProtoReflect() protoreflect.Message

+ func (x *UserId) Reset()

+ func (x *UserId) String() string

+ type UsersList struct

+ Users []*User

+ func (*UsersList) Descriptor() ([]byte, []int)

+ func (*UsersList) ProtoMessage()

+ func (x *UsersList) GetUsers() []*User

+ func (x *UsersList) ProtoReflect() protoreflect.Message

+ func (x *UsersList) Reset()

+ func (x *UsersList) String() string

+ type Worker struct

+ Concurrency int32

+ Flavor string

+ Ipv4 string

+ Ipv6 string

+ IsPermanent bool

+ Name string

+ Prefetch int32

+ Provider string

+ RecyclableScope string

+ Region string

+ Status string

+ StepId *int32

+ StepName *string

+ WorkerId int32

+ WorkflowId *int32

+ WorkflowName *string

+ func (*Worker) Descriptor() ([]byte, []int)

+ func (*Worker) ProtoMessage()

+ 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 (x *Worker) ProtoReflect() protoreflect.Message

+ func (x *Worker) Reset()

+ func (x *Worker) String() string

+ type WorkerDeletion struct

+ Undeployed *bool

+ WorkerId int32

+ func (*WorkerDeletion) Descriptor() ([]byte, []int)

+ func (*WorkerDeletion) ProtoMessage()

+ func (x *WorkerDeletion) GetUndeployed() bool

+ func (x *WorkerDeletion) GetWorkerId() int32

+ func (x *WorkerDeletion) ProtoReflect() protoreflect.Message

+ func (x *WorkerDeletion) Reset()

+ func (x *WorkerDeletion) String() string

+ type WorkerDetails struct

+ JobId int32

+ WorkerId int32

+ WorkerName string

+ func (*WorkerDetails) Descriptor() ([]byte, []int)

+ func (*WorkerDetails) ProtoMessage()

+ func (x *WorkerDetails) GetJobId() int32

+ func (x *WorkerDetails) GetWorkerId() int32

+ func (x *WorkerDetails) GetWorkerName() string

+ func (x *WorkerDetails) ProtoReflect() protoreflect.Message

+ func (x *WorkerDetails) Reset()

+ func (x *WorkerDetails) String() string

+ type WorkerEvent struct

+ DetailsJson string

+ EventClass string

+ Level string

+ Message string

+ WorkerId *int32

+ WorkerName string

+ func (*WorkerEvent) Descriptor() ([]byte, []int)

+ func (*WorkerEvent) ProtoMessage()

+ 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 (x *WorkerEvent) ProtoReflect() protoreflect.Message

+ func (x *WorkerEvent) Reset()

+ func (x *WorkerEvent) String() string

+ type WorkerEventFilter struct

+ Class *string

+ Level *string

+ Limit *int32

+ WorkerId *int32

+ func (*WorkerEventFilter) Descriptor() ([]byte, []int)

+ func (*WorkerEventFilter) ProtoMessage()

+ func (x *WorkerEventFilter) GetClass() string

+ func (x *WorkerEventFilter) GetLevel() string

+ func (x *WorkerEventFilter) GetLimit() int32

+ func (x *WorkerEventFilter) GetWorkerId() int32

+ func (x *WorkerEventFilter) ProtoReflect() protoreflect.Message

+ func (x *WorkerEventFilter) Reset()

+ func (x *WorkerEventFilter) String() string

+ type WorkerEventId struct

+ EventId int32

+ func (*WorkerEventId) Descriptor() ([]byte, []int)

+ func (*WorkerEventId) ProtoMessage()

+ func (x *WorkerEventId) GetEventId() int32

+ func (x *WorkerEventId) ProtoReflect() protoreflect.Message

+ func (x *WorkerEventId) Reset()

+ func (x *WorkerEventId) String() string

+ type WorkerEventList struct

+ Events []*WorkerEventRecord

+ func (*WorkerEventList) Descriptor() ([]byte, []int)

+ func (*WorkerEventList) ProtoMessage()

+ func (x *WorkerEventList) GetEvents() []*WorkerEventRecord

+ func (x *WorkerEventList) ProtoReflect() protoreflect.Message

+ func (x *WorkerEventList) Reset()

+ func (x *WorkerEventList) String() string

+ type WorkerEventPruneFilter struct

+ Before *string

+ Class *string

+ DryRun bool

+ Level *string

+ WorkerId *int32

+ func (*WorkerEventPruneFilter) Descriptor() ([]byte, []int)

+ func (*WorkerEventPruneFilter) ProtoMessage()

+ 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 (x *WorkerEventPruneFilter) ProtoReflect() protoreflect.Message

+ func (x *WorkerEventPruneFilter) Reset()

+ func (x *WorkerEventPruneFilter) String() string

+ type WorkerEventPruneResult struct

+ Deleted int32

+ Matched int32

+ func (*WorkerEventPruneResult) Descriptor() ([]byte, []int)

+ func (*WorkerEventPruneResult) ProtoMessage()

+ func (x *WorkerEventPruneResult) GetDeleted() int32

+ func (x *WorkerEventPruneResult) GetMatched() int32

+ func (x *WorkerEventPruneResult) ProtoReflect() protoreflect.Message

+ func (x *WorkerEventPruneResult) Reset()

+ func (x *WorkerEventPruneResult) String() string

+ type WorkerEventRecord struct

+ CreatedAt string

+ DetailsJson string

+ EventClass string

+ EventId int32

+ Level string

+ Message string

+ WorkerId *int32

+ WorkerName string

+ func (*WorkerEventRecord) Descriptor() ([]byte, []int)

+ func (*WorkerEventRecord) ProtoMessage()

+ 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 (x *WorkerEventRecord) ProtoReflect() protoreflect.Message

+ func (x *WorkerEventRecord) Reset()

+ func (x *WorkerEventRecord) String() string

+ type WorkerId struct

+ WorkerId int32

+ func (*WorkerId) Descriptor() ([]byte, []int)

+ func (*WorkerId) ProtoMessage()

+ func (x *WorkerId) GetWorkerId() int32

+ func (x *WorkerId) ProtoReflect() protoreflect.Message

+ func (x *WorkerId) Reset()

+ func (x *WorkerId) String() string

+ type WorkerIds struct

+ WorkersDetails []*WorkerDetails

+ func (*WorkerIds) Descriptor() ([]byte, []int)

+ func (*WorkerIds) ProtoMessage()

+ func (x *WorkerIds) GetWorkersDetails() []*WorkerDetails

+ func (x *WorkerIds) ProtoReflect() protoreflect.Message

+ func (x *WorkerIds) Reset()

+ func (x *WorkerIds) String() string

+ type WorkerInfo struct

+ Concurrency *int32

+ IsPermanent *bool

+ Name string

+ Provider *string

+ Region *string

+ func (*WorkerInfo) Descriptor() ([]byte, []int)

+ func (*WorkerInfo) ProtoMessage()

+ 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 (x *WorkerInfo) ProtoReflect() protoreflect.Message

+ func (x *WorkerInfo) Reset()

+ func (x *WorkerInfo) String() string

+ type WorkerRequest struct

+ Concurrency int32

+ FlavorId int32

+ Number int32

+ Prefetch int32

+ ProviderId int32

+ RegionId int32

+ StepId *int32

+ func (*WorkerRequest) Descriptor() ([]byte, []int)

+ func (*WorkerRequest) ProtoMessage()

+ 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 (x *WorkerRequest) ProtoReflect() protoreflect.Message

+ func (x *WorkerRequest) Reset()

+ func (x *WorkerRequest) String() string

+ type WorkerStats struct

+ CpuUsagePercent float32

+ DiskIo *DiskIOStats

+ Disks []*DiskUsage

+ IowaitPercent float32

+ Load_1Min float32

+ MemUsagePercent float32

+ NetIo *NetIOStats

+ func (*WorkerStats) Descriptor() ([]byte, []int)

+ func (*WorkerStats) ProtoMessage()

+ 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 (x *WorkerStats) ProtoReflect() protoreflect.Message

+ func (x *WorkerStats) Reset()

+ func (x *WorkerStats) String() string

+ type WorkerStatus struct

+ Status string

+ WorkerId int32

+ func (*WorkerStatus) Descriptor() ([]byte, []int)

+ func (*WorkerStatus) ProtoMessage()

+ func (x *WorkerStatus) GetStatus() string

+ func (x *WorkerStatus) GetWorkerId() int32

+ func (x *WorkerStatus) ProtoReflect() protoreflect.Message

+ func (x *WorkerStatus) Reset()

+ func (x *WorkerStatus) String() string

+ type WorkerStatusRequest struct

+ WorkerIds []int32

+ func (*WorkerStatusRequest) Descriptor() ([]byte, []int)

+ func (*WorkerStatusRequest) ProtoMessage()

+ func (x *WorkerStatusRequest) GetWorkerIds() []int32

+ func (x *WorkerStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *WorkerStatusRequest) Reset()

+ func (x *WorkerStatusRequest) String() string

+ type WorkerStatusResponse struct

+ Statuses []*WorkerStatus

+ func (*WorkerStatusResponse) Descriptor() ([]byte, []int)

+ func (*WorkerStatusResponse) ProtoMessage()

+ func (x *WorkerStatusResponse) GetStatuses() []*WorkerStatus

+ func (x *WorkerStatusResponse) ProtoReflect() protoreflect.Message

+ func (x *WorkerStatusResponse) Reset()

+ func (x *WorkerStatusResponse) String() string

+ type WorkerUpdateRequest struct

+ Concurrency *int32

+ FlavorId *int32

+ IsPermanent *bool

+ Prefetch *int32

+ ProviderId *int32

+ RecyclableScope *string

+ RegionId *int32

+ StepId *int32

+ StepName *string

+ WorkerId int32

+ WorkflowName *string

+ func (*WorkerUpdateRequest) Descriptor() ([]byte, []int)

+ func (*WorkerUpdateRequest) ProtoMessage()

+ 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 (x *WorkerUpdateRequest) ProtoReflect() protoreflect.Message

+ func (x *WorkerUpdateRequest) Reset()

+ func (x *WorkerUpdateRequest) String() string

+ type WorkersList struct

+ Workers []*Worker

+ func (*WorkersList) Descriptor() ([]byte, []int)

+ func (*WorkersList) ProtoMessage()

+ func (x *WorkersList) GetWorkers() []*Worker

+ func (x *WorkersList) ProtoReflect() protoreflect.Message

+ func (x *WorkersList) Reset()

+ func (x *WorkersList) String() string

+ type Workflow struct

+ MaximumWorkers *int32

+ Name string

+ RunStrategy string

+ Status string

+ WorkflowId int32

+ func (*Workflow) Descriptor() ([]byte, []int)

+ func (*Workflow) ProtoMessage()

+ 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 (x *Workflow) ProtoReflect() protoreflect.Message

+ func (x *Workflow) Reset()

+ func (x *Workflow) String() string

+ type WorkflowFilter struct

+ Limit *int32

+ NameLike *string

+ Offset *int32

+ func (*WorkflowFilter) Descriptor() ([]byte, []int)

+ func (*WorkflowFilter) ProtoMessage()

+ func (x *WorkflowFilter) GetLimit() int32

+ func (x *WorkflowFilter) GetNameLike() string

+ func (x *WorkflowFilter) GetOffset() int32

+ func (x *WorkflowFilter) ProtoReflect() protoreflect.Message

+ func (x *WorkflowFilter) Reset()

+ func (x *WorkflowFilter) String() string

+ type WorkflowId struct

+ WorkflowId int32

+ func (*WorkflowId) Descriptor() ([]byte, []int)

+ func (*WorkflowId) ProtoMessage()

+ func (x *WorkflowId) GetWorkflowId() int32

+ func (x *WorkflowId) ProtoReflect() protoreflect.Message

+ func (x *WorkflowId) Reset()

+ func (x *WorkflowId) String() string

+ type WorkflowList struct

+ Workflows []*Workflow

+ func (*WorkflowList) Descriptor() ([]byte, []int)

+ func (*WorkflowList) ProtoMessage()

+ func (x *WorkflowList) GetWorkflows() []*Workflow

+ func (x *WorkflowList) ProtoReflect() protoreflect.Message

+ func (x *WorkflowList) Reset()

+ func (x *WorkflowList) String() string

+ type WorkflowRequest struct

+ MaximumWorkers *int32

+ Name string

+ RunStrategy *string

+ Status *string

+ func (*WorkflowRequest) Descriptor() ([]byte, []int)

+ func (*WorkflowRequest) ProtoMessage()

+ func (x *WorkflowRequest) GetMaximumWorkers() int32

+ func (x *WorkflowRequest) GetName() string

+ func (x *WorkflowRequest) GetRunStrategy() string

+ func (x *WorkflowRequest) GetStatus() string

+ func (x *WorkflowRequest) ProtoReflect() protoreflect.Message

+ func (x *WorkflowRequest) Reset()

+ func (x *WorkflowRequest) String() string

+ type WorkflowStatusUpdate struct

+ Status string

+ WorkflowId int32

+ func (*WorkflowStatusUpdate) Descriptor() ([]byte, []int)

+ func (*WorkflowStatusUpdate) ProtoMessage()

+ func (x *WorkflowStatusUpdate) GetStatus() string

+ func (x *WorkflowStatusUpdate) GetWorkflowId() int32

+ func (x *WorkflowStatusUpdate) ProtoReflect() protoreflect.Message

+ func (x *WorkflowStatusUpdate) Reset()

+ func (x *WorkflowStatusUpdate) String() string

+ type WorkspaceRootRequest struct

+ Provider string

+ Region string

+ func (*WorkspaceRootRequest) Descriptor() ([]byte, []int)

+ func (*WorkspaceRootRequest) ProtoMessage()

+ func (x *WorkspaceRootRequest) GetProvider() string

+ func (x *WorkspaceRootRequest) GetRegion() string

+ func (x *WorkspaceRootRequest) ProtoReflect() protoreflect.Message

+ func (x *WorkspaceRootRequest) Reset()

+ func (x *WorkspaceRootRequest) String() string

+ type WorkspaceRootResponse struct

+ RootUri string

+ func (*WorkspaceRootResponse) Descriptor() ([]byte, []int)

+ func (*WorkspaceRootResponse) ProtoMessage()

+ func (x *WorkspaceRootResponse) GetRootUri() string

+ func (x *WorkspaceRootResponse) ProtoReflect() protoreflect.Message

+ func (x *WorkspaceRootResponse) Reset()

+ func (x *WorkspaceRootResponse) String() string

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