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

taskqueuepb

package
v0.7.1 Latest Latest
Warning

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

 Go to latest Published: Apr 1, 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_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_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_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_ListTemplateRuns_FullMethodName          = "/taskqueue.TaskQueue/ListTemplateRuns"
	TaskQueue_UpdateTemplateRun_FullMethodName         = "/taskqueue.TaskQueue/UpdateTemplateRun"
	TaskQueue_DeleteTemplateRun_FullMethodName         = "/taskqueue.TaskQueue/DeleteTemplateRun"
	TaskQueue_UploadModule_FullMethodName              = "/taskqueue.TaskQueue/UploadModule"
	TaskQueue_ListModules_FullMethodName               = "/taskqueue.TaskQueue/ListModules"
	TaskQueue_DownloadModule_FullMethodName            = "/taskqueue.TaskQueue/DownloadModule"
	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"
)

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: "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: "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: "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: "ListTemplateRuns",
			Handler:    _TaskQueue_ListTemplateRuns_Handler,
		},
		{
			MethodName: "UpdateTemplateRun",
			Handler:    _TaskQueue_UpdateTemplateRun_Handler,
		},
		{
			MethodName: "DeleteTemplateRun",
			Handler:    _TaskQueue_DeleteTemplateRun_Handler,
		},
		{
			MethodName: "UploadModule",
			Handler:    _TaskQueue_UploadModule_Handler,
		},
		{
			MethodName: "ListModules",
			Handler:    _TaskQueue_ListModules_Handler,
		},
		{
			MethodName: "DownloadModule",
			Handler:    _TaskQueue_DownloadModule_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,
		},
	},
	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 (x *AdminResetPasswordRequest) ProtoReflect() protoreflect.Message

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 ChangePasswordRequest 

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

func (*ChangePasswordRequest) Descriptor deprecated 

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

Deprecated: Use ChangePasswordRequest.ProtoReflect.Descriptor instead.

func (*ChangePasswordRequest) GetNewPassword 

func (x *ChangePasswordRequest) GetNewPassword() string

func (*ChangePasswordRequest) GetOldPassword 

func (x *ChangePasswordRequest) GetOldPassword() string

func (*ChangePasswordRequest) GetUsername 

func (x *ChangePasswordRequest) GetUsername() string

func (*ChangePasswordRequest) ProtoMessage 

func (*ChangePasswordRequest) ProtoMessage()

func (*ChangePasswordRequest) ProtoReflect 

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

func (*ChangePasswordRequest) Reset 

func (x *ChangePasswordRequest) Reset()

func (*ChangePasswordRequest) String 

func (x *ChangePasswordRequest) String() string

type CreateUserRequest 

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

func (*CreateUserRequest) Descriptor deprecated 

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

Deprecated: Use CreateUserRequest.ProtoReflect.Descriptor instead.

func (*CreateUserRequest) GetEmail 

func (x *CreateUserRequest) GetEmail() string

func (*CreateUserRequest) GetIsAdmin 

func (x *CreateUserRequest) GetIsAdmin() bool

func (*CreateUserRequest) GetPassword 

func (x *CreateUserRequest) GetPassword() string

func (*CreateUserRequest) GetUsername 

func (x *CreateUserRequest) GetUsername() string

func (*CreateUserRequest) ProtoMessage 

func (*CreateUserRequest) ProtoMessage()

func (*CreateUserRequest) ProtoReflect 

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

func (*CreateUserRequest) Reset 

func (x *CreateUserRequest) Reset()

func (*CreateUserRequest) String 

func (x *CreateUserRequest) String() string

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

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 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
	// 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) 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 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 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 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 GetLogsRequest 

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

func (*GetLogsRequest) Descriptor deprecated 

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

Deprecated: Use GetLogsRequest.ProtoReflect.Descriptor instead.

func (*GetLogsRequest) GetChunkSize 

func (x *GetLogsRequest) GetChunkSize() int32

func (*GetLogsRequest) GetLogType 

func (x *GetLogsRequest) GetLogType() string

func (*GetLogsRequest) GetSkipFromEnd 

func (x *GetLogsRequest) GetSkipFromEnd() int32

func (*GetLogsRequest) GetTaskIds 

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

func (*GetLogsRequest) ProtoMessage 

func (*GetLogsRequest) ProtoMessage()

func (*GetLogsRequest) ProtoReflect 

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

func (*GetLogsRequest) Reset 

func (x *GetLogsRequest) Reset()

func (*GetLogsRequest) String 

func (x *GetLogsRequest) String() string

type GetWorkerStatsRequest 

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

func (*GetWorkerStatsRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkerStatsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkerStatsRequest) GetWorkerIds 

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

func (*GetWorkerStatsRequest) ProtoMessage 

func (*GetWorkerStatsRequest) ProtoMessage()

func (*GetWorkerStatsRequest) ProtoReflect 

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

func (*GetWorkerStatsRequest) Reset 

func (x *GetWorkerStatsRequest) Reset()

func (*GetWorkerStatsRequest) String 

func (x *GetWorkerStatsRequest) String() string

type GetWorkerStatsResponse 

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

func (*GetWorkerStatsResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkerStatsResponse.ProtoReflect.Descriptor instead.

func (*GetWorkerStatsResponse) GetWorkerStats 

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

func (*GetWorkerStatsResponse) ProtoMessage 

func (*GetWorkerStatsResponse) ProtoMessage()

func (*GetWorkerStatsResponse) ProtoReflect 

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

func (*GetWorkerStatsResponse) Reset 

func (x *GetWorkerStatsResponse) Reset()

func (*GetWorkerStatsResponse) String 

func (x *GetWorkerStatsResponse) String() string

type Job 

type Job struct {
	JobId       int32  `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Status      string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	FlavorId    int32  `protobuf:"varint,3,opt,name=flavor_id,json=flavorId,proto3" json:"flavor_id,omitempty"`
	Retry       int32  `protobuf:"varint,4,opt,name=retry,proto3" json:"retry,omitempty"`
	WorkerId    int32  `protobuf:"varint,5,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Action      string `protobuf:"bytes,6,opt,name=action,proto3" json:"action,omitempty"`
	CreatedAt   string `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ModifiedAt  string `protobuf:"bytes,8,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
	Progression int32  `protobuf:"varint,9,opt,name=progression,proto3" json:"progression,omitempty"`
	Log         string `protobuf:"bytes,10,opt,name=log,proto3" json:"log,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

func (*Job) 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) GetFlavorId 

func (x *Job) GetFlavorId() int32

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) 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 ListFlavorsRequest 

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

func (*ListFlavorsRequest) Descriptor deprecated 

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

Deprecated: Use ListFlavorsRequest.ProtoReflect.Descriptor instead.

func (*ListFlavorsRequest) GetFilter 

func (x *ListFlavorsRequest) GetFilter() string

func (*ListFlavorsRequest) GetLimit 

func (x *ListFlavorsRequest) GetLimit() int32

func (*ListFlavorsRequest) ProtoMessage 

func (*ListFlavorsRequest) ProtoMessage()

func (*ListFlavorsRequest) ProtoReflect 

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

func (*ListFlavorsRequest) Reset 

func (x *ListFlavorsRequest) Reset()

func (*ListFlavorsRequest) String 

func (x *ListFlavorsRequest) String() string

type ListJobsRequest 

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

func (*ListJobsRequest) Descriptor deprecated 

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

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) GetLimit 

func (x *ListJobsRequest) GetLimit() int32

func (*ListJobsRequest) GetOffset 

func (x *ListJobsRequest) GetOffset() int32

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect 

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

func (*ListJobsRequest) Reset 

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String 

func (x *ListJobsRequest) String() string

type ListTasksRequest 

type ListTasksRequest struct {
	StatusFilter     *string `protobuf:"bytes,1,opt,name=status_filter,json=statusFilter,proto3,oneof" json:"status_filter,omitempty"`
	WorkerIdFilter   *int32  `protobuf:"varint,2,opt,name=worker_id_filter,json=workerIdFilter,proto3,oneof" json:"worker_id_filter,omitempty"`
	WorkflowIdFilter *int32  `protobuf:"varint,3,opt,name=workflow_id_filter,json=workflowIdFilter,proto3,oneof" json:"workflow_id_filter,omitempty"`
	StepIdFilter     *int32  `protobuf:"varint,4,opt,name=step_id_filter,json=stepIdFilter,proto3,oneof" json:"step_id_filter,omitempty"`
	CommandFilter    *string `protobuf:"bytes,5,opt,name=command_filter,json=commandFilter,proto3,oneof" json:"command_filter,omitempty"`
	Limit            *int32  `protobuf:"varint,6,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	Offset           *int32  `protobuf:"varint,7,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	ShowHidden       *bool   `protobuf:"varint,8,opt,name=show_hidden,json=showHidden,proto3,oneof" json:"show_hidden,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) Descriptor deprecated 

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

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetCommandFilter 

func (x *ListTasksRequest) GetCommandFilter() string

func (*ListTasksRequest) GetLimit 

func (x *ListTasksRequest) GetLimit() int32

func (*ListTasksRequest) GetOffset 

func (x *ListTasksRequest) GetOffset() int32

func (*ListTasksRequest) GetShowHidden 

func (x *ListTasksRequest) GetShowHidden() bool

func (*ListTasksRequest) GetStatusFilter 

func (x *ListTasksRequest) GetStatusFilter() string

func (*ListTasksRequest) GetStepIdFilter 

func (x *ListTasksRequest) GetStepIdFilter() int32

func (*ListTasksRequest) GetWorkerIdFilter 

func (x *ListTasksRequest) GetWorkerIdFilter() int32

func (*ListTasksRequest) GetWorkflowIdFilter 

func (x *ListTasksRequest) GetWorkflowIdFilter() int32

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect 

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

func (*ListTasksRequest) Reset 

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (x *ListTasksRequest) String() string

type ListWorkersRequest 

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

func (*ListWorkersRequest) Descriptor deprecated 

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

Deprecated: Use ListWorkersRequest.ProtoReflect.Descriptor instead.

func (*ListWorkersRequest) GetWorkflowId 

func (x *ListWorkersRequest) GetWorkflowId() int32

func (*ListWorkersRequest) ProtoMessage 

func (*ListWorkersRequest) ProtoMessage()

func (*ListWorkersRequest) ProtoReflect 

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

func (*ListWorkersRequest) Reset 

func (x *ListWorkersRequest) Reset()

func (*ListWorkersRequest) String 

func (x *ListWorkersRequest) String() string

type LogChunk 

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

func (*LogChunk) Descriptor deprecated 

func (*LogChunk) 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 ModuleList added in v0.7.1 

type ModuleList struct {
	Modules []string `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,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) 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 NetIOStats 

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

func (*NetIOStats) Descriptor deprecated 

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

Deprecated: Use NetIOStats.ProtoReflect.Descriptor instead.

func (*NetIOStats) GetRecvBytesRate 

func (x *NetIOStats) GetRecvBytesRate() float32

func (*NetIOStats) GetRecvBytesTotal 

func (x *NetIOStats) GetRecvBytesTotal() int64

func (*NetIOStats) GetSentBytesRate 

func (x *NetIOStats) GetSentBytesRate() float32

func (*NetIOStats) GetSentBytesTotal 

func (x *NetIOStats) GetSentBytesTotal() int64

func (*NetIOStats) ProtoMessage 

func (*NetIOStats) ProtoMessage()

func (*NetIOStats) ProtoReflect 

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

func (*NetIOStats) Reset 

func (x *NetIOStats) Reset()

func (*NetIOStats) String 

func (x *NetIOStats) String() string

type PingAndGetNewTasksRequest 

type PingAndGetNewTasksRequest struct {
	WorkerId int32        `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Stats    *WorkerStats `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"` // Optional
	// contains filtered or unexported fields
}

func (*PingAndGetNewTasksRequest) Descriptor deprecated 

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

Deprecated: Use PingAndGetNewTasksRequest.ProtoReflect.Descriptor instead.

func (*PingAndGetNewTasksRequest) GetStats 

func (x *PingAndGetNewTasksRequest) GetStats() *WorkerStats

func (*PingAndGetNewTasksRequest) GetWorkerId 

func (x *PingAndGetNewTasksRequest) GetWorkerId() int32

func (*PingAndGetNewTasksRequest) ProtoMessage 

func (*PingAndGetNewTasksRequest) ProtoMessage()

func (*PingAndGetNewTasksRequest) ProtoReflect 

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

func (*PingAndGetNewTasksRequest) Reset 

func (x *PingAndGetNewTasksRequest) Reset()

func (*PingAndGetNewTasksRequest) String 

func (x *PingAndGetNewTasksRequest) String() string

type Provider 

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

func (*Provider) Descriptor deprecated 

func (*Provider) 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 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"`
	// contains filtered or unexported fields
}

func (*RunTemplateRequest) Descriptor deprecated 

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

Deprecated: Use RunTemplateRequest.ProtoReflect.Descriptor instead.

func (*RunTemplateRequest) GetNoRecruiters added in v0.7.1 

func (x *RunTemplateRequest) GetNoRecruiters() bool

func (*RunTemplateRequest) GetParamValuesJson 

func (x *RunTemplateRequest) GetParamValuesJson() string

func (*RunTemplateRequest) GetWorkflowTemplateId 

func (x *RunTemplateRequest) GetWorkflowTemplateId() int32

func (*RunTemplateRequest) ProtoMessage 

func (*RunTemplateRequest) ProtoMessage()

func (*RunTemplateRequest) ProtoReflect 

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

func (*RunTemplateRequest) Reset 

func (x *RunTemplateRequest) Reset()

func (*RunTemplateRequest) String 

func (x *RunTemplateRequest) String() string

type StatusCountEntry added in v0.6.1 

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

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

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

Deprecated: Use StatusCountEntry.ProtoReflect.Descriptor instead.

func (*StatusCountEntry) GetCount added in v0.6.1 

func (x *StatusCountEntry) GetCount() int32

func (*StatusCountEntry) GetStatus added in v0.6.1 

func (x *StatusCountEntry) GetStatus() string

func (*StatusCountEntry) GetWorkerId added in v0.6.1 

func (x *StatusCountEntry) GetWorkerId() int32

func (*StatusCountEntry) ProtoMessage added in v0.6.1 

func (*StatusCountEntry) ProtoMessage()

func (*StatusCountEntry) ProtoReflect added in v0.6.1 

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

func (*StatusCountEntry) Reset added in v0.6.1 

func (x *StatusCountEntry) Reset()

func (*StatusCountEntry) String added in v0.6.1 

func (x *StatusCountEntry) String() string

type Step 

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

func (*Step) Descriptor deprecated 

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

Deprecated: Use Step.ProtoReflect.Descriptor instead.

func (*Step) GetName 

func (x *Step) GetName() 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"`
	// contains filtered or unexported fields
}

func (*StepRequest) Descriptor deprecated 

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

Deprecated: Use StepRequest.ProtoReflect.Descriptor instead.

func (*StepRequest) GetName 

func (x *StepRequest) GetName() string

func (*StepRequest) GetWorkflowId 

func (x *StepRequest) GetWorkflowId() int32

func (*StepRequest) GetWorkflowName 

func (x *StepRequest) GetWorkflowName() string

func (*StepRequest) ProtoMessage 

func (*StepRequest) ProtoMessage()

func (*StepRequest) ProtoReflect 

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

func (*StepRequest) Reset 

func (x *StepRequest) Reset()

func (*StepRequest) String 

func (x *StepRequest) String() string

type StepStats 

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

func (*StepStats) Descriptor deprecated 

func (*StepStats) 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 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)
	// 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) GetDownloadTimeout 

func (x *Task) GetDownloadTimeout() float32

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) 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) GetResource 

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

func (*Task) GetRetry 

func (x *Task) GetRetry() int32

func (*Task) GetRetryCount 

func (x *Task) GetRetryCount() int32

func (*Task) GetRunStartTime 

func (x *Task) GetRunStartTime() int64

func (*Task) GetRunningTimeout 

func (x *Task) GetRunningTimeout() float32

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) 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"`
	// contains filtered or unexported fields
}

func (*TaskListAndOther) Descriptor deprecated 

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

Deprecated: Use TaskListAndOther.ProtoReflect.Descriptor instead.

func (*TaskListAndOther) GetActiveTasks 

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

func (*TaskListAndOther) GetConcurrency 

func (x *TaskListAndOther) GetConcurrency() int32

func (*TaskListAndOther) GetTasks 

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

func (*TaskListAndOther) GetUpdates 

func (x *TaskListAndOther) GetUpdates() *TaskUpdateList

func (*TaskListAndOther) ProtoMessage 

func (*TaskListAndOther) ProtoMessage()

func (*TaskListAndOther) ProtoReflect 

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

func (*TaskListAndOther) Reset 

func (x *TaskListAndOther) Reset()

func (*TaskListAndOther) String 

func (x *TaskListAndOther) String() string

type TaskLog 

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

func (*TaskLog) Descriptor deprecated 

func (*TaskLog) 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)
	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)
	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)
	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)
	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)
	// 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)
	DownloadModule(ctx context.Context, in *DownloadModuleRequest, opts ...grpc.CallOption) (*FileContent, 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)
}

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)
	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)
	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)
	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)
	ListTemplateRuns(context.Context, *TemplateRunFilter) (*TemplateRunList, error)
	UpdateTemplateRun(context.Context, *UpdateTemplateRunRequest) (*Ack, error)
	DeleteTemplateRun(context.Context, *DeleteTemplateRunRequest) (*Ack, error)
	// Module system
	UploadModule(context.Context, *UploadModuleRequest) (*Ack, error)
	ListModules(context.Context, *emptypb.Empty) (*ModuleList, error)
	DownloadModule(context.Context, *DownloadModuleRequest) (*FileContent, 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)
	// 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)
	// 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) GetContainer 

func (x *TaskRequest) GetContainer() string

func (*TaskRequest) GetContainerOptions 

func (x *TaskRequest) GetContainerOptions() string

func (*TaskRequest) GetDependency 

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

func (*TaskRequest) GetDownloadTimeout 

func (x *TaskRequest) GetDownloadTimeout() float32

func (*TaskRequest) GetInput 

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

func (*TaskRequest) GetIsFinal 

func (x *TaskRequest) GetIsFinal() bool

func (*TaskRequest) GetOutput 

func (x *TaskRequest) GetOutput() string

func (*TaskRequest) GetPublish added in v0.7.1 

func (x *TaskRequest) GetPublish() string

func (*TaskRequest) GetResource 

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

func (*TaskRequest) GetRetry 

func (x *TaskRequest) GetRetry() int32

func (*TaskRequest) GetRunningTimeout 

func (x *TaskRequest) GetRunningTimeout() float32

func (*TaskRequest) GetShell 

func (x *TaskRequest) GetShell() string

func (*TaskRequest) 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 TaskStatusCountsRequest added in v0.6.1 

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

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

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

Deprecated: Use TaskStatusCountsRequest.ProtoReflect.Descriptor instead.

func (*TaskStatusCountsRequest) GetShowHidden added in v0.6.1 

func (x *TaskStatusCountsRequest) GetShowHidden() bool

func (*TaskStatusCountsRequest) ProtoMessage added in v0.6.1 

func (*TaskStatusCountsRequest) ProtoMessage()

func (*TaskStatusCountsRequest) ProtoReflect added in v0.6.1 

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

func (*TaskStatusCountsRequest) Reset added in v0.6.1 

func (x *TaskStatusCountsRequest) Reset()

func (*TaskStatusCountsRequest) String added in v0.6.1 

func (x *TaskStatusCountsRequest) String() string

type TaskStatusCountsResponse added in v0.6.1 

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

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

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

Deprecated: Use TaskStatusCountsResponse.ProtoReflect.Descriptor instead.

func (*TaskStatusCountsResponse) GetGlobalCounts added in v0.6.1 

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

func (*TaskStatusCountsResponse) GetPerWorkerCounts added in v0.6.1 

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

func (*TaskStatusCountsResponse) GetTotalCount added in v0.6.1 

func (x *TaskStatusCountsResponse) GetTotalCount() int32

func (*TaskStatusCountsResponse) ProtoMessage added in v0.6.1 

func (*TaskStatusCountsResponse) ProtoMessage()

func (*TaskStatusCountsResponse) ProtoReflect added in v0.6.1 

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

func (*TaskStatusCountsResponse) Reset added in v0.6.1 

func (x *TaskStatusCountsResponse) Reset()

func (*TaskStatusCountsResponse) String added in v0.6.1 

func (x *TaskStatusCountsResponse) String() string

type TaskStatusUpdate 

type TaskStatusUpdate struct {
	TaskId    int32  `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	NewStatus string `protobuf:"bytes,2,opt,name=new_status,json=newStatus,proto3" json:"new_status,omitempty"`
	Duration  *int32 `protobuf:"varint,3,opt,name=duration,proto3,oneof" json:"duration,omitempty"`                    // in seconds
	FreeRetry *bool  `protobuf:"varint,4,opt,name=free_retry,json=freeRetry,proto3,oneof" json:"free_retry,omitempty"` // if new_status is F and this is true, then retry is increased by 1 before setting status to F
	// contains filtered or unexported fields
}

func (*TaskStatusUpdate) Descriptor deprecated 

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

Deprecated: Use TaskStatusUpdate.ProtoReflect.Descriptor instead.

func (*TaskStatusUpdate) GetDuration 

func (x *TaskStatusUpdate) GetDuration() int32

func (*TaskStatusUpdate) GetFreeRetry 

func (x *TaskStatusUpdate) GetFreeRetry() bool

func (*TaskStatusUpdate) GetNewStatus 

func (x *TaskStatusUpdate) GetNewStatus() string

func (*TaskStatusUpdate) GetTaskId 

func (x *TaskStatusUpdate) GetTaskId() int32

func (*TaskStatusUpdate) ProtoMessage 

func (*TaskStatusUpdate) ProtoMessage()

func (*TaskStatusUpdate) ProtoReflect 

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

func (*TaskStatusUpdate) Reset 

func (x *TaskStatusUpdate) Reset()

func (*TaskStatusUpdate) String 

func (x *TaskStatusUpdate) String() string

type TaskUpdate 

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

func (*TaskUpdate) Descriptor deprecated 

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

Deprecated: Use TaskUpdate.ProtoReflect.Descriptor instead.

func (*TaskUpdate) GetWeight 

func (x *TaskUpdate) GetWeight() float64

func (*TaskUpdate) ProtoMessage 

func (*TaskUpdate) ProtoMessage()

func (*TaskUpdate) ProtoReflect 

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

func (*TaskUpdate) Reset 

func (x *TaskUpdate) Reset()

func (*TaskUpdate) String 

func (x *TaskUpdate) String() string

type TaskUpdateList 

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

func (*TaskUpdateList) Descriptor deprecated 

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

Deprecated: Use TaskUpdateList.ProtoReflect.Descriptor instead.

func (*TaskUpdateList) GetUpdates 

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

func (*TaskUpdateList) ProtoMessage 

func (*TaskUpdateList) ProtoMessage()

func (*TaskUpdateList) ProtoReflect 

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

func (*TaskUpdateList) Reset 

func (x *TaskUpdateList) Reset()

func (*TaskUpdateList) String 

func (x *TaskUpdateList) String() string

type Template 

type Template struct {
	WorkflowTemplateId int32  `protobuf:"varint,1,opt,name=workflow_template_id,json=workflowTemplateId,proto3" json:"workflow_template_id,omitempty"`
	Name               string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version            string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Description        string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	ParamJson          string `protobuf:"bytes,5,opt,name=param_json,json=paramJson,proto3" json:"param_json,omitempty"`
	UploadedAt         string `protobuf:"bytes,6,opt,name=uploaded_at,json=uploadedAt,proto3" json:"uploaded_at,omitempty"`
	UploadedBy         *int32 `protobuf:"varint,7,opt,name=uploaded_by,json=uploadedBy,proto3,oneof" json:"uploaded_by,omitempty"`
	// contains filtered or unexported fields
}

func (*Template) Descriptor deprecated 

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

Deprecated: Use Template.ProtoReflect.Descriptor instead.

func (*Template) GetDescription 

func (x *Template) GetDescription() string

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) 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"`
	// contains filtered or unexported fields
}

func (*TemplateFilter) Descriptor deprecated 

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

Deprecated: Use TemplateFilter.ProtoReflect.Descriptor instead.

func (*TemplateFilter) GetName 

func (x *TemplateFilter) GetName() string

func (*TemplateFilter) GetVersion 

func (x *TemplateFilter) GetVersion() string

func (*TemplateFilter) GetWorkflowTemplateId 

func (x *TemplateFilter) GetWorkflowTemplateId() int32

func (*TemplateFilter) ProtoMessage 

func (*TemplateFilter) ProtoMessage()

func (*TemplateFilter) ProtoReflect 

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

func (*TemplateFilter) Reset 

func (x *TemplateFilter) Reset()

func (*TemplateFilter) String 

func (x *TemplateFilter) String() string

type TemplateList 

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

func (*TemplateList) Descriptor deprecated 

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

Deprecated: Use TemplateList.ProtoReflect.Descriptor instead.

func (*TemplateList) GetTemplates 

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

func (*TemplateList) ProtoMessage 

func (*TemplateList) ProtoMessage()

func (*TemplateList) ProtoReflect 

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

func (*TemplateList) Reset 

func (x *TemplateList) Reset()

func (*TemplateList) String 

func (x *TemplateList) String() string

type TemplateRun 

type TemplateRun struct {
	TemplateRunId      int32   `protobuf:"varint,1,opt,name=template_run_id,json=templateRunId,proto3" json:"template_run_id,omitempty"`
	WorkflowTemplateId int32   `protobuf:"varint,2,opt,name=workflow_template_id,json=workflowTemplateId,proto3" json:"workflow_template_id,omitempty"`
	TemplateName       *string `protobuf:"bytes,3,opt,name=template_name,json=templateName,proto3,oneof" json:"template_name,omitempty"`
	TemplateVersion    *string `protobuf:"bytes,4,opt,name=template_version,json=templateVersion,proto3,oneof" json:"template_version,omitempty"`
	WorkflowName       *string `protobuf:"bytes,5,opt,name=workflow_name,json=workflowName,proto3,oneof" json:"workflow_name,omitempty"`
	RunBy              *int32  `protobuf:"varint,6,opt,name=run_by,json=runBy,proto3,oneof" json:"run_by,omitempty"`
	Status             string  `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"`
	WorkflowId         *int32  `protobuf:"varint,8,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
	CreatedAt          string  `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ParamValuesJson    string  `protobuf:"bytes,10,opt,name=param_values_json,json=paramValuesJson,proto3" json:"param_values_json,omitempty"`
	ErrorMessage       *string `protobuf:"bytes,11,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"`
	RunByUsername      *string `protobuf:"bytes,12,opt,name=run_by_username,json=runByUsername,proto3,oneof" json:"run_by_username,omitempty"`
	// contains filtered or unexported fields
}

func (*TemplateRun) Descriptor deprecated 

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

Deprecated: Use TemplateRun.ProtoReflect.Descriptor instead.

func (*TemplateRun) GetCreatedAt 

func (x *TemplateRun) GetCreatedAt() string

func (*TemplateRun) GetErrorMessage 

func (x *TemplateRun) GetErrorMessage() string

func (*TemplateRun) GetParamValuesJson 

func (x *TemplateRun) GetParamValuesJson() string

func (*TemplateRun) GetRunBy 

func (x *TemplateRun) GetRunBy() int32

func (*TemplateRun) GetRunByUsername 

func (x *TemplateRun) GetRunByUsername() string

func (*TemplateRun) GetStatus 

func (x *TemplateRun) GetStatus() string

func (*TemplateRun) GetTemplateName 

func (x *TemplateRun) GetTemplateName() string

func (*TemplateRun) GetTemplateRunId 

func (x *TemplateRun) GetTemplateRunId() int32

func (*TemplateRun) GetTemplateVersion 

func (x *TemplateRun) GetTemplateVersion() string

func (*TemplateRun) GetWorkflowId 

func (x *TemplateRun) GetWorkflowId() int32

func (*TemplateRun) GetWorkflowName 

func (x *TemplateRun) GetWorkflowName() string

func (*TemplateRun) GetWorkflowTemplateId 

func (x *TemplateRun) GetWorkflowTemplateId() int32

func (*TemplateRun) ProtoMessage 

func (*TemplateRun) ProtoMessage()

func (*TemplateRun) ProtoReflect 

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

func (*TemplateRun) Reset 

func (x *TemplateRun) Reset()

func (*TemplateRun) String 

func (x *TemplateRun) String() string

type TemplateRunFilter 

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

func (*TemplateRunFilter) Descriptor deprecated 

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

Deprecated: Use TemplateRunFilter.ProtoReflect.Descriptor instead.

func (*TemplateRunFilter) GetWorkflowTemplateId 

func (x *TemplateRunFilter) GetWorkflowTemplateId() int32

func (*TemplateRunFilter) ProtoMessage 

func (*TemplateRunFilter) ProtoMessage()

func (*TemplateRunFilter) ProtoReflect 

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

func (*TemplateRunFilter) Reset 

func (x *TemplateRunFilter) Reset()

func (*TemplateRunFilter) String 

func (x *TemplateRunFilter) String() string

type TemplateRunList 

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

func (*TemplateRunList) Descriptor deprecated 

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

Deprecated: Use TemplateRunList.ProtoReflect.Descriptor instead.

func (*TemplateRunList) GetRuns 

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

func (*TemplateRunList) ProtoMessage 

func (*TemplateRunList) ProtoMessage()

func (*TemplateRunList) ProtoReflect 

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

func (*TemplateRunList) Reset 

func (x *TemplateRunList) Reset()

func (*TemplateRunList) String 

func (x *TemplateRunList) String() string

type Token 

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

func (*Token) Descriptor deprecated 

func (*Token) 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) AdminResetPassword(context.Context, *AdminResetPasswordRequest) (*Ack, error)

func (UnimplementedTaskQueueServer) ChangePassword 

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

func (UnimplementedTaskQueueServer) CreateFlavor 

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

func (UnimplementedTaskQueueServer) CreateRecruiter 

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

func (UnimplementedTaskQueueServer) CreateStep 

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

func (UnimplementedTaskQueueServer) CreateUser 

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

func (UnimplementedTaskQueueServer) CreateWorker 

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

func (UnimplementedTaskQueueServer) CreateWorkerByName added in v0.7.1 

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

func (UnimplementedTaskQueueServer) CreateWorkflow 

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

func (UnimplementedTaskQueueServer) DebugAssignTask 

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

func (UnimplementedTaskQueueServer) DebugRecruitStep 

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

func (UnimplementedTaskQueueServer) DebugRetryTask 

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

func (UnimplementedTaskQueueServer) DeleteJob 

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

func (UnimplementedTaskQueueServer) DeleteRecruiter 

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

func (UnimplementedTaskQueueServer) DeleteStep 

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

func (UnimplementedTaskQueueServer) DeleteTemplateRun 

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

func (UnimplementedTaskQueueServer) DeleteUser 

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

func (UnimplementedTaskQueueServer) DeleteWorker 

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

func (UnimplementedTaskQueueServer) DeleteWorkerEvent 

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

func (UnimplementedTaskQueueServer) DeleteWorkflow 

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

func (UnimplementedTaskQueueServer) DownloadModule added in v0.7.1 

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

func (UnimplementedTaskQueueServer) DownloadTemplate added in v0.7.1 

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

func (UnimplementedTaskQueueServer) EditAndRetryTask added in v0.7.1 

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

func (UnimplementedTaskQueueServer) EditStepCommand added in v0.7.1 

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

func (UnimplementedTaskQueueServer) FetchInfo 

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

func (UnimplementedTaskQueueServer) FetchList 

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

func (UnimplementedTaskQueueServer) ForceRunTask added in v0.7.1 

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

func (UnimplementedTaskQueueServer) GetCertificate 

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

func (UnimplementedTaskQueueServer) GetDockerCredentials 

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

func (UnimplementedTaskQueueServer) GetJobStatuses 

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

func (UnimplementedTaskQueueServer) GetLogsChunk 

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

func (UnimplementedTaskQueueServer) GetRcloneConfig 

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

func (UnimplementedTaskQueueServer) GetResourceRoot added in v0.7.1 

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

func (UnimplementedTaskQueueServer) GetStepStats 

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

func (UnimplementedTaskQueueServer) GetTaskStatusCounts added in v0.6.1 

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

func (UnimplementedTaskQueueServer) GetWorkerStats 

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

func (UnimplementedTaskQueueServer) GetWorkerStatuses 

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

func (UnimplementedTaskQueueServer) GetWorkspaceRoot 

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

func (UnimplementedTaskQueueServer) ListDependentPendingTasks 

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

func (UnimplementedTaskQueueServer) ListFlavors 

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

func (UnimplementedTaskQueueServer) ListJobs 

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

func (UnimplementedTaskQueueServer) ListModules added in v0.7.1 

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

func (UnimplementedTaskQueueServer) ListProviders 

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

func (UnimplementedTaskQueueServer) ListRecruiters 

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

func (UnimplementedTaskQueueServer) ListRegions 

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

func (UnimplementedTaskQueueServer) ListSteps 

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

func (UnimplementedTaskQueueServer) ListTasks 

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

func (UnimplementedTaskQueueServer) ListTemplateRuns 

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

func (UnimplementedTaskQueueServer) ListTemplates 

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

func (UnimplementedTaskQueueServer) ListUsers 

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

func (UnimplementedTaskQueueServer) ListWorkerEvents 

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

func (UnimplementedTaskQueueServer) ListWorkers 

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

func (UnimplementedTaskQueueServer) ListWorkflows 

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

func (UnimplementedTaskQueueServer) Login 

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

func (UnimplementedTaskQueueServer) Logout 

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

func (UnimplementedTaskQueueServer) PingAndTakeNewTasks 

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

func (UnimplementedTaskQueueServer) PruneWorkerEvents 

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

func (UnimplementedTaskQueueServer) RegisterSpecifications 

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

func (UnimplementedTaskQueueServer) RegisterWorker 

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

func (UnimplementedTaskQueueServer) ReportWorkerEvent 

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

func (UnimplementedTaskQueueServer) RetryTask 

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

func (UnimplementedTaskQueueServer) RunTemplate 

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

func (UnimplementedTaskQueueServer) SendTaskLogs 

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

func (UnimplementedTaskQueueServer) StreamTaskLogsErr 

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

func (UnimplementedTaskQueueServer) StreamTaskLogsOutput 

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

func (UnimplementedTaskQueueServer) SubmitTask 

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

func (UnimplementedTaskQueueServer) UpdateJob 

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

func (UnimplementedTaskQueueServer) UpdateRecruiter 

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

func (UnimplementedTaskQueueServer) UpdateTaskStatus 

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

func (UnimplementedTaskQueueServer) UpdateTemplateRun 

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

func (UnimplementedTaskQueueServer) UpdateUser 

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

func (UnimplementedTaskQueueServer) UpdateWorker 

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

func (UnimplementedTaskQueueServer) UpdateWorkerStatus 

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

func (UnimplementedTaskQueueServer) UpdateWorkflowStatus 

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

func (UnimplementedTaskQueueServer) UploadModule added in v0.7.1 

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

func (UnimplementedTaskQueueServer) UploadTemplate 

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

func (UnimplementedTaskQueueServer) UserUpdateWorker 

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

type UnsafeTaskQueueServer 

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

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

type UpdateTemplateRunRequest 

type UpdateTemplateRunRequest struct {
	TemplateRunId int32   `protobuf:"varint,1,opt,name=template_run_id,json=templateRunId,proto3" json:"template_run_id,omitempty"`
	WorkflowId    *int32  `protobuf:"varint,2,opt,name=workflow_id,json=workflowId,proto3,oneof" json:"workflow_id,omitempty"`
	ErrorMessage  *string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTemplateRunRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTemplateRunRequest.ProtoReflect.Descriptor instead.

func (*UpdateTemplateRunRequest) GetErrorMessage 

func (x *UpdateTemplateRunRequest) GetErrorMessage() string

func (*UpdateTemplateRunRequest) GetTemplateRunId 

func (x *UpdateTemplateRunRequest) GetTemplateRunId() int32

func (*UpdateTemplateRunRequest) GetWorkflowId 

func (x *UpdateTemplateRunRequest) GetWorkflowId() int32

func (*UpdateTemplateRunRequest) ProtoMessage 

func (*UpdateTemplateRunRequest) ProtoMessage()

func (*UpdateTemplateRunRequest) ProtoReflect 

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

func (*UpdateTemplateRunRequest) Reset 

func (x *UpdateTemplateRunRequest) Reset()

func (*UpdateTemplateRunRequest) String 

func (x *UpdateTemplateRunRequest) String() string

type 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"`
	// contains filtered or unexported fields
}

func (*Worker) Descriptor deprecated 

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

Deprecated: Use Worker.ProtoReflect.Descriptor instead.

func (*Worker) GetConcurrency 

func (x *Worker) GetConcurrency() int32

func (*Worker) GetFlavor 

func (x *Worker) GetFlavor() string

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) 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) 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"`
	// contains filtered or unexported fields
}

func (*WorkerInfo) Descriptor deprecated 

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

Deprecated: Use WorkerInfo.ProtoReflect.Descriptor instead.

func (*WorkerInfo) GetConcurrency 

func (x *WorkerInfo) GetConcurrency() int32

func (*WorkerInfo) GetIsPermanent 

func (x *WorkerInfo) GetIsPermanent() bool

func (*WorkerInfo) GetName 

func (x *WorkerInfo) GetName() string

func (*WorkerInfo) GetProvider 

func (x *WorkerInfo) GetProvider() string

func (*WorkerInfo) GetRegion 

func (x *WorkerInfo) GetRegion() string

func (*WorkerInfo) ProtoMessage 

func (*WorkerInfo) ProtoMessage()

func (*WorkerInfo) ProtoReflect 

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

func (*WorkerInfo) Reset 

func (x *WorkerInfo) Reset()

func (*WorkerInfo) String 

func (x *WorkerInfo) String() string

type WorkerRequest 

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

func (*WorkerRequest) Descriptor deprecated 

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

Deprecated: Use WorkerRequest.ProtoReflect.Descriptor instead.

func (*WorkerRequest) GetConcurrency 

func (x *WorkerRequest) GetConcurrency() int32

func (*WorkerRequest) GetFlavorId 

func (x *WorkerRequest) GetFlavorId() int32

func (*WorkerRequest) GetNumber 

func (x *WorkerRequest) GetNumber() int32

func (*WorkerRequest) GetPrefetch 

func (x *WorkerRequest) GetPrefetch() int32

func (*WorkerRequest) GetProviderId 

func (x *WorkerRequest) GetProviderId() int32

func (*WorkerRequest) GetRegionId 

func (x *WorkerRequest) GetRegionId() int32

func (*WorkerRequest) GetStepId 

func (x *WorkerRequest) GetStepId() int32

func (*WorkerRequest) ProtoMessage 

func (*WorkerRequest) ProtoMessage()

func (*WorkerRequest) ProtoReflect 

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

func (*WorkerRequest) Reset 

func (x *WorkerRequest) Reset()

func (*WorkerRequest) String 

func (x *WorkerRequest) String() string

type WorkerStats 

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

func (*WorkerUpdateRequest) Descriptor deprecated 

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

Deprecated: Use WorkerUpdateRequest.ProtoReflect.Descriptor instead.

func (*WorkerUpdateRequest) GetConcurrency 

func (x *WorkerUpdateRequest) GetConcurrency() int32

func (*WorkerUpdateRequest) GetFlavorId 

func (x *WorkerUpdateRequest) GetFlavorId() int32

func (*WorkerUpdateRequest) GetIsPermanent 

func (x *WorkerUpdateRequest) GetIsPermanent() bool

func (*WorkerUpdateRequest) GetPrefetch 

func (x *WorkerUpdateRequest) GetPrefetch() int32

func (*WorkerUpdateRequest) GetProviderId 

func (x *WorkerUpdateRequest) GetProviderId() int32

func (*WorkerUpdateRequest) GetRecyclableScope 

func (x *WorkerUpdateRequest) GetRecyclableScope() string

func (*WorkerUpdateRequest) GetRegionId 

func (x *WorkerUpdateRequest) GetRegionId() int32

func (*WorkerUpdateRequest) GetStepId 

func (x *WorkerUpdateRequest) GetStepId() int32

func (*WorkerUpdateRequest) GetStepName 

func (x *WorkerUpdateRequest) GetStepName() string

func (*WorkerUpdateRequest) GetWorkerId 

func (x *WorkerUpdateRequest) GetWorkerId() int32

func (*WorkerUpdateRequest) GetWorkflowName 

func (x *WorkerUpdateRequest) GetWorkflowName() string

func (*WorkerUpdateRequest) ProtoMessage 

func (*WorkerUpdateRequest) ProtoMessage()

func (*WorkerUpdateRequest) ProtoReflect 

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

func (*WorkerUpdateRequest) Reset 

func (x *WorkerUpdateRequest) Reset()

func (*WorkerUpdateRequest) String 

func (x *WorkerUpdateRequest) String() string

type WorkersList 

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

func (*WorkersList) Descriptor deprecated 

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

Deprecated: Use WorkersList.ProtoReflect.Descriptor instead.

func (*WorkersList) GetWorkers 

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

func (*WorkersList) ProtoMessage 

func (*WorkersList) ProtoMessage()

func (*WorkersList) ProtoReflect 

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

func (*WorkersList) Reset 

func (x *WorkersList) Reset()

func (*WorkersList) String 

func (x *WorkersList) String() string

type Workflow 

type Workflow struct {
	WorkflowId     int32  `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	Name           string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Status         string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	RunStrategy    string `protobuf:"bytes,4,opt,name=run_strategy,json=runStrategy,proto3" json:"run_strategy,omitempty"`
	MaximumWorkers *int32 `protobuf:"varint,5,opt,name=maximum_workers,json=maximumWorkers,proto3,oneof" json:"maximum_workers,omitempty"`
	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)
	// 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) GetMaximumWorkers 

func (x *Workflow) GetMaximumWorkers() int32

func (*Workflow) GetName 

func (x *Workflow) GetName() string

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) GetStatus 

func (x *Workflow) GetStatus() string

func (*Workflow) GetSucceededTasks added in v0.7.1 

func (x *Workflow) GetSucceededTasks() int32

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"`
	// contains filtered or unexported fields
}

func (*WorkflowFilter) Descriptor deprecated 

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

Deprecated: Use WorkflowFilter.ProtoReflect.Descriptor instead.

func (*WorkflowFilter) GetLimit 

func (x *WorkflowFilter) GetLimit() int32

func (*WorkflowFilter) GetNameLike 

func (x *WorkflowFilter) GetNameLike() string

func (*WorkflowFilter) GetOffset 

func (x *WorkflowFilter) GetOffset() int32

func (*WorkflowFilter) ProtoMessage 

func (*WorkflowFilter) ProtoMessage()

func (*WorkflowFilter) ProtoReflect 

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

func (*WorkflowFilter) Reset 

func (x *WorkflowFilter) Reset()

func (*WorkflowFilter) String 

func (x *WorkflowFilter) String() string

type WorkflowId 

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

func (*WorkflowId) Descriptor deprecated 

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

Deprecated: Use WorkflowId.ProtoReflect.Descriptor instead.

func (*WorkflowId) GetWorkflowId 

func (x *WorkflowId) GetWorkflowId() int32

func (*WorkflowId) ProtoMessage 

func (*WorkflowId) ProtoMessage()

func (*WorkflowId) ProtoReflect 

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

func (*WorkflowId) Reset 

func (x *WorkflowId) Reset()

func (*WorkflowId) String 

func (x *WorkflowId) String() string

type WorkflowList 

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

func (*WorkflowList) Descriptor deprecated 

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

Deprecated: Use WorkflowList.ProtoReflect.Descriptor instead.

func (*WorkflowList) GetWorkflows 

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

func (*WorkflowList) ProtoMessage 

func (*WorkflowList) ProtoMessage()

func (*WorkflowList) ProtoReflect 

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

func (*WorkflowList) Reset 

func (x *WorkflowList) Reset()

func (*WorkflowList) String 

func (x *WorkflowList) String() string

type WorkflowRequest 

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

func (*WorkflowRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowRequest.ProtoReflect.Descriptor instead.

func (*WorkflowRequest) GetMaximumWorkers 

func (x *WorkflowRequest) GetMaximumWorkers() int32

func (*WorkflowRequest) GetName 

func (x *WorkflowRequest) GetName() string

func (*WorkflowRequest) GetRunStrategy 

func (x *WorkflowRequest) GetRunStrategy() string

func (*WorkflowRequest) GetStatus 

func (x *WorkflowRequest) GetStatus() string

func (*WorkflowRequest) ProtoMessage 

func (*WorkflowRequest) ProtoMessage()

func (*WorkflowRequest) ProtoReflect 

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

func (*WorkflowRequest) Reset 

func (x *WorkflowRequest) Reset()

func (*WorkflowRequest) String 

func (x *WorkflowRequest) String() string

type WorkflowStatusUpdate 

type WorkflowStatusUpdate struct {
	WorkflowId     int32  `protobuf:"varint,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	Status         string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.