v1

package
v0.0.12 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2025 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	QueueTask_GetAgentTask_FullMethodName    = "/server.queue.v1.QueueTask/GetAgentTask"
	QueueTask_UpdateAgentTask_FullMethodName = "/server.queue.v1.QueueTask/UpdateAgentTask"
)
View Source 
const OperationQueueTaskGetAgentTask = "/server.queue.v1.QueueTask/GetAgentTask"
View Source 
const OperationQueueTaskUpdateAgentTask = "/server.queue.v1.QueueTask/UpdateAgentTask"

Variables

View Source 
var (
	TaskCmd_name = map[int32]string{
		0:  "VM_CREATE",
		1:  "VM_DELETE",
		2:  "VM_START",
		3:  "VM_SHUTDOWN",
		4:  "VM_RESTART",
		5:  "VM_RECREATE",
		6:  "NAT_PROXY_CREATE",
		7:  "NAT_PROXY_DELETE",
		8:  "NAT_PROXY_EDIT",
		9:  "NAT_VISITOR_CREATE",
		10: "NAT_VISITOR_DELETE",
		11: "STORAGE_CREATE",
		12: "STORAGE_DELETE",
		99: "PING",
	}
	TaskCmd_value = map[string]int32{
		"VM_CREATE":          0,
		"VM_DELETE":          1,
		"VM_START":           2,
		"VM_SHUTDOWN":        3,
		"VM_RESTART":         4,
		"VM_RECREATE":        5,
		"NAT_PROXY_CREATE":   6,
		"NAT_PROXY_DELETE":   7,
		"NAT_PROXY_EDIT":     8,
		"NAT_VISITOR_CREATE": 9,
		"NAT_VISITOR_DELETE": 10,
		"STORAGE_CREATE":     11,
		"STORAGE_DELETE":     12,
		"PING":               99,
	}
)

Enum value maps for TaskCmd.

View Source 
var (
	TaskStatus_name = map[int32]string{
		0: "CREATED",
		1: "EXECUTING",
		2: "EXECUTED",
		3: "FAILED",
	}
	TaskStatus_value = map[string]int32{
		"CREATED":   0,
		"EXECUTING": 1,
		"EXECUTED":  2,
		"FAILED":    3,
	}
)

Enum value maps for TaskStatus.

View Source 
var File_server_queue_v1_task_proto protoreflect.FileDescriptor
View Source 
var QueueTask_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "server.queue.v1.QueueTask",
	HandlerType: (*QueueTaskServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetAgentTask",
			Handler:    _QueueTask_GetAgentTask_Handler,
		},
		{
			MethodName: "UpdateAgentTask",
			Handler:    _QueueTask_UpdateAgentTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "server/queue/v1/task.proto",
}

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

Functions

func RegisterQueueTaskHTTPServer 

func RegisterQueueTaskHTTPServer(s *http.Server, srv QueueTaskHTTPServer)

func RegisterQueueTaskServer 

func RegisterQueueTaskServer(s grpc.ServiceRegistrar, srv QueueTaskServer)

Types

type ComputeInstanceTaskParamVO 

type ComputeInstanceTaskParamVO struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name           string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Cpu            int64  `protobuf:"varint,3,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory         int64  `protobuf:"varint,4,opt,name=memory,proto3" json:"memory,omitempty"`
	Image          string `protobuf:"bytes,5,opt,name=image,proto3" json:"image,omitempty"`
	PublicKey      string `protobuf:"bytes,6,opt,name=publicKey,proto3" json:"publicKey,omitempty"`
	Password       string `protobuf:"bytes,7,opt,name=password,proto3" json:"password,omitempty"`
	InstanceId     string `protobuf:"bytes,8,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	GatewayIp      string `protobuf:"bytes,9,opt,name=gatewayIp,proto3" json:"gatewayIp,omitempty"`
	GatewayPort    int32  `protobuf:"varint,10,opt,name=gatewayPort,proto3" json:"gatewayPort,omitempty"`
	VncConnectIp   string `protobuf:"bytes,11,opt,name=vncConnectIp,proto3" json:"vncConnectIp,omitempty"`
	VncConnectPort int32  `protobuf:"varint,12,opt,name=vncConnectPort,proto3" json:"vncConnectPort,omitempty"`
	DockerCompose  string `protobuf:"bytes,13,opt,name=docker_compose,json=dockerCompose,proto3" json:"docker_compose,omitempty"`
	ImageId        int32  `protobuf:"varint,14,opt,name=imageId,proto3" json:"imageId,omitempty"`
	AuthToken      string `protobuf:"bytes,15,opt,name=authToken,proto3" json:"authToken,omitempty"`
	BootType       string `protobuf:"bytes,16,opt,name=bootType,proto3" json:"bootType,omitempty"`
	// contains filtered or unexported fields
}

func (*ComputeInstanceTaskParamVO) Descriptor deprecated 

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

Deprecated: Use ComputeInstanceTaskParamVO.ProtoReflect.Descriptor instead.

func (*ComputeInstanceTaskParamVO) GetAuthToken added in v0.0.12 

func (x *ComputeInstanceTaskParamVO) GetAuthToken() string

func (*ComputeInstanceTaskParamVO) GetBootType added in v0.0.12 

func (x *ComputeInstanceTaskParamVO) GetBootType() string

func (*ComputeInstanceTaskParamVO) GetCpu 

func (x *ComputeInstanceTaskParamVO) GetCpu() int64

func (*ComputeInstanceTaskParamVO) GetDockerCompose 

func (x *ComputeInstanceTaskParamVO) GetDockerCompose() string

func (*ComputeInstanceTaskParamVO) GetGatewayIp 

func (x *ComputeInstanceTaskParamVO) GetGatewayIp() string

func (*ComputeInstanceTaskParamVO) GetGatewayPort 

func (x *ComputeInstanceTaskParamVO) GetGatewayPort() int32

func (*ComputeInstanceTaskParamVO) GetId 

func (x *ComputeInstanceTaskParamVO) GetId() string

func (*ComputeInstanceTaskParamVO) GetImage 

func (x *ComputeInstanceTaskParamVO) GetImage() string

func (*ComputeInstanceTaskParamVO) GetImageId 

func (x *ComputeInstanceTaskParamVO) GetImageId() int32

func (*ComputeInstanceTaskParamVO) GetInstanceId 

func (x *ComputeInstanceTaskParamVO) GetInstanceId() string

func (*ComputeInstanceTaskParamVO) GetMemory 

func (x *ComputeInstanceTaskParamVO) GetMemory() int64

func (*ComputeInstanceTaskParamVO) GetName 

func (x *ComputeInstanceTaskParamVO) GetName() string

func (*ComputeInstanceTaskParamVO) GetPassword 

func (x *ComputeInstanceTaskParamVO) GetPassword() string

func (*ComputeInstanceTaskParamVO) GetPublicKey 

func (x *ComputeInstanceTaskParamVO) GetPublicKey() string

func (*ComputeInstanceTaskParamVO) GetVncConnectIp 

func (x *ComputeInstanceTaskParamVO) GetVncConnectIp() string

func (*ComputeInstanceTaskParamVO) GetVncConnectPort 

func (x *ComputeInstanceTaskParamVO) GetVncConnectPort() int32

func (*ComputeInstanceTaskParamVO) ProtoMessage 

func (*ComputeInstanceTaskParamVO) ProtoMessage()

func (*ComputeInstanceTaskParamVO) ProtoReflect 

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

func (*ComputeInstanceTaskParamVO) Reset 

func (x *ComputeInstanceTaskParamVO) Reset()

func (*ComputeInstanceTaskParamVO) String 

func (x *ComputeInstanceTaskParamVO) String() string

type NatNetworkMappingTaskParamVO 

type NatNetworkMappingTaskParamVO struct {
	Id           string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name         string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	InstanceId   string `protobuf:"bytes,3,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	InstancePort int32  `protobuf:"varint,4,opt,name=instancePort,proto3" json:"instancePort,omitempty"`
	RemotePort   int32  `protobuf:"varint,5,opt,name=remotePort,proto3" json:"remotePort,omitempty"`
	GatewayId    string `protobuf:"bytes,6,opt,name=gatewayId,proto3" json:"gatewayId,omitempty"`
	GatewayIp    string `protobuf:"bytes,7,opt,name=gatewayIp,proto3" json:"gatewayIp,omitempty"`
	GatewayPort  int32  `protobuf:"varint,8,opt,name=gatewayPort,proto3" json:"gatewayPort,omitempty"`
	Protocol     string `protobuf:"bytes,9,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// contains filtered or unexported fields
}

func (*NatNetworkMappingTaskParamVO) Descriptor deprecated 

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

Deprecated: Use NatNetworkMappingTaskParamVO.ProtoReflect.Descriptor instead.

func (*NatNetworkMappingTaskParamVO) GetGatewayId 

func (x *NatNetworkMappingTaskParamVO) GetGatewayId() string

func (*NatNetworkMappingTaskParamVO) GetGatewayIp 

func (x *NatNetworkMappingTaskParamVO) GetGatewayIp() string

func (*NatNetworkMappingTaskParamVO) GetGatewayPort 

func (x *NatNetworkMappingTaskParamVO) GetGatewayPort() int32

func (*NatNetworkMappingTaskParamVO) GetId 

func (x *NatNetworkMappingTaskParamVO) GetId() string

func (*NatNetworkMappingTaskParamVO) GetInstanceId 

func (x *NatNetworkMappingTaskParamVO) GetInstanceId() string

func (*NatNetworkMappingTaskParamVO) GetInstancePort 

func (x *NatNetworkMappingTaskParamVO) GetInstancePort() int32

func (*NatNetworkMappingTaskParamVO) GetName 

func (x *NatNetworkMappingTaskParamVO) GetName() string

func (*NatNetworkMappingTaskParamVO) GetProtocol 

func (x *NatNetworkMappingTaskParamVO) GetProtocol() string

func (*NatNetworkMappingTaskParamVO) GetRemotePort 

func (x *NatNetworkMappingTaskParamVO) GetRemotePort() int32

func (*NatNetworkMappingTaskParamVO) ProtoMessage 

func (*NatNetworkMappingTaskParamVO) ProtoMessage()

func (*NatNetworkMappingTaskParamVO) ProtoReflect 

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

func (*NatNetworkMappingTaskParamVO) Reset 

func (x *NatNetworkMappingTaskParamVO) Reset()

func (*NatNetworkMappingTaskParamVO) String 

func (x *NatNetworkMappingTaskParamVO) String() string

type QueueTaskClient 

type QueueTaskClient interface {
	// 查询队列任务
	GetAgentTask(ctx context.Context, in *QueueTaskGetRequest, opts ...grpc.CallOption) (*QueueTaskGetResponse, error)
	// 更新任务状态
	UpdateAgentTask(ctx context.Context, in *QueueTaskUpdateRequest, opts ...grpc.CallOption) (*QueueTaskUpdateResponse, error)
}

QueueTaskClient is the client API for QueueTask 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 NewQueueTaskClient 

func NewQueueTaskClient(cc grpc.ClientConnInterface) QueueTaskClient

type QueueTaskGetRequest 

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

func (*QueueTaskGetRequest) Descriptor deprecated 

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

Deprecated: Use QueueTaskGetRequest.ProtoReflect.Descriptor instead.

func (*QueueTaskGetRequest) GetId 

func (x *QueueTaskGetRequest) GetId() string

func (*QueueTaskGetRequest) ProtoMessage 

func (*QueueTaskGetRequest) ProtoMessage()

func (*QueueTaskGetRequest) ProtoReflect 

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

func (*QueueTaskGetRequest) Reset 

func (x *QueueTaskGetRequest) Reset()

func (*QueueTaskGetRequest) String 

func (x *QueueTaskGetRequest) String() string

type QueueTaskGetResponse 

type QueueTaskGetResponse struct {
	Code    int32        `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string       `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Data    *QueueTaskVo `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueTaskGetResponse) Descriptor deprecated 

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

Deprecated: Use QueueTaskGetResponse.ProtoReflect.Descriptor instead.

func (*QueueTaskGetResponse) GetCode 

func (x *QueueTaskGetResponse) GetCode() int32

func (*QueueTaskGetResponse) GetData 

func (x *QueueTaskGetResponse) GetData() *QueueTaskVo

func (*QueueTaskGetResponse) GetMessage 

func (x *QueueTaskGetResponse) GetMessage() string

func (*QueueTaskGetResponse) ProtoMessage 

func (*QueueTaskGetResponse) ProtoMessage()

func (*QueueTaskGetResponse) ProtoReflect 

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

func (*QueueTaskGetResponse) Reset 

func (x *QueueTaskGetResponse) Reset()

func (*QueueTaskGetResponse) String 

func (x *QueueTaskGetResponse) String() string

type QueueTaskHTTPClient 

type QueueTaskHTTPClient interface {
	// GetAgentTask 查询队列任务
	GetAgentTask(ctx context.Context, req *QueueTaskGetRequest, opts ...http.CallOption) (rsp *QueueTaskGetResponse, err error)
	// UpdateAgentTask 更新任务状态
	UpdateAgentTask(ctx context.Context, req *QueueTaskUpdateRequest, opts ...http.CallOption) (rsp *QueueTaskUpdateResponse, err error)
}

func NewQueueTaskHTTPClient 

func NewQueueTaskHTTPClient(client *http.Client) QueueTaskHTTPClient

type QueueTaskHTTPClientImpl 

type QueueTaskHTTPClientImpl struct {
	// contains filtered or unexported fields
}

func (*QueueTaskHTTPClientImpl) GetAgentTask 

func (c *QueueTaskHTTPClientImpl) GetAgentTask(ctx context.Context, in *QueueTaskGetRequest, opts ...http.CallOption) (*QueueTaskGetResponse, error)

GetAgentTask 查询队列任务

func (*QueueTaskHTTPClientImpl) UpdateAgentTask 

func (c *QueueTaskHTTPClientImpl) UpdateAgentTask(ctx context.Context, in *QueueTaskUpdateRequest, opts ...http.CallOption) (*QueueTaskUpdateResponse, error)

UpdateAgentTask 更新任务状态

type QueueTaskHTTPServer 

type QueueTaskHTTPServer interface {
	// GetAgentTask 查询队列任务
	GetAgentTask(context.Context, *QueueTaskGetRequest) (*QueueTaskGetResponse, error)
	// UpdateAgentTask 更新任务状态
	UpdateAgentTask(context.Context, *QueueTaskUpdateRequest) (*QueueTaskUpdateResponse, error)
}

type QueueTaskServer 

type QueueTaskServer interface {
	// 查询队列任务
	GetAgentTask(context.Context, *QueueTaskGetRequest) (*QueueTaskGetResponse, error)
	// 更新任务状态
	UpdateAgentTask(context.Context, *QueueTaskUpdateRequest) (*QueueTaskUpdateResponse, error)
	// contains filtered or unexported methods
}

QueueTaskServer is the server API for QueueTask service. All implementations must embed UnimplementedQueueTaskServer for forward compatibility.

type QueueTaskUpdateRequest 

type QueueTaskUpdateRequest struct {
	Id      string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	AgentId string     `protobuf:"bytes,2,opt,name=agentId,proto3" json:"agentId,omitempty"`
	Status  TaskStatus `protobuf:"varint,3,opt,name=status,proto3,enum=server.queue.v1.TaskStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueTaskUpdateRequest) Descriptor deprecated 

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

Deprecated: Use QueueTaskUpdateRequest.ProtoReflect.Descriptor instead.

func (*QueueTaskUpdateRequest) GetAgentId 

func (x *QueueTaskUpdateRequest) GetAgentId() string

func (*QueueTaskUpdateRequest) GetId 

func (x *QueueTaskUpdateRequest) GetId() string

func (*QueueTaskUpdateRequest) GetStatus 

func (x *QueueTaskUpdateRequest) GetStatus() TaskStatus

func (*QueueTaskUpdateRequest) ProtoMessage 

func (*QueueTaskUpdateRequest) ProtoMessage()

func (*QueueTaskUpdateRequest) ProtoReflect 

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

func (*QueueTaskUpdateRequest) Reset 

func (x *QueueTaskUpdateRequest) Reset()

func (*QueueTaskUpdateRequest) String 

func (x *QueueTaskUpdateRequest) String() string

type QueueTaskUpdateResponse 

type QueueTaskUpdateResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueTaskUpdateResponse) Descriptor deprecated 

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

Deprecated: Use QueueTaskUpdateResponse.ProtoReflect.Descriptor instead.

func (*QueueTaskUpdateResponse) GetCode 

func (x *QueueTaskUpdateResponse) GetCode() int32

func (*QueueTaskUpdateResponse) GetMessage 

func (x *QueueTaskUpdateResponse) GetMessage() string

func (*QueueTaskUpdateResponse) ProtoMessage 

func (*QueueTaskUpdateResponse) ProtoMessage()

func (*QueueTaskUpdateResponse) ProtoReflect 

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

func (*QueueTaskUpdateResponse) Reset 

func (x *QueueTaskUpdateResponse) Reset()

func (*QueueTaskUpdateResponse) String 

func (x *QueueTaskUpdateResponse) String() string

type QueueTaskVo 

type QueueTaskVo struct {
	Id      string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                          // 任务id
	AgentId string     `protobuf:"bytes,2,opt,name=agentId,proto3" json:"agentId,omitempty"`                                // 客户端节点id
	Cmd     TaskCmd    `protobuf:"varint,3,opt,name=cmd,proto3,enum=server.queue.v1.TaskCmd" json:"cmd,omitempty"`          // 执行任务枚举
	Params  string     `protobuf:"bytes,4,opt,name=params,proto3" json:"params,omitempty"`                                  // 执行参数，nat 网络类型对应 NatProxyCreateVO, 虚拟机类型对应 ComputeInstanceTaskParamVO
	Status  TaskStatus `protobuf:"varint,5,opt,name=status,proto3,enum=server.queue.v1.TaskStatus" json:"status,omitempty"` // 任务状态
	// contains filtered or unexported fields
}

func (*QueueTaskVo) Descriptor deprecated 

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

Deprecated: Use QueueTaskVo.ProtoReflect.Descriptor instead.

func (*QueueTaskVo) GetAgentId 

func (x *QueueTaskVo) GetAgentId() string

func (*QueueTaskVo) GetCmd 

func (x *QueueTaskVo) GetCmd() TaskCmd

func (*QueueTaskVo) GetId 

func (x *QueueTaskVo) GetId() string

func (*QueueTaskVo) GetParams 

func (x *QueueTaskVo) GetParams() string

func (*QueueTaskVo) GetStatus 

func (x *QueueTaskVo) GetStatus() TaskStatus

func (*QueueTaskVo) GetTaskParam 

func (task *QueueTaskVo) GetTaskParam() (any, error)

func (*QueueTaskVo) ProtoMessage 

func (*QueueTaskVo) ProtoMessage()

func (*QueueTaskVo) ProtoReflect 

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

func (*QueueTaskVo) Reset 

func (x *QueueTaskVo) Reset()

func (*QueueTaskVo) String 

func (x *QueueTaskVo) String() string

type StorageSetupTaskParamVO 

type StorageSetupTaskParamVO struct {
	Id           string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	MasterServer string `protobuf:"bytes,2,opt,name=masterServer,proto3" json:"masterServer,omitempty"`
	PublicIp     string `protobuf:"bytes,3,opt,name=publicIp,proto3" json:"publicIp,omitempty"`
	PublicPort   int32  `protobuf:"varint,4,opt,name=publicPort,proto3" json:"publicPort,omitempty"`
	GrpcPort     int32  `protobuf:"varint,5,opt,name=grpcPort,proto3" json:"grpcPort,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageSetupTaskParamVO) Descriptor deprecated 

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

Deprecated: Use StorageSetupTaskParamVO.ProtoReflect.Descriptor instead.

func (*StorageSetupTaskParamVO) GetGrpcPort 

func (x *StorageSetupTaskParamVO) GetGrpcPort() int32

func (*StorageSetupTaskParamVO) GetId 

func (x *StorageSetupTaskParamVO) GetId() string

func (*StorageSetupTaskParamVO) GetMasterServer 

func (x *StorageSetupTaskParamVO) GetMasterServer() string

func (*StorageSetupTaskParamVO) GetPublicIp 

func (x *StorageSetupTaskParamVO) GetPublicIp() string

func (*StorageSetupTaskParamVO) GetPublicPort 

func (x *StorageSetupTaskParamVO) GetPublicPort() int32

func (*StorageSetupTaskParamVO) ProtoMessage 

func (*StorageSetupTaskParamVO) ProtoMessage()

func (*StorageSetupTaskParamVO) ProtoReflect 

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

func (*StorageSetupTaskParamVO) Reset 

func (x *StorageSetupTaskParamVO) Reset()

func (*StorageSetupTaskParamVO) String 

func (x *StorageSetupTaskParamVO) String() string

type TaskCmd 

type TaskCmd int32
const (
	TaskCmd_VM_CREATE          TaskCmd = 0  // 创建虚拟机
	TaskCmd_VM_DELETE          TaskCmd = 1  // 删除虚拟机
	TaskCmd_VM_START           TaskCmd = 2  // 启动虚拟机
	TaskCmd_VM_SHUTDOWN        TaskCmd = 3  //关闭虚拟机
	TaskCmd_VM_RESTART         TaskCmd = 4  //关闭虚拟机
	TaskCmd_VM_RECREATE        TaskCmd = 5  // 虚拟机重置
	TaskCmd_NAT_PROXY_CREATE   TaskCmd = 6  // nat 代理创建
	TaskCmd_NAT_PROXY_DELETE   TaskCmd = 7  // nat 代理删除
	TaskCmd_NAT_PROXY_EDIT     TaskCmd = 8  // nat 编辑
	TaskCmd_NAT_VISITOR_CREATE TaskCmd = 9  // nat 访问创建
	TaskCmd_NAT_VISITOR_DELETE TaskCmd = 10 // nat 访问删除
	TaskCmd_STORAGE_CREATE     TaskCmd = 11 // 存储节点创建（虚拟机)
	TaskCmd_STORAGE_DELETE     TaskCmd = 12 // 存储节点删除（虚拟机）
	TaskCmd_PING               TaskCmd = 99 // ping
)

func (TaskCmd) Descriptor 

func (TaskCmd) Descriptor() protoreflect.EnumDescriptor

func (TaskCmd) Enum 

func (x TaskCmd) Enum() *TaskCmd

func (TaskCmd) EnumDescriptor deprecated 

func (TaskCmd) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskCmd.Descriptor instead.

func (TaskCmd) Number 

func (x TaskCmd) Number() protoreflect.EnumNumber

func (TaskCmd) String 

func (x TaskCmd) String() string

func (TaskCmd) Type 

func (TaskCmd) Type() protoreflect.EnumType

type TaskStatus 

type TaskStatus int32
const (
	TaskStatus_CREATED   TaskStatus = 0 //创建
	TaskStatus_EXECUTING TaskStatus = 1 //执行中
	TaskStatus_EXECUTED  TaskStatus = 2 // 执行成功
	TaskStatus_FAILED    TaskStatus = 3 // 执行失败
)

func (TaskStatus) Descriptor 

func (TaskStatus) Descriptor() protoreflect.EnumDescriptor

func (TaskStatus) Enum 

func (x TaskStatus) Enum() *TaskStatus

func (TaskStatus) EnumDescriptor deprecated 

func (TaskStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskStatus.Descriptor instead.

func (TaskStatus) Number 

func (x TaskStatus) Number() protoreflect.EnumNumber

func (TaskStatus) String 

func (x TaskStatus) String() string

func (TaskStatus) Type 

func (TaskStatus) Type() protoreflect.EnumType

type UnimplementedQueueTaskServer 

type UnimplementedQueueTaskServer struct{}

UnimplementedQueueTaskServer 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 (UnimplementedQueueTaskServer) GetAgentTask 

func (UnimplementedQueueTaskServer) GetAgentTask(context.Context, *QueueTaskGetRequest) (*QueueTaskGetResponse, error)

func (UnimplementedQueueTaskServer) UpdateAgentTask 

func (UnimplementedQueueTaskServer) UpdateAgentTask(context.Context, *QueueTaskUpdateRequest) (*QueueTaskUpdateResponse, error)

type UnsafeQueueTaskServer 

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

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

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.