Help us shape the future of Go! Take the 2026 Go Developer Survey

taskqueuepb

package
v0.8.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 16, 2026 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TaskQueue_SubmitTask_FullMethodName                = "/taskqueue.TaskQueue/SubmitTask"
	TaskQueue_RegisterWorker_FullMethodName            = "/taskqueue.TaskQueue/RegisterWorker"
	TaskQueue_PingAndTakeNewTasks_FullMethodName       = "/taskqueue.TaskQueue/PingAndTakeNewTasks"
	TaskQueue_UpdateTaskStatus_FullMethodName          = "/taskqueue.TaskQueue/UpdateTaskStatus"
	TaskQueue_SendTaskLogs_FullMethodName              = "/taskqueue.TaskQueue/SendTaskLogs"
	TaskQueue_StreamTaskLogsOutput_FullMethodName      = "/taskqueue.TaskQueue/StreamTaskLogsOutput"
	TaskQueue_StreamTaskLogsErr_FullMethodName         = "/taskqueue.TaskQueue/StreamTaskLogsErr"
	TaskQueue_GetLogsChunk_FullMethodName              = "/taskqueue.TaskQueue/GetLogsChunk"
	TaskQueue_ListTasks_FullMethodName                 = "/taskqueue.TaskQueue/ListTasks"
	TaskQueue_RetryTask_FullMethodName                 = "/taskqueue.TaskQueue/RetryTask"
	TaskQueue_ForceRunTask_FullMethodName              = "/taskqueue.TaskQueue/ForceRunTask"
	TaskQueue_EditAndRetryTask_FullMethodName          = "/taskqueue.TaskQueue/EditAndRetryTask"
	TaskQueue_EditTask_FullMethodName                  = "/taskqueue.TaskQueue/EditTask"
	TaskQueue_GetTask_FullMethodName                   = "/taskqueue.TaskQueue/GetTask"
	TaskQueue_EditStepCommand_FullMethodName           = "/taskqueue.TaskQueue/EditStepCommand"
	TaskQueue_ListWorkers_FullMethodName               = "/taskqueue.TaskQueue/ListWorkers"
	TaskQueue_CreateWorker_FullMethodName              = "/taskqueue.TaskQueue/CreateWorker"
	TaskQueue_CreateWorkerByName_FullMethodName        = "/taskqueue.TaskQueue/CreateWorkerByName"
	TaskQueue_UpdateWorkerStatus_FullMethodName        = "/taskqueue.TaskQueue/UpdateWorkerStatus"
	TaskQueue_DeleteWorker_FullMethodName              = "/taskqueue.TaskQueue/DeleteWorker"
	TaskQueue_UpdateWorker_FullMethodName              = "/taskqueue.TaskQueue/UpdateWorker"
	TaskQueue_UserUpdateWorker_FullMethodName          = "/taskqueue.TaskQueue/UserUpdateWorker"
	TaskQueue_GetWorkerStatuses_FullMethodName         = "/taskqueue.TaskQueue/GetWorkerStatuses"
	TaskQueue_ListJobs_FullMethodName                  = "/taskqueue.TaskQueue/ListJobs"
	TaskQueue_GetJobStatuses_FullMethodName            = "/taskqueue.TaskQueue/GetJobStatuses"
	TaskQueue_DeleteJob_FullMethodName                 = "/taskqueue.TaskQueue/DeleteJob"
	TaskQueue_UpdateJob_FullMethodName                 = "/taskqueue.TaskQueue/UpdateJob"
	TaskQueue_ListFlavors_FullMethodName               = "/taskqueue.TaskQueue/ListFlavors"
	TaskQueue_ListProviders_FullMethodName             = "/taskqueue.TaskQueue/ListProviders"
	TaskQueue_ListRegions_FullMethodName               = "/taskqueue.TaskQueue/ListRegions"
	TaskQueue_CreateFlavor_FullMethodName              = "/taskqueue.TaskQueue/CreateFlavor"
	TaskQueue_SetFlavorAvailability_FullMethodName     = "/taskqueue.TaskQueue/SetFlavorAvailability"
	TaskQueue_GetRcloneConfig_FullMethodName           = "/taskqueue.TaskQueue/GetRcloneConfig"
	TaskQueue_GetDockerCredentials_FullMethodName      = "/taskqueue.TaskQueue/GetDockerCredentials"
	TaskQueue_Login_FullMethodName                     = "/taskqueue.TaskQueue/Login"
	TaskQueue_GetCertificate_FullMethodName            = "/taskqueue.TaskQueue/GetCertificate"
	TaskQueue_Logout_FullMethodName                    = "/taskqueue.TaskQueue/Logout"
	TaskQueue_CreateUser_FullMethodName                = "/taskqueue.TaskQueue/CreateUser"
	TaskQueue_ListUsers_FullMethodName                 = "/taskqueue.TaskQueue/ListUsers"
	TaskQueue_DeleteUser_FullMethodName                = "/taskqueue.TaskQueue/DeleteUser"
	TaskQueue_UpdateUser_FullMethodName                = "/taskqueue.TaskQueue/UpdateUser"
	TaskQueue_ChangePassword_FullMethodName            = "/taskqueue.TaskQueue/ChangePassword"
	TaskQueue_AdminResetPassword_FullMethodName        = "/taskqueue.TaskQueue/AdminResetPassword"
	TaskQueue_ListRecruiters_FullMethodName            = "/taskqueue.TaskQueue/ListRecruiters"
	TaskQueue_CreateRecruiter_FullMethodName           = "/taskqueue.TaskQueue/CreateRecruiter"
	TaskQueue_UpdateRecruiter_FullMethodName           = "/taskqueue.TaskQueue/UpdateRecruiter"
	TaskQueue_DeleteRecruiter_FullMethodName           = "/taskqueue.TaskQueue/DeleteRecruiter"
	TaskQueue_ListWorkflows_FullMethodName             = "/taskqueue.TaskQueue/ListWorkflows"
	TaskQueue_CreateWorkflow_FullMethodName            = "/taskqueue.TaskQueue/CreateWorkflow"
	TaskQueue_UpdateWorkflowStatus_FullMethodName      = "/taskqueue.TaskQueue/UpdateWorkflowStatus"
	TaskQueue_DeleteWorkflow_FullMethodName            = "/taskqueue.TaskQueue/DeleteWorkflow"
	TaskQueue_CreateChainEntries_FullMethodName        = "/taskqueue.TaskQueue/CreateChainEntries"
	TaskQueue_ListChainEntries_FullMethodName          = "/taskqueue.TaskQueue/ListChainEntries"
	TaskQueue_GetChainEntry_FullMethodName             = "/taskqueue.TaskQueue/GetChainEntry"
	TaskQueue_SuspendChainEntry_FullMethodName         = "/taskqueue.TaskQueue/SuspendChainEntry"
	TaskQueue_ResumeChainEntry_FullMethodName          = "/taskqueue.TaskQueue/ResumeChainEntry"
	TaskQueue_CancelChainEntry_FullMethodName          = "/taskqueue.TaskQueue/CancelChainEntry"
	TaskQueue_EditChainEntry_FullMethodName            = "/taskqueue.TaskQueue/EditChainEntry"
	TaskQueue_DebugAssignTask_FullMethodName           = "/taskqueue.TaskQueue/DebugAssignTask"
	TaskQueue_DebugRecruitStep_FullMethodName          = "/taskqueue.TaskQueue/DebugRecruitStep"
	TaskQueue_DebugRetryTask_FullMethodName            = "/taskqueue.TaskQueue/DebugRetryTask"
	TaskQueue_ListDependentPendingTasks_FullMethodName = "/taskqueue.TaskQueue/ListDependentPendingTasks"
	TaskQueue_ListSteps_FullMethodName                 = "/taskqueue.TaskQueue/ListSteps"
	TaskQueue_CreateStep_FullMethodName                = "/taskqueue.TaskQueue/CreateStep"
	TaskQueue_DeleteStep_FullMethodName                = "/taskqueue.TaskQueue/DeleteStep"
	TaskQueue_GetStepStats_FullMethodName              = "/taskqueue.TaskQueue/GetStepStats"
	TaskQueue_GetWorkerStats_FullMethodName            = "/taskqueue.TaskQueue/GetWorkerStats"
	TaskQueue_FetchList_FullMethodName                 = "/taskqueue.TaskQueue/FetchList"
	TaskQueue_FetchInfo_FullMethodName                 = "/taskqueue.TaskQueue/FetchInfo"
	TaskQueue_UploadTemplate_FullMethodName            = "/taskqueue.TaskQueue/UploadTemplate"
	TaskQueue_DownloadTemplate_FullMethodName          = "/taskqueue.TaskQueue/DownloadTemplate"
	TaskQueue_RunTemplate_FullMethodName               = "/taskqueue.TaskQueue/RunTemplate"
	TaskQueue_ListTemplates_FullMethodName             = "/taskqueue.TaskQueue/ListTemplates"
	TaskQueue_UpdateTemplate_FullMethodName            = "/taskqueue.TaskQueue/UpdateTemplate"
	TaskQueue_ListTemplateRuns_FullMethodName          = "/taskqueue.TaskQueue/ListTemplateRuns"
	TaskQueue_UpdateTemplateRun_FullMethodName         = "/taskqueue.TaskQueue/UpdateTemplateRun"
	TaskQueue_DeleteTemplateRun_FullMethodName         = "/taskqueue.TaskQueue/DeleteTemplateRun"
	TaskQueue_RegisterAdhocRun_FullMethodName          = "/taskqueue.TaskQueue/RegisterAdhocRun"
	TaskQueue_UploadModule_FullMethodName              = "/taskqueue.TaskQueue/UploadModule"
	TaskQueue_ListModules_FullMethodName               = "/taskqueue.TaskQueue/ListModules"
	TaskQueue_ListModulesFiltered_FullMethodName       = "/taskqueue.TaskQueue/ListModulesFiltered"
	TaskQueue_DownloadModule_FullMethodName            = "/taskqueue.TaskQueue/DownloadModule"
	TaskQueue_DeleteModule_FullMethodName              = "/taskqueue.TaskQueue/DeleteModule"
	TaskQueue_UpgradeBundledModules_FullMethodName     = "/taskqueue.TaskQueue/UpgradeBundledModules"
	TaskQueue_GetModuleOrigin_FullMethodName           = "/taskqueue.TaskQueue/GetModuleOrigin"
	TaskQueue_ForkModule_FullMethodName                = "/taskqueue.TaskQueue/ForkModule"
	TaskQueue_GetWorkspaceRoot_FullMethodName          = "/taskqueue.TaskQueue/GetWorkspaceRoot"
	TaskQueue_GetResourceRoot_FullMethodName           = "/taskqueue.TaskQueue/GetResourceRoot"
	TaskQueue_RegisterSpecifications_FullMethodName    = "/taskqueue.TaskQueue/RegisterSpecifications"
	TaskQueue_ReportWorkerEvent_FullMethodName         = "/taskqueue.TaskQueue/ReportWorkerEvent"
	TaskQueue_ListWorkerEvents_FullMethodName          = "/taskqueue.TaskQueue/ListWorkerEvents"
	TaskQueue_DeleteWorkerEvent_FullMethodName         = "/taskqueue.TaskQueue/DeleteWorkerEvent"
	TaskQueue_PruneWorkerEvents_FullMethodName         = "/taskqueue.TaskQueue/PruneWorkerEvents"
	TaskQueue_GetTaskStatusCounts_FullMethodName       = "/taskqueue.TaskQueue/GetTaskStatusCounts"
	TaskQueue_SignalTask_FullMethodName                = "/taskqueue.TaskQueue/SignalTask"
	TaskQueue_ServerVersion_FullMethodName             = "/taskqueue.TaskQueue/ServerVersion"
	TaskQueue_RequestWorkerUpgrade_FullMethodName      = "/taskqueue.TaskQueue/RequestWorkerUpgrade"
	TaskQueue_GetClientUpgradeInfo_FullMethodName      = "/taskqueue.TaskQueue/GetClientUpgradeInfo"
)

Variables

View Source
var File_taskqueue_proto protoreflect.FileDescriptor
View Source
var TaskQueue_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "taskqueue.TaskQueue",
	HandlerType: (*TaskQueueServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SubmitTask",
			Handler:    _TaskQueue_SubmitTask_Handler,
		},
		{
			MethodName: "RegisterWorker",
			Handler:    _TaskQueue_RegisterWorker_Handler,
		},
		{
			MethodName: "PingAndTakeNewTasks",
			Handler:    _TaskQueue_PingAndTakeNewTasks_Handler,
		},
		{
			MethodName: "UpdateTaskStatus",
			Handler:    _TaskQueue_UpdateTaskStatus_Handler,
		},
		{
			MethodName: "GetLogsChunk",
			Handler:    _TaskQueue_GetLogsChunk_Handler,
		},
		{
			MethodName: "ListTasks",
			Handler:    _TaskQueue_ListTasks_Handler,
		},
		{
			MethodName: "RetryTask",
			Handler:    _TaskQueue_RetryTask_Handler,
		},
		{
			MethodName: "ForceRunTask",
			Handler:    _TaskQueue_ForceRunTask_Handler,
		},
		{
			MethodName: "EditAndRetryTask",
			Handler:    _TaskQueue_EditAndRetryTask_Handler,
		},
		{
			MethodName: "EditTask",
			Handler:    _TaskQueue_EditTask_Handler,
		},
		{
			MethodName: "GetTask",
			Handler:    _TaskQueue_GetTask_Handler,
		},
		{
			MethodName: "EditStepCommand",
			Handler:    _TaskQueue_EditStepCommand_Handler,
		},
		{
			MethodName: "ListWorkers",
			Handler:    _TaskQueue_ListWorkers_Handler,
		},
		{
			MethodName: "CreateWorker",
			Handler:    _TaskQueue_CreateWorker_Handler,
		},
		{
			MethodName: "CreateWorkerByName",
			Handler:    _TaskQueue_CreateWorkerByName_Handler,
		},
		{
			MethodName: "UpdateWorkerStatus",
			Handler:    _TaskQueue_UpdateWorkerStatus_Handler,
		},
		{
			MethodName: "DeleteWorker",
			Handler:    _TaskQueue_DeleteWorker_Handler,
		},
		{
			MethodName: "UpdateWorker",
			Handler:    _TaskQueue_UpdateWorker_Handler,
		},
		{
			MethodName: "UserUpdateWorker",
			Handler:    _TaskQueue_UserUpdateWorker_Handler,
		},
		{
			MethodName: "GetWorkerStatuses",
			Handler:    _TaskQueue_GetWorkerStatuses_Handler,
		},
		{
			MethodName: "ListJobs",
			Handler:    _TaskQueue_ListJobs_Handler,
		},
		{
			MethodName: "GetJobStatuses",
			Handler:    _TaskQueue_GetJobStatuses_Handler,
		},
		{
			MethodName: "DeleteJob",
			Handler:    _TaskQueue_DeleteJob_Handler,
		},
		{
			MethodName: "UpdateJob",
			Handler:    _TaskQueue_UpdateJob_Handler,
		},
		{
			MethodName: "ListFlavors",
			Handler:    _TaskQueue_ListFlavors_Handler,
		},
		{
			MethodName: "ListProviders",
			Handler:    _TaskQueue_ListProviders_Handler,
		},
		{
			MethodName: "ListRegions",
			Handler:    _TaskQueue_ListRegions_Handler,
		},
		{
			MethodName: "CreateFlavor",
			Handler:    _TaskQueue_CreateFlavor_Handler,
		},
		{
			MethodName: "SetFlavorAvailability",
			Handler:    _TaskQueue_SetFlavorAvailability_Handler,
		},
		{
			MethodName: "GetRcloneConfig",
			Handler:    _TaskQueue_GetRcloneConfig_Handler,
		},
		{
			MethodName: "GetDockerCredentials",
			Handler:    _TaskQueue_GetDockerCredentials_Handler,
		},
		{
			MethodName: "Login",
			Handler:    _TaskQueue_Login_Handler,
		},
		{
			MethodName: "GetCertificate",
			Handler:    _TaskQueue_GetCertificate_Handler,
		},
		{
			MethodName: "Logout",
			Handler:    _TaskQueue_Logout_Handler,
		},
		{
			MethodName: "CreateUser",
			Handler:    _TaskQueue_CreateUser_Handler,
		},
		{
			MethodName: "ListUsers",
			Handler:    _TaskQueue_ListUsers_Handler,
		},
		{
			MethodName: "DeleteUser",
			Handler:    _TaskQueue_DeleteUser_Handler,
		},
		{
			MethodName: "UpdateUser",
			Handler:    _TaskQueue_UpdateUser_Handler,
		},
		{
			MethodName: "ChangePassword",
			Handler:    _TaskQueue_ChangePassword_Handler,
		},
		{
			MethodName: "AdminResetPassword",
			Handler:    _TaskQueue_AdminResetPassword_Handler,
		},
		{
			MethodName: "ListRecruiters",
			Handler:    _TaskQueue_ListRecruiters_Handler,
		},
		{
			MethodName: "CreateRecruiter",
			Handler:    _TaskQueue_CreateRecruiter_Handler,
		},
		{
			MethodName: "UpdateRecruiter",
			Handler:    _TaskQueue_UpdateRecruiter_Handler,
		},
		{
			MethodName: "DeleteRecruiter",
			Handler:    _TaskQueue_DeleteRecruiter_Handler,
		},
		{
			MethodName: "ListWorkflows",
			Handler:    _TaskQueue_ListWorkflows_Handler,
		},
		{
			MethodName: "CreateWorkflow",
			Handler:    _TaskQueue_CreateWorkflow_Handler,
		},
		{
			MethodName: "UpdateWorkflowStatus",
			Handler:    _TaskQueue_UpdateWorkflowStatus_Handler,
		},
		{
			MethodName: "DeleteWorkflow",
			Handler:    _TaskQueue_DeleteWorkflow_Handler,
		},
		{
			MethodName: "CreateChainEntries",
			Handler:    _TaskQueue_CreateChainEntries_Handler,
		},
		{
			MethodName: "ListChainEntries",
			Handler:    _TaskQueue_ListChainEntries_Handler,
		},
		{
			MethodName: "GetChainEntry",
			Handler:    _TaskQueue_GetChainEntry_Handler,
		},
		{
			MethodName: "SuspendChainEntry",
			Handler:    _TaskQueue_SuspendChainEntry_Handler,
		},
		{
			MethodName: "ResumeChainEntry",
			Handler:    _TaskQueue_ResumeChainEntry_Handler,
		},
		{
			MethodName: "CancelChainEntry",
			Handler:    _TaskQueue_CancelChainEntry_Handler,
		},
		{
			MethodName: "EditChainEntry",
			Handler:    _TaskQueue_EditChainEntry_Handler,
		},
		{
			MethodName: "DebugAssignTask",
			Handler:    _TaskQueue_DebugAssignTask_Handler,
		},
		{
			MethodName: "DebugRecruitStep",
			Handler:    _TaskQueue_DebugRecruitStep_Handler,
		},
		{
			MethodName: "DebugRetryTask",
			Handler:    _TaskQueue_DebugRetryTask_Handler,
		},
		{
			MethodName: "ListDependentPendingTasks",
			Handler:    _TaskQueue_ListDependentPendingTasks_Handler,
		},
		{
			MethodName: "ListSteps",
			Handler:    _TaskQueue_ListSteps_Handler,
		},
		{
			MethodName: "CreateStep",
			Handler:    _TaskQueue_CreateStep_Handler,
		},
		{
			MethodName: "DeleteStep",
			Handler:    _TaskQueue_DeleteStep_Handler,
		},
		{
			MethodName: "GetStepStats",
			Handler:    _TaskQueue_GetStepStats_Handler,
		},
		{
			MethodName: "GetWorkerStats",
			Handler:    _TaskQueue_GetWorkerStats_Handler,
		},
		{
			MethodName: "FetchList",
			Handler:    _TaskQueue_FetchList_Handler,
		},
		{
			MethodName: "FetchInfo",
			Handler:    _TaskQueue_FetchInfo_Handler,
		},
		{
			MethodName: "UploadTemplate",
			Handler:    _TaskQueue_UploadTemplate_Handler,
		},
		{
			MethodName: "DownloadTemplate",
			Handler:    _TaskQueue_DownloadTemplate_Handler,
		},
		{
			MethodName: "RunTemplate",
			Handler:    _TaskQueue_RunTemplate_Handler,
		},
		{
			MethodName: "ListTemplates",
			Handler:    _TaskQueue_ListTemplates_Handler,
		},
		{
			MethodName: "UpdateTemplate",
			Handler:    _TaskQueue_UpdateTemplate_Handler,
		},
		{
			MethodName: "ListTemplateRuns",
			Handler:    _TaskQueue_ListTemplateRuns_Handler,
		},
		{
			MethodName: "UpdateTemplateRun",
			Handler:    _TaskQueue_UpdateTemplateRun_Handler,
		},
		{
			MethodName: "DeleteTemplateRun",
			Handler:    _TaskQueue_DeleteTemplateRun_Handler,
		},
		{
			MethodName: "RegisterAdhocRun",
			Handler:    _TaskQueue_RegisterAdhocRun_Handler,
		},
		{
			MethodName: "UploadModule",
			Handler:    _TaskQueue_UploadModule_Handler,
		},
		{
			MethodName: "ListModules",
			Handler:    _TaskQueue_ListModules_Handler,
		},
		{
			MethodName: "ListModulesFiltered",
			Handler:    _TaskQueue_ListModulesFiltered_Handler,
		},
		{
			MethodName: "DownloadModule",
			Handler:    _TaskQueue_DownloadModule_Handler,
		},
		{
			MethodName: "DeleteModule",
			Handler:    _TaskQueue_DeleteModule_Handler,
		},
		{
			MethodName: "UpgradeBundledModules",
			Handler:    _TaskQueue_UpgradeBundledModules_Handler,
		},
		{
			MethodName: "GetModuleOrigin",
			Handler:    _TaskQueue_GetModuleOrigin_Handler,
		},
		{
			MethodName: "ForkModule",
			Handler:    _TaskQueue_ForkModule_Handler,
		},
		{
			MethodName: "GetWorkspaceRoot",
			Handler:    _TaskQueue_GetWorkspaceRoot_Handler,
		},
		{
			MethodName: "GetResourceRoot",
			Handler:    _TaskQueue_GetResourceRoot_Handler,
		},
		{
			MethodName: "RegisterSpecifications",
			Handler:    _TaskQueue_RegisterSpecifications_Handler,
		},
		{
			MethodName: "ReportWorkerEvent",
			Handler:    _TaskQueue_ReportWorkerEvent_Handler,
		},
		{
			MethodName: "ListWorkerEvents",
			Handler:    _TaskQueue_ListWorkerEvents_Handler,
		},
		{
			MethodName: "DeleteWorkerEvent",
			Handler:    _TaskQueue_DeleteWorkerEvent_Handler,
		},
		{
			MethodName: "PruneWorkerEvents",
			Handler:    _TaskQueue_PruneWorkerEvents_Handler,
		},
		{
			MethodName: "GetTaskStatusCounts",
			Handler:    _TaskQueue_GetTaskStatusCounts_Handler,
		},
		{
			MethodName: "SignalTask",
			Handler:    _TaskQueue_SignalTask_Handler,
		},
		{
			MethodName: "ServerVersion",
			Handler:    _TaskQueue_ServerVersion_Handler,
		},
		{
			MethodName: "RequestWorkerUpgrade",
			Handler:    _TaskQueue_RequestWorkerUpgrade_Handler,
		},
		{
			MethodName: "GetClientUpgradeInfo",
			Handler:    _TaskQueue_GetClientUpgradeInfo_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SendTaskLogs",
			Handler:       _TaskQueue_SendTaskLogs_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "StreamTaskLogsOutput",
			Handler:       _TaskQueue_StreamTaskLogsOutput_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamTaskLogsErr",
			Handler:       _TaskQueue_StreamTaskLogsErr_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "taskqueue.proto",
}

TaskQueue_ServiceDesc is the grpc.ServiceDesc for TaskQueue service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTaskQueueServer

func RegisterTaskQueueServer(s grpc.ServiceRegistrar, srv TaskQueueServer)

Types

type Accum

type Accum struct {
	Count int32   `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` // number of observations
	Sum   float32 `protobuf:"fixed32,2,opt,name=sum,proto3" json:"sum,omitempty"`    // total seconds
	Min   float32 `protobuf:"fixed32,3,opt,name=min,proto3" json:"min,omitempty"`    // minimum seconds
	Max   float32 `protobuf:"fixed32,4,opt,name=max,proto3" json:"max,omitempty"`    // maximum seconds
	// contains filtered or unexported fields
}

func (*Accum) Descriptor deprecated

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

Deprecated: Use Accum.ProtoReflect.Descriptor instead.

func (*Accum) GetCount

func (x *Accum) GetCount() int32

func (*Accum) GetMax

func (x *Accum) GetMax() float32

func (*Accum) GetMin

func (x *Accum) GetMin() float32

func (*Accum) GetSum

func (x *Accum) GetSum() float32

func (*Accum) ProtoMessage

func (*Accum) ProtoMessage()

func (*Accum) ProtoReflect

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

func (*Accum) Reset

func (x *Accum) Reset()

func (*Accum) String

func (x *Accum) String() string

type Ack

type Ack struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*Ack) Descriptor deprecated

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

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetSuccess

func (x *Ack) GetSuccess() bool

func (*Ack) ProtoMessage

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect

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

func (*Ack) Reset

func (x *Ack) Reset()

func (*Ack) String

func (x *Ack) String() string

type AdminResetPasswordRequest added in v0.7.1

type AdminResetPasswordRequest struct {
	UserId      int32  `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	NewPassword string `protobuf:"bytes,2,opt,name=new_password,json=newPassword,proto3" json:"new_password,omitempty"`
	// contains filtered or unexported fields
}

func (*AdminResetPasswordRequest) Descriptor deprecated added in v0.7.1

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

Deprecated: Use AdminResetPasswordRequest.ProtoReflect.Descriptor instead.

func (*AdminResetPasswordRequest) GetNewPassword added in v0.7.1

func (x *AdminResetPasswordRequest) GetNewPassword() string

func (*AdminResetPasswordRequest) GetUserId added in v0.7.1

func (x *AdminResetPasswordRequest) GetUserId() int32

func (*AdminResetPasswordRequest) ProtoMessage added in v0.7.1

func (*AdminResetPasswordRequest) ProtoMessage()

func (*AdminResetPasswordRequest) ProtoReflect added in v0.7.1

func (*AdminResetPasswordRequest) Reset added in v0.7.1

func (x *AdminResetPasswordRequest) Reset()

func (*AdminResetPasswordRequest) String added in v0.7.1

func (x *AdminResetPasswordRequest) String() string

type Certificate

type Certificate struct {
	Pem string `protobuf:"bytes,1,opt,name=pem,proto3" json:"pem,omitempty"`
	// contains filtered or unexported fields
}

func (*Certificate) Descriptor deprecated

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

Deprecated: Use Certificate.ProtoReflect.Descriptor instead.

func (*Certificate) GetPem

func (x *Certificate) GetPem() string

func (*Certificate) ProtoMessage

func (*Certificate) ProtoMessage()

func (*Certificate) ProtoReflect

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

func (*Certificate) Reset

func (x *Certificate) Reset()

func (*Certificate) String

func (x *Certificate) String() string

type ChainEntry added in v0.8.5

type ChainEntry struct {
	ChainEntryId     int32 `protobuf:"varint,1,opt,name=chain_entry_id,json=chainEntryId,proto3" json:"chain_entry_id,omitempty"`
	ParentWorkflowId int32 `protobuf:"varint,2,opt,name=parent_workflow_id,json=parentWorkflowId,proto3" json:"parent_workflow_id,omitempty"`
	// Position in the parent's `chain:` list (stable ordering for display).
	Idx          int32  `protobuf:"varint,3,opt,name=idx,proto3" json:"idx,omitempty"`
	TemplateName string `protobuf:"bytes,4,opt,name=template_name,json=templateName,proto3" json:"template_name,omitempty"`
	// Pinned version (null = "latest" at fire time).
	TemplateVersion *string `protobuf:"bytes,5,opt,name=template_version,json=templateVersion,proto3,oneof" json:"template_version,omitempty"`
	// JSON object: keys are child param names, values are unresolved
	// strings containing {parent.params.X} / {parent.publish.<step>} / ...
	ParamsTemplateJson string `protobuf:"bytes,6,opt,name=params_template_json,json=paramsTemplateJson,proto3" json:"params_template_json,omitempty"`
	// Truthy condition expression; "" means default (true).
	WhenExpr string `protobuf:"bytes,7,opt,name=when_expr,json=whenExpr,proto3" json:"when_expr,omitempty"`
	// Parent-status filter: "succeeded" (default) | "always" | "failed".
	OnStatus string `protobuf:"bytes,8,opt,name=on_status,json=onStatus,proto3" json:"on_status,omitempty"`
	// If true, fire a fresh child each time instead of reconciling via --continue.
	AlwaysNew bool `protobuf:"varint,9,opt,name=always_new,json=alwaysNew,proto3" json:"always_new,omitempty"`
	// Lifecycle: pending|suspended|skipped|fired|failed|cancelled.
	Status string `protobuf:"bytes,10,opt,name=status,proto3" json:"status,omitempty"`
	// Populated when status=fired (or last child if re-fired on parent extend).
	ChildWorkflowId *int32 `protobuf:"varint,11,opt,name=child_workflow_id,json=childWorkflowId,proto3,oneof" json:"child_workflow_id,omitempty"`
	// Populated when status=failed (chain firing itself failed).
	ErrorMessage *string `protobuf:"bytes,12,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"`
	CreatedAt    string  `protobuf:"bytes,13,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	FiredAt      *string `protobuf:"bytes,14,opt,name=fired_at,json=firedAt,proto3,oneof" json:"fired_at,omitempty"`
	LastFiredAt  *string `protobuf:"bytes,15,opt,name=last_fired_at,json=lastFiredAt,proto3,oneof" json:"last_fired_at,omitempty"`
	// contains filtered or unexported fields
}

A planned (or historical) chain entry: armed at parent-submit time, evaluated when the parent reaches a terminal status.

func (*ChainEntry) Descriptor deprecated added in v0.8.5

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

Deprecated: Use ChainEntry.ProtoReflect.Descriptor instead.

func (*ChainEntry) GetAlwaysNew added in v0.8.5

func (x *ChainEntry) GetAlwaysNew() bool

func (*ChainEntry) GetChainEntryId added in v0.8.5

func (x *ChainEntry) GetChainEntryId() int32

func (*ChainEntry) GetChildWorkflowId added in v0.8.5

func (x *ChainEntry) GetChildWorkflowId() int32

func (*ChainEntry) GetCreatedAt added in v0.8.5

func (x *ChainEntry) GetCreatedAt() string

func (*ChainEntry) GetErrorMessage added in v0.8.5

func (x *ChainEntry) GetErrorMessage() string

func (*ChainEntry) GetFiredAt added in v0.8.5

func (x *ChainEntry) GetFiredAt() string

func (*ChainEntry) GetIdx added in v0.8.5

func (x *ChainEntry) GetIdx() int32

func (*ChainEntry) GetLastFiredAt added in v0.8.5

func (x *ChainEntry) GetLastFiredAt() string

func (*ChainEntry) GetOnStatus added in v0.8.5

func (x *ChainEntry) GetOnStatus() string

func (*ChainEntry) GetParamsTemplateJson added in v0.8.5

func (x *ChainEntry) GetParamsTemplateJson() string

func (*ChainEntry) GetParentWorkflowId added in v0.8.5

func (x *ChainEntry) GetParentWorkflowId() int32

func (*ChainEntry) GetStatus added in v0.8.5

func (x *ChainEntry) GetStatus() string

func (*ChainEntry) GetTemplateName added in v0.8.5

func (x *ChainEntry) GetTemplateName() string

func (*ChainEntry) GetTemplateVersion added in v0.8.5

func (x *ChainEntry) GetTemplateVersion() string

func (*ChainEntry) GetWhenExpr added in v0.8.5

func (x *ChainEntry) GetWhenExpr() string

func (*ChainEntry) ProtoMessage added in v0.8.5

func (*ChainEntry) ProtoMessage()

func (*ChainEntry) ProtoReflect added in v0.8.5

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

func (*ChainEntry) Reset added in v0.8.5

func (x *ChainEntry) Reset()

func (*ChainEntry) String added in v0.8.5

func (x *ChainEntry) String() string

type ChainEntryDraft added in v0.8.5

type ChainEntryDraft struct {
	TemplateName       string  `protobuf:"bytes,1,opt,name=template_name,json=templateName,proto3" json:"template_name,omitempty"`
	TemplateVersion    *string `protobuf:"bytes,2,opt,name=template_version,json=templateVersion,proto3,oneof" json:"template_version,omitempty"`
	ParamsTemplateJson string  `protobuf:"bytes,3,opt,name=params_template_json,json=paramsTemplateJson,proto3" json:"params_template_json,omitempty"`
	WhenExpr           string  `protobuf:"bytes,4,opt,name=when_expr,json=whenExpr,proto3" json:"when_expr,omitempty"`
	OnStatus           string  `protobuf:"bytes,5,opt,name=on_status,json=onStatus,proto3" json:"on_status,omitempty"`
	AlwaysNew          bool    `protobuf:"varint,6,opt,name=always_new,json=alwaysNew,proto3" json:"always_new,omitempty"`
	// contains filtered or unexported fields
}

A pre-creation chain entry — fields the caller supplies; the server assigns chain_entry_id, idx, created_at, status=pending.

func (*ChainEntryDraft) Descriptor deprecated added in v0.8.5

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

Deprecated: Use ChainEntryDraft.ProtoReflect.Descriptor instead.

func (*ChainEntryDraft) GetAlwaysNew added in v0.8.5

func (x *ChainEntryDraft) GetAlwaysNew() bool

func (*ChainEntryDraft) GetOnStatus added in v0.8.5

func (x *ChainEntryDraft) GetOnStatus() string

func (*ChainEntryDraft) GetParamsTemplateJson added in v0.8.5

func (x *ChainEntryDraft) GetParamsTemplateJson() string

func (*ChainEntryDraft) GetTemplateName added in v0.8.5

func (x *ChainEntryDraft) GetTemplateName() string

func (*ChainEntryDraft) GetTemplateVersion added in v0.8.5

func (x *ChainEntryDraft) GetTemplateVersion() string

func (*ChainEntryDraft) GetWhenExpr added in v0.8.5

func (x *ChainEntryDraft) GetWhenExpr() string

func (*ChainEntryDraft) ProtoMessage added in v0.8.5

func (*ChainEntryDraft) ProtoMessage()

func (*ChainEntryDraft) ProtoReflect added in v0.8.5

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

func (*ChainEntryDraft) Reset added in v0.8.5

func (x *ChainEntryDraft) Reset()

func (*ChainEntryDraft) String added in v0.8.5

func (x *ChainEntryDraft) String() string

type ChainEntryId added in v0.8.5

type ChainEntryId struct {
	ChainEntryId int32 `protobuf:"varint,1,opt,name=chain_entry_id,json=chainEntryId,proto3" json:"chain_entry_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainEntryId) Descriptor deprecated added in v0.8.5

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

Deprecated: Use ChainEntryId.ProtoReflect.Descriptor instead.

func (*ChainEntryId) GetChainEntryId added in v0.8.5

func (x *ChainEntryId) GetChainEntryId() int32

func (*ChainEntryId) ProtoMessage added in v0.8.5

func (*ChainEntryId) ProtoMessage()

func (*ChainEntryId) ProtoReflect added in v0.8.5

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

func (*ChainEntryId) Reset added in v0.8.5

func (x *ChainEntryId) Reset()

func (*ChainEntryId) String added in v0.8.5

func (x *ChainEntryId) String() string

type ChainEntryList added in v0.8.5

type ChainEntryList struct {
	Entries []*ChainEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainEntryList) Descriptor deprecated added in v0.8.5

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

Deprecated: Use ChainEntryList.ProtoReflect.Descriptor instead.

func (*ChainEntryList) GetEntries added in v0.8.5

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

func (*ChainEntryList) ProtoMessage added in v0.8.5

func (*ChainEntryList) ProtoMessage()

func (*ChainEntryList) ProtoReflect added in v0.8.5

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

func (*ChainEntryList) Reset added in v0.8.5

func (x *ChainEntryList) Reset()

func (*ChainEntryList) String added in v0.8.5

func (x *ChainEntryList) String() string

type ChangePasswordRequest

type ChangePasswordRequest struct {
	Username    string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	OldPassword string `protobuf:"bytes,2,opt,name=old_password,json=oldPassword,proto3" json:"old_password,omitempty"`
	NewPassword string `protobuf:"bytes,3,opt,name=new_password,json=newPassword,proto3" json:"new_password,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangePasswordRequest) Descriptor deprecated

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

Deprecated: Use ChangePasswordRequest.ProtoReflect.Descriptor instead.

func (*ChangePasswordRequest) GetNewPassword

func (x *ChangePasswordRequest) GetNewPassword() string

func (*ChangePasswordRequest) GetOldPassword

func (x *ChangePasswordRequest) GetOldPassword() string

func (*ChangePasswordRequest) GetUsername

func (x *ChangePasswordRequest) GetUsername() string

func (*ChangePasswordRequest) ProtoMessage

func (*ChangePasswordRequest) ProtoMessage()

func (*ChangePasswordRequest) ProtoReflect

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

func (*ChangePasswordRequest) Reset

func (x *ChangePasswordRequest) Reset()

func (*ChangePasswordRequest) String

func (x *ChangePasswordRequest) String() string

type ClientUpgradeInfo added in v0.8.1

type ClientUpgradeInfo struct {
	BinaryUrl          string `protobuf:"bytes,1,opt,name=binary_url,json=binaryUrl,proto3" json:"binary_url,omitempty"`                               // GET → bytes; auth token already embedded
	Sha256Url          string `protobuf:"bytes,2,opt,name=sha256_url,json=sha256Url,proto3" json:"sha256_url,omitempty"`                               // GET → hex digest; auth token already embedded
	InsecureSkipVerify bool   `protobuf:"varint,3,opt,name=insecure_skip_verify,json=insecureSkipVerify,proto3" json:"insecure_skip_verify,omitempty"` // server uses an embedded self-signed cert; worker should skip TLS verify
	// scitq CLI binary — refreshed in the same upgrade pass so the binary
	// bind-mounted into task containers (`task_spec.scitq_auth: true`)
	// stays in sync with the worker version. Empty when the server hasn't
	// got a CLI binary to ship (older deploys, dev setups).
	CliBinaryUrl   string `protobuf:"bytes,4,opt,name=cli_binary_url,json=cliBinaryUrl,proto3" json:"cli_binary_url,omitempty"`
	CliSha256Url   string `protobuf:"bytes,5,opt,name=cli_sha256_url,json=cliSha256Url,proto3" json:"cli_sha256_url,omitempty"`
	CliInstallPath string `protobuf:"bytes,6,opt,name=cli_install_path,json=cliInstallPath,proto3" json:"cli_install_path,omitempty"` // absolute path on the worker, e.g. /usr/local/bin/scitq
	// contains filtered or unexported fields
}

func (*ClientUpgradeInfo) Descriptor deprecated added in v0.8.1

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

Deprecated: Use ClientUpgradeInfo.ProtoReflect.Descriptor instead.

func (*ClientUpgradeInfo) GetBinaryUrl added in v0.8.1

func (x *ClientUpgradeInfo) GetBinaryUrl() string

func (*ClientUpgradeInfo) GetCliBinaryUrl added in v0.8.5

func (x *ClientUpgradeInfo) GetCliBinaryUrl() string

func (*ClientUpgradeInfo) GetCliInstallPath added in v0.8.5

func (x *ClientUpgradeInfo) GetCliInstallPath() string

func (*ClientUpgradeInfo) GetCliSha256Url added in v0.8.5

func (x *ClientUpgradeInfo) GetCliSha256Url() string

func (*ClientUpgradeInfo) GetInsecureSkipVerify added in v0.8.1

func (x *ClientUpgradeInfo) GetInsecureSkipVerify() bool

func (*ClientUpgradeInfo) GetSha256Url added in v0.8.1

func (x *ClientUpgradeInfo) GetSha256Url() string

func (*ClientUpgradeInfo) ProtoMessage added in v0.8.1

func (*ClientUpgradeInfo) ProtoMessage()

func (*ClientUpgradeInfo) ProtoReflect added in v0.8.1

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

func (*ClientUpgradeInfo) Reset added in v0.8.1

func (x *ClientUpgradeInfo) Reset()

func (*ClientUpgradeInfo) String added in v0.8.1

func (x *ClientUpgradeInfo) String() string

type CreateChainEntriesRequest added in v0.8.5

type CreateChainEntriesRequest struct {
	WorkflowId int32              `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	Entries    []*ChainEntryDraft `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateChainEntriesRequest) Descriptor deprecated added in v0.8.5

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

Deprecated: Use CreateChainEntriesRequest.ProtoReflect.Descriptor instead.

func (*CreateChainEntriesRequest) GetEntries added in v0.8.5

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

func (*CreateChainEntriesRequest) GetWorkflowId added in v0.8.5

func (x *CreateChainEntriesRequest) GetWorkflowId() int32

func (*CreateChainEntriesRequest) ProtoMessage added in v0.8.5

func (*CreateChainEntriesRequest) ProtoMessage()

func (*CreateChainEntriesRequest) ProtoReflect added in v0.8.5

func (*CreateChainEntriesRequest) Reset added in v0.8.5

func (x *CreateChainEntriesRequest) Reset()

func (*CreateChainEntriesRequest) String added in v0.8.5

func (x *CreateChainEntriesRequest) String() string

type CreateUserRequest

type CreateUserRequest struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Email    string `protobuf:"bytes,3,opt,name=email,proto3" json:"email,omitempty"`
	IsAdmin  bool   `protobuf:"varint,4,opt,name=is_admin,json=isAdmin,proto3" json:"is_admin,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateUserRequest) Descriptor deprecated

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

Deprecated: Use CreateUserRequest.ProtoReflect.Descriptor instead.

func (*CreateUserRequest) GetEmail

func (x *CreateUserRequest) GetEmail() string

func (*CreateUserRequest) GetIsAdmin

func (x *CreateUserRequest) GetIsAdmin() bool

func (*CreateUserRequest) GetPassword

func (x *CreateUserRequest) GetPassword() string

func (*CreateUserRequest) GetUsername

func (x *CreateUserRequest) GetUsername() string

func (*CreateUserRequest) ProtoMessage

func (*CreateUserRequest) ProtoMessage()

func (*CreateUserRequest) ProtoReflect

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

func (*CreateUserRequest) Reset

func (x *CreateUserRequest) Reset()

func (*CreateUserRequest) String

func (x *CreateUserRequest) String() string

type CreateWorkerByNameRequest added in v0.7.1

type CreateWorkerByNameRequest struct {
	Provider    string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"` // e.g. "azure.primary" or "openstack.ovh"
	Flavor      string `protobuf:"bytes,2,opt,name=flavor,proto3" json:"flavor,omitempty"`     // e.g. "Standard_D32s_v5"
	Region      string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`     // e.g. "swedencentral" (optional, defaults to provider default)
	Count       int32  `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`      // number of workers (default: 1)
	Concurrency int32  `protobuf:"varint,5,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	Prefetch    int32  `protobuf:"varint,6,opt,name=prefetch,proto3" json:"prefetch,omitempty"`
	StepId      *int32 `protobuf:"varint,7,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateWorkerByNameRequest) Descriptor deprecated added in v0.7.1

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

Deprecated: Use CreateWorkerByNameRequest.ProtoReflect.Descriptor instead.

func (*CreateWorkerByNameRequest) GetConcurrency added in v0.7.1

func (x *CreateWorkerByNameRequest) GetConcurrency() int32

func (*CreateWorkerByNameRequest) GetCount added in v0.7.1

func (x *CreateWorkerByNameRequest) GetCount() int32

func (*CreateWorkerByNameRequest) GetFlavor added in v0.7.1

func (x *CreateWorkerByNameRequest) GetFlavor() string

func (*CreateWorkerByNameRequest) GetPrefetch added in v0.7.1

func (x *CreateWorkerByNameRequest) GetPrefetch() int32

func (*CreateWorkerByNameRequest) GetProvider added in v0.7.1

func (x *CreateWorkerByNameRequest) GetProvider() string

func (*CreateWorkerByNameRequest) GetRegion added in v0.7.1

func (x *CreateWorkerByNameRequest) GetRegion() string

func (*CreateWorkerByNameRequest) GetStepId added in v0.7.1

func (x *CreateWorkerByNameRequest) GetStepId() int32

func (*CreateWorkerByNameRequest) ProtoMessage added in v0.7.1

func (*CreateWorkerByNameRequest) ProtoMessage()

func (*CreateWorkerByNameRequest) ProtoReflect added in v0.7.1

func (*CreateWorkerByNameRequest) Reset added in v0.7.1

func (x *CreateWorkerByNameRequest) Reset()

func (*CreateWorkerByNameRequest) String added in v0.7.1

func (x *CreateWorkerByNameRequest) String() string

type DebugAssignRequest

type DebugAssignRequest struct {
	WorkflowId int32 `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	TaskId     int32 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DebugAssignRequest) Descriptor deprecated

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

Deprecated: Use DebugAssignRequest.ProtoReflect.Descriptor instead.

func (*DebugAssignRequest) GetTaskId

func (x *DebugAssignRequest) GetTaskId() int32

func (*DebugAssignRequest) GetWorkflowId

func (x *DebugAssignRequest) GetWorkflowId() int32

func (*DebugAssignRequest) ProtoMessage

func (*DebugAssignRequest) ProtoMessage()

func (*DebugAssignRequest) ProtoReflect

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

func (*DebugAssignRequest) Reset

func (x *DebugAssignRequest) Reset()

func (*DebugAssignRequest) String

func (x *DebugAssignRequest) String() string

type DebugRecruitRequest

type DebugRecruitRequest struct {
	WorkflowId int32 `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	StepId     int32 `protobuf:"varint,2,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DebugRecruitRequest) Descriptor deprecated

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

Deprecated: Use DebugRecruitRequest.ProtoReflect.Descriptor instead.

func (*DebugRecruitRequest) GetStepId

func (x *DebugRecruitRequest) GetStepId() int32

func (*DebugRecruitRequest) GetWorkflowId

func (x *DebugRecruitRequest) GetWorkflowId() int32

func (*DebugRecruitRequest) ProtoMessage

func (*DebugRecruitRequest) ProtoMessage()

func (*DebugRecruitRequest) ProtoReflect

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

func (*DebugRecruitRequest) Reset

func (x *DebugRecruitRequest) Reset()

func (*DebugRecruitRequest) String

func (x *DebugRecruitRequest) String() string

type DeleteModuleRequest added in v0.8.5

type DeleteModuleRequest struct {
	Path    string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

Admin-only: drop a module row from the DB. After deletion, the next auto-upgrade pass (or server restart) reinserts the bundled copy if one exists at the same path/version.

func (*DeleteModuleRequest) Descriptor deprecated added in v0.8.5

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

Deprecated: Use DeleteModuleRequest.ProtoReflect.Descriptor instead.

func (*DeleteModuleRequest) GetPath added in v0.8.5

func (x *DeleteModuleRequest) GetPath() string

func (*DeleteModuleRequest) GetVersion added in v0.8.5

func (x *DeleteModuleRequest) GetVersion() string

func (*DeleteModuleRequest) ProtoMessage added in v0.8.5

func (*DeleteModuleRequest) ProtoMessage()

func (*DeleteModuleRequest) ProtoReflect added in v0.8.5

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

func (*DeleteModuleRequest) Reset added in v0.8.5

func (x *DeleteModuleRequest) Reset()

func (*DeleteModuleRequest) String added in v0.8.5

func (x *DeleteModuleRequest) String() string

type DeleteTemplateRunRequest

type DeleteTemplateRunRequest struct {
	TemplateRunId int32 `protobuf:"varint,1,opt,name=template_run_id,json=templateRunId,proto3" json:"template_run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTemplateRunRequest) Descriptor deprecated

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

Deprecated: Use DeleteTemplateRunRequest.ProtoReflect.Descriptor instead.

func (*DeleteTemplateRunRequest) GetTemplateRunId

func (x *DeleteTemplateRunRequest) GetTemplateRunId() int32

func (*DeleteTemplateRunRequest) ProtoMessage

func (*DeleteTemplateRunRequest) ProtoMessage()

func (*DeleteTemplateRunRequest) ProtoReflect

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

func (*DeleteTemplateRunRequest) Reset

func (x *DeleteTemplateRunRequest) Reset()

func (*DeleteTemplateRunRequest) String

func (x *DeleteTemplateRunRequest) String() string

type DiskIOStats

type DiskIOStats struct {
	ReadBytesTotal  int64   `protobuf:"varint,1,opt,name=read_bytes_total,json=readBytesTotal,proto3" json:"read_bytes_total,omitempty"`    // Total bytes read
	WriteBytesTotal int64   `protobuf:"varint,2,opt,name=write_bytes_total,json=writeBytesTotal,proto3" json:"write_bytes_total,omitempty"` // Total bytes written
	ReadBytesRate   float32 `protobuf:"fixed32,3,opt,name=read_bytes_rate,json=readBytesRate,proto3" json:"read_bytes_rate,omitempty"`      // Bytes per second
	WriteBytesRate  float32 `protobuf:"fixed32,4,opt,name=write_bytes_rate,json=writeBytesRate,proto3" json:"write_bytes_rate,omitempty"`   // Bytes per second
	// contains filtered or unexported fields
}

func (*DiskIOStats) Descriptor deprecated

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

Deprecated: Use DiskIOStats.ProtoReflect.Descriptor instead.

func (*DiskIOStats) GetReadBytesRate

func (x *DiskIOStats) GetReadBytesRate() float32

func (*DiskIOStats) GetReadBytesTotal

func (x *DiskIOStats) GetReadBytesTotal() int64

func (*DiskIOStats) GetWriteBytesRate

func (x *DiskIOStats) GetWriteBytesRate() float32

func (*DiskIOStats) GetWriteBytesTotal

func (x *DiskIOStats) GetWriteBytesTotal() int64

func (*DiskIOStats) ProtoMessage

func (*DiskIOStats) ProtoMessage()

func (*DiskIOStats) ProtoReflect

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

func (*DiskIOStats) Reset

func (x *DiskIOStats) Reset()

func (*DiskIOStats) String

func (x *DiskIOStats) String() string

type DiskUsage

type DiskUsage struct {
	DeviceName   string  `protobuf:"bytes,1,opt,name=device_name,json=deviceName,proto3" json:"device_name,omitempty"`         // E.g., "/dev/sda1"
	UsagePercent float32 `protobuf:"fixed32,2,opt,name=usage_percent,json=usagePercent,proto3" json:"usage_percent,omitempty"` // 0-100, float
	// contains filtered or unexported fields
}

func (*DiskUsage) Descriptor deprecated

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

Deprecated: Use DiskUsage.ProtoReflect.Descriptor instead.

func (*DiskUsage) GetDeviceName

func (x *DiskUsage) GetDeviceName() string

func (*DiskUsage) GetUsagePercent

func (x *DiskUsage) GetUsagePercent() float32

func (*DiskUsage) ProtoMessage

func (*DiskUsage) ProtoMessage()

func (*DiskUsage) ProtoReflect

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

func (*DiskUsage) Reset

func (x *DiskUsage) Reset()

func (*DiskUsage) String

func (x *DiskUsage) String() string

type DockerCredential

type DockerCredential struct {
	Registry string `protobuf:"bytes,1,opt,name=registry,proto3" json:"registry,omitempty"` // e.g., "3jfz1gy8.gra7.container-registry.ovh.net"
	Auth     string `protobuf:"bytes,2,opt,name=auth,proto3" json:"auth,omitempty"`         // auth string as found in .docker/config.json
	// contains filtered or unexported fields
}

func (*DockerCredential) Descriptor deprecated

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

Deprecated: Use DockerCredential.ProtoReflect.Descriptor instead.

func (*DockerCredential) GetAuth

func (x *DockerCredential) GetAuth() string

func (*DockerCredential) GetRegistry

func (x *DockerCredential) GetRegistry() string

func (*DockerCredential) ProtoMessage

func (*DockerCredential) ProtoMessage()

func (*DockerCredential) ProtoReflect

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

func (*DockerCredential) Reset

func (x *DockerCredential) Reset()

func (*DockerCredential) String

func (x *DockerCredential) String() string

type DockerCredentials

type DockerCredentials struct {
	Credentials []*DockerCredential `protobuf:"bytes,1,rep,name=credentials,proto3" json:"credentials,omitempty"`
	// contains filtered or unexported fields
}

func (*DockerCredentials) Descriptor deprecated

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

Deprecated: Use DockerCredentials.ProtoReflect.Descriptor instead.

func (*DockerCredentials) GetCredentials

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

func (*DockerCredentials) ProtoMessage

func (*DockerCredentials) ProtoMessage()

func (*DockerCredentials) ProtoReflect

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

func (*DockerCredentials) Reset

func (x *DockerCredentials) Reset()

func (*DockerCredentials) String

func (x *DockerCredentials) String() string

type DownloadModuleRequest added in v0.7.1

type DownloadModuleRequest struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadModuleRequest) Descriptor deprecated added in v0.7.1

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

Deprecated: Use DownloadModuleRequest.ProtoReflect.Descriptor instead.

func (*DownloadModuleRequest) GetFilename added in v0.7.1

func (x *DownloadModuleRequest) GetFilename() string

func (*DownloadModuleRequest) ProtoMessage added in v0.7.1

func (*DownloadModuleRequest) ProtoMessage()

func (*DownloadModuleRequest) ProtoReflect added in v0.7.1

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

func (*DownloadModuleRequest) Reset added in v0.7.1

func (x *DownloadModuleRequest) Reset()

func (*DownloadModuleRequest) String added in v0.7.1

func (x *DownloadModuleRequest) String() string

type DownloadTemplateRequest added in v0.7.1

type DownloadTemplateRequest struct {
	WorkflowTemplateId *int32  `protobuf:"varint,1,opt,name=workflow_template_id,json=workflowTemplateId,proto3,oneof" json:"workflow_template_id,omitempty"`
	Name               *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Version            *string `protobuf:"bytes,3,opt,name=version,proto3,oneof" json:"version,omitempty"`
	// contains filtered or unexported fields
}

Template download

func (*DownloadTemplateRequest) Descriptor deprecated added in v0.7.1

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

Deprecated: Use DownloadTemplateRequest.ProtoReflect.Descriptor instead.

func (*DownloadTemplateRequest) GetName added in v0.7.1

func (x *DownloadTemplateRequest) GetName() string

func (*DownloadTemplateRequest) GetVersion added in v0.7.1

func (x *DownloadTemplateRequest) GetVersion() string

func (*DownloadTemplateRequest) GetWorkflowTemplateId added in v0.7.1

func (x *DownloadTemplateRequest) GetWorkflowTemplateId() int32

func (*DownloadTemplateRequest) ProtoMessage added in v0.7.1

func (*DownloadTemplateRequest) ProtoMessage()

func (*DownloadTemplateRequest) ProtoReflect added in v0.7.1

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

func (*DownloadTemplateRequest) Reset added in v0.7.1

func (x *DownloadTemplateRequest) Reset()

func (*DownloadTemplateRequest) String added in v0.7.1

func (x *DownloadTemplateRequest) String() string

type EditAndRetryTaskRequest added in v0.7.1

type EditAndRetryTaskRequest struct {
	TaskId  int32  `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"` // New command to use for the retry
	// Optional overrides applied to the retry clone. Absent (nil pointer)
	// means "copy from the parent task" — the legacy behavior used by
	// operator-driven retries from the UI/CLI. Present means "replace on
	// the clone". Required for the workflow-extend fan-in case where
	// re-running a grouped/compile task must wire the freshly-submitted
	// samples into the new clone's inputs and prerequisite list.
	Inputs    *StringList `protobuf:"bytes,3,opt,name=inputs,proto3,oneof" json:"inputs,omitempty"`
	Resources *StringList `protobuf:"bytes,4,opt,name=resources,proto3,oneof" json:"resources,omitempty"`
	Depends   *Int32List  `protobuf:"bytes,5,opt,name=depends,proto3,oneof" json:"depends,omitempty"`
	// contains filtered or unexported fields
}

func (*EditAndRetryTaskRequest) Descriptor deprecated added in v0.7.1

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

Deprecated: Use EditAndRetryTaskRequest.ProtoReflect.Descriptor instead.

func (*EditAndRetryTaskRequest) GetCommand added in v0.7.1

func (x *EditAndRetryTaskRequest) GetCommand() string

func (*EditAndRetryTaskRequest) GetDepends added in v0.8.7

func (x *EditAndRetryTaskRequest) GetDepends() *Int32List

func (*EditAndRetryTaskRequest) GetInputs added in v0.8.7

func (x *EditAndRetryTaskRequest) GetInputs() *StringList

func (*EditAndRetryTaskRequest) GetResources added in v0.8.7

func (x *EditAndRetryTaskRequest) GetResources() *StringList

func (*EditAndRetryTaskRequest) GetTaskId added in v0.7.1

func (x *EditAndRetryTaskRequest) GetTaskId() int32

func (*EditAndRetryTaskRequest) ProtoMessage added in v0.7.1

func (*EditAndRetryTaskRequest) ProtoMessage()

func (*EditAndRetryTaskRequest) ProtoReflect added in v0.7.1

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

func (*EditAndRetryTaskRequest) Reset added in v0.7.1

func (x *EditAndRetryTaskRequest) Reset()

func (*EditAndRetryTaskRequest) String added in v0.7.1

func (x *EditAndRetryTaskRequest) String() string

type EditChainEntryRequest added in v0.8.5

type EditChainEntryRequest struct {
	ChainEntryId int32   `protobuf:"varint,1,opt,name=chain_entry_id,json=chainEntryId,proto3" json:"chain_entry_id,omitempty"`
	TemplateName *string `protobuf:"bytes,2,opt,name=template_name,json=templateName,proto3,oneof" json:"template_name,omitempty"`
	// Pass the empty string to clear template_version (resolve latest at
	// fire time). Unset = no change.
	TemplateVersion    *string `protobuf:"bytes,3,opt,name=template_version,json=templateVersion,proto3,oneof" json:"template_version,omitempty"`
	ParamsTemplateJson *string `protobuf:"bytes,4,opt,name=params_template_json,json=paramsTemplateJson,proto3,oneof" json:"params_template_json,omitempty"`
	WhenExpr           *string `protobuf:"bytes,5,opt,name=when_expr,json=whenExpr,proto3,oneof" json:"when_expr,omitempty"`
	OnStatus           *string `protobuf:"bytes,6,opt,name=on_status,json=onStatus,proto3,oneof" json:"on_status,omitempty"`
	AlwaysNew          *bool   `protobuf:"varint,7,opt,name=always_new,json=alwaysNew,proto3,oneof" json:"always_new,omitempty"`
	// contains filtered or unexported fields
}

func (*EditChainEntryRequest) Descriptor deprecated added in v0.8.5

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

Deprecated: Use EditChainEntryRequest.ProtoReflect.Descriptor instead.

func (*EditChainEntryRequest) GetAlwaysNew added in v0.8.5

func (x *EditChainEntryRequest) GetAlwaysNew() bool

func (*EditChainEntryRequest) GetChainEntryId added in v0.8.5

func (x *EditChainEntryRequest) GetChainEntryId() int32

func (*EditChainEntryRequest) GetOnStatus added in v0.8.5

func (x *EditChainEntryRequest) GetOnStatus() string

func (*EditChainEntryRequest) GetParamsTemplateJson added in v0.8.5

func (x *EditChainEntryRequest) GetParamsTemplateJson() string

func (*EditChainEntryRequest) GetTemplateName added in v0.8.5

func (x *EditChainEntryRequest) GetTemplateName() string

func (*EditChainEntryRequest) GetTemplateVersion added in v0.8.5

func (x *EditChainEntryRequest) GetTemplateVersion() string

func (*EditChainEntryRequest) GetWhenExpr added in v0.8.5

func (x *EditChainEntryRequest) GetWhenExpr() string

func (*EditChainEntryRequest) ProtoMessage added in v0.8.5

func (*EditChainEntryRequest) ProtoMessage()

func (*EditChainEntryRequest) ProtoReflect added in v0.8.5

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

func (*EditChainEntryRequest) Reset added in v0.8.5

func (x *EditChainEntryRequest) Reset()

func (*EditChainEntryRequest) String added in v0.8.5

func (x *EditChainEntryRequest) String() string

type EditStepCommandRequest added in v0.7.1

type EditStepCommandRequest struct {
	StepId   int32  `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	Find     string `protobuf:"bytes,2,opt,name=find,proto3" json:"find,omitempty"`                          // Plain text or regexp pattern to find
	Replace  string `protobuf:"bytes,3,opt,name=replace,proto3" json:"replace,omitempty"`                    // Replacement string
	IsRegexp bool   `protobuf:"varint,4,opt,name=is_regexp,json=isRegexp,proto3" json:"is_regexp,omitempty"` // If true, find is a regexp pattern
	// contains filtered or unexported fields
}

func (*EditStepCommandRequest) Descriptor deprecated added in v0.7.1

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

Deprecated: Use EditStepCommandRequest.ProtoReflect.Descriptor instead.

func (*EditStepCommandRequest) GetFind added in v0.7.1

func (x *EditStepCommandRequest) GetFind() string

func (*EditStepCommandRequest) GetIsRegexp added in v0.7.1

func (x *EditStepCommandRequest) GetIsRegexp() bool

func (*EditStepCommandRequest) GetReplace added in v0.7.1

func (x *EditStepCommandRequest) GetReplace() string

func (*EditStepCommandRequest) GetStepId added in v0.7.1

func (x *EditStepCommandRequest) GetStepId() int32

func (*EditStepCommandRequest) ProtoMessage added in v0.7.1

func (*EditStepCommandRequest) ProtoMessage()

func (*EditStepCommandRequest) ProtoReflect added in v0.7.1

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

func (*EditStepCommandRequest) Reset added in v0.7.1

func (x *EditStepCommandRequest) Reset()

func (*EditStepCommandRequest) String added in v0.7.1

func (x *EditStepCommandRequest) String() string

type EditStepCommandResponse added in v0.7.1

type EditStepCommandResponse struct {
	EditedCount int32   `protobuf:"varint,1,opt,name=edited_count,json=editedCount,proto3" json:"edited_count,omitempty"` // Number of tasks edited and retried
	NewTaskIds  []int32 `protobuf:"varint,2,rep,packed,name=new_task_ids,json=newTaskIds,proto3" json:"new_task_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*EditStepCommandResponse) Descriptor deprecated added in v0.7.1

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

Deprecated: Use EditStepCommandResponse.ProtoReflect.Descriptor instead.

func (*EditStepCommandResponse) GetEditedCount added in v0.7.1

func (x *EditStepCommandResponse) GetEditedCount() int32

func (*EditStepCommandResponse) GetNewTaskIds added in v0.7.1

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

func (*EditStepCommandResponse) ProtoMessage added in v0.7.1

func (*EditStepCommandResponse) ProtoMessage()

func (*EditStepCommandResponse) ProtoReflect added in v0.7.1

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

func (*EditStepCommandResponse) Reset added in v0.7.1

func (x *EditStepCommandResponse) Reset()

func (*EditStepCommandResponse) String added in v0.7.1

func (x *EditStepCommandResponse) String() string

type EditTaskRequest added in v0.7.7

type EditTaskRequest struct {
	TaskId           int32       `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Command          *string     `protobuf:"bytes,2,opt,name=command,proto3,oneof" json:"command,omitempty"`
	Container        *string     `protobuf:"bytes,3,opt,name=container,proto3,oneof" json:"container,omitempty"`
	ContainerOptions *string     `protobuf:"bytes,4,opt,name=container_options,json=containerOptions,proto3,oneof" json:"container_options,omitempty"`
	Shell            *string     `protobuf:"bytes,5,opt,name=shell,proto3,oneof" json:"shell,omitempty"`
	Status           *string     `protobuf:"bytes,6,opt,name=status,proto3,oneof" json:"status,omitempty"` // e.g. "P", "W", "F", "S"
	Input            *StringList `protobuf:"bytes,7,opt,name=input,proto3,oneof" json:"input,omitempty"`
	Resource         *StringList `protobuf:"bytes,8,opt,name=resource,proto3,oneof" json:"resource,omitempty"`
	Output           *string     `protobuf:"bytes,9,opt,name=output,proto3,oneof" json:"output,omitempty"`
	Publish          *string     `protobuf:"bytes,10,opt,name=publish,proto3,oneof" json:"publish,omitempty"`
	Retry            *int32      `protobuf:"varint,11,opt,name=retry,proto3,oneof" json:"retry,omitempty"`
	// contains filtered or unexported fields
}

EditTaskRequest updates fields on an existing task in place, without triggering a retry (use EditAndRetryTask for that). Only fields whose `optional` is set are touched; everything else is left as-is. The server rejects status transitions into worker-managed running states ("A", "C", "D", "O", "R", "U", "V") to avoid stomping on the workload's lifecycle.

func (*EditTaskRequest) Descriptor deprecated added in v0.7.7

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

Deprecated: Use EditTaskRequest.ProtoReflect.Descriptor instead.

func (*EditTaskRequest) GetCommand added in v0.7.7

func (x *EditTaskRequest) GetCommand() string

func (*EditTaskRequest) GetContainer added in v0.7.7

func (x *EditTaskRequest) GetContainer() string

func (*EditTaskRequest) GetContainerOptions added in v0.7.7

func (x *EditTaskRequest) GetContainerOptions() string

func (*EditTaskRequest) GetInput added in v0.7.7

func (x *EditTaskRequest) GetInput() *StringList

func (*EditTaskRequest) GetOutput added in v0.7.7

func (x *EditTaskRequest) GetOutput() string

func (*EditTaskRequest) GetPublish added in v0.7.7

func (x *EditTaskRequest) GetPublish() string

func (*EditTaskRequest) GetResource added in v0.7.7

func (x *EditTaskRequest) GetResource() *StringList

func (*EditTaskRequest) GetRetry added in v0.7.7

func (x *EditTaskRequest) GetRetry() int32

func (*EditTaskRequest) GetShell added in v0.7.7

func (x *EditTaskRequest) GetShell() string

func (*EditTaskRequest) GetStatus added in v0.7.7

func (x *EditTaskRequest) GetStatus() string

func (*EditTaskRequest) GetTaskId added in v0.7.7

func (x *EditTaskRequest) GetTaskId() int32

func (*EditTaskRequest) ProtoMessage added in v0.7.7

func (*EditTaskRequest) ProtoMessage()

func (*EditTaskRequest) ProtoReflect added in v0.7.7

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

func (*EditTaskRequest) Reset added in v0.7.7

func (x *EditTaskRequest) Reset()

func (*EditTaskRequest) String added in v0.7.7

func (x *EditTaskRequest) String() string

type FetchInfoResponse

type FetchInfoResponse struct {
	Uri         string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Filename    string `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Size        int64  `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	IsFile      bool   `protobuf:"varint,5,opt,name=is_file,json=isFile,proto3" json:"is_file,omitempty"`
	IsDir       bool   `protobuf:"varint,6,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchInfoResponse) Descriptor deprecated

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

Deprecated: Use FetchInfoResponse.ProtoReflect.Descriptor instead.

func (*FetchInfoResponse) GetDescription

func (x *FetchInfoResponse) GetDescription() string

func (*FetchInfoResponse) GetFilename

func (x *FetchInfoResponse) GetFilename() string

func (*FetchInfoResponse) GetIsDir

func (x *FetchInfoResponse) GetIsDir() bool

func (*FetchInfoResponse) GetIsFile

func (x *FetchInfoResponse) GetIsFile() bool

func (*FetchInfoResponse) GetSize

func (x *FetchInfoResponse) GetSize() int64

func (*FetchInfoResponse) GetUri

func (x *FetchInfoResponse) GetUri() string

func (*FetchInfoResponse) ProtoMessage

func (*FetchInfoResponse) ProtoMessage()

func (*FetchInfoResponse) ProtoReflect

func (x *FetchInfoResponse) ProtoReflect() protoreflect.Message

func (*FetchInfoResponse) Reset

func (x *FetchInfoResponse) Reset()

func (*FetchInfoResponse) String

func (x *FetchInfoResponse) String() string

type FetchListRequest

type FetchListRequest struct {
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"` // URI to fetch the list from (can include glob patterns)
	// contains filtered or unexported fields
}

func (*FetchListRequest) Descriptor deprecated

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

Deprecated: Use FetchListRequest.ProtoReflect.Descriptor instead.

func (*FetchListRequest) GetUri

func (x *FetchListRequest) GetUri() string

func (*FetchListRequest) ProtoMessage

func (*FetchListRequest) ProtoMessage()

func (*FetchListRequest) ProtoReflect

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

func (*FetchListRequest) Reset

func (x *FetchListRequest) Reset()

func (*FetchListRequest) String

func (x *FetchListRequest) String() string

type FetchListResponse

type FetchListResponse struct {
	Files []string `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"` // Absolute paths from the given URI
	// contains filtered or unexported fields
}

func (*FetchListResponse) Descriptor deprecated

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

Deprecated: Use FetchListResponse.ProtoReflect.Descriptor instead.

func (*FetchListResponse) GetFiles

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

func (*FetchListResponse) ProtoMessage

func (*FetchListResponse) ProtoMessage()

func (*FetchListResponse) ProtoReflect

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

func (*FetchListResponse) Reset

func (x *FetchListResponse) Reset()

func (*FetchListResponse) String

func (x *FetchListResponse) String() string

type FileContent added in v0.7.1

type FileContent struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Content  []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*FileContent) Descriptor deprecated added in v0.7.1

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

Deprecated: Use FileContent.ProtoReflect.Descriptor instead.

func (*FileContent) GetContent added in v0.7.1

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

func (*FileContent) GetFilename added in v0.7.1

func (x *FileContent) GetFilename() string

func (*FileContent) ProtoMessage added in v0.7.1

func (*FileContent) ProtoMessage()

func (*FileContent) ProtoReflect added in v0.7.1

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

func (*FileContent) Reset added in v0.7.1

func (x *FileContent) Reset()

func (*FileContent) String added in v0.7.1

func (x *FileContent) String() string

type Flavor

type Flavor struct {

	// Fields from the "flavor" table
	FlavorId      int32   `protobuf:"varint,1,opt,name=flavor_id,json=flavorId,proto3" json:"flavor_id,omitempty"`                   // PRIMARY KEY
	FlavorName    string  `protobuf:"bytes,2,opt,name=flavor_name,json=flavorName,proto3" json:"flavor_name,omitempty"`              // Name of the flavor
	ProviderId    int32   `protobuf:"varint,3,opt,name=provider_id,json=providerId,proto3" json:"provider_id,omitempty"`             // Foreign key to provider table
	Provider      string  `protobuf:"bytes,4,opt,name=provider,proto3" json:"provider,omitempty"`                                    // Name of the provider (provider_name.config_name)
	Cpu           int32   `protobuf:"varint,5,opt,name=cpu,proto3" json:"cpu,omitempty"`                                             // Number of CPU cores
	Mem           float32 `protobuf:"fixed32,6,opt,name=mem,proto3" json:"mem,omitempty"`                                            // Memory in GB (or as needed)
	Disk          float32 `protobuf:"fixed32,7,opt,name=disk,proto3" json:"disk,omitempty"`                                          // Disk size in GB (or as needed)
	Bandwidth     int32   `protobuf:"varint,8,opt,name=bandwidth,proto3" json:"bandwidth,omitempty"`                                 // Bandwidth (if applicable)
	Gpu           string  `protobuf:"bytes,9,opt,name=gpu,proto3" json:"gpu,omitempty"`                                              // GPU description
	Gpumem        int32   `protobuf:"varint,10,opt,name=gpumem,proto3" json:"gpumem,omitempty"`                                      // GPU memory (in GB, for example)
	HasGpu        bool    `protobuf:"varint,11,opt,name=has_gpu,json=hasGpu,proto3" json:"has_gpu,omitempty"`                        // Whether a GPU is present
	HasQuickDisks bool    `protobuf:"varint,12,opt,name=has_quick_disks,json=hasQuickDisks,proto3" json:"has_quick_disks,omitempty"` // Whether quick disks are supported
	// Fields from the "flavor_region" table
	RegionId int32   `protobuf:"varint,13,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"` // Foreign key to region table
	Region   string  `protobuf:"bytes,14,opt,name=region,proto3" json:"region,omitempty"`                      // (Optional) Region name
	Eviction float32 `protobuf:"fixed32,15,opt,name=eviction,proto3" json:"eviction,omitempty"`                // Eviction rate value
	Cost     float32 `protobuf:"fixed32,16,opt,name=cost,proto3" json:"cost,omitempty"`                        // Cost value
	// contains filtered or unexported fields
}

func (*Flavor) Descriptor deprecated

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

Deprecated: Use Flavor.ProtoReflect.Descriptor instead.

func (*Flavor) GetBandwidth

func (x *Flavor) GetBandwidth() int32

func (*Flavor) GetCost

func (x *Flavor) GetCost() float32

func (*Flavor) GetCpu

func (x *Flavor) GetCpu() int32

func (*Flavor) GetDisk

func (x *Flavor) GetDisk() float32

func (*Flavor) GetEviction

func (x *Flavor) GetEviction() float32

func (*Flavor) GetFlavorId

func (x *Flavor) GetFlavorId() int32

func (*Flavor) GetFlavorName

func (x *Flavor) GetFlavorName() string

func (*Flavor) GetGpu

func (x *Flavor) GetGpu() string

func (*Flavor) GetGpumem

func (x *Flavor) GetGpumem() int32

func (*Flavor) GetHasGpu

func (x *Flavor) GetHasGpu() bool

func (*Flavor) GetHasQuickDisks

func (x *Flavor) GetHasQuickDisks() bool

func (*Flavor) GetMem

func (x *Flavor) GetMem() float32

func (*Flavor) GetProvider

func (x *Flavor) GetProvider() string

func (*Flavor) GetProviderId

func (x *Flavor) GetProviderId() int32

func (*Flavor) GetRegion

func (x *Flavor) GetRegion() string

func (*Flavor) GetRegionId

func (x *Flavor) GetRegionId() int32

func (*Flavor) ProtoMessage

func (*Flavor) ProtoMessage()

func (*Flavor) ProtoReflect

func (x *Flavor) ProtoReflect() protoreflect.Message

func (*Flavor) Reset

func (x *Flavor) Reset()

func (*Flavor) String

func (x *Flavor) String() string

type FlavorAvailability added in v0.8.1

type FlavorAvailability struct {
	FlavorName string  `protobuf:"bytes,1,opt,name=flavor_name,json=flavorName,proto3" json:"flavor_name,omitempty"`
	Provider   string  `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	Region     *string `protobuf:"bytes,3,opt,name=region,proto3,oneof" json:"region,omitempty"`
	Available  bool    `protobuf:"varint,4,opt,name=available,proto3" json:"available,omitempty"`
	// contains filtered or unexported fields
}

Operator-driven flavor (de)activation. `provider` is the canonical "providerName.configName" form (e.g. "azure.primary"). `region` is optional — empty means "every region of that provider". `available` = false disables the flavor for new recruitment but leaves existing workers running and recyclable.

func (*FlavorAvailability) Descriptor deprecated added in v0.8.1

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

Deprecated: Use FlavorAvailability.ProtoReflect.Descriptor instead.

func (*FlavorAvailability) GetAvailable added in v0.8.1

func (x *FlavorAvailability) GetAvailable() bool

func (*FlavorAvailability) GetFlavorName added in v0.8.1

func (x *FlavorAvailability) GetFlavorName() string

func (*FlavorAvailability) GetProvider added in v0.8.1

func (x *FlavorAvailability) GetProvider() string

func (*FlavorAvailability) GetRegion added in v0.8.1

func (x *FlavorAvailability) GetRegion() string

func (*FlavorAvailability) ProtoMessage added in v0.8.1

func (*FlavorAvailability) ProtoMessage()

func (*FlavorAvailability) ProtoReflect added in v0.8.1

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

func (*FlavorAvailability) Reset added in v0.8.1

func (x *FlavorAvailability) Reset()

func (*FlavorAvailability) String added in v0.8.1

func (x *FlavorAvailability) String() string

type FlavorAvailabilityReply added in v0.8.1

type FlavorAvailabilityReply struct {
	AffectedRows int32 `protobuf:"varint,1,opt,name=affected_rows,json=affectedRows,proto3" json:"affected_rows,omitempty"` // number of flavor_region rows updated
	// contains filtered or unexported fields
}

func (*FlavorAvailabilityReply) Descriptor deprecated added in v0.8.1

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

Deprecated: Use FlavorAvailabilityReply.ProtoReflect.Descriptor instead.

func (*FlavorAvailabilityReply) GetAffectedRows added in v0.8.1

func (x *FlavorAvailabilityReply) GetAffectedRows() int32

func (*FlavorAvailabilityReply) ProtoMessage added in v0.8.1

func (*FlavorAvailabilityReply) ProtoMessage()

func (*FlavorAvailabilityReply) ProtoReflect added in v0.8.1

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

func (*FlavorAvailabilityReply) Reset added in v0.8.1

func (x *FlavorAvailabilityReply) Reset()

func (*FlavorAvailabilityReply) String added in v0.8.1

func (x *FlavorAvailabilityReply) String() string

type FlavorCreateRequest

type FlavorCreateRequest struct {
	ProviderName  string    `protobuf:"bytes,1,opt,name=provider_name,json=providerName,proto3" json:"provider_name,omitempty"`
	ConfigName    string    `protobuf:"bytes,2,opt,name=config_name,json=configName,proto3" json:"config_name,omitempty"`
	FlavorName    string    `protobuf:"bytes,3,opt,name=flavor_name,json=flavorName,proto3" json:"flavor_name,omitempty"`
	Cpu           int32     `protobuf:"varint,4,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory        float32   `protobuf:"fixed32,5,opt,name=memory,proto3" json:"memory,omitempty"`
	Disk          float32   `protobuf:"fixed32,6,opt,name=disk,proto3" json:"disk,omitempty"`
	Bandwidth     *int32    `protobuf:"varint,7,opt,name=bandwidth,proto3,oneof" json:"bandwidth,omitempty"`
	Gpu           *string   `protobuf:"bytes,8,opt,name=gpu,proto3,oneof" json:"gpu,omitempty"`
	Gpumem        *int32    `protobuf:"varint,9,opt,name=gpumem,proto3,oneof" json:"gpumem,omitempty"`
	HasGpu        *bool     `protobuf:"varint,10,opt,name=has_gpu,json=hasGpu,proto3,oneof" json:"has_gpu,omitempty"`
	HasQuickDisks *bool     `protobuf:"varint,11,opt,name=has_quick_disks,json=hasQuickDisks,proto3,oneof" json:"has_quick_disks,omitempty"`
	RegionNames   []string  `protobuf:"bytes,12,rep,name=region_names,json=regionNames,proto3" json:"region_names,omitempty"`
	Costs         []float32 `protobuf:"fixed32,13,rep,packed,name=costs,proto3" json:"costs,omitempty"`
	Evictions     []float32 `protobuf:"fixed32,14,rep,packed,name=evictions,proto3" json:"evictions,omitempty"`
	// contains filtered or unexported fields
}

func (*FlavorCreateRequest) Descriptor deprecated

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

Deprecated: Use FlavorCreateRequest.ProtoReflect.Descriptor instead.

func (*FlavorCreateRequest) GetBandwidth

func (x *FlavorCreateRequest) GetBandwidth() int32

func (*FlavorCreateRequest) GetConfigName

func (x *FlavorCreateRequest) GetConfigName() string

func (*FlavorCreateRequest) GetCosts

func (x *FlavorCreateRequest) GetCosts() []float32

func (*FlavorCreateRequest) GetCpu

func (x *FlavorCreateRequest) GetCpu() int32

func (*FlavorCreateRequest) GetDisk

func (x *FlavorCreateRequest) GetDisk() float32

func (*FlavorCreateRequest) GetEvictions

func (x *FlavorCreateRequest) GetEvictions() []float32

func (*FlavorCreateRequest) GetFlavorName

func (x *FlavorCreateRequest) GetFlavorName() string

func (*FlavorCreateRequest) GetGpu

func (x *FlavorCreateRequest) GetGpu() string

func (*FlavorCreateRequest) GetGpumem

func (x *FlavorCreateRequest) GetGpumem() int32

func (*FlavorCreateRequest) GetHasGpu

func (x *FlavorCreateRequest) GetHasGpu() bool

func (*FlavorCreateRequest) GetHasQuickDisks

func (x *FlavorCreateRequest) GetHasQuickDisks() bool

func (*FlavorCreateRequest) GetMemory

func (x *FlavorCreateRequest) GetMemory() float32

func (*FlavorCreateRequest) GetProviderName

func (x *FlavorCreateRequest) GetProviderName() string

func (*FlavorCreateRequest) GetRegionNames

func (x *FlavorCreateRequest) GetRegionNames() []string

func (*FlavorCreateRequest) ProtoMessage

func (*FlavorCreateRequest) ProtoMessage()

func (*FlavorCreateRequest) ProtoReflect

func (x *FlavorCreateRequest) ProtoReflect() protoreflect.Message

func (*FlavorCreateRequest) Reset

func (x *FlavorCreateRequest) Reset()

func (*FlavorCreateRequest) String

func (x *FlavorCreateRequest) String() string

type FlavorId

type FlavorId struct {
	FlavorId int32 `protobuf:"varint,1,opt,name=flavor_id,json=flavorId,proto3" json:"flavor_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FlavorId) Descriptor deprecated

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

Deprecated: Use FlavorId.ProtoReflect.Descriptor instead.

func (*FlavorId) GetFlavorId

func (x *FlavorId) GetFlavorId() int32

func (*FlavorId) ProtoMessage

func (*FlavorId) ProtoMessage()

func (*FlavorId) ProtoReflect

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

func (*FlavorId) Reset

func (x *FlavorId) Reset()

func (*FlavorId) String

func (x *FlavorId) String() string

type FlavorsList

type FlavorsList struct {
	Flavors []*Flavor `protobuf:"bytes,1,rep,name=flavors,proto3" json:"flavors,omitempty"`
	// contains filtered or unexported fields
}

func (*FlavorsList) Descriptor deprecated

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

Deprecated: Use FlavorsList.ProtoReflect.Descriptor instead.

func (*FlavorsList) GetFlavors

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

func (*FlavorsList) ProtoMessage

func (*FlavorsList) ProtoMessage()

func (*FlavorsList) ProtoReflect

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

func (*FlavorsList) Reset

func (x *FlavorsList) Reset()

func (*FlavorsList) String

func (x *FlavorsList) String() string

type ForceRunTaskRequest added in v0.7.1

type ForceRunTaskRequest struct {
	TaskId int32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ForceRunTaskRequest) Descriptor deprecated added in v0.7.1

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

Deprecated: Use ForceRunTaskRequest.ProtoReflect.Descriptor instead.

func (*ForceRunTaskRequest) GetTaskId added in v0.7.1

func (x *ForceRunTaskRequest) GetTaskId() int32

func (*ForceRunTaskRequest) ProtoMessage added in v0.7.1

func (*ForceRunTaskRequest) ProtoMessage()

func (*ForceRunTaskRequest) ProtoReflect added in v0.7.1

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

func (*ForceRunTaskRequest) Reset added in v0.7.1

func (x *ForceRunTaskRequest) Reset()

func (*ForceRunTaskRequest) String added in v0.7.1

func (x *ForceRunTaskRequest) String() string

type ForkModuleRequest added in v0.7.5

type ForkModuleRequest struct {
	SourcePath    string `protobuf:"bytes,1,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	SourceVersion string `protobuf:"bytes,2,opt,name=source_version,json=sourceVersion,proto3" json:"source_version,omitempty"` // optional; empty → latest bundled at source_path
	NewVersion    string `protobuf:"bytes,3,opt,name=new_version,json=newVersion,proto3" json:"new_version,omitempty"`          // required; rejected if already present
	// contains filtered or unexported fields
}

Create a new forked row by cloning a bundled module to a new version. Content is taken from the source row; caller typically follows up with `scitq module download` + edit + `scitq module upload --force`.

func (*ForkModuleRequest) Descriptor deprecated added in v0.7.5

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

Deprecated: Use ForkModuleRequest.ProtoReflect.Descriptor instead.

func (*ForkModuleRequest) GetNewVersion added in v0.7.5

func (x *ForkModuleRequest) GetNewVersion() string

func (*ForkModuleRequest) GetSourcePath added in v0.7.5

func (x *ForkModuleRequest) GetSourcePath() string

func (*ForkModuleRequest) GetSourceVersion added in v0.7.5

func (x *ForkModuleRequest) GetSourceVersion() string

func (*ForkModuleRequest) ProtoMessage added in v0.7.5

func (*ForkModuleRequest) ProtoMessage()

func (*ForkModuleRequest) ProtoReflect added in v0.7.5

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

func (*ForkModuleRequest) Reset added in v0.7.5

func (x *ForkModuleRequest) Reset()

func (*ForkModuleRequest) String added in v0.7.5

func (x *ForkModuleRequest) String() string

type GetLogsRequest

type GetLogsRequest struct {
	TaskIds     []int32 `protobuf:"varint,1,rep,packed,name=taskIds,proto3" json:"taskIds,omitempty"`
	ChunkSize   int32   `protobuf:"varint,2,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"`
	SkipFromEnd *int32  `protobuf:"varint,3,opt,name=skipFromEnd,proto3,oneof" json:"skipFromEnd,omitempty"`
	LogType     *string `protobuf:"bytes,4,opt,name=log_type,json=logType,proto3,oneof" json:"log_type,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogsRequest) Descriptor deprecated

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

Deprecated: Use GetLogsRequest.ProtoReflect.Descriptor instead.

func (*GetLogsRequest) GetChunkSize

func (x *GetLogsRequest) GetChunkSize() int32

func (*GetLogsRequest) GetLogType

func (x *GetLogsRequest) GetLogType() string

func (*GetLogsRequest) GetSkipFromEnd

func (x *GetLogsRequest) GetSkipFromEnd() int32

func (*GetLogsRequest) GetTaskIds

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

func (*GetLogsRequest) ProtoMessage

func (*GetLogsRequest) ProtoMessage()

func (*GetLogsRequest) ProtoReflect

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

func (*GetLogsRequest) Reset

func (x *GetLogsRequest) Reset()

func (*GetLogsRequest) String

func (x *GetLogsRequest) String() string

type GetWorkerStatsRequest

type GetWorkerStatsRequest struct {
	WorkerIds []int32 `protobuf:"varint,1,rep,packed,name=worker_ids,json=workerIds,proto3" json:"worker_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkerStatsRequest) Descriptor deprecated

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

Deprecated: Use GetWorkerStatsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkerStatsRequest) GetWorkerIds

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

func (*GetWorkerStatsRequest) ProtoMessage

func (*GetWorkerStatsRequest) ProtoMessage()

func (*GetWorkerStatsRequest) ProtoReflect

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

func (*GetWorkerStatsRequest) Reset

func (x *GetWorkerStatsRequest) Reset()

func (*GetWorkerStatsRequest) String

func (x *GetWorkerStatsRequest) String() string

type GetWorkerStatsResponse

type GetWorkerStatsResponse struct {
	WorkerStats map[int32]*WorkerStats `` /* 169-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetWorkerStatsResponse) Descriptor deprecated

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

Deprecated: Use GetWorkerStatsResponse.ProtoReflect.Descriptor instead.

func (*GetWorkerStatsResponse) GetWorkerStats

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

func (*GetWorkerStatsResponse) ProtoMessage

func (*GetWorkerStatsResponse) ProtoMessage()

func (*GetWorkerStatsResponse) ProtoReflect

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

func (*GetWorkerStatsResponse) Reset

func (x *GetWorkerStatsResponse) Reset()

func (*GetWorkerStatsResponse) String

func (x *GetWorkerStatsResponse) String() string

type Int32List added in v0.8.7

type Int32List struct {
	Values []int32 `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Int32List mirrors StringList for `repeated int32`. Same absent/present-empty/present-non-empty semantics — used for EditAndRetryTask.depends so we can distinguish "don't touch the dependency list" (absent) from "wipe all dependencies" (present-empty) from "replace with these task ids" (present-non-empty).

func (*Int32List) Descriptor deprecated added in v0.8.7

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

Deprecated: Use Int32List.ProtoReflect.Descriptor instead.

func (*Int32List) GetValues added in v0.8.7

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

func (*Int32List) ProtoMessage added in v0.8.7

func (*Int32List) ProtoMessage()

func (*Int32List) ProtoReflect added in v0.8.7

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

func (*Int32List) Reset added in v0.8.7

func (x *Int32List) Reset()

func (*Int32List) String added in v0.8.7

func (x *Int32List) String() string

type Job

type Job struct {
	JobId       int32   `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Status      string  `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	FlavorId    int32   `protobuf:"varint,3,opt,name=flavor_id,json=flavorId,proto3" json:"flavor_id,omitempty"`
	Retry       int32   `protobuf:"varint,4,opt,name=retry,proto3" json:"retry,omitempty"`
	WorkerId    int32   `protobuf:"varint,5,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Action      string  `protobuf:"bytes,6,opt,name=action,proto3" json:"action,omitempty"`
	CreatedAt   string  `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ModifiedAt  string  `protobuf:"bytes,8,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
	Progression int32   `protobuf:"varint,9,opt,name=progression,proto3" json:"progression,omitempty"`
	Log         string  `protobuf:"bytes,10,opt,name=log,proto3" json:"log,omitempty"`
	WorkerName  *string `protobuf:"bytes,11,opt,name=worker_name,json=workerName,proto3,oneof" json:"worker_name,omitempty"`
	FlavorInfo  *string `protobuf:"bytes,12,opt,name=flavor_info,json=flavorInfo,proto3,oneof" json:"flavor_info,omitempty"` // e.g. "Standard_D8s_v3 — 8 CPU, 32GB mem"
	// Provider-error category. Set on F-status jobs by classifyProviderError.
	// One of: "auth", "quota", "capacity", "unsupported_flavor",
	// "transient", "unknown". Empty/absent for non-failed jobs.
	// See specs / 2026-05-05 incident.
	ErrorClass   *string `protobuf:"bytes,13,opt,name=error_class,json=errorClass,proto3,oneof" json:"error_class,omitempty"`
	ErrorMessage *string `protobuf:"bytes,14,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"` // raw provider error text
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetAction

func (x *Job) GetAction() string

func (*Job) GetCreatedAt

func (x *Job) GetCreatedAt() string

func (*Job) GetErrorClass added in v0.8.1

func (x *Job) GetErrorClass() string

func (*Job) GetErrorMessage added in v0.8.1

func (x *Job) GetErrorMessage() string

func (*Job) GetFlavorId

func (x *Job) GetFlavorId() int32

func (*Job) GetFlavorInfo added in v0.7.2

func (x *Job) GetFlavorInfo() string

func (*Job) GetJobId

func (x *Job) GetJobId() int32

func (*Job) GetLog

func (x *Job) GetLog() string

func (*Job) GetModifiedAt

func (x *Job) GetModifiedAt() string

func (*Job) GetProgression

func (x *Job) GetProgression() int32

func (*Job) GetRetry

func (x *Job) GetRetry() int32

func (*Job) GetStatus

func (x *Job) GetStatus() string

func (*Job) GetWorkerId

func (x *Job) GetWorkerId() int32

func (*Job) GetWorkerName added in v0.7.2

func (x *Job) GetWorkerName() string

func (*Job) ProtoMessage

func (*Job) ProtoMessage()

func (*Job) ProtoReflect

func (x *Job) ProtoReflect() protoreflect.Message

func (*Job) Reset

func (x *Job) Reset()

func (*Job) String

func (x *Job) String() string

type JobId

type JobId struct {
	JobId int32 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*JobId) Descriptor deprecated

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

Deprecated: Use JobId.ProtoReflect.Descriptor instead.

func (*JobId) GetJobId

func (x *JobId) GetJobId() int32

func (*JobId) ProtoMessage

func (*JobId) ProtoMessage()

func (*JobId) ProtoReflect

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

func (*JobId) Reset

func (x *JobId) Reset()

func (*JobId) String

func (x *JobId) String() string

type JobStatus

type JobStatus struct {
	JobId       int32  `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Status      string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Progression int32  `protobuf:"varint,3,opt,name=progression,proto3" json:"progression,omitempty"`
	// contains filtered or unexported fields
}

func (*JobStatus) Descriptor deprecated

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

Deprecated: Use JobStatus.ProtoReflect.Descriptor instead.

func (*JobStatus) GetJobId

func (x *JobStatus) GetJobId() int32

func (*JobStatus) GetProgression

func (x *JobStatus) GetProgression() int32

func (*JobStatus) GetStatus

func (x *JobStatus) GetStatus() string

func (*JobStatus) ProtoMessage

func (*JobStatus) ProtoMessage()

func (*JobStatus) ProtoReflect

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

func (*JobStatus) Reset

func (x *JobStatus) Reset()

func (*JobStatus) String

func (x *JobStatus) String() string

type JobStatusRequest

type JobStatusRequest struct {
	JobIds []int32 `protobuf:"varint,1,rep,packed,name=job_ids,json=jobIds,proto3" json:"job_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*JobStatusRequest) Descriptor deprecated

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

Deprecated: Use JobStatusRequest.ProtoReflect.Descriptor instead.

func (*JobStatusRequest) GetJobIds

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

func (*JobStatusRequest) ProtoMessage

func (*JobStatusRequest) ProtoMessage()

func (*JobStatusRequest) ProtoReflect

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

func (*JobStatusRequest) Reset

func (x *JobStatusRequest) Reset()

func (*JobStatusRequest) String

func (x *JobStatusRequest) String() string

type JobStatusResponse

type JobStatusResponse struct {
	Statuses []*JobStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*JobStatusResponse) Descriptor deprecated

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

Deprecated: Use JobStatusResponse.ProtoReflect.Descriptor instead.

func (*JobStatusResponse) GetStatuses

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

func (*JobStatusResponse) ProtoMessage

func (*JobStatusResponse) ProtoMessage()

func (*JobStatusResponse) ProtoReflect

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

func (*JobStatusResponse) Reset

func (x *JobStatusResponse) Reset()

func (*JobStatusResponse) String

func (x *JobStatusResponse) String() string

type JobUpdate

type JobUpdate struct {
	JobId       int32   `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`                  // which job to update
	Status      *string `protobuf:"bytes,2,opt,name=status,proto3,oneof" json:"status,omitempty"`                        // 'P'|'R'|'S'|'F'|'X' (only if you want to set it)
	AppendLog   *string `protobuf:"bytes,3,opt,name=append_log,json=appendLog,proto3,oneof" json:"append_log,omitempty"` // text appended to job.log (server prepends timestamp)
	Progression *int32  `protobuf:"varint,4,opt,name=progression,proto3,oneof" json:"progression,omitempty"`             // 0..100 (server clamps)
	// contains filtered or unexported fields
}

func (*JobUpdate) Descriptor deprecated

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

Deprecated: Use JobUpdate.ProtoReflect.Descriptor instead.

func (*JobUpdate) GetAppendLog

func (x *JobUpdate) GetAppendLog() string

func (*JobUpdate) GetJobId

func (x *JobUpdate) GetJobId() int32

func (*JobUpdate) GetProgression

func (x *JobUpdate) GetProgression() int32

func (*JobUpdate) GetStatus

func (x *JobUpdate) GetStatus() string

func (*JobUpdate) ProtoMessage

func (*JobUpdate) ProtoMessage()

func (*JobUpdate) ProtoReflect

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

func (*JobUpdate) Reset

func (x *JobUpdate) Reset()

func (*JobUpdate) String

func (x *JobUpdate) String() string

type JobsList

type JobsList struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*JobsList) Descriptor deprecated

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

Deprecated: Use JobsList.ProtoReflect.Descriptor instead.

func (*JobsList) GetJobs

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

func (*JobsList) ProtoMessage

func (*JobsList) ProtoMessage()

func (*JobsList) ProtoReflect

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

func (*JobsList) Reset

func (x *JobsList) Reset()

func (*JobsList) String

func (x *JobsList) String() string

type ListChainEntriesRequest added in v0.8.5

type ListChainEntriesRequest struct {

	// Filter by parent workflow. If unset, returns entries across all
	// workflows the caller can see (useful with status_filter).
	ParentWorkflowId *int32 `protobuf:"varint,1,opt,name=parent_workflow_id,json=parentWorkflowId,proto3,oneof" json:"parent_workflow_id,omitempty"`
	// Filter by lifecycle status (e.g. "pending", "suspended").
	StatusFilter *string `protobuf:"bytes,2,opt,name=status_filter,json=statusFilter,proto3,oneof" json:"status_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListChainEntriesRequest) Descriptor deprecated added in v0.8.5

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

Deprecated: Use ListChainEntriesRequest.ProtoReflect.Descriptor instead.

func (*ListChainEntriesRequest) GetParentWorkflowId added in v0.8.5

func (x *ListChainEntriesRequest) GetParentWorkflowId() int32

func (*ListChainEntriesRequest) GetStatusFilter added in v0.8.5

func (x *ListChainEntriesRequest) GetStatusFilter() string

func (*ListChainEntriesRequest) ProtoMessage added in v0.8.5

func (*ListChainEntriesRequest) ProtoMessage()

func (*ListChainEntriesRequest) ProtoReflect added in v0.8.5

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

func (*ListChainEntriesRequest) Reset added in v0.8.5

func (x *ListChainEntriesRequest) Reset()

func (*ListChainEntriesRequest) String added in v0.8.5

func (x *ListChainEntriesRequest) String() string

type ListFlavorsRequest

type ListFlavorsRequest struct {
	Limit  int32  `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFlavorsRequest) Descriptor deprecated

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

Deprecated: Use ListFlavorsRequest.ProtoReflect.Descriptor instead.

func (*ListFlavorsRequest) GetFilter

func (x *ListFlavorsRequest) GetFilter() string

func (*ListFlavorsRequest) GetLimit

func (x *ListFlavorsRequest) GetLimit() int32

func (*ListFlavorsRequest) ProtoMessage

func (*ListFlavorsRequest) ProtoMessage()

func (*ListFlavorsRequest) ProtoReflect

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

func (*ListFlavorsRequest) Reset

func (x *ListFlavorsRequest) Reset()

func (*ListFlavorsRequest) String

func (x *ListFlavorsRequest) String() string

type ListJobsRequest

type ListJobsRequest struct {
	Limit  *int32 `protobuf:"varint,1,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	Offset *int32 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsRequest) Descriptor deprecated

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

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) GetLimit

func (x *ListJobsRequest) GetLimit() int32

func (*ListJobsRequest) GetOffset

func (x *ListJobsRequest) GetOffset() int32

func (*ListJobsRequest) ProtoMessage

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect

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

func (*ListJobsRequest) Reset

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String

func (x *ListJobsRequest) String() string

type ListTasksRequest

type ListTasksRequest struct {
	StatusFilter     *string `protobuf:"bytes,1,opt,name=status_filter,json=statusFilter,proto3,oneof" json:"status_filter,omitempty"`
	WorkerIdFilter   *int32  `protobuf:"varint,2,opt,name=worker_id_filter,json=workerIdFilter,proto3,oneof" json:"worker_id_filter,omitempty"`
	WorkflowIdFilter *int32  `protobuf:"varint,3,opt,name=workflow_id_filter,json=workflowIdFilter,proto3,oneof" json:"workflow_id_filter,omitempty"`
	StepIdFilter     *int32  `protobuf:"varint,4,opt,name=step_id_filter,json=stepIdFilter,proto3,oneof" json:"step_id_filter,omitempty"`
	CommandFilter    *string `protobuf:"bytes,5,opt,name=command_filter,json=commandFilter,proto3,oneof" json:"command_filter,omitempty"`
	Limit            *int32  `protobuf:"varint,6,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	Offset           *int32  `protobuf:"varint,7,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	ShowHidden       *bool   `protobuf:"varint,8,opt,name=show_hidden,json=showHidden,proto3,oneof" json:"show_hidden,omitempty"`
	// When true, the server clips Task.command to compact_command_max
	// characters (default 200) before returning. Used by the basic
	// `scitq task list` view so a kilobyte-scale shell script doesn't
	// get shipped over gRPC just to be truncated client-side. The full
	// command is still available via `task list -l/--long` (which omits
	// this flag).
	CompactCommand    *bool  `protobuf:"varint,9,opt,name=compact_command,json=compactCommand,proto3,oneof" json:"compact_command,omitempty"`
	CompactCommandMax *int32 `protobuf:"varint,10,opt,name=compact_command_max,json=compactCommandMax,proto3,oneof" json:"compact_command_max,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) Descriptor deprecated

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

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetCommandFilter

func (x *ListTasksRequest) GetCommandFilter() string

func (*ListTasksRequest) GetCompactCommand added in v0.7.7

func (x *ListTasksRequest) GetCompactCommand() bool

func (*ListTasksRequest) GetCompactCommandMax added in v0.7.7

func (x *ListTasksRequest) GetCompactCommandMax() int32

func (*ListTasksRequest) GetLimit

func (x *ListTasksRequest) GetLimit() int32

func (*ListTasksRequest) GetOffset

func (x *ListTasksRequest) GetOffset() int32

func (*ListTasksRequest) GetShowHidden

func (x *ListTasksRequest) GetShowHidden() bool

func (*ListTasksRequest) GetStatusFilter

func (x *ListTasksRequest) GetStatusFilter() string

func (*ListTasksRequest) GetStepIdFilter

func (x *ListTasksRequest) GetStepIdFilter() int32

func (*ListTasksRequest) GetWorkerIdFilter

func (x *ListTasksRequest) GetWorkerIdFilter() int32

func (*ListTasksRequest) GetWorkflowIdFilter

func (x *ListTasksRequest) GetWorkflowIdFilter() int32

func (*ListTasksRequest) ProtoMessage

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect

func (x *ListTasksRequest) ProtoReflect() protoreflect.Message

func (*ListTasksRequest) Reset

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String

func (x *ListTasksRequest) String() string

type ListWorkersRequest

type ListWorkersRequest struct {
	WorkflowId *int32 `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkersRequest) Descriptor deprecated

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

Deprecated: Use ListWorkersRequest.ProtoReflect.Descriptor instead.

func (*ListWorkersRequest) GetWorkflowId

func (x *ListWorkersRequest) GetWorkflowId() int32

func (*ListWorkersRequest) ProtoMessage

func (*ListWorkersRequest) ProtoMessage()

func (*ListWorkersRequest) ProtoReflect

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

func (*ListWorkersRequest) Reset

func (x *ListWorkersRequest) Reset()

func (*ListWorkersRequest) String

func (x *ListWorkersRequest) String() string

type LogChunk

type LogChunk struct {
	TaskId int32    `protobuf:"varint,1,opt,name=taskId,proto3" json:"taskId,omitempty"`
	Stdout []string `protobuf:"bytes,2,rep,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr []string `protobuf:"bytes,3,rep,name=stderr,proto3" json:"stderr,omitempty"`
	// contains filtered or unexported fields
}

func (*LogChunk) Descriptor deprecated

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

Deprecated: Use LogChunk.ProtoReflect.Descriptor instead.

func (*LogChunk) GetStderr

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

func (*LogChunk) GetStdout

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

func (*LogChunk) GetTaskId

func (x *LogChunk) GetTaskId() int32

func (*LogChunk) ProtoMessage

func (*LogChunk) ProtoMessage()

func (*LogChunk) ProtoReflect

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

func (*LogChunk) Reset

func (x *LogChunk) Reset()

func (*LogChunk) String

func (x *LogChunk) String() string

type LogChunkList

type LogChunkList struct {
	Logs []*LogChunk `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*LogChunkList) Descriptor deprecated

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

Deprecated: Use LogChunkList.ProtoReflect.Descriptor instead.

func (*LogChunkList) GetLogs

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

func (*LogChunkList) ProtoMessage

func (*LogChunkList) ProtoMessage()

func (*LogChunkList) ProtoReflect

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

func (*LogChunkList) Reset

func (x *LogChunkList) Reset()

func (*LogChunkList) String

func (x *LogChunkList) String() string

type LoginRequest

type LoginRequest struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginRequest) Descriptor deprecated

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

Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.

func (*LoginRequest) GetPassword

func (x *LoginRequest) GetPassword() string

func (*LoginRequest) GetUsername

func (x *LoginRequest) GetUsername() string

func (*LoginRequest) ProtoMessage

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) ProtoReflect

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

func (*LoginRequest) Reset

func (x *LoginRequest) Reset()

func (*LoginRequest) String

func (x *LoginRequest) String() string

type LoginResponse

type LoginResponse struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginResponse) Descriptor deprecated

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

Deprecated: Use LoginResponse.ProtoReflect.Descriptor instead.

func (*LoginResponse) GetToken

func (x *LoginResponse) GetToken() string

func (*LoginResponse) ProtoMessage

func (*LoginResponse) ProtoMessage()

func (*LoginResponse) ProtoReflect

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

func (*LoginResponse) Reset

func (x *LoginResponse) Reset()

func (*LoginResponse) String

func (x *LoginResponse) String() string

type ModuleEntry added in v0.7.5

type ModuleEntry struct {
	Path        string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Version     string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Origin      string `protobuf:"bytes,3,opt,name=origin,proto3" json:"origin,omitempty"` // "bundled" | "local" | "forked"
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleEntry) Descriptor deprecated added in v0.7.5

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

Deprecated: Use ModuleEntry.ProtoReflect.Descriptor instead.

func (*ModuleEntry) GetDescription added in v0.7.5

func (x *ModuleEntry) GetDescription() string

func (*ModuleEntry) GetOrigin added in v0.7.5

func (x *ModuleEntry) GetOrigin() string

func (*ModuleEntry) GetPath added in v0.7.5

func (x *ModuleEntry) GetPath() string

func (*ModuleEntry) GetVersion added in v0.7.5

func (x *ModuleEntry) GetVersion() string

func (*ModuleEntry) ProtoMessage added in v0.7.5

func (*ModuleEntry) ProtoMessage()

func (*ModuleEntry) ProtoReflect added in v0.7.5

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

func (*ModuleEntry) Reset added in v0.7.5

func (x *ModuleEntry) Reset()

func (*ModuleEntry) String added in v0.7.5

func (x *ModuleEntry) String() string

type ModuleList added in v0.7.1

type ModuleList struct {

	// Flat list of `path@version` strings. Kept for backward compatibility.
	Modules []string `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"`
	// Structured view — populated by newer callers. Old callers can ignore it.
	Entries []*ModuleEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleList) Descriptor deprecated added in v0.7.1

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

Deprecated: Use ModuleList.ProtoReflect.Descriptor instead.

func (*ModuleList) GetEntries added in v0.7.5

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

func (*ModuleList) GetModules added in v0.7.1

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

func (*ModuleList) ProtoMessage added in v0.7.1

func (*ModuleList) ProtoMessage()

func (*ModuleList) ProtoReflect added in v0.7.1

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

func (*ModuleList) Reset added in v0.7.1

func (x *ModuleList) Reset()

func (*ModuleList) String added in v0.7.1

func (x *ModuleList) String() string

type ModuleListFilter added in v0.7.5

type ModuleListFilter struct {

	// Restrict results to one module path (e.g. 'genomics/fastp') — returns
	// every version at that path. Matches the `scitq module list
	// --versions X` use case.
	Path *string `protobuf:"bytes,1,opt,name=path,proto3,oneof" json:"path,omitempty"`
	// If true, return only the highest-ordered version per path.
	LatestOnly *bool `protobuf:"varint,2,opt,name=latest_only,json=latestOnly,proto3,oneof" json:"latest_only,omitempty"`
	// Origin filter — case-insensitive, accepts full word ('bundled',
	// 'local', 'forked') or single letter ('B', 'L', 'F'). Matches the
	// `scitq module list --origin X` use case, typically used to audit
	// pre-library files that were auto-imported as origin=local at server
	// startup.
	Origin *string `protobuf:"bytes,3,opt,name=origin,proto3,oneof" json:"origin,omitempty"`
	// If true, return only modules where a local upload (origin='L')
	// diverges from a bundled module at the same path/version. The auto-
	// upgrade pass records bundled_sha on L rows that collide with a
	// bundled entry; this filter is a pure DB query against that column.
	// Identical-byte L copies are auto-promoted to 'B' on server start,
	// so they never appear here. Matches `scitq module conflicts`.
	ConflictsOnly *bool `protobuf:"varint,4,opt,name=conflicts_only,json=conflictsOnly,proto3,oneof" json:"conflicts_only,omitempty"`
	// contains filtered or unexported fields
}

Filter for ListModulesFiltered. All fields optional: an empty request returns the same data as `ListModules` (all rows).

func (*ModuleListFilter) Descriptor deprecated added in v0.7.5

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

Deprecated: Use ModuleListFilter.ProtoReflect.Descriptor instead.

func (*ModuleListFilter) GetConflictsOnly added in v0.8.5

func (x *ModuleListFilter) GetConflictsOnly() bool

func (*ModuleListFilter) GetLatestOnly added in v0.7.5

func (x *ModuleListFilter) GetLatestOnly() bool

func (*ModuleListFilter) GetOrigin added in v0.7.5

func (x *ModuleListFilter) GetOrigin() string

func (*ModuleListFilter) GetPath added in v0.7.5

func (x *ModuleListFilter) GetPath() string

func (*ModuleListFilter) ProtoMessage added in v0.7.5

func (*ModuleListFilter) ProtoMessage()

func (*ModuleListFilter) ProtoReflect added in v0.7.5

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

func (*ModuleListFilter) Reset added in v0.7.5

func (x *ModuleListFilter) Reset()

func (*ModuleListFilter) String added in v0.7.5

func (x *ModuleListFilter) String() string

type ModuleOriginRequest added in v0.7.5

type ModuleOriginRequest struct {
	Path    string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

Single-row origin lookup. `version` is optional — empty means "latest".

func (*ModuleOriginRequest) Descriptor deprecated added in v0.7.5

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

Deprecated: Use ModuleOriginRequest.ProtoReflect.Descriptor instead.

func (*ModuleOriginRequest) GetPath added in v0.7.5

func (x *ModuleOriginRequest) GetPath() string

func (*ModuleOriginRequest) GetVersion added in v0.7.5

func (x *ModuleOriginRequest) GetVersion() string

func (*ModuleOriginRequest) ProtoMessage added in v0.7.5

func (*ModuleOriginRequest) ProtoMessage()

func (*ModuleOriginRequest) ProtoReflect added in v0.7.5

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

func (*ModuleOriginRequest) Reset added in v0.7.5

func (x *ModuleOriginRequest) Reset()

func (*ModuleOriginRequest) String added in v0.7.5

func (x *ModuleOriginRequest) String() string

type ModuleOriginResponse added in v0.7.5

type ModuleOriginResponse struct {
	Path           string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Version        string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Origin         string `protobuf:"bytes,3,opt,name=origin,proto3" json:"origin,omitempty"` // "bundled" | "local" | "forked"
	ContentSha256  string `protobuf:"bytes,4,opt,name=content_sha256,json=contentSha256,proto3" json:"content_sha256,omitempty"`
	BundledSha256  string `protobuf:"bytes,5,opt,name=bundled_sha256,json=bundledSha256,proto3" json:"bundled_sha256,omitempty"` // set on forked rows; the pre-fork content hash
	Description    string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	UploadedAt     string `protobuf:"bytes,7,opt,name=uploaded_at,json=uploadedAt,proto3" json:"uploaded_at,omitempty"`                // RFC3339
	UploadedBy     string `protobuf:"bytes,8,opt,name=uploaded_by,json=uploadedBy,proto3" json:"uploaded_by,omitempty"`                // username, empty if unknown or system-seeded
	ForkIsOutdated bool   `protobuf:"varint,9,opt,name=fork_is_outdated,json=forkIsOutdated,proto3" json:"fork_is_outdated,omitempty"` // true if a newer bundled content at the same path has shipped since the fork
	// contains filtered or unexported fields
}

func (*ModuleOriginResponse) Descriptor deprecated added in v0.7.5

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

Deprecated: Use ModuleOriginResponse.ProtoReflect.Descriptor instead.

func (*ModuleOriginResponse) GetBundledSha256 added in v0.7.5

func (x *ModuleOriginResponse) GetBundledSha256() string

func (*ModuleOriginResponse) GetContentSha256 added in v0.7.5

func (x *ModuleOriginResponse) GetContentSha256() string

func (*ModuleOriginResponse) GetDescription added in v0.7.5

func (x *ModuleOriginResponse) GetDescription() string

func (*ModuleOriginResponse) GetForkIsOutdated added in v0.7.5

func (x *ModuleOriginResponse) GetForkIsOutdated() bool

func (*ModuleOriginResponse) GetOrigin added in v0.7.5

func (x *ModuleOriginResponse) GetOrigin() string

func (*ModuleOriginResponse) GetPath added in v0.7.5

func (x *ModuleOriginResponse) GetPath() string

func (*ModuleOriginResponse) GetUploadedAt added in v0.7.5

func (x *ModuleOriginResponse) GetUploadedAt() string

func (*ModuleOriginResponse) GetUploadedBy added in v0.7.5

func (x *ModuleOriginResponse) GetUploadedBy() string

func (*ModuleOriginResponse) GetVersion added in v0.7.5

func (x *ModuleOriginResponse) GetVersion() string

func (*ModuleOriginResponse) ProtoMessage added in v0.7.5

func (*ModuleOriginResponse) ProtoMessage()

func (*ModuleOriginResponse) ProtoReflect added in v0.7.5

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

func (*ModuleOriginResponse) Reset added in v0.7.5

func (x *ModuleOriginResponse) Reset()

func (*ModuleOriginResponse) String added in v0.7.5

func (x *ModuleOriginResponse) String() string

type NetIOStats

type NetIOStats struct {
	RecvBytesTotal int64   `protobuf:"varint,1,opt,name=recv_bytes_total,json=recvBytesTotal,proto3" json:"recv_bytes_total,omitempty"` // Total bytes received
	SentBytesTotal int64   `protobuf:"varint,2,opt,name=sent_bytes_total,json=sentBytesTotal,proto3" json:"sent_bytes_total,omitempty"` // Total bytes sent
	RecvBytesRate  float32 `protobuf:"fixed32,3,opt,name=recv_bytes_rate,json=recvBytesRate,proto3" json:"recv_bytes_rate,omitempty"`   // Bytes per second
	SentBytesRate  float32 `protobuf:"fixed32,4,opt,name=sent_bytes_rate,json=sentBytesRate,proto3" json:"sent_bytes_rate,omitempty"`   // Bytes per second
	// contains filtered or unexported fields
}

func (*NetIOStats) Descriptor deprecated

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

Deprecated: Use NetIOStats.ProtoReflect.Descriptor instead.

func (*NetIOStats) GetRecvBytesRate

func (x *NetIOStats) GetRecvBytesRate() float32

func (*NetIOStats) GetRecvBytesTotal

func (x *NetIOStats) GetRecvBytesTotal() int64

func (*NetIOStats) GetSentBytesRate

func (x *NetIOStats) GetSentBytesRate() float32

func (*NetIOStats) GetSentBytesTotal

func (x *NetIOStats) GetSentBytesTotal() int64

func (*NetIOStats) ProtoMessage

func (*NetIOStats) ProtoMessage()

func (*NetIOStats) ProtoReflect

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

func (*NetIOStats) Reset

func (x *NetIOStats) Reset()

func (*NetIOStats) String

func (x *NetIOStats) String() string

type PingAndGetNewTasksRequest

type PingAndGetNewTasksRequest struct {
	WorkerId int32        `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Stats    *WorkerStats `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"` // Optional
	// Task IDs the worker is currently tracking locally (its activeTasks set).
	// Used by the server to reconcile: a task the server believes is active on
	// this worker but that the worker no longer lists has been lost (e.g. the
	// worker finished + cleaned up but the terminal status update was lost).
	// reports_known_tasks gates this — proto3 can't tell an empty repeated
	// field from an absent one, so an old worker (which never sets the flag)
	// is never reconciled, avoiding mass-failing its tasks.
	KnownTaskIds      []int32 `protobuf:"varint,3,rep,packed,name=known_task_ids,json=knownTaskIds,proto3" json:"known_task_ids,omitempty"`
	ReportsKnownTasks bool    `protobuf:"varint,4,opt,name=reports_known_tasks,json=reportsKnownTasks,proto3" json:"reports_known_tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*PingAndGetNewTasksRequest) Descriptor deprecated

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

Deprecated: Use PingAndGetNewTasksRequest.ProtoReflect.Descriptor instead.

func (*PingAndGetNewTasksRequest) GetKnownTaskIds added in v0.8.5

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

func (*PingAndGetNewTasksRequest) GetReportsKnownTasks added in v0.8.5

func (x *PingAndGetNewTasksRequest) GetReportsKnownTasks() bool

func (*PingAndGetNewTasksRequest) GetStats

func (x *PingAndGetNewTasksRequest) GetStats() *WorkerStats

func (*PingAndGetNewTasksRequest) GetWorkerId

func (x *PingAndGetNewTasksRequest) GetWorkerId() int32

func (*PingAndGetNewTasksRequest) ProtoMessage

func (*PingAndGetNewTasksRequest) ProtoMessage()

func (*PingAndGetNewTasksRequest) ProtoReflect

func (*PingAndGetNewTasksRequest) Reset

func (x *PingAndGetNewTasksRequest) Reset()

func (*PingAndGetNewTasksRequest) String

func (x *PingAndGetNewTasksRequest) String() string

type Provider

type Provider struct {
	ProviderId   int32  `protobuf:"varint,1,opt,name=provider_id,json=providerId,proto3" json:"provider_id,omitempty"`
	ProviderName string `protobuf:"bytes,2,opt,name=provider_name,json=providerName,proto3" json:"provider_name,omitempty"`
	ConfigName   string `protobuf:"bytes,3,opt,name=config_name,json=configName,proto3" json:"config_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Provider) Descriptor deprecated

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

Deprecated: Use Provider.ProtoReflect.Descriptor instead.

func (*Provider) GetConfigName

func (x *Provider) GetConfigName() string

func (*Provider) GetProviderId

func (x *Provider) GetProviderId() int32

func (*Provider) GetProviderName

func (x *Provider) GetProviderName() string

func (*Provider) ProtoMessage

func (*Provider) ProtoMessage()

func (*Provider) ProtoReflect

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

func (*Provider) Reset

func (x *Provider) Reset()

func (*Provider) String

func (x *Provider) String() string

type ProviderList

type ProviderList struct {
	Providers []*Provider `protobuf:"bytes,1,rep,name=providers,proto3" json:"providers,omitempty"`
	// contains filtered or unexported fields
}

func (*ProviderList) Descriptor deprecated

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

Deprecated: Use ProviderList.ProtoReflect.Descriptor instead.

func (*ProviderList) GetProviders

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

func (*ProviderList) ProtoMessage

func (*ProviderList) ProtoMessage()

func (*ProviderList) ProtoReflect

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

func (*ProviderList) Reset

func (x *ProviderList) Reset()

func (*ProviderList) String

func (x *ProviderList) String() string

type RcloneRemote

type RcloneRemote struct {
	Options map[string]string `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RcloneRemote) Descriptor deprecated

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

Deprecated: Use RcloneRemote.ProtoReflect.Descriptor instead.

func (*RcloneRemote) GetOptions

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

func (*RcloneRemote) ProtoMessage

func (*RcloneRemote) ProtoMessage()

func (*RcloneRemote) ProtoReflect

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

func (*RcloneRemote) Reset

func (x *RcloneRemote) Reset()

func (*RcloneRemote) String

func (x *RcloneRemote) String() string

type RcloneRemotes

type RcloneRemotes struct {
	Remotes map[string]*RcloneRemote `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RcloneRemotes) Descriptor deprecated

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

Deprecated: Use RcloneRemotes.ProtoReflect.Descriptor instead.

func (*RcloneRemotes) GetRemotes

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

func (*RcloneRemotes) ProtoMessage

func (*RcloneRemotes) ProtoMessage()

func (*RcloneRemotes) ProtoReflect

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

func (*RcloneRemotes) Reset

func (x *RcloneRemotes) Reset()

func (*RcloneRemotes) String

func (x *RcloneRemotes) String() string

type Recruiter

type Recruiter struct {
	StepId          int32    `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	Rank            int32    `protobuf:"varint,2,opt,name=rank,proto3" json:"rank,omitempty"`
	Protofilter     string   `protobuf:"bytes,3,opt,name=protofilter,proto3" json:"protofilter,omitempty"`
	Concurrency     *int32   `protobuf:"varint,4,opt,name=concurrency,proto3,oneof" json:"concurrency,omitempty"`
	Prefetch        *int32   `protobuf:"varint,5,opt,name=prefetch,proto3,oneof" json:"prefetch,omitempty"`
	MaxWorkers      *int32   `protobuf:"varint,6,opt,name=max_workers,json=maxWorkers,proto3,oneof" json:"max_workers,omitempty"`
	Rounds          int32    `protobuf:"varint,7,opt,name=rounds,proto3" json:"rounds,omitempty"`
	Timeout         int32    `protobuf:"varint,8,opt,name=timeout,proto3" json:"timeout,omitempty"`
	CpuPerTask      *int32   `protobuf:"varint,9,opt,name=cpu_per_task,json=cpuPerTask,proto3,oneof" json:"cpu_per_task,omitempty"`
	MemoryPerTask   *float32 `protobuf:"fixed32,10,opt,name=memory_per_task,json=memoryPerTask,proto3,oneof" json:"memory_per_task,omitempty"`
	DiskPerTask     *float32 `protobuf:"fixed32,11,opt,name=disk_per_task,json=diskPerTask,proto3,oneof" json:"disk_per_task,omitempty"`
	PrefetchPercent *int32   `protobuf:"varint,12,opt,name=prefetch_percent,json=prefetchPercent,proto3,oneof" json:"prefetch_percent,omitempty"`
	ConcurrencyMin  *int32   `protobuf:"varint,13,opt,name=concurrency_min,json=concurrencyMin,proto3,oneof" json:"concurrency_min,omitempty"`
	ConcurrencyMax  *int32   `protobuf:"varint,14,opt,name=concurrency_max,json=concurrencyMax,proto3,oneof" json:"concurrency_max,omitempty"`
	// contains filtered or unexported fields
}

func (*Recruiter) Descriptor deprecated

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

Deprecated: Use Recruiter.ProtoReflect.Descriptor instead.

func (*Recruiter) GetConcurrency

func (x *Recruiter) GetConcurrency() int32

func (*Recruiter) GetConcurrencyMax

func (x *Recruiter) GetConcurrencyMax() int32

func (*Recruiter) GetConcurrencyMin

func (x *Recruiter) GetConcurrencyMin() int32

func (*Recruiter) GetCpuPerTask

func (x *Recruiter) GetCpuPerTask() int32

func (*Recruiter) GetDiskPerTask

func (x *Recruiter) GetDiskPerTask() float32

func (*Recruiter) GetMaxWorkers

func (x *Recruiter) GetMaxWorkers() int32

func (*Recruiter) GetMemoryPerTask

func (x *Recruiter) GetMemoryPerTask() float32

func (*Recruiter) GetPrefetch

func (x *Recruiter) GetPrefetch() int32

func (*Recruiter) GetPrefetchPercent

func (x *Recruiter) GetPrefetchPercent() int32

func (*Recruiter) GetProtofilter

func (x *Recruiter) GetProtofilter() string

func (*Recruiter) GetRank

func (x *Recruiter) GetRank() int32

func (*Recruiter) GetRounds

func (x *Recruiter) GetRounds() int32

func (*Recruiter) GetStepId

func (x *Recruiter) GetStepId() int32

func (*Recruiter) GetTimeout

func (x *Recruiter) GetTimeout() int32

func (*Recruiter) ProtoMessage

func (*Recruiter) ProtoMessage()

func (*Recruiter) ProtoReflect

func (x *Recruiter) ProtoReflect() protoreflect.Message

func (*Recruiter) Reset

func (x *Recruiter) Reset()

func (*Recruiter) String

func (x *Recruiter) String() string

type RecruiterFilter

type RecruiterFilter struct {
	StepId *int32 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RecruiterFilter) Descriptor deprecated

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

Deprecated: Use RecruiterFilter.ProtoReflect.Descriptor instead.

func (*RecruiterFilter) GetStepId

func (x *RecruiterFilter) GetStepId() int32

func (*RecruiterFilter) ProtoMessage

func (*RecruiterFilter) ProtoMessage()

func (*RecruiterFilter) ProtoReflect

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

func (*RecruiterFilter) Reset

func (x *RecruiterFilter) Reset()

func (*RecruiterFilter) String

func (x *RecruiterFilter) String() string

type RecruiterId

type RecruiterId struct {
	StepId int32 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	Rank   int32 `protobuf:"varint,2,opt,name=rank,proto3" json:"rank,omitempty"`
	// contains filtered or unexported fields
}

func (*RecruiterId) Descriptor deprecated

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

Deprecated: Use RecruiterId.ProtoReflect.Descriptor instead.

func (*RecruiterId) GetRank

func (x *RecruiterId) GetRank() int32

func (*RecruiterId) GetStepId

func (x *RecruiterId) GetStepId() int32

func (*RecruiterId) ProtoMessage

func (*RecruiterId) ProtoMessage()

func (*RecruiterId) ProtoReflect

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

func (*RecruiterId) Reset

func (x *RecruiterId) Reset()

func (*RecruiterId) String

func (x *RecruiterId) String() string

type RecruiterList

type RecruiterList struct {
	Recruiters []*Recruiter `protobuf:"bytes,1,rep,name=recruiters,proto3" json:"recruiters,omitempty"`
	// contains filtered or unexported fields
}

func (*RecruiterList) Descriptor deprecated

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

Deprecated: Use RecruiterList.ProtoReflect.Descriptor instead.

func (*RecruiterList) GetRecruiters

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

func (*RecruiterList) ProtoMessage

func (*RecruiterList) ProtoMessage()

func (*RecruiterList) ProtoReflect

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

func (*RecruiterList) Reset

func (x *RecruiterList) Reset()

func (*RecruiterList) String

func (x *RecruiterList) String() string

type RecruiterUpdate

type RecruiterUpdate struct {
	StepId          int32    `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	Rank            int32    `protobuf:"varint,2,opt,name=rank,proto3" json:"rank,omitempty"`
	Protofilter     *string  `protobuf:"bytes,3,opt,name=protofilter,proto3,oneof" json:"protofilter,omitempty"`
	Concurrency     *int32   `protobuf:"varint,4,opt,name=concurrency,proto3,oneof" json:"concurrency,omitempty"`
	Prefetch        *int32   `protobuf:"varint,5,opt,name=prefetch,proto3,oneof" json:"prefetch,omitempty"`
	MaxWorkers      *int32   `protobuf:"varint,6,opt,name=max_workers,json=maxWorkers,proto3,oneof" json:"max_workers,omitempty"`
	Rounds          *int32   `protobuf:"varint,7,opt,name=rounds,proto3,oneof" json:"rounds,omitempty"`
	Timeout         *int32   `protobuf:"varint,8,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	CpuPerTask      *int32   `protobuf:"varint,9,opt,name=cpu_per_task,json=cpuPerTask,proto3,oneof" json:"cpu_per_task,omitempty"`
	MemoryPerTask   *float32 `protobuf:"fixed32,10,opt,name=memory_per_task,json=memoryPerTask,proto3,oneof" json:"memory_per_task,omitempty"`
	DiskPerTask     *float32 `protobuf:"fixed32,11,opt,name=disk_per_task,json=diskPerTask,proto3,oneof" json:"disk_per_task,omitempty"`
	PrefetchPercent *int32   `protobuf:"varint,12,opt,name=prefetch_percent,json=prefetchPercent,proto3,oneof" json:"prefetch_percent,omitempty"`
	ConcurrencyMin  *int32   `protobuf:"varint,13,opt,name=concurrency_min,json=concurrencyMin,proto3,oneof" json:"concurrency_min,omitempty"`
	ConcurrencyMax  *int32   `protobuf:"varint,14,opt,name=concurrency_max,json=concurrencyMax,proto3,oneof" json:"concurrency_max,omitempty"`
	// contains filtered or unexported fields
}

func (*RecruiterUpdate) Descriptor deprecated

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

Deprecated: Use RecruiterUpdate.ProtoReflect.Descriptor instead.

func (*RecruiterUpdate) GetConcurrency

func (x *RecruiterUpdate) GetConcurrency() int32

func (*RecruiterUpdate) GetConcurrencyMax

func (x *RecruiterUpdate) GetConcurrencyMax() int32

func (*RecruiterUpdate) GetConcurrencyMin

func (x *RecruiterUpdate) GetConcurrencyMin() int32

func (*RecruiterUpdate) GetCpuPerTask

func (x *RecruiterUpdate) GetCpuPerTask() int32

func (*RecruiterUpdate) GetDiskPerTask

func (x *RecruiterUpdate) GetDiskPerTask() float32

func (*RecruiterUpdate) GetMaxWorkers

func (x *RecruiterUpdate) GetMaxWorkers() int32

func (*RecruiterUpdate) GetMemoryPerTask

func (x *RecruiterUpdate) GetMemoryPerTask() float32

func (*RecruiterUpdate) GetPrefetch

func (x *RecruiterUpdate) GetPrefetch() int32

func (*RecruiterUpdate) GetPrefetchPercent

func (x *RecruiterUpdate) GetPrefetchPercent() int32

func (*RecruiterUpdate) GetProtofilter

func (x *RecruiterUpdate) GetProtofilter() string

func (*RecruiterUpdate) GetRank

func (x *RecruiterUpdate) GetRank() int32

func (*RecruiterUpdate) GetRounds

func (x *RecruiterUpdate) GetRounds() int32

func (*RecruiterUpdate) GetStepId

func (x *RecruiterUpdate) GetStepId() int32

func (*RecruiterUpdate) GetTimeout

func (x *RecruiterUpdate) GetTimeout() int32

func (*RecruiterUpdate) ProtoMessage

func (*RecruiterUpdate) ProtoMessage()

func (*RecruiterUpdate) ProtoReflect

func (x *RecruiterUpdate) ProtoReflect() protoreflect.Message

func (*RecruiterUpdate) Reset

func (x *RecruiterUpdate) Reset()

func (*RecruiterUpdate) String

func (x *RecruiterUpdate) String() string

type Region

type Region struct {
	RegionId   int32  `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	ProviderId int32  `protobuf:"varint,2,opt,name=provider_id,json=providerId,proto3" json:"provider_id,omitempty"`
	RegionName string `protobuf:"bytes,3,opt,name=region_name,json=regionName,proto3" json:"region_name,omitempty"`
	IsDefault  bool   `protobuf:"varint,4,opt,name=is_default,json=isDefault,proto3" json:"is_default,omitempty"`
	// contains filtered or unexported fields
}

func (*Region) Descriptor deprecated

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

Deprecated: Use Region.ProtoReflect.Descriptor instead.

func (*Region) GetIsDefault

func (x *Region) GetIsDefault() bool

func (*Region) GetProviderId

func (x *Region) GetProviderId() int32

func (*Region) GetRegionId

func (x *Region) GetRegionId() int32

func (*Region) GetRegionName

func (x *Region) GetRegionName() string

func (*Region) ProtoMessage

func (*Region) ProtoMessage()

func (*Region) ProtoReflect

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

func (*Region) Reset

func (x *Region) Reset()

func (*Region) String

func (x *Region) String() string

type RegionList

type RegionList struct {
	Regions []*Region `protobuf:"bytes,1,rep,name=regions,proto3" json:"regions,omitempty"`
	// contains filtered or unexported fields
}

func (*RegionList) Descriptor deprecated

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

Deprecated: Use RegionList.ProtoReflect.Descriptor instead.

func (*RegionList) GetRegions

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

func (*RegionList) ProtoMessage

func (*RegionList) ProtoMessage()

func (*RegionList) ProtoReflect

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

func (*RegionList) Reset

func (x *RegionList) Reset()

func (*RegionList) String

func (x *RegionList) String() string

type RegisterAdhocRunRequest added in v0.7.5

type RegisterAdhocRunRequest struct {
	ScriptName      string `protobuf:"bytes,1,opt,name=script_name,json=scriptName,proto3" json:"script_name,omitempty"`                  // bare filename of the launching script
	ScriptSha256    string `protobuf:"bytes,2,opt,name=script_sha256,json=scriptSha256,proto3" json:"script_sha256,omitempty"`            // SHA-256 of the script file's content (hex)
	ParamValuesJson string `protobuf:"bytes,3,opt,name=param_values_json,json=paramValuesJson,proto3" json:"param_values_json,omitempty"` // JSON snapshot of the params the user ran with
	// module_pins_json stores the Python versioning knobs — typically
	// {"scitq2":"0.7.4"} so replays can check compatibility against later
	// upgrades. Same column as YAML's per-module pins, different shape.
	ModulePinsJson string `protobuf:"bytes,4,opt,name=module_pins_json,json=modulePinsJson,proto3" json:"module_pins_json,omitempty"`
	// contains filtered or unexported fields
}

Ad-hoc (local Python) run registration — no uploaded template, just a script file with some params. The server stores it as a template_run with workflow_template_id=NULL.

func (*RegisterAdhocRunRequest) Descriptor deprecated added in v0.7.5

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

Deprecated: Use RegisterAdhocRunRequest.ProtoReflect.Descriptor instead.

func (*RegisterAdhocRunRequest) GetModulePinsJson added in v0.7.5

func (x *RegisterAdhocRunRequest) GetModulePinsJson() string

func (*RegisterAdhocRunRequest) GetParamValuesJson added in v0.7.5

func (x *RegisterAdhocRunRequest) GetParamValuesJson() string

func (*RegisterAdhocRunRequest) GetScriptName added in v0.7.5

func (x *RegisterAdhocRunRequest) GetScriptName() string

func (*RegisterAdhocRunRequest) GetScriptSha256 added in v0.7.5

func (x *RegisterAdhocRunRequest) GetScriptSha256() string

func (*RegisterAdhocRunRequest) ProtoMessage added in v0.7.5

func (*RegisterAdhocRunRequest) ProtoMessage()

func (*RegisterAdhocRunRequest) ProtoReflect added in v0.7.5

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

func (*RegisterAdhocRunRequest) Reset added in v0.7.5

func (x *RegisterAdhocRunRequest) Reset()

func (*RegisterAdhocRunRequest) String added in v0.7.5

func (x *RegisterAdhocRunRequest) String() string

type ResourceSpec

type ResourceSpec struct {
	WorkerId string  `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Cpu      int32   `protobuf:"varint,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Mem      float32 `protobuf:"fixed32,3,opt,name=mem,proto3" json:"mem,omitempty"`
	Disk     float32 `protobuf:"fixed32,4,opt,name=disk,proto3" json:"disk,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceSpec) Descriptor deprecated

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

Deprecated: Use ResourceSpec.ProtoReflect.Descriptor instead.

func (*ResourceSpec) GetCpu

func (x *ResourceSpec) GetCpu() int32

func (*ResourceSpec) GetDisk

func (x *ResourceSpec) GetDisk() float32

func (*ResourceSpec) GetMem

func (x *ResourceSpec) GetMem() float32

func (*ResourceSpec) GetWorkerId

func (x *ResourceSpec) GetWorkerId() string

func (*ResourceSpec) ProtoMessage

func (*ResourceSpec) ProtoMessage()

func (*ResourceSpec) ProtoReflect

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

func (*ResourceSpec) Reset

func (x *ResourceSpec) Reset()

func (*ResourceSpec) String

func (x *ResourceSpec) String() string

type RetryTaskRequest

type RetryTaskRequest struct {
	TaskId int32  `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Retry  *int32 `protobuf:"varint,2,opt,name=retry,proto3,oneof" json:"retry,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryTaskRequest) Descriptor deprecated

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

Deprecated: Use RetryTaskRequest.ProtoReflect.Descriptor instead.

func (*RetryTaskRequest) GetRetry

func (x *RetryTaskRequest) GetRetry() int32

func (*RetryTaskRequest) GetTaskId

func (x *RetryTaskRequest) GetTaskId() int32

func (*RetryTaskRequest) ProtoMessage

func (*RetryTaskRequest) ProtoMessage()

func (*RetryTaskRequest) ProtoReflect

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

func (*RetryTaskRequest) Reset

func (x *RetryTaskRequest) Reset()

func (*RetryTaskRequest) String

func (x *RetryTaskRequest) String() string

type RunTemplateRequest

type RunTemplateRequest struct {
	WorkflowTemplateId int32  `protobuf:"varint,1,opt,name=workflow_template_id,json=workflowTemplateId,proto3" json:"workflow_template_id,omitempty"`
	ParamValuesJson    string `protobuf:"bytes,2,opt,name=param_values_json,json=paramValuesJson,proto3" json:"param_values_json,omitempty"`
	NoRecruiters       bool   `protobuf:"varint,3,opt,name=no_recruiters,json=noRecruiters,proto3" json:"no_recruiters,omitempty"`
	// Extend an existing workflow instead of creating a new one. See
	// specs/workflow_extend.md. retry_failed_only narrows the reconcile to
	// re-running only the existing failed tasks (no cascade).
	ExtendWorkflowId *int32 `protobuf:"varint,4,opt,name=extend_workflow_id,json=extendWorkflowId,proto3,oneof" json:"extend_workflow_id,omitempty"`
	RetryFailedOnly  bool   `protobuf:"varint,5,opt,name=retry_failed_only,json=retryFailedOnly,proto3" json:"retry_failed_only,omitempty"`
	// continue_last resolves the workflow to extend automatically: the caller's
	// most recent run of the same template *name* (any version) with matching
	// params. The server fills extend_workflow_id from it. Mutually exclusive
	// with extend_workflow_id.
	ContinueLast bool `protobuf:"varint,6,opt,name=continue_last,json=continueLast,proto3" json:"continue_last,omitempty"`
	// contains filtered or unexported fields
}

func (*RunTemplateRequest) Descriptor deprecated

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

Deprecated: Use RunTemplateRequest.ProtoReflect.Descriptor instead.

func (*RunTemplateRequest) GetContinueLast added in v0.8.5

func (x *RunTemplateRequest) GetContinueLast() bool

func (*RunTemplateRequest) GetExtendWorkflowId added in v0.8.5

func (x *RunTemplateRequest) GetExtendWorkflowId() int32

func (*RunTemplateRequest) GetNoRecruiters added in v0.7.1

func (x *RunTemplateRequest) GetNoRecruiters() bool

func (*RunTemplateRequest) GetParamValuesJson

func (x *RunTemplateRequest) GetParamValuesJson() string

func (*RunTemplateRequest) GetRetryFailedOnly added in v0.8.5

func (x *RunTemplateRequest) GetRetryFailedOnly() bool

func (*RunTemplateRequest) GetWorkflowTemplateId

func (x *RunTemplateRequest) GetWorkflowTemplateId() int32

func (*RunTemplateRequest) ProtoMessage

func (*RunTemplateRequest) ProtoMessage()

func (*RunTemplateRequest) ProtoReflect

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

func (*RunTemplateRequest) Reset

func (x *RunTemplateRequest) Reset()

func (*RunTemplateRequest) String

func (x *RunTemplateRequest) String() string

type ServerVersionResponse added in v0.8.1

type ServerVersionResponse struct {
	Version   string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`                      // server semver+suffix
	Commit    string `protobuf:"bytes,2,opt,name=commit,proto3" json:"commit,omitempty"`                        // full git SHA
	BuildArch string `protobuf:"bytes,3,opt,name=build_arch,json=buildArch,proto3" json:"build_arch,omitempty"` // GOOS/GOARCH (informational)
	// contains filtered or unexported fields
}

func (*ServerVersionResponse) Descriptor deprecated added in v0.8.1

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

Deprecated: Use ServerVersionResponse.ProtoReflect.Descriptor instead.

func (*ServerVersionResponse) GetBuildArch added in v0.8.1

func (x *ServerVersionResponse) GetBuildArch() string

func (*ServerVersionResponse) GetCommit added in v0.8.1

func (x *ServerVersionResponse) GetCommit() string

func (*ServerVersionResponse) GetVersion added in v0.8.1

func (x *ServerVersionResponse) GetVersion() string

func (*ServerVersionResponse) ProtoMessage added in v0.8.1

func (*ServerVersionResponse) ProtoMessage()

func (*ServerVersionResponse) ProtoReflect added in v0.8.1

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

func (*ServerVersionResponse) Reset added in v0.8.1

func (x *ServerVersionResponse) Reset()

func (*ServerVersionResponse) String added in v0.8.1

func (x *ServerVersionResponse) String() string

type StatusCountEntry added in v0.6.1

type StatusCountEntry struct {
	Status   string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Count    int32  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	WorkerId *int32 `protobuf:"varint,3,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusCountEntry) Descriptor deprecated added in v0.6.1

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

Deprecated: Use StatusCountEntry.ProtoReflect.Descriptor instead.

func (*StatusCountEntry) GetCount added in v0.6.1

func (x *StatusCountEntry) GetCount() int32

func (*StatusCountEntry) GetStatus added in v0.6.1

func (x *StatusCountEntry) GetStatus() string

func (*StatusCountEntry) GetWorkerId added in v0.6.1

func (x *StatusCountEntry) GetWorkerId() int32

func (*StatusCountEntry) ProtoMessage added in v0.6.1

func (*StatusCountEntry) ProtoMessage()

func (*StatusCountEntry) ProtoReflect added in v0.6.1

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

func (*StatusCountEntry) Reset added in v0.6.1

func (x *StatusCountEntry) Reset()

func (*StatusCountEntry) String added in v0.6.1

func (x *StatusCountEntry) String() string

type Step

type Step struct {
	StepId            int32   `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	WorkflowName      string  `protobuf:"bytes,2,opt,name=workflow_name,json=workflowName,proto3" json:"workflow_name,omitempty"`
	WorkflowId        int32   `protobuf:"varint,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	Name              string  `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	QualityDefinition *string `protobuf:"bytes,5,opt,name=quality_definition,json=qualityDefinition,proto3,oneof" json:"quality_definition,omitempty"` // JSON: {"variables": {...}, "formula": "..."}
	// contains filtered or unexported fields
}

func (*Step) Descriptor deprecated

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

Deprecated: Use Step.ProtoReflect.Descriptor instead.

func (*Step) GetName

func (x *Step) GetName() string

func (*Step) GetQualityDefinition added in v0.7.2

func (x *Step) GetQualityDefinition() string

func (*Step) GetStepId

func (x *Step) GetStepId() int32

func (*Step) GetWorkflowId

func (x *Step) GetWorkflowId() int32

func (*Step) GetWorkflowName

func (x *Step) GetWorkflowName() string

func (*Step) ProtoMessage

func (*Step) ProtoMessage()

func (*Step) ProtoReflect

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

func (*Step) Reset

func (x *Step) Reset()

func (*Step) String

func (x *Step) String() string

type StepFilter

type StepFilter struct {
	WorkflowId int32  `protobuf:"varint,1,opt,name=WorkflowId,proto3" json:"WorkflowId,omitempty"`
	Limit      *int32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	Offset     *int32 `protobuf:"varint,3,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*StepFilter) Descriptor deprecated

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

Deprecated: Use StepFilter.ProtoReflect.Descriptor instead.

func (*StepFilter) GetLimit

func (x *StepFilter) GetLimit() int32

func (*StepFilter) GetOffset

func (x *StepFilter) GetOffset() int32

func (*StepFilter) GetWorkflowId

func (x *StepFilter) GetWorkflowId() int32

func (*StepFilter) ProtoMessage

func (*StepFilter) ProtoMessage()

func (*StepFilter) ProtoReflect

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

func (*StepFilter) Reset

func (x *StepFilter) Reset()

func (*StepFilter) String

func (x *StepFilter) String() string

type StepId

type StepId struct {
	StepId int32 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StepId) Descriptor deprecated

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

Deprecated: Use StepId.ProtoReflect.Descriptor instead.

func (*StepId) GetStepId

func (x *StepId) GetStepId() int32

func (*StepId) ProtoMessage

func (*StepId) ProtoMessage()

func (*StepId) ProtoReflect

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

func (*StepId) Reset

func (x *StepId) Reset()

func (*StepId) String

func (x *StepId) String() string

type StepList

type StepList struct {
	Steps []*Step `protobuf:"bytes,1,rep,name=steps,proto3" json:"steps,omitempty"`
	// contains filtered or unexported fields
}

func (*StepList) Descriptor deprecated

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

Deprecated: Use StepList.ProtoReflect.Descriptor instead.

func (*StepList) GetSteps

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

func (*StepList) ProtoMessage

func (*StepList) ProtoMessage()

func (*StepList) ProtoReflect

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

func (*StepList) Reset

func (x *StepList) Reset()

func (*StepList) String

func (x *StepList) String() string

type StepRequest

type StepRequest struct {
	WorkflowName      *string `protobuf:"bytes,1,opt,name=workflow_name,json=workflowName,proto3,oneof" json:"workflow_name,omitempty"`
	WorkflowId        *int32  `protobuf:"varint,2,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
	Name              string  `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	QualityDefinition *string `protobuf:"bytes,4,opt,name=quality_definition,json=qualityDefinition,proto3,oneof" json:"quality_definition,omitempty"` // JSON: {"variables": {...}, "formula": "..."}
	// contains filtered or unexported fields
}

func (*StepRequest) Descriptor deprecated

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

Deprecated: Use StepRequest.ProtoReflect.Descriptor instead.

func (*StepRequest) GetName

func (x *StepRequest) GetName() string

func (*StepRequest) GetQualityDefinition added in v0.7.2

func (x *StepRequest) GetQualityDefinition() string

func (*StepRequest) GetWorkflowId

func (x *StepRequest) GetWorkflowId() int32

func (*StepRequest) GetWorkflowName

func (x *StepRequest) GetWorkflowName() string

func (*StepRequest) ProtoMessage

func (*StepRequest) ProtoMessage()

func (*StepRequest) ProtoReflect

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

func (*StepRequest) Reset

func (x *StepRequest) Reset()

func (*StepRequest) String

func (x *StepRequest) String() string

type StepStats

type StepStats struct {
	StepId            int32  `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	StepName          string `protobuf:"bytes,2,opt,name=step_name,json=stepName,proto3" json:"step_name,omitempty"`
	TotalTasks        int32  `protobuf:"varint,3,opt,name=total_tasks,json=totalTasks,proto3" json:"total_tasks,omitempty"`
	WaitingTasks      int32  `protobuf:"varint,4,opt,name=waiting_tasks,json=waitingTasks,proto3" json:"waiting_tasks,omitempty"`
	PendingTasks      int32  `protobuf:"varint,5,opt,name=pending_tasks,json=pendingTasks,proto3" json:"pending_tasks,omitempty"`
	AcceptedTasks     int32  `protobuf:"varint,6,opt,name=accepted_tasks,json=acceptedTasks,proto3" json:"accepted_tasks,omitempty"`
	RunningTasks      int32  `protobuf:"varint,7,opt,name=running_tasks,json=runningTasks,proto3" json:"running_tasks,omitempty"`
	UploadingTasks    int32  `protobuf:"varint,8,opt,name=uploading_tasks,json=uploadingTasks,proto3" json:"uploading_tasks,omitempty"`
	SuccessfulTasks   int32  `protobuf:"varint,9,opt,name=successful_tasks,json=successfulTasks,proto3" json:"successful_tasks,omitempty"`
	FailedTasks       int32  `protobuf:"varint,10,opt,name=failed_tasks,json=failedTasks,proto3" json:"failed_tasks,omitempty"`
	ReallyFailedTasks int32  `protobuf:"varint,11,opt,name=really_failed_tasks,json=reallyFailedTasks,proto3" json:"really_failed_tasks,omitempty"` // tasks that have exhausted all retries and are failed
	SuccessRun        *Accum `protobuf:"bytes,12,opt,name=success_run,json=successRun,proto3" json:"success_run,omitempty"`                         // succeeded tasks' run durations
	FailedRun         *Accum `protobuf:"bytes,13,opt,name=failed_run,json=failedRun,proto3" json:"failed_run,omitempty"`                            // failed tasks' run durations
	RunningRun        *Accum `protobuf:"bytes,14,opt,name=running_run,json=runningRun,proto3" json:"running_run,omitempty"`                         // running tasks' elapsed durations (at eval time)
	Download          *Accum `protobuf:"bytes,15,opt,name=download,proto3" json:"download,omitempty"`                                               // download durations
	Upload            *Accum `protobuf:"bytes,16,opt,name=upload,proto3" json:"upload,omitempty"`                                                   // upload durations
	StartTime         *int64 `protobuf:"varint,17,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`                     // epoch timestamp of the first task start time
	EndTime           *int64 `protobuf:"varint,18,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`                           // epoch timestamp of the last task end time
	StatsEvalTime     int32  `protobuf:"varint,19,opt,name=stats_eval_time,json=statsEvalTime,proto3" json:"stats_eval_time,omitempty"`             // epoch seconds when these stats were computed
	// contains filtered or unexported fields
}

func (*StepStats) Descriptor deprecated

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

Deprecated: Use StepStats.ProtoReflect.Descriptor instead.

func (*StepStats) GetAcceptedTasks

func (x *StepStats) GetAcceptedTasks() int32

func (*StepStats) GetDownload

func (x *StepStats) GetDownload() *Accum

func (*StepStats) GetEndTime

func (x *StepStats) GetEndTime() int64

func (*StepStats) GetFailedRun

func (x *StepStats) GetFailedRun() *Accum

func (*StepStats) GetFailedTasks

func (x *StepStats) GetFailedTasks() int32

func (*StepStats) GetPendingTasks

func (x *StepStats) GetPendingTasks() int32

func (*StepStats) GetReallyFailedTasks

func (x *StepStats) GetReallyFailedTasks() int32

func (*StepStats) GetRunningRun

func (x *StepStats) GetRunningRun() *Accum

func (*StepStats) GetRunningTasks

func (x *StepStats) GetRunningTasks() int32

func (*StepStats) GetStartTime

func (x *StepStats) GetStartTime() int64

func (*StepStats) GetStatsEvalTime

func (x *StepStats) GetStatsEvalTime() int32

func (*StepStats) GetStepId

func (x *StepStats) GetStepId() int32

func (*StepStats) GetStepName

func (x *StepStats) GetStepName() string

func (*StepStats) GetSuccessRun

func (x *StepStats) GetSuccessRun() *Accum

func (*StepStats) GetSuccessfulTasks

func (x *StepStats) GetSuccessfulTasks() int32

func (*StepStats) GetTotalTasks

func (x *StepStats) GetTotalTasks() int32

func (*StepStats) GetUpload

func (x *StepStats) GetUpload() *Accum

func (*StepStats) GetUploadingTasks

func (x *StepStats) GetUploadingTasks() int32

func (*StepStats) GetWaitingTasks

func (x *StepStats) GetWaitingTasks() int32

func (*StepStats) ProtoMessage

func (*StepStats) ProtoMessage()

func (*StepStats) ProtoReflect

func (x *StepStats) ProtoReflect() protoreflect.Message

func (*StepStats) Reset

func (x *StepStats) Reset()

func (*StepStats) String

func (x *StepStats) String() string

type StepStatsRequest

type StepStatsRequest struct {
	WorkflowId *int32  `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
	StepIds    []int32 `protobuf:"varint,2,rep,packed,name=step_ids,json=stepIds,proto3" json:"step_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StepStatsRequest) Descriptor deprecated

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

Deprecated: Use StepStatsRequest.ProtoReflect.Descriptor instead.

func (*StepStatsRequest) GetStepIds

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

func (*StepStatsRequest) GetWorkflowId

func (x *StepStatsRequest) GetWorkflowId() int32

func (*StepStatsRequest) ProtoMessage

func (*StepStatsRequest) ProtoMessage()

func (*StepStatsRequest) ProtoReflect

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

func (*StepStatsRequest) Reset

func (x *StepStatsRequest) Reset()

func (*StepStatsRequest) String

func (x *StepStatsRequest) String() string

type StepStatsResponse

type StepStatsResponse struct {
	Stats []*StepStats `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*StepStatsResponse) Descriptor deprecated

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

Deprecated: Use StepStatsResponse.ProtoReflect.Descriptor instead.

func (*StepStatsResponse) GetStats

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

func (*StepStatsResponse) ProtoMessage

func (*StepStatsResponse) ProtoMessage()

func (*StepStatsResponse) ProtoReflect

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

func (*StepStatsResponse) Reset

func (x *StepStatsResponse) Reset()

func (*StepStatsResponse) String

func (x *StepStatsResponse) String() string

type StringList added in v0.7.7

type StringList struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

StringList wraps a `repeated string` so it can be carried as `optional` in EditTaskRequest. Required because proto3 doesn't natively support `optional repeated`. Semantics in the requests that use it:

  • field absent (nil pointer) → leave the underlying list alone
  • field present, values empty slice → clear the underlying list
  • field present, values non-empty → replace the underlying list

func (*StringList) Descriptor deprecated added in v0.7.7

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

Deprecated: Use StringList.ProtoReflect.Descriptor instead.

func (*StringList) GetValues added in v0.7.7

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

func (*StringList) ProtoMessage added in v0.7.7

func (*StringList) ProtoMessage()

func (*StringList) ProtoReflect added in v0.7.7

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

func (*StringList) Reset added in v0.7.7

func (x *StringList) Reset()

func (*StringList) String added in v0.7.7

func (x *StringList) String() string

type Task

type Task struct {
	TaskId           int32    `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Command          string   `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	Shell            *string  `protobuf:"bytes,3,opt,name=shell,proto3,oneof" json:"shell,omitempty"`
	Container        string   `protobuf:"bytes,4,opt,name=container,proto3" json:"container,omitempty"`
	ContainerOptions *string  `protobuf:"bytes,5,opt,name=container_options,json=containerOptions,proto3,oneof" json:"container_options,omitempty"`
	StepId           *int32   `protobuf:"varint,6,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
	Input            []string `protobuf:"bytes,7,rep,name=input,proto3" json:"input,omitempty"`
	Resource         []string `protobuf:"bytes,8,rep,name=resource,proto3" json:"resource,omitempty"`
	Output           *string  `protobuf:"bytes,9,opt,name=output,proto3,oneof" json:"output,omitempty"`
	Retry            *int32   `protobuf:"varint,10,opt,name=retry,proto3,oneof" json:"retry,omitempty"`
	IsFinal          *bool    `protobuf:"varint,11,opt,name=is_final,json=isFinal,proto3,oneof" json:"is_final,omitempty"`
	UsesCache        *bool    `protobuf:"varint,12,opt,name=uses_cache,json=usesCache,proto3,oneof" json:"uses_cache,omitempty"`
	DownloadTimeout  *float32 `protobuf:"fixed32,13,opt,name=download_timeout,json=downloadTimeout,proto3,oneof" json:"download_timeout,omitempty"`
	RunningTimeout   *float32 `protobuf:"fixed32,14,opt,name=running_timeout,json=runningTimeout,proto3,oneof" json:"running_timeout,omitempty"`
	UploadTimeout    *float32 `protobuf:"fixed32,15,opt,name=upload_timeout,json=uploadTimeout,proto3,oneof" json:"upload_timeout,omitempty"`
	Status           string   `protobuf:"bytes,16,opt,name=status,proto3" json:"status,omitempty"`
	WorkerId         *int32   `protobuf:"varint,17,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
	WorkflowId       *int32   `protobuf:"varint,18,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
	TaskName         *string  `protobuf:"bytes,19,opt,name=task_name,json=taskName,proto3,oneof" json:"task_name,omitempty"`
	RetryCount       int32    `protobuf:"varint,20,opt,name=retry_count,json=retryCount,proto3" json:"retry_count,omitempty"`
	Hidden           bool     `protobuf:"varint,21,opt,name=hidden,proto3" json:"hidden,omitempty"`
	PreviousTaskId   *int32   `protobuf:"varint,22,opt,name=previous_task_id,json=previousTaskId,proto3,oneof" json:"previous_task_id,omitempty"`
	Weight           *float64 `protobuf:"fixed64,23,opt,name=weight,proto3,oneof" json:"weight,omitempty"`                                  // Fraction of the assigned worker's concurrency consumed by this task (default 1.0)
	RunStartTime     *int64   `protobuf:"varint,24,opt,name=run_start_time,json=runStartTime,proto3,oneof" json:"run_start_time,omitempty"` // epoch timestamp of the first task start time
	SkipIfExists     bool     `protobuf:"varint,25,opt,name=skip_if_exists,json=skipIfExists,proto3" json:"skip_if_exists,omitempty"`
	Publish          *string  `protobuf:"bytes,26,opt,name=publish,proto3,oneof" json:"publish,omitempty"`                                            // Publish path (output copied here on success only)
	ReuseKey         *string  `protobuf:"bytes,27,opt,name=reuse_key,json=reuseKey,proto3,oneof" json:"reuse_key,omitempty"`                          // SHA-256 hex for opportunistic reuse
	DownloadDuration *int32   `protobuf:"varint,28,opt,name=download_duration,json=downloadDuration,proto3,oneof" json:"download_duration,omitempty"` // seconds spent downloading inputs
	RunDuration      *int32   `protobuf:"varint,29,opt,name=run_duration,json=runDuration,proto3,oneof" json:"run_duration,omitempty"`                // seconds spent running the command
	UploadDuration   *int32   `protobuf:"varint,30,opt,name=upload_duration,json=uploadDuration,proto3,oneof" json:"upload_duration,omitempty"`       // seconds spent uploading outputs
	QualityScore     *float64 `protobuf:"fixed64,31,opt,name=quality_score,json=qualityScore,proto3,oneof" json:"quality_score,omitempty"`            // quality score (higher is better)
	QualityVars      *string  `protobuf:"bytes,32,opt,name=quality_vars,json=qualityVars,proto3,oneof" json:"quality_vars,omitempty"`                 // JSON: extracted quality variables
	// See TaskRequest.scitq_auth.
	ScitqAuth *bool `protobuf:"varint,33,opt,name=scitq_auth,json=scitqAuth,proto3,oneof" json:"scitq_auth,omitempty"`
	// See TaskRequest.numa.
	Numa *int32 `protobuf:"varint,34,opt,name=numa,proto3,oneof" json:"numa,omitempty"`
	// See TaskRequest.min_cpu / min_mem / min_disk (per-task resource
	// requirements; spec: addition_from_nextflow.md A).
	MinCpu  *float32 `protobuf:"fixed32,35,opt,name=min_cpu,json=minCpu,proto3,oneof" json:"min_cpu,omitempty"`
	MinMem  *float32 `protobuf:"fixed32,36,opt,name=min_mem,json=minMem,proto3,oneof" json:"min_mem,omitempty"`
	MinDisk *float32 `protobuf:"fixed32,37,opt,name=min_disk,json=minDisk,proto3,oneof" json:"min_disk,omitempty"`
	// See TaskRequest.cpu_curve / mem_curve / disk_curve.
	CpuCurve  []float32 `protobuf:"fixed32,38,rep,packed,name=cpu_curve,json=cpuCurve,proto3" json:"cpu_curve,omitempty"`
	MemCurve  []float32 `protobuf:"fixed32,39,rep,packed,name=mem_curve,json=memCurve,proto3" json:"mem_curve,omitempty"`
	DiskCurve []float32 `protobuf:"fixed32,40,rep,packed,name=disk_curve,json=diskCurve,proto3" json:"disk_curve,omitempty"`
	// failure_class set by the worker on terminal failures (oom / timeout /
	// network / other) and propagated to the next TaskStatusUpdate. Server
	// also writes this column directly when reaping orphaned tasks
	// (failure_class="eviction"). See TaskStatusUpdate.failure_class for the
	// value set.
	FailureClass *string `protobuf:"bytes,41,opt,name=failure_class,json=failureClass,proto3,oneof" json:"failure_class,omitempty"`
	// See TaskRequest.publish_mode.
	PublishMode *string `protobuf:"bytes,42,opt,name=publish_mode,json=publishMode,proto3,oneof" json:"publish_mode,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCommand

func (x *Task) GetCommand() string

func (*Task) GetContainer

func (x *Task) GetContainer() string

func (*Task) GetContainerOptions

func (x *Task) GetContainerOptions() string

func (*Task) GetCpuCurve added in v0.8.5

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

func (*Task) GetDiskCurve added in v0.8.5

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

func (*Task) GetDownloadDuration added in v0.7.2

func (x *Task) GetDownloadDuration() int32

func (*Task) GetDownloadTimeout

func (x *Task) GetDownloadTimeout() float32

func (*Task) GetFailureClass added in v0.8.5

func (x *Task) GetFailureClass() string

func (*Task) GetHidden

func (x *Task) GetHidden() bool

func (*Task) GetInput

func (x *Task) GetInput() []string

func (*Task) GetIsFinal

func (x *Task) GetIsFinal() bool

func (*Task) GetMemCurve added in v0.8.5

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

func (*Task) GetMinCpu added in v0.8.5

func (x *Task) GetMinCpu() float32

func (*Task) GetMinDisk added in v0.8.5

func (x *Task) GetMinDisk() float32

func (*Task) GetMinMem added in v0.8.5

func (x *Task) GetMinMem() float32

func (*Task) GetNuma added in v0.8.5

func (x *Task) GetNuma() int32

func (*Task) GetOutput

func (x *Task) GetOutput() string

func (*Task) GetPreviousTaskId

func (x *Task) GetPreviousTaskId() int32

func (*Task) GetPublish added in v0.7.1

func (x *Task) GetPublish() string

func (*Task) GetPublishMode added in v0.8.5

func (x *Task) GetPublishMode() string

func (*Task) GetQualityScore added in v0.7.2

func (x *Task) GetQualityScore() float64

func (*Task) GetQualityVars added in v0.7.2

func (x *Task) GetQualityVars() string

func (*Task) GetResource

func (x *Task) GetResource() []string

func (*Task) GetRetry

func (x *Task) GetRetry() int32

func (*Task) GetRetryCount

func (x *Task) GetRetryCount() int32

func (*Task) GetReuseKey added in v0.7.2

func (x *Task) GetReuseKey() string

func (*Task) GetRunDuration added in v0.7.2

func (x *Task) GetRunDuration() int32

func (*Task) GetRunStartTime

func (x *Task) GetRunStartTime() int64

func (*Task) GetRunningTimeout

func (x *Task) GetRunningTimeout() float32

func (*Task) GetScitqAuth added in v0.8.5

func (x *Task) GetScitqAuth() bool

func (*Task) GetShell

func (x *Task) GetShell() string

func (*Task) GetSkipIfExists added in v0.7.1

func (x *Task) GetSkipIfExists() bool

func (*Task) GetStatus

func (x *Task) GetStatus() string

func (*Task) GetStepId

func (x *Task) GetStepId() int32

func (*Task) GetTaskId

func (x *Task) GetTaskId() int32

func (*Task) GetTaskName

func (x *Task) GetTaskName() string

func (*Task) GetUploadDuration added in v0.7.2

func (x *Task) GetUploadDuration() int32

func (*Task) GetUploadTimeout

func (x *Task) GetUploadTimeout() float32

func (*Task) GetUsesCache

func (x *Task) GetUsesCache() bool

func (*Task) GetWeight

func (x *Task) GetWeight() float64

func (*Task) GetWorkerId

func (x *Task) GetWorkerId() int32

func (*Task) GetWorkflowId

func (x *Task) GetWorkflowId() int32

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) ProtoReflect

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset

func (x *Task) Reset()

func (*Task) String

func (x *Task) String() string

type TaskId

type TaskId struct {
	TaskId int32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskId) Descriptor deprecated

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

Deprecated: Use TaskId.ProtoReflect.Descriptor instead.

func (*TaskId) GetTaskId

func (x *TaskId) GetTaskId() int32

func (*TaskId) ProtoMessage

func (*TaskId) ProtoMessage()

func (*TaskId) ProtoReflect

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

func (*TaskId) Reset

func (x *TaskId) Reset()

func (*TaskId) String

func (x *TaskId) String() string

type TaskIds

type TaskIds struct {
	TaskIds []int32 `protobuf:"varint,1,rep,packed,name=task_ids,json=taskIds,proto3" json:"task_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskIds) Descriptor deprecated

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

Deprecated: Use TaskIds.ProtoReflect.Descriptor instead.

func (*TaskIds) GetTaskIds

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

func (*TaskIds) ProtoMessage

func (*TaskIds) ProtoMessage()

func (*TaskIds) ProtoReflect

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

func (*TaskIds) Reset

func (x *TaskIds) Reset()

func (*TaskIds) String

func (x *TaskIds) String() string

type TaskList

type TaskList struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskList) Descriptor deprecated

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

Deprecated: Use TaskList.ProtoReflect.Descriptor instead.

func (*TaskList) GetTasks

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

func (*TaskList) ProtoMessage

func (*TaskList) ProtoMessage()

func (*TaskList) ProtoReflect

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

func (*TaskList) Reset

func (x *TaskList) Reset()

func (*TaskList) String

func (x *TaskList) String() string

type TaskListAndOther

type TaskListAndOther struct {
	Tasks       []*Task         `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Concurrency int32           `protobuf:"varint,2,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	Updates     *TaskUpdateList `protobuf:"bytes,3,opt,name=updates,proto3" json:"updates,omitempty"`
	ActiveTasks []int32         `protobuf:"varint,4,rep,packed,name=active_tasks,json=activeTasks,proto3" json:"active_tasks,omitempty"`
	Signals     []*TaskSignal   `protobuf:"bytes,6,rep,name=signals,proto3" json:"signals,omitempty"` // tasks to signal on this worker
	// Operator-triggered upgrade flag. Empty = no request; "normal" =
	// wait for full idle then upgrade; "emergency" = drain in-flight
	// tasks (hard 30-min cap) then upgrade. See
	// specs/worker_autoupgrade.md (Phase II).
	UpgradeRequested string `protobuf:"bytes,7,opt,name=upgrade_requested,json=upgradeRequested,proto3" json:"upgrade_requested,omitempty"`
	// Phase III: server has received SIGUSR1 and is draining its
	// active admin jobs in preparation for a graceful exit. Workers
	// that see this flag should stop *requesting* new task slots
	// (existing in-flight tasks continue; the gRPC retry loop will
	// absorb the brief bounce). See specs/worker_autoupgrade.md.
	ServerUpgradeInProgress bool `` /* 135-byte string literal not displayed */
	// Server-pushed resource caps. The server sends what *it* currently
	// believes the worker should advertise (the worker's flavor cpu/mem,
	// editable live via UpdateWorker). The client compares against its
	// local cap and resizes if changed — letting an operator dial a
	// shared node's contribution up or down without restarting the
	// client. Optional so older servers still work with newer clients.
	MaxCpu *int32   `protobuf:"varint,9,opt,name=max_cpu,json=maxCpu,proto3,oneof" json:"max_cpu,omitempty"`
	MaxMem *float32 `protobuf:"fixed32,10,opt,name=max_mem,json=maxMem,proto3,oneof" json:"max_mem,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskListAndOther) Descriptor deprecated

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

Deprecated: Use TaskListAndOther.ProtoReflect.Descriptor instead.

func (*TaskListAndOther) GetActiveTasks

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

func (*TaskListAndOther) GetConcurrency

func (x *TaskListAndOther) GetConcurrency() int32

func (*TaskListAndOther) GetMaxCpu added in v0.8.5

func (x *TaskListAndOther) GetMaxCpu() int32

func (*TaskListAndOther) GetMaxMem added in v0.8.5

func (x *TaskListAndOther) GetMaxMem() float32

func (*TaskListAndOther) GetServerUpgradeInProgress added in v0.8.1

func (x *TaskListAndOther) GetServerUpgradeInProgress() bool

func (*TaskListAndOther) GetSignals added in v0.7.2

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

func (*TaskListAndOther) GetTasks

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

func (*TaskListAndOther) GetUpdates

func (x *TaskListAndOther) GetUpdates() *TaskUpdateList

func (*TaskListAndOther) GetUpgradeRequested added in v0.8.1

func (x *TaskListAndOther) GetUpgradeRequested() string

func (*TaskListAndOther) ProtoMessage

func (*TaskListAndOther) ProtoMessage()

func (*TaskListAndOther) ProtoReflect

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

func (*TaskListAndOther) Reset

func (x *TaskListAndOther) Reset()

func (*TaskListAndOther) String

func (x *TaskListAndOther) String() string

type TaskLog

type TaskLog struct {
	TaskId  int32  `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	LogType string `protobuf:"bytes,2,opt,name=log_type,json=logType,proto3" json:"log_type,omitempty"` // 'O' for stdout, 'E' for stderr
	LogText string `protobuf:"bytes,3,opt,name=log_text,json=logText,proto3" json:"log_text,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskLog) Descriptor deprecated

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

Deprecated: Use TaskLog.ProtoReflect.Descriptor instead.

func (*TaskLog) GetLogText

func (x *TaskLog) GetLogText() string

func (*TaskLog) GetLogType

func (x *TaskLog) GetLogType() string

func (*TaskLog) GetTaskId

func (x *TaskLog) GetTaskId() int32

func (*TaskLog) ProtoMessage

func (*TaskLog) ProtoMessage()

func (*TaskLog) ProtoReflect

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

func (*TaskLog) Reset

func (x *TaskLog) Reset()

func (*TaskLog) String

func (x *TaskLog) String() string

type TaskQueueClient

type TaskQueueClient interface {
	SubmitTask(ctx context.Context, in *TaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)
	RegisterWorker(ctx context.Context, in *WorkerInfo, opts ...grpc.CallOption) (*WorkerId, error)
	PingAndTakeNewTasks(ctx context.Context, in *PingAndGetNewTasksRequest, opts ...grpc.CallOption) (*TaskListAndOther, error)
	UpdateTaskStatus(ctx context.Context, in *TaskStatusUpdate, opts ...grpc.CallOption) (*Ack, error)
	SendTaskLogs(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[TaskLog, Ack], error)
	StreamTaskLogsOutput(ctx context.Context, in *TaskId, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TaskLog], error)
	StreamTaskLogsErr(ctx context.Context, in *TaskId, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TaskLog], error)
	GetLogsChunk(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*LogChunkList, error)
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*TaskList, error)
	RetryTask(ctx context.Context, in *RetryTaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)
	ForceRunTask(ctx context.Context, in *ForceRunTaskRequest, opts ...grpc.CallOption) (*Ack, error)
	EditAndRetryTask(ctx context.Context, in *EditAndRetryTaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)
	EditTask(ctx context.Context, in *EditTaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)
	GetTask(ctx context.Context, in *TaskId, opts ...grpc.CallOption) (*Task, error)
	EditStepCommand(ctx context.Context, in *EditStepCommandRequest, opts ...grpc.CallOption) (*EditStepCommandResponse, error)
	ListWorkers(ctx context.Context, in *ListWorkersRequest, opts ...grpc.CallOption) (*WorkersList, error)
	CreateWorker(ctx context.Context, in *WorkerRequest, opts ...grpc.CallOption) (*WorkerIds, error)
	CreateWorkerByName(ctx context.Context, in *CreateWorkerByNameRequest, opts ...grpc.CallOption) (*WorkerIds, error)
	UpdateWorkerStatus(ctx context.Context, in *WorkerStatus, opts ...grpc.CallOption) (*Ack, error)
	DeleteWorker(ctx context.Context, in *WorkerDeletion, opts ...grpc.CallOption) (*JobId, error)
	UpdateWorker(ctx context.Context, in *WorkerUpdateRequest, opts ...grpc.CallOption) (*Ack, error)
	UserUpdateWorker(ctx context.Context, in *WorkerUpdateRequest, opts ...grpc.CallOption) (*Ack, error)
	GetWorkerStatuses(ctx context.Context, in *WorkerStatusRequest, opts ...grpc.CallOption) (*WorkerStatusResponse, error)
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*JobsList, error)
	GetJobStatuses(ctx context.Context, in *JobStatusRequest, opts ...grpc.CallOption) (*JobStatusResponse, error)
	DeleteJob(ctx context.Context, in *JobId, opts ...grpc.CallOption) (*Ack, error)
	UpdateJob(ctx context.Context, in *JobUpdate, opts ...grpc.CallOption) (*Ack, error)
	ListFlavors(ctx context.Context, in *ListFlavorsRequest, opts ...grpc.CallOption) (*FlavorsList, error)
	ListProviders(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ProviderList, error)
	ListRegions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RegionList, error)
	CreateFlavor(ctx context.Context, in *FlavorCreateRequest, opts ...grpc.CallOption) (*FlavorId, error)
	// Operator: mark a flavor as (un)available for new recruitment in a
	// specific provider/region (or all regions of that provider).
	// Existing workers are untouched. The flavor stays in the catalog;
	// only `flavor_region.available` is flipped. See
	// specs/worker_autoupgrade.md / docs.
	SetFlavorAvailability(ctx context.Context, in *FlavorAvailability, opts ...grpc.CallOption) (*FlavorAvailabilityReply, error)
	GetRcloneConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RcloneRemotes, error)
	GetDockerCredentials(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DockerCredentials, error)
	Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error)
	GetCertificate(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Certificate, error)
	Logout(ctx context.Context, in *Token, opts ...grpc.CallOption) (*Ack, error)
	CreateUser(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*UserId, error)
	ListUsers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*UsersList, error)
	DeleteUser(ctx context.Context, in *UserId, opts ...grpc.CallOption) (*Ack, error)
	UpdateUser(ctx context.Context, in *User, opts ...grpc.CallOption) (*Ack, error)
	ChangePassword(ctx context.Context, in *ChangePasswordRequest, opts ...grpc.CallOption) (*Ack, error)
	AdminResetPassword(ctx context.Context, in *AdminResetPasswordRequest, opts ...grpc.CallOption) (*Ack, error)
	ListRecruiters(ctx context.Context, in *RecruiterFilter, opts ...grpc.CallOption) (*RecruiterList, error)
	CreateRecruiter(ctx context.Context, in *Recruiter, opts ...grpc.CallOption) (*Ack, error)
	UpdateRecruiter(ctx context.Context, in *RecruiterUpdate, opts ...grpc.CallOption) (*Ack, error)
	DeleteRecruiter(ctx context.Context, in *RecruiterId, opts ...grpc.CallOption) (*Ack, error)
	ListWorkflows(ctx context.Context, in *WorkflowFilter, opts ...grpc.CallOption) (*WorkflowList, error)
	CreateWorkflow(ctx context.Context, in *WorkflowRequest, opts ...grpc.CallOption) (*WorkflowId, error)
	UpdateWorkflowStatus(ctx context.Context, in *WorkflowStatusUpdate, opts ...grpc.CallOption) (*Ack, error)
	DeleteWorkflow(ctx context.Context, in *WorkflowId, opts ...grpc.CallOption) (*Ack, error)
	// Workflow chain — template-to-template sequencing. Entries are armed
	// at parent-submit time (CreateChainEntries) and fire when the parent
	// reaches a terminal status. See specs/workflow_chain.md.
	CreateChainEntries(ctx context.Context, in *CreateChainEntriesRequest, opts ...grpc.CallOption) (*ChainEntryList, error)
	ListChainEntries(ctx context.Context, in *ListChainEntriesRequest, opts ...grpc.CallOption) (*ChainEntryList, error)
	GetChainEntry(ctx context.Context, in *ChainEntryId, opts ...grpc.CallOption) (*ChainEntry, error)
	SuspendChainEntry(ctx context.Context, in *ChainEntryId, opts ...grpc.CallOption) (*ChainEntry, error)
	ResumeChainEntry(ctx context.Context, in *ChainEntryId, opts ...grpc.CallOption) (*ChainEntry, error)
	CancelChainEntry(ctx context.Context, in *ChainEntryId, opts ...grpc.CallOption) (*ChainEntry, error)
	EditChainEntry(ctx context.Context, in *EditChainEntryRequest, opts ...grpc.CallOption) (*ChainEntry, error)
	DebugAssignTask(ctx context.Context, in *DebugAssignRequest, opts ...grpc.CallOption) (*Ack, error)
	DebugRecruitStep(ctx context.Context, in *DebugRecruitRequest, opts ...grpc.CallOption) (*Ack, error)
	DebugRetryTask(ctx context.Context, in *RetryTaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)
	ListDependentPendingTasks(ctx context.Context, in *TaskId, opts ...grpc.CallOption) (*TaskIds, error)
	ListSteps(ctx context.Context, in *StepFilter, opts ...grpc.CallOption) (*StepList, error)
	CreateStep(ctx context.Context, in *StepRequest, opts ...grpc.CallOption) (*StepId, error)
	DeleteStep(ctx context.Context, in *StepId, opts ...grpc.CallOption) (*Ack, error)
	GetStepStats(ctx context.Context, in *StepStatsRequest, opts ...grpc.CallOption) (*StepStatsResponse, error)
	GetWorkerStats(ctx context.Context, in *GetWorkerStatsRequest, opts ...grpc.CallOption) (*GetWorkerStatsResponse, error)
	FetchList(ctx context.Context, in *FetchListRequest, opts ...grpc.CallOption) (*FetchListResponse, error)
	FetchInfo(ctx context.Context, in *FetchListRequest, opts ...grpc.CallOption) (*FetchInfoResponse, error)
	// Template system
	UploadTemplate(ctx context.Context, in *UploadTemplateRequest, opts ...grpc.CallOption) (*UploadTemplateResponse, error)
	DownloadTemplate(ctx context.Context, in *DownloadTemplateRequest, opts ...grpc.CallOption) (*FileContent, error)
	RunTemplate(ctx context.Context, in *RunTemplateRequest, opts ...grpc.CallOption) (*TemplateRun, error)
	ListTemplates(ctx context.Context, in *TemplateFilter, opts ...grpc.CallOption) (*TemplateList, error)
	UpdateTemplate(ctx context.Context, in *UpdateTemplateRequest, opts ...grpc.CallOption) (*Template, error)
	ListTemplateRuns(ctx context.Context, in *TemplateRunFilter, opts ...grpc.CallOption) (*TemplateRunList, error)
	UpdateTemplateRun(ctx context.Context, in *UpdateTemplateRunRequest, opts ...grpc.CallOption) (*Ack, error)
	DeleteTemplateRun(ctx context.Context, in *DeleteTemplateRunRequest, opts ...grpc.CallOption) (*Ack, error)
	// Register a local run (python script that doesn't come from an uploaded
	// template). Creates a template_run row with a NULL workflow_template_id
	// and records script identity so "what launched this workflow?" stays
	// answerable. The returned template_run_id should be set on
	// UpdateTemplateRun once the workflow is created (same flow as
	// server-launched templates).
	RegisterAdhocRun(ctx context.Context, in *RegisterAdhocRunRequest, opts ...grpc.CallOption) (*TemplateRun, error)
	// Module system
	UploadModule(ctx context.Context, in *UploadModuleRequest, opts ...grpc.CallOption) (*Ack, error)
	ListModules(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ModuleList, error)
	ListModulesFiltered(ctx context.Context, in *ModuleListFilter, opts ...grpc.CallOption) (*ModuleList, error)
	DownloadModule(ctx context.Context, in *DownloadModuleRequest, opts ...grpc.CallOption) (*FileContent, error)
	DeleteModule(ctx context.Context, in *DeleteModuleRequest, opts ...grpc.CallOption) (*Ack, error)
	UpgradeBundledModules(ctx context.Context, in *UpgradeBundledModulesRequest, opts ...grpc.CallOption) (*UpgradeBundledModulesResponse, error)
	GetModuleOrigin(ctx context.Context, in *ModuleOriginRequest, opts ...grpc.CallOption) (*ModuleOriginResponse, error)
	ForkModule(ctx context.Context, in *ForkModuleRequest, opts ...grpc.CallOption) (*Ack, error)
	GetWorkspaceRoot(ctx context.Context, in *WorkspaceRootRequest, opts ...grpc.CallOption) (*WorkspaceRootResponse, error)
	GetResourceRoot(ctx context.Context, in *WorkspaceRootRequest, opts ...grpc.CallOption) (*WorkspaceRootResponse, error)
	RegisterSpecifications(ctx context.Context, in *ResourceSpec, opts ...grpc.CallOption) (*Ack, error)
	// Worker events
	ReportWorkerEvent(ctx context.Context, in *WorkerEvent, opts ...grpc.CallOption) (*Ack, error)
	ListWorkerEvents(ctx context.Context, in *WorkerEventFilter, opts ...grpc.CallOption) (*WorkerEventList, error)
	DeleteWorkerEvent(ctx context.Context, in *WorkerEventId, opts ...grpc.CallOption) (*Ack, error)
	PruneWorkerEvents(ctx context.Context, in *WorkerEventPruneFilter, opts ...grpc.CallOption) (*WorkerEventPruneResult, error)
	GetTaskStatusCounts(ctx context.Context, in *TaskStatusCountsRequest, opts ...grpc.CallOption) (*TaskStatusCountsResponse, error)
	SignalTask(ctx context.Context, in *TaskSignalRequest, opts ...grpc.CallOption) (*Ack, error)
	// Returns the server's own build identity so callers (CLI, worker) can
	// detect a version mismatch. Cheap, unauthenticated lookup — version
	// info is not a secret. See specs/worker_autoupgrade.md (Phase I).
	ServerVersion(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ServerVersionResponse, error)
	// Operator-triggered worker upgrade. Sets worker.upgrade_requested
	// for the given workers; the worker reads the column from its next
	// ping response and acts (idle-wait or drain). See
	// specs/worker_autoupgrade.md (Phase II).
	RequestWorkerUpgrade(ctx context.Context, in *WorkerUpgradeRequest, opts ...grpc.CallOption) (*WorkerUpgradeReply, error)
	// Returns the URL the worker should download a fresh client binary
	// from (and the matching sha256 sibling URL). Both URLs already
	// include the auth token in their query string. Authenticated.
	// See specs/worker_autoupgrade.md (Phase II).
	GetClientUpgradeInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ClientUpgradeInfo, error)
}

TaskQueueClient is the client API for TaskQueue service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTaskQueueClient

func NewTaskQueueClient(cc grpc.ClientConnInterface) TaskQueueClient

type TaskQueueServer

type TaskQueueServer interface {
	SubmitTask(context.Context, *TaskRequest) (*TaskResponse, error)
	RegisterWorker(context.Context, *WorkerInfo) (*WorkerId, error)
	PingAndTakeNewTasks(context.Context, *PingAndGetNewTasksRequest) (*TaskListAndOther, error)
	UpdateTaskStatus(context.Context, *TaskStatusUpdate) (*Ack, error)
	SendTaskLogs(grpc.ClientStreamingServer[TaskLog, Ack]) error
	StreamTaskLogsOutput(*TaskId, grpc.ServerStreamingServer[TaskLog]) error
	StreamTaskLogsErr(*TaskId, grpc.ServerStreamingServer[TaskLog]) error
	GetLogsChunk(context.Context, *GetLogsRequest) (*LogChunkList, error)
	ListTasks(context.Context, *ListTasksRequest) (*TaskList, error)
	RetryTask(context.Context, *RetryTaskRequest) (*TaskResponse, error)
	ForceRunTask(context.Context, *ForceRunTaskRequest) (*Ack, error)
	EditAndRetryTask(context.Context, *EditAndRetryTaskRequest) (*TaskResponse, error)
	EditTask(context.Context, *EditTaskRequest) (*TaskResponse, error)
	GetTask(context.Context, *TaskId) (*Task, error)
	EditStepCommand(context.Context, *EditStepCommandRequest) (*EditStepCommandResponse, error)
	ListWorkers(context.Context, *ListWorkersRequest) (*WorkersList, error)
	CreateWorker(context.Context, *WorkerRequest) (*WorkerIds, error)
	CreateWorkerByName(context.Context, *CreateWorkerByNameRequest) (*WorkerIds, error)
	UpdateWorkerStatus(context.Context, *WorkerStatus) (*Ack, error)
	DeleteWorker(context.Context, *WorkerDeletion) (*JobId, error)
	UpdateWorker(context.Context, *WorkerUpdateRequest) (*Ack, error)
	UserUpdateWorker(context.Context, *WorkerUpdateRequest) (*Ack, error)
	GetWorkerStatuses(context.Context, *WorkerStatusRequest) (*WorkerStatusResponse, error)
	ListJobs(context.Context, *ListJobsRequest) (*JobsList, error)
	GetJobStatuses(context.Context, *JobStatusRequest) (*JobStatusResponse, error)
	DeleteJob(context.Context, *JobId) (*Ack, error)
	UpdateJob(context.Context, *JobUpdate) (*Ack, error)
	ListFlavors(context.Context, *ListFlavorsRequest) (*FlavorsList, error)
	ListProviders(context.Context, *emptypb.Empty) (*ProviderList, error)
	ListRegions(context.Context, *emptypb.Empty) (*RegionList, error)
	CreateFlavor(context.Context, *FlavorCreateRequest) (*FlavorId, error)
	// Operator: mark a flavor as (un)available for new recruitment in a
	// specific provider/region (or all regions of that provider).
	// Existing workers are untouched. The flavor stays in the catalog;
	// only `flavor_region.available` is flipped. See
	// specs/worker_autoupgrade.md / docs.
	SetFlavorAvailability(context.Context, *FlavorAvailability) (*FlavorAvailabilityReply, error)
	GetRcloneConfig(context.Context, *emptypb.Empty) (*RcloneRemotes, error)
	GetDockerCredentials(context.Context, *emptypb.Empty) (*DockerCredentials, error)
	Login(context.Context, *LoginRequest) (*LoginResponse, error)
	GetCertificate(context.Context, *emptypb.Empty) (*Certificate, error)
	Logout(context.Context, *Token) (*Ack, error)
	CreateUser(context.Context, *CreateUserRequest) (*UserId, error)
	ListUsers(context.Context, *emptypb.Empty) (*UsersList, error)
	DeleteUser(context.Context, *UserId) (*Ack, error)
	UpdateUser(context.Context, *User) (*Ack, error)
	ChangePassword(context.Context, *ChangePasswordRequest) (*Ack, error)
	AdminResetPassword(context.Context, *AdminResetPasswordRequest) (*Ack, error)
	ListRecruiters(context.Context, *RecruiterFilter) (*RecruiterList, error)
	CreateRecruiter(context.Context, *Recruiter) (*Ack, error)
	UpdateRecruiter(context.Context, *RecruiterUpdate) (*Ack, error)
	DeleteRecruiter(context.Context, *RecruiterId) (*Ack, error)
	ListWorkflows(context.Context, *WorkflowFilter) (*WorkflowList, error)
	CreateWorkflow(context.Context, *WorkflowRequest) (*WorkflowId, error)
	UpdateWorkflowStatus(context.Context, *WorkflowStatusUpdate) (*Ack, error)
	DeleteWorkflow(context.Context, *WorkflowId) (*Ack, error)
	// Workflow chain — template-to-template sequencing. Entries are armed
	// at parent-submit time (CreateChainEntries) and fire when the parent
	// reaches a terminal status. See specs/workflow_chain.md.
	CreateChainEntries(context.Context, *CreateChainEntriesRequest) (*ChainEntryList, error)
	ListChainEntries(context.Context, *ListChainEntriesRequest) (*ChainEntryList, error)
	GetChainEntry(context.Context, *ChainEntryId) (*ChainEntry, error)
	SuspendChainEntry(context.Context, *ChainEntryId) (*ChainEntry, error)
	ResumeChainEntry(context.Context, *ChainEntryId) (*ChainEntry, error)
	CancelChainEntry(context.Context, *ChainEntryId) (*ChainEntry, error)
	EditChainEntry(context.Context, *EditChainEntryRequest) (*ChainEntry, error)
	DebugAssignTask(context.Context, *DebugAssignRequest) (*Ack, error)
	DebugRecruitStep(context.Context, *DebugRecruitRequest) (*Ack, error)
	DebugRetryTask(context.Context, *RetryTaskRequest) (*TaskResponse, error)
	ListDependentPendingTasks(context.Context, *TaskId) (*TaskIds, error)
	ListSteps(context.Context, *StepFilter) (*StepList, error)
	CreateStep(context.Context, *StepRequest) (*StepId, error)
	DeleteStep(context.Context, *StepId) (*Ack, error)
	GetStepStats(context.Context, *StepStatsRequest) (*StepStatsResponse, error)
	GetWorkerStats(context.Context, *GetWorkerStatsRequest) (*GetWorkerStatsResponse, error)
	FetchList(context.Context, *FetchListRequest) (*FetchListResponse, error)
	FetchInfo(context.Context, *FetchListRequest) (*FetchInfoResponse, error)
	// Template system
	UploadTemplate(context.Context, *UploadTemplateRequest) (*UploadTemplateResponse, error)
	DownloadTemplate(context.Context, *DownloadTemplateRequest) (*FileContent, error)
	RunTemplate(context.Context, *RunTemplateRequest) (*TemplateRun, error)
	ListTemplates(context.Context, *TemplateFilter) (*TemplateList, error)
	UpdateTemplate(context.Context, *UpdateTemplateRequest) (*Template, error)
	ListTemplateRuns(context.Context, *TemplateRunFilter) (*TemplateRunList, error)
	UpdateTemplateRun(context.Context, *UpdateTemplateRunRequest) (*Ack, error)
	DeleteTemplateRun(context.Context, *DeleteTemplateRunRequest) (*Ack, error)
	// Register a local run (python script that doesn't come from an uploaded
	// template). Creates a template_run row with a NULL workflow_template_id
	// and records script identity so "what launched this workflow?" stays
	// answerable. The returned template_run_id should be set on
	// UpdateTemplateRun once the workflow is created (same flow as
	// server-launched templates).
	RegisterAdhocRun(context.Context, *RegisterAdhocRunRequest) (*TemplateRun, error)
	// Module system
	UploadModule(context.Context, *UploadModuleRequest) (*Ack, error)
	ListModules(context.Context, *emptypb.Empty) (*ModuleList, error)
	ListModulesFiltered(context.Context, *ModuleListFilter) (*ModuleList, error)
	DownloadModule(context.Context, *DownloadModuleRequest) (*FileContent, error)
	DeleteModule(context.Context, *DeleteModuleRequest) (*Ack, error)
	UpgradeBundledModules(context.Context, *UpgradeBundledModulesRequest) (*UpgradeBundledModulesResponse, error)
	GetModuleOrigin(context.Context, *ModuleOriginRequest) (*ModuleOriginResponse, error)
	ForkModule(context.Context, *ForkModuleRequest) (*Ack, error)
	GetWorkspaceRoot(context.Context, *WorkspaceRootRequest) (*WorkspaceRootResponse, error)
	GetResourceRoot(context.Context, *WorkspaceRootRequest) (*WorkspaceRootResponse, error)
	RegisterSpecifications(context.Context, *ResourceSpec) (*Ack, error)
	// Worker events
	ReportWorkerEvent(context.Context, *WorkerEvent) (*Ack, error)
	ListWorkerEvents(context.Context, *WorkerEventFilter) (*WorkerEventList, error)
	DeleteWorkerEvent(context.Context, *WorkerEventId) (*Ack, error)
	PruneWorkerEvents(context.Context, *WorkerEventPruneFilter) (*WorkerEventPruneResult, error)
	GetTaskStatusCounts(context.Context, *TaskStatusCountsRequest) (*TaskStatusCountsResponse, error)
	SignalTask(context.Context, *TaskSignalRequest) (*Ack, error)
	// Returns the server's own build identity so callers (CLI, worker) can
	// detect a version mismatch. Cheap, unauthenticated lookup — version
	// info is not a secret. See specs/worker_autoupgrade.md (Phase I).
	ServerVersion(context.Context, *emptypb.Empty) (*ServerVersionResponse, error)
	// Operator-triggered worker upgrade. Sets worker.upgrade_requested
	// for the given workers; the worker reads the column from its next
	// ping response and acts (idle-wait or drain). See
	// specs/worker_autoupgrade.md (Phase II).
	RequestWorkerUpgrade(context.Context, *WorkerUpgradeRequest) (*WorkerUpgradeReply, error)
	// Returns the URL the worker should download a fresh client binary
	// from (and the matching sha256 sibling URL). Both URLs already
	// include the auth token in their query string. Authenticated.
	// See specs/worker_autoupgrade.md (Phase II).
	GetClientUpgradeInfo(context.Context, *emptypb.Empty) (*ClientUpgradeInfo, error)
	// contains filtered or unexported methods
}

TaskQueueServer is the server API for TaskQueue service. All implementations must embed UnimplementedTaskQueueServer for forward compatibility.

type TaskQueue_SendTaskLogsClient

type TaskQueue_SendTaskLogsClient = grpc.ClientStreamingClient[TaskLog, Ack]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskQueue_SendTaskLogsServer

type TaskQueue_SendTaskLogsServer = grpc.ClientStreamingServer[TaskLog, Ack]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskQueue_StreamTaskLogsErrClient

type TaskQueue_StreamTaskLogsErrClient = grpc.ServerStreamingClient[TaskLog]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskQueue_StreamTaskLogsErrServer

type TaskQueue_StreamTaskLogsErrServer = grpc.ServerStreamingServer[TaskLog]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskQueue_StreamTaskLogsOutputClient

type TaskQueue_StreamTaskLogsOutputClient = grpc.ServerStreamingClient[TaskLog]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskQueue_StreamTaskLogsOutputServer

type TaskQueue_StreamTaskLogsOutputServer = grpc.ServerStreamingServer[TaskLog]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskRequest

type TaskRequest struct {
	Command          string   `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Shell            *string  `protobuf:"bytes,2,opt,name=shell,proto3,oneof" json:"shell,omitempty"`
	Container        string   `protobuf:"bytes,3,opt,name=container,proto3" json:"container,omitempty"`
	ContainerOptions *string  `protobuf:"bytes,4,opt,name=container_options,json=containerOptions,proto3,oneof" json:"container_options,omitempty"`
	StepId           *int32   `protobuf:"varint,5,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
	Input            []string `protobuf:"bytes,6,rep,name=input,proto3" json:"input,omitempty"`
	Resource         []string `protobuf:"bytes,7,rep,name=resource,proto3" json:"resource,omitempty"`
	Output           *string  `protobuf:"bytes,8,opt,name=output,proto3,oneof" json:"output,omitempty"`
	Retry            *int32   `protobuf:"varint,9,opt,name=retry,proto3,oneof" json:"retry,omitempty"`
	IsFinal          *bool    `protobuf:"varint,10,opt,name=is_final,json=isFinal,proto3,oneof" json:"is_final,omitempty"`
	UsesCache        *bool    `protobuf:"varint,11,opt,name=uses_cache,json=usesCache,proto3,oneof" json:"uses_cache,omitempty"`
	DownloadTimeout  *float32 `protobuf:"fixed32,12,opt,name=download_timeout,json=downloadTimeout,proto3,oneof" json:"download_timeout,omitempty"`
	RunningTimeout   *float32 `protobuf:"fixed32,13,opt,name=running_timeout,json=runningTimeout,proto3,oneof" json:"running_timeout,omitempty"`
	UploadTimeout    *float32 `protobuf:"fixed32,14,opt,name=upload_timeout,json=uploadTimeout,proto3,oneof" json:"upload_timeout,omitempty"`
	Status           string   `protobuf:"bytes,15,opt,name=status,proto3" json:"status,omitempty"`
	Dependency       []int32  `protobuf:"varint,16,rep,packed,name=dependency,proto3" json:"dependency,omitempty"` // IDs of tasks that this task depends on
	TaskName         *string  `protobuf:"bytes,17,opt,name=task_name,json=taskName,proto3,oneof" json:"task_name,omitempty"`
	SkipIfExists     bool     `protobuf:"varint,18,opt,name=skip_if_exists,json=skipIfExists,proto3" json:"skip_if_exists,omitempty"`
	AcceptFailure    bool     `protobuf:"varint,19,opt,name=accept_failure,json=acceptFailure,proto3" json:"accept_failure,omitempty"`    // If true, dependencies accept failed prerequisites
	Publish          *string  `protobuf:"bytes,20,opt,name=publish,proto3,oneof" json:"publish,omitempty"`                                // Publish path (copied from output on success only)
	ReuseKey         *string  `protobuf:"bytes,21,opt,name=reuse_key,json=reuseKey,proto3,oneof" json:"reuse_key,omitempty"`              // SHA-256 hex for opportunistic reuse — producer side: always set when content is reuse-eligible (step not untrusted)
	ConsumeReuse     *bool    `protobuf:"varint,22,opt,name=consume_reuse,json=consumeReuse,proto3,oneof" json:"consume_reuse,omitempty"` // If true, server may reuse a cached result for this task (consumer side, set from workflow-level `opportunistic` flag)
	// Opt-in: when true, the worker injects SCITQ_SERVER + SCITQ_TOKEN env
	// vars into the task and (for docker tasks) bind-mounts the worker's
	// scitq CLI into the container at /usr/local/bin/scitq. Lets the task
	// call `scitq file copy <src> <dst>` for moves that scitq's native
	// publish mechanism can't express (e.g. two different destinations per
	// file, asymmetric path layouts). Default false — most tasks never
	// need it. Token shape today: the worker's own auth token (the same
	// token the worker uses for its own RPCs), inherited by the task.
	ScitqAuth *bool `protobuf:"varint,23,opt,name=scitq_auth,json=scitqAuth,proto3,oneof" json:"scitq_auth,omitempty"`
	// NUMA binding: number of NUMA nodes the task should be pinned to on
	// the worker. Unset = NUMA-unaware (current behavior). 1 = the
	// common case (one task per node). N > 1 = task spans N adjacent
	// nodes. The worker translates this into `--cpuset-cpus` /
	// `--cpuset-mems` on the docker run. Mutually exclusive with
	// task_spec.cpu and task_spec.mem in the DSL — concurrency and
	// per-task budget are derived from the topology.
	Numa *int32 `protobuf:"varint,24,opt,name=numa,proto3,oneof" json:"numa,omitempty"`
	// Per-task minimum resource requirements (spec: addition_from_nextflow.md A).
	// When the step's task_spec declares a list curve (e.g. `mem: [40, 80, 160]`),
	// the initial submission carries curve[0] here; on retry the server-side
	// retry-decision logic shifts these to curve[attempt] so the assignment
	// & recruitment paths see the heavier requirement. Unset = inherit from
	// the step's task_spec defaults (today's behaviour, no per-task override).
	MinCpu  *float32 `protobuf:"fixed32,25,opt,name=min_cpu,json=minCpu,proto3,oneof" json:"min_cpu,omitempty"`    // minimum cpu cores per task (also drives weight)
	MinMem  *float32 `protobuf:"fixed32,26,opt,name=min_mem,json=minMem,proto3,oneof" json:"min_mem,omitempty"`    // minimum GB of memory per task
	MinDisk *float32 `protobuf:"fixed32,27,opt,name=min_disk,json=minDisk,proto3,oneof" json:"min_disk,omitempty"` // minimum GB of disk per task
	// Per-attempt resource curve. The full list the workflow author declared
	// in `task_spec.cpu/mem/disk: [...]`. Empty = no curve (scalar resource).
	// The server keeps it on the task so the retry-decision path can look up
	// curve[attempt] without joining back to the step's recruiter.
	CpuCurve  []float32 `protobuf:"fixed32,28,rep,packed,name=cpu_curve,json=cpuCurve,proto3" json:"cpu_curve,omitempty"`
	MemCurve  []float32 `protobuf:"fixed32,29,rep,packed,name=mem_curve,json=memCurve,proto3" json:"mem_curve,omitempty"`
	DiskCurve []float32 `protobuf:"fixed32,30,rep,packed,name=disk_curve,json=diskCurve,proto3" json:"disk_curve,omitempty"`
	// Publish mode: "move" (default — successful task uploads to publish
	// *instead of* the workspace) or "copy" (uploads to *both*, so a
	// downstream consumer can still read from the workspace while the
	// results bucket also gets the artefacts). Empty = move. Only
	// meaningful when `publish` is set. Spec: addition_from_nextflow.md B.
	PublishMode *string `protobuf:"bytes,31,opt,name=publish_mode,json=publishMode,proto3,oneof" json:"publish_mode,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskRequest) Descriptor deprecated

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

Deprecated: Use TaskRequest.ProtoReflect.Descriptor instead.

func (*TaskRequest) GetAcceptFailure added in v0.7.1

func (x *TaskRequest) GetAcceptFailure() bool

func (*TaskRequest) GetCommand

func (x *TaskRequest) GetCommand() string

func (*TaskRequest) GetConsumeReuse added in v0.7.8

func (x *TaskRequest) GetConsumeReuse() bool

func (*TaskRequest) GetContainer

func (x *TaskRequest) GetContainer() string

func (*TaskRequest) GetContainerOptions

func (x *TaskRequest) GetContainerOptions() string

func (*TaskRequest) GetCpuCurve added in v0.8.5

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

func (*TaskRequest) GetDependency

func (x *TaskRequest) GetDependency() []int32

func (*TaskRequest) GetDiskCurve added in v0.8.5

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

func (*TaskRequest) GetDownloadTimeout

func (x *TaskRequest) GetDownloadTimeout() float32

func (*TaskRequest) GetInput

func (x *TaskRequest) GetInput() []string

func (*TaskRequest) GetIsFinal

func (x *TaskRequest) GetIsFinal() bool

func (*TaskRequest) GetMemCurve added in v0.8.5

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

func (*TaskRequest) GetMinCpu added in v0.8.5

func (x *TaskRequest) GetMinCpu() float32

func (*TaskRequest) GetMinDisk added in v0.8.5

func (x *TaskRequest) GetMinDisk() float32

func (*TaskRequest) GetMinMem added in v0.8.5

func (x *TaskRequest) GetMinMem() float32

func (*TaskRequest) GetNuma added in v0.8.5

func (x *TaskRequest) GetNuma() int32

func (*TaskRequest) GetOutput

func (x *TaskRequest) GetOutput() string

func (*TaskRequest) GetPublish added in v0.7.1

func (x *TaskRequest) GetPublish() string

func (*TaskRequest) GetPublishMode added in v0.8.5

func (x *TaskRequest) GetPublishMode() string

func (*TaskRequest) GetResource

func (x *TaskRequest) GetResource() []string

func (*TaskRequest) GetRetry

func (x *TaskRequest) GetRetry() int32

func (*TaskRequest) GetReuseKey added in v0.7.2

func (x *TaskRequest) GetReuseKey() string

func (*TaskRequest) GetRunningTimeout

func (x *TaskRequest) GetRunningTimeout() float32

func (*TaskRequest) GetScitqAuth added in v0.8.5

func (x *TaskRequest) GetScitqAuth() bool

func (*TaskRequest) GetShell

func (x *TaskRequest) GetShell() string

func (*TaskRequest) GetSkipIfExists added in v0.7.1

func (x *TaskRequest) GetSkipIfExists() bool

func (*TaskRequest) GetStatus

func (x *TaskRequest) GetStatus() string

func (*TaskRequest) GetStepId

func (x *TaskRequest) GetStepId() int32

func (*TaskRequest) GetTaskName

func (x *TaskRequest) GetTaskName() string

func (*TaskRequest) GetUploadTimeout

func (x *TaskRequest) GetUploadTimeout() float32

func (*TaskRequest) GetUsesCache

func (x *TaskRequest) GetUsesCache() bool

func (*TaskRequest) ProtoMessage

func (*TaskRequest) ProtoMessage()

func (*TaskRequest) ProtoReflect

func (x *TaskRequest) ProtoReflect() protoreflect.Message

func (*TaskRequest) Reset

func (x *TaskRequest) Reset()

func (*TaskRequest) String

func (x *TaskRequest) String() string

type TaskResponse

type TaskResponse struct {
	TaskId int32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResponse) Descriptor deprecated

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

Deprecated: Use TaskResponse.ProtoReflect.Descriptor instead.

func (*TaskResponse) GetTaskId

func (x *TaskResponse) GetTaskId() int32

func (*TaskResponse) ProtoMessage

func (*TaskResponse) ProtoMessage()

func (*TaskResponse) ProtoReflect

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

func (*TaskResponse) Reset

func (x *TaskResponse) Reset()

func (*TaskResponse) String

func (x *TaskResponse) String() string

type TaskSignal added in v0.7.2

type TaskSignal struct {
	TaskId      int32  `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Signal      string `protobuf:"bytes,2,opt,name=signal,proto3" json:"signal,omitempty"`                                     // "K" = SIGKILL (docker kill), "T" = SIGTERM (docker stop)
	GracePeriod *int32 `protobuf:"varint,3,opt,name=grace_period,json=gracePeriod,proto3,oneof" json:"grace_period,omitempty"` // seconds before SIGKILL after SIGTERM (default: 10)
	// contains filtered or unexported fields
}

func (*TaskSignal) Descriptor deprecated added in v0.7.2

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

Deprecated: Use TaskSignal.ProtoReflect.Descriptor instead.

func (*TaskSignal) GetGracePeriod added in v0.7.2

func (x *TaskSignal) GetGracePeriod() int32

func (*TaskSignal) GetSignal added in v0.7.2

func (x *TaskSignal) GetSignal() string

func (*TaskSignal) GetTaskId added in v0.7.2

func (x *TaskSignal) GetTaskId() int32

func (*TaskSignal) ProtoMessage added in v0.7.2

func (*TaskSignal) ProtoMessage()

func (*TaskSignal) ProtoReflect added in v0.7.2

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

func (*TaskSignal) Reset added in v0.7.2

func (x *TaskSignal) Reset()

func (*TaskSignal) String added in v0.7.2

func (x *TaskSignal) String() string

type TaskSignalRequest added in v0.7.2

type TaskSignalRequest struct {
	TaskId      int32  `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Signal      string `protobuf:"bytes,2,opt,name=signal,proto3" json:"signal,omitempty"`                                     // "K" for kill, "T" for terminate (SIGTERM)
	GracePeriod *int32 `protobuf:"varint,3,opt,name=grace_period,json=gracePeriod,proto3,oneof" json:"grace_period,omitempty"` // seconds before SIGKILL after SIGTERM (default: 10)
	// contains filtered or unexported fields
}

func (*TaskSignalRequest) Descriptor deprecated added in v0.7.2

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

Deprecated: Use TaskSignalRequest.ProtoReflect.Descriptor instead.

func (*TaskSignalRequest) GetGracePeriod added in v0.7.2

func (x *TaskSignalRequest) GetGracePeriod() int32

func (*TaskSignalRequest) GetSignal added in v0.7.2

func (x *TaskSignalRequest) GetSignal() string

func (*TaskSignalRequest) GetTaskId added in v0.7.2

func (x *TaskSignalRequest) GetTaskId() int32

func (*TaskSignalRequest) ProtoMessage added in v0.7.2

func (*TaskSignalRequest) ProtoMessage()

func (*TaskSignalRequest) ProtoReflect added in v0.7.2

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

func (*TaskSignalRequest) Reset added in v0.7.2

func (x *TaskSignalRequest) Reset()

func (*TaskSignalRequest) String added in v0.7.2

func (x *TaskSignalRequest) String() string

type TaskStatusCountsRequest added in v0.6.1

type TaskStatusCountsRequest struct {
	ShowHidden *bool `protobuf:"varint,1,opt,name=show_hidden,json=showHidden,proto3,oneof" json:"show_hidden,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskStatusCountsRequest) Descriptor deprecated added in v0.6.1

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

Deprecated: Use TaskStatusCountsRequest.ProtoReflect.Descriptor instead.

func (*TaskStatusCountsRequest) GetShowHidden added in v0.6.1

func (x *TaskStatusCountsRequest) GetShowHidden() bool

func (*TaskStatusCountsRequest) ProtoMessage added in v0.6.1

func (*TaskStatusCountsRequest) ProtoMessage()

func (*TaskStatusCountsRequest) ProtoReflect added in v0.6.1

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

func (*TaskStatusCountsRequest) Reset added in v0.6.1

func (x *TaskStatusCountsRequest) Reset()

func (*TaskStatusCountsRequest) String added in v0.6.1

func (x *TaskStatusCountsRequest) String() string

type TaskStatusCountsResponse added in v0.6.1

type TaskStatusCountsResponse struct {
	GlobalCounts    []*StatusCountEntry `protobuf:"bytes,1,rep,name=global_counts,json=globalCounts,proto3" json:"global_counts,omitempty"`
	PerWorkerCounts []*StatusCountEntry `protobuf:"bytes,2,rep,name=per_worker_counts,json=perWorkerCounts,proto3" json:"per_worker_counts,omitempty"`
	TotalCount      int32               `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskStatusCountsResponse) Descriptor deprecated added in v0.6.1

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

Deprecated: Use TaskStatusCountsResponse.ProtoReflect.Descriptor instead.

func (*TaskStatusCountsResponse) GetGlobalCounts added in v0.6.1

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

func (*TaskStatusCountsResponse) GetPerWorkerCounts added in v0.6.1

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

func (*TaskStatusCountsResponse) GetTotalCount added in v0.6.1

func (x *TaskStatusCountsResponse) GetTotalCount() int32

func (*TaskStatusCountsResponse) ProtoMessage added in v0.6.1

func (*TaskStatusCountsResponse) ProtoMessage()

func (*TaskStatusCountsResponse) ProtoReflect added in v0.6.1

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

func (*TaskStatusCountsResponse) Reset added in v0.6.1

func (x *TaskStatusCountsResponse) Reset()

func (*TaskStatusCountsResponse) String added in v0.6.1

func (x *TaskStatusCountsResponse) String() string

type TaskStatusUpdate

type TaskStatusUpdate struct {
	TaskId    int32  `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	NewStatus string `protobuf:"bytes,2,opt,name=new_status,json=newStatus,proto3" json:"new_status,omitempty"`
	Duration  *int32 `protobuf:"varint,3,opt,name=duration,proto3,oneof" json:"duration,omitempty"`                    // in seconds
	FreeRetry *bool  `protobuf:"varint,4,opt,name=free_retry,json=freeRetry,proto3,oneof" json:"free_retry,omitempty"` // if new_status is F and this is true, then retry is increased by 1 before setting status to F
	// Failure classification (spec: addition_from_nextflow.md A). Set when
	// new_status is "F". Controls whether the retry-decision logic should
	// advance the step's resource-escalation curve. The worker reports
	// OOM (docker exit 137), timeout (exceeded running_timeout), and
	// explicit-error / unknown ("other"). Eviction / worker-disappeared
	// failures are server-declared — the worker is gone by definition —
	// and the server tags the task with failure_class="eviction" directly
	// when reaping orphaned tasks. Empty / unset is treated the same as
	// "other" by downstream logic. Recognised values:
	//
	//	"oom"      — out-of-memory kill (docker exit 137 / OOMKilled)
	//	"timeout"  — exceeded running_timeout / upload_timeout / download_timeout
	//	"eviction" — server-declared (spot preempt, manual worker delete,
	//	             worker watchdog reaped)
	//	"network"  — transient connectivity failure (uploads, downloads)
	//	"other"    — anything else (script exit non-zero, segfault, …)
	FailureClass *string `protobuf:"bytes,5,opt,name=failure_class,json=failureClass,proto3,oneof" json:"failure_class,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskStatusUpdate) Descriptor deprecated

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

Deprecated: Use TaskStatusUpdate.ProtoReflect.Descriptor instead.

func (*TaskStatusUpdate) GetDuration

func (x *TaskStatusUpdate) GetDuration() int32

func (*TaskStatusUpdate) GetFailureClass added in v0.8.5

func (x *TaskStatusUpdate) GetFailureClass() string

func (*TaskStatusUpdate) GetFreeRetry

func (x *TaskStatusUpdate) GetFreeRetry() bool

func (*TaskStatusUpdate) GetNewStatus

func (x *TaskStatusUpdate) GetNewStatus() string

func (*TaskStatusUpdate) GetTaskId

func (x *TaskStatusUpdate) GetTaskId() int32

func (*TaskStatusUpdate) ProtoMessage

func (*TaskStatusUpdate) ProtoMessage()

func (*TaskStatusUpdate) ProtoReflect

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

func (*TaskStatusUpdate) Reset

func (x *TaskStatusUpdate) Reset()

func (*TaskStatusUpdate) String

func (x *TaskStatusUpdate) String() string

type TaskUpdate

type TaskUpdate struct {
	Weight float64 `protobuf:"fixed64,1,opt,name=weight,proto3" json:"weight,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskUpdate) Descriptor deprecated

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

Deprecated: Use TaskUpdate.ProtoReflect.Descriptor instead.

func (*TaskUpdate) GetWeight

func (x *TaskUpdate) GetWeight() float64

func (*TaskUpdate) ProtoMessage

func (*TaskUpdate) ProtoMessage()

func (*TaskUpdate) ProtoReflect

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

func (*TaskUpdate) Reset

func (x *TaskUpdate) Reset()

func (*TaskUpdate) String

func (x *TaskUpdate) String() string

type TaskUpdateList

type TaskUpdateList struct {
	Updates map[int32]*TaskUpdate `` // optional — can be empty
	/* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskUpdateList) Descriptor deprecated

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

Deprecated: Use TaskUpdateList.ProtoReflect.Descriptor instead.

func (*TaskUpdateList) GetUpdates

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

func (*TaskUpdateList) ProtoMessage

func (*TaskUpdateList) ProtoMessage()

func (*TaskUpdateList) ProtoReflect

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

func (*TaskUpdateList) Reset

func (x *TaskUpdateList) Reset()

func (*TaskUpdateList) String

func (x *TaskUpdateList) String() string

type Template

type Template struct {
	WorkflowTemplateId int32  `protobuf:"varint,1,opt,name=workflow_template_id,json=workflowTemplateId,proto3" json:"workflow_template_id,omitempty"`
	Name               string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version            string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Description        string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	ParamJson          string `protobuf:"bytes,5,opt,name=param_json,json=paramJson,proto3" json:"param_json,omitempty"`
	UploadedAt         string `protobuf:"bytes,6,opt,name=uploaded_at,json=uploadedAt,proto3" json:"uploaded_at,omitempty"`
	UploadedBy         *int32 `protobuf:"varint,7,opt,name=uploaded_by,json=uploadedBy,proto3,oneof" json:"uploaded_by,omitempty"`
	Hidden             bool   `protobuf:"varint,8,opt,name=hidden,proto3" json:"hidden,omitempty"`
	// How many versions exist for this name (counted across visible rows
	// honouring the same show_hidden filter as the listing). Populated only
	// when the server is collapsing to latest-per-name; in `all_versions`
	// mode every row is its own version, so the field stays 0/unset and
	// callers should ignore it. Used by the UI to decide whether to render
	// a "more versions" dropdown trigger.
	VersionCount int32 `protobuf:"varint,9,opt,name=version_count,json=versionCount,proto3" json:"version_count,omitempty"`
	// contains filtered or unexported fields
}

func (*Template) Descriptor deprecated

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

Deprecated: Use Template.ProtoReflect.Descriptor instead.

func (*Template) GetDescription

func (x *Template) GetDescription() string

func (*Template) GetHidden added in v0.7.7

func (x *Template) GetHidden() bool

func (*Template) GetName

func (x *Template) GetName() string

func (*Template) GetParamJson

func (x *Template) GetParamJson() string

func (*Template) GetUploadedAt

func (x *Template) GetUploadedAt() string

func (*Template) GetUploadedBy

func (x *Template) GetUploadedBy() int32

func (*Template) GetVersion

func (x *Template) GetVersion() string

func (*Template) GetVersionCount added in v0.7.7

func (x *Template) GetVersionCount() int32

func (*Template) GetWorkflowTemplateId

func (x *Template) GetWorkflowTemplateId() int32

func (*Template) ProtoMessage

func (*Template) ProtoMessage()

func (*Template) ProtoReflect

func (x *Template) ProtoReflect() protoreflect.Message

func (*Template) Reset

func (x *Template) Reset()

func (*Template) String

func (x *Template) String() string

type TemplateFilter

type TemplateFilter struct {
	WorkflowTemplateId *int32  `protobuf:"varint,1,opt,name=workflow_template_id,json=workflowTemplateId,proto3,oneof" json:"workflow_template_id,omitempty"`
	Name               *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Version            *string `protobuf:"bytes,3,opt,name=version,proto3,oneof" json:"version,omitempty"`
	// When true, return every version that matches the other filters. The
	// default (false) collapses the result to one row per name — the
	// most-recently-uploaded version. Most operators want the latest by
	// default; pass all_versions=true (or `--all-versions` on the CLI) to
	// see history for upgrades, rollbacks, and audits.
	AllVersions *bool `protobuf:"varint,4,opt,name=all_versions,json=allVersions,proto3,oneof" json:"all_versions,omitempty"`
	// When true, include hidden templates in the result. Default (false)
	// excludes them. See workflow_template.hidden (migration 24).
	ShowHidden *bool `protobuf:"varint,5,opt,name=show_hidden,json=showHidden,proto3,oneof" json:"show_hidden,omitempty"`
	// contains filtered or unexported fields
}

func (*TemplateFilter) Descriptor deprecated

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

Deprecated: Use TemplateFilter.ProtoReflect.Descriptor instead.

func (*TemplateFilter) GetAllVersions added in v0.7.7

func (x *TemplateFilter) GetAllVersions() bool

func (*TemplateFilter) GetName

func (x *TemplateFilter) GetName() string

func (*TemplateFilter) GetShowHidden added in v0.7.7

func (x *TemplateFilter) GetShowHidden() bool

func (*TemplateFilter) GetVersion

func (x *TemplateFilter) GetVersion() string

func (*TemplateFilter) GetWorkflowTemplateId

func (x *TemplateFilter) GetWorkflowTemplateId() int32

func (*TemplateFilter) ProtoMessage

func (*TemplateFilter) ProtoMessage()

func (*TemplateFilter) ProtoReflect

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

func (*TemplateFilter) Reset

func (x *TemplateFilter) Reset()

func (*TemplateFilter) String

func (x *TemplateFilter) String() string

type TemplateList

type TemplateList struct {
	Templates []*Template `protobuf:"bytes,1,rep,name=templates,proto3" json:"templates,omitempty"`
	// contains filtered or unexported fields
}

func (*TemplateList) Descriptor deprecated

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

Deprecated: Use TemplateList.ProtoReflect.Descriptor instead.

func (*TemplateList) GetTemplates

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

func (*TemplateList) ProtoMessage

func (*TemplateList) ProtoMessage()

func (*TemplateList) ProtoReflect

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

func (*TemplateList) Reset

func (x *TemplateList) Reset()

func (*TemplateList) String

func (x *TemplateList) String() string

type TemplateRun

type TemplateRun struct {
	TemplateRunId int32 `protobuf:"varint,1,opt,name=template_run_id,json=templateRunId,proto3" json:"template_run_id,omitempty"`
	// 0 = ad-hoc run (local Python script, no template uploaded). For those,
	// see script_name / script_sha256 instead.
	WorkflowTemplateId int32   `protobuf:"varint,2,opt,name=workflow_template_id,json=workflowTemplateId,proto3" json:"workflow_template_id,omitempty"`
	TemplateName       *string `protobuf:"bytes,3,opt,name=template_name,json=templateName,proto3,oneof" json:"template_name,omitempty"`
	TemplateVersion    *string `protobuf:"bytes,4,opt,name=template_version,json=templateVersion,proto3,oneof" json:"template_version,omitempty"`
	WorkflowName       *string `protobuf:"bytes,5,opt,name=workflow_name,json=workflowName,proto3,oneof" json:"workflow_name,omitempty"`
	RunBy              *int32  `protobuf:"varint,6,opt,name=run_by,json=runBy,proto3,oneof" json:"run_by,omitempty"`
	Status             string  `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"`
	WorkflowId         *int32  `protobuf:"varint,8,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
	CreatedAt          string  `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ParamValuesJson    string  `protobuf:"bytes,10,opt,name=param_values_json,json=paramValuesJson,proto3" json:"param_values_json,omitempty"`
	ErrorMessage       *string `protobuf:"bytes,11,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"`
	RunByUsername      *string `protobuf:"bytes,12,opt,name=run_by_username,json=runByUsername,proto3,oneof" json:"run_by_username,omitempty"`
	ScriptName         *string `protobuf:"bytes,13,opt,name=script_name,json=scriptName,proto3,oneof" json:"script_name,omitempty"`       // ad-hoc runs only
	ScriptSha256       *string `protobuf:"bytes,14,opt,name=script_sha256,json=scriptSha256,proto3,oneof" json:"script_sha256,omitempty"` // ad-hoc runs only
	// When this run was created by a chain firing, the parent's template_run id.
	// Mirrors workflow.parent_workflow_id at the run-record layer.
	// See specs/workflow_chain.md.
	ParentTemplateRunId *int32 `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TemplateRun) Descriptor deprecated

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

Deprecated: Use TemplateRun.ProtoReflect.Descriptor instead.

func (*TemplateRun) GetCreatedAt

func (x *TemplateRun) GetCreatedAt() string

func (*TemplateRun) GetErrorMessage

func (x *TemplateRun) GetErrorMessage() string

func (*TemplateRun) GetParamValuesJson

func (x *TemplateRun) GetParamValuesJson() string

func (*TemplateRun) GetParentTemplateRunId added in v0.8.5

func (x *TemplateRun) GetParentTemplateRunId() int32

func (*TemplateRun) GetRunBy

func (x *TemplateRun) GetRunBy() int32

func (*TemplateRun) GetRunByUsername

func (x *TemplateRun) GetRunByUsername() string

func (*TemplateRun) GetScriptName added in v0.7.5

func (x *TemplateRun) GetScriptName() string

func (*TemplateRun) GetScriptSha256 added in v0.7.5

func (x *TemplateRun) GetScriptSha256() string

func (*TemplateRun) GetStatus

func (x *TemplateRun) GetStatus() string

func (*TemplateRun) GetTemplateName

func (x *TemplateRun) GetTemplateName() string

func (*TemplateRun) GetTemplateRunId

func (x *TemplateRun) GetTemplateRunId() int32

func (*TemplateRun) GetTemplateVersion

func (x *TemplateRun) GetTemplateVersion() string

func (*TemplateRun) GetWorkflowId

func (x *TemplateRun) GetWorkflowId() int32

func (*TemplateRun) GetWorkflowName

func (x *TemplateRun) GetWorkflowName() string

func (*TemplateRun) GetWorkflowTemplateId

func (x *TemplateRun) GetWorkflowTemplateId() int32

func (*TemplateRun) ProtoMessage

func (*TemplateRun) ProtoMessage()

func (*TemplateRun) ProtoReflect

func (x *TemplateRun) ProtoReflect() protoreflect.Message

func (*TemplateRun) Reset

func (x *TemplateRun) Reset()

func (*TemplateRun) String

func (x *TemplateRun) String() string

type TemplateRunFilter

type TemplateRunFilter struct {
	WorkflowTemplateId *int32 `protobuf:"varint,1,opt,name=workflow_template_id,json=workflowTemplateId,proto3,oneof" json:"workflow_template_id,omitempty"`
	TemplateRunId      *int32 `protobuf:"varint,2,opt,name=template_run_id,json=templateRunId,proto3,oneof" json:"template_run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TemplateRunFilter) Descriptor deprecated

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

Deprecated: Use TemplateRunFilter.ProtoReflect.Descriptor instead.

func (*TemplateRunFilter) GetTemplateRunId added in v0.8.2

func (x *TemplateRunFilter) GetTemplateRunId() int32

func (*TemplateRunFilter) GetWorkflowTemplateId

func (x *TemplateRunFilter) GetWorkflowTemplateId() int32

func (*TemplateRunFilter) ProtoMessage

func (*TemplateRunFilter) ProtoMessage()

func (*TemplateRunFilter) ProtoReflect

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

func (*TemplateRunFilter) Reset

func (x *TemplateRunFilter) Reset()

func (*TemplateRunFilter) String

func (x *TemplateRunFilter) String() string

type TemplateRunList

type TemplateRunList struct {
	Runs []*TemplateRun `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
	// contains filtered or unexported fields
}

func (*TemplateRunList) Descriptor deprecated

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

Deprecated: Use TemplateRunList.ProtoReflect.Descriptor instead.

func (*TemplateRunList) GetRuns

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

func (*TemplateRunList) ProtoMessage

func (*TemplateRunList) ProtoMessage()

func (*TemplateRunList) ProtoReflect

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

func (*TemplateRunList) Reset

func (x *TemplateRunList) Reset()

func (*TemplateRunList) String

func (x *TemplateRunList) String() string

type Token

type Token struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*Token) Descriptor deprecated

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

Deprecated: Use Token.ProtoReflect.Descriptor instead.

func (*Token) GetToken

func (x *Token) GetToken() string

func (*Token) ProtoMessage

func (*Token) ProtoMessage()

func (*Token) ProtoReflect

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

func (*Token) Reset

func (x *Token) Reset()

func (*Token) String

func (x *Token) String() string

type UnimplementedTaskQueueServer

type UnimplementedTaskQueueServer struct{}

UnimplementedTaskQueueServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTaskQueueServer) AdminResetPassword added in v0.7.1

func (UnimplementedTaskQueueServer) CancelChainEntry added in v0.8.5

func (UnimplementedTaskQueueServer) ChangePassword

func (UnimplementedTaskQueueServer) CreateChainEntries added in v0.8.5

func (UnimplementedTaskQueueServer) CreateFlavor

func (UnimplementedTaskQueueServer) CreateRecruiter

func (UnimplementedTaskQueueServer) CreateStep

func (UnimplementedTaskQueueServer) CreateUser

func (UnimplementedTaskQueueServer) CreateWorker

func (UnimplementedTaskQueueServer) CreateWorkerByName added in v0.7.1

func (UnimplementedTaskQueueServer) CreateWorkflow

func (UnimplementedTaskQueueServer) DebugAssignTask

func (UnimplementedTaskQueueServer) DebugRecruitStep

func (UnimplementedTaskQueueServer) DebugRetryTask

func (UnimplementedTaskQueueServer) DeleteJob

func (UnimplementedTaskQueueServer) DeleteModule added in v0.8.5

func (UnimplementedTaskQueueServer) DeleteRecruiter

func (UnimplementedTaskQueueServer) DeleteStep

func (UnimplementedTaskQueueServer) DeleteTemplateRun

func (UnimplementedTaskQueueServer) DeleteUser

func (UnimplementedTaskQueueServer) DeleteWorker

func (UnimplementedTaskQueueServer) DeleteWorkerEvent

func (UnimplementedTaskQueueServer) DeleteWorkflow

func (UnimplementedTaskQueueServer) DownloadModule added in v0.7.1

func (UnimplementedTaskQueueServer) DownloadTemplate added in v0.7.1

func (UnimplementedTaskQueueServer) EditAndRetryTask added in v0.7.1

func (UnimplementedTaskQueueServer) EditChainEntry added in v0.8.5

func (UnimplementedTaskQueueServer) EditStepCommand added in v0.7.1

func (UnimplementedTaskQueueServer) EditTask added in v0.7.7

func (UnimplementedTaskQueueServer) FetchInfo

func (UnimplementedTaskQueueServer) FetchList

func (UnimplementedTaskQueueServer) ForceRunTask added in v0.7.1

func (UnimplementedTaskQueueServer) ForkModule added in v0.7.5

func (UnimplementedTaskQueueServer) GetCertificate

func (UnimplementedTaskQueueServer) GetChainEntry added in v0.8.5

func (UnimplementedTaskQueueServer) GetClientUpgradeInfo added in v0.8.1

func (UnimplementedTaskQueueServer) GetDockerCredentials

func (UnimplementedTaskQueueServer) GetJobStatuses

func (UnimplementedTaskQueueServer) GetLogsChunk

func (UnimplementedTaskQueueServer) GetModuleOrigin added in v0.7.5

func (UnimplementedTaskQueueServer) GetRcloneConfig

func (UnimplementedTaskQueueServer) GetResourceRoot added in v0.7.1

func (UnimplementedTaskQueueServer) GetStepStats

func (UnimplementedTaskQueueServer) GetTask added in v0.8.5

func (UnimplementedTaskQueueServer) GetTaskStatusCounts added in v0.6.1

func (UnimplementedTaskQueueServer) GetWorkerStats

func (UnimplementedTaskQueueServer) GetWorkerStatuses

func (UnimplementedTaskQueueServer) GetWorkspaceRoot

func (UnimplementedTaskQueueServer) ListChainEntries added in v0.8.5

func (UnimplementedTaskQueueServer) ListDependentPendingTasks

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

func (UnimplementedTaskQueueServer) ListFlavors

func (UnimplementedTaskQueueServer) ListJobs

func (UnimplementedTaskQueueServer) ListModules added in v0.7.1

func (UnimplementedTaskQueueServer) ListModulesFiltered added in v0.7.5

func (UnimplementedTaskQueueServer) ListProviders

func (UnimplementedTaskQueueServer) ListRecruiters

func (UnimplementedTaskQueueServer) ListRegions

func (UnimplementedTaskQueueServer) ListSteps

func (UnimplementedTaskQueueServer) ListTasks

func (UnimplementedTaskQueueServer) ListTemplateRuns

func (UnimplementedTaskQueueServer) ListTemplates

func (UnimplementedTaskQueueServer) ListUsers

func (UnimplementedTaskQueueServer) ListWorkerEvents

func (UnimplementedTaskQueueServer) ListWorkers

func (UnimplementedTaskQueueServer) ListWorkflows

func (UnimplementedTaskQueueServer) Login

func (UnimplementedTaskQueueServer) Logout

func (UnimplementedTaskQueueServer) PingAndTakeNewTasks

func (UnimplementedTaskQueueServer) PruneWorkerEvents

func (UnimplementedTaskQueueServer) RegisterAdhocRun added in v0.7.5

func (UnimplementedTaskQueueServer) RegisterSpecifications

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

func (UnimplementedTaskQueueServer) RegisterWorker

func (UnimplementedTaskQueueServer) ReportWorkerEvent

func (UnimplementedTaskQueueServer) RequestWorkerUpgrade added in v0.8.1

func (UnimplementedTaskQueueServer) ResumeChainEntry added in v0.8.5

func (UnimplementedTaskQueueServer) RetryTask

func (UnimplementedTaskQueueServer) RunTemplate

func (UnimplementedTaskQueueServer) SendTaskLogs

func (UnimplementedTaskQueueServer) ServerVersion added in v0.8.1

func (UnimplementedTaskQueueServer) SetFlavorAvailability added in v0.8.1

func (UnimplementedTaskQueueServer) SignalTask added in v0.7.2

func (UnimplementedTaskQueueServer) StreamTaskLogsErr

func (UnimplementedTaskQueueServer) StreamTaskLogsOutput

func (UnimplementedTaskQueueServer) SubmitTask

func (UnimplementedTaskQueueServer) SuspendChainEntry added in v0.8.5

func (UnimplementedTaskQueueServer) UpdateJob

func (UnimplementedTaskQueueServer) UpdateRecruiter

func (UnimplementedTaskQueueServer) UpdateTaskStatus

func (UnimplementedTaskQueueServer) UpdateTemplate added in v0.7.7

func (UnimplementedTaskQueueServer) UpdateTemplateRun

func (UnimplementedTaskQueueServer) UpdateUser

func (UnimplementedTaskQueueServer) UpdateWorker

func (UnimplementedTaskQueueServer) UpdateWorkerStatus

func (UnimplementedTaskQueueServer) UpdateWorkflowStatus

func (UnimplementedTaskQueueServer) UpgradeBundledModules added in v0.7.5

func (UnimplementedTaskQueueServer) UploadModule added in v0.7.1

func (UnimplementedTaskQueueServer) UploadTemplate

func (UnimplementedTaskQueueServer) UserUpdateWorker

type UnsafeTaskQueueServer

type UnsafeTaskQueueServer interface {
	// contains filtered or unexported methods
}

UnsafeTaskQueueServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskQueueServer will result in compilation errors.

type UpdateTemplateRequest added in v0.7.7

type UpdateTemplateRequest struct {
	WorkflowTemplateId int32 `protobuf:"varint,1,opt,name=workflow_template_id,json=workflowTemplateId,proto3" json:"workflow_template_id,omitempty"`
	Hidden             *bool `protobuf:"varint,2,opt,name=hidden,proto3,oneof" json:"hidden,omitempty"`
	// contains filtered or unexported fields
}

UpdateTemplateRequest carries an in-place edit of a workflow_template row. Currently only `hidden` is mutable — uploads still go through UploadTemplate which validates the script and bumps the version.

func (*UpdateTemplateRequest) Descriptor deprecated added in v0.7.7

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

Deprecated: Use UpdateTemplateRequest.ProtoReflect.Descriptor instead.

func (*UpdateTemplateRequest) GetHidden added in v0.7.7

func (x *UpdateTemplateRequest) GetHidden() bool

func (*UpdateTemplateRequest) GetWorkflowTemplateId added in v0.7.7

func (x *UpdateTemplateRequest) GetWorkflowTemplateId() int32

func (*UpdateTemplateRequest) ProtoMessage added in v0.7.7

func (*UpdateTemplateRequest) ProtoMessage()

func (*UpdateTemplateRequest) ProtoReflect added in v0.7.7

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

func (*UpdateTemplateRequest) Reset added in v0.7.7

func (x *UpdateTemplateRequest) Reset()

func (*UpdateTemplateRequest) String added in v0.7.7

func (x *UpdateTemplateRequest) String() string

type UpdateTemplateRunRequest

type UpdateTemplateRunRequest struct {
	TemplateRunId int32   `protobuf:"varint,1,opt,name=template_run_id,json=templateRunId,proto3" json:"template_run_id,omitempty"`
	WorkflowId    *int32  `protobuf:"varint,2,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
	ErrorMessage  *string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"`
	// JSON-encoded array of pin objects (see specs/module_library.md).
	// The yaml_runner snapshots the concrete (path, version) it resolved
	// for each `import:` so replays can use identical module content.
	ModulePins *string `protobuf:"bytes,4,opt,name=module_pins,json=modulePins,proto3,oneof" json:"module_pins,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTemplateRunRequest) Descriptor deprecated

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

Deprecated: Use UpdateTemplateRunRequest.ProtoReflect.Descriptor instead.

func (*UpdateTemplateRunRequest) GetErrorMessage

func (x *UpdateTemplateRunRequest) GetErrorMessage() string

func (*UpdateTemplateRunRequest) GetModulePins added in v0.7.5

func (x *UpdateTemplateRunRequest) GetModulePins() string

func (*UpdateTemplateRunRequest) GetTemplateRunId

func (x *UpdateTemplateRunRequest) GetTemplateRunId() int32

func (*UpdateTemplateRunRequest) GetWorkflowId

func (x *UpdateTemplateRunRequest) GetWorkflowId() int32

func (*UpdateTemplateRunRequest) ProtoMessage

func (*UpdateTemplateRunRequest) ProtoMessage()

func (*UpdateTemplateRunRequest) ProtoReflect

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

func (*UpdateTemplateRunRequest) Reset

func (x *UpdateTemplateRunRequest) Reset()

func (*UpdateTemplateRunRequest) String

func (x *UpdateTemplateRunRequest) String() string

type UpgradeBundledModulesRequest added in v0.7.5

type UpgradeBundledModulesRequest struct {

	// If false (default), the server returns the diff the upgrade would apply
	// without touching the DB. If true, the changes are committed.
	Apply bool `protobuf:"varint,1,opt,name=apply,proto3" json:"apply,omitempty"`
	// contains filtered or unexported fields
}

`scitq module upgrade` seeds/updates bundled YAML modules in the server-side module library from the installed scitq2_modules Python package. See specs/module_library.md.

func (*UpgradeBundledModulesRequest) Descriptor deprecated added in v0.7.5

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

Deprecated: Use UpgradeBundledModulesRequest.ProtoReflect.Descriptor instead.

func (*UpgradeBundledModulesRequest) GetApply added in v0.7.5

func (x *UpgradeBundledModulesRequest) GetApply() bool

func (*UpgradeBundledModulesRequest) ProtoMessage added in v0.7.5

func (*UpgradeBundledModulesRequest) ProtoMessage()

func (*UpgradeBundledModulesRequest) ProtoReflect added in v0.7.5

func (*UpgradeBundledModulesRequest) Reset added in v0.7.5

func (x *UpgradeBundledModulesRequest) Reset()

func (*UpgradeBundledModulesRequest) String added in v0.7.5

type UpgradeBundledModulesResponse added in v0.7.5

type UpgradeBundledModulesResponse struct {

	// Human-readable multi-line report of the scanned bundled modules and the
	// action taken (or that would be taken in dry-run).
	Report string `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
	// Summary counters — useful for scripted callers that don't want to parse
	// the text report.
	Inserted       int32 `protobuf:"varint,2,opt,name=inserted,proto3" json:"inserted,omitempty"`                                   // bundled rows newly inserted
	ForksPreserved int32 `protobuf:"varint,3,opt,name=forks_preserved,json=forksPreserved,proto3" json:"forks_preserved,omitempty"` // existing origin=F rows left alone
	Conflicts      int32 `protobuf:"varint,4,opt,name=conflicts,proto3" json:"conflicts,omitempty"`                                 // same (path,version) re-shipped with different bytes
	Skipped        int32 `protobuf:"varint,5,opt,name=skipped,proto3" json:"skipped,omitempty"`                                     // bundled modules without a version field
	UpToDate       int32 `protobuf:"varint,6,opt,name=up_to_date,json=upToDate,proto3" json:"up_to_date,omitempty"`                 // bundled rows already present with matching content
	// contains filtered or unexported fields
}

func (*UpgradeBundledModulesResponse) Descriptor deprecated added in v0.7.5

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

Deprecated: Use UpgradeBundledModulesResponse.ProtoReflect.Descriptor instead.

func (*UpgradeBundledModulesResponse) GetConflicts added in v0.7.5

func (x *UpgradeBundledModulesResponse) GetConflicts() int32

func (*UpgradeBundledModulesResponse) GetForksPreserved added in v0.7.5

func (x *UpgradeBundledModulesResponse) GetForksPreserved() int32

func (*UpgradeBundledModulesResponse) GetInserted added in v0.7.5

func (x *UpgradeBundledModulesResponse) GetInserted() int32

func (*UpgradeBundledModulesResponse) GetReport added in v0.7.5

func (x *UpgradeBundledModulesResponse) GetReport() string

func (*UpgradeBundledModulesResponse) GetSkipped added in v0.7.5

func (x *UpgradeBundledModulesResponse) GetSkipped() int32

func (*UpgradeBundledModulesResponse) GetUpToDate added in v0.7.5

func (x *UpgradeBundledModulesResponse) GetUpToDate() int32

func (*UpgradeBundledModulesResponse) ProtoMessage added in v0.7.5

func (*UpgradeBundledModulesResponse) ProtoMessage()

func (*UpgradeBundledModulesResponse) ProtoReflect added in v0.7.5

func (*UpgradeBundledModulesResponse) Reset added in v0.7.5

func (x *UpgradeBundledModulesResponse) Reset()

func (*UpgradeBundledModulesResponse) String added in v0.7.5

type UploadModuleRequest added in v0.7.1

type UploadModuleRequest struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Content  []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	Force    bool   `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

Module management

func (*UploadModuleRequest) Descriptor deprecated added in v0.7.1

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

Deprecated: Use UploadModuleRequest.ProtoReflect.Descriptor instead.

func (*UploadModuleRequest) GetContent added in v0.7.1

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

func (*UploadModuleRequest) GetFilename added in v0.7.1

func (x *UploadModuleRequest) GetFilename() string

func (*UploadModuleRequest) GetForce added in v0.7.1

func (x *UploadModuleRequest) GetForce() bool

func (*UploadModuleRequest) ProtoMessage added in v0.7.1

func (*UploadModuleRequest) ProtoMessage()

func (*UploadModuleRequest) ProtoReflect added in v0.7.1

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

func (*UploadModuleRequest) Reset added in v0.7.1

func (x *UploadModuleRequest) Reset()

func (*UploadModuleRequest) String added in v0.7.1

func (x *UploadModuleRequest) String() string

type UploadTemplateRequest

type UploadTemplateRequest struct {
	Script   []byte  `protobuf:"bytes,1,opt,name=script,proto3" json:"script,omitempty"`
	Force    bool    `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	Filename *string `protobuf:"bytes,3,opt,name=filename,proto3,oneof" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadTemplateRequest) Descriptor deprecated

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

Deprecated: Use UploadTemplateRequest.ProtoReflect.Descriptor instead.

func (*UploadTemplateRequest) GetFilename added in v0.7.1

func (x *UploadTemplateRequest) GetFilename() string

func (*UploadTemplateRequest) GetForce

func (x *UploadTemplateRequest) GetForce() bool

func (*UploadTemplateRequest) GetScript

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

func (*UploadTemplateRequest) ProtoMessage

func (*UploadTemplateRequest) ProtoMessage()

func (*UploadTemplateRequest) ProtoReflect

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

func (*UploadTemplateRequest) Reset

func (x *UploadTemplateRequest) Reset()

func (*UploadTemplateRequest) String

func (x *UploadTemplateRequest) String() string

type UploadTemplateResponse

type UploadTemplateResponse struct {
	Success            bool    `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message            string  `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	WorkflowTemplateId *int32  `protobuf:"varint,3,opt,name=workflow_template_id,json=workflowTemplateId,proto3,oneof" json:"workflow_template_id,omitempty"`
	Name               *string `protobuf:"bytes,4,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Version            *string `protobuf:"bytes,5,opt,name=version,proto3,oneof" json:"version,omitempty"`
	Description        *string `protobuf:"bytes,6,opt,name=description,proto3,oneof" json:"description,omitempty"`
	ParamJson          *string `protobuf:"bytes,7,opt,name=param_json,json=paramJson,proto3,oneof" json:"param_json,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadTemplateResponse) Descriptor deprecated

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

Deprecated: Use UploadTemplateResponse.ProtoReflect.Descriptor instead.

func (*UploadTemplateResponse) GetDescription

func (x *UploadTemplateResponse) GetDescription() string

func (*UploadTemplateResponse) GetMessage

func (x *UploadTemplateResponse) GetMessage() string

func (*UploadTemplateResponse) GetName

func (x *UploadTemplateResponse) GetName() string

func (*UploadTemplateResponse) GetParamJson

func (x *UploadTemplateResponse) GetParamJson() string

func (*UploadTemplateResponse) GetSuccess

func (x *UploadTemplateResponse) GetSuccess() bool

func (*UploadTemplateResponse) GetVersion

func (x *UploadTemplateResponse) GetVersion() string

func (*UploadTemplateResponse) GetWorkflowTemplateId

func (x *UploadTemplateResponse) GetWorkflowTemplateId() int32

func (*UploadTemplateResponse) ProtoMessage

func (*UploadTemplateResponse) ProtoMessage()

func (*UploadTemplateResponse) ProtoReflect

func (x *UploadTemplateResponse) ProtoReflect() protoreflect.Message

func (*UploadTemplateResponse) Reset

func (x *UploadTemplateResponse) Reset()

func (*UploadTemplateResponse) String

func (x *UploadTemplateResponse) String() string

type User

type User struct {
	UserId   int32   `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Username *string `protobuf:"bytes,2,opt,name=username,proto3,oneof" json:"username,omitempty"`
	Email    *string `protobuf:"bytes,3,opt,name=email,proto3,oneof" json:"email,omitempty"`
	IsAdmin  *bool   `protobuf:"varint,4,opt,name=is_admin,json=isAdmin,proto3,oneof" json:"is_admin,omitempty"`
	// contains filtered or unexported fields
}

func (*User) Descriptor deprecated

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetEmail

func (x *User) GetEmail() string

func (*User) GetIsAdmin

func (x *User) GetIsAdmin() bool

func (*User) GetUserId

func (x *User) GetUserId() int32

func (*User) GetUsername

func (x *User) GetUsername() string

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) ProtoReflect

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

func (*User) Reset

func (x *User) Reset()

func (*User) String

func (x *User) String() string

type UserId

type UserId struct {
	UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UserId) Descriptor deprecated

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

Deprecated: Use UserId.ProtoReflect.Descriptor instead.

func (*UserId) GetUserId

func (x *UserId) GetUserId() int32

func (*UserId) ProtoMessage

func (*UserId) ProtoMessage()

func (*UserId) ProtoReflect

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

func (*UserId) Reset

func (x *UserId) Reset()

func (*UserId) String

func (x *UserId) String() string

type UsersList

type UsersList struct {
	Users []*User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	// contains filtered or unexported fields
}

func (*UsersList) Descriptor deprecated

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

Deprecated: Use UsersList.ProtoReflect.Descriptor instead.

func (*UsersList) GetUsers

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

func (*UsersList) ProtoMessage

func (*UsersList) ProtoMessage()

func (*UsersList) ProtoReflect

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

func (*UsersList) Reset

func (x *UsersList) Reset()

func (*UsersList) String

func (x *UsersList) String() string

type Worker

type Worker struct {
	WorkerId        int32    `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Name            string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Concurrency     int32    `protobuf:"varint,3,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	Prefetch        int32    `protobuf:"varint,4,opt,name=prefetch,proto3" json:"prefetch,omitempty"`
	Status          string   `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	Ipv4            string   `protobuf:"bytes,6,opt,name=ipv4,proto3" json:"ipv4,omitempty"`
	Ipv6            string   `protobuf:"bytes,7,opt,name=ipv6,proto3" json:"ipv6,omitempty"`
	Flavor          string   `protobuf:"bytes,8,opt,name=flavor,proto3" json:"flavor,omitempty"`
	Provider        string   `protobuf:"bytes,9,opt,name=provider,proto3" json:"provider,omitempty"`
	Region          string   `protobuf:"bytes,10,opt,name=region,proto3" json:"region,omitempty"`
	StepId          *int32   `protobuf:"varint,11,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
	StepName        *string  `protobuf:"bytes,12,opt,name=step_name,json=stepName,proto3,oneof" json:"step_name,omitempty"`
	IsPermanent     bool     `protobuf:"varint,13,opt,name=is_permanent,json=isPermanent,proto3" json:"is_permanent,omitempty"`
	RecyclableScope string   `protobuf:"bytes,14,opt,name=recyclable_scope,json=recyclableScope,proto3" json:"recyclable_scope,omitempty"`
	WorkflowId      *int32   `protobuf:"varint,15,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
	WorkflowName    *string  `protobuf:"bytes,16,opt,name=workflow_name,json=workflowName,proto3,oneof" json:"workflow_name,omitempty"`
	FlavorCpu       *int32   `protobuf:"varint,17,opt,name=flavor_cpu,json=flavorCpu,proto3,oneof" json:"flavor_cpu,omitempty"`
	FlavorMem       *float32 `protobuf:"fixed32,18,opt,name=flavor_mem,json=flavorMem,proto3,oneof" json:"flavor_mem,omitempty"`
	FlavorDisk      *float32 `protobuf:"fixed32,19,opt,name=flavor_disk,json=flavorDisk,proto3,oneof" json:"flavor_disk,omitempty"`
	// Build identity (reported by the worker on registration; persisted
	// by the server). See specs/worker_autoupgrade.md.
	Version   *string `protobuf:"bytes,20,opt,name=version,proto3,oneof" json:"version,omitempty"`                      // worker's semver+suffix
	Commit    *string `protobuf:"bytes,21,opt,name=commit,proto3,oneof" json:"commit,omitempty"`                        // worker's git SHA
	BuildArch *string `protobuf:"bytes,22,opt,name=build_arch,json=buildArch,proto3,oneof" json:"build_arch,omitempty"` // worker's GOOS/GOARCH
	// Derived upgrade status — computed live by the server from the
	// worker's commit vs. the server's current commit. One of:
	// "up_to_date" | "needs_upgrade" | "unsupported_arch" | "unknown"
	// (unknown = pre-Phase-I worker that didn't report build identity).
	UpgradeStatus *string `protobuf:"bytes,23,opt,name=upgrade_status,json=upgradeStatus,proto3,oneof" json:"upgrade_status,omitempty"`
	// Pending operator-triggered upgrade request, if any. Phase II.
	// "" | "normal" | "emergency".
	UpgradeRequested *string `protobuf:"bytes,24,opt,name=upgrade_requested,json=upgradeRequested,proto3,oneof" json:"upgrade_requested,omitempty"`
	// Number of tasks this worker has FAILED since its most recent SUCCESS
	// (counting hidden retry-parents, which retain worker_id). A worker that
	// is structurally broken for the current step (e.g. a binary that crashes
	// on its CPU) shows this climbing while it produces no successes — the UI
	// surfaces it as a warning. 0 when the worker's latest task outcome is a
	// success (or it has no failures).
	RecentFailures *int32 `protobuf:"varint,25,opt,name=recent_failures,json=recentFailures,proto3,oneof" json:"recent_failures,omitempty"`
	// contains filtered or unexported fields
}

func (*Worker) Descriptor deprecated

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

Deprecated: Use Worker.ProtoReflect.Descriptor instead.

func (*Worker) GetBuildArch added in v0.8.1

func (x *Worker) GetBuildArch() string

func (*Worker) GetCommit added in v0.8.1

func (x *Worker) GetCommit() string

func (*Worker) GetConcurrency

func (x *Worker) GetConcurrency() int32

func (*Worker) GetFlavor

func (x *Worker) GetFlavor() string

func (*Worker) GetFlavorCpu added in v0.7.2

func (x *Worker) GetFlavorCpu() int32

func (*Worker) GetFlavorDisk added in v0.7.2

func (x *Worker) GetFlavorDisk() float32

func (*Worker) GetFlavorMem added in v0.7.2

func (x *Worker) GetFlavorMem() float32

func (*Worker) GetIpv4

func (x *Worker) GetIpv4() string

func (*Worker) GetIpv6

func (x *Worker) GetIpv6() string

func (*Worker) GetIsPermanent

func (x *Worker) GetIsPermanent() bool

func (*Worker) GetName

func (x *Worker) GetName() string

func (*Worker) GetPrefetch

func (x *Worker) GetPrefetch() int32

func (*Worker) GetProvider

func (x *Worker) GetProvider() string

func (*Worker) GetRecentFailures added in v0.8.5

func (x *Worker) GetRecentFailures() int32

func (*Worker) GetRecyclableScope

func (x *Worker) GetRecyclableScope() string

func (*Worker) GetRegion

func (x *Worker) GetRegion() string

func (*Worker) GetStatus

func (x *Worker) GetStatus() string

func (*Worker) GetStepId

func (x *Worker) GetStepId() int32

func (*Worker) GetStepName

func (x *Worker) GetStepName() string

func (*Worker) GetUpgradeRequested added in v0.8.1

func (x *Worker) GetUpgradeRequested() string

func (*Worker) GetUpgradeStatus added in v0.8.1

func (x *Worker) GetUpgradeStatus() string

func (*Worker) GetVersion added in v0.8.1

func (x *Worker) GetVersion() string

func (*Worker) GetWorkerId

func (x *Worker) GetWorkerId() int32

func (*Worker) GetWorkflowId

func (x *Worker) GetWorkflowId() int32

func (*Worker) GetWorkflowName

func (x *Worker) GetWorkflowName() string

func (*Worker) ProtoMessage

func (*Worker) ProtoMessage()

func (*Worker) ProtoReflect

func (x *Worker) ProtoReflect() protoreflect.Message

func (*Worker) Reset

func (x *Worker) Reset()

func (*Worker) String

func (x *Worker) String() string

type WorkerDeletion

type WorkerDeletion struct {
	WorkerId   int32 `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Undeployed *bool `protobuf:"varint,2,opt,name=undeployed,proto3,oneof" json:"undeployed,omitempty"` // if true, the worker is already undeployed so deletion can proceed
	// contains filtered or unexported fields
}

func (*WorkerDeletion) Descriptor deprecated

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

Deprecated: Use WorkerDeletion.ProtoReflect.Descriptor instead.

func (*WorkerDeletion) GetUndeployed

func (x *WorkerDeletion) GetUndeployed() bool

func (*WorkerDeletion) GetWorkerId

func (x *WorkerDeletion) GetWorkerId() int32

func (*WorkerDeletion) ProtoMessage

func (*WorkerDeletion) ProtoMessage()

func (*WorkerDeletion) ProtoReflect

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

func (*WorkerDeletion) Reset

func (x *WorkerDeletion) Reset()

func (*WorkerDeletion) String

func (x *WorkerDeletion) String() string

type WorkerDetails

type WorkerDetails struct {
	WorkerId   int32  `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	WorkerName string `protobuf:"bytes,2,opt,name=worker_name,json=workerName,proto3" json:"worker_name,omitempty"`
	JobId      int32  `protobuf:"varint,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerDetails) Descriptor deprecated

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

Deprecated: Use WorkerDetails.ProtoReflect.Descriptor instead.

func (*WorkerDetails) GetJobId

func (x *WorkerDetails) GetJobId() int32

func (*WorkerDetails) GetWorkerId

func (x *WorkerDetails) GetWorkerId() int32

func (*WorkerDetails) GetWorkerName

func (x *WorkerDetails) GetWorkerName() string

func (*WorkerDetails) ProtoMessage

func (*WorkerDetails) ProtoMessage()

func (*WorkerDetails) ProtoReflect

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

func (*WorkerDetails) Reset

func (x *WorkerDetails) Reset()

func (*WorkerDetails) String

func (x *WorkerDetails) String() string

type WorkerEvent

type WorkerEvent struct {

	// optional because a worker may fail before registration
	WorkerId    *int32 `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
	WorkerName  string `protobuf:"bytes,2,opt,name=worker_name,json=workerName,proto3" json:"worker_name,omitempty"`    // free text (hostname or generated name)
	Level       string `protobuf:"bytes,3,opt,name=level,proto3" json:"level,omitempty"`                                // single letter: D/I/W/E
	EventClass  string `protobuf:"bytes,4,opt,name=event_class,json=eventClass,proto3" json:"event_class,omitempty"`    // e.g. "install", "bootstrap", "runtime", "network"
	Message     string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`                            // short human description
	DetailsJson string `protobuf:"bytes,6,opt,name=details_json,json=detailsJson,proto3" json:"details_json,omitempty"` // raw JSON string (optional)
	// contains filtered or unexported fields
}

func (*WorkerEvent) Descriptor deprecated

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

Deprecated: Use WorkerEvent.ProtoReflect.Descriptor instead.

func (*WorkerEvent) GetDetailsJson

func (x *WorkerEvent) GetDetailsJson() string

func (*WorkerEvent) GetEventClass

func (x *WorkerEvent) GetEventClass() string

func (*WorkerEvent) GetLevel

func (x *WorkerEvent) GetLevel() string

func (*WorkerEvent) GetMessage

func (x *WorkerEvent) GetMessage() string

func (*WorkerEvent) GetWorkerId

func (x *WorkerEvent) GetWorkerId() int32

func (*WorkerEvent) GetWorkerName

func (x *WorkerEvent) GetWorkerName() string

func (*WorkerEvent) ProtoMessage

func (*WorkerEvent) ProtoMessage()

func (*WorkerEvent) ProtoReflect

func (x *WorkerEvent) ProtoReflect() protoreflect.Message

func (*WorkerEvent) Reset

func (x *WorkerEvent) Reset()

func (*WorkerEvent) String

func (x *WorkerEvent) String() string

type WorkerEventFilter

type WorkerEventFilter struct {
	WorkerId *int32  `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
	Level    *string `protobuf:"bytes,2,opt,name=level,proto3,oneof" json:"level,omitempty"`  // 'D','I','W','E'
	Class    *string `protobuf:"bytes,3,opt,name=class,proto3,oneof" json:"class,omitempty"`  // event_class filter
	Limit    *int32  `protobuf:"varint,4,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // max number of events (default 50)
	// contains filtered or unexported fields
}

func (*WorkerEventFilter) Descriptor deprecated

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

Deprecated: Use WorkerEventFilter.ProtoReflect.Descriptor instead.

func (*WorkerEventFilter) GetClass

func (x *WorkerEventFilter) GetClass() string

func (*WorkerEventFilter) GetLevel

func (x *WorkerEventFilter) GetLevel() string

func (*WorkerEventFilter) GetLimit

func (x *WorkerEventFilter) GetLimit() int32

func (*WorkerEventFilter) GetWorkerId

func (x *WorkerEventFilter) GetWorkerId() int32

func (*WorkerEventFilter) ProtoMessage

func (*WorkerEventFilter) ProtoMessage()

func (*WorkerEventFilter) ProtoReflect

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

func (*WorkerEventFilter) Reset

func (x *WorkerEventFilter) Reset()

func (*WorkerEventFilter) String

func (x *WorkerEventFilter) String() string

type WorkerEventId

type WorkerEventId struct {
	EventId int32 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerEventId) Descriptor deprecated

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

Deprecated: Use WorkerEventId.ProtoReflect.Descriptor instead.

func (*WorkerEventId) GetEventId

func (x *WorkerEventId) GetEventId() int32

func (*WorkerEventId) ProtoMessage

func (*WorkerEventId) ProtoMessage()

func (*WorkerEventId) ProtoReflect

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

func (*WorkerEventId) Reset

func (x *WorkerEventId) Reset()

func (*WorkerEventId) String

func (x *WorkerEventId) String() string

type WorkerEventList

type WorkerEventList struct {
	Events []*WorkerEventRecord `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerEventList) Descriptor deprecated

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

Deprecated: Use WorkerEventList.ProtoReflect.Descriptor instead.

func (*WorkerEventList) GetEvents

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

func (*WorkerEventList) ProtoMessage

func (*WorkerEventList) ProtoMessage()

func (*WorkerEventList) ProtoReflect

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

func (*WorkerEventList) Reset

func (x *WorkerEventList) Reset()

func (*WorkerEventList) String

func (x *WorkerEventList) String() string

type WorkerEventPruneFilter

type WorkerEventPruneFilter struct {
	Before   *string `protobuf:"bytes,1,opt,name=before,proto3,oneof" json:"before,omitempty"` // RFC3339 UTC, e.g. "2025-08-19T00:00:00Z"
	Level    *string `protobuf:"bytes,2,opt,name=level,proto3,oneof" json:"level,omitempty"`   // 'D'|'I'|'W'|'E'
	Class    *string `protobuf:"bytes,3,opt,name=class,proto3,oneof" json:"class,omitempty"`   // event_class exact match
	WorkerId *int32  `protobuf:"varint,4,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
	DryRun   bool    `protobuf:"varint,5,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"` // if true, count only; no deletion
	// contains filtered or unexported fields
}

func (*WorkerEventPruneFilter) Descriptor deprecated

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

Deprecated: Use WorkerEventPruneFilter.ProtoReflect.Descriptor instead.

func (*WorkerEventPruneFilter) GetBefore

func (x *WorkerEventPruneFilter) GetBefore() string

func (*WorkerEventPruneFilter) GetClass

func (x *WorkerEventPruneFilter) GetClass() string

func (*WorkerEventPruneFilter) GetDryRun

func (x *WorkerEventPruneFilter) GetDryRun() bool

func (*WorkerEventPruneFilter) GetLevel

func (x *WorkerEventPruneFilter) GetLevel() string

func (*WorkerEventPruneFilter) GetWorkerId

func (x *WorkerEventPruneFilter) GetWorkerId() int32

func (*WorkerEventPruneFilter) ProtoMessage

func (*WorkerEventPruneFilter) ProtoMessage()

func (*WorkerEventPruneFilter) ProtoReflect

func (x *WorkerEventPruneFilter) ProtoReflect() protoreflect.Message

func (*WorkerEventPruneFilter) Reset

func (x *WorkerEventPruneFilter) Reset()

func (*WorkerEventPruneFilter) String

func (x *WorkerEventPruneFilter) String() string

type WorkerEventPruneResult

type WorkerEventPruneResult struct {
	Matched int32 `protobuf:"varint,1,opt,name=matched,proto3" json:"matched,omitempty"`
	Deleted int32 `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerEventPruneResult) Descriptor deprecated

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

Deprecated: Use WorkerEventPruneResult.ProtoReflect.Descriptor instead.

func (*WorkerEventPruneResult) GetDeleted

func (x *WorkerEventPruneResult) GetDeleted() int32

func (*WorkerEventPruneResult) GetMatched

func (x *WorkerEventPruneResult) GetMatched() int32

func (*WorkerEventPruneResult) ProtoMessage

func (*WorkerEventPruneResult) ProtoMessage()

func (*WorkerEventPruneResult) ProtoReflect

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

func (*WorkerEventPruneResult) Reset

func (x *WorkerEventPruneResult) Reset()

func (*WorkerEventPruneResult) String

func (x *WorkerEventPruneResult) String() string

type WorkerEventRecord

type WorkerEventRecord struct {
	EventId     int32  `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	CreatedAt   string `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	WorkerId    *int32 `protobuf:"varint,3,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
	WorkerName  string `protobuf:"bytes,4,opt,name=worker_name,json=workerName,proto3" json:"worker_name,omitempty"`
	Level       string `protobuf:"bytes,5,opt,name=level,proto3" json:"level,omitempty"`
	EventClass  string `protobuf:"bytes,6,opt,name=event_class,json=eventClass,proto3" json:"event_class,omitempty"`
	Message     string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`
	DetailsJson string `protobuf:"bytes,8,opt,name=details_json,json=detailsJson,proto3" json:"details_json,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerEventRecord) Descriptor deprecated

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

Deprecated: Use WorkerEventRecord.ProtoReflect.Descriptor instead.

func (*WorkerEventRecord) GetCreatedAt

func (x *WorkerEventRecord) GetCreatedAt() string

func (*WorkerEventRecord) GetDetailsJson

func (x *WorkerEventRecord) GetDetailsJson() string

func (*WorkerEventRecord) GetEventClass

func (x *WorkerEventRecord) GetEventClass() string

func (*WorkerEventRecord) GetEventId

func (x *WorkerEventRecord) GetEventId() int32

func (*WorkerEventRecord) GetLevel

func (x *WorkerEventRecord) GetLevel() string

func (*WorkerEventRecord) GetMessage

func (x *WorkerEventRecord) GetMessage() string

func (*WorkerEventRecord) GetWorkerId

func (x *WorkerEventRecord) GetWorkerId() int32

func (*WorkerEventRecord) GetWorkerName

func (x *WorkerEventRecord) GetWorkerName() string

func (*WorkerEventRecord) ProtoMessage

func (*WorkerEventRecord) ProtoMessage()

func (*WorkerEventRecord) ProtoReflect

func (x *WorkerEventRecord) ProtoReflect() protoreflect.Message

func (*WorkerEventRecord) Reset

func (x *WorkerEventRecord) Reset()

func (*WorkerEventRecord) String

func (x *WorkerEventRecord) String() string

type WorkerId

type WorkerId struct {
	WorkerId int32 `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerId) Descriptor deprecated

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

Deprecated: Use WorkerId.ProtoReflect.Descriptor instead.

func (*WorkerId) GetWorkerId

func (x *WorkerId) GetWorkerId() int32

func (*WorkerId) ProtoMessage

func (*WorkerId) ProtoMessage()

func (*WorkerId) ProtoReflect

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

func (*WorkerId) Reset

func (x *WorkerId) Reset()

func (*WorkerId) String

func (x *WorkerId) String() string

type WorkerIds

type WorkerIds struct {
	WorkersDetails []*WorkerDetails `protobuf:"bytes,1,rep,name=workers_details,json=workersDetails,proto3" json:"workers_details,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerIds) Descriptor deprecated

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

Deprecated: Use WorkerIds.ProtoReflect.Descriptor instead.

func (*WorkerIds) GetWorkersDetails

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

func (*WorkerIds) ProtoMessage

func (*WorkerIds) ProtoMessage()

func (*WorkerIds) ProtoReflect

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

func (*WorkerIds) Reset

func (x *WorkerIds) Reset()

func (*WorkerIds) String

func (x *WorkerIds) String() string

type WorkerInfo

type WorkerInfo struct {
	Name        string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Concurrency *int32  `protobuf:"varint,2,opt,name=concurrency,proto3,oneof" json:"concurrency,omitempty"`
	IsPermanent *bool   `protobuf:"varint,3,opt,name=is_permanent,json=isPermanent,proto3,oneof" json:"is_permanent,omitempty"`
	Provider    *string `protobuf:"bytes,4,opt,name=provider,proto3,oneof" json:"provider,omitempty"`
	Region      *string `protobuf:"bytes,5,opt,name=region,proto3,oneof" json:"region,omitempty"`
	// Build identity, reported on registration so the server can flag
	// out-of-date workers. Phase I (visibility-only). See
	// specs/worker_autoupgrade.md.
	Version   *string `protobuf:"bytes,6,opt,name=version,proto3,oneof" json:"version,omitempty"`                      // semver+suffix, e.g. "v0.7.7-dev"
	Commit    *string `protobuf:"bytes,7,opt,name=commit,proto3,oneof" json:"commit,omitempty"`                        // full git SHA
	BuildArch *string `protobuf:"bytes,8,opt,name=build_arch,json=buildArch,proto3,oneof" json:"build_arch,omitempty"` // GOOS/GOARCH, e.g. "linux/amd64"
	// contains filtered or unexported fields
}

func (*WorkerInfo) Descriptor deprecated

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

Deprecated: Use WorkerInfo.ProtoReflect.Descriptor instead.

func (*WorkerInfo) GetBuildArch added in v0.8.1

func (x *WorkerInfo) GetBuildArch() string

func (*WorkerInfo) GetCommit added in v0.8.1

func (x *WorkerInfo) GetCommit() string

func (*WorkerInfo) GetConcurrency

func (x *WorkerInfo) GetConcurrency() int32

func (*WorkerInfo) GetIsPermanent

func (x *WorkerInfo) GetIsPermanent() bool

func (*WorkerInfo) GetName

func (x *WorkerInfo) GetName() string

func (*WorkerInfo) GetProvider

func (x *WorkerInfo) GetProvider() string

func (*WorkerInfo) GetRegion

func (x *WorkerInfo) GetRegion() string

func (*WorkerInfo) GetVersion added in v0.8.1

func (x *WorkerInfo) GetVersion() string

func (*WorkerInfo) ProtoMessage

func (*WorkerInfo) ProtoMessage()

func (*WorkerInfo) ProtoReflect

func (x *WorkerInfo) ProtoReflect() protoreflect.Message

func (*WorkerInfo) Reset

func (x *WorkerInfo) Reset()

func (*WorkerInfo) String

func (x *WorkerInfo) String() string

type WorkerRequest

type WorkerRequest struct {
	ProviderId  int32  `protobuf:"varint,1,opt,name=provider_id,json=providerId,proto3" json:"provider_id,omitempty"`
	FlavorId    int32  `protobuf:"varint,2,opt,name=flavor_id,json=flavorId,proto3" json:"flavor_id,omitempty"`
	RegionId    int32  `protobuf:"varint,3,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	Number      int32  `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"`
	Concurrency int32  `protobuf:"varint,5,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	Prefetch    int32  `protobuf:"varint,6,opt,name=prefetch,proto3" json:"prefetch,omitempty"`
	StepId      *int32 `protobuf:"varint,7,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerRequest) Descriptor deprecated

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

Deprecated: Use WorkerRequest.ProtoReflect.Descriptor instead.

func (*WorkerRequest) GetConcurrency

func (x *WorkerRequest) GetConcurrency() int32

func (*WorkerRequest) GetFlavorId

func (x *WorkerRequest) GetFlavorId() int32

func (*WorkerRequest) GetNumber

func (x *WorkerRequest) GetNumber() int32

func (*WorkerRequest) GetPrefetch

func (x *WorkerRequest) GetPrefetch() int32

func (*WorkerRequest) GetProviderId

func (x *WorkerRequest) GetProviderId() int32

func (*WorkerRequest) GetRegionId

func (x *WorkerRequest) GetRegionId() int32

func (*WorkerRequest) GetStepId

func (x *WorkerRequest) GetStepId() int32

func (*WorkerRequest) ProtoMessage

func (*WorkerRequest) ProtoMessage()

func (*WorkerRequest) ProtoReflect

func (x *WorkerRequest) ProtoReflect() protoreflect.Message

func (*WorkerRequest) Reset

func (x *WorkerRequest) Reset()

func (*WorkerRequest) String

func (x *WorkerRequest) String() string

type WorkerStats

type WorkerStats struct {
	CpuUsagePercent float32      `protobuf:"fixed32,1,opt,name=cpu_usage_percent,json=cpuUsagePercent,proto3" json:"cpu_usage_percent,omitempty"` // 0-100, float
	MemUsagePercent float32      `protobuf:"fixed32,2,opt,name=mem_usage_percent,json=memUsagePercent,proto3" json:"mem_usage_percent,omitempty"` // 0-100, float
	Load_1Min       float32      `protobuf:"fixed32,3,opt,name=load_1min,json=load1min,proto3" json:"load_1min,omitempty"`                        // e.g., 0.58, float
	IowaitPercent   float32      `protobuf:"fixed32,4,opt,name=iowait_percent,json=iowaitPercent,proto3" json:"iowait_percent,omitempty"`         // 0-100 float
	Disks           []*DiskUsage `protobuf:"bytes,5,rep,name=disks,proto3" json:"disks,omitempty"`                                                // Per-disk usage
	DiskIo          *DiskIOStats `protobuf:"bytes,6,opt,name=disk_io,json=diskIo,proto3" json:"disk_io,omitempty"`                                // Global disk IO (aggregated)
	NetIo           *NetIOStats  `protobuf:"bytes,7,opt,name=net_io,json=netIo,proto3" json:"net_io,omitempty"`                                   // Global network IO (aggregated)
	NumCpus         int32        `protobuf:"varint,8,opt,name=num_cpus,json=numCpus,proto3" json:"num_cpus,omitempty"`                            // Number of CPU cores on this worker
	// contains filtered or unexported fields
}

func (*WorkerStats) Descriptor deprecated

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

Deprecated: Use WorkerStats.ProtoReflect.Descriptor instead.

func (*WorkerStats) GetCpuUsagePercent

func (x *WorkerStats) GetCpuUsagePercent() float32

func (*WorkerStats) GetDiskIo

func (x *WorkerStats) GetDiskIo() *DiskIOStats

func (*WorkerStats) GetDisks

func (x *WorkerStats) GetDisks() []*DiskUsage

func (*WorkerStats) GetIowaitPercent

func (x *WorkerStats) GetIowaitPercent() float32

func (*WorkerStats) GetLoad_1Min

func (x *WorkerStats) GetLoad_1Min() float32

func (*WorkerStats) GetMemUsagePercent

func (x *WorkerStats) GetMemUsagePercent() float32

func (*WorkerStats) GetNetIo

func (x *WorkerStats) GetNetIo() *NetIOStats

func (*WorkerStats) GetNumCpus added in v0.7.1

func (x *WorkerStats) GetNumCpus() int32

func (*WorkerStats) ProtoMessage

func (*WorkerStats) ProtoMessage()

func (*WorkerStats) ProtoReflect

func (x *WorkerStats) ProtoReflect() protoreflect.Message

func (*WorkerStats) Reset

func (x *WorkerStats) Reset()

func (*WorkerStats) String

func (x *WorkerStats) String() string

type WorkerStatus

type WorkerStatus struct {
	WorkerId int32  `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Status   string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerStatus) Descriptor deprecated

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

Deprecated: Use WorkerStatus.ProtoReflect.Descriptor instead.

func (*WorkerStatus) GetStatus

func (x *WorkerStatus) GetStatus() string

func (*WorkerStatus) GetWorkerId

func (x *WorkerStatus) GetWorkerId() int32

func (*WorkerStatus) ProtoMessage

func (*WorkerStatus) ProtoMessage()

func (*WorkerStatus) ProtoReflect

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

func (*WorkerStatus) Reset

func (x *WorkerStatus) Reset()

func (*WorkerStatus) String

func (x *WorkerStatus) String() string

type WorkerStatusRequest

type WorkerStatusRequest struct {
	WorkerIds []int32 `protobuf:"varint,1,rep,packed,name=worker_ids,json=workerIds,proto3" json:"worker_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerStatusRequest) Descriptor deprecated

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

Deprecated: Use WorkerStatusRequest.ProtoReflect.Descriptor instead.

func (*WorkerStatusRequest) GetWorkerIds

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

func (*WorkerStatusRequest) ProtoMessage

func (*WorkerStatusRequest) ProtoMessage()

func (*WorkerStatusRequest) ProtoReflect

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

func (*WorkerStatusRequest) Reset

func (x *WorkerStatusRequest) Reset()

func (*WorkerStatusRequest) String

func (x *WorkerStatusRequest) String() string

type WorkerStatusResponse

type WorkerStatusResponse struct {
	Statuses []*WorkerStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerStatusResponse) Descriptor deprecated

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

Deprecated: Use WorkerStatusResponse.ProtoReflect.Descriptor instead.

func (*WorkerStatusResponse) GetStatuses

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

func (*WorkerStatusResponse) ProtoMessage

func (*WorkerStatusResponse) ProtoMessage()

func (*WorkerStatusResponse) ProtoReflect

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

func (*WorkerStatusResponse) Reset

func (x *WorkerStatusResponse) Reset()

func (*WorkerStatusResponse) String

func (x *WorkerStatusResponse) String() string

type WorkerUpdateRequest

type WorkerUpdateRequest struct {
	WorkerId        int32   `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	ProviderId      *int32  `protobuf:"varint,2,opt,name=provider_id,json=providerId,proto3,oneof" json:"provider_id,omitempty"`
	FlavorId        *int32  `protobuf:"varint,3,opt,name=flavor_id,json=flavorId,proto3,oneof" json:"flavor_id,omitempty"`
	RegionId        *int32  `protobuf:"varint,4,opt,name=region_id,json=regionId,proto3,oneof" json:"region_id,omitempty"`
	Concurrency     *int32  `protobuf:"varint,5,opt,name=concurrency,proto3,oneof" json:"concurrency,omitempty"`
	Prefetch        *int32  `protobuf:"varint,6,opt,name=prefetch,proto3,oneof" json:"prefetch,omitempty"`
	StepId          *int32  `protobuf:"varint,7,opt,name=step_id,json=stepId,proto3,oneof" json:"step_id,omitempty"`
	IsPermanent     *bool   `protobuf:"varint,8,opt,name=is_permanent,json=isPermanent,proto3,oneof" json:"is_permanent,omitempty"`
	RecyclableScope *string `protobuf:"bytes,9,opt,name=recyclable_scope,json=recyclableScope,proto3,oneof" json:"recyclable_scope,omitempty"`
	WorkflowName    *string `protobuf:"bytes,10,opt,name=workflow_name,json=workflowName,proto3,oneof" json:"workflow_name,omitempty"`
	StepName        *string `protobuf:"bytes,11,opt,name=step_name,json=stepName,proto3,oneof" json:"step_name,omitempty"`
	// Dynamic resource caps. When set, the server updates the worker's
	// flavor cpu/mem and the new value is pushed to the worker on its
	// next ping (via TaskListAndOther.max_cpu / max_mem). Mirrors the
	// existing concurrency-resize hook.
	MaxCpu *int32   `protobuf:"varint,12,opt,name=max_cpu,json=maxCpu,proto3,oneof" json:"max_cpu,omitempty"`
	MaxMem *float32 `protobuf:"fixed32,13,opt,name=max_mem,json=maxMem,proto3,oneof" json:"max_mem,omitempty"`
	// Detach the worker from any current step/workflow assignment by
	// setting step_id to NULL. Mutually exclusive with step_id /
	// workflow_name / step_name.
	ClearStep *bool `protobuf:"varint,14,opt,name=clear_step,json=clearStep,proto3,oneof" json:"clear_step,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerUpdateRequest) Descriptor deprecated

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

Deprecated: Use WorkerUpdateRequest.ProtoReflect.Descriptor instead.

func (*WorkerUpdateRequest) GetClearStep added in v0.8.5

func (x *WorkerUpdateRequest) GetClearStep() bool

func (*WorkerUpdateRequest) GetConcurrency

func (x *WorkerUpdateRequest) GetConcurrency() int32

func (*WorkerUpdateRequest) GetFlavorId

func (x *WorkerUpdateRequest) GetFlavorId() int32

func (*WorkerUpdateRequest) GetIsPermanent

func (x *WorkerUpdateRequest) GetIsPermanent() bool

func (*WorkerUpdateRequest) GetMaxCpu added in v0.8.5

func (x *WorkerUpdateRequest) GetMaxCpu() int32

func (*WorkerUpdateRequest) GetMaxMem added in v0.8.5

func (x *WorkerUpdateRequest) GetMaxMem() float32

func (*WorkerUpdateRequest) GetPrefetch

func (x *WorkerUpdateRequest) GetPrefetch() int32

func (*WorkerUpdateRequest) GetProviderId

func (x *WorkerUpdateRequest) GetProviderId() int32

func (*WorkerUpdateRequest) GetRecyclableScope

func (x *WorkerUpdateRequest) GetRecyclableScope() string

func (*WorkerUpdateRequest) GetRegionId

func (x *WorkerUpdateRequest) GetRegionId() int32

func (*WorkerUpdateRequest) GetStepId

func (x *WorkerUpdateRequest) GetStepId() int32

func (*WorkerUpdateRequest) GetStepName

func (x *WorkerUpdateRequest) GetStepName() string

func (*WorkerUpdateRequest) GetWorkerId

func (x *WorkerUpdateRequest) GetWorkerId() int32

func (*WorkerUpdateRequest) GetWorkflowName

func (x *WorkerUpdateRequest) GetWorkflowName() string

func (*WorkerUpdateRequest) ProtoMessage

func (*WorkerUpdateRequest) ProtoMessage()

func (*WorkerUpdateRequest) ProtoReflect

func (x *WorkerUpdateRequest) ProtoReflect() protoreflect.Message

func (*WorkerUpdateRequest) Reset

func (x *WorkerUpdateRequest) Reset()

func (*WorkerUpdateRequest) String

func (x *WorkerUpdateRequest) String() string

type WorkerUpgradeReply added in v0.8.1

type WorkerUpgradeReply struct {
	AffectedWorkerIds []int32 `protobuf:"varint,1,rep,packed,name=affected_worker_ids,json=affectedWorkerIds,proto3" json:"affected_worker_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerUpgradeReply) Descriptor deprecated added in v0.8.1

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

Deprecated: Use WorkerUpgradeReply.ProtoReflect.Descriptor instead.

func (*WorkerUpgradeReply) GetAffectedWorkerIds added in v0.8.1

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

func (*WorkerUpgradeReply) ProtoMessage added in v0.8.1

func (*WorkerUpgradeReply) ProtoMessage()

func (*WorkerUpgradeReply) ProtoReflect added in v0.8.1

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

func (*WorkerUpgradeReply) Reset added in v0.8.1

func (x *WorkerUpgradeReply) Reset()

func (*WorkerUpgradeReply) String added in v0.8.1

func (x *WorkerUpgradeReply) String() string

type WorkerUpgradeRequest added in v0.8.1

type WorkerUpgradeRequest struct {
	WorkerIds []int32 `protobuf:"varint,1,rep,packed,name=worker_ids,json=workerIds,proto3" json:"worker_ids,omitempty"`
	All       bool    `protobuf:"varint,2,opt,name=all,proto3" json:"all,omitempty"`
	Mode      string  `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

Phase II: operator triggers an upgrade on one or many workers. `worker_ids` carries the targets; if `all` is true, worker_ids is ignored and every worker (matching arch/commit guard server-side) is flagged. `mode` is "normal", "emergency", or "cancel".

func (*WorkerUpgradeRequest) Descriptor deprecated added in v0.8.1

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

Deprecated: Use WorkerUpgradeRequest.ProtoReflect.Descriptor instead.

func (*WorkerUpgradeRequest) GetAll added in v0.8.1

func (x *WorkerUpgradeRequest) GetAll() bool

func (*WorkerUpgradeRequest) GetMode added in v0.8.1

func (x *WorkerUpgradeRequest) GetMode() string

func (*WorkerUpgradeRequest) GetWorkerIds added in v0.8.1

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

func (*WorkerUpgradeRequest) ProtoMessage added in v0.8.1

func (*WorkerUpgradeRequest) ProtoMessage()

func (*WorkerUpgradeRequest) ProtoReflect added in v0.8.1

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

func (*WorkerUpgradeRequest) Reset added in v0.8.1

func (x *WorkerUpgradeRequest) Reset()

func (*WorkerUpgradeRequest) String added in v0.8.1

func (x *WorkerUpgradeRequest) String() string

type WorkersList

type WorkersList struct {
	Workers []*Worker `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkersList) Descriptor deprecated

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

Deprecated: Use WorkersList.ProtoReflect.Descriptor instead.

func (*WorkersList) GetWorkers

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

func (*WorkersList) ProtoMessage

func (*WorkersList) ProtoMessage()

func (*WorkersList) ProtoReflect

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

func (*WorkersList) Reset

func (x *WorkersList) Reset()

func (*WorkersList) String

func (x *WorkersList) String() string

type Workflow

type Workflow struct {
	WorkflowId     int32  `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	Name           string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Status         string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	RunStrategy    string `protobuf:"bytes,4,opt,name=run_strategy,json=runStrategy,proto3" json:"run_strategy,omitempty"`
	MaximumWorkers *int32 `protobuf:"varint,5,opt,name=maximum_workers,json=maximumWorkers,proto3,oneof" json:"maximum_workers,omitempty"`
	TotalTasks     int32  `protobuf:"varint,6,opt,name=total_tasks,json=totalTasks,proto3" json:"total_tasks,omitempty"`
	SucceededTasks int32  `protobuf:"varint,7,opt,name=succeeded_tasks,json=succeededTasks,proto3" json:"succeeded_tasks,omitempty"`
	FailedTasks    int32  `protobuf:"varint,8,opt,name=failed_tasks,json=failedTasks,proto3" json:"failed_tasks,omitempty"`        // Terminal failures only
	RunningTasks   int32  `protobuf:"varint,9,opt,name=running_tasks,json=runningTasks,proto3" json:"running_tasks,omitempty"`     // Accepted + Running + Uploading
	RetryingTasks  int32  `protobuf:"varint,10,opt,name=retrying_tasks,json=retryingTasks,proto3" json:"retrying_tasks,omitempty"` // Tasks currently being retried (failed once, clone in progress)
	Live           bool   `protobuf:"varint,11,opt,name=live,proto3" json:"live,omitempty"`                                        // Live mode: prevents auto-completion of workflow
	// Launch provenance: lets "how was this workflow created?" be answered
	// without a follow-up query. For template-launched workflows,
	// template_name + template_version are set. For local-Python ad-hoc
	// runs, script_name (and optionally script_sha256) are set instead.
	// template_run_id is populated for both.
	TemplateRunId   *int32  `protobuf:"varint,12,opt,name=template_run_id,json=templateRunId,proto3,oneof" json:"template_run_id,omitempty"`
	TemplateName    *string `protobuf:"bytes,13,opt,name=template_name,json=templateName,proto3,oneof" json:"template_name,omitempty"`
	TemplateVersion *string `protobuf:"bytes,14,opt,name=template_version,json=templateVersion,proto3,oneof" json:"template_version,omitempty"`
	ScriptName      *string `protobuf:"bytes,15,opt,name=script_name,json=scriptName,proto3,oneof" json:"script_name,omitempty"`
	ScriptSha256    *string `protobuf:"bytes,16,opt,name=script_sha256,json=scriptSha256,proto3,oneof" json:"script_sha256,omitempty"`
	// When this workflow was created by a parent workflow's chain firing,
	// the parent's id. See specs/workflow_chain.md.
	ParentWorkflowId *int32 `protobuf:"varint,17,opt,name=parent_workflow_id,json=parentWorkflowId,proto3,oneof" json:"parent_workflow_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow) Descriptor deprecated

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

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetFailedTasks added in v0.7.1

func (x *Workflow) GetFailedTasks() int32

func (*Workflow) GetLive added in v0.7.2

func (x *Workflow) GetLive() bool

func (*Workflow) GetMaximumWorkers

func (x *Workflow) GetMaximumWorkers() int32

func (*Workflow) GetName

func (x *Workflow) GetName() string

func (*Workflow) GetParentWorkflowId added in v0.8.5

func (x *Workflow) GetParentWorkflowId() int32

func (*Workflow) GetRetryingTasks added in v0.7.1

func (x *Workflow) GetRetryingTasks() int32

func (*Workflow) GetRunStrategy

func (x *Workflow) GetRunStrategy() string

func (*Workflow) GetRunningTasks added in v0.7.1

func (x *Workflow) GetRunningTasks() int32

func (*Workflow) GetScriptName added in v0.7.5

func (x *Workflow) GetScriptName() string

func (*Workflow) GetScriptSha256 added in v0.7.5

func (x *Workflow) GetScriptSha256() string

func (*Workflow) GetStatus

func (x *Workflow) GetStatus() string

func (*Workflow) GetSucceededTasks added in v0.7.1

func (x *Workflow) GetSucceededTasks() int32

func (*Workflow) GetTemplateName added in v0.7.5

func (x *Workflow) GetTemplateName() string

func (*Workflow) GetTemplateRunId added in v0.7.5

func (x *Workflow) GetTemplateRunId() int32

func (*Workflow) GetTemplateVersion added in v0.7.5

func (x *Workflow) GetTemplateVersion() string

func (*Workflow) GetTotalTasks added in v0.7.1

func (x *Workflow) GetTotalTasks() int32

func (*Workflow) GetWorkflowId

func (x *Workflow) GetWorkflowId() int32

func (*Workflow) ProtoMessage

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect

func (x *Workflow) ProtoReflect() protoreflect.Message

func (*Workflow) Reset

func (x *Workflow) Reset()

func (*Workflow) String

func (x *Workflow) String() string

type WorkflowFilter

type WorkflowFilter struct {
	NameLike *string `protobuf:"bytes,1,opt,name=name_like,json=nameLike,proto3,oneof" json:"name_like,omitempty"`
	Limit    *int32  `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	Offset   *int32  `protobuf:"varint,3,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	// User filter (resolved against the workflow's launching template_run.run_by):
	//   - unset            → no user filter (returns every workflow)
	//   - "@me"            → resolve to the authenticated caller
	//   - "<username>"     → filter by that user
	//
	// The "@me" sentinel lets clients send a fixed marker and have the server
	// resolve it from the call context, avoiding a separate whoami round-trip.
	// Workflows without a template_run_id (pre-template legacy rows) have no
	// attributable user; they appear only when this filter is unset.
	UsernameFilter *string `protobuf:"bytes,4,opt,name=username_filter,json=usernameFilter,proto3,oneof" json:"username_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowFilter) Descriptor deprecated

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

Deprecated: Use WorkflowFilter.ProtoReflect.Descriptor instead.

func (*WorkflowFilter) GetLimit

func (x *WorkflowFilter) GetLimit() int32

func (*WorkflowFilter) GetNameLike

func (x *WorkflowFilter) GetNameLike() string

func (*WorkflowFilter) GetOffset

func (x *WorkflowFilter) GetOffset() int32

func (*WorkflowFilter) GetUsernameFilter added in v0.8.5

func (x *WorkflowFilter) GetUsernameFilter() string

func (*WorkflowFilter) ProtoMessage

func (*WorkflowFilter) ProtoMessage()

func (*WorkflowFilter) ProtoReflect

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

func (*WorkflowFilter) Reset

func (x *WorkflowFilter) Reset()

func (*WorkflowFilter) String

func (x *WorkflowFilter) String() string

type WorkflowId

type WorkflowId struct {
	WorkflowId int32 `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowId) Descriptor deprecated

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

Deprecated: Use WorkflowId.ProtoReflect.Descriptor instead.

func (*WorkflowId) GetWorkflowId

func (x *WorkflowId) GetWorkflowId() int32

func (*WorkflowId) ProtoMessage

func (*WorkflowId) ProtoMessage()

func (*WorkflowId) ProtoReflect

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

func (*WorkflowId) Reset

func (x *WorkflowId) Reset()

func (*WorkflowId) String

func (x *WorkflowId) String() string

type WorkflowList

type WorkflowList struct {
	Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowList) Descriptor deprecated

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

Deprecated: Use WorkflowList.ProtoReflect.Descriptor instead.

func (*WorkflowList) GetWorkflows

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

func (*WorkflowList) ProtoMessage

func (*WorkflowList) ProtoMessage()

func (*WorkflowList) ProtoReflect

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

func (*WorkflowList) Reset

func (x *WorkflowList) Reset()

func (*WorkflowList) String

func (x *WorkflowList) String() string

type WorkflowRequest

type WorkflowRequest struct {
	Name           string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	RunStrategy    *string `protobuf:"bytes,2,opt,name=run_strategy,json=runStrategy,proto3,oneof" json:"run_strategy,omitempty"`
	MaximumWorkers *int32  `protobuf:"varint,3,opt,name=maximum_workers,json=maximumWorkers,proto3,oneof" json:"maximum_workers,omitempty"`
	Status         *string `protobuf:"bytes,4,opt,name=status,proto3,oneof" json:"status,omitempty"`
	Live           *bool   `protobuf:"varint,5,opt,name=live,proto3,oneof" json:"live,omitempty"` // Live mode: prevents auto-completion
	// contains filtered or unexported fields
}

func (*WorkflowRequest) Descriptor deprecated

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

Deprecated: Use WorkflowRequest.ProtoReflect.Descriptor instead.

func (*WorkflowRequest) GetLive added in v0.7.2

func (x *WorkflowRequest) GetLive() bool

func (*WorkflowRequest) GetMaximumWorkers

func (x *WorkflowRequest) GetMaximumWorkers() int32

func (*WorkflowRequest) GetName

func (x *WorkflowRequest) GetName() string

func (*WorkflowRequest) GetRunStrategy

func (x *WorkflowRequest) GetRunStrategy() string

func (*WorkflowRequest) GetStatus

func (x *WorkflowRequest) GetStatus() string

func (*WorkflowRequest) ProtoMessage

func (*WorkflowRequest) ProtoMessage()

func (*WorkflowRequest) ProtoReflect

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

func (*WorkflowRequest) Reset

func (x *WorkflowRequest) Reset()

func (*WorkflowRequest) String

func (x *WorkflowRequest) String() string

type WorkflowStatusUpdate

type WorkflowStatusUpdate struct {
	WorkflowId     int32  `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	Status         string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	MaximumWorkers *int32 `protobuf:"varint,3,opt,name=maximum_workers,json=maximumWorkers,proto3,oneof" json:"maximum_workers,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowStatusUpdate) Descriptor deprecated

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

Deprecated: Use WorkflowStatusUpdate.ProtoReflect.Descriptor instead.

func (*WorkflowStatusUpdate) GetMaximumWorkers added in v0.6.2

func (x *WorkflowStatusUpdate) GetMaximumWorkers() int32

func (*WorkflowStatusUpdate) GetStatus

func (x *WorkflowStatusUpdate) GetStatus() string

func (*WorkflowStatusUpdate) GetWorkflowId

func (x *WorkflowStatusUpdate) GetWorkflowId() int32

func (*WorkflowStatusUpdate) ProtoMessage

func (*WorkflowStatusUpdate) ProtoMessage()

func (*WorkflowStatusUpdate) ProtoReflect

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

func (*WorkflowStatusUpdate) Reset

func (x *WorkflowStatusUpdate) Reset()

func (*WorkflowStatusUpdate) String

func (x *WorkflowStatusUpdate) String() string

type WorkspaceRootRequest

type WorkspaceRootRequest struct {
	Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"` // e.g., "azure.default" or "openstack.ovh"
	Region   string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`     // e.g., "northeurope"
	// contains filtered or unexported fields
}

func (*WorkspaceRootRequest) Descriptor deprecated

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

Deprecated: Use WorkspaceRootRequest.ProtoReflect.Descriptor instead.

func (*WorkspaceRootRequest) GetProvider

func (x *WorkspaceRootRequest) GetProvider() string

func (*WorkspaceRootRequest) GetRegion

func (x *WorkspaceRootRequest) GetRegion() string

func (*WorkspaceRootRequest) ProtoMessage

func (*WorkspaceRootRequest) ProtoMessage()

func (*WorkspaceRootRequest) ProtoReflect

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

func (*WorkspaceRootRequest) Reset

func (x *WorkspaceRootRequest) Reset()

func (*WorkspaceRootRequest) String

func (x *WorkspaceRootRequest) String() string

type WorkspaceRootResponse

type WorkspaceRootResponse struct {
	RootUri string `protobuf:"bytes,1,opt,name=root_uri,json=rootUri,proto3" json:"root_uri,omitempty"` // e.g., "aznorth://workspace"
	// contains filtered or unexported fields
}

func (*WorkspaceRootResponse) Descriptor deprecated

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

Deprecated: Use WorkspaceRootResponse.ProtoReflect.Descriptor instead.

func (*WorkspaceRootResponse) GetRootUri

func (x *WorkspaceRootResponse) GetRootUri() string

func (*WorkspaceRootResponse) ProtoMessage

func (*WorkspaceRootResponse) ProtoMessage()

func (*WorkspaceRootResponse) ProtoReflect

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

func (*WorkspaceRootResponse) Reset

func (x *WorkspaceRootResponse) Reset()

func (*WorkspaceRootResponse) String

func (x *WorkspaceRootResponse) String() string

Jump to

Keyboard shortcuts

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