protos

package
v1.0.5 Latest Latest
Warning

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

Go to latest
Published: Jan 14, 2025 License: AGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	CraneCtld_TaskStatusChange_FullMethodName   = "/crane.grpc.CraneCtld/TaskStatusChange"
	CraneCtld_CranedRegister_FullMethodName     = "/crane.grpc.CraneCtld/CranedRegister"
	CraneCtld_CforedStream_FullMethodName       = "/crane.grpc.CraneCtld/CforedStream"
	CraneCtld_CancelTask_FullMethodName         = "/crane.grpc.CraneCtld/CancelTask"
	CraneCtld_SubmitBatchTask_FullMethodName    = "/crane.grpc.CraneCtld/SubmitBatchTask"
	CraneCtld_SubmitBatchTasks_FullMethodName   = "/crane.grpc.CraneCtld/SubmitBatchTasks"
	CraneCtld_QueryCranedInfo_FullMethodName    = "/crane.grpc.CraneCtld/QueryCranedInfo"
	CraneCtld_QueryPartitionInfo_FullMethodName = "/crane.grpc.CraneCtld/QueryPartitionInfo"
	CraneCtld_ModifyTask_FullMethodName         = "/crane.grpc.CraneCtld/ModifyTask"
	CraneCtld_ModifyNode_FullMethodName         = "/crane.grpc.CraneCtld/ModifyNode"
	CraneCtld_AddAccount_FullMethodName         = "/crane.grpc.CraneCtld/AddAccount"
	CraneCtld_AddUser_FullMethodName            = "/crane.grpc.CraneCtld/AddUser"
	CraneCtld_AddQos_FullMethodName             = "/crane.grpc.CraneCtld/AddQos"
	CraneCtld_DeleteAccount_FullMethodName      = "/crane.grpc.CraneCtld/DeleteAccount"
	CraneCtld_DeleteUser_FullMethodName         = "/crane.grpc.CraneCtld/DeleteUser"
	CraneCtld_DeleteQos_FullMethodName          = "/crane.grpc.CraneCtld/DeleteQos"
	CraneCtld_QueryAccountInfo_FullMethodName   = "/crane.grpc.CraneCtld/QueryAccountInfo"
	CraneCtld_QueryUserInfo_FullMethodName      = "/crane.grpc.CraneCtld/QueryUserInfo"
	CraneCtld_QueryQosInfo_FullMethodName       = "/crane.grpc.CraneCtld/QueryQosInfo"
	CraneCtld_ModifyAccount_FullMethodName      = "/crane.grpc.CraneCtld/ModifyAccount"
	CraneCtld_ModifyUser_FullMethodName         = "/crane.grpc.CraneCtld/ModifyUser"
	CraneCtld_ModifyQos_FullMethodName          = "/crane.grpc.CraneCtld/ModifyQos"
	CraneCtld_BlockAccountOrUser_FullMethodName = "/crane.grpc.CraneCtld/BlockAccountOrUser"
	CraneCtld_QueryClusterInfo_FullMethodName   = "/crane.grpc.CraneCtld/QueryClusterInfo"
	CraneCtld_QueryTasksInfo_FullMethodName     = "/crane.grpc.CraneCtld/QueryTasksInfo"
)
View Source
const (
	Craned_ExecuteTask_FullMethodName                  = "/crane.grpc.Craned/ExecuteTask"
	Craned_CheckTaskStatus_FullMethodName              = "/crane.grpc.Craned/CheckTaskStatus"
	Craned_CreateCgroupForTasks_FullMethodName         = "/crane.grpc.Craned/CreateCgroupForTasks"
	Craned_ReleaseCgroupForTasks_FullMethodName        = "/crane.grpc.Craned/ReleaseCgroupForTasks"
	Craned_QueryCranedRemoteMeta_FullMethodName        = "/crane.grpc.Craned/QueryCranedRemoteMeta"
	Craned_TerminateTasks_FullMethodName               = "/crane.grpc.Craned/TerminateTasks"
	Craned_TerminateOrphanedTask_FullMethodName        = "/crane.grpc.Craned/TerminateOrphanedTask"
	Craned_ChangeTaskTimeLimit_FullMethodName          = "/crane.grpc.Craned/ChangeTaskTimeLimit"
	Craned_QueryTaskIdFromPort_FullMethodName          = "/crane.grpc.Craned/QueryTaskIdFromPort"
	Craned_QueryTaskIdFromPortForward_FullMethodName   = "/crane.grpc.Craned/QueryTaskIdFromPortForward"
	Craned_MigrateSshProcToCgroup_FullMethodName       = "/crane.grpc.Craned/MigrateSshProcToCgroup"
	Craned_QueryTaskEnvVariables_FullMethodName        = "/crane.grpc.Craned/QueryTaskEnvVariables"
	Craned_QueryTaskEnvVariablesForward_FullMethodName = "/crane.grpc.Craned/QueryTaskEnvVariablesForward"
)
View Source
const (
	CraneForeD_CallocStream_FullMethodName        = "/crane.grpc.CraneForeD/CallocStream"
	CraneForeD_CrunStream_FullMethodName          = "/crane.grpc.CraneForeD/CrunStream"
	CraneForeD_TaskIOStream_FullMethodName        = "/crane.grpc.CraneForeD/TaskIOStream"
	CraneForeD_QueryTaskIdFromPort_FullMethodName = "/crane.grpc.CraneForeD/QueryTaskIdFromPort"
)
View Source
const (
	CranePluginD_StartHook_FullMethodName         = "/crane.grpc.plugin.CranePluginD/StartHook"
	CranePluginD_EndHook_FullMethodName           = "/crane.grpc.plugin.CranePluginD/EndHook"
	CranePluginD_CreateCgroupHook_FullMethodName  = "/crane.grpc.plugin.CranePluginD/CreateCgroupHook"
	CranePluginD_DestroyCgroupHook_FullMethodName = "/crane.grpc.plugin.CranePluginD/DestroyCgroupHook"
)

Variables

View Source
var (
	ModifyTaskRequest_TargetAttributes_name = map[int32]string{
		0: "TimeLimit",
		1: "Priority",
		2: "Hold",
	}
	ModifyTaskRequest_TargetAttributes_value = map[string]int32{
		"TimeLimit": 0,
		"Priority":  1,
		"Hold":      2,
	}
)

Enum value maps for ModifyTaskRequest_TargetAttributes.

View Source
var (
	StreamCallocRequest_CallocRequestType_name = map[int32]string{
		0: "TASK_REQUEST",
		1: "TASK_COMPLETION_REQUEST",
	}
	StreamCallocRequest_CallocRequestType_value = map[string]int32{
		"TASK_REQUEST":            0,
		"TASK_COMPLETION_REQUEST": 1,
	}
)

Enum value maps for StreamCallocRequest_CallocRequestType.

View Source
var (
	StreamCforedReply_CforedReplyType_name = map[int32]string{
		0: "TASK_ID_REPLY",
		1: "TASK_RES_ALLOC_REPLY",
		2: "TASK_CANCEL_REQUEST",
		3: "TASK_COMPLETION_ACK_REPLY",
	}
	StreamCforedReply_CforedReplyType_value = map[string]int32{
		"TASK_ID_REPLY":             0,
		"TASK_RES_ALLOC_REPLY":      1,
		"TASK_CANCEL_REQUEST":       2,
		"TASK_COMPLETION_ACK_REPLY": 3,
	}
)

Enum value maps for StreamCforedReply_CforedReplyType.

View Source
var (
	StreamCforedRequest_CforedRequestType_name = map[int32]string{
		0: "CFORED_REGISTRATION",
		1: "TASK_REQUEST",
		2: "TASK_COMPLETION_REQUEST",
		3: "CFORED_GRACEFUL_EXIT",
	}
	StreamCforedRequest_CforedRequestType_value = map[string]int32{
		"CFORED_REGISTRATION":     0,
		"TASK_REQUEST":            1,
		"TASK_COMPLETION_REQUEST": 2,
		"CFORED_GRACEFUL_EXIT":    3,
	}
)

Enum value maps for StreamCforedRequest_CforedRequestType.

View Source
var (
	StreamCtldReply_CtldReplyType_name = map[int32]string{
		0: "TASK_ID_REPLY",
		1: "TASK_RES_ALLOC_REPLY",
		2: "TASK_CANCEL_REQUEST",
		3: "TASK_COMPLETION_ACK_REPLY",
		4: "CFORED_REGISTRATION_ACK",
		5: "CFORED_GRACEFUL_EXIT_ACK",
	}
	StreamCtldReply_CtldReplyType_value = map[string]int32{
		"TASK_ID_REPLY":             0,
		"TASK_RES_ALLOC_REPLY":      1,
		"TASK_CANCEL_REQUEST":       2,
		"TASK_COMPLETION_ACK_REPLY": 3,
		"CFORED_REGISTRATION_ACK":   4,
		"CFORED_GRACEFUL_EXIT_ACK":  5,
	}
)

Enum value maps for StreamCtldReply_CtldReplyType.

View Source
var (
	StreamCrunRequest_CrunRequestType_name = map[int32]string{
		0: "TASK_REQUEST",
		1: "TASK_COMPLETION_REQUEST",
		2: "TASK_IO_FORWARD",
	}
	StreamCrunRequest_CrunRequestType_value = map[string]int32{
		"TASK_REQUEST":            0,
		"TASK_COMPLETION_REQUEST": 1,
		"TASK_IO_FORWARD":         2,
	}
)

Enum value maps for StreamCrunRequest_CrunRequestType.

View Source
var (
	StreamCforedCrunReply_CforedCrunReplyType_name = map[int32]string{
		0: "TASK_ID_REPLY",
		1: "TASK_RES_ALLOC_REPLY",
		2: "TASK_CANCEL_REQUEST",
		3: "TASK_COMPLETION_ACK_REPLY",
		4: "TASK_IO_FORWARD",
		5: "TASK_IO_FORWARD_READY",
	}
	StreamCforedCrunReply_CforedCrunReplyType_value = map[string]int32{
		"TASK_ID_REPLY":             0,
		"TASK_RES_ALLOC_REPLY":      1,
		"TASK_CANCEL_REQUEST":       2,
		"TASK_COMPLETION_ACK_REPLY": 3,
		"TASK_IO_FORWARD":           4,
		"TASK_IO_FORWARD_READY":     5,
	}
)

Enum value maps for StreamCforedCrunReply_CforedCrunReplyType.

View Source
var (
	StreamCforedTaskIORequest_CranedRequestType_name = map[int32]string{
		0: "CRANED_REGISTER",
		1: "CRANED_TASK_OUTPUT",
		2: "CRANED_UNREGISTER",
	}
	StreamCforedTaskIORequest_CranedRequestType_value = map[string]int32{
		"CRANED_REGISTER":    0,
		"CRANED_TASK_OUTPUT": 1,
		"CRANED_UNREGISTER":  2,
	}
)

Enum value maps for StreamCforedTaskIORequest_CranedRequestType.

View Source
var (
	StreamCforedTaskIOReply_CranedReplyType_name = map[int32]string{
		0: "CRANED_REGISTER_REPLY",
		1: "CRANED_TASK_INPUT",
		2: "CRANED_UNREGISTER_REPLY",
	}
	StreamCforedTaskIOReply_CranedReplyType_value = map[string]int32{
		"CRANED_REGISTER_REPLY":   0,
		"CRANED_TASK_INPUT":       1,
		"CRANED_UNREGISTER_REPLY": 2,
	}
)

Enum value maps for StreamCforedTaskIOReply_CranedReplyType.

View Source
var (
	PartitionState_name = map[int32]string{
		0: "PARTITION_UP",
		1: "PARTITION_DOWN",
	}
	PartitionState_value = map[string]int32{
		"PARTITION_UP":   0,
		"PARTITION_DOWN": 1,
	}
)

Enum value maps for PartitionState.

View Source
var (
	CranedResourceState_name = map[int32]string{
		0: "CRANE_IDLE",
		1: "CRANE_MIX",
		2: "CRANE_ALLOC",
		3: "CRANE_DOWN",
	}
	CranedResourceState_value = map[string]int32{
		"CRANE_IDLE":  0,
		"CRANE_MIX":   1,
		"CRANE_ALLOC": 2,
		"CRANE_DOWN":  3,
	}
)

Enum value maps for CranedResourceState.

View Source
var (
	CranedControlState_name = map[int32]string{
		0: "CRANE_NONE",
		1: "CRANE_DRAIN",
	}
	CranedControlState_value = map[string]int32{
		"CRANE_NONE":  0,
		"CRANE_DRAIN": 1,
	}
)

Enum value maps for CranedControlState.

View Source
var (
	TaskStatus_name = map[int32]string{
		0:  "Pending",
		1:  "Running",
		2:  "Completed",
		3:  "Failed",
		4:  "ExceedTimeLimit",
		5:  "Cancelled",
		15: "Invalid",
	}
	TaskStatus_value = map[string]int32{
		"Pending":         0,
		"Running":         1,
		"Completed":       2,
		"Failed":          3,
		"ExceedTimeLimit": 4,
		"Cancelled":       5,
		"Invalid":         15,
	}
)

Enum value maps for TaskStatus.

View Source
var (
	TaskType_name = map[int32]string{
		0: "Interactive",
		1: "Batch",
	}
	TaskType_value = map[string]int32{
		"Interactive": 0,
		"Batch":       1,
	}
)

Enum value maps for TaskType.

View Source
var (
	InteractiveTaskType_name = map[int32]string{
		0: "Calloc",
		1: "Crun",
	}
	InteractiveTaskType_value = map[string]int32{
		"Calloc": 0,
		"Crun":   1,
	}
)

Enum value maps for InteractiveTaskType.

View Source
var (
	ErrCode_name = map[int32]string{
		0:     "SUCCESS",
		10001: "ERR_INVALID_UID",
		10002: "ERR_INVALID_OP_USER",
		10003: "ERR_INVALID_USER",
		10004: "ERR_PERMISSION_USER",
		10005: "ERR_USER_DUPLICATE_ACCOUNT",
		10006: "ERR_USER_ALLOWED_ACCOUNT",
		10007: "ERR_INVALID_ADMIN_LEVEL",
		10008: "ERR_USER_ACCOUNT_MISMATCH",
		10009: "ERR_NO_ACCOUNT_SPECIFIED",
		10010: "ERR_INVALID_ACCOUNT",
		10011: "ERR_DUPLICATE_ACCOUNT",
		10012: "ERR_INVALID_PARENTACCOUNT",
		10013: "ERR_DELETE_ACCOUNT",
		10014: "ERR_INVALID_PARTITION",
		10015: "ERR_ALLOWED_PARTITION",
		10016: "ERR_DUPLICATE_PARTITION",
		10017: "ERR_PARENT_ALLOWED_PARTITION",
		10018: "ERR_USER_EMPTY_PARTITION",
		10019: "ERR_CHILD_HAS_PARTITION",
		10020: "ERR_INVALID_QOS",
		10021: "ERR_DB_DUPLICATE_QOS",
		10022: "ERR_DELETE_QOS",
		10023: "ERR_CONVERT_TO_INTERGER",
		10024: "ERR_TIME_LIMIT",
		10025: "ERR_ALLOWED_QOS",
		10026: "ERR_DUPLICATE_QOS",
		10027: "ERR_PARENT_ALLOWED_QOS",
		10028: "ERR_SET_ALLOWED_QOS",
		10029: "ERR_ALLOWED_DEFAULT_QOS",
		10030: "ERR_DUPLICATE_DEFAULT_QOS",
		10031: "ERR_CHILD_HAS_DEFAULT_QOS",
		10032: "ERR_SET_ACCOUNT_QOS",
		10033: "ERR_SET_DEFAULT_QOS",
		10034: "ERR_IS_DEFAULT_QOS",
		10035: "ERR_UPDATE_DATABASE",
		10100: "ERR_GENERIC_FAILURE",
		10101: "ERR_NO_RESOURCE",
		10102: "ERR_NON_EXISTENT",
		10103: "ERR_INVALID_NODE_NUM",
		10104: "ERR_SYSTEM_ERR",
		10105: "ERR_EXISTING_TASK",
		10106: "ERR_INVALID_PARAM",
		10107: "ERR_STOP",
		10108: "ERR_PERMISSION_DENIED",
		10109: "ERR_CONNECTION_TIMEOUT",
		10110: "ERR_CONNECTION_ABORTED",
		10111: "ERR_RPC_FAILURE",
		10112: "ERR_TOKEN_REQUEST_FAILURE",
		10113: "ERR_STREAM_BROKEN",
		10114: "ERR_INVALID_STUB",
		10115: "ERR_CGROUP",
		10116: "ERR_PROTOBUF",
		10117: "ERR_LIB_EVENT",
		10118: "ERR_NO_AVAIL_NODE",
	}
	ErrCode_value = map[string]int32{
		"SUCCESS":                      0,
		"ERR_INVALID_UID":              10001,
		"ERR_INVALID_OP_USER":          10002,
		"ERR_INVALID_USER":             10003,
		"ERR_PERMISSION_USER":          10004,
		"ERR_USER_DUPLICATE_ACCOUNT":   10005,
		"ERR_USER_ALLOWED_ACCOUNT":     10006,
		"ERR_INVALID_ADMIN_LEVEL":      10007,
		"ERR_USER_ACCOUNT_MISMATCH":    10008,
		"ERR_NO_ACCOUNT_SPECIFIED":     10009,
		"ERR_INVALID_ACCOUNT":          10010,
		"ERR_DUPLICATE_ACCOUNT":        10011,
		"ERR_INVALID_PARENTACCOUNT":    10012,
		"ERR_DELETE_ACCOUNT":           10013,
		"ERR_INVALID_PARTITION":        10014,
		"ERR_ALLOWED_PARTITION":        10015,
		"ERR_DUPLICATE_PARTITION":      10016,
		"ERR_PARENT_ALLOWED_PARTITION": 10017,
		"ERR_USER_EMPTY_PARTITION":     10018,
		"ERR_CHILD_HAS_PARTITION":      10019,
		"ERR_INVALID_QOS":              10020,
		"ERR_DB_DUPLICATE_QOS":         10021,
		"ERR_DELETE_QOS":               10022,
		"ERR_CONVERT_TO_INTERGER":      10023,
		"ERR_TIME_LIMIT":               10024,
		"ERR_ALLOWED_QOS":              10025,
		"ERR_DUPLICATE_QOS":            10026,
		"ERR_PARENT_ALLOWED_QOS":       10027,
		"ERR_SET_ALLOWED_QOS":          10028,
		"ERR_ALLOWED_DEFAULT_QOS":      10029,
		"ERR_DUPLICATE_DEFAULT_QOS":    10030,
		"ERR_CHILD_HAS_DEFAULT_QOS":    10031,
		"ERR_SET_ACCOUNT_QOS":          10032,
		"ERR_SET_DEFAULT_QOS":          10033,
		"ERR_IS_DEFAULT_QOS":           10034,
		"ERR_UPDATE_DATABASE":          10035,
		"ERR_GENERIC_FAILURE":          10100,
		"ERR_NO_RESOURCE":              10101,
		"ERR_NON_EXISTENT":             10102,
		"ERR_INVALID_NODE_NUM":         10103,
		"ERR_SYSTEM_ERR":               10104,
		"ERR_EXISTING_TASK":            10105,
		"ERR_INVALID_PARAM":            10106,
		"ERR_STOP":                     10107,
		"ERR_PERMISSION_DENIED":        10108,
		"ERR_CONNECTION_TIMEOUT":       10109,
		"ERR_CONNECTION_ABORTED":       10110,
		"ERR_RPC_FAILURE":              10111,
		"ERR_TOKEN_REQUEST_FAILURE":    10112,
		"ERR_STREAM_BROKEN":            10113,
		"ERR_INVALID_STUB":             10114,
		"ERR_CGROUP":                   10115,
		"ERR_PROTOBUF":                 10116,
		"ERR_LIB_EVENT":                10117,
		"ERR_NO_AVAIL_NODE":            10118,
	}
)

Enum value maps for ErrCode.

View Source
var (
	EntityType_name = map[int32]string{
		0: "Account",
		1: "User",
	}
	EntityType_value = map[string]int32{
		"Account": 0,
		"User":    1,
	}
)

Enum value maps for EntityType.

View Source
var (
	OperationType_name = map[int32]string{
		0: "Overwrite",
		1: "Add",
		2: "Delete",
	}
	OperationType_value = map[string]int32{
		"Overwrite": 0,
		"Add":       1,
		"Delete":    2,
	}
)

Enum value maps for OperationType.

View Source
var (
	ModifyField_name = map[int32]string{
		0: "Partition",
		1: "Qos",
		2: "DefaultQos",
		3: "Description",
		4: "AdminLevel",
		5: "Priority",
		6: "MaxJobsPerUser",
		7: "MaxCpusPerUser",
		8: "MaxTimeLimitPerTask",
	}
	ModifyField_value = map[string]int32{
		"Partition":           0,
		"Qos":                 1,
		"DefaultQos":          2,
		"Description":         3,
		"AdminLevel":          4,
		"Priority":            5,
		"MaxJobsPerUser":      6,
		"MaxCpusPerUser":      7,
		"MaxTimeLimitPerTask": 8,
	}
)

Enum value maps for ModifyField.

View Source
var (
	UserInfo_AdminLevel_name = map[int32]string{
		0: "None",
		1: "Operator",
		2: "Admin",
		3: "Root",
	}
	UserInfo_AdminLevel_value = map[string]int32{
		"None":     0,
		"Operator": 1,
		"Admin":    2,
		"Root":     3,
	}
)

Enum value maps for UserInfo_AdminLevel.

View Source
var CraneCtld_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "crane.grpc.CraneCtld",
	HandlerType: (*CraneCtldServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TaskStatusChange",
			Handler:    _CraneCtld_TaskStatusChange_Handler,
		},
		{
			MethodName: "CranedRegister",
			Handler:    _CraneCtld_CranedRegister_Handler,
		},
		{
			MethodName: "CancelTask",
			Handler:    _CraneCtld_CancelTask_Handler,
		},
		{
			MethodName: "SubmitBatchTask",
			Handler:    _CraneCtld_SubmitBatchTask_Handler,
		},
		{
			MethodName: "SubmitBatchTasks",
			Handler:    _CraneCtld_SubmitBatchTasks_Handler,
		},
		{
			MethodName: "QueryCranedInfo",
			Handler:    _CraneCtld_QueryCranedInfo_Handler,
		},
		{
			MethodName: "QueryPartitionInfo",
			Handler:    _CraneCtld_QueryPartitionInfo_Handler,
		},
		{
			MethodName: "ModifyTask",
			Handler:    _CraneCtld_ModifyTask_Handler,
		},
		{
			MethodName: "ModifyNode",
			Handler:    _CraneCtld_ModifyNode_Handler,
		},
		{
			MethodName: "AddAccount",
			Handler:    _CraneCtld_AddAccount_Handler,
		},
		{
			MethodName: "AddUser",
			Handler:    _CraneCtld_AddUser_Handler,
		},
		{
			MethodName: "AddQos",
			Handler:    _CraneCtld_AddQos_Handler,
		},
		{
			MethodName: "DeleteAccount",
			Handler:    _CraneCtld_DeleteAccount_Handler,
		},
		{
			MethodName: "DeleteUser",
			Handler:    _CraneCtld_DeleteUser_Handler,
		},
		{
			MethodName: "DeleteQos",
			Handler:    _CraneCtld_DeleteQos_Handler,
		},
		{
			MethodName: "QueryAccountInfo",
			Handler:    _CraneCtld_QueryAccountInfo_Handler,
		},
		{
			MethodName: "QueryUserInfo",
			Handler:    _CraneCtld_QueryUserInfo_Handler,
		},
		{
			MethodName: "QueryQosInfo",
			Handler:    _CraneCtld_QueryQosInfo_Handler,
		},
		{
			MethodName: "ModifyAccount",
			Handler:    _CraneCtld_ModifyAccount_Handler,
		},
		{
			MethodName: "ModifyUser",
			Handler:    _CraneCtld_ModifyUser_Handler,
		},
		{
			MethodName: "ModifyQos",
			Handler:    _CraneCtld_ModifyQos_Handler,
		},
		{
			MethodName: "BlockAccountOrUser",
			Handler:    _CraneCtld_BlockAccountOrUser_Handler,
		},
		{
			MethodName: "QueryClusterInfo",
			Handler:    _CraneCtld_QueryClusterInfo_Handler,
		},
		{
			MethodName: "QueryTasksInfo",
			Handler:    _CraneCtld_QueryTasksInfo_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CforedStream",
			Handler:       _CraneCtld_CforedStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "Crane.proto",
}

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

View Source
var CraneForeD_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "crane.grpc.CraneForeD",
	HandlerType: (*CraneForeDServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryTaskIdFromPort",
			Handler:    _CraneForeD_QueryTaskIdFromPort_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CallocStream",
			Handler:       _CraneForeD_CallocStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "CrunStream",
			Handler:       _CraneForeD_CrunStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "TaskIOStream",
			Handler:       _CraneForeD_TaskIOStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "Crane.proto",
}

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

View Source
var CranePluginD_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "crane.grpc.plugin.CranePluginD",
	HandlerType: (*CranePluginDServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartHook",
			Handler:    _CranePluginD_StartHook_Handler,
		},
		{
			MethodName: "EndHook",
			Handler:    _CranePluginD_EndHook_Handler,
		},
		{
			MethodName: "CreateCgroupHook",
			Handler:    _CranePluginD_CreateCgroupHook_Handler,
		},
		{
			MethodName: "DestroyCgroupHook",
			Handler:    _CranePluginD_DestroyCgroupHook_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "Plugin.proto",
}

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

View Source
var Craned_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "crane.grpc.Craned",
	HandlerType: (*CranedServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecuteTask",
			Handler:    _Craned_ExecuteTask_Handler,
		},
		{
			MethodName: "CheckTaskStatus",
			Handler:    _Craned_CheckTaskStatus_Handler,
		},
		{
			MethodName: "CreateCgroupForTasks",
			Handler:    _Craned_CreateCgroupForTasks_Handler,
		},
		{
			MethodName: "ReleaseCgroupForTasks",
			Handler:    _Craned_ReleaseCgroupForTasks_Handler,
		},
		{
			MethodName: "QueryCranedRemoteMeta",
			Handler:    _Craned_QueryCranedRemoteMeta_Handler,
		},
		{
			MethodName: "TerminateTasks",
			Handler:    _Craned_TerminateTasks_Handler,
		},
		{
			MethodName: "TerminateOrphanedTask",
			Handler:    _Craned_TerminateOrphanedTask_Handler,
		},
		{
			MethodName: "ChangeTaskTimeLimit",
			Handler:    _Craned_ChangeTaskTimeLimit_Handler,
		},
		{
			MethodName: "QueryTaskIdFromPort",
			Handler:    _Craned_QueryTaskIdFromPort_Handler,
		},
		{
			MethodName: "QueryTaskIdFromPortForward",
			Handler:    _Craned_QueryTaskIdFromPortForward_Handler,
		},
		{
			MethodName: "MigrateSshProcToCgroup",
			Handler:    _Craned_MigrateSshProcToCgroup_Handler,
		},
		{
			MethodName: "QueryTaskEnvVariables",
			Handler:    _Craned_QueryTaskEnvVariables_Handler,
		},
		{
			MethodName: "QueryTaskEnvVariablesForward",
			Handler:    _Craned_QueryTaskEnvVariablesForward_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "Crane.proto",
}

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

View Source
var File_Crane_proto protoreflect.FileDescriptor
View Source
var File_Plugin_proto protoreflect.FileDescriptor
View Source
var File_PublicDefs_proto protoreflect.FileDescriptor

Functions

func RegisterCraneCtldServer

func RegisterCraneCtldServer(s grpc.ServiceRegistrar, srv CraneCtldServer)

func RegisterCraneForeDServer

func RegisterCraneForeDServer(s grpc.ServiceRegistrar, srv CraneForeDServer)

func RegisterCranePluginDServer

func RegisterCranePluginDServer(s grpc.ServiceRegistrar, srv CranePluginDServer)

func RegisterCranedServer

func RegisterCranedServer(s grpc.ServiceRegistrar, srv CranedServer)

Types

type AccountInfo

type AccountInfo struct {
	Name              string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description       string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Users             []string `protobuf:"bytes,3,rep,name=users,proto3" json:"users,omitempty"`
	ChildAccounts     []string `protobuf:"bytes,4,rep,name=child_accounts,json=childAccounts,proto3" json:"child_accounts,omitempty"`
	ParentAccount     string   `protobuf:"bytes,5,opt,name=parent_account,json=parentAccount,proto3" json:"parent_account,omitempty"`
	AllowedPartitions []string `protobuf:"bytes,6,rep,name=allowed_partitions,json=allowedPartitions,proto3" json:"allowed_partitions,omitempty"`
	DefaultQos        string   `protobuf:"bytes,7,opt,name=default_qos,json=defaultQos,proto3" json:"default_qos,omitempty"`
	AllowedQosList    []string `protobuf:"bytes,8,rep,name=allowed_qos_list,json=allowedQosList,proto3" json:"allowed_qos_list,omitempty"`
	Coordinators      []string `protobuf:"bytes,9,rep,name=coordinators,proto3" json:"coordinators,omitempty"`
	Blocked           bool     `protobuf:"varint,10,opt,name=blocked,proto3" json:"blocked,omitempty"`
	// contains filtered or unexported fields
}

func (*AccountInfo) Descriptor deprecated

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

Deprecated: Use AccountInfo.ProtoReflect.Descriptor instead.

func (*AccountInfo) GetAllowedPartitions

func (x *AccountInfo) GetAllowedPartitions() []string

func (*AccountInfo) GetAllowedQosList

func (x *AccountInfo) GetAllowedQosList() []string

func (*AccountInfo) GetBlocked

func (x *AccountInfo) GetBlocked() bool

func (*AccountInfo) GetChildAccounts

func (x *AccountInfo) GetChildAccounts() []string

func (*AccountInfo) GetCoordinators

func (x *AccountInfo) GetCoordinators() []string

func (*AccountInfo) GetDefaultQos

func (x *AccountInfo) GetDefaultQos() string

func (*AccountInfo) GetDescription

func (x *AccountInfo) GetDescription() string

func (*AccountInfo) GetName

func (x *AccountInfo) GetName() string

func (*AccountInfo) GetParentAccount

func (x *AccountInfo) GetParentAccount() string

func (*AccountInfo) GetUsers

func (x *AccountInfo) GetUsers() []string

func (*AccountInfo) ProtoMessage

func (*AccountInfo) ProtoMessage()

func (*AccountInfo) ProtoReflect

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

func (*AccountInfo) Reset

func (x *AccountInfo) Reset()

func (*AccountInfo) String

func (x *AccountInfo) String() string

type AddAccountReply

type AddAccountReply struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason ErrCode `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*AddAccountReply) Descriptor deprecated

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

Deprecated: Use AddAccountReply.ProtoReflect.Descriptor instead.

func (*AddAccountReply) GetOk

func (x *AddAccountReply) GetOk() bool

func (*AddAccountReply) GetReason

func (x *AddAccountReply) GetReason() ErrCode

func (*AddAccountReply) ProtoMessage

func (*AddAccountReply) ProtoMessage()

func (*AddAccountReply) ProtoReflect

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

func (*AddAccountReply) Reset

func (x *AddAccountReply) Reset()

func (*AddAccountReply) String

func (x *AddAccountReply) String() string

type AddAccountRequest

type AddAccountRequest struct {
	Uid     uint32       `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Account *AccountInfo `protobuf:"bytes,2,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*AddAccountRequest) Descriptor deprecated

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

Deprecated: Use AddAccountRequest.ProtoReflect.Descriptor instead.

func (*AddAccountRequest) GetAccount

func (x *AddAccountRequest) GetAccount() *AccountInfo

func (*AddAccountRequest) GetUid

func (x *AddAccountRequest) GetUid() uint32

func (*AddAccountRequest) ProtoMessage

func (*AddAccountRequest) ProtoMessage()

func (*AddAccountRequest) ProtoReflect

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

func (*AddAccountRequest) Reset

func (x *AddAccountRequest) Reset()

func (*AddAccountRequest) String

func (x *AddAccountRequest) String() string

type AddQosReply

type AddQosReply struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason ErrCode `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*AddQosReply) Descriptor deprecated

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

Deprecated: Use AddQosReply.ProtoReflect.Descriptor instead.

func (*AddQosReply) GetOk

func (x *AddQosReply) GetOk() bool

func (*AddQosReply) GetReason

func (x *AddQosReply) GetReason() ErrCode

func (*AddQosReply) ProtoMessage

func (*AddQosReply) ProtoMessage()

func (*AddQosReply) ProtoReflect

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

func (*AddQosReply) Reset

func (x *AddQosReply) Reset()

func (*AddQosReply) String

func (x *AddQosReply) String() string

type AddQosRequest

type AddQosRequest struct {
	Uid uint32   `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Qos *QosInfo `protobuf:"bytes,2,opt,name=qos,proto3" json:"qos,omitempty"`
	// contains filtered or unexported fields
}

func (*AddQosRequest) Descriptor deprecated

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

Deprecated: Use AddQosRequest.ProtoReflect.Descriptor instead.

func (*AddQosRequest) GetQos

func (x *AddQosRequest) GetQos() *QosInfo

func (*AddQosRequest) GetUid

func (x *AddQosRequest) GetUid() uint32

func (*AddQosRequest) ProtoMessage

func (*AddQosRequest) ProtoMessage()

func (*AddQosRequest) ProtoReflect

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

func (*AddQosRequest) Reset

func (x *AddQosRequest) Reset()

func (*AddQosRequest) String

func (x *AddQosRequest) String() string

type AddUserReply

type AddUserReply struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason ErrCode `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*AddUserReply) Descriptor deprecated

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

Deprecated: Use AddUserReply.ProtoReflect.Descriptor instead.

func (*AddUserReply) GetOk

func (x *AddUserReply) GetOk() bool

func (*AddUserReply) GetReason

func (x *AddUserReply) GetReason() ErrCode

func (*AddUserReply) ProtoMessage

func (*AddUserReply) ProtoMessage()

func (*AddUserReply) ProtoReflect

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

func (*AddUserReply) Reset

func (x *AddUserReply) Reset()

func (*AddUserReply) String

func (x *AddUserReply) String() string

type AddUserRequest

type AddUserRequest struct {
	Uid  uint32    `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	User *UserInfo `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*AddUserRequest) Descriptor deprecated

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

Deprecated: Use AddUserRequest.ProtoReflect.Descriptor instead.

func (*AddUserRequest) GetUid

func (x *AddUserRequest) GetUid() uint32

func (*AddUserRequest) GetUser

func (x *AddUserRequest) GetUser() *UserInfo

func (*AddUserRequest) ProtoMessage

func (*AddUserRequest) ProtoMessage()

func (*AddUserRequest) ProtoReflect

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

func (*AddUserRequest) Reset

func (x *AddUserRequest) Reset()

func (*AddUserRequest) String

func (x *AddUserRequest) String() string

type AllocatableResource

type AllocatableResource struct {
	CpuCoreLimit       float64 `protobuf:"fixed64,1,opt,name=cpu_core_limit,json=cpuCoreLimit,proto3" json:"cpu_core_limit,omitempty"`
	MemoryLimitBytes   uint64  `protobuf:"varint,2,opt,name=memory_limit_bytes,json=memoryLimitBytes,proto3" json:"memory_limit_bytes,omitempty"`
	MemorySwLimitBytes uint64  `protobuf:"varint,3,opt,name=memory_sw_limit_bytes,json=memorySwLimitBytes,proto3" json:"memory_sw_limit_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocatableResource) Descriptor deprecated

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

Deprecated: Use AllocatableResource.ProtoReflect.Descriptor instead.

func (*AllocatableResource) GetCpuCoreLimit

func (x *AllocatableResource) GetCpuCoreLimit() float64

func (*AllocatableResource) GetMemoryLimitBytes

func (x *AllocatableResource) GetMemoryLimitBytes() uint64

func (*AllocatableResource) GetMemorySwLimitBytes

func (x *AllocatableResource) GetMemorySwLimitBytes() uint64

func (*AllocatableResource) ProtoMessage

func (*AllocatableResource) ProtoMessage()

func (*AllocatableResource) ProtoReflect

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

func (*AllocatableResource) Reset

func (x *AllocatableResource) Reset()

func (*AllocatableResource) String

func (x *AllocatableResource) String() string

type BatchTaskAdditionalMeta

type BatchTaskAdditionalMeta struct {
	ShScript          string `protobuf:"bytes,1,opt,name=sh_script,json=shScript,proto3" json:"sh_script,omitempty"`
	OutputFilePattern string `protobuf:"bytes,3,opt,name=output_file_pattern,json=outputFilePattern,proto3" json:"output_file_pattern,omitempty"`
	ErrorFilePattern  string `protobuf:"bytes,4,opt,name=error_file_pattern,json=errorFilePattern,proto3" json:"error_file_pattern,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchTaskAdditionalMeta) Descriptor deprecated

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

Deprecated: Use BatchTaskAdditionalMeta.ProtoReflect.Descriptor instead.

func (*BatchTaskAdditionalMeta) GetErrorFilePattern

func (x *BatchTaskAdditionalMeta) GetErrorFilePattern() string

func (*BatchTaskAdditionalMeta) GetOutputFilePattern

func (x *BatchTaskAdditionalMeta) GetOutputFilePattern() string

func (*BatchTaskAdditionalMeta) GetShScript

func (x *BatchTaskAdditionalMeta) GetShScript() string

func (*BatchTaskAdditionalMeta) ProtoMessage

func (*BatchTaskAdditionalMeta) ProtoMessage()

func (*BatchTaskAdditionalMeta) ProtoReflect

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

func (*BatchTaskAdditionalMeta) Reset

func (x *BatchTaskAdditionalMeta) Reset()

func (*BatchTaskAdditionalMeta) String

func (x *BatchTaskAdditionalMeta) String() string

type BlockAccountOrUserReply

type BlockAccountOrUserReply struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason ErrCode `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockAccountOrUserReply) Descriptor deprecated

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

Deprecated: Use BlockAccountOrUserReply.ProtoReflect.Descriptor instead.

func (*BlockAccountOrUserReply) GetOk

func (x *BlockAccountOrUserReply) GetOk() bool

func (*BlockAccountOrUserReply) GetReason

func (x *BlockAccountOrUserReply) GetReason() ErrCode

func (*BlockAccountOrUserReply) ProtoMessage

func (*BlockAccountOrUserReply) ProtoMessage()

func (*BlockAccountOrUserReply) ProtoReflect

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

func (*BlockAccountOrUserReply) Reset

func (x *BlockAccountOrUserReply) Reset()

func (*BlockAccountOrUserReply) String

func (x *BlockAccountOrUserReply) String() string

type BlockAccountOrUserRequest

type BlockAccountOrUserRequest struct {
	Uid        uint32     `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Block      bool       `protobuf:"varint,2,opt,name=block,proto3" json:"block,omitempty"`
	EntityType EntityType `protobuf:"varint,3,opt,name=entity_type,json=entityType,proto3,enum=crane.grpc.EntityType" json:"entity_type,omitempty"`
	Name       string     `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Account    string     `protobuf:"bytes,5,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockAccountOrUserRequest) Descriptor deprecated

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

Deprecated: Use BlockAccountOrUserRequest.ProtoReflect.Descriptor instead.

func (*BlockAccountOrUserRequest) GetAccount

func (x *BlockAccountOrUserRequest) GetAccount() string

func (*BlockAccountOrUserRequest) GetBlock

func (x *BlockAccountOrUserRequest) GetBlock() bool

func (*BlockAccountOrUserRequest) GetEntityType

func (x *BlockAccountOrUserRequest) GetEntityType() EntityType

func (*BlockAccountOrUserRequest) GetName

func (x *BlockAccountOrUserRequest) GetName() string

func (*BlockAccountOrUserRequest) GetUid

func (x *BlockAccountOrUserRequest) GetUid() uint32

func (*BlockAccountOrUserRequest) ProtoMessage

func (*BlockAccountOrUserRequest) ProtoMessage()

func (*BlockAccountOrUserRequest) ProtoReflect

func (*BlockAccountOrUserRequest) Reset

func (x *BlockAccountOrUserRequest) Reset()

func (*BlockAccountOrUserRequest) String

func (x *BlockAccountOrUserRequest) String() string

type CancelTaskReply

type CancelTaskReply struct {
	CancelledTasks      []uint32 `protobuf:"varint,2,rep,packed,name=cancelled_tasks,json=cancelledTasks,proto3" json:"cancelled_tasks,omitempty"`
	NotCancelledTasks   []uint32 `protobuf:"varint,3,rep,packed,name=not_cancelled_tasks,json=notCancelledTasks,proto3" json:"not_cancelled_tasks,omitempty"`
	NotCancelledReasons []string `protobuf:"bytes,4,rep,name=not_cancelled_reasons,json=notCancelledReasons,proto3" json:"not_cancelled_reasons,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelTaskReply) Descriptor deprecated

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

Deprecated: Use CancelTaskReply.ProtoReflect.Descriptor instead.

func (*CancelTaskReply) GetCancelledTasks

func (x *CancelTaskReply) GetCancelledTasks() []uint32

func (*CancelTaskReply) GetNotCancelledReasons

func (x *CancelTaskReply) GetNotCancelledReasons() []string

func (*CancelTaskReply) GetNotCancelledTasks

func (x *CancelTaskReply) GetNotCancelledTasks() []uint32

func (*CancelTaskReply) ProtoMessage

func (*CancelTaskReply) ProtoMessage()

func (*CancelTaskReply) ProtoReflect

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

func (*CancelTaskReply) Reset

func (x *CancelTaskReply) Reset()

func (*CancelTaskReply) String

func (x *CancelTaskReply) String() string

type CancelTaskRequest

type CancelTaskRequest struct {
	OperatorUid uint32 `protobuf:"varint,1,opt,name=operator_uid,json=operatorUid,proto3" json:"operator_uid,omitempty"`
	// Filters
	FilterTaskIds   []uint32   `protobuf:"varint,2,rep,packed,name=filter_task_ids,json=filterTaskIds,proto3" json:"filter_task_ids,omitempty"`
	FilterPartition string     `protobuf:"bytes,3,opt,name=filter_partition,json=filterPartition,proto3" json:"filter_partition,omitempty"`
	FilterAccount   string     `protobuf:"bytes,4,opt,name=filter_account,json=filterAccount,proto3" json:"filter_account,omitempty"`
	FilterState     TaskStatus `protobuf:"varint,5,opt,name=filter_state,json=filterState,proto3,enum=crane.grpc.TaskStatus" json:"filter_state,omitempty"`
	FilterTaskName  string     `protobuf:"bytes,6,opt,name=filter_task_name,json=filterTaskName,proto3" json:"filter_task_name,omitempty"`
	FilterNodes     []string   `protobuf:"bytes,7,rep,name=filter_nodes,json=filterNodes,proto3" json:"filter_nodes,omitempty"`
	FilterUsername  string     `protobuf:"bytes,8,opt,name=filter_username,json=filterUsername,proto3" json:"filter_username,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelTaskRequest) Descriptor deprecated

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

Deprecated: Use CancelTaskRequest.ProtoReflect.Descriptor instead.

func (*CancelTaskRequest) GetFilterAccount

func (x *CancelTaskRequest) GetFilterAccount() string

func (*CancelTaskRequest) GetFilterNodes

func (x *CancelTaskRequest) GetFilterNodes() []string

func (*CancelTaskRequest) GetFilterPartition

func (x *CancelTaskRequest) GetFilterPartition() string

func (*CancelTaskRequest) GetFilterState

func (x *CancelTaskRequest) GetFilterState() TaskStatus

func (*CancelTaskRequest) GetFilterTaskIds

func (x *CancelTaskRequest) GetFilterTaskIds() []uint32

func (*CancelTaskRequest) GetFilterTaskName

func (x *CancelTaskRequest) GetFilterTaskName() string

func (*CancelTaskRequest) GetFilterUsername

func (x *CancelTaskRequest) GetFilterUsername() string

func (*CancelTaskRequest) GetOperatorUid

func (x *CancelTaskRequest) GetOperatorUid() uint32

func (*CancelTaskRequest) ProtoMessage

func (*CancelTaskRequest) ProtoMessage()

func (*CancelTaskRequest) ProtoReflect

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

func (*CancelTaskRequest) Reset

func (x *CancelTaskRequest) Reset()

func (*CancelTaskRequest) String

func (x *CancelTaskRequest) String() string

type ChangeTaskTimeLimitReply

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

func (*ChangeTaskTimeLimitReply) Descriptor deprecated

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

Deprecated: Use ChangeTaskTimeLimitReply.ProtoReflect.Descriptor instead.

func (*ChangeTaskTimeLimitReply) GetOk

func (x *ChangeTaskTimeLimitReply) GetOk() bool

func (*ChangeTaskTimeLimitReply) ProtoMessage

func (*ChangeTaskTimeLimitReply) ProtoMessage()

func (*ChangeTaskTimeLimitReply) ProtoReflect

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

func (*ChangeTaskTimeLimitReply) Reset

func (x *ChangeTaskTimeLimitReply) Reset()

func (*ChangeTaskTimeLimitReply) String

func (x *ChangeTaskTimeLimitReply) String() string

type ChangeTaskTimeLimitRequest

type ChangeTaskTimeLimitRequest struct {
	TaskId           uint32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TimeLimitSeconds int64  `protobuf:"varint,2,opt,name=time_limit_seconds,json=timeLimitSeconds,proto3" json:"time_limit_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeTaskTimeLimitRequest) Descriptor deprecated

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

Deprecated: Use ChangeTaskTimeLimitRequest.ProtoReflect.Descriptor instead.

func (*ChangeTaskTimeLimitRequest) GetTaskId

func (x *ChangeTaskTimeLimitRequest) GetTaskId() uint32

func (*ChangeTaskTimeLimitRequest) GetTimeLimitSeconds

func (x *ChangeTaskTimeLimitRequest) GetTimeLimitSeconds() int64

func (*ChangeTaskTimeLimitRequest) ProtoMessage

func (*ChangeTaskTimeLimitRequest) ProtoMessage()

func (*ChangeTaskTimeLimitRequest) ProtoReflect

func (*ChangeTaskTimeLimitRequest) Reset

func (x *ChangeTaskTimeLimitRequest) Reset()

func (*ChangeTaskTimeLimitRequest) String

func (x *ChangeTaskTimeLimitRequest) String() string

type CheckTaskStatusReply

type CheckTaskStatusReply struct {
	Ok     bool       `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Status TaskStatus `protobuf:"varint,2,opt,name=status,proto3,enum=crane.grpc.TaskStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckTaskStatusReply) Descriptor deprecated

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

Deprecated: Use CheckTaskStatusReply.ProtoReflect.Descriptor instead.

func (*CheckTaskStatusReply) GetOk

func (x *CheckTaskStatusReply) GetOk() bool

func (*CheckTaskStatusReply) GetStatus

func (x *CheckTaskStatusReply) GetStatus() TaskStatus

func (*CheckTaskStatusReply) ProtoMessage

func (*CheckTaskStatusReply) ProtoMessage()

func (*CheckTaskStatusReply) ProtoReflect

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

func (*CheckTaskStatusReply) Reset

func (x *CheckTaskStatusReply) Reset()

func (*CheckTaskStatusReply) String

func (x *CheckTaskStatusReply) String() string

type CheckTaskStatusRequest

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

func (*CheckTaskStatusRequest) Descriptor deprecated

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

Deprecated: Use CheckTaskStatusRequest.ProtoReflect.Descriptor instead.

func (*CheckTaskStatusRequest) GetTaskId

func (x *CheckTaskStatusRequest) GetTaskId() uint32

func (*CheckTaskStatusRequest) ProtoMessage

func (*CheckTaskStatusRequest) ProtoMessage()

func (*CheckTaskStatusRequest) ProtoReflect

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

func (*CheckTaskStatusRequest) Reset

func (x *CheckTaskStatusRequest) Reset()

func (*CheckTaskStatusRequest) String

func (x *CheckTaskStatusRequest) String() string

type CraneCtldClient

type CraneCtldClient interface {
	// RPCs called from Craned
	TaskStatusChange(ctx context.Context, in *TaskStatusChangeRequest, opts ...grpc.CallOption) (*TaskStatusChangeReply, error)
	CranedRegister(ctx context.Context, in *CranedRegisterRequest, opts ...grpc.CallOption) (*CranedRegisterReply, error)
	// RPCs called from Cfored
	CforedStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamCforedRequest, StreamCtldReply], error)
	// RPCs called from ccancel
	CancelTask(ctx context.Context, in *CancelTaskRequest, opts ...grpc.CallOption) (*CancelTaskReply, error)
	// RPCs called from cbatch
	SubmitBatchTask(ctx context.Context, in *SubmitBatchTaskRequest, opts ...grpc.CallOption) (*SubmitBatchTaskReply, error)
	SubmitBatchTasks(ctx context.Context, in *SubmitBatchTasksRequest, opts ...grpc.CallOption) (*SubmitBatchTasksReply, error)
	// PRCs called from ccontrol
	QueryCranedInfo(ctx context.Context, in *QueryCranedInfoRequest, opts ...grpc.CallOption) (*QueryCranedInfoReply, error)
	QueryPartitionInfo(ctx context.Context, in *QueryPartitionInfoRequest, opts ...grpc.CallOption) (*QueryPartitionInfoReply, error)
	ModifyTask(ctx context.Context, in *ModifyTaskRequest, opts ...grpc.CallOption) (*ModifyTaskReply, error)
	ModifyNode(ctx context.Context, in *ModifyCranedStateRequest, opts ...grpc.CallOption) (*ModifyCranedStateReply, error)
	// RPCs called from cacctmgr
	AddAccount(ctx context.Context, in *AddAccountRequest, opts ...grpc.CallOption) (*AddAccountReply, error)
	AddUser(ctx context.Context, in *AddUserRequest, opts ...grpc.CallOption) (*AddUserReply, error)
	AddQos(ctx context.Context, in *AddQosRequest, opts ...grpc.CallOption) (*AddQosReply, error)
	DeleteAccount(ctx context.Context, in *DeleteAccountRequest, opts ...grpc.CallOption) (*DeleteAccountReply, error)
	DeleteUser(ctx context.Context, in *DeleteUserRequest, opts ...grpc.CallOption) (*DeleteUserReply, error)
	DeleteQos(ctx context.Context, in *DeleteQosRequest, opts ...grpc.CallOption) (*DeleteQosReply, error)
	QueryAccountInfo(ctx context.Context, in *QueryAccountInfoRequest, opts ...grpc.CallOption) (*QueryAccountInfoReply, error)
	QueryUserInfo(ctx context.Context, in *QueryUserInfoRequest, opts ...grpc.CallOption) (*QueryUserInfoReply, error)
	QueryQosInfo(ctx context.Context, in *QueryQosInfoRequest, opts ...grpc.CallOption) (*QueryQosInfoReply, error)
	ModifyAccount(ctx context.Context, in *ModifyAccountRequest, opts ...grpc.CallOption) (*ModifyAccountReply, error)
	ModifyUser(ctx context.Context, in *ModifyUserRequest, opts ...grpc.CallOption) (*ModifyUserReply, error)
	ModifyQos(ctx context.Context, in *ModifyQosRequest, opts ...grpc.CallOption) (*ModifyQosReply, error)
	BlockAccountOrUser(ctx context.Context, in *BlockAccountOrUserRequest, opts ...grpc.CallOption) (*BlockAccountOrUserReply, error)
	// RPCs called from cinfo
	QueryClusterInfo(ctx context.Context, in *QueryClusterInfoRequest, opts ...grpc.CallOption) (*QueryClusterInfoReply, error)
	// common RPCs
	QueryTasksInfo(ctx context.Context, in *QueryTasksInfoRequest, opts ...grpc.CallOption) (*QueryTasksInfoReply, error)
}

CraneCtldClient is the client API for CraneCtld 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.

Todo: Divide service into two parts: one for Craned and one for Crun

We need to distinguish the message sender
and have some kind of authentication

func NewCraneCtldClient

func NewCraneCtldClient(cc grpc.ClientConnInterface) CraneCtldClient

type CraneCtldServer

type CraneCtldServer interface {
	// RPCs called from Craned
	TaskStatusChange(context.Context, *TaskStatusChangeRequest) (*TaskStatusChangeReply, error)
	CranedRegister(context.Context, *CranedRegisterRequest) (*CranedRegisterReply, error)
	// RPCs called from Cfored
	CforedStream(grpc.BidiStreamingServer[StreamCforedRequest, StreamCtldReply]) error
	// RPCs called from ccancel
	CancelTask(context.Context, *CancelTaskRequest) (*CancelTaskReply, error)
	// RPCs called from cbatch
	SubmitBatchTask(context.Context, *SubmitBatchTaskRequest) (*SubmitBatchTaskReply, error)
	SubmitBatchTasks(context.Context, *SubmitBatchTasksRequest) (*SubmitBatchTasksReply, error)
	// PRCs called from ccontrol
	QueryCranedInfo(context.Context, *QueryCranedInfoRequest) (*QueryCranedInfoReply, error)
	QueryPartitionInfo(context.Context, *QueryPartitionInfoRequest) (*QueryPartitionInfoReply, error)
	ModifyTask(context.Context, *ModifyTaskRequest) (*ModifyTaskReply, error)
	ModifyNode(context.Context, *ModifyCranedStateRequest) (*ModifyCranedStateReply, error)
	// RPCs called from cacctmgr
	AddAccount(context.Context, *AddAccountRequest) (*AddAccountReply, error)
	AddUser(context.Context, *AddUserRequest) (*AddUserReply, error)
	AddQos(context.Context, *AddQosRequest) (*AddQosReply, error)
	DeleteAccount(context.Context, *DeleteAccountRequest) (*DeleteAccountReply, error)
	DeleteUser(context.Context, *DeleteUserRequest) (*DeleteUserReply, error)
	DeleteQos(context.Context, *DeleteQosRequest) (*DeleteQosReply, error)
	QueryAccountInfo(context.Context, *QueryAccountInfoRequest) (*QueryAccountInfoReply, error)
	QueryUserInfo(context.Context, *QueryUserInfoRequest) (*QueryUserInfoReply, error)
	QueryQosInfo(context.Context, *QueryQosInfoRequest) (*QueryQosInfoReply, error)
	ModifyAccount(context.Context, *ModifyAccountRequest) (*ModifyAccountReply, error)
	ModifyUser(context.Context, *ModifyUserRequest) (*ModifyUserReply, error)
	ModifyQos(context.Context, *ModifyQosRequest) (*ModifyQosReply, error)
	BlockAccountOrUser(context.Context, *BlockAccountOrUserRequest) (*BlockAccountOrUserReply, error)
	// RPCs called from cinfo
	QueryClusterInfo(context.Context, *QueryClusterInfoRequest) (*QueryClusterInfoReply, error)
	// common RPCs
	QueryTasksInfo(context.Context, *QueryTasksInfoRequest) (*QueryTasksInfoReply, error)
	// contains filtered or unexported methods
}

CraneCtldServer is the server API for CraneCtld service. All implementations must embed UnimplementedCraneCtldServer for forward compatibility.

Todo: Divide service into two parts: one for Craned and one for Crun

We need to distinguish the message sender
and have some kind of authentication

type CraneCtld_CforedStreamClient

type CraneCtld_CforedStreamClient = grpc.BidiStreamingClient[StreamCforedRequest, StreamCtldReply]

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

type CraneCtld_CforedStreamServer

type CraneCtld_CforedStreamServer = grpc.BidiStreamingServer[StreamCforedRequest, StreamCtldReply]

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

type CraneForeDClient

CraneForeDClient is the client API for CraneForeD 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 NewCraneForeDClient

func NewCraneForeDClient(cc grpc.ClientConnInterface) CraneForeDClient

type CraneForeDServer

CraneForeDServer is the server API for CraneForeD service. All implementations must embed UnimplementedCraneForeDServer for forward compatibility.

type CraneForeD_CallocStreamClient

type CraneForeD_CallocStreamClient = grpc.BidiStreamingClient[StreamCallocRequest, StreamCforedReply]

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

type CraneForeD_CallocStreamServer

type CraneForeD_CallocStreamServer = grpc.BidiStreamingServer[StreamCallocRequest, StreamCforedReply]

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

type CraneForeD_CrunStreamClient

type CraneForeD_CrunStreamClient = grpc.BidiStreamingClient[StreamCrunRequest, StreamCforedCrunReply]

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

type CraneForeD_CrunStreamServer

type CraneForeD_CrunStreamServer = grpc.BidiStreamingServer[StreamCrunRequest, StreamCforedCrunReply]

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

type CraneForeD_TaskIOStreamClient

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

type CraneForeD_TaskIOStreamServer

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

type CranePluginDClient

type CranePluginDClient interface {
	// ----------------------------------- Called from CraneCtld ----------------------------------------------------
	StartHook(ctx context.Context, in *StartHookRequest, opts ...grpc.CallOption) (*StartHookReply, error)
	EndHook(ctx context.Context, in *EndHookRequest, opts ...grpc.CallOption) (*EndHookReply, error)
	// ----------------------------------- Called from Craned ----------------------------------------------------
	CreateCgroupHook(ctx context.Context, in *CreateCgroupHookRequest, opts ...grpc.CallOption) (*CreateCgroupHookReply, error)
	DestroyCgroupHook(ctx context.Context, in *DestroyCgroupHookRequest, opts ...grpc.CallOption) (*DestroyCgroupHookReply, error)
}

CranePluginDClient is the client API for CranePluginD 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.

type CranePluginDServer

type CranePluginDServer interface {
	// ----------------------------------- Called from CraneCtld ----------------------------------------------------
	StartHook(context.Context, *StartHookRequest) (*StartHookReply, error)
	EndHook(context.Context, *EndHookRequest) (*EndHookReply, error)
	// ----------------------------------- Called from Craned ----------------------------------------------------
	CreateCgroupHook(context.Context, *CreateCgroupHookRequest) (*CreateCgroupHookReply, error)
	DestroyCgroupHook(context.Context, *DestroyCgroupHookRequest) (*DestroyCgroupHookReply, error)
	// contains filtered or unexported methods
}

CranePluginDServer is the server API for CranePluginD service. All implementations must embed UnimplementedCranePluginDServer for forward compatibility.

type CranedClient

type CranedClient interface {
	// ----------------------------------- Called from CraneCtld ----------------------------------------------------
	ExecuteTask(ctx context.Context, in *ExecuteTasksRequest, opts ...grpc.CallOption) (*ExecuteTasksReply, error)
	CheckTaskStatus(ctx context.Context, in *CheckTaskStatusRequest, opts ...grpc.CallOption) (*CheckTaskStatusReply, error)
	CreateCgroupForTasks(ctx context.Context, in *CreateCgroupForTasksRequest, opts ...grpc.CallOption) (*CreateCgroupForTasksReply, error)
	ReleaseCgroupForTasks(ctx context.Context, in *ReleaseCgroupForTasksRequest, opts ...grpc.CallOption) (*ReleaseCgroupForTasksReply, error)
	QueryCranedRemoteMeta(ctx context.Context, in *QueryCranedRemoteMetaRequest, opts ...grpc.CallOption) (*QueryCranedRemoteMetaReply, error)
	// If the task is an interactive task, the resource uuid is also revoked.
	// If there's no process in this interactive task, just deallocate all the resources.
	// If there are processes in this interactive task, kill all the processes and deallocate resources.
	// If the task is a batch task, just kill it.
	TerminateTasks(ctx context.Context, in *TerminateTasksRequest, opts ...grpc.CallOption) (*TerminateTasksReply, error)
	TerminateOrphanedTask(ctx context.Context, in *TerminateOrphanedTaskRequest, opts ...grpc.CallOption) (*TerminateOrphanedTaskReply, error)
	ChangeTaskTimeLimit(ctx context.Context, in *ChangeTaskTimeLimitRequest, opts ...grpc.CallOption) (*ChangeTaskTimeLimitReply, error)
	// ----------------------------------- Called from Craned  ------------------------------------------------------
	QueryTaskIdFromPort(ctx context.Context, in *QueryTaskIdFromPortRequest, opts ...grpc.CallOption) (*QueryTaskIdFromPortReply, error)
	// ----------------------------------- Called from Pam Module  ---------------------------------------------------
	QueryTaskIdFromPortForward(ctx context.Context, in *QueryTaskIdFromPortForwardRequest, opts ...grpc.CallOption) (*QueryTaskIdFromPortForwardReply, error)
	MigrateSshProcToCgroup(ctx context.Context, in *MigrateSshProcToCgroupRequest, opts ...grpc.CallOption) (*MigrateSshProcToCgroupReply, error)
	QueryTaskEnvVariables(ctx context.Context, in *QueryTaskEnvVariablesRequest, opts ...grpc.CallOption) (*QueryTaskEnvVariablesReply, error)
	QueryTaskEnvVariablesForward(ctx context.Context, in *QueryTaskEnvVariablesForwardRequest, opts ...grpc.CallOption) (*QueryTaskEnvVariablesForwardReply, error)
}

CranedClient is the client API for Craned 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 NewCranedClient

func NewCranedClient(cc grpc.ClientConnInterface) CranedClient

type CranedControlState

type CranedControlState int32
const (
	CranedControlState_CRANE_NONE  CranedControlState = 0
	CranedControlState_CRANE_DRAIN CranedControlState = 1
)

func (CranedControlState) Descriptor

func (CranedControlState) Enum

func (CranedControlState) EnumDescriptor deprecated

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

Deprecated: Use CranedControlState.Descriptor instead.

func (CranedControlState) Number

func (CranedControlState) String

func (x CranedControlState) String() string

func (CranedControlState) Type

type CranedId

type CranedId struct {
	PartitionId uint32 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	CranedIndex uint32 `protobuf:"varint,2,opt,name=craned_index,json=cranedIndex,proto3" json:"craned_index,omitempty"`
	// contains filtered or unexported fields
}

func (*CranedId) Descriptor deprecated

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

Deprecated: Use CranedId.ProtoReflect.Descriptor instead.

func (*CranedId) GetCranedIndex

func (x *CranedId) GetCranedIndex() uint32

func (*CranedId) GetPartitionId

func (x *CranedId) GetPartitionId() uint32

func (*CranedId) ProtoMessage

func (*CranedId) ProtoMessage()

func (*CranedId) ProtoReflect

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

func (*CranedId) Reset

func (x *CranedId) Reset()

func (*CranedId) String

func (x *CranedId) String() string

type CranedInfo

type CranedInfo struct {
	Hostname        string                 `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	ResourceState   CranedResourceState    `` /* 137-byte string literal not displayed */
	ControlState    CranedControlState     `` /* 133-byte string literal not displayed */
	ResTotal        *ResourceInNode        `protobuf:"bytes,4,opt,name=res_total,json=resTotal,proto3" json:"res_total,omitempty"`
	ResAvail        *ResourceInNode        `protobuf:"bytes,5,opt,name=res_avail,json=resAvail,proto3" json:"res_avail,omitempty"`
	ResAlloc        *ResourceInNode        `protobuf:"bytes,6,opt,name=res_alloc,json=resAlloc,proto3" json:"res_alloc,omitempty"`
	PartitionNames  []string               `protobuf:"bytes,10,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	RunningTaskNum  uint32                 `protobuf:"varint,11,opt,name=running_task_num,json=runningTaskNum,proto3" json:"running_task_num,omitempty"`
	CranedVersion   string                 `protobuf:"bytes,12,opt,name=craned_version,json=cranedVersion,proto3" json:"craned_version,omitempty"`
	SystemDesc      string                 `protobuf:"bytes,13,opt,name=system_desc,json=systemDesc,proto3" json:"system_desc,omitempty"`
	CranedStartTime *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=craned_start_time,json=cranedStartTime,proto3" json:"craned_start_time,omitempty"`
	SystemBootTime  *timestamppb.Timestamp `protobuf:"bytes,15,opt,name=system_boot_time,json=systemBootTime,proto3" json:"system_boot_time,omitempty"`
	LastBusyTime    *timestamppb.Timestamp `protobuf:"bytes,16,opt,name=last_busy_time,json=lastBusyTime,proto3" json:"last_busy_time,omitempty"`
	// contains filtered or unexported fields
}

func (*CranedInfo) Descriptor deprecated

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

Deprecated: Use CranedInfo.ProtoReflect.Descriptor instead.

func (*CranedInfo) GetControlState

func (x *CranedInfo) GetControlState() CranedControlState

func (*CranedInfo) GetCranedStartTime

func (x *CranedInfo) GetCranedStartTime() *timestamppb.Timestamp

func (*CranedInfo) GetCranedVersion

func (x *CranedInfo) GetCranedVersion() string

func (*CranedInfo) GetHostname

func (x *CranedInfo) GetHostname() string

func (*CranedInfo) GetLastBusyTime

func (x *CranedInfo) GetLastBusyTime() *timestamppb.Timestamp

func (*CranedInfo) GetPartitionNames

func (x *CranedInfo) GetPartitionNames() []string

func (*CranedInfo) GetResAlloc

func (x *CranedInfo) GetResAlloc() *ResourceInNode

func (*CranedInfo) GetResAvail

func (x *CranedInfo) GetResAvail() *ResourceInNode

func (*CranedInfo) GetResTotal

func (x *CranedInfo) GetResTotal() *ResourceInNode

func (*CranedInfo) GetResourceState

func (x *CranedInfo) GetResourceState() CranedResourceState

func (*CranedInfo) GetRunningTaskNum

func (x *CranedInfo) GetRunningTaskNum() uint32

func (*CranedInfo) GetSystemBootTime

func (x *CranedInfo) GetSystemBootTime() *timestamppb.Timestamp

func (*CranedInfo) GetSystemDesc

func (x *CranedInfo) GetSystemDesc() string

func (*CranedInfo) ProtoMessage

func (*CranedInfo) ProtoMessage()

func (*CranedInfo) ProtoReflect

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

func (*CranedInfo) Reset

func (x *CranedInfo) Reset()

func (*CranedInfo) String

func (x *CranedInfo) String() string

type CranedRegisterReply

type CranedRegisterReply struct {
	Ok                bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	AlreadyRegistered bool `protobuf:"varint,2,opt,name=already_registered,json=alreadyRegistered,proto3" json:"already_registered,omitempty"`
	// contains filtered or unexported fields
}

func (*CranedRegisterReply) Descriptor deprecated

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

Deprecated: Use CranedRegisterReply.ProtoReflect.Descriptor instead.

func (*CranedRegisterReply) GetAlreadyRegistered

func (x *CranedRegisterReply) GetAlreadyRegistered() bool

func (*CranedRegisterReply) GetOk

func (x *CranedRegisterReply) GetOk() bool

func (*CranedRegisterReply) ProtoMessage

func (*CranedRegisterReply) ProtoMessage()

func (*CranedRegisterReply) ProtoReflect

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

func (*CranedRegisterReply) Reset

func (x *CranedRegisterReply) Reset()

func (*CranedRegisterReply) String

func (x *CranedRegisterReply) String() string

type CranedRegisterRequest

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

func (*CranedRegisterRequest) Descriptor deprecated

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

Deprecated: Use CranedRegisterRequest.ProtoReflect.Descriptor instead.

func (*CranedRegisterRequest) GetCranedId

func (x *CranedRegisterRequest) GetCranedId() string

func (*CranedRegisterRequest) ProtoMessage

func (*CranedRegisterRequest) ProtoMessage()

func (*CranedRegisterRequest) ProtoReflect

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

func (*CranedRegisterRequest) Reset

func (x *CranedRegisterRequest) Reset()

func (*CranedRegisterRequest) String

func (x *CranedRegisterRequest) String() string

type CranedRemoteMeta

type CranedRemoteMeta struct {
	DresInNode      *DedicatedResourceInNode `protobuf:"bytes,1,opt,name=dres_in_node,json=dresInNode,proto3" json:"dres_in_node,omitempty"`
	SysRelInfo      *SystemRelInfo           `protobuf:"bytes,2,opt,name=sys_rel_info,json=sysRelInfo,proto3" json:"sys_rel_info,omitempty"`
	CranedVersion   string                   `protobuf:"bytes,3,opt,name=craned_version,json=cranedVersion,proto3" json:"craned_version,omitempty"`
	CranedStartTime *timestamppb.Timestamp   `protobuf:"bytes,4,opt,name=craned_start_time,json=cranedStartTime,proto3" json:"craned_start_time,omitempty"`
	SystemBootTime  *timestamppb.Timestamp   `protobuf:"bytes,5,opt,name=system_boot_time,json=systemBootTime,proto3" json:"system_boot_time,omitempty"`
	// contains filtered or unexported fields
}

func (*CranedRemoteMeta) Descriptor deprecated

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

Deprecated: Use CranedRemoteMeta.ProtoReflect.Descriptor instead.

func (*CranedRemoteMeta) GetCranedStartTime

func (x *CranedRemoteMeta) GetCranedStartTime() *timestamppb.Timestamp

func (*CranedRemoteMeta) GetCranedVersion

func (x *CranedRemoteMeta) GetCranedVersion() string

func (*CranedRemoteMeta) GetDresInNode

func (x *CranedRemoteMeta) GetDresInNode() *DedicatedResourceInNode

func (*CranedRemoteMeta) GetSysRelInfo

func (x *CranedRemoteMeta) GetSysRelInfo() *SystemRelInfo

func (*CranedRemoteMeta) GetSystemBootTime

func (x *CranedRemoteMeta) GetSystemBootTime() *timestamppb.Timestamp

func (*CranedRemoteMeta) ProtoMessage

func (*CranedRemoteMeta) ProtoMessage()

func (*CranedRemoteMeta) ProtoReflect

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

func (*CranedRemoteMeta) Reset

func (x *CranedRemoteMeta) Reset()

func (*CranedRemoteMeta) String

func (x *CranedRemoteMeta) String() string

type CranedResourceState

type CranedResourceState int32
const (
	CranedResourceState_CRANE_IDLE  CranedResourceState = 0
	CranedResourceState_CRANE_MIX   CranedResourceState = 1
	CranedResourceState_CRANE_ALLOC CranedResourceState = 2
	CranedResourceState_CRANE_DOWN  CranedResourceState = 3
)

func (CranedResourceState) Descriptor

func (CranedResourceState) Enum

func (CranedResourceState) EnumDescriptor deprecated

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

Deprecated: Use CranedResourceState.Descriptor instead.

func (CranedResourceState) Number

func (CranedResourceState) String

func (x CranedResourceState) String() string

func (CranedResourceState) Type

type CranedServer

type CranedServer interface {
	// ----------------------------------- Called from CraneCtld ----------------------------------------------------
	ExecuteTask(context.Context, *ExecuteTasksRequest) (*ExecuteTasksReply, error)
	CheckTaskStatus(context.Context, *CheckTaskStatusRequest) (*CheckTaskStatusReply, error)
	CreateCgroupForTasks(context.Context, *CreateCgroupForTasksRequest) (*CreateCgroupForTasksReply, error)
	ReleaseCgroupForTasks(context.Context, *ReleaseCgroupForTasksRequest) (*ReleaseCgroupForTasksReply, error)
	QueryCranedRemoteMeta(context.Context, *QueryCranedRemoteMetaRequest) (*QueryCranedRemoteMetaReply, error)
	// If the task is an interactive task, the resource uuid is also revoked.
	// If there's no process in this interactive task, just deallocate all the resources.
	// If there are processes in this interactive task, kill all the processes and deallocate resources.
	// If the task is a batch task, just kill it.
	TerminateTasks(context.Context, *TerminateTasksRequest) (*TerminateTasksReply, error)
	TerminateOrphanedTask(context.Context, *TerminateOrphanedTaskRequest) (*TerminateOrphanedTaskReply, error)
	ChangeTaskTimeLimit(context.Context, *ChangeTaskTimeLimitRequest) (*ChangeTaskTimeLimitReply, error)
	// ----------------------------------- Called from Craned  ------------------------------------------------------
	QueryTaskIdFromPort(context.Context, *QueryTaskIdFromPortRequest) (*QueryTaskIdFromPortReply, error)
	// ----------------------------------- Called from Pam Module  ---------------------------------------------------
	QueryTaskIdFromPortForward(context.Context, *QueryTaskIdFromPortForwardRequest) (*QueryTaskIdFromPortForwardReply, error)
	MigrateSshProcToCgroup(context.Context, *MigrateSshProcToCgroupRequest) (*MigrateSshProcToCgroupReply, error)
	QueryTaskEnvVariables(context.Context, *QueryTaskEnvVariablesRequest) (*QueryTaskEnvVariablesReply, error)
	QueryTaskEnvVariablesForward(context.Context, *QueryTaskEnvVariablesForwardRequest) (*QueryTaskEnvVariablesForwardReply, error)
	// contains filtered or unexported methods
}

CranedServer is the server API for Craned service. All implementations must embed UnimplementedCranedServer for forward compatibility.

type CreateCgroupForTasksReply

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

func (*CreateCgroupForTasksReply) Descriptor deprecated

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

Deprecated: Use CreateCgroupForTasksReply.ProtoReflect.Descriptor instead.

func (*CreateCgroupForTasksReply) ProtoMessage

func (*CreateCgroupForTasksReply) ProtoMessage()

func (*CreateCgroupForTasksReply) ProtoReflect

func (*CreateCgroupForTasksReply) Reset

func (x *CreateCgroupForTasksReply) Reset()

func (*CreateCgroupForTasksReply) String

func (x *CreateCgroupForTasksReply) String() string

type CreateCgroupForTasksRequest

type CreateCgroupForTasksRequest struct {
	TaskIdList    []uint32          `protobuf:"varint,1,rep,packed,name=task_id_list,json=taskIdList,proto3" json:"task_id_list,omitempty"`
	UidList       []uint32          `protobuf:"varint,2,rep,packed,name=uid_list,json=uidList,proto3" json:"uid_list,omitempty"`
	ResList       []*ResourceInNode `protobuf:"bytes,3,rep,name=res_list,json=resList,proto3" json:"res_list,omitempty"`
	ExecutionNode []string          `protobuf:"bytes,4,rep,name=execution_node,json=executionNode,proto3" json:"execution_node,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateCgroupForTasksRequest) Descriptor deprecated

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

Deprecated: Use CreateCgroupForTasksRequest.ProtoReflect.Descriptor instead.

func (*CreateCgroupForTasksRequest) GetExecutionNode

func (x *CreateCgroupForTasksRequest) GetExecutionNode() []string

func (*CreateCgroupForTasksRequest) GetResList

func (x *CreateCgroupForTasksRequest) GetResList() []*ResourceInNode

func (*CreateCgroupForTasksRequest) GetTaskIdList

func (x *CreateCgroupForTasksRequest) GetTaskIdList() []uint32

func (*CreateCgroupForTasksRequest) GetUidList

func (x *CreateCgroupForTasksRequest) GetUidList() []uint32

func (*CreateCgroupForTasksRequest) ProtoMessage

func (*CreateCgroupForTasksRequest) ProtoMessage()

func (*CreateCgroupForTasksRequest) ProtoReflect

func (*CreateCgroupForTasksRequest) Reset

func (x *CreateCgroupForTasksRequest) Reset()

func (*CreateCgroupForTasksRequest) String

func (x *CreateCgroupForTasksRequest) String() string

type CreateCgroupHookReply

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

func (*CreateCgroupHookReply) Descriptor deprecated

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

Deprecated: Use CreateCgroupHookReply.ProtoReflect.Descriptor instead.

func (*CreateCgroupHookReply) GetOk

func (x *CreateCgroupHookReply) GetOk() bool

func (*CreateCgroupHookReply) ProtoMessage

func (*CreateCgroupHookReply) ProtoMessage()

func (*CreateCgroupHookReply) ProtoReflect

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

func (*CreateCgroupHookReply) Reset

func (x *CreateCgroupHookReply) Reset()

func (*CreateCgroupHookReply) String

func (x *CreateCgroupHookReply) String() string

type CreateCgroupHookRequest

type CreateCgroupHookRequest struct {
	TaskId   uint32                   `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Cgroup   string                   `protobuf:"bytes,2,opt,name=cgroup,proto3" json:"cgroup,omitempty"`
	Resource *DedicatedResourceInNode `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateCgroupHookRequest) Descriptor deprecated

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

Deprecated: Use CreateCgroupHookRequest.ProtoReflect.Descriptor instead.

func (*CreateCgroupHookRequest) GetCgroup

func (x *CreateCgroupHookRequest) GetCgroup() string

func (*CreateCgroupHookRequest) GetResource

func (*CreateCgroupHookRequest) GetTaskId

func (x *CreateCgroupHookRequest) GetTaskId() uint32

func (*CreateCgroupHookRequest) ProtoMessage

func (*CreateCgroupHookRequest) ProtoMessage()

func (*CreateCgroupHookRequest) ProtoReflect

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

func (*CreateCgroupHookRequest) Reset

func (x *CreateCgroupHookRequest) Reset()

func (*CreateCgroupHookRequest) String

func (x *CreateCgroupHookRequest) String() string

type DedicatedResourceInNode

type DedicatedResourceInNode struct {
	NameTypeMap map[string]*DeviceTypeSlotsMap `` /* 184-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DedicatedResourceInNode) Descriptor deprecated

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

Deprecated: Use DedicatedResourceInNode.ProtoReflect.Descriptor instead.

func (*DedicatedResourceInNode) GetNameTypeMap

func (x *DedicatedResourceInNode) GetNameTypeMap() map[string]*DeviceTypeSlotsMap

func (*DedicatedResourceInNode) ProtoMessage

func (*DedicatedResourceInNode) ProtoMessage()

func (*DedicatedResourceInNode) ProtoReflect

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

func (*DedicatedResourceInNode) Reset

func (x *DedicatedResourceInNode) Reset()

func (*DedicatedResourceInNode) String

func (x *DedicatedResourceInNode) String() string

type DeleteAccountReply

type DeleteAccountReply struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason ErrCode `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteAccountReply) Descriptor deprecated

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

Deprecated: Use DeleteAccountReply.ProtoReflect.Descriptor instead.

func (*DeleteAccountReply) GetOk

func (x *DeleteAccountReply) GetOk() bool

func (*DeleteAccountReply) GetReason

func (x *DeleteAccountReply) GetReason() ErrCode

func (*DeleteAccountReply) ProtoMessage

func (*DeleteAccountReply) ProtoMessage()

func (*DeleteAccountReply) ProtoReflect

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

func (*DeleteAccountReply) Reset

func (x *DeleteAccountReply) Reset()

func (*DeleteAccountReply) String

func (x *DeleteAccountReply) String() string

type DeleteAccountRequest

type DeleteAccountRequest struct {
	Uid  uint32 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteAccountRequest) Descriptor deprecated

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

Deprecated: Use DeleteAccountRequest.ProtoReflect.Descriptor instead.

func (*DeleteAccountRequest) GetName

func (x *DeleteAccountRequest) GetName() string

func (*DeleteAccountRequest) GetUid

func (x *DeleteAccountRequest) GetUid() uint32

func (*DeleteAccountRequest) ProtoMessage

func (*DeleteAccountRequest) ProtoMessage()

func (*DeleteAccountRequest) ProtoReflect

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

func (*DeleteAccountRequest) Reset

func (x *DeleteAccountRequest) Reset()

func (*DeleteAccountRequest) String

func (x *DeleteAccountRequest) String() string

type DeleteQosReply

type DeleteQosReply struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason ErrCode `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteQosReply) Descriptor deprecated

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

Deprecated: Use DeleteQosReply.ProtoReflect.Descriptor instead.

func (*DeleteQosReply) GetOk

func (x *DeleteQosReply) GetOk() bool

func (*DeleteQosReply) GetReason

func (x *DeleteQosReply) GetReason() ErrCode

func (*DeleteQosReply) ProtoMessage

func (*DeleteQosReply) ProtoMessage()

func (*DeleteQosReply) ProtoReflect

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

func (*DeleteQosReply) Reset

func (x *DeleteQosReply) Reset()

func (*DeleteQosReply) String

func (x *DeleteQosReply) String() string

type DeleteQosRequest

type DeleteQosRequest struct {
	Uid  uint32 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteQosRequest) Descriptor deprecated

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

Deprecated: Use DeleteQosRequest.ProtoReflect.Descriptor instead.

func (*DeleteQosRequest) GetName

func (x *DeleteQosRequest) GetName() string

func (*DeleteQosRequest) GetUid

func (x *DeleteQosRequest) GetUid() uint32

func (*DeleteQosRequest) ProtoMessage

func (*DeleteQosRequest) ProtoMessage()

func (*DeleteQosRequest) ProtoReflect

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

func (*DeleteQosRequest) Reset

func (x *DeleteQosRequest) Reset()

func (*DeleteQosRequest) String

func (x *DeleteQosRequest) String() string

type DeleteUserReply

type DeleteUserReply struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason ErrCode `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteUserReply) Descriptor deprecated

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

Deprecated: Use DeleteUserReply.ProtoReflect.Descriptor instead.

func (*DeleteUserReply) GetOk

func (x *DeleteUserReply) GetOk() bool

func (*DeleteUserReply) GetReason

func (x *DeleteUserReply) GetReason() ErrCode

func (*DeleteUserReply) ProtoMessage

func (*DeleteUserReply) ProtoMessage()

func (*DeleteUserReply) ProtoReflect

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

func (*DeleteUserReply) Reset

func (x *DeleteUserReply) Reset()

func (*DeleteUserReply) String

func (x *DeleteUserReply) String() string

type DeleteUserRequest

type DeleteUserRequest struct {
	Uid     uint32 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Account string `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteUserRequest) Descriptor deprecated

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

Deprecated: Use DeleteUserRequest.ProtoReflect.Descriptor instead.

func (*DeleteUserRequest) GetAccount

func (x *DeleteUserRequest) GetAccount() string

func (*DeleteUserRequest) GetName

func (x *DeleteUserRequest) GetName() string

func (*DeleteUserRequest) GetUid

func (x *DeleteUserRequest) GetUid() uint32

func (*DeleteUserRequest) ProtoMessage

func (*DeleteUserRequest) ProtoMessage()

func (*DeleteUserRequest) ProtoReflect

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

func (*DeleteUserRequest) Reset

func (x *DeleteUserRequest) Reset()

func (*DeleteUserRequest) String

func (x *DeleteUserRequest) String() string

type DestroyCgroupHookReply

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

func (*DestroyCgroupHookReply) Descriptor deprecated

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

Deprecated: Use DestroyCgroupHookReply.ProtoReflect.Descriptor instead.

func (*DestroyCgroupHookReply) GetOk

func (x *DestroyCgroupHookReply) GetOk() bool

func (*DestroyCgroupHookReply) ProtoMessage

func (*DestroyCgroupHookReply) ProtoMessage()

func (*DestroyCgroupHookReply) ProtoReflect

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

func (*DestroyCgroupHookReply) Reset

func (x *DestroyCgroupHookReply) Reset()

func (*DestroyCgroupHookReply) String

func (x *DestroyCgroupHookReply) String() string

type DestroyCgroupHookRequest

type DestroyCgroupHookRequest struct {
	TaskId uint32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Cgroup string `protobuf:"bytes,2,opt,name=cgroup,proto3" json:"cgroup,omitempty"`
	// contains filtered or unexported fields
}

func (*DestroyCgroupHookRequest) Descriptor deprecated

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

Deprecated: Use DestroyCgroupHookRequest.ProtoReflect.Descriptor instead.

func (*DestroyCgroupHookRequest) GetCgroup

func (x *DestroyCgroupHookRequest) GetCgroup() string

func (*DestroyCgroupHookRequest) GetTaskId

func (x *DestroyCgroupHookRequest) GetTaskId() uint32

func (*DestroyCgroupHookRequest) ProtoMessage

func (*DestroyCgroupHookRequest) ProtoMessage()

func (*DestroyCgroupHookRequest) ProtoReflect

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

func (*DestroyCgroupHookRequest) Reset

func (x *DestroyCgroupHookRequest) Reset()

func (*DestroyCgroupHookRequest) String

func (x *DestroyCgroupHookRequest) String() string

type DeviceMap

type DeviceMap struct {
	NameTypeMap map[string]*TypeCountMap `` /* 184-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DeviceMap) Descriptor deprecated

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

Deprecated: Use DeviceMap.ProtoReflect.Descriptor instead.

func (*DeviceMap) GetNameTypeMap

func (x *DeviceMap) GetNameTypeMap() map[string]*TypeCountMap

func (*DeviceMap) ProtoMessage

func (*DeviceMap) ProtoMessage()

func (*DeviceMap) ProtoReflect

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

func (*DeviceMap) Reset

func (x *DeviceMap) Reset()

func (*DeviceMap) String

func (x *DeviceMap) String() string

type DeviceTypeSlotsMap

type DeviceTypeSlotsMap struct {
	TypeSlotsMap map[string]*Slots `` /* 187-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DeviceTypeSlotsMap) Descriptor deprecated

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

Deprecated: Use DeviceTypeSlotsMap.ProtoReflect.Descriptor instead.

func (*DeviceTypeSlotsMap) GetTypeSlotsMap

func (x *DeviceTypeSlotsMap) GetTypeSlotsMap() map[string]*Slots

func (*DeviceTypeSlotsMap) ProtoMessage

func (*DeviceTypeSlotsMap) ProtoMessage()

func (*DeviceTypeSlotsMap) ProtoReflect

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

func (*DeviceTypeSlotsMap) Reset

func (x *DeviceTypeSlotsMap) Reset()

func (*DeviceTypeSlotsMap) String

func (x *DeviceTypeSlotsMap) String() string

type EndHookReply

type EndHookReply struct {
	Result []*EndHookReply_TaskIdReply `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*EndHookReply) Descriptor deprecated

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

Deprecated: Use EndHookReply.ProtoReflect.Descriptor instead.

func (*EndHookReply) GetResult

func (x *EndHookReply) GetResult() []*EndHookReply_TaskIdReply

func (*EndHookReply) ProtoMessage

func (*EndHookReply) ProtoMessage()

func (*EndHookReply) ProtoReflect

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

func (*EndHookReply) Reset

func (x *EndHookReply) Reset()

func (*EndHookReply) String

func (x *EndHookReply) String() string

type EndHookReply_TaskIdReply

type EndHookReply_TaskIdReply struct {
	Ok            bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	TaskId        uint32 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	FailureReason string `protobuf:"bytes,3,opt,name=failure_reason,json=failureReason,proto3" json:"failure_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*EndHookReply_TaskIdReply) Descriptor deprecated

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

Deprecated: Use EndHookReply_TaskIdReply.ProtoReflect.Descriptor instead.

func (*EndHookReply_TaskIdReply) GetFailureReason

func (x *EndHookReply_TaskIdReply) GetFailureReason() string

func (*EndHookReply_TaskIdReply) GetOk

func (x *EndHookReply_TaskIdReply) GetOk() bool

func (*EndHookReply_TaskIdReply) GetTaskId

func (x *EndHookReply_TaskIdReply) GetTaskId() uint32

func (*EndHookReply_TaskIdReply) ProtoMessage

func (*EndHookReply_TaskIdReply) ProtoMessage()

func (*EndHookReply_TaskIdReply) ProtoReflect

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

func (*EndHookReply_TaskIdReply) Reset

func (x *EndHookReply_TaskIdReply) Reset()

func (*EndHookReply_TaskIdReply) String

func (x *EndHookReply_TaskIdReply) String() string

type EndHookRequest

type EndHookRequest struct {
	TaskInfoList []*TaskInfo `protobuf:"bytes,1,rep,name=task_info_list,json=taskInfoList,proto3" json:"task_info_list,omitempty"`
	// contains filtered or unexported fields
}

func (*EndHookRequest) Descriptor deprecated

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

Deprecated: Use EndHookRequest.ProtoReflect.Descriptor instead.

func (*EndHookRequest) GetTaskInfoList

func (x *EndHookRequest) GetTaskInfoList() []*TaskInfo

func (*EndHookRequest) ProtoMessage

func (*EndHookRequest) ProtoMessage()

func (*EndHookRequest) ProtoReflect

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

func (*EndHookRequest) Reset

func (x *EndHookRequest) Reset()

func (*EndHookRequest) String

func (x *EndHookRequest) String() string

type EntityType

type EntityType int32
const (
	EntityType_Account EntityType = 0
	EntityType_User    EntityType = 1
)

func (EntityType) Descriptor

func (EntityType) Descriptor() protoreflect.EnumDescriptor

func (EntityType) Enum

func (x EntityType) Enum() *EntityType

func (EntityType) EnumDescriptor deprecated

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

Deprecated: Use EntityType.Descriptor instead.

func (EntityType) Number

func (x EntityType) Number() protoreflect.EnumNumber

func (EntityType) String

func (x EntityType) String() string

func (EntityType) Type

type ErrCode

type ErrCode int32
const (
	ErrCode_SUCCESS                      ErrCode = 0     // Success
	ErrCode_ERR_INVALID_UID              ErrCode = 10001 // Invalid UID passed
	ErrCode_ERR_INVALID_OP_USER          ErrCode = 10002 // Invalid operation user
	ErrCode_ERR_INVALID_USER             ErrCode = 10003 // Invalid user
	ErrCode_ERR_PERMISSION_USER          ErrCode = 10004 // User permissions too low, no permission to operate
	ErrCode_ERR_USER_DUPLICATE_ACCOUNT   ErrCode = 10005 // User duplicate account insertion
	ErrCode_ERR_USER_ALLOWED_ACCOUNT     ErrCode = 10006 // User does not have permission for the account
	ErrCode_ERR_INVALID_ADMIN_LEVEL      ErrCode = 10007 // Invalid permission level
	ErrCode_ERR_USER_ACCOUNT_MISMATCH    ErrCode = 10008 // User does not belong to the account
	ErrCode_ERR_NO_ACCOUNT_SPECIFIED     ErrCode = 10009
	ErrCode_ERR_INVALID_ACCOUNT          ErrCode = 10010 // Invalid account
	ErrCode_ERR_DUPLICATE_ACCOUNT        ErrCode = 10011 // Duplicate account insertion
	ErrCode_ERR_INVALID_PARENTACCOUNT    ErrCode = 10012 // Invalid parent account
	ErrCode_ERR_DELETE_ACCOUNT           ErrCode = 10013 // Account has child nodes
	ErrCode_ERR_INVALID_PARTITION        ErrCode = 10014 // Invalid partition, partition does not exist
	ErrCode_ERR_ALLOWED_PARTITION        ErrCode = 10015 // Account/user does not include this partition
	ErrCode_ERR_DUPLICATE_PARTITION      ErrCode = 10016 // Account/user duplicate insertion
	ErrCode_ERR_PARENT_ALLOWED_PARTITION ErrCode = 10017 // Parent account does not include this partition
	ErrCode_ERR_USER_EMPTY_PARTITION     ErrCode = 10018 // Cannot add QoS when user has no partition
	ErrCode_ERR_CHILD_HAS_PARTITION      ErrCode = 10019 // Partition '{}' is used by some descendant node of the account '{}'. Ignoring this constraint with forced operation.
	ErrCode_ERR_INVALID_QOS              ErrCode = 10020 // Invalid QoS, QoS does not exist
	ErrCode_ERR_DB_DUPLICATE_QOS         ErrCode = 10021 // Duplicate QoS insertion in the database.
	ErrCode_ERR_DELETE_QOS               ErrCode = 10022 // QoS reference count is not zero.
	ErrCode_ERR_CONVERT_TO_INTERGER      ErrCode = 10023 // String to integer conversion failed
	ErrCode_ERR_TIME_LIMIT               ErrCode = 10024 // Invalid time value
	ErrCode_ERR_ALLOWED_QOS              ErrCode = 10025 // Account/user does not include this QoS.
	ErrCode_ERR_DUPLICATE_QOS            ErrCode = 10026 // Account/user duplicate insertion.
	ErrCode_ERR_PARENT_ALLOWED_QOS       ErrCode = 10027 // Parent account does not include this QoS.
	ErrCode_ERR_SET_ALLOWED_QOS          ErrCode = 10028 // QoS '{}' is the default QoS of partition '{}', but not found in the new QoS list.
	ErrCode_ERR_ALLOWED_DEFAULT_QOS      ErrCode = 10029 // Default QoS is not in the allowed QoS list
	ErrCode_ERR_DUPLICATE_DEFAULT_QOS    ErrCode = 10030 // Duplicate default QoS setting
	ErrCode_ERR_CHILD_HAS_DEFAULT_QOS    ErrCode = 10031 // Someone is using QoS '{}' as default QoS. Ignoring this constraint with forced deletion, the deleted default QoS is randomly replaced with one of the remaining items in the QoS list.
	ErrCode_ERR_SET_ACCOUNT_QOS          ErrCode = 10032 // QoS '{}' is used by some descendant node or itself of the account '{}'. Ignoring this constraint with forced operation.
	ErrCode_ERR_SET_DEFAULT_QOS          ErrCode = 10033 // Qos '{}' not in allowed qos list or is already the default qos
	ErrCode_ERR_IS_DEFAULT_QOS           ErrCode = 10034
	ErrCode_ERR_UPDATE_DATABASE          ErrCode = 10035 // Database update failed
	ErrCode_ERR_GENERIC_FAILURE          ErrCode = 10100
	ErrCode_ERR_NO_RESOURCE              ErrCode = 10101
	ErrCode_ERR_NON_EXISTENT             ErrCode = 10102
	ErrCode_ERR_INVALID_NODE_NUM         ErrCode = 10103
	ErrCode_ERR_SYSTEM_ERR               ErrCode = 10104
	ErrCode_ERR_EXISTING_TASK            ErrCode = 10105
	ErrCode_ERR_INVALID_PARAM            ErrCode = 10106
	ErrCode_ERR_STOP                     ErrCode = 10107
	ErrCode_ERR_PERMISSION_DENIED        ErrCode = 10108
	ErrCode_ERR_CONNECTION_TIMEOUT       ErrCode = 10109
	ErrCode_ERR_CONNECTION_ABORTED       ErrCode = 10110
	ErrCode_ERR_RPC_FAILURE              ErrCode = 10111
	ErrCode_ERR_TOKEN_REQUEST_FAILURE    ErrCode = 10112
	ErrCode_ERR_STREAM_BROKEN            ErrCode = 10113
	ErrCode_ERR_INVALID_STUB             ErrCode = 10114
	ErrCode_ERR_CGROUP                   ErrCode = 10115
	ErrCode_ERR_PROTOBUF                 ErrCode = 10116
	ErrCode_ERR_LIB_EVENT                ErrCode = 10117
	ErrCode_ERR_NO_AVAIL_NODE            ErrCode = 10118
)

func (ErrCode) Descriptor

func (ErrCode) Descriptor() protoreflect.EnumDescriptor

func (ErrCode) Enum

func (x ErrCode) Enum() *ErrCode

func (ErrCode) EnumDescriptor deprecated

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

Deprecated: Use ErrCode.Descriptor instead.

func (ErrCode) Number

func (x ErrCode) Number() protoreflect.EnumNumber

func (ErrCode) String

func (x ErrCode) String() string

func (ErrCode) Type

func (ErrCode) Type() protoreflect.EnumType

type ExecuteTasksReply

type ExecuteTasksReply struct {
	FailedTaskIdList []uint32 `protobuf:"varint,1,rep,packed,name=failed_task_id_list,json=failedTaskIdList,proto3" json:"failed_task_id_list,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteTasksReply) Descriptor deprecated

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

Deprecated: Use ExecuteTasksReply.ProtoReflect.Descriptor instead.

func (*ExecuteTasksReply) GetFailedTaskIdList

func (x *ExecuteTasksReply) GetFailedTaskIdList() []uint32

func (*ExecuteTasksReply) ProtoMessage

func (*ExecuteTasksReply) ProtoMessage()

func (*ExecuteTasksReply) ProtoReflect

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

func (*ExecuteTasksReply) Reset

func (x *ExecuteTasksReply) Reset()

func (*ExecuteTasksReply) String

func (x *ExecuteTasksReply) String() string

type ExecuteTasksRequest

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

func (*ExecuteTasksRequest) Descriptor deprecated

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

Deprecated: Use ExecuteTasksRequest.ProtoReflect.Descriptor instead.

func (*ExecuteTasksRequest) GetTasks

func (x *ExecuteTasksRequest) GetTasks() []*TaskToD

func (*ExecuteTasksRequest) ProtoMessage

func (*ExecuteTasksRequest) ProtoMessage()

func (*ExecuteTasksRequest) ProtoReflect

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

func (*ExecuteTasksRequest) Reset

func (x *ExecuteTasksRequest) Reset()

func (*ExecuteTasksRequest) String

func (x *ExecuteTasksRequest) String() string

type InteractiveTaskAdditionalMeta

type InteractiveTaskAdditionalMeta struct {
	CforedName      string              `protobuf:"bytes,1,opt,name=cfored_name,json=cforedName,proto3" json:"cfored_name,omitempty"`
	ShScript        string              `protobuf:"bytes,2,opt,name=sh_script,json=shScript,proto3" json:"sh_script,omitempty"`
	TermEnv         string              `protobuf:"bytes,3,opt,name=term_env,json=termEnv,proto3" json:"term_env,omitempty"`
	InteractiveType InteractiveTaskType `` /* 143-byte string literal not displayed */
	Pty             bool                `protobuf:"varint,5,opt,name=pty,proto3" json:"pty,omitempty"`
	// contains filtered or unexported fields
}

func (*InteractiveTaskAdditionalMeta) Descriptor deprecated

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

Deprecated: Use InteractiveTaskAdditionalMeta.ProtoReflect.Descriptor instead.

func (*InteractiveTaskAdditionalMeta) GetCforedName

func (x *InteractiveTaskAdditionalMeta) GetCforedName() string

func (*InteractiveTaskAdditionalMeta) GetInteractiveType

func (x *InteractiveTaskAdditionalMeta) GetInteractiveType() InteractiveTaskType

func (*InteractiveTaskAdditionalMeta) GetPty

func (x *InteractiveTaskAdditionalMeta) GetPty() bool

func (*InteractiveTaskAdditionalMeta) GetShScript

func (x *InteractiveTaskAdditionalMeta) GetShScript() string

func (*InteractiveTaskAdditionalMeta) GetTermEnv

func (x *InteractiveTaskAdditionalMeta) GetTermEnv() string

func (*InteractiveTaskAdditionalMeta) ProtoMessage

func (*InteractiveTaskAdditionalMeta) ProtoMessage()

func (*InteractiveTaskAdditionalMeta) ProtoReflect

func (*InteractiveTaskAdditionalMeta) Reset

func (x *InteractiveTaskAdditionalMeta) Reset()

func (*InteractiveTaskAdditionalMeta) String

type InteractiveTaskType

type InteractiveTaskType int32
const (
	InteractiveTaskType_Calloc InteractiveTaskType = 0
	InteractiveTaskType_Crun   InteractiveTaskType = 1
)

func (InteractiveTaskType) Descriptor

func (InteractiveTaskType) Enum

func (InteractiveTaskType) EnumDescriptor deprecated

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

Deprecated: Use InteractiveTaskType.Descriptor instead.

func (InteractiveTaskType) Number

func (InteractiveTaskType) String

func (x InteractiveTaskType) String() string

func (InteractiveTaskType) Type

type MigrateSshProcToCgroupReply

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

func (*MigrateSshProcToCgroupReply) Descriptor deprecated

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

Deprecated: Use MigrateSshProcToCgroupReply.ProtoReflect.Descriptor instead.

func (*MigrateSshProcToCgroupReply) GetOk

func (x *MigrateSshProcToCgroupReply) GetOk() bool

func (*MigrateSshProcToCgroupReply) ProtoMessage

func (*MigrateSshProcToCgroupReply) ProtoMessage()

func (*MigrateSshProcToCgroupReply) ProtoReflect

func (*MigrateSshProcToCgroupReply) Reset

func (x *MigrateSshProcToCgroupReply) Reset()

func (*MigrateSshProcToCgroupReply) String

func (x *MigrateSshProcToCgroupReply) String() string

type MigrateSshProcToCgroupRequest

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

func (*MigrateSshProcToCgroupRequest) Descriptor deprecated

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

Deprecated: Use MigrateSshProcToCgroupRequest.ProtoReflect.Descriptor instead.

func (*MigrateSshProcToCgroupRequest) GetPid

func (*MigrateSshProcToCgroupRequest) GetTaskId

func (x *MigrateSshProcToCgroupRequest) GetTaskId() uint32

func (*MigrateSshProcToCgroupRequest) ProtoMessage

func (*MigrateSshProcToCgroupRequest) ProtoMessage()

func (*MigrateSshProcToCgroupRequest) ProtoReflect

func (*MigrateSshProcToCgroupRequest) Reset

func (x *MigrateSshProcToCgroupRequest) Reset()

func (*MigrateSshProcToCgroupRequest) String

type ModifyAccountReply

type ModifyAccountReply struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason ErrCode `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyAccountReply) Descriptor deprecated

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

Deprecated: Use ModifyAccountReply.ProtoReflect.Descriptor instead.

func (*ModifyAccountReply) GetOk

func (x *ModifyAccountReply) GetOk() bool

func (*ModifyAccountReply) GetReason

func (x *ModifyAccountReply) GetReason() ErrCode

func (*ModifyAccountReply) ProtoMessage

func (*ModifyAccountReply) ProtoMessage()

func (*ModifyAccountReply) ProtoReflect

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

func (*ModifyAccountReply) Reset

func (x *ModifyAccountReply) Reset()

func (*ModifyAccountReply) String

func (x *ModifyAccountReply) String() string

type ModifyAccountRequest

type ModifyAccountRequest struct {
	Uid         uint32        `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	ModifyField ModifyField   `protobuf:"varint,2,opt,name=modify_field,json=modifyField,proto3,enum=crane.grpc.ModifyField" json:"modify_field,omitempty"` //modify item field
	Value       string        `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`                                                             //new value
	Name        string        `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Type        OperationType `protobuf:"varint,5,opt,name=type,proto3,enum=crane.grpc.OperationType" json:"type,omitempty"`
	Force       bool          `protobuf:"varint,6,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyAccountRequest) Descriptor deprecated

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

Deprecated: Use ModifyAccountRequest.ProtoReflect.Descriptor instead.

func (*ModifyAccountRequest) GetForce

func (x *ModifyAccountRequest) GetForce() bool

func (*ModifyAccountRequest) GetModifyField

func (x *ModifyAccountRequest) GetModifyField() ModifyField

func (*ModifyAccountRequest) GetName

func (x *ModifyAccountRequest) GetName() string

func (*ModifyAccountRequest) GetType

func (x *ModifyAccountRequest) GetType() OperationType

func (*ModifyAccountRequest) GetUid

func (x *ModifyAccountRequest) GetUid() uint32

func (*ModifyAccountRequest) GetValue

func (x *ModifyAccountRequest) GetValue() string

func (*ModifyAccountRequest) ProtoMessage

func (*ModifyAccountRequest) ProtoMessage()

func (*ModifyAccountRequest) ProtoReflect

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

func (*ModifyAccountRequest) Reset

func (x *ModifyAccountRequest) Reset()

func (*ModifyAccountRequest) String

func (x *ModifyAccountRequest) String() string

type ModifyCranedStateReply

type ModifyCranedStateReply struct {
	ModifiedNodes      []string `protobuf:"bytes,2,rep,name=modified_nodes,json=modifiedNodes,proto3" json:"modified_nodes,omitempty"`
	NotModifiedNodes   []string `protobuf:"bytes,3,rep,name=not_modified_nodes,json=notModifiedNodes,proto3" json:"not_modified_nodes,omitempty"`
	NotModifiedReasons []string `protobuf:"bytes,4,rep,name=not_modified_reasons,json=notModifiedReasons,proto3" json:"not_modified_reasons,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyCranedStateReply) Descriptor deprecated

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

Deprecated: Use ModifyCranedStateReply.ProtoReflect.Descriptor instead.

func (*ModifyCranedStateReply) GetModifiedNodes

func (x *ModifyCranedStateReply) GetModifiedNodes() []string

func (*ModifyCranedStateReply) GetNotModifiedNodes

func (x *ModifyCranedStateReply) GetNotModifiedNodes() []string

func (*ModifyCranedStateReply) GetNotModifiedReasons

func (x *ModifyCranedStateReply) GetNotModifiedReasons() []string

func (*ModifyCranedStateReply) ProtoMessage

func (*ModifyCranedStateReply) ProtoMessage()

func (*ModifyCranedStateReply) ProtoReflect

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

func (*ModifyCranedStateReply) Reset

func (x *ModifyCranedStateReply) Reset()

func (*ModifyCranedStateReply) String

func (x *ModifyCranedStateReply) String() string

type ModifyCranedStateRequest

type ModifyCranedStateRequest struct {
	Uid       uint32             `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	CranedIds []string           `protobuf:"bytes,2,rep,name=craned_ids,json=cranedIds,proto3" json:"craned_ids,omitempty"`
	NewState  CranedControlState `protobuf:"varint,3,opt,name=new_state,json=newState,proto3,enum=crane.grpc.CranedControlState" json:"new_state,omitempty"`
	Reason    string             `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyCranedStateRequest) Descriptor deprecated

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

Deprecated: Use ModifyCranedStateRequest.ProtoReflect.Descriptor instead.

func (*ModifyCranedStateRequest) GetCranedIds

func (x *ModifyCranedStateRequest) GetCranedIds() []string

func (*ModifyCranedStateRequest) GetNewState

func (*ModifyCranedStateRequest) GetReason

func (x *ModifyCranedStateRequest) GetReason() string

func (*ModifyCranedStateRequest) GetUid

func (x *ModifyCranedStateRequest) GetUid() uint32

func (*ModifyCranedStateRequest) ProtoMessage

func (*ModifyCranedStateRequest) ProtoMessage()

func (*ModifyCranedStateRequest) ProtoReflect

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

func (*ModifyCranedStateRequest) Reset

func (x *ModifyCranedStateRequest) Reset()

func (*ModifyCranedStateRequest) String

func (x *ModifyCranedStateRequest) String() string

type ModifyField

type ModifyField int32
const (
	// user and account
	ModifyField_Partition  ModifyField = 0
	ModifyField_Qos        ModifyField = 1
	ModifyField_DefaultQos ModifyField = 2
	// account and qos
	ModifyField_Description ModifyField = 3
	// user
	ModifyField_AdminLevel ModifyField = 4
	// qos
	ModifyField_Priority            ModifyField = 5
	ModifyField_MaxJobsPerUser      ModifyField = 6
	ModifyField_MaxCpusPerUser      ModifyField = 7
	ModifyField_MaxTimeLimitPerTask ModifyField = 8
)

func (ModifyField) Descriptor

func (ModifyField) Enum

func (x ModifyField) Enum() *ModifyField

func (ModifyField) EnumDescriptor deprecated

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

Deprecated: Use ModifyField.Descriptor instead.

func (ModifyField) Number

func (x ModifyField) Number() protoreflect.EnumNumber

func (ModifyField) String

func (x ModifyField) String() string

func (ModifyField) Type

type ModifyQosReply

type ModifyQosReply struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason ErrCode `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyQosReply) Descriptor deprecated

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

Deprecated: Use ModifyQosReply.ProtoReflect.Descriptor instead.

func (*ModifyQosReply) GetOk

func (x *ModifyQosReply) GetOk() bool

func (*ModifyQosReply) GetReason

func (x *ModifyQosReply) GetReason() ErrCode

func (*ModifyQosReply) ProtoMessage

func (*ModifyQosReply) ProtoMessage()

func (*ModifyQosReply) ProtoReflect

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

func (*ModifyQosReply) Reset

func (x *ModifyQosReply) Reset()

func (*ModifyQosReply) String

func (x *ModifyQosReply) String() string

type ModifyQosRequest

type ModifyQosRequest struct {
	Uid         uint32      `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	ModifyField ModifyField `protobuf:"varint,2,opt,name=modify_field,json=modifyField,proto3,enum=crane.grpc.ModifyField" json:"modify_field,omitempty"` //modify item field
	Value       string      `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`                                                             //new value
	Name        string      `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyQosRequest) Descriptor deprecated

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

Deprecated: Use ModifyQosRequest.ProtoReflect.Descriptor instead.

func (*ModifyQosRequest) GetModifyField

func (x *ModifyQosRequest) GetModifyField() ModifyField

func (*ModifyQosRequest) GetName

func (x *ModifyQosRequest) GetName() string

func (*ModifyQosRequest) GetUid

func (x *ModifyQosRequest) GetUid() uint32

func (*ModifyQosRequest) GetValue

func (x *ModifyQosRequest) GetValue() string

func (*ModifyQosRequest) ProtoMessage

func (*ModifyQosRequest) ProtoMessage()

func (*ModifyQosRequest) ProtoReflect

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

func (*ModifyQosRequest) Reset

func (x *ModifyQosRequest) Reset()

func (*ModifyQosRequest) String

func (x *ModifyQosRequest) String() string

type ModifyTaskReply

type ModifyTaskReply struct {
	ModifiedTasks      []uint32 `protobuf:"varint,2,rep,packed,name=modified_tasks,json=modifiedTasks,proto3" json:"modified_tasks,omitempty"`
	NotModifiedTasks   []uint32 `protobuf:"varint,3,rep,packed,name=not_modified_tasks,json=notModifiedTasks,proto3" json:"not_modified_tasks,omitempty"`
	NotModifiedReasons []string `protobuf:"bytes,4,rep,name=not_modified_reasons,json=notModifiedReasons,proto3" json:"not_modified_reasons,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyTaskReply) Descriptor deprecated

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

Deprecated: Use ModifyTaskReply.ProtoReflect.Descriptor instead.

func (*ModifyTaskReply) GetModifiedTasks

func (x *ModifyTaskReply) GetModifiedTasks() []uint32

func (*ModifyTaskReply) GetNotModifiedReasons

func (x *ModifyTaskReply) GetNotModifiedReasons() []string

func (*ModifyTaskReply) GetNotModifiedTasks

func (x *ModifyTaskReply) GetNotModifiedTasks() []uint32

func (*ModifyTaskReply) ProtoMessage

func (*ModifyTaskReply) ProtoMessage()

func (*ModifyTaskReply) ProtoReflect

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

func (*ModifyTaskReply) Reset

func (x *ModifyTaskReply) Reset()

func (*ModifyTaskReply) String

func (x *ModifyTaskReply) String() string

type ModifyTaskRequest

type ModifyTaskRequest struct {
	Uid       uint32                             `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	TaskIds   []uint32                           `protobuf:"varint,2,rep,packed,name=task_ids,json=taskIds,proto3" json:"task_ids,omitempty"`
	Attribute ModifyTaskRequest_TargetAttributes `protobuf:"varint,3,opt,name=attribute,proto3,enum=crane.grpc.ModifyTaskRequest_TargetAttributes" json:"attribute,omitempty"`
	// Types that are assignable to Value:
	//
	//	*ModifyTaskRequest_TimeLimitSeconds
	//	*ModifyTaskRequest_MandatedPriority
	//	*ModifyTaskRequest_HoldSeconds
	Value isModifyTaskRequest_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*ModifyTaskRequest) Descriptor deprecated

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

Deprecated: Use ModifyTaskRequest.ProtoReflect.Descriptor instead.

func (*ModifyTaskRequest) GetAttribute

func (*ModifyTaskRequest) GetHoldSeconds

func (x *ModifyTaskRequest) GetHoldSeconds() int64

func (*ModifyTaskRequest) GetMandatedPriority

func (x *ModifyTaskRequest) GetMandatedPriority() float64

func (*ModifyTaskRequest) GetTaskIds

func (x *ModifyTaskRequest) GetTaskIds() []uint32

func (*ModifyTaskRequest) GetTimeLimitSeconds

func (x *ModifyTaskRequest) GetTimeLimitSeconds() int64

func (*ModifyTaskRequest) GetUid

func (x *ModifyTaskRequest) GetUid() uint32

func (*ModifyTaskRequest) GetValue

func (m *ModifyTaskRequest) GetValue() isModifyTaskRequest_Value

func (*ModifyTaskRequest) ProtoMessage

func (*ModifyTaskRequest) ProtoMessage()

func (*ModifyTaskRequest) ProtoReflect

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

func (*ModifyTaskRequest) Reset

func (x *ModifyTaskRequest) Reset()

func (*ModifyTaskRequest) String

func (x *ModifyTaskRequest) String() string

type ModifyTaskRequest_HoldSeconds

type ModifyTaskRequest_HoldSeconds struct {
	// If hold_seconds == 0, release the hold constraint timer if any exists;
	// If hold_seconds > 0, add or overwrite a hold constraint timer;
	// If hold_seconds == MaxInt64, add a hold constraint without timer.
	HoldSeconds int64 `protobuf:"varint,7,opt,name=hold_seconds,json=holdSeconds,proto3,oneof"`
}

type ModifyTaskRequest_MandatedPriority

type ModifyTaskRequest_MandatedPriority struct {
	MandatedPriority float64 `protobuf:"fixed64,5,opt,name=mandated_priority,json=mandatedPriority,proto3,oneof"`
}

type ModifyTaskRequest_TargetAttributes

type ModifyTaskRequest_TargetAttributes int32
const (
	ModifyTaskRequest_TimeLimit ModifyTaskRequest_TargetAttributes = 0
	ModifyTaskRequest_Priority  ModifyTaskRequest_TargetAttributes = 1
	ModifyTaskRequest_Hold      ModifyTaskRequest_TargetAttributes = 2
)

func (ModifyTaskRequest_TargetAttributes) Descriptor

func (ModifyTaskRequest_TargetAttributes) Enum

func (ModifyTaskRequest_TargetAttributes) EnumDescriptor deprecated

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

Deprecated: Use ModifyTaskRequest_TargetAttributes.Descriptor instead.

func (ModifyTaskRequest_TargetAttributes) Number

func (ModifyTaskRequest_TargetAttributes) String

func (ModifyTaskRequest_TargetAttributes) Type

type ModifyTaskRequest_TimeLimitSeconds

type ModifyTaskRequest_TimeLimitSeconds struct {
	TimeLimitSeconds int64 `protobuf:"varint,4,opt,name=time_limit_seconds,json=timeLimitSeconds,proto3,oneof"`
}

type ModifyUserReply

type ModifyUserReply struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason ErrCode `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyUserReply) Descriptor deprecated

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

Deprecated: Use ModifyUserReply.ProtoReflect.Descriptor instead.

func (*ModifyUserReply) GetOk

func (x *ModifyUserReply) GetOk() bool

func (*ModifyUserReply) GetReason

func (x *ModifyUserReply) GetReason() ErrCode

func (*ModifyUserReply) ProtoMessage

func (*ModifyUserReply) ProtoMessage()

func (*ModifyUserReply) ProtoReflect

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

func (*ModifyUserReply) Reset

func (x *ModifyUserReply) Reset()

func (*ModifyUserReply) String

func (x *ModifyUserReply) String() string

type ModifyUserRequest

type ModifyUserRequest struct {
	Uid         uint32        `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	ModifyField ModifyField   `protobuf:"varint,2,opt,name=modify_field,json=modifyField,proto3,enum=crane.grpc.ModifyField" json:"modify_field,omitempty"` //modify item field
	Value       string        `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`                                                             //new value
	Name        string        `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Partition   string        `protobuf:"bytes,5,opt,name=partition,proto3" json:"partition,omitempty"`
	Type        OperationType `protobuf:"varint,6,opt,name=type,proto3,enum=crane.grpc.OperationType" json:"type,omitempty"`
	Account     string        `protobuf:"bytes,8,opt,name=account,proto3" json:"account,omitempty"`
	Force       bool          `protobuf:"varint,9,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyUserRequest) Descriptor deprecated

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

Deprecated: Use ModifyUserRequest.ProtoReflect.Descriptor instead.

func (*ModifyUserRequest) GetAccount

func (x *ModifyUserRequest) GetAccount() string

func (*ModifyUserRequest) GetForce

func (x *ModifyUserRequest) GetForce() bool

func (*ModifyUserRequest) GetModifyField

func (x *ModifyUserRequest) GetModifyField() ModifyField

func (*ModifyUserRequest) GetName

func (x *ModifyUserRequest) GetName() string

func (*ModifyUserRequest) GetPartition

func (x *ModifyUserRequest) GetPartition() string

func (*ModifyUserRequest) GetType

func (x *ModifyUserRequest) GetType() OperationType

func (*ModifyUserRequest) GetUid

func (x *ModifyUserRequest) GetUid() uint32

func (*ModifyUserRequest) GetValue

func (x *ModifyUserRequest) GetValue() string

func (*ModifyUserRequest) ProtoMessage

func (*ModifyUserRequest) ProtoMessage()

func (*ModifyUserRequest) ProtoReflect

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

func (*ModifyUserRequest) Reset

func (x *ModifyUserRequest) Reset()

func (*ModifyUserRequest) String

func (x *ModifyUserRequest) String() string

type OperationType

type OperationType int32
const (
	OperationType_Overwrite OperationType = 0
	OperationType_Add       OperationType = 1
	OperationType_Delete    OperationType = 2
)

func (OperationType) Descriptor

func (OperationType) Enum

func (x OperationType) Enum() *OperationType

func (OperationType) EnumDescriptor deprecated

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

Deprecated: Use OperationType.Descriptor instead.

func (OperationType) Number

func (OperationType) String

func (x OperationType) String() string

func (OperationType) Type

type PartitionInfo

type PartitionInfo struct {
	Hostlist   string         `protobuf:"bytes,1,opt,name=hostlist,proto3" json:"hostlist,omitempty"`
	State      PartitionState `protobuf:"varint,2,opt,name=state,proto3,enum=crane.grpc.PartitionState" json:"state,omitempty"`
	Name       string         `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	TotalNodes uint32         `protobuf:"varint,4,opt,name=total_nodes,json=totalNodes,proto3" json:"total_nodes,omitempty"`
	AliveNodes uint32         `protobuf:"varint,5,opt,name=alive_nodes,json=aliveNodes,proto3" json:"alive_nodes,omitempty"`
	ResTotal   *ResourceView  `protobuf:"bytes,6,opt,name=res_total,json=resTotal,proto3" json:"res_total,omitempty"`
	ResAvail   *ResourceView  `protobuf:"bytes,7,opt,name=res_avail,json=resAvail,proto3" json:"res_avail,omitempty"`
	ResAlloc   *ResourceView  `protobuf:"bytes,8,opt,name=res_alloc,json=resAlloc,proto3" json:"res_alloc,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitionInfo) Descriptor deprecated

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

Deprecated: Use PartitionInfo.ProtoReflect.Descriptor instead.

func (*PartitionInfo) GetAliveNodes

func (x *PartitionInfo) GetAliveNodes() uint32

func (*PartitionInfo) GetHostlist

func (x *PartitionInfo) GetHostlist() string

func (*PartitionInfo) GetName

func (x *PartitionInfo) GetName() string

func (*PartitionInfo) GetResAlloc

func (x *PartitionInfo) GetResAlloc() *ResourceView

func (*PartitionInfo) GetResAvail

func (x *PartitionInfo) GetResAvail() *ResourceView

func (*PartitionInfo) GetResTotal

func (x *PartitionInfo) GetResTotal() *ResourceView

func (*PartitionInfo) GetState

func (x *PartitionInfo) GetState() PartitionState

func (*PartitionInfo) GetTotalNodes

func (x *PartitionInfo) GetTotalNodes() uint32

func (*PartitionInfo) ProtoMessage

func (*PartitionInfo) ProtoMessage()

func (*PartitionInfo) ProtoReflect

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

func (*PartitionInfo) Reset

func (x *PartitionInfo) Reset()

func (*PartitionInfo) String

func (x *PartitionInfo) String() string

type PartitionState

type PartitionState int32
const (
	PartitionState_PARTITION_UP   PartitionState = 0
	PartitionState_PARTITION_DOWN PartitionState = 1
)

func (PartitionState) Descriptor

func (PartitionState) Enum

func (x PartitionState) Enum() *PartitionState

func (PartitionState) EnumDescriptor deprecated

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

Deprecated: Use PartitionState.Descriptor instead.

func (PartitionState) Number

func (PartitionState) String

func (x PartitionState) String() string

func (PartitionState) Type

type QosInfo

type QosInfo struct {
	Name                string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description         string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Priority            uint32 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	MaxJobsPerUser      uint32 `protobuf:"varint,4,opt,name=max_jobs_per_user,json=maxJobsPerUser,proto3" json:"max_jobs_per_user,omitempty"`
	MaxCpusPerUser      uint32 `protobuf:"varint,5,opt,name=max_cpus_per_user,json=maxCpusPerUser,proto3" json:"max_cpus_per_user,omitempty"`
	MaxTimeLimitPerTask uint64 `protobuf:"varint,6,opt,name=max_time_limit_per_task,json=maxTimeLimitPerTask,proto3" json:"max_time_limit_per_task,omitempty"`
	// contains filtered or unexported fields
}

func (*QosInfo) Descriptor deprecated

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

Deprecated: Use QosInfo.ProtoReflect.Descriptor instead.

func (*QosInfo) GetDescription

func (x *QosInfo) GetDescription() string

func (*QosInfo) GetMaxCpusPerUser

func (x *QosInfo) GetMaxCpusPerUser() uint32

func (*QosInfo) GetMaxJobsPerUser

func (x *QosInfo) GetMaxJobsPerUser() uint32

func (*QosInfo) GetMaxTimeLimitPerTask

func (x *QosInfo) GetMaxTimeLimitPerTask() uint64

func (*QosInfo) GetName

func (x *QosInfo) GetName() string

func (*QosInfo) GetPriority

func (x *QosInfo) GetPriority() uint32

func (*QosInfo) ProtoMessage

func (*QosInfo) ProtoMessage()

func (*QosInfo) ProtoReflect

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

func (*QosInfo) Reset

func (x *QosInfo) Reset()

func (*QosInfo) String

func (x *QosInfo) String() string

type QueryAccountInfoReply

type QueryAccountInfoReply struct {
	Ok          bool           `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason      ErrCode        `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	AccountList []*AccountInfo `protobuf:"bytes,3,rep,name=account_list,json=accountList,proto3" json:"account_list,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryAccountInfoReply) Descriptor deprecated

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

Deprecated: Use QueryAccountInfoReply.ProtoReflect.Descriptor instead.

func (*QueryAccountInfoReply) GetAccountList

func (x *QueryAccountInfoReply) GetAccountList() []*AccountInfo

func (*QueryAccountInfoReply) GetOk

func (x *QueryAccountInfoReply) GetOk() bool

func (*QueryAccountInfoReply) GetReason

func (x *QueryAccountInfoReply) GetReason() ErrCode

func (*QueryAccountInfoReply) ProtoMessage

func (*QueryAccountInfoReply) ProtoMessage()

func (*QueryAccountInfoReply) ProtoReflect

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

func (*QueryAccountInfoReply) Reset

func (x *QueryAccountInfoReply) Reset()

func (*QueryAccountInfoReply) String

func (x *QueryAccountInfoReply) String() string

type QueryAccountInfoRequest

type QueryAccountInfoRequest struct {
	Uid  uint32 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryAccountInfoRequest) Descriptor deprecated

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

Deprecated: Use QueryAccountInfoRequest.ProtoReflect.Descriptor instead.

func (*QueryAccountInfoRequest) GetName

func (x *QueryAccountInfoRequest) GetName() string

func (*QueryAccountInfoRequest) GetUid

func (x *QueryAccountInfoRequest) GetUid() uint32

func (*QueryAccountInfoRequest) ProtoMessage

func (*QueryAccountInfoRequest) ProtoMessage()

func (*QueryAccountInfoRequest) ProtoReflect

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

func (*QueryAccountInfoRequest) Reset

func (x *QueryAccountInfoRequest) Reset()

func (*QueryAccountInfoRequest) String

func (x *QueryAccountInfoRequest) String() string

type QueryClusterInfoReply

type QueryClusterInfoReply struct {
	Ok         bool                    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Partitions []*TrimmedPartitionInfo `protobuf:"bytes,2,rep,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryClusterInfoReply) Descriptor deprecated

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

Deprecated: Use QueryClusterInfoReply.ProtoReflect.Descriptor instead.

func (*QueryClusterInfoReply) GetOk

func (x *QueryClusterInfoReply) GetOk() bool

func (*QueryClusterInfoReply) GetPartitions

func (x *QueryClusterInfoReply) GetPartitions() []*TrimmedPartitionInfo

func (*QueryClusterInfoReply) ProtoMessage

func (*QueryClusterInfoReply) ProtoMessage()

func (*QueryClusterInfoReply) ProtoReflect

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

func (*QueryClusterInfoReply) Reset

func (x *QueryClusterInfoReply) Reset()

func (*QueryClusterInfoReply) String

func (x *QueryClusterInfoReply) String() string

type QueryClusterInfoRequest

type QueryClusterInfoRequest struct {
	FilterPartitions           []string              `protobuf:"bytes,1,rep,name=filter_partitions,json=filterPartitions,proto3" json:"filter_partitions,omitempty"`
	FilterNodes                []string              `protobuf:"bytes,2,rep,name=filter_nodes,json=filterNodes,proto3" json:"filter_nodes,omitempty"`
	FilterCranedResourceStates []CranedResourceState `` /* 187-byte string literal not displayed */
	FilterCranedControlStates  []CranedControlState  `` /* 183-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*QueryClusterInfoRequest) Descriptor deprecated

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

Deprecated: Use QueryClusterInfoRequest.ProtoReflect.Descriptor instead.

func (*QueryClusterInfoRequest) GetFilterCranedControlStates

func (x *QueryClusterInfoRequest) GetFilterCranedControlStates() []CranedControlState

func (*QueryClusterInfoRequest) GetFilterCranedResourceStates

func (x *QueryClusterInfoRequest) GetFilterCranedResourceStates() []CranedResourceState

func (*QueryClusterInfoRequest) GetFilterNodes

func (x *QueryClusterInfoRequest) GetFilterNodes() []string

func (*QueryClusterInfoRequest) GetFilterPartitions

func (x *QueryClusterInfoRequest) GetFilterPartitions() []string

func (*QueryClusterInfoRequest) ProtoMessage

func (*QueryClusterInfoRequest) ProtoMessage()

func (*QueryClusterInfoRequest) ProtoReflect

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

func (*QueryClusterInfoRequest) Reset

func (x *QueryClusterInfoRequest) Reset()

func (*QueryClusterInfoRequest) String

func (x *QueryClusterInfoRequest) String() string

type QueryCranedInfoReply

type QueryCranedInfoReply struct {
	CranedInfoList []*CranedInfo `protobuf:"bytes,1,rep,name=craned_info_list,json=cranedInfoList,proto3" json:"craned_info_list,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryCranedInfoReply) Descriptor deprecated

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

Deprecated: Use QueryCranedInfoReply.ProtoReflect.Descriptor instead.

func (*QueryCranedInfoReply) GetCranedInfoList

func (x *QueryCranedInfoReply) GetCranedInfoList() []*CranedInfo

func (*QueryCranedInfoReply) ProtoMessage

func (*QueryCranedInfoReply) ProtoMessage()

func (*QueryCranedInfoReply) ProtoReflect

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

func (*QueryCranedInfoReply) Reset

func (x *QueryCranedInfoReply) Reset()

func (*QueryCranedInfoReply) String

func (x *QueryCranedInfoReply) String() string

type QueryCranedInfoRequest

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

func (*QueryCranedInfoRequest) Descriptor deprecated

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

Deprecated: Use QueryCranedInfoRequest.ProtoReflect.Descriptor instead.

func (*QueryCranedInfoRequest) GetCranedName

func (x *QueryCranedInfoRequest) GetCranedName() string

func (*QueryCranedInfoRequest) ProtoMessage

func (*QueryCranedInfoRequest) ProtoMessage()

func (*QueryCranedInfoRequest) ProtoReflect

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

func (*QueryCranedInfoRequest) Reset

func (x *QueryCranedInfoRequest) Reset()

func (*QueryCranedInfoRequest) String

func (x *QueryCranedInfoRequest) String() string

type QueryCranedListFromTaskIdReply

type QueryCranedListFromTaskIdReply struct {
	Ok         bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	CranedList string `protobuf:"bytes,2,opt,name=craned_list,json=cranedList,proto3" json:"craned_list,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryCranedListFromTaskIdReply) Descriptor deprecated

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

Deprecated: Use QueryCranedListFromTaskIdReply.ProtoReflect.Descriptor instead.

func (*QueryCranedListFromTaskIdReply) GetCranedList

func (x *QueryCranedListFromTaskIdReply) GetCranedList() string

func (*QueryCranedListFromTaskIdReply) GetOk

func (*QueryCranedListFromTaskIdReply) ProtoMessage

func (*QueryCranedListFromTaskIdReply) ProtoMessage()

func (*QueryCranedListFromTaskIdReply) ProtoReflect

func (*QueryCranedListFromTaskIdReply) Reset

func (x *QueryCranedListFromTaskIdReply) Reset()

func (*QueryCranedListFromTaskIdReply) String

type QueryCranedListFromTaskIdRequest

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

func (*QueryCranedListFromTaskIdRequest) Descriptor deprecated

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

Deprecated: Use QueryCranedListFromTaskIdRequest.ProtoReflect.Descriptor instead.

func (*QueryCranedListFromTaskIdRequest) GetTaskId

func (*QueryCranedListFromTaskIdRequest) ProtoMessage

func (*QueryCranedListFromTaskIdRequest) ProtoMessage()

func (*QueryCranedListFromTaskIdRequest) ProtoReflect

func (*QueryCranedListFromTaskIdRequest) Reset

func (*QueryCranedListFromTaskIdRequest) String

type QueryCranedRemoteMetaReply

type QueryCranedRemoteMetaReply struct {
	Ok               bool              `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	CranedRemoteMeta *CranedRemoteMeta `protobuf:"bytes,2,opt,name=craned_remote_meta,json=cranedRemoteMeta,proto3" json:"craned_remote_meta,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryCranedRemoteMetaReply) Descriptor deprecated

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

Deprecated: Use QueryCranedRemoteMetaReply.ProtoReflect.Descriptor instead.

func (*QueryCranedRemoteMetaReply) GetCranedRemoteMeta

func (x *QueryCranedRemoteMetaReply) GetCranedRemoteMeta() *CranedRemoteMeta

func (*QueryCranedRemoteMetaReply) GetOk

func (x *QueryCranedRemoteMetaReply) GetOk() bool

func (*QueryCranedRemoteMetaReply) ProtoMessage

func (*QueryCranedRemoteMetaReply) ProtoMessage()

func (*QueryCranedRemoteMetaReply) ProtoReflect

func (*QueryCranedRemoteMetaReply) Reset

func (x *QueryCranedRemoteMetaReply) Reset()

func (*QueryCranedRemoteMetaReply) String

func (x *QueryCranedRemoteMetaReply) String() string

type QueryCranedRemoteMetaRequest

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

func (*QueryCranedRemoteMetaRequest) Descriptor deprecated

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

Deprecated: Use QueryCranedRemoteMetaRequest.ProtoReflect.Descriptor instead.

func (*QueryCranedRemoteMetaRequest) ProtoMessage

func (*QueryCranedRemoteMetaRequest) ProtoMessage()

func (*QueryCranedRemoteMetaRequest) ProtoReflect

func (*QueryCranedRemoteMetaRequest) Reset

func (x *QueryCranedRemoteMetaRequest) Reset()

func (*QueryCranedRemoteMetaRequest) String

type QueryPartitionInfoReply

type QueryPartitionInfoReply struct {
	PartitionInfo []*PartitionInfo `protobuf:"bytes,1,rep,name=partition_info,json=partitionInfo,proto3" json:"partition_info,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryPartitionInfoReply) Descriptor deprecated

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

Deprecated: Use QueryPartitionInfoReply.ProtoReflect.Descriptor instead.

func (*QueryPartitionInfoReply) GetPartitionInfo

func (x *QueryPartitionInfoReply) GetPartitionInfo() []*PartitionInfo

func (*QueryPartitionInfoReply) ProtoMessage

func (*QueryPartitionInfoReply) ProtoMessage()

func (*QueryPartitionInfoReply) ProtoReflect

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

func (*QueryPartitionInfoReply) Reset

func (x *QueryPartitionInfoReply) Reset()

func (*QueryPartitionInfoReply) String

func (x *QueryPartitionInfoReply) String() string

type QueryPartitionInfoRequest

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

func (*QueryPartitionInfoRequest) Descriptor deprecated

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

Deprecated: Use QueryPartitionInfoRequest.ProtoReflect.Descriptor instead.

func (*QueryPartitionInfoRequest) GetPartitionName

func (x *QueryPartitionInfoRequest) GetPartitionName() string

func (*QueryPartitionInfoRequest) ProtoMessage

func (*QueryPartitionInfoRequest) ProtoMessage()

func (*QueryPartitionInfoRequest) ProtoReflect

func (*QueryPartitionInfoRequest) Reset

func (x *QueryPartitionInfoRequest) Reset()

func (*QueryPartitionInfoRequest) String

func (x *QueryPartitionInfoRequest) String() string

type QueryQosInfoReply

type QueryQosInfoReply struct {
	Ok      bool       `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason  ErrCode    `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	QosList []*QosInfo `protobuf:"bytes,5,rep,name=qos_list,json=qosList,proto3" json:"qos_list,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryQosInfoReply) Descriptor deprecated

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

Deprecated: Use QueryQosInfoReply.ProtoReflect.Descriptor instead.

func (*QueryQosInfoReply) GetOk

func (x *QueryQosInfoReply) GetOk() bool

func (*QueryQosInfoReply) GetQosList

func (x *QueryQosInfoReply) GetQosList() []*QosInfo

func (*QueryQosInfoReply) GetReason

func (x *QueryQosInfoReply) GetReason() ErrCode

func (*QueryQosInfoReply) ProtoMessage

func (*QueryQosInfoReply) ProtoMessage()

func (*QueryQosInfoReply) ProtoReflect

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

func (*QueryQosInfoReply) Reset

func (x *QueryQosInfoReply) Reset()

func (*QueryQosInfoReply) String

func (x *QueryQosInfoReply) String() string

type QueryQosInfoRequest

type QueryQosInfoRequest struct {
	Uid  uint32 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryQosInfoRequest) Descriptor deprecated

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

Deprecated: Use QueryQosInfoRequest.ProtoReflect.Descriptor instead.

func (*QueryQosInfoRequest) GetName

func (x *QueryQosInfoRequest) GetName() string

func (*QueryQosInfoRequest) GetUid

func (x *QueryQosInfoRequest) GetUid() uint32

func (*QueryQosInfoRequest) ProtoMessage

func (*QueryQosInfoRequest) ProtoMessage()

func (*QueryQosInfoRequest) ProtoReflect

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

func (*QueryQosInfoRequest) Reset

func (x *QueryQosInfoRequest) Reset()

func (*QueryQosInfoRequest) String

func (x *QueryQosInfoRequest) String() string

type QueryTaskEnvVariablesForwardReply

type QueryTaskEnvVariablesForwardReply struct {
	Ok     bool              `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	EnvMap map[string]string `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*QueryTaskEnvVariablesForwardReply) Descriptor deprecated

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

Deprecated: Use QueryTaskEnvVariablesForwardReply.ProtoReflect.Descriptor instead.

func (*QueryTaskEnvVariablesForwardReply) GetEnvMap

func (x *QueryTaskEnvVariablesForwardReply) GetEnvMap() map[string]string

func (*QueryTaskEnvVariablesForwardReply) GetOk

func (*QueryTaskEnvVariablesForwardReply) ProtoMessage

func (*QueryTaskEnvVariablesForwardReply) ProtoMessage()

func (*QueryTaskEnvVariablesForwardReply) ProtoReflect

func (*QueryTaskEnvVariablesForwardReply) Reset

func (*QueryTaskEnvVariablesForwardReply) String

type QueryTaskEnvVariablesForwardRequest

type QueryTaskEnvVariablesForwardRequest struct {
	TaskId        uint32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ExecutionNode string `protobuf:"bytes,2,opt,name=execution_node,json=executionNode,proto3" json:"execution_node,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryTaskEnvVariablesForwardRequest) Descriptor deprecated

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

Deprecated: Use QueryTaskEnvVariablesForwardRequest.ProtoReflect.Descriptor instead.

func (*QueryTaskEnvVariablesForwardRequest) GetExecutionNode

func (x *QueryTaskEnvVariablesForwardRequest) GetExecutionNode() string

func (*QueryTaskEnvVariablesForwardRequest) GetTaskId

func (*QueryTaskEnvVariablesForwardRequest) ProtoMessage

func (*QueryTaskEnvVariablesForwardRequest) ProtoMessage()

func (*QueryTaskEnvVariablesForwardRequest) ProtoReflect

func (*QueryTaskEnvVariablesForwardRequest) Reset

func (*QueryTaskEnvVariablesForwardRequest) String

type QueryTaskEnvVariablesReply

type QueryTaskEnvVariablesReply struct {
	Ok     bool              `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	EnvMap map[string]string `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*QueryTaskEnvVariablesReply) Descriptor deprecated

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

Deprecated: Use QueryTaskEnvVariablesReply.ProtoReflect.Descriptor instead.

func (*QueryTaskEnvVariablesReply) GetEnvMap

func (x *QueryTaskEnvVariablesReply) GetEnvMap() map[string]string

func (*QueryTaskEnvVariablesReply) GetOk

func (x *QueryTaskEnvVariablesReply) GetOk() bool

func (*QueryTaskEnvVariablesReply) ProtoMessage

func (*QueryTaskEnvVariablesReply) ProtoMessage()

func (*QueryTaskEnvVariablesReply) ProtoReflect

func (*QueryTaskEnvVariablesReply) Reset

func (x *QueryTaskEnvVariablesReply) Reset()

func (*QueryTaskEnvVariablesReply) String

func (x *QueryTaskEnvVariablesReply) String() string

type QueryTaskEnvVariablesRequest

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

func (*QueryTaskEnvVariablesRequest) Descriptor deprecated

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

Deprecated: Use QueryTaskEnvVariablesRequest.ProtoReflect.Descriptor instead.

func (*QueryTaskEnvVariablesRequest) GetTaskId

func (x *QueryTaskEnvVariablesRequest) GetTaskId() uint32

func (*QueryTaskEnvVariablesRequest) ProtoMessage

func (*QueryTaskEnvVariablesRequest) ProtoMessage()

func (*QueryTaskEnvVariablesRequest) ProtoReflect

func (*QueryTaskEnvVariablesRequest) Reset

func (x *QueryTaskEnvVariablesRequest) Reset()

func (*QueryTaskEnvVariablesRequest) String

type QueryTaskIdFromPortForwardReply

type QueryTaskIdFromPortForwardReply struct {
	Ok         bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	FromUser   bool   `protobuf:"varint,2,opt,name=from_user,json=fromUser,proto3" json:"from_user,omitempty"`
	TaskId     uint32 `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	CgroupPath string `protobuf:"bytes,4,opt,name=cgroup_path,json=cgroupPath,proto3" json:"cgroup_path,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryTaskIdFromPortForwardReply) Descriptor deprecated

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

Deprecated: Use QueryTaskIdFromPortForwardReply.ProtoReflect.Descriptor instead.

func (*QueryTaskIdFromPortForwardReply) GetCgroupPath

func (x *QueryTaskIdFromPortForwardReply) GetCgroupPath() string

func (*QueryTaskIdFromPortForwardReply) GetFromUser

func (x *QueryTaskIdFromPortForwardReply) GetFromUser() bool

func (*QueryTaskIdFromPortForwardReply) GetOk

func (*QueryTaskIdFromPortForwardReply) GetTaskId

func (x *QueryTaskIdFromPortForwardReply) GetTaskId() uint32

func (*QueryTaskIdFromPortForwardReply) ProtoMessage

func (*QueryTaskIdFromPortForwardReply) ProtoMessage()

func (*QueryTaskIdFromPortForwardReply) ProtoReflect

func (*QueryTaskIdFromPortForwardReply) Reset

func (*QueryTaskIdFromPortForwardReply) String

type QueryTaskIdFromPortForwardRequest

type QueryTaskIdFromPortForwardRequest struct {
	SshRemotePort    uint32 `protobuf:"varint,1,opt,name=ssh_remote_port,json=sshRemotePort,proto3" json:"ssh_remote_port,omitempty"`
	SshRemoteAddress string `protobuf:"bytes,2,opt,name=ssh_remote_address,json=sshRemoteAddress,proto3" json:"ssh_remote_address,omitempty"`
	Uid              uint32 `protobuf:"varint,3,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryTaskIdFromPortForwardRequest) Descriptor deprecated

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

Deprecated: Use QueryTaskIdFromPortForwardRequest.ProtoReflect.Descriptor instead.

func (*QueryTaskIdFromPortForwardRequest) GetSshRemoteAddress

func (x *QueryTaskIdFromPortForwardRequest) GetSshRemoteAddress() string

func (*QueryTaskIdFromPortForwardRequest) GetSshRemotePort

func (x *QueryTaskIdFromPortForwardRequest) GetSshRemotePort() uint32

func (*QueryTaskIdFromPortForwardRequest) GetUid

func (*QueryTaskIdFromPortForwardRequest) ProtoMessage

func (*QueryTaskIdFromPortForwardRequest) ProtoMessage()

func (*QueryTaskIdFromPortForwardRequest) ProtoReflect

func (*QueryTaskIdFromPortForwardRequest) Reset

func (*QueryTaskIdFromPortForwardRequest) String

type QueryTaskIdFromPortReply

type QueryTaskIdFromPortReply struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	TaskId uint32 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryTaskIdFromPortReply) Descriptor deprecated

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

Deprecated: Use QueryTaskIdFromPortReply.ProtoReflect.Descriptor instead.

func (*QueryTaskIdFromPortReply) GetOk

func (x *QueryTaskIdFromPortReply) GetOk() bool

func (*QueryTaskIdFromPortReply) GetTaskId

func (x *QueryTaskIdFromPortReply) GetTaskId() uint32

func (*QueryTaskIdFromPortReply) ProtoMessage

func (*QueryTaskIdFromPortReply) ProtoMessage()

func (*QueryTaskIdFromPortReply) ProtoReflect

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

func (*QueryTaskIdFromPortReply) Reset

func (x *QueryTaskIdFromPortReply) Reset()

func (*QueryTaskIdFromPortReply) String

func (x *QueryTaskIdFromPortReply) String() string

type QueryTaskIdFromPortRequest

type QueryTaskIdFromPortRequest struct {
	Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryTaskIdFromPortRequest) Descriptor deprecated

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

Deprecated: Use QueryTaskIdFromPortRequest.ProtoReflect.Descriptor instead.

func (*QueryTaskIdFromPortRequest) GetPort

func (x *QueryTaskIdFromPortRequest) GetPort() uint32

func (*QueryTaskIdFromPortRequest) ProtoMessage

func (*QueryTaskIdFromPortRequest) ProtoMessage()

func (*QueryTaskIdFromPortRequest) ProtoReflect

func (*QueryTaskIdFromPortRequest) Reset

func (x *QueryTaskIdFromPortRequest) Reset()

func (*QueryTaskIdFromPortRequest) String

func (x *QueryTaskIdFromPortRequest) String() string

type QueryTasksInfoReply

type QueryTasksInfoReply struct {
	Ok           bool        `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	TaskInfoList []*TaskInfo `protobuf:"bytes,2,rep,name=task_info_list,json=taskInfoList,proto3" json:"task_info_list,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryTasksInfoReply) Descriptor deprecated

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

Deprecated: Use QueryTasksInfoReply.ProtoReflect.Descriptor instead.

func (*QueryTasksInfoReply) GetOk

func (x *QueryTasksInfoReply) GetOk() bool

func (*QueryTasksInfoReply) GetTaskInfoList

func (x *QueryTasksInfoReply) GetTaskInfoList() []*TaskInfo

func (*QueryTasksInfoReply) ProtoMessage

func (*QueryTasksInfoReply) ProtoMessage()

func (*QueryTasksInfoReply) ProtoReflect

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

func (*QueryTasksInfoReply) Reset

func (x *QueryTasksInfoReply) Reset()

func (*QueryTasksInfoReply) String

func (x *QueryTasksInfoReply) String() string

type QueryTasksInfoRequest

type QueryTasksInfoRequest struct {
	FilterTaskIds               []uint32      `protobuf:"varint,1,rep,packed,name=filter_task_ids,json=filterTaskIds,proto3" json:"filter_task_ids,omitempty"`
	FilterPartitions            []string      `protobuf:"bytes,2,rep,name=filter_partitions,json=filterPartitions,proto3" json:"filter_partitions,omitempty"`
	NumLimit                    uint32        `protobuf:"varint,3,opt,name=num_limit,json=numLimit,proto3" json:"num_limit,omitempty"`
	FilterTaskNames             []string      `protobuf:"bytes,4,rep,name=filter_task_names,json=filterTaskNames,proto3" json:"filter_task_names,omitempty"`
	FilterQos                   []string      `protobuf:"bytes,5,rep,name=filter_qos,json=filterQos,proto3" json:"filter_qos,omitempty"`
	FilterTaskStates            []TaskStatus  `` /* 146-byte string literal not displayed */
	FilterUsers                 []string      `protobuf:"bytes,7,rep,name=filter_users,json=filterUsers,proto3" json:"filter_users,omitempty"`
	FilterAccounts              []string      `protobuf:"bytes,8,rep,name=filter_accounts,json=filterAccounts,proto3" json:"filter_accounts,omitempty"`
	FilterSubmitTimeInterval    *TimeInterval `` /* 137-byte string literal not displayed */
	FilterStartTimeInterval     *TimeInterval `` /* 135-byte string literal not displayed */
	FilterEndTimeInterval       *TimeInterval `` /* 129-byte string literal not displayed */
	OptionIncludeCompletedTasks bool          `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*QueryTasksInfoRequest) Descriptor deprecated

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

Deprecated: Use QueryTasksInfoRequest.ProtoReflect.Descriptor instead.

func (*QueryTasksInfoRequest) GetFilterAccounts

func (x *QueryTasksInfoRequest) GetFilterAccounts() []string

func (*QueryTasksInfoRequest) GetFilterEndTimeInterval

func (x *QueryTasksInfoRequest) GetFilterEndTimeInterval() *TimeInterval

func (*QueryTasksInfoRequest) GetFilterPartitions

func (x *QueryTasksInfoRequest) GetFilterPartitions() []string

func (*QueryTasksInfoRequest) GetFilterQos

func (x *QueryTasksInfoRequest) GetFilterQos() []string

func (*QueryTasksInfoRequest) GetFilterStartTimeInterval

func (x *QueryTasksInfoRequest) GetFilterStartTimeInterval() *TimeInterval

func (*QueryTasksInfoRequest) GetFilterSubmitTimeInterval

func (x *QueryTasksInfoRequest) GetFilterSubmitTimeInterval() *TimeInterval

func (*QueryTasksInfoRequest) GetFilterTaskIds

func (x *QueryTasksInfoRequest) GetFilterTaskIds() []uint32

func (*QueryTasksInfoRequest) GetFilterTaskNames

func (x *QueryTasksInfoRequest) GetFilterTaskNames() []string

func (*QueryTasksInfoRequest) GetFilterTaskStates

func (x *QueryTasksInfoRequest) GetFilterTaskStates() []TaskStatus

func (*QueryTasksInfoRequest) GetFilterUsers

func (x *QueryTasksInfoRequest) GetFilterUsers() []string

func (*QueryTasksInfoRequest) GetNumLimit

func (x *QueryTasksInfoRequest) GetNumLimit() uint32

func (*QueryTasksInfoRequest) GetOptionIncludeCompletedTasks

func (x *QueryTasksInfoRequest) GetOptionIncludeCompletedTasks() bool

func (*QueryTasksInfoRequest) ProtoMessage

func (*QueryTasksInfoRequest) ProtoMessage()

func (*QueryTasksInfoRequest) ProtoReflect

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

func (*QueryTasksInfoRequest) Reset

func (x *QueryTasksInfoRequest) Reset()

func (*QueryTasksInfoRequest) String

func (x *QueryTasksInfoRequest) String() string

type QueryUserInfoReply

type QueryUserInfoReply struct {
	Ok       bool        `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason   ErrCode     `protobuf:"varint,2,opt,name=reason,proto3,enum=crane.grpc.ErrCode" json:"reason,omitempty"`
	UserList []*UserInfo `protobuf:"bytes,3,rep,name=user_list,json=userList,proto3" json:"user_list,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryUserInfoReply) Descriptor deprecated

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

Deprecated: Use QueryUserInfoReply.ProtoReflect.Descriptor instead.

func (*QueryUserInfoReply) GetOk

func (x *QueryUserInfoReply) GetOk() bool

func (*QueryUserInfoReply) GetReason

func (x *QueryUserInfoReply) GetReason() ErrCode

func (*QueryUserInfoReply) GetUserList

func (x *QueryUserInfoReply) GetUserList() []*UserInfo

func (*QueryUserInfoReply) ProtoMessage

func (*QueryUserInfoReply) ProtoMessage()

func (*QueryUserInfoReply) ProtoReflect

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

func (*QueryUserInfoReply) Reset

func (x *QueryUserInfoReply) Reset()

func (*QueryUserInfoReply) String

func (x *QueryUserInfoReply) String() string

type QueryUserInfoRequest

type QueryUserInfoRequest struct {
	Uid     uint32 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Account string `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryUserInfoRequest) Descriptor deprecated

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

Deprecated: Use QueryUserInfoRequest.ProtoReflect.Descriptor instead.

func (*QueryUserInfoRequest) GetAccount

func (x *QueryUserInfoRequest) GetAccount() string

func (*QueryUserInfoRequest) GetName

func (x *QueryUserInfoRequest) GetName() string

func (*QueryUserInfoRequest) GetUid

func (x *QueryUserInfoRequest) GetUid() uint32

func (*QueryUserInfoRequest) ProtoMessage

func (*QueryUserInfoRequest) ProtoMessage()

func (*QueryUserInfoRequest) ProtoReflect

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

func (*QueryUserInfoRequest) Reset

func (x *QueryUserInfoRequest) Reset()

func (*QueryUserInfoRequest) String

func (x *QueryUserInfoRequest) String() string

type ReleaseCgroupForTasksReply

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

func (*ReleaseCgroupForTasksReply) Descriptor deprecated

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

Deprecated: Use ReleaseCgroupForTasksReply.ProtoReflect.Descriptor instead.

func (*ReleaseCgroupForTasksReply) ProtoMessage

func (*ReleaseCgroupForTasksReply) ProtoMessage()

func (*ReleaseCgroupForTasksReply) ProtoReflect

func (*ReleaseCgroupForTasksReply) Reset

func (x *ReleaseCgroupForTasksReply) Reset()

func (*ReleaseCgroupForTasksReply) String

func (x *ReleaseCgroupForTasksReply) String() string

type ReleaseCgroupForTasksRequest

type ReleaseCgroupForTasksRequest struct {
	TaskIdList []uint32 `protobuf:"varint,1,rep,packed,name=task_id_list,json=taskIdList,proto3" json:"task_id_list,omitempty"`
	UidList    []uint32 `protobuf:"varint,2,rep,packed,name=uid_list,json=uidList,proto3" json:"uid_list,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseCgroupForTasksRequest) Descriptor deprecated

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

Deprecated: Use ReleaseCgroupForTasksRequest.ProtoReflect.Descriptor instead.

func (*ReleaseCgroupForTasksRequest) GetTaskIdList

func (x *ReleaseCgroupForTasksRequest) GetTaskIdList() []uint32

func (*ReleaseCgroupForTasksRequest) GetUidList

func (x *ReleaseCgroupForTasksRequest) GetUidList() []uint32

func (*ReleaseCgroupForTasksRequest) ProtoMessage

func (*ReleaseCgroupForTasksRequest) ProtoMessage()

func (*ReleaseCgroupForTasksRequest) ProtoReflect

func (*ReleaseCgroupForTasksRequest) Reset

func (x *ReleaseCgroupForTasksRequest) Reset()

func (*ReleaseCgroupForTasksRequest) String

type ResourceInNode

type ResourceInNode struct {
	AllocatableResInNode *AllocatableResource     `protobuf:"bytes,1,opt,name=allocatable_res_in_node,json=allocatableResInNode,proto3" json:"allocatable_res_in_node,omitempty"`
	DedicatedResInNode   *DedicatedResourceInNode `protobuf:"bytes,2,opt,name=dedicated_res_in_node,json=dedicatedResInNode,proto3" json:"dedicated_res_in_node,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceInNode) Descriptor deprecated

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

Deprecated: Use ResourceInNode.ProtoReflect.Descriptor instead.

func (*ResourceInNode) GetAllocatableResInNode

func (x *ResourceInNode) GetAllocatableResInNode() *AllocatableResource

func (*ResourceInNode) GetDedicatedResInNode

func (x *ResourceInNode) GetDedicatedResInNode() *DedicatedResourceInNode

func (*ResourceInNode) ProtoMessage

func (*ResourceInNode) ProtoMessage()

func (*ResourceInNode) ProtoReflect

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

func (*ResourceInNode) Reset

func (x *ResourceInNode) Reset()

func (*ResourceInNode) String

func (x *ResourceInNode) String() string

type ResourceV2

type ResourceV2 struct {
	EachNodeRes map[string]*ResourceInNode `` /* 184-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResourceV2) Descriptor deprecated

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

Deprecated: Use ResourceV2.ProtoReflect.Descriptor instead.

func (*ResourceV2) GetEachNodeRes

func (x *ResourceV2) GetEachNodeRes() map[string]*ResourceInNode

func (*ResourceV2) ProtoMessage

func (*ResourceV2) ProtoMessage()

func (*ResourceV2) ProtoReflect

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

func (*ResourceV2) Reset

func (x *ResourceV2) Reset()

func (*ResourceV2) String

func (x *ResourceV2) String() string

type ResourceView

type ResourceView struct {
	AllocatableRes *AllocatableResource `protobuf:"bytes,1,opt,name=allocatable_res,json=allocatableRes,proto3" json:"allocatable_res,omitempty"`
	DeviceMap      *DeviceMap           `protobuf:"bytes,2,opt,name=device_map,json=deviceMap,proto3" json:"device_map,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceView) Descriptor deprecated

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

Deprecated: Use ResourceView.ProtoReflect.Descriptor instead.

func (*ResourceView) GetAllocatableRes

func (x *ResourceView) GetAllocatableRes() *AllocatableResource

func (*ResourceView) GetDeviceMap

func (x *ResourceView) GetDeviceMap() *DeviceMap

func (*ResourceView) ProtoMessage

func (*ResourceView) ProtoMessage()

func (*ResourceView) ProtoReflect

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

func (*ResourceView) Reset

func (x *ResourceView) Reset()

func (*ResourceView) String

func (x *ResourceView) String() string

type RuntimeAttrOfTask

type RuntimeAttrOfTask struct {

	// Fields that won't change after this task is accepted.
	TaskId   uint32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TaskDbId int64  `protobuf:"varint,3,opt,name=task_db_id,json=taskDbId,proto3" json:"task_db_id,omitempty"`
	Username string `protobuf:"bytes,5,opt,name=username,proto3" json:"username,omitempty"`
	// Fields that will change after this task is accepted.
	RequeueCount int32                  `protobuf:"varint,11,opt,name=requeue_count,json=requeueCount,proto3" json:"requeue_count,omitempty"`
	CranedIds    []string               `protobuf:"bytes,12,rep,name=craned_ids,json=cranedIds,proto3" json:"craned_ids,omitempty"`
	Status       TaskStatus             `protobuf:"varint,13,opt,name=status,proto3,enum=crane.grpc.TaskStatus" json:"status,omitempty"`
	ExitCode     uint32                 `protobuf:"varint,14,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	SubmitTime   *timestamppb.Timestamp `protobuf:"bytes,15,opt,name=submit_time,json=submitTime,proto3" json:"submit_time,omitempty"`
	StartTime    *timestamppb.Timestamp `protobuf:"bytes,16,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime      *timestamppb.Timestamp `protobuf:"bytes,17,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Held         bool                   `protobuf:"varint,18,opt,name=held,proto3" json:"held,omitempty"`
	Resources    *ResourceV2            `protobuf:"bytes,19,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeAttrOfTask) Descriptor deprecated

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

Deprecated: Use RuntimeAttrOfTask.ProtoReflect.Descriptor instead.

func (*RuntimeAttrOfTask) GetCranedIds

func (x *RuntimeAttrOfTask) GetCranedIds() []string

func (*RuntimeAttrOfTask) GetEndTime

func (x *RuntimeAttrOfTask) GetEndTime() *timestamppb.Timestamp

func (*RuntimeAttrOfTask) GetExitCode

func (x *RuntimeAttrOfTask) GetExitCode() uint32

func (*RuntimeAttrOfTask) GetHeld

func (x *RuntimeAttrOfTask) GetHeld() bool

func (*RuntimeAttrOfTask) GetRequeueCount

func (x *RuntimeAttrOfTask) GetRequeueCount() int32

func (*RuntimeAttrOfTask) GetResources

func (x *RuntimeAttrOfTask) GetResources() *ResourceV2

func (*RuntimeAttrOfTask) GetStartTime

func (x *RuntimeAttrOfTask) GetStartTime() *timestamppb.Timestamp

func (*RuntimeAttrOfTask) GetStatus

func (x *RuntimeAttrOfTask) GetStatus() TaskStatus

func (*RuntimeAttrOfTask) GetSubmitTime

func (x *RuntimeAttrOfTask) GetSubmitTime() *timestamppb.Timestamp

func (*RuntimeAttrOfTask) GetTaskDbId

func (x *RuntimeAttrOfTask) GetTaskDbId() int64

func (*RuntimeAttrOfTask) GetTaskId

func (x *RuntimeAttrOfTask) GetTaskId() uint32

func (*RuntimeAttrOfTask) GetUsername

func (x *RuntimeAttrOfTask) GetUsername() string

func (*RuntimeAttrOfTask) ProtoMessage

func (*RuntimeAttrOfTask) ProtoMessage()

func (*RuntimeAttrOfTask) ProtoReflect

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

func (*RuntimeAttrOfTask) Reset

func (x *RuntimeAttrOfTask) Reset()

func (*RuntimeAttrOfTask) String

func (x *RuntimeAttrOfTask) String() string

type Slots

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

func (*Slots) Descriptor deprecated

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

Deprecated: Use Slots.ProtoReflect.Descriptor instead.

func (*Slots) GetSlots

func (x *Slots) GetSlots() []string

func (*Slots) ProtoMessage

func (*Slots) ProtoMessage()

func (*Slots) ProtoReflect

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

func (*Slots) Reset

func (x *Slots) Reset()

func (*Slots) String

func (x *Slots) String() string

type StartHookReply

type StartHookReply struct {
	Result []*StartHookReply_TaskIdReply `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*StartHookReply) Descriptor deprecated

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

Deprecated: Use StartHookReply.ProtoReflect.Descriptor instead.

func (*StartHookReply) GetResult

func (x *StartHookReply) GetResult() []*StartHookReply_TaskIdReply

func (*StartHookReply) ProtoMessage

func (*StartHookReply) ProtoMessage()

func (*StartHookReply) ProtoReflect

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

func (*StartHookReply) Reset

func (x *StartHookReply) Reset()

func (*StartHookReply) String

func (x *StartHookReply) String() string

type StartHookReply_TaskIdReply

type StartHookReply_TaskIdReply struct {
	Ok            bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	TaskId        uint32 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	FailureReason string `protobuf:"bytes,3,opt,name=failure_reason,json=failureReason,proto3" json:"failure_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*StartHookReply_TaskIdReply) Descriptor deprecated

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

Deprecated: Use StartHookReply_TaskIdReply.ProtoReflect.Descriptor instead.

func (*StartHookReply_TaskIdReply) GetFailureReason

func (x *StartHookReply_TaskIdReply) GetFailureReason() string

func (*StartHookReply_TaskIdReply) GetOk

func (x *StartHookReply_TaskIdReply) GetOk() bool

func (*StartHookReply_TaskIdReply) GetTaskId

func (x *StartHookReply_TaskIdReply) GetTaskId() uint32

func (*StartHookReply_TaskIdReply) ProtoMessage

func (*StartHookReply_TaskIdReply) ProtoMessage()

func (*StartHookReply_TaskIdReply) ProtoReflect

func (*StartHookReply_TaskIdReply) Reset

func (x *StartHookReply_TaskIdReply) Reset()

func (*StartHookReply_TaskIdReply) String

func (x *StartHookReply_TaskIdReply) String() string

type StartHookRequest

type StartHookRequest struct {
	TaskInfoList []*TaskInfo `protobuf:"bytes,1,rep,name=task_info_list,json=taskInfoList,proto3" json:"task_info_list,omitempty"`
	// contains filtered or unexported fields
}

func (*StartHookRequest) Descriptor deprecated

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

Deprecated: Use StartHookRequest.ProtoReflect.Descriptor instead.

func (*StartHookRequest) GetTaskInfoList

func (x *StartHookRequest) GetTaskInfoList() []*TaskInfo

func (*StartHookRequest) ProtoMessage

func (*StartHookRequest) ProtoMessage()

func (*StartHookRequest) ProtoReflect

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

func (*StartHookRequest) Reset

func (x *StartHookRequest) Reset()

func (*StartHookRequest) String

func (x *StartHookRequest) String() string

type StreamCallocRequest

type StreamCallocRequest struct {
	Type StreamCallocRequest_CallocRequestType `protobuf:"varint,1,opt,name=type,proto3,enum=crane.grpc.StreamCallocRequest_CallocRequestType" json:"type,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*StreamCallocRequest_PayloadTaskReq
	//	*StreamCallocRequest_PayloadTaskCompleteReq
	Payload isStreamCallocRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*StreamCallocRequest) Descriptor deprecated

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

Deprecated: Use StreamCallocRequest.ProtoReflect.Descriptor instead.

func (*StreamCallocRequest) GetPayload

func (m *StreamCallocRequest) GetPayload() isStreamCallocRequest_Payload

func (*StreamCallocRequest) GetPayloadTaskCompleteReq

func (x *StreamCallocRequest) GetPayloadTaskCompleteReq() *StreamCallocRequest_TaskCompleteReq

func (*StreamCallocRequest) GetPayloadTaskReq

func (x *StreamCallocRequest) GetPayloadTaskReq() *StreamCallocRequest_TaskReq

func (*StreamCallocRequest) GetType

func (*StreamCallocRequest) ProtoMessage

func (*StreamCallocRequest) ProtoMessage()

func (*StreamCallocRequest) ProtoReflect

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

func (*StreamCallocRequest) Reset

func (x *StreamCallocRequest) Reset()

func (*StreamCallocRequest) String

func (x *StreamCallocRequest) String() string

type StreamCallocRequest_CallocRequestType

type StreamCallocRequest_CallocRequestType int32
const (
	StreamCallocRequest_TASK_REQUEST            StreamCallocRequest_CallocRequestType = 0
	StreamCallocRequest_TASK_COMPLETION_REQUEST StreamCallocRequest_CallocRequestType = 1
)

func (StreamCallocRequest_CallocRequestType) Descriptor

func (StreamCallocRequest_CallocRequestType) Enum

func (StreamCallocRequest_CallocRequestType) EnumDescriptor deprecated

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

Deprecated: Use StreamCallocRequest_CallocRequestType.Descriptor instead.

func (StreamCallocRequest_CallocRequestType) Number

func (StreamCallocRequest_CallocRequestType) String

func (StreamCallocRequest_CallocRequestType) Type

type StreamCallocRequest_PayloadTaskCompleteReq

type StreamCallocRequest_PayloadTaskCompleteReq struct {
	PayloadTaskCompleteReq *StreamCallocRequest_TaskCompleteReq `protobuf:"bytes,3,opt,name=payload_task_complete_req,json=payloadTaskCompleteReq,proto3,oneof"`
}

type StreamCallocRequest_PayloadTaskReq

type StreamCallocRequest_PayloadTaskReq struct {
	PayloadTaskReq *StreamCallocRequest_TaskReq `protobuf:"bytes,2,opt,name=payload_task_req,json=payloadTaskReq,proto3,oneof"`
}

type StreamCallocRequest_TaskCompleteReq

type StreamCallocRequest_TaskCompleteReq struct {
	TaskId uint32     `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Status TaskStatus `protobuf:"varint,2,opt,name=status,proto3,enum=crane.grpc.TaskStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCallocRequest_TaskCompleteReq) Descriptor deprecated

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

Deprecated: Use StreamCallocRequest_TaskCompleteReq.ProtoReflect.Descriptor instead.

func (*StreamCallocRequest_TaskCompleteReq) GetStatus

func (*StreamCallocRequest_TaskCompleteReq) GetTaskId

func (*StreamCallocRequest_TaskCompleteReq) ProtoMessage

func (*StreamCallocRequest_TaskCompleteReq) ProtoMessage()

func (*StreamCallocRequest_TaskCompleteReq) ProtoReflect

func (*StreamCallocRequest_TaskCompleteReq) Reset

func (*StreamCallocRequest_TaskCompleteReq) String

type StreamCallocRequest_TaskReq

type StreamCallocRequest_TaskReq struct {
	CallocPid int32       `protobuf:"varint,1,opt,name=calloc_pid,json=callocPid,proto3" json:"calloc_pid,omitempty"`
	Task      *TaskToCtld `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCallocRequest_TaskReq) Descriptor deprecated

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

Deprecated: Use StreamCallocRequest_TaskReq.ProtoReflect.Descriptor instead.

func (*StreamCallocRequest_TaskReq) GetCallocPid

func (x *StreamCallocRequest_TaskReq) GetCallocPid() int32

func (*StreamCallocRequest_TaskReq) GetTask

func (*StreamCallocRequest_TaskReq) ProtoMessage

func (*StreamCallocRequest_TaskReq) ProtoMessage()

func (*StreamCallocRequest_TaskReq) ProtoReflect

func (*StreamCallocRequest_TaskReq) Reset

func (x *StreamCallocRequest_TaskReq) Reset()

func (*StreamCallocRequest_TaskReq) String

func (x *StreamCallocRequest_TaskReq) String() string

type StreamCforedCrunReply

type StreamCforedCrunReply struct {
	Type StreamCforedCrunReply_CforedCrunReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=crane.grpc.StreamCforedCrunReply_CforedCrunReplyType" json:"type,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*StreamCforedCrunReply_PayloadTaskIdReply
	//	*StreamCforedCrunReply_PayloadTaskAllocReply
	//	*StreamCforedCrunReply_PayloadTaskCancelRequest
	//	*StreamCforedCrunReply_PayloadTaskCompletionAckReply
	//	*StreamCforedCrunReply_PayloadTaskIoForwardReadyReply
	//	*StreamCforedCrunReply_PayloadTaskIoForwardReply
	Payload isStreamCforedCrunReply_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*StreamCforedCrunReply) Descriptor deprecated

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

Deprecated: Use StreamCforedCrunReply.ProtoReflect.Descriptor instead.

func (*StreamCforedCrunReply) GetPayload

func (m *StreamCforedCrunReply) GetPayload() isStreamCforedCrunReply_Payload

func (*StreamCforedCrunReply) GetPayloadTaskAllocReply

func (*StreamCforedCrunReply) GetPayloadTaskCancelRequest

func (x *StreamCforedCrunReply) GetPayloadTaskCancelRequest() *StreamCforedCrunReply_TaskCancelRequest

func (*StreamCforedCrunReply) GetPayloadTaskCompletionAckReply

func (x *StreamCforedCrunReply) GetPayloadTaskCompletionAckReply() *StreamCforedCrunReply_TaskCompletionAckReply

func (*StreamCforedCrunReply) GetPayloadTaskIdReply

func (x *StreamCforedCrunReply) GetPayloadTaskIdReply() *StreamCforedCrunReply_TaskIdReply

func (*StreamCforedCrunReply) GetPayloadTaskIoForwardReadyReply

func (x *StreamCforedCrunReply) GetPayloadTaskIoForwardReadyReply() *StreamCforedCrunReply_TaskIOForwardReadyReply

func (*StreamCforedCrunReply) GetPayloadTaskIoForwardReply

func (x *StreamCforedCrunReply) GetPayloadTaskIoForwardReply() *StreamCforedCrunReply_TaskIOForwardReply

func (*StreamCforedCrunReply) GetType

func (*StreamCforedCrunReply) ProtoMessage

func (*StreamCforedCrunReply) ProtoMessage()

func (*StreamCforedCrunReply) ProtoReflect

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

func (*StreamCforedCrunReply) Reset

func (x *StreamCforedCrunReply) Reset()

func (*StreamCforedCrunReply) String

func (x *StreamCforedCrunReply) String() string

type StreamCforedCrunReply_CforedCrunReplyType

type StreamCforedCrunReply_CforedCrunReplyType int32
const (
	StreamCforedCrunReply_TASK_ID_REPLY             StreamCforedCrunReply_CforedCrunReplyType = 0
	StreamCforedCrunReply_TASK_RES_ALLOC_REPLY      StreamCforedCrunReply_CforedCrunReplyType = 1
	StreamCforedCrunReply_TASK_CANCEL_REQUEST       StreamCforedCrunReply_CforedCrunReplyType = 2
	StreamCforedCrunReply_TASK_COMPLETION_ACK_REPLY StreamCforedCrunReply_CforedCrunReplyType = 3
	StreamCforedCrunReply_TASK_IO_FORWARD           StreamCforedCrunReply_CforedCrunReplyType = 4
	StreamCforedCrunReply_TASK_IO_FORWARD_READY     StreamCforedCrunReply_CforedCrunReplyType = 5
)

func (StreamCforedCrunReply_CforedCrunReplyType) Descriptor

func (StreamCforedCrunReply_CforedCrunReplyType) Enum

func (StreamCforedCrunReply_CforedCrunReplyType) EnumDescriptor deprecated

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

Deprecated: Use StreamCforedCrunReply_CforedCrunReplyType.Descriptor instead.

func (StreamCforedCrunReply_CforedCrunReplyType) Number

func (StreamCforedCrunReply_CforedCrunReplyType) String

func (StreamCforedCrunReply_CforedCrunReplyType) Type

type StreamCforedCrunReply_PayloadTaskAllocReply

type StreamCforedCrunReply_PayloadTaskAllocReply struct {
	PayloadTaskAllocReply *StreamCforedCrunReply_TaskResAllocatedReply `protobuf:"bytes,3,opt,name=payload_task_alloc_reply,json=payloadTaskAllocReply,proto3,oneof"`
}

type StreamCforedCrunReply_PayloadTaskCancelRequest

type StreamCforedCrunReply_PayloadTaskCancelRequest struct {
	PayloadTaskCancelRequest *StreamCforedCrunReply_TaskCancelRequest `protobuf:"bytes,4,opt,name=payload_task_cancel_request,json=payloadTaskCancelRequest,proto3,oneof"`
}

type StreamCforedCrunReply_PayloadTaskCompletionAckReply

type StreamCforedCrunReply_PayloadTaskCompletionAckReply struct {
	PayloadTaskCompletionAckReply *StreamCforedCrunReply_TaskCompletionAckReply `protobuf:"bytes,5,opt,name=payload_task_completion_ack_reply,json=payloadTaskCompletionAckReply,proto3,oneof"`
}

type StreamCforedCrunReply_PayloadTaskIdReply

type StreamCforedCrunReply_PayloadTaskIdReply struct {
	PayloadTaskIdReply *StreamCforedCrunReply_TaskIdReply `protobuf:"bytes,2,opt,name=payload_task_id_reply,json=payloadTaskIdReply,proto3,oneof"`
}

type StreamCforedCrunReply_PayloadTaskIoForwardReadyReply

type StreamCforedCrunReply_PayloadTaskIoForwardReadyReply struct {
	PayloadTaskIoForwardReadyReply *StreamCforedCrunReply_TaskIOForwardReadyReply `protobuf:"bytes,6,opt,name=payload_task_io_forward_ready_reply,json=payloadTaskIoForwardReadyReply,proto3,oneof"`
}

type StreamCforedCrunReply_PayloadTaskIoForwardReply

type StreamCforedCrunReply_PayloadTaskIoForwardReply struct {
	PayloadTaskIoForwardReply *StreamCforedCrunReply_TaskIOForwardReply `protobuf:"bytes,7,opt,name=payload_task_io_forward_reply,json=payloadTaskIoForwardReply,proto3,oneof"`
}

type StreamCforedCrunReply_TaskCancelRequest

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

func (*StreamCforedCrunReply_TaskCancelRequest) Descriptor deprecated

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

Deprecated: Use StreamCforedCrunReply_TaskCancelRequest.ProtoReflect.Descriptor instead.

func (*StreamCforedCrunReply_TaskCancelRequest) GetTaskId

func (*StreamCforedCrunReply_TaskCancelRequest) ProtoMessage

func (*StreamCforedCrunReply_TaskCancelRequest) ProtoReflect

func (*StreamCforedCrunReply_TaskCancelRequest) Reset

func (*StreamCforedCrunReply_TaskCancelRequest) String

type StreamCforedCrunReply_TaskCompletionAckReply

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

func (*StreamCforedCrunReply_TaskCompletionAckReply) Descriptor deprecated

Deprecated: Use StreamCforedCrunReply_TaskCompletionAckReply.ProtoReflect.Descriptor instead.

func (*StreamCforedCrunReply_TaskCompletionAckReply) GetOk

func (*StreamCforedCrunReply_TaskCompletionAckReply) ProtoMessage

func (*StreamCforedCrunReply_TaskCompletionAckReply) ProtoReflect

func (*StreamCforedCrunReply_TaskCompletionAckReply) Reset

func (*StreamCforedCrunReply_TaskCompletionAckReply) String

type StreamCforedCrunReply_TaskIOForwardReadyReply

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

func (*StreamCforedCrunReply_TaskIOForwardReadyReply) Descriptor deprecated

Deprecated: Use StreamCforedCrunReply_TaskIOForwardReadyReply.ProtoReflect.Descriptor instead.

func (*StreamCforedCrunReply_TaskIOForwardReadyReply) GetOk

func (*StreamCforedCrunReply_TaskIOForwardReadyReply) ProtoMessage

func (*StreamCforedCrunReply_TaskIOForwardReadyReply) ProtoReflect

func (*StreamCforedCrunReply_TaskIOForwardReadyReply) Reset

func (*StreamCforedCrunReply_TaskIOForwardReadyReply) String

type StreamCforedCrunReply_TaskIOForwardReply

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

func (*StreamCforedCrunReply_TaskIOForwardReply) Descriptor deprecated

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

Deprecated: Use StreamCforedCrunReply_TaskIOForwardReply.ProtoReflect.Descriptor instead.

func (*StreamCforedCrunReply_TaskIOForwardReply) GetMsg

func (*StreamCforedCrunReply_TaskIOForwardReply) ProtoMessage

func (*StreamCforedCrunReply_TaskIOForwardReply) ProtoReflect

func (*StreamCforedCrunReply_TaskIOForwardReply) Reset

func (*StreamCforedCrunReply_TaskIOForwardReply) String

type StreamCforedCrunReply_TaskIdReply

type StreamCforedCrunReply_TaskIdReply struct {
	Ok            bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	TaskId        uint32 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	FailureReason string `protobuf:"bytes,3,opt,name=failure_reason,json=failureReason,proto3" json:"failure_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCforedCrunReply_TaskIdReply) Descriptor deprecated

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

Deprecated: Use StreamCforedCrunReply_TaskIdReply.ProtoReflect.Descriptor instead.

func (*StreamCforedCrunReply_TaskIdReply) GetFailureReason

func (x *StreamCforedCrunReply_TaskIdReply) GetFailureReason() string

func (*StreamCforedCrunReply_TaskIdReply) GetOk

func (*StreamCforedCrunReply_TaskIdReply) GetTaskId

func (*StreamCforedCrunReply_TaskIdReply) ProtoMessage

func (*StreamCforedCrunReply_TaskIdReply) ProtoMessage()

func (*StreamCforedCrunReply_TaskIdReply) ProtoReflect

func (*StreamCforedCrunReply_TaskIdReply) Reset

func (*StreamCforedCrunReply_TaskIdReply) String

type StreamCforedCrunReply_TaskResAllocatedReply

type StreamCforedCrunReply_TaskResAllocatedReply struct {
	Ok                   bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	AllocatedCranedRegex string `protobuf:"bytes,2,opt,name=allocated_craned_regex,json=allocatedCranedRegex,proto3" json:"allocated_craned_regex,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCforedCrunReply_TaskResAllocatedReply) Descriptor deprecated

Deprecated: Use StreamCforedCrunReply_TaskResAllocatedReply.ProtoReflect.Descriptor instead.

func (*StreamCforedCrunReply_TaskResAllocatedReply) GetAllocatedCranedRegex

func (x *StreamCforedCrunReply_TaskResAllocatedReply) GetAllocatedCranedRegex() string

func (*StreamCforedCrunReply_TaskResAllocatedReply) GetOk

func (*StreamCforedCrunReply_TaskResAllocatedReply) ProtoMessage

func (*StreamCforedCrunReply_TaskResAllocatedReply) ProtoReflect

func (*StreamCforedCrunReply_TaskResAllocatedReply) Reset

func (*StreamCforedCrunReply_TaskResAllocatedReply) String

type StreamCforedReply

type StreamCforedReply struct {
	Type StreamCforedReply_CforedReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=crane.grpc.StreamCforedReply_CforedReplyType" json:"type,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*StreamCforedReply_PayloadTaskIdReply
	//	*StreamCforedReply_PayloadTaskAllocReply
	//	*StreamCforedReply_PayloadTaskCancelRequest
	//	*StreamCforedReply_PayloadTaskCompletionAckReply
	Payload isStreamCforedReply_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*StreamCforedReply) Descriptor deprecated

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

Deprecated: Use StreamCforedReply.ProtoReflect.Descriptor instead.

func (*StreamCforedReply) GetPayload

func (m *StreamCforedReply) GetPayload() isStreamCforedReply_Payload

func (*StreamCforedReply) GetPayloadTaskAllocReply

func (x *StreamCforedReply) GetPayloadTaskAllocReply() *StreamCforedReply_TaskResAllocatedReply

func (*StreamCforedReply) GetPayloadTaskCancelRequest

func (x *StreamCforedReply) GetPayloadTaskCancelRequest() *StreamCforedReply_TaskCancelRequest

func (*StreamCforedReply) GetPayloadTaskCompletionAckReply

func (x *StreamCforedReply) GetPayloadTaskCompletionAckReply() *StreamCforedReply_TaskCompletionAckReply

func (*StreamCforedReply) GetPayloadTaskIdReply

func (x *StreamCforedReply) GetPayloadTaskIdReply() *StreamCforedReply_TaskIdReply

func (*StreamCforedReply) GetType

func (*StreamCforedReply) ProtoMessage

func (*StreamCforedReply) ProtoMessage()

func (*StreamCforedReply) ProtoReflect

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

func (*StreamCforedReply) Reset

func (x *StreamCforedReply) Reset()

func (*StreamCforedReply) String

func (x *StreamCforedReply) String() string

type StreamCforedReply_CforedReplyType

type StreamCforedReply_CforedReplyType int32
const (
	StreamCforedReply_TASK_ID_REPLY             StreamCforedReply_CforedReplyType = 0
	StreamCforedReply_TASK_RES_ALLOC_REPLY      StreamCforedReply_CforedReplyType = 1
	StreamCforedReply_TASK_CANCEL_REQUEST       StreamCforedReply_CforedReplyType = 2
	StreamCforedReply_TASK_COMPLETION_ACK_REPLY StreamCforedReply_CforedReplyType = 3
)

func (StreamCforedReply_CforedReplyType) Descriptor

func (StreamCforedReply_CforedReplyType) Enum

func (StreamCforedReply_CforedReplyType) EnumDescriptor deprecated

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

Deprecated: Use StreamCforedReply_CforedReplyType.Descriptor instead.

func (StreamCforedReply_CforedReplyType) Number

func (StreamCforedReply_CforedReplyType) String

func (StreamCforedReply_CforedReplyType) Type

type StreamCforedReply_PayloadTaskAllocReply

type StreamCforedReply_PayloadTaskAllocReply struct {
	PayloadTaskAllocReply *StreamCforedReply_TaskResAllocatedReply `protobuf:"bytes,3,opt,name=payload_task_alloc_reply,json=payloadTaskAllocReply,proto3,oneof"`
}

type StreamCforedReply_PayloadTaskCancelRequest

type StreamCforedReply_PayloadTaskCancelRequest struct {
	PayloadTaskCancelRequest *StreamCforedReply_TaskCancelRequest `protobuf:"bytes,4,opt,name=payload_task_cancel_request,json=payloadTaskCancelRequest,proto3,oneof"`
}

type StreamCforedReply_PayloadTaskCompletionAckReply

type StreamCforedReply_PayloadTaskCompletionAckReply struct {
	PayloadTaskCompletionAckReply *StreamCforedReply_TaskCompletionAckReply `protobuf:"bytes,5,opt,name=payload_task_completion_ack_reply,json=payloadTaskCompletionAckReply,proto3,oneof"`
}

type StreamCforedReply_PayloadTaskIdReply

type StreamCforedReply_PayloadTaskIdReply struct {
	PayloadTaskIdReply *StreamCforedReply_TaskIdReply `protobuf:"bytes,2,opt,name=payload_task_id_reply,json=payloadTaskIdReply,proto3,oneof"`
}

type StreamCforedReply_TaskCancelRequest

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

func (*StreamCforedReply_TaskCancelRequest) Descriptor deprecated

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

Deprecated: Use StreamCforedReply_TaskCancelRequest.ProtoReflect.Descriptor instead.

func (*StreamCforedReply_TaskCancelRequest) GetTaskId

func (*StreamCforedReply_TaskCancelRequest) ProtoMessage

func (*StreamCforedReply_TaskCancelRequest) ProtoMessage()

func (*StreamCforedReply_TaskCancelRequest) ProtoReflect

func (*StreamCforedReply_TaskCancelRequest) Reset

func (*StreamCforedReply_TaskCancelRequest) String

type StreamCforedReply_TaskCompletionAckReply

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

func (*StreamCforedReply_TaskCompletionAckReply) Descriptor deprecated

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

Deprecated: Use StreamCforedReply_TaskCompletionAckReply.ProtoReflect.Descriptor instead.

func (*StreamCforedReply_TaskCompletionAckReply) GetOk

func (*StreamCforedReply_TaskCompletionAckReply) ProtoMessage

func (*StreamCforedReply_TaskCompletionAckReply) ProtoReflect

func (*StreamCforedReply_TaskCompletionAckReply) Reset

func (*StreamCforedReply_TaskCompletionAckReply) String

type StreamCforedReply_TaskIdReply

type StreamCforedReply_TaskIdReply struct {
	Ok            bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	TaskId        uint32 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	FailureReason string `protobuf:"bytes,3,opt,name=failure_reason,json=failureReason,proto3" json:"failure_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCforedReply_TaskIdReply) Descriptor deprecated

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

Deprecated: Use StreamCforedReply_TaskIdReply.ProtoReflect.Descriptor instead.

func (*StreamCforedReply_TaskIdReply) GetFailureReason

func (x *StreamCforedReply_TaskIdReply) GetFailureReason() string

func (*StreamCforedReply_TaskIdReply) GetOk

func (*StreamCforedReply_TaskIdReply) GetTaskId

func (x *StreamCforedReply_TaskIdReply) GetTaskId() uint32

func (*StreamCforedReply_TaskIdReply) ProtoMessage

func (*StreamCforedReply_TaskIdReply) ProtoMessage()

func (*StreamCforedReply_TaskIdReply) ProtoReflect

func (*StreamCforedReply_TaskIdReply) Reset

func (x *StreamCforedReply_TaskIdReply) Reset()

func (*StreamCforedReply_TaskIdReply) String

type StreamCforedReply_TaskResAllocatedReply

type StreamCforedReply_TaskResAllocatedReply struct {
	Ok                   bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	AllocatedCranedRegex string `protobuf:"bytes,2,opt,name=allocated_craned_regex,json=allocatedCranedRegex,proto3" json:"allocated_craned_regex,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCforedReply_TaskResAllocatedReply) Descriptor deprecated

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

Deprecated: Use StreamCforedReply_TaskResAllocatedReply.ProtoReflect.Descriptor instead.

func (*StreamCforedReply_TaskResAllocatedReply) GetAllocatedCranedRegex

func (x *StreamCforedReply_TaskResAllocatedReply) GetAllocatedCranedRegex() string

func (*StreamCforedReply_TaskResAllocatedReply) GetOk

func (*StreamCforedReply_TaskResAllocatedReply) ProtoMessage

func (*StreamCforedReply_TaskResAllocatedReply) ProtoReflect

func (*StreamCforedReply_TaskResAllocatedReply) Reset

func (*StreamCforedReply_TaskResAllocatedReply) String

type StreamCforedRequest

type StreamCforedRequest struct {
	Type StreamCforedRequest_CforedRequestType `protobuf:"varint,1,opt,name=type,proto3,enum=crane.grpc.StreamCforedRequest_CforedRequestType" json:"type,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*StreamCforedRequest_PayloadCforedReg
	//	*StreamCforedRequest_PayloadTaskReq
	//	*StreamCforedRequest_PayloadTaskCompleteReq
	//	*StreamCforedRequest_PayloadGracefulExitReq
	Payload isStreamCforedRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*StreamCforedRequest) Descriptor deprecated

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

Deprecated: Use StreamCforedRequest.ProtoReflect.Descriptor instead.

func (*StreamCforedRequest) GetPayload

func (m *StreamCforedRequest) GetPayload() isStreamCforedRequest_Payload

func (*StreamCforedRequest) GetPayloadCforedReg

func (x *StreamCforedRequest) GetPayloadCforedReg() *StreamCforedRequest_CforedReg

func (*StreamCforedRequest) GetPayloadGracefulExitReq

func (x *StreamCforedRequest) GetPayloadGracefulExitReq() *StreamCforedRequest_GracefulExitReq

func (*StreamCforedRequest) GetPayloadTaskCompleteReq

func (x *StreamCforedRequest) GetPayloadTaskCompleteReq() *StreamCforedRequest_TaskCompleteReq

func (*StreamCforedRequest) GetPayloadTaskReq

func (x *StreamCforedRequest) GetPayloadTaskReq() *StreamCforedRequest_TaskReq

func (*StreamCforedRequest) GetType

func (*StreamCforedRequest) ProtoMessage

func (*StreamCforedRequest) ProtoMessage()

func (*StreamCforedRequest) ProtoReflect

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

func (*StreamCforedRequest) Reset

func (x *StreamCforedRequest) Reset()

func (*StreamCforedRequest) String

func (x *StreamCforedRequest) String() string

type StreamCforedRequest_CforedReg

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

func (*StreamCforedRequest_CforedReg) Descriptor deprecated

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

Deprecated: Use StreamCforedRequest_CforedReg.ProtoReflect.Descriptor instead.

func (*StreamCforedRequest_CforedReg) GetCforedName

func (x *StreamCforedRequest_CforedReg) GetCforedName() string

func (*StreamCforedRequest_CforedReg) ProtoMessage

func (*StreamCforedRequest_CforedReg) ProtoMessage()

func (*StreamCforedRequest_CforedReg) ProtoReflect

func (*StreamCforedRequest_CforedReg) Reset

func (x *StreamCforedRequest_CforedReg) Reset()

func (*StreamCforedRequest_CforedReg) String

type StreamCforedRequest_CforedRequestType

type StreamCforedRequest_CforedRequestType int32
const (
	StreamCforedRequest_CFORED_REGISTRATION     StreamCforedRequest_CforedRequestType = 0
	StreamCforedRequest_TASK_REQUEST            StreamCforedRequest_CforedRequestType = 1
	StreamCforedRequest_TASK_COMPLETION_REQUEST StreamCforedRequest_CforedRequestType = 2
	StreamCforedRequest_CFORED_GRACEFUL_EXIT    StreamCforedRequest_CforedRequestType = 3
)

func (StreamCforedRequest_CforedRequestType) Descriptor

func (StreamCforedRequest_CforedRequestType) Enum

func (StreamCforedRequest_CforedRequestType) EnumDescriptor deprecated

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

Deprecated: Use StreamCforedRequest_CforedRequestType.Descriptor instead.

func (StreamCforedRequest_CforedRequestType) Number

func (StreamCforedRequest_CforedRequestType) String

func (StreamCforedRequest_CforedRequestType) Type

type StreamCforedRequest_GracefulExitReq

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

func (*StreamCforedRequest_GracefulExitReq) Descriptor deprecated

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

Deprecated: Use StreamCforedRequest_GracefulExitReq.ProtoReflect.Descriptor instead.

func (*StreamCforedRequest_GracefulExitReq) GetCforedName

func (x *StreamCforedRequest_GracefulExitReq) GetCforedName() string

func (*StreamCforedRequest_GracefulExitReq) ProtoMessage

func (*StreamCforedRequest_GracefulExitReq) ProtoMessage()

func (*StreamCforedRequest_GracefulExitReq) ProtoReflect

func (*StreamCforedRequest_GracefulExitReq) Reset

func (*StreamCforedRequest_GracefulExitReq) String

type StreamCforedRequest_PayloadCforedReg

type StreamCforedRequest_PayloadCforedReg struct {
	PayloadCforedReg *StreamCforedRequest_CforedReg `protobuf:"bytes,2,opt,name=payload_cfored_reg,json=payloadCforedReg,proto3,oneof"`
}

type StreamCforedRequest_PayloadGracefulExitReq

type StreamCforedRequest_PayloadGracefulExitReq struct {
	PayloadGracefulExitReq *StreamCforedRequest_GracefulExitReq `protobuf:"bytes,5,opt,name=payload_graceful_exit_req,json=payloadGracefulExitReq,proto3,oneof"`
}

type StreamCforedRequest_PayloadTaskCompleteReq

type StreamCforedRequest_PayloadTaskCompleteReq struct {
	PayloadTaskCompleteReq *StreamCforedRequest_TaskCompleteReq `protobuf:"bytes,4,opt,name=payload_task_complete_req,json=payloadTaskCompleteReq,proto3,oneof"`
}

type StreamCforedRequest_PayloadTaskReq

type StreamCforedRequest_PayloadTaskReq struct {
	PayloadTaskReq *StreamCforedRequest_TaskReq `protobuf:"bytes,3,opt,name=payload_task_req,json=payloadTaskReq,proto3,oneof"`
}

type StreamCforedRequest_TaskCompleteReq

type StreamCforedRequest_TaskCompleteReq struct {
	CforedName      string              `protobuf:"bytes,1,opt,name=cfored_name,json=cforedName,proto3" json:"cfored_name,omitempty"`
	TaskId          uint32              `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Status          TaskStatus          `protobuf:"varint,3,opt,name=status,proto3,enum=crane.grpc.TaskStatus" json:"status,omitempty"`
	InteractiveType InteractiveTaskType `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StreamCforedRequest_TaskCompleteReq) Descriptor deprecated

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

Deprecated: Use StreamCforedRequest_TaskCompleteReq.ProtoReflect.Descriptor instead.

func (*StreamCforedRequest_TaskCompleteReq) GetCforedName

func (x *StreamCforedRequest_TaskCompleteReq) GetCforedName() string

func (*StreamCforedRequest_TaskCompleteReq) GetInteractiveType

func (*StreamCforedRequest_TaskCompleteReq) GetStatus

func (*StreamCforedRequest_TaskCompleteReq) GetTaskId

func (*StreamCforedRequest_TaskCompleteReq) ProtoMessage

func (*StreamCforedRequest_TaskCompleteReq) ProtoMessage()

func (*StreamCforedRequest_TaskCompleteReq) ProtoReflect

func (*StreamCforedRequest_TaskCompleteReq) Reset

func (*StreamCforedRequest_TaskCompleteReq) String

type StreamCforedRequest_TaskReq

type StreamCforedRequest_TaskReq struct {
	CforedName string      `protobuf:"bytes,1,opt,name=cfored_name,json=cforedName,proto3" json:"cfored_name,omitempty"`
	Pid        int32       `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	Task       *TaskToCtld `protobuf:"bytes,3,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCforedRequest_TaskReq) Descriptor deprecated

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

Deprecated: Use StreamCforedRequest_TaskReq.ProtoReflect.Descriptor instead.

func (*StreamCforedRequest_TaskReq) GetCforedName

func (x *StreamCforedRequest_TaskReq) GetCforedName() string

func (*StreamCforedRequest_TaskReq) GetPid

func (x *StreamCforedRequest_TaskReq) GetPid() int32

func (*StreamCforedRequest_TaskReq) GetTask

func (*StreamCforedRequest_TaskReq) ProtoMessage

func (*StreamCforedRequest_TaskReq) ProtoMessage()

func (*StreamCforedRequest_TaskReq) ProtoReflect

func (*StreamCforedRequest_TaskReq) Reset

func (x *StreamCforedRequest_TaskReq) Reset()

func (*StreamCforedRequest_TaskReq) String

func (x *StreamCforedRequest_TaskReq) String() string

type StreamCforedTaskIOReply

type StreamCforedTaskIOReply struct {
	Type StreamCforedTaskIOReply_CranedReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=crane.grpc.StreamCforedTaskIOReply_CranedReplyType" json:"type,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*StreamCforedTaskIOReply_PayloadCranedRegisterReply
	//	*StreamCforedTaskIOReply_PayloadTaskInputReq
	//	*StreamCforedTaskIOReply_PayloadCranedUnregisterReply
	Payload isStreamCforedTaskIOReply_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*StreamCforedTaskIOReply) Descriptor deprecated

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

Deprecated: Use StreamCforedTaskIOReply.ProtoReflect.Descriptor instead.

func (*StreamCforedTaskIOReply) GetPayload

func (m *StreamCforedTaskIOReply) GetPayload() isStreamCforedTaskIOReply_Payload

func (*StreamCforedTaskIOReply) GetPayloadCranedRegisterReply

func (x *StreamCforedTaskIOReply) GetPayloadCranedRegisterReply() *StreamCforedTaskIOReply_CranedRegisterReply

func (*StreamCforedTaskIOReply) GetPayloadCranedUnregisterReply

func (x *StreamCforedTaskIOReply) GetPayloadCranedUnregisterReply() *StreamCforedTaskIOReply_CranedUnregisterReply

func (*StreamCforedTaskIOReply) GetPayloadTaskInputReq

func (*StreamCforedTaskIOReply) GetType

func (*StreamCforedTaskIOReply) ProtoMessage

func (*StreamCforedTaskIOReply) ProtoMessage()

func (*StreamCforedTaskIOReply) ProtoReflect

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

func (*StreamCforedTaskIOReply) Reset

func (x *StreamCforedTaskIOReply) Reset()

func (*StreamCforedTaskIOReply) String

func (x *StreamCforedTaskIOReply) String() string

type StreamCforedTaskIOReply_CranedRegisterReply

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

func (*StreamCforedTaskIOReply_CranedRegisterReply) Descriptor deprecated

Deprecated: Use StreamCforedTaskIOReply_CranedRegisterReply.ProtoReflect.Descriptor instead.

func (*StreamCforedTaskIOReply_CranedRegisterReply) GetOk

func (*StreamCforedTaskIOReply_CranedRegisterReply) ProtoMessage

func (*StreamCforedTaskIOReply_CranedRegisterReply) ProtoReflect

func (*StreamCforedTaskIOReply_CranedRegisterReply) Reset

func (*StreamCforedTaskIOReply_CranedRegisterReply) String

type StreamCforedTaskIOReply_CranedReplyType

type StreamCforedTaskIOReply_CranedReplyType int32
const (
	StreamCforedTaskIOReply_CRANED_REGISTER_REPLY   StreamCforedTaskIOReply_CranedReplyType = 0
	StreamCforedTaskIOReply_CRANED_TASK_INPUT       StreamCforedTaskIOReply_CranedReplyType = 1
	StreamCforedTaskIOReply_CRANED_UNREGISTER_REPLY StreamCforedTaskIOReply_CranedReplyType = 2
)

func (StreamCforedTaskIOReply_CranedReplyType) Descriptor

func (StreamCforedTaskIOReply_CranedReplyType) Enum

func (StreamCforedTaskIOReply_CranedReplyType) EnumDescriptor deprecated

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

Deprecated: Use StreamCforedTaskIOReply_CranedReplyType.Descriptor instead.

func (StreamCforedTaskIOReply_CranedReplyType) Number

func (StreamCforedTaskIOReply_CranedReplyType) String

func (StreamCforedTaskIOReply_CranedReplyType) Type

type StreamCforedTaskIOReply_CranedTaskInputReq

type StreamCforedTaskIOReply_CranedTaskInputReq struct {
	TaskId uint32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCforedTaskIOReply_CranedTaskInputReq) Descriptor deprecated

Deprecated: Use StreamCforedTaskIOReply_CranedTaskInputReq.ProtoReflect.Descriptor instead.

func (*StreamCforedTaskIOReply_CranedTaskInputReq) GetMsg

func (*StreamCforedTaskIOReply_CranedTaskInputReq) GetTaskId

func (*StreamCforedTaskIOReply_CranedTaskInputReq) ProtoMessage

func (*StreamCforedTaskIOReply_CranedTaskInputReq) ProtoReflect

func (*StreamCforedTaskIOReply_CranedTaskInputReq) Reset

func (*StreamCforedTaskIOReply_CranedTaskInputReq) String

type StreamCforedTaskIOReply_CranedUnregisterReply

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

func (*StreamCforedTaskIOReply_CranedUnregisterReply) Descriptor deprecated

Deprecated: Use StreamCforedTaskIOReply_CranedUnregisterReply.ProtoReflect.Descriptor instead.

func (*StreamCforedTaskIOReply_CranedUnregisterReply) GetOk

func (*StreamCforedTaskIOReply_CranedUnregisterReply) ProtoMessage

func (*StreamCforedTaskIOReply_CranedUnregisterReply) ProtoReflect

func (*StreamCforedTaskIOReply_CranedUnregisterReply) Reset

func (*StreamCforedTaskIOReply_CranedUnregisterReply) String

type StreamCforedTaskIOReply_PayloadCranedRegisterReply

type StreamCforedTaskIOReply_PayloadCranedRegisterReply struct {
	PayloadCranedRegisterReply *StreamCforedTaskIOReply_CranedRegisterReply `protobuf:"bytes,2,opt,name=payload_craned_register_reply,json=payloadCranedRegisterReply,proto3,oneof"`
}

type StreamCforedTaskIOReply_PayloadCranedUnregisterReply

type StreamCforedTaskIOReply_PayloadCranedUnregisterReply struct {
	PayloadCranedUnregisterReply *StreamCforedTaskIOReply_CranedUnregisterReply `protobuf:"bytes,4,opt,name=payload_craned_unregister_reply,json=payloadCranedUnregisterReply,proto3,oneof"`
}

type StreamCforedTaskIOReply_PayloadTaskInputReq

type StreamCforedTaskIOReply_PayloadTaskInputReq struct {
	PayloadTaskInputReq *StreamCforedTaskIOReply_CranedTaskInputReq `protobuf:"bytes,3,opt,name=payload_task_input_req,json=payloadTaskInputReq,proto3,oneof"`
}

type StreamCforedTaskIORequest

type StreamCforedTaskIORequest struct {
	Type StreamCforedTaskIORequest_CranedRequestType `protobuf:"varint,1,opt,name=type,proto3,enum=crane.grpc.StreamCforedTaskIORequest_CranedRequestType" json:"type,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*StreamCforedTaskIORequest_PayloadRegisterReq
	//	*StreamCforedTaskIORequest_PayloadTaskOutputReq
	//	*StreamCforedTaskIORequest_PayloadUnregisterReq
	Payload isStreamCforedTaskIORequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*StreamCforedTaskIORequest) Descriptor deprecated

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

Deprecated: Use StreamCforedTaskIORequest.ProtoReflect.Descriptor instead.

func (*StreamCforedTaskIORequest) GetPayload

func (m *StreamCforedTaskIORequest) GetPayload() isStreamCforedTaskIORequest_Payload

func (*StreamCforedTaskIORequest) GetPayloadRegisterReq

func (*StreamCforedTaskIORequest) GetPayloadTaskOutputReq

func (*StreamCforedTaskIORequest) GetPayloadUnregisterReq

func (*StreamCforedTaskIORequest) GetType

func (*StreamCforedTaskIORequest) ProtoMessage

func (*StreamCforedTaskIORequest) ProtoMessage()

func (*StreamCforedTaskIORequest) ProtoReflect

func (*StreamCforedTaskIORequest) Reset

func (x *StreamCforedTaskIORequest) Reset()

func (*StreamCforedTaskIORequest) String

func (x *StreamCforedTaskIORequest) String() string

type StreamCforedTaskIORequest_CranedRegisterReq

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

func (*StreamCforedTaskIORequest_CranedRegisterReq) Descriptor deprecated

Deprecated: Use StreamCforedTaskIORequest_CranedRegisterReq.ProtoReflect.Descriptor instead.

func (*StreamCforedTaskIORequest_CranedRegisterReq) GetCranedId

func (*StreamCforedTaskIORequest_CranedRegisterReq) ProtoMessage

func (*StreamCforedTaskIORequest_CranedRegisterReq) ProtoReflect

func (*StreamCforedTaskIORequest_CranedRegisterReq) Reset

func (*StreamCforedTaskIORequest_CranedRegisterReq) String

type StreamCforedTaskIORequest_CranedRequestType

type StreamCforedTaskIORequest_CranedRequestType int32
const (
	StreamCforedTaskIORequest_CRANED_REGISTER    StreamCforedTaskIORequest_CranedRequestType = 0
	StreamCforedTaskIORequest_CRANED_TASK_OUTPUT StreamCforedTaskIORequest_CranedRequestType = 1
	StreamCforedTaskIORequest_CRANED_UNREGISTER  StreamCforedTaskIORequest_CranedRequestType = 2
)

func (StreamCforedTaskIORequest_CranedRequestType) Descriptor

func (StreamCforedTaskIORequest_CranedRequestType) Enum

func (StreamCforedTaskIORequest_CranedRequestType) EnumDescriptor deprecated

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

Deprecated: Use StreamCforedTaskIORequest_CranedRequestType.Descriptor instead.

func (StreamCforedTaskIORequest_CranedRequestType) Number

func (StreamCforedTaskIORequest_CranedRequestType) String

func (StreamCforedTaskIORequest_CranedRequestType) Type

type StreamCforedTaskIORequest_CranedTaskOutputReq

type StreamCforedTaskIORequest_CranedTaskOutputReq struct {
	TaskId uint32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCforedTaskIORequest_CranedTaskOutputReq) Descriptor deprecated

Deprecated: Use StreamCforedTaskIORequest_CranedTaskOutputReq.ProtoReflect.Descriptor instead.

func (*StreamCforedTaskIORequest_CranedTaskOutputReq) GetMsg

func (*StreamCforedTaskIORequest_CranedTaskOutputReq) GetTaskId

func (*StreamCforedTaskIORequest_CranedTaskOutputReq) ProtoMessage

func (*StreamCforedTaskIORequest_CranedTaskOutputReq) ProtoReflect

func (*StreamCforedTaskIORequest_CranedTaskOutputReq) Reset

func (*StreamCforedTaskIORequest_CranedTaskOutputReq) String

type StreamCforedTaskIORequest_CranedUnRegisterReq

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

func (*StreamCforedTaskIORequest_CranedUnRegisterReq) Descriptor deprecated

Deprecated: Use StreamCforedTaskIORequest_CranedUnRegisterReq.ProtoReflect.Descriptor instead.

func (*StreamCforedTaskIORequest_CranedUnRegisterReq) GetCranedId

func (*StreamCforedTaskIORequest_CranedUnRegisterReq) ProtoMessage

func (*StreamCforedTaskIORequest_CranedUnRegisterReq) ProtoReflect

func (*StreamCforedTaskIORequest_CranedUnRegisterReq) Reset

func (*StreamCforedTaskIORequest_CranedUnRegisterReq) String

type StreamCforedTaskIORequest_PayloadRegisterReq

type StreamCforedTaskIORequest_PayloadRegisterReq struct {
	PayloadRegisterReq *StreamCforedTaskIORequest_CranedRegisterReq `protobuf:"bytes,2,opt,name=payload_register_req,json=payloadRegisterReq,proto3,oneof"`
}

type StreamCforedTaskIORequest_PayloadTaskOutputReq

type StreamCforedTaskIORequest_PayloadTaskOutputReq struct {
	PayloadTaskOutputReq *StreamCforedTaskIORequest_CranedTaskOutputReq `protobuf:"bytes,3,opt,name=payload_task_output_req,json=payloadTaskOutputReq,proto3,oneof"`
}

type StreamCforedTaskIORequest_PayloadUnregisterReq

type StreamCforedTaskIORequest_PayloadUnregisterReq struct {
	PayloadUnregisterReq *StreamCforedTaskIORequest_CranedUnRegisterReq `protobuf:"bytes,4,opt,name=payload_unregister_req,json=payloadUnregisterReq,proto3,oneof"`
}

type StreamCrunRequest

type StreamCrunRequest struct {
	Type StreamCrunRequest_CrunRequestType `protobuf:"varint,1,opt,name=type,proto3,enum=crane.grpc.StreamCrunRequest_CrunRequestType" json:"type,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*StreamCrunRequest_PayloadTaskReq
	//	*StreamCrunRequest_PayloadTaskCompleteReq
	//	*StreamCrunRequest_PayloadTaskIoForwardReq
	Payload isStreamCrunRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*StreamCrunRequest) Descriptor deprecated

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

Deprecated: Use StreamCrunRequest.ProtoReflect.Descriptor instead.

func (*StreamCrunRequest) GetPayload

func (m *StreamCrunRequest) GetPayload() isStreamCrunRequest_Payload

func (*StreamCrunRequest) GetPayloadTaskCompleteReq

func (x *StreamCrunRequest) GetPayloadTaskCompleteReq() *StreamCrunRequest_TaskCompleteReq

func (*StreamCrunRequest) GetPayloadTaskIoForwardReq

func (x *StreamCrunRequest) GetPayloadTaskIoForwardReq() *StreamCrunRequest_TaskIOForwardReq

func (*StreamCrunRequest) GetPayloadTaskReq

func (x *StreamCrunRequest) GetPayloadTaskReq() *StreamCrunRequest_TaskReq

func (*StreamCrunRequest) GetType

func (*StreamCrunRequest) ProtoMessage

func (*StreamCrunRequest) ProtoMessage()

func (*StreamCrunRequest) ProtoReflect

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

func (*StreamCrunRequest) Reset

func (x *StreamCrunRequest) Reset()

func (*StreamCrunRequest) String

func (x *StreamCrunRequest) String() string

type StreamCrunRequest_CrunRequestType

type StreamCrunRequest_CrunRequestType int32
const (
	StreamCrunRequest_TASK_REQUEST            StreamCrunRequest_CrunRequestType = 0
	StreamCrunRequest_TASK_COMPLETION_REQUEST StreamCrunRequest_CrunRequestType = 1
	StreamCrunRequest_TASK_IO_FORWARD         StreamCrunRequest_CrunRequestType = 2
)

func (StreamCrunRequest_CrunRequestType) Descriptor

func (StreamCrunRequest_CrunRequestType) Enum

func (StreamCrunRequest_CrunRequestType) EnumDescriptor deprecated

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

Deprecated: Use StreamCrunRequest_CrunRequestType.Descriptor instead.

func (StreamCrunRequest_CrunRequestType) Number

func (StreamCrunRequest_CrunRequestType) String

func (StreamCrunRequest_CrunRequestType) Type

type StreamCrunRequest_PayloadTaskCompleteReq

type StreamCrunRequest_PayloadTaskCompleteReq struct {
	PayloadTaskCompleteReq *StreamCrunRequest_TaskCompleteReq `protobuf:"bytes,3,opt,name=payload_task_complete_req,json=payloadTaskCompleteReq,proto3,oneof"`
}

type StreamCrunRequest_PayloadTaskIoForwardReq

type StreamCrunRequest_PayloadTaskIoForwardReq struct {
	PayloadTaskIoForwardReq *StreamCrunRequest_TaskIOForwardReq `protobuf:"bytes,4,opt,name=payload_task_io_forward_req,json=payloadTaskIoForwardReq,proto3,oneof"`
}

type StreamCrunRequest_PayloadTaskReq

type StreamCrunRequest_PayloadTaskReq struct {
	PayloadTaskReq *StreamCrunRequest_TaskReq `protobuf:"bytes,2,opt,name=payload_task_req,json=payloadTaskReq,proto3,oneof"`
}

type StreamCrunRequest_TaskCompleteReq

type StreamCrunRequest_TaskCompleteReq struct {
	TaskId uint32     `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Status TaskStatus `protobuf:"varint,2,opt,name=status,proto3,enum=crane.grpc.TaskStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCrunRequest_TaskCompleteReq) Descriptor deprecated

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

Deprecated: Use StreamCrunRequest_TaskCompleteReq.ProtoReflect.Descriptor instead.

func (*StreamCrunRequest_TaskCompleteReq) GetStatus

func (*StreamCrunRequest_TaskCompleteReq) GetTaskId

func (*StreamCrunRequest_TaskCompleteReq) ProtoMessage

func (*StreamCrunRequest_TaskCompleteReq) ProtoMessage()

func (*StreamCrunRequest_TaskCompleteReq) ProtoReflect

func (*StreamCrunRequest_TaskCompleteReq) Reset

func (*StreamCrunRequest_TaskCompleteReq) String

type StreamCrunRequest_TaskIOForwardReq

type StreamCrunRequest_TaskIOForwardReq struct {
	TaskId uint32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCrunRequest_TaskIOForwardReq) Descriptor deprecated

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

Deprecated: Use StreamCrunRequest_TaskIOForwardReq.ProtoReflect.Descriptor instead.

func (*StreamCrunRequest_TaskIOForwardReq) GetMsg

func (*StreamCrunRequest_TaskIOForwardReq) GetTaskId

func (*StreamCrunRequest_TaskIOForwardReq) ProtoMessage

func (*StreamCrunRequest_TaskIOForwardReq) ProtoMessage()

func (*StreamCrunRequest_TaskIOForwardReq) ProtoReflect

func (*StreamCrunRequest_TaskIOForwardReq) Reset

func (*StreamCrunRequest_TaskIOForwardReq) String

type StreamCrunRequest_TaskReq

type StreamCrunRequest_TaskReq struct {
	CrunPid int32       `protobuf:"varint,1,opt,name=crun_pid,json=crunPid,proto3" json:"crun_pid,omitempty"`
	Task    *TaskToCtld `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCrunRequest_TaskReq) Descriptor deprecated

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

Deprecated: Use StreamCrunRequest_TaskReq.ProtoReflect.Descriptor instead.

func (*StreamCrunRequest_TaskReq) GetCrunPid

func (x *StreamCrunRequest_TaskReq) GetCrunPid() int32

func (*StreamCrunRequest_TaskReq) GetTask

func (x *StreamCrunRequest_TaskReq) GetTask() *TaskToCtld

func (*StreamCrunRequest_TaskReq) ProtoMessage

func (*StreamCrunRequest_TaskReq) ProtoMessage()

func (*StreamCrunRequest_TaskReq) ProtoReflect

func (*StreamCrunRequest_TaskReq) Reset

func (x *StreamCrunRequest_TaskReq) Reset()

func (*StreamCrunRequest_TaskReq) String

func (x *StreamCrunRequest_TaskReq) String() string

type StreamCtldReply

type StreamCtldReply struct {
	Type StreamCtldReply_CtldReplyType `protobuf:"varint,1,opt,name=type,proto3,enum=crane.grpc.StreamCtldReply_CtldReplyType" json:"type,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*StreamCtldReply_PayloadCforedRegAck
	//	*StreamCtldReply_PayloadTaskResAllocReply
	//	*StreamCtldReply_PayloadTaskCancelRequest
	//	*StreamCtldReply_PayloadTaskCompletionAck
	//	*StreamCtldReply_PayloadTaskIdReply
	//	*StreamCtldReply_PayloadGracefulExitAck
	Payload isStreamCtldReply_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*StreamCtldReply) Descriptor deprecated

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

Deprecated: Use StreamCtldReply.ProtoReflect.Descriptor instead.

func (*StreamCtldReply) GetPayload

func (m *StreamCtldReply) GetPayload() isStreamCtldReply_Payload

func (*StreamCtldReply) GetPayloadCforedRegAck

func (x *StreamCtldReply) GetPayloadCforedRegAck() *StreamCtldReply_CforedRegistrationAck

func (*StreamCtldReply) GetPayloadGracefulExitAck

func (x *StreamCtldReply) GetPayloadGracefulExitAck() *StreamCtldReply_CforedGracefulExitAck

func (*StreamCtldReply) GetPayloadTaskCancelRequest

func (x *StreamCtldReply) GetPayloadTaskCancelRequest() *StreamCtldReply_TaskCancelRequest

func (*StreamCtldReply) GetPayloadTaskCompletionAck

func (x *StreamCtldReply) GetPayloadTaskCompletionAck() *StreamCtldReply_TaskCompletionAckReply

func (*StreamCtldReply) GetPayloadTaskIdReply

func (x *StreamCtldReply) GetPayloadTaskIdReply() *StreamCtldReply_TaskIdReply

func (*StreamCtldReply) GetPayloadTaskResAllocReply

func (x *StreamCtldReply) GetPayloadTaskResAllocReply() *StreamCtldReply_TaskResAllocatedReply

func (*StreamCtldReply) GetType

func (*StreamCtldReply) ProtoMessage

func (*StreamCtldReply) ProtoMessage()

func (*StreamCtldReply) ProtoReflect

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

func (*StreamCtldReply) Reset

func (x *StreamCtldReply) Reset()

func (*StreamCtldReply) String

func (x *StreamCtldReply) String() string

type StreamCtldReply_CforedGracefulExitAck

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

func (*StreamCtldReply_CforedGracefulExitAck) Descriptor deprecated

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

Deprecated: Use StreamCtldReply_CforedGracefulExitAck.ProtoReflect.Descriptor instead.

func (*StreamCtldReply_CforedGracefulExitAck) GetOk

func (*StreamCtldReply_CforedGracefulExitAck) ProtoMessage

func (*StreamCtldReply_CforedGracefulExitAck) ProtoMessage()

func (*StreamCtldReply_CforedGracefulExitAck) ProtoReflect

func (*StreamCtldReply_CforedGracefulExitAck) Reset

func (*StreamCtldReply_CforedGracefulExitAck) String

type StreamCtldReply_CforedRegistrationAck

type StreamCtldReply_CforedRegistrationAck struct {
	Ok            bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	FailureReason string `protobuf:"bytes,2,opt,name=failure_reason,json=failureReason,proto3" json:"failure_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCtldReply_CforedRegistrationAck) Descriptor deprecated

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

Deprecated: Use StreamCtldReply_CforedRegistrationAck.ProtoReflect.Descriptor instead.

func (*StreamCtldReply_CforedRegistrationAck) GetFailureReason

func (x *StreamCtldReply_CforedRegistrationAck) GetFailureReason() string

func (*StreamCtldReply_CforedRegistrationAck) GetOk

func (*StreamCtldReply_CforedRegistrationAck) ProtoMessage

func (*StreamCtldReply_CforedRegistrationAck) ProtoMessage()

func (*StreamCtldReply_CforedRegistrationAck) ProtoReflect

func (*StreamCtldReply_CforedRegistrationAck) Reset

func (*StreamCtldReply_CforedRegistrationAck) String

type StreamCtldReply_CtldReplyType

type StreamCtldReply_CtldReplyType int32
const (
	StreamCtldReply_TASK_ID_REPLY             StreamCtldReply_CtldReplyType = 0
	StreamCtldReply_TASK_RES_ALLOC_REPLY      StreamCtldReply_CtldReplyType = 1
	StreamCtldReply_TASK_CANCEL_REQUEST       StreamCtldReply_CtldReplyType = 2
	StreamCtldReply_TASK_COMPLETION_ACK_REPLY StreamCtldReply_CtldReplyType = 3
	StreamCtldReply_CFORED_REGISTRATION_ACK   StreamCtldReply_CtldReplyType = 4
	StreamCtldReply_CFORED_GRACEFUL_EXIT_ACK  StreamCtldReply_CtldReplyType = 5
)

func (StreamCtldReply_CtldReplyType) Descriptor

func (StreamCtldReply_CtldReplyType) Enum

func (StreamCtldReply_CtldReplyType) EnumDescriptor deprecated

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

Deprecated: Use StreamCtldReply_CtldReplyType.Descriptor instead.

func (StreamCtldReply_CtldReplyType) Number

func (StreamCtldReply_CtldReplyType) String

func (StreamCtldReply_CtldReplyType) Type

type StreamCtldReply_PayloadCforedRegAck

type StreamCtldReply_PayloadCforedRegAck struct {
	PayloadCforedRegAck *StreamCtldReply_CforedRegistrationAck `protobuf:"bytes,2,opt,name=payload_cfored_reg_ack,json=payloadCforedRegAck,proto3,oneof"`
}

type StreamCtldReply_PayloadGracefulExitAck

type StreamCtldReply_PayloadGracefulExitAck struct {
	PayloadGracefulExitAck *StreamCtldReply_CforedGracefulExitAck `protobuf:"bytes,7,opt,name=payload_graceful_exit_ack,json=payloadGracefulExitAck,proto3,oneof"`
}

type StreamCtldReply_PayloadTaskCancelRequest

type StreamCtldReply_PayloadTaskCancelRequest struct {
	PayloadTaskCancelRequest *StreamCtldReply_TaskCancelRequest `protobuf:"bytes,4,opt,name=payload_task_cancel_request,json=payloadTaskCancelRequest,proto3,oneof"`
}

type StreamCtldReply_PayloadTaskCompletionAck

type StreamCtldReply_PayloadTaskCompletionAck struct {
	PayloadTaskCompletionAck *StreamCtldReply_TaskCompletionAckReply `protobuf:"bytes,5,opt,name=payload_task_completion_ack,json=payloadTaskCompletionAck,proto3,oneof"`
}

type StreamCtldReply_PayloadTaskIdReply

type StreamCtldReply_PayloadTaskIdReply struct {
	PayloadTaskIdReply *StreamCtldReply_TaskIdReply `protobuf:"bytes,6,opt,name=payload_task_id_reply,json=payloadTaskIdReply,proto3,oneof"`
}

type StreamCtldReply_PayloadTaskResAllocReply

type StreamCtldReply_PayloadTaskResAllocReply struct {
	PayloadTaskResAllocReply *StreamCtldReply_TaskResAllocatedReply `protobuf:"bytes,3,opt,name=payload_task_res_alloc_reply,json=payloadTaskResAllocReply,proto3,oneof"`
}

type StreamCtldReply_TaskCancelRequest

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

func (*StreamCtldReply_TaskCancelRequest) Descriptor deprecated

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

Deprecated: Use StreamCtldReply_TaskCancelRequest.ProtoReflect.Descriptor instead.

func (*StreamCtldReply_TaskCancelRequest) GetTaskId

func (*StreamCtldReply_TaskCancelRequest) ProtoMessage

func (*StreamCtldReply_TaskCancelRequest) ProtoMessage()

func (*StreamCtldReply_TaskCancelRequest) ProtoReflect

func (*StreamCtldReply_TaskCancelRequest) Reset

func (*StreamCtldReply_TaskCancelRequest) String

type StreamCtldReply_TaskCompletionAckReply

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

func (*StreamCtldReply_TaskCompletionAckReply) Descriptor deprecated

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

Deprecated: Use StreamCtldReply_TaskCompletionAckReply.ProtoReflect.Descriptor instead.

func (*StreamCtldReply_TaskCompletionAckReply) GetTaskId

func (*StreamCtldReply_TaskCompletionAckReply) ProtoMessage

func (*StreamCtldReply_TaskCompletionAckReply) ProtoReflect

func (*StreamCtldReply_TaskCompletionAckReply) Reset

func (*StreamCtldReply_TaskCompletionAckReply) String

type StreamCtldReply_TaskIdReply

type StreamCtldReply_TaskIdReply struct {
	Pid           int32  `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Ok            bool   `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	TaskId        uint32 `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	FailureReason string `protobuf:"bytes,4,opt,name=failure_reason,json=failureReason,proto3" json:"failure_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCtldReply_TaskIdReply) Descriptor deprecated

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

Deprecated: Use StreamCtldReply_TaskIdReply.ProtoReflect.Descriptor instead.

func (*StreamCtldReply_TaskIdReply) GetFailureReason

func (x *StreamCtldReply_TaskIdReply) GetFailureReason() string

func (*StreamCtldReply_TaskIdReply) GetOk

func (x *StreamCtldReply_TaskIdReply) GetOk() bool

func (*StreamCtldReply_TaskIdReply) GetPid

func (x *StreamCtldReply_TaskIdReply) GetPid() int32

func (*StreamCtldReply_TaskIdReply) GetTaskId

func (x *StreamCtldReply_TaskIdReply) GetTaskId() uint32

func (*StreamCtldReply_TaskIdReply) ProtoMessage

func (*StreamCtldReply_TaskIdReply) ProtoMessage()

func (*StreamCtldReply_TaskIdReply) ProtoReflect

func (*StreamCtldReply_TaskIdReply) Reset

func (x *StreamCtldReply_TaskIdReply) Reset()

func (*StreamCtldReply_TaskIdReply) String

func (x *StreamCtldReply_TaskIdReply) String() string

type StreamCtldReply_TaskResAllocatedReply

type StreamCtldReply_TaskResAllocatedReply struct {
	TaskId               uint32   `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Ok                   bool     `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	AllocatedCranedRegex string   `protobuf:"bytes,3,opt,name=allocated_craned_regex,json=allocatedCranedRegex,proto3" json:"allocated_craned_regex,omitempty"`
	FailureReason        string   `protobuf:"bytes,4,opt,name=failure_reason,json=failureReason,proto3" json:"failure_reason,omitempty"`
	CranedIds            []string `protobuf:"bytes,5,rep,name=craned_ids,json=cranedIds,proto3" json:"craned_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCtldReply_TaskResAllocatedReply) Descriptor deprecated

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

Deprecated: Use StreamCtldReply_TaskResAllocatedReply.ProtoReflect.Descriptor instead.

func (*StreamCtldReply_TaskResAllocatedReply) GetAllocatedCranedRegex

func (x *StreamCtldReply_TaskResAllocatedReply) GetAllocatedCranedRegex() string

func (*StreamCtldReply_TaskResAllocatedReply) GetCranedIds

func (x *StreamCtldReply_TaskResAllocatedReply) GetCranedIds() []string

func (*StreamCtldReply_TaskResAllocatedReply) GetFailureReason

func (x *StreamCtldReply_TaskResAllocatedReply) GetFailureReason() string

func (*StreamCtldReply_TaskResAllocatedReply) GetOk

func (*StreamCtldReply_TaskResAllocatedReply) GetTaskId

func (*StreamCtldReply_TaskResAllocatedReply) ProtoMessage

func (*StreamCtldReply_TaskResAllocatedReply) ProtoMessage()

func (*StreamCtldReply_TaskResAllocatedReply) ProtoReflect

func (*StreamCtldReply_TaskResAllocatedReply) Reset

func (*StreamCtldReply_TaskResAllocatedReply) String

type SubmitBatchTaskReply

type SubmitBatchTaskReply struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*SubmitBatchTaskReply_TaskId
	//	*SubmitBatchTaskReply_Reason
	Payload isSubmitBatchTaskReply_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*SubmitBatchTaskReply) Descriptor deprecated

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

Deprecated: Use SubmitBatchTaskReply.ProtoReflect.Descriptor instead.

func (*SubmitBatchTaskReply) GetOk

func (x *SubmitBatchTaskReply) GetOk() bool

func (*SubmitBatchTaskReply) GetPayload

func (m *SubmitBatchTaskReply) GetPayload() isSubmitBatchTaskReply_Payload

func (*SubmitBatchTaskReply) GetReason

func (x *SubmitBatchTaskReply) GetReason() string

func (*SubmitBatchTaskReply) GetTaskId

func (x *SubmitBatchTaskReply) GetTaskId() uint32

func (*SubmitBatchTaskReply) ProtoMessage

func (*SubmitBatchTaskReply) ProtoMessage()

func (*SubmitBatchTaskReply) ProtoReflect

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

func (*SubmitBatchTaskReply) Reset

func (x *SubmitBatchTaskReply) Reset()

func (*SubmitBatchTaskReply) String

func (x *SubmitBatchTaskReply) String() string

type SubmitBatchTaskReply_Reason

type SubmitBatchTaskReply_Reason struct {
	Reason string `protobuf:"bytes,3,opt,name=reason,proto3,oneof"`
}

type SubmitBatchTaskReply_TaskId

type SubmitBatchTaskReply_TaskId struct {
	TaskId uint32 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3,oneof"`
}

type SubmitBatchTaskRequest

type SubmitBatchTaskRequest struct {
	Task *TaskToCtld `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitBatchTaskRequest) Descriptor deprecated

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

Deprecated: Use SubmitBatchTaskRequest.ProtoReflect.Descriptor instead.

func (*SubmitBatchTaskRequest) GetTask

func (x *SubmitBatchTaskRequest) GetTask() *TaskToCtld

func (*SubmitBatchTaskRequest) ProtoMessage

func (*SubmitBatchTaskRequest) ProtoMessage()

func (*SubmitBatchTaskRequest) ProtoReflect

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

func (*SubmitBatchTaskRequest) Reset

func (x *SubmitBatchTaskRequest) Reset()

func (*SubmitBatchTaskRequest) String

func (x *SubmitBatchTaskRequest) String() string

type SubmitBatchTasksReply

type SubmitBatchTasksReply struct {
	TaskIdList []uint32 `protobuf:"varint,1,rep,packed,name=task_id_list,json=taskIdList,proto3" json:"task_id_list,omitempty"`
	ReasonList []string `protobuf:"bytes,2,rep,name=reason_list,json=reasonList,proto3" json:"reason_list,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitBatchTasksReply) Descriptor deprecated

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

Deprecated: Use SubmitBatchTasksReply.ProtoReflect.Descriptor instead.

func (*SubmitBatchTasksReply) GetReasonList

func (x *SubmitBatchTasksReply) GetReasonList() []string

func (*SubmitBatchTasksReply) GetTaskIdList

func (x *SubmitBatchTasksReply) GetTaskIdList() []uint32

func (*SubmitBatchTasksReply) ProtoMessage

func (*SubmitBatchTasksReply) ProtoMessage()

func (*SubmitBatchTasksReply) ProtoReflect

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

func (*SubmitBatchTasksReply) Reset

func (x *SubmitBatchTasksReply) Reset()

func (*SubmitBatchTasksReply) String

func (x *SubmitBatchTasksReply) String() string

type SubmitBatchTasksRequest

type SubmitBatchTasksRequest struct {
	Task  *TaskToCtld `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Count uint32      `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitBatchTasksRequest) Descriptor deprecated

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

Deprecated: Use SubmitBatchTasksRequest.ProtoReflect.Descriptor instead.

func (*SubmitBatchTasksRequest) GetCount

func (x *SubmitBatchTasksRequest) GetCount() uint32

func (*SubmitBatchTasksRequest) GetTask

func (x *SubmitBatchTasksRequest) GetTask() *TaskToCtld

func (*SubmitBatchTasksRequest) ProtoMessage

func (*SubmitBatchTasksRequest) ProtoMessage()

func (*SubmitBatchTasksRequest) ProtoReflect

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

func (*SubmitBatchTasksRequest) Reset

func (x *SubmitBatchTasksRequest) Reset()

func (*SubmitBatchTasksRequest) String

func (x *SubmitBatchTasksRequest) String() string

type SystemRelInfo

type SystemRelInfo struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Release string `protobuf:"bytes,2,opt,name=release,proto3" json:"release,omitempty"`
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*SystemRelInfo) Descriptor deprecated

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

Deprecated: Use SystemRelInfo.ProtoReflect.Descriptor instead.

func (*SystemRelInfo) GetName

func (x *SystemRelInfo) GetName() string

func (*SystemRelInfo) GetRelease

func (x *SystemRelInfo) GetRelease() string

func (*SystemRelInfo) GetVersion

func (x *SystemRelInfo) GetVersion() string

func (*SystemRelInfo) ProtoMessage

func (*SystemRelInfo) ProtoMessage()

func (*SystemRelInfo) ProtoReflect

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

func (*SystemRelInfo) Reset

func (x *SystemRelInfo) Reset()

func (*SystemRelInfo) String

func (x *SystemRelInfo) String() string

type TaskInEmbeddedDb

type TaskInEmbeddedDb struct {
	RuntimeAttr *RuntimeAttrOfTask `protobuf:"bytes,1,opt,name=runtime_attr,json=runtimeAttr,proto3" json:"runtime_attr,omitempty"`
	TaskToCtld  *TaskToCtld        `protobuf:"bytes,2,opt,name=task_to_ctld,json=taskToCtld,proto3" json:"task_to_ctld,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskInEmbeddedDb) Descriptor deprecated

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

Deprecated: Use TaskInEmbeddedDb.ProtoReflect.Descriptor instead.

func (*TaskInEmbeddedDb) GetRuntimeAttr

func (x *TaskInEmbeddedDb) GetRuntimeAttr() *RuntimeAttrOfTask

func (*TaskInEmbeddedDb) GetTaskToCtld

func (x *TaskInEmbeddedDb) GetTaskToCtld() *TaskToCtld

func (*TaskInEmbeddedDb) ProtoMessage

func (*TaskInEmbeddedDb) ProtoMessage()

func (*TaskInEmbeddedDb) ProtoReflect

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

func (*TaskInEmbeddedDb) Reset

func (x *TaskInEmbeddedDb) Reset()

func (*TaskInEmbeddedDb) String

func (x *TaskInEmbeddedDb) String() string

type TaskInfo

type TaskInfo struct {

	// Static task information
	Type         TaskType               `protobuf:"varint,1,opt,name=type,proto3,enum=crane.grpc.TaskType" json:"type,omitempty"`
	TaskId       uint32                 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Name         string                 `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Partition    string                 `protobuf:"bytes,4,opt,name=partition,proto3" json:"partition,omitempty"`
	Uid          uint32                 `protobuf:"varint,5,opt,name=uid,proto3" json:"uid,omitempty"`
	Gid          uint32                 `protobuf:"varint,6,opt,name=gid,proto3" json:"gid,omitempty"`
	TimeLimit    *durationpb.Duration   `protobuf:"bytes,7,opt,name=time_limit,json=timeLimit,proto3" json:"time_limit,omitempty"`
	StartTime    *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime      *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	SubmitTime   *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=submit_time,json=submitTime,proto3" json:"submit_time,omitempty"`
	Account      string                 `protobuf:"bytes,11,opt,name=account,proto3" json:"account,omitempty"`
	NodeNum      uint32                 `protobuf:"varint,12,opt,name=node_num,json=nodeNum,proto3" json:"node_num,omitempty"`
	CmdLine      string                 `protobuf:"bytes,13,opt,name=cmd_line,json=cmdLine,proto3" json:"cmd_line,omitempty"`
	Cwd          string                 `protobuf:"bytes,14,opt,name=cwd,proto3" json:"cwd,omitempty"`
	Username     string                 `protobuf:"bytes,15,opt,name=username,proto3" json:"username,omitempty"`
	Qos          string                 `protobuf:"bytes,16,opt,name=qos,proto3" json:"qos,omitempty"`
	ResView      *ResourceView          `protobuf:"bytes,17,opt,name=res_view,json=resView,proto3" json:"res_view,omitempty"`
	ReqNodes     []string               `protobuf:"bytes,19,rep,name=req_nodes,json=reqNodes,proto3" json:"req_nodes,omitempty"`
	ExcludeNodes []string               `protobuf:"bytes,20,rep,name=exclude_nodes,json=excludeNodes,proto3" json:"exclude_nodes,omitempty"`
	ExtraAttr    string                 `protobuf:"bytes,21,opt,name=extra_attr,json=extraAttr,proto3" json:"extra_attr,omitempty"`
	// Dynamic task information
	Held     bool       `protobuf:"varint,30,opt,name=held,proto3" json:"held,omitempty"`
	Status   TaskStatus `protobuf:"varint,31,opt,name=status,proto3,enum=crane.grpc.TaskStatus" json:"status,omitempty"`
	ExitCode uint32     `protobuf:"varint,33,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Priority uint32     `protobuf:"varint,34,opt,name=priority,proto3" json:"priority,omitempty"`
	// Types that are assignable to PendingReasonOrCranedList:
	//
	//	*TaskInfo_PendingReason
	//	*TaskInfo_CranedList
	PendingReasonOrCranedList isTaskInfo_PendingReasonOrCranedList `protobuf_oneof:"pending_reason_or_craned_list"`
	// The time of different nodes across the whole cluster might not always be synchronized.
	// If the time on the front end node is more than several seconds ahead of the CraneCtld node,
	// a negative elapsed time might occur.
	// To avoid this, the elapsed time of a task is calculated on the CraneCtld side.
	ElapsedTime   *durationpb.Duration `protobuf:"bytes,37,opt,name=elapsed_time,json=elapsedTime,proto3" json:"elapsed_time,omitempty"`
	ExecutionNode []string             `protobuf:"bytes,38,rep,name=execution_node,json=executionNode,proto3" json:"execution_node,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskInfo) Descriptor deprecated

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

Deprecated: Use TaskInfo.ProtoReflect.Descriptor instead.

func (*TaskInfo) GetAccount

func (x *TaskInfo) GetAccount() string

func (*TaskInfo) GetCmdLine

func (x *TaskInfo) GetCmdLine() string

func (*TaskInfo) GetCranedList

func (x *TaskInfo) GetCranedList() string

func (*TaskInfo) GetCwd

func (x *TaskInfo) GetCwd() string

func (*TaskInfo) GetElapsedTime

func (x *TaskInfo) GetElapsedTime() *durationpb.Duration

func (*TaskInfo) GetEndTime

func (x *TaskInfo) GetEndTime() *timestamppb.Timestamp

func (*TaskInfo) GetExcludeNodes

func (x *TaskInfo) GetExcludeNodes() []string

func (*TaskInfo) GetExecutionNode

func (x *TaskInfo) GetExecutionNode() []string

func (*TaskInfo) GetExitCode

func (x *TaskInfo) GetExitCode() uint32

func (*TaskInfo) GetExtraAttr

func (x *TaskInfo) GetExtraAttr() string

func (*TaskInfo) GetGid

func (x *TaskInfo) GetGid() uint32

func (*TaskInfo) GetHeld

func (x *TaskInfo) GetHeld() bool

func (*TaskInfo) GetName

func (x *TaskInfo) GetName() string

func (*TaskInfo) GetNodeNum

func (x *TaskInfo) GetNodeNum() uint32

func (*TaskInfo) GetPartition

func (x *TaskInfo) GetPartition() string

func (*TaskInfo) GetPendingReason

func (x *TaskInfo) GetPendingReason() string

func (*TaskInfo) GetPendingReasonOrCranedList

func (m *TaskInfo) GetPendingReasonOrCranedList() isTaskInfo_PendingReasonOrCranedList

func (*TaskInfo) GetPriority

func (x *TaskInfo) GetPriority() uint32

func (*TaskInfo) GetQos

func (x *TaskInfo) GetQos() string

func (*TaskInfo) GetReqNodes

func (x *TaskInfo) GetReqNodes() []string

func (*TaskInfo) GetResView

func (x *TaskInfo) GetResView() *ResourceView

func (*TaskInfo) GetStartTime

func (x *TaskInfo) GetStartTime() *timestamppb.Timestamp

func (*TaskInfo) GetStatus

func (x *TaskInfo) GetStatus() TaskStatus

func (*TaskInfo) GetSubmitTime

func (x *TaskInfo) GetSubmitTime() *timestamppb.Timestamp

func (*TaskInfo) GetTaskId

func (x *TaskInfo) GetTaskId() uint32

func (*TaskInfo) GetTimeLimit

func (x *TaskInfo) GetTimeLimit() *durationpb.Duration

func (*TaskInfo) GetType

func (x *TaskInfo) GetType() TaskType

func (*TaskInfo) GetUid

func (x *TaskInfo) GetUid() uint32

func (*TaskInfo) GetUsername

func (x *TaskInfo) GetUsername() string

func (*TaskInfo) ProtoMessage

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) ProtoReflect

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

func (*TaskInfo) Reset

func (x *TaskInfo) Reset()

func (*TaskInfo) String

func (x *TaskInfo) String() string

type TaskInfo_CranedList

type TaskInfo_CranedList struct {
	CranedList string `protobuf:"bytes,36,opt,name=craned_list,json=cranedList,proto3,oneof"`
}

type TaskInfo_PendingReason

type TaskInfo_PendingReason struct {
	PendingReason string `protobuf:"bytes,35,opt,name=pending_reason,json=pendingReason,proto3,oneof"`
}

type TaskStatus

type TaskStatus int32
const (
	TaskStatus_Pending         TaskStatus = 0
	TaskStatus_Running         TaskStatus = 1
	TaskStatus_Completed       TaskStatus = 2
	TaskStatus_Failed          TaskStatus = 3
	TaskStatus_ExceedTimeLimit TaskStatus = 4
	TaskStatus_Cancelled       TaskStatus = 5
	TaskStatus_Invalid         TaskStatus = 15
)

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

type TaskStatusChangeReply

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

func (*TaskStatusChangeReply) Descriptor deprecated

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

Deprecated: Use TaskStatusChangeReply.ProtoReflect.Descriptor instead.

func (*TaskStatusChangeReply) GetOk

func (x *TaskStatusChangeReply) GetOk() bool

func (*TaskStatusChangeReply) ProtoMessage

func (*TaskStatusChangeReply) ProtoMessage()

func (*TaskStatusChangeReply) ProtoReflect

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

func (*TaskStatusChangeReply) Reset

func (x *TaskStatusChangeReply) Reset()

func (*TaskStatusChangeReply) String

func (x *TaskStatusChangeReply) String() string

type TaskStatusChangeRequest

type TaskStatusChangeRequest struct {
	TaskId    uint32     `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	CranedId  string     `protobuf:"bytes,2,opt,name=craned_id,json=cranedId,proto3" json:"craned_id,omitempty"`
	NewStatus TaskStatus `protobuf:"varint,3,opt,name=new_status,json=newStatus,proto3,enum=crane.grpc.TaskStatus" json:"new_status,omitempty"`
	ExitCode  uint32     `protobuf:"varint,4,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Reason    string     `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskStatusChangeRequest) Descriptor deprecated

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

Deprecated: Use TaskStatusChangeRequest.ProtoReflect.Descriptor instead.

func (*TaskStatusChangeRequest) GetCranedId

func (x *TaskStatusChangeRequest) GetCranedId() string

func (*TaskStatusChangeRequest) GetExitCode

func (x *TaskStatusChangeRequest) GetExitCode() uint32

func (*TaskStatusChangeRequest) GetNewStatus

func (x *TaskStatusChangeRequest) GetNewStatus() TaskStatus

func (*TaskStatusChangeRequest) GetReason

func (x *TaskStatusChangeRequest) GetReason() string

func (*TaskStatusChangeRequest) GetTaskId

func (x *TaskStatusChangeRequest) GetTaskId() uint32

func (*TaskStatusChangeRequest) ProtoMessage

func (*TaskStatusChangeRequest) ProtoMessage()

func (*TaskStatusChangeRequest) ProtoReflect

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

func (*TaskStatusChangeRequest) Reset

func (x *TaskStatusChangeRequest) Reset()

func (*TaskStatusChangeRequest) String

func (x *TaskStatusChangeRequest) String() string

type TaskToCtld

type TaskToCtld struct {

	// -------- Fields that are set at the submission time. -------
	TimeLimit       *durationpb.Duration `protobuf:"bytes,1,opt,name=time_limit,json=timeLimit,proto3" json:"time_limit,omitempty"`
	PartitionName   string               `protobuf:"bytes,2,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	Resources       *ResourceView        `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"`
	Type            TaskType             `protobuf:"varint,4,opt,name=type,proto3,enum=crane.grpc.TaskType" json:"type,omitempty"`
	Uid             uint32               `protobuf:"varint,5,opt,name=uid,proto3" json:"uid,omitempty"`
	Account         string               `protobuf:"bytes,6,opt,name=account,proto3" json:"account,omitempty"`
	Name            string               `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	Qos             string               `protobuf:"bytes,8,opt,name=qos,proto3" json:"qos,omitempty"`
	NodeNum         uint32               `protobuf:"varint,9,opt,name=node_num,json=nodeNum,proto3" json:"node_num,omitempty"`
	NtasksPerNode   uint32               `protobuf:"varint,10,opt,name=ntasks_per_node,json=ntasksPerNode,proto3" json:"ntasks_per_node,omitempty"`
	CpusPerTask     float64              `protobuf:"fixed64,11,opt,name=cpus_per_task,json=cpusPerTask,proto3" json:"cpus_per_task,omitempty"`
	RequeueIfFailed bool                 `protobuf:"varint,12,opt,name=requeue_if_failed,json=requeueIfFailed,proto3" json:"requeue_if_failed,omitempty"`
	GetUserEnv      bool                 `protobuf:"varint,13,opt,name=get_user_env,json=getUserEnv,proto3" json:"get_user_env,omitempty"`
	Gid             uint32               `protobuf:"varint,14,opt,name=gid,proto3" json:"gid,omitempty"` // egid
	// Types that are assignable to Payload:
	//
	//	*TaskToCtld_BatchMeta
	//	*TaskToCtld_InteractiveMeta
	Payload   isTaskToCtld_Payload `protobuf_oneof:"payload"`
	ExtraAttr string               `protobuf:"bytes,23,opt,name=extra_attr,json=extraAttr,proto3" json:"extra_attr,omitempty"`
	CmdLine   string               `protobuf:"bytes,31,opt,name=cmd_line,json=cmdLine,proto3" json:"cmd_line,omitempty"`
	Cwd       string               `protobuf:"bytes,32,opt,name=cwd,proto3" json:"cwd,omitempty"` // Current working directory
	Env       map[string]string    ``                                                             /* 148-byte string literal not displayed */
	Excludes  string               `protobuf:"bytes,34,opt,name=excludes,proto3" json:"excludes,omitempty"`
	Nodelist  string               `protobuf:"bytes,35,opt,name=nodelist,proto3" json:"nodelist,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskToCtld) Descriptor deprecated

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

Deprecated: Use TaskToCtld.ProtoReflect.Descriptor instead.

func (*TaskToCtld) GetAccount

func (x *TaskToCtld) GetAccount() string

func (*TaskToCtld) GetBatchMeta

func (x *TaskToCtld) GetBatchMeta() *BatchTaskAdditionalMeta

func (*TaskToCtld) GetCmdLine

func (x *TaskToCtld) GetCmdLine() string

func (*TaskToCtld) GetCpusPerTask

func (x *TaskToCtld) GetCpusPerTask() float64

func (*TaskToCtld) GetCwd

func (x *TaskToCtld) GetCwd() string

func (*TaskToCtld) GetEnv

func (x *TaskToCtld) GetEnv() map[string]string

func (*TaskToCtld) GetExcludes

func (x *TaskToCtld) GetExcludes() string

func (*TaskToCtld) GetExtraAttr

func (x *TaskToCtld) GetExtraAttr() string

func (*TaskToCtld) GetGetUserEnv

func (x *TaskToCtld) GetGetUserEnv() bool

func (*TaskToCtld) GetGid

func (x *TaskToCtld) GetGid() uint32

func (*TaskToCtld) GetInteractiveMeta

func (x *TaskToCtld) GetInteractiveMeta() *InteractiveTaskAdditionalMeta

func (*TaskToCtld) GetName

func (x *TaskToCtld) GetName() string

func (*TaskToCtld) GetNodeNum

func (x *TaskToCtld) GetNodeNum() uint32

func (*TaskToCtld) GetNodelist

func (x *TaskToCtld) GetNodelist() string

func (*TaskToCtld) GetNtasksPerNode

func (x *TaskToCtld) GetNtasksPerNode() uint32

func (*TaskToCtld) GetPartitionName

func (x *TaskToCtld) GetPartitionName() string

func (*TaskToCtld) GetPayload

func (m *TaskToCtld) GetPayload() isTaskToCtld_Payload

func (*TaskToCtld) GetQos

func (x *TaskToCtld) GetQos() string

func (*TaskToCtld) GetRequeueIfFailed

func (x *TaskToCtld) GetRequeueIfFailed() bool

func (*TaskToCtld) GetResources

func (x *TaskToCtld) GetResources() *ResourceView

func (*TaskToCtld) GetTimeLimit

func (x *TaskToCtld) GetTimeLimit() *durationpb.Duration

func (*TaskToCtld) GetType

func (x *TaskToCtld) GetType() TaskType

func (*TaskToCtld) GetUid

func (x *TaskToCtld) GetUid() uint32

func (*TaskToCtld) ProtoMessage

func (*TaskToCtld) ProtoMessage()

func (*TaskToCtld) ProtoReflect

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

func (*TaskToCtld) Reset

func (x *TaskToCtld) Reset()

func (*TaskToCtld) String

func (x *TaskToCtld) String() string

type TaskToCtld_BatchMeta

type TaskToCtld_BatchMeta struct {
	BatchMeta *BatchTaskAdditionalMeta `protobuf:"bytes,21,opt,name=batch_meta,json=batchMeta,proto3,oneof"`
}

type TaskToCtld_InteractiveMeta

type TaskToCtld_InteractiveMeta struct {
	InteractiveMeta *InteractiveTaskAdditionalMeta `protobuf:"bytes,22,opt,name=interactive_meta,json=interactiveMeta,proto3,oneof"`
}

type TaskToD

type TaskToD struct {
	TaskId      uint32          `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Type        TaskType        `protobuf:"varint,2,opt,name=type,proto3,enum=crane.grpc.TaskType" json:"type,omitempty"`
	PartitionId uint32          `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	Resources   *ResourceInNode `protobuf:"bytes,4,opt,name=resources,proto3" json:"resources,omitempty"`
	// If this task is PENDING, start_time is either not set (default constructed)
	// or an estimated start time.
	// If this task is RUNNING, start_time is the actual starting time.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // Currently Only used in CraneCtld
	TimeLimit *durationpb.Duration   `protobuf:"bytes,6,opt,name=time_limit,json=timeLimit,proto3" json:"time_limit,omitempty"`
	Partition string                 `protobuf:"bytes,8,opt,name=partition,proto3" json:"partition,omitempty"`
	Uid       uint32                 `protobuf:"varint,9,opt,name=uid,proto3" json:"uid,omitempty"`
	Gid       uint32                 `protobuf:"varint,10,opt,name=gid,proto3" json:"gid,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*TaskToD_BatchMeta
	//	*TaskToD_InteractiveMeta
	Payload        isTaskToD_Payload `protobuf_oneof:"payload"`
	Env            map[string]string `` /* 148-byte string literal not displayed */
	Cwd            string            `protobuf:"bytes,14,opt,name=cwd,proto3" json:"cwd,omitempty"`
	AllocatedNodes []string          `protobuf:"bytes,15,rep,name=allocated_nodes,json=allocatedNodes,proto3" json:"allocated_nodes,omitempty"`
	Name           string            `protobuf:"bytes,16,opt,name=name,proto3" json:"name,omitempty"`
	Account        string            `protobuf:"bytes,17,opt,name=account,proto3" json:"account,omitempty"`
	Qos            string            `protobuf:"bytes,18,opt,name=qos,proto3" json:"qos,omitempty"`
	Excludes       []string          `protobuf:"bytes,19,rep,name=excludes,proto3" json:"excludes,omitempty"`
	Nodelist       []string          `protobuf:"bytes,20,rep,name=nodelist,proto3" json:"nodelist,omitempty"`
	NodeNum        uint32            `protobuf:"varint,21,opt,name=node_num,json=nodeNum,proto3" json:"node_num,omitempty"`
	NtasksPerNode  uint32            `protobuf:"varint,22,opt,name=ntasks_per_node,json=ntasksPerNode,proto3" json:"ntasks_per_node,omitempty"`
	CpusPerTask    float64           `protobuf:"fixed64,23,opt,name=cpus_per_task,json=cpusPerTask,proto3" json:"cpus_per_task,omitempty"`
	GetUserEnv     bool              `protobuf:"varint,24,opt,name=get_user_env,json=getUserEnv,proto3" json:"get_user_env,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskToD) Descriptor deprecated

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

Deprecated: Use TaskToD.ProtoReflect.Descriptor instead.

func (*TaskToD) GetAccount

func (x *TaskToD) GetAccount() string

func (*TaskToD) GetAllocatedNodes

func (x *TaskToD) GetAllocatedNodes() []string

func (*TaskToD) GetBatchMeta

func (x *TaskToD) GetBatchMeta() *BatchTaskAdditionalMeta

func (*TaskToD) GetCpusPerTask

func (x *TaskToD) GetCpusPerTask() float64

func (*TaskToD) GetCwd

func (x *TaskToD) GetCwd() string

func (*TaskToD) GetEnv

func (x *TaskToD) GetEnv() map[string]string

func (*TaskToD) GetExcludes

func (x *TaskToD) GetExcludes() []string

func (*TaskToD) GetGetUserEnv

func (x *TaskToD) GetGetUserEnv() bool

func (*TaskToD) GetGid

func (x *TaskToD) GetGid() uint32

func (*TaskToD) GetInteractiveMeta

func (x *TaskToD) GetInteractiveMeta() *InteractiveTaskAdditionalMeta

func (*TaskToD) GetName

func (x *TaskToD) GetName() string

func (*TaskToD) GetNodeNum

func (x *TaskToD) GetNodeNum() uint32

func (*TaskToD) GetNodelist

func (x *TaskToD) GetNodelist() []string

func (*TaskToD) GetNtasksPerNode

func (x *TaskToD) GetNtasksPerNode() uint32

func (*TaskToD) GetPartition

func (x *TaskToD) GetPartition() string

func (*TaskToD) GetPartitionId

func (x *TaskToD) GetPartitionId() uint32

func (*TaskToD) GetPayload

func (m *TaskToD) GetPayload() isTaskToD_Payload

func (*TaskToD) GetQos

func (x *TaskToD) GetQos() string

func (*TaskToD) GetResources

func (x *TaskToD) GetResources() *ResourceInNode

func (*TaskToD) GetStartTime

func (x *TaskToD) GetStartTime() *timestamppb.Timestamp

func (*TaskToD) GetTaskId

func (x *TaskToD) GetTaskId() uint32

func (*TaskToD) GetTimeLimit

func (x *TaskToD) GetTimeLimit() *durationpb.Duration

func (*TaskToD) GetType

func (x *TaskToD) GetType() TaskType

func (*TaskToD) GetUid

func (x *TaskToD) GetUid() uint32

func (*TaskToD) ProtoMessage

func (*TaskToD) ProtoMessage()

func (*TaskToD) ProtoReflect

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

func (*TaskToD) Reset

func (x *TaskToD) Reset()

func (*TaskToD) String

func (x *TaskToD) String() string

type TaskToD_BatchMeta

type TaskToD_BatchMeta struct {
	BatchMeta *BatchTaskAdditionalMeta `protobuf:"bytes,11,opt,name=batch_meta,json=batchMeta,proto3,oneof"`
}

type TaskToD_InteractiveMeta

type TaskToD_InteractiveMeta struct {
	InteractiveMeta *InteractiveTaskAdditionalMeta `protobuf:"bytes,12,opt,name=interactive_meta,json=interactiveMeta,proto3,oneof"`
}

type TaskType

type TaskType int32
const (
	TaskType_Interactive TaskType = 0
	TaskType_Batch       TaskType = 1
)

func (TaskType) Descriptor

func (TaskType) Descriptor() protoreflect.EnumDescriptor

func (TaskType) Enum

func (x TaskType) Enum() *TaskType

func (TaskType) EnumDescriptor deprecated

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

Deprecated: Use TaskType.Descriptor instead.

func (TaskType) Number

func (x TaskType) Number() protoreflect.EnumNumber

func (TaskType) String

func (x TaskType) String() string

func (TaskType) Type

type TerminateOrphanedTaskReply

type TerminateOrphanedTaskReply struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateOrphanedTaskReply) Descriptor deprecated

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

Deprecated: Use TerminateOrphanedTaskReply.ProtoReflect.Descriptor instead.

func (*TerminateOrphanedTaskReply) GetOk

func (x *TerminateOrphanedTaskReply) GetOk() bool

func (*TerminateOrphanedTaskReply) GetReason

func (x *TerminateOrphanedTaskReply) GetReason() string

func (*TerminateOrphanedTaskReply) ProtoMessage

func (*TerminateOrphanedTaskReply) ProtoMessage()

func (*TerminateOrphanedTaskReply) ProtoReflect

func (*TerminateOrphanedTaskReply) Reset

func (x *TerminateOrphanedTaskReply) Reset()

func (*TerminateOrphanedTaskReply) String

func (x *TerminateOrphanedTaskReply) String() string

type TerminateOrphanedTaskRequest

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

func (*TerminateOrphanedTaskRequest) Descriptor deprecated

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

Deprecated: Use TerminateOrphanedTaskRequest.ProtoReflect.Descriptor instead.

func (*TerminateOrphanedTaskRequest) GetTaskId

func (x *TerminateOrphanedTaskRequest) GetTaskId() uint32

func (*TerminateOrphanedTaskRequest) ProtoMessage

func (*TerminateOrphanedTaskRequest) ProtoMessage()

func (*TerminateOrphanedTaskRequest) ProtoReflect

func (*TerminateOrphanedTaskRequest) Reset

func (x *TerminateOrphanedTaskRequest) Reset()

func (*TerminateOrphanedTaskRequest) String

type TerminateTasksReply

type TerminateTasksReply struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateTasksReply) Descriptor deprecated

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

Deprecated: Use TerminateTasksReply.ProtoReflect.Descriptor instead.

func (*TerminateTasksReply) GetOk

func (x *TerminateTasksReply) GetOk() bool

func (*TerminateTasksReply) GetReason

func (x *TerminateTasksReply) GetReason() string

func (*TerminateTasksReply) ProtoMessage

func (*TerminateTasksReply) ProtoMessage()

func (*TerminateTasksReply) ProtoReflect

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

func (*TerminateTasksReply) Reset

func (x *TerminateTasksReply) Reset()

func (*TerminateTasksReply) String

func (x *TerminateTasksReply) String() string

type TerminateTasksRequest

type TerminateTasksRequest struct {
	TaskIdList []uint32 `protobuf:"varint,1,rep,packed,name=task_id_list,json=taskIdList,proto3" json:"task_id_list,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateTasksRequest) Descriptor deprecated

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

Deprecated: Use TerminateTasksRequest.ProtoReflect.Descriptor instead.

func (*TerminateTasksRequest) GetTaskIdList

func (x *TerminateTasksRequest) GetTaskIdList() []uint32

func (*TerminateTasksRequest) ProtoMessage

func (*TerminateTasksRequest) ProtoMessage()

func (*TerminateTasksRequest) ProtoReflect

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

func (*TerminateTasksRequest) Reset

func (x *TerminateTasksRequest) Reset()

func (*TerminateTasksRequest) String

func (x *TerminateTasksRequest) String() string

type TimeInterval

type TimeInterval struct {
	LowerBound *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=lower_bound,json=lowerBound,proto3" json:"lower_bound,omitempty"`
	UpperBound *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=upper_bound,json=upperBound,proto3" json:"upper_bound,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeInterval) Descriptor deprecated

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

Deprecated: Use TimeInterval.ProtoReflect.Descriptor instead.

func (*TimeInterval) GetLowerBound

func (x *TimeInterval) GetLowerBound() *timestamppb.Timestamp

func (*TimeInterval) GetUpperBound

func (x *TimeInterval) GetUpperBound() *timestamppb.Timestamp

func (*TimeInterval) ProtoMessage

func (*TimeInterval) ProtoMessage()

func (*TimeInterval) ProtoReflect

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

func (*TimeInterval) Reset

func (x *TimeInterval) Reset()

func (*TimeInterval) String

func (x *TimeInterval) String() string

type TrimmedPartitionInfo

type TrimmedPartitionInfo struct {
	Name        string                                    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	State       PartitionState                            `protobuf:"varint,2,opt,name=state,proto3,enum=crane.grpc.PartitionState" json:"state,omitempty"`
	CranedLists []*TrimmedPartitionInfo_TrimmedCranedInfo `protobuf:"bytes,3,rep,name=craned_lists,json=cranedLists,proto3" json:"craned_lists,omitempty"`
	// contains filtered or unexported fields
}

func (*TrimmedPartitionInfo) Descriptor deprecated

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

Deprecated: Use TrimmedPartitionInfo.ProtoReflect.Descriptor instead.

func (*TrimmedPartitionInfo) GetCranedLists

func (*TrimmedPartitionInfo) GetName

func (x *TrimmedPartitionInfo) GetName() string

func (*TrimmedPartitionInfo) GetState

func (x *TrimmedPartitionInfo) GetState() PartitionState

func (*TrimmedPartitionInfo) ProtoMessage

func (*TrimmedPartitionInfo) ProtoMessage()

func (*TrimmedPartitionInfo) ProtoReflect

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

func (*TrimmedPartitionInfo) Reset

func (x *TrimmedPartitionInfo) Reset()

func (*TrimmedPartitionInfo) String

func (x *TrimmedPartitionInfo) String() string

type TrimmedPartitionInfo_TrimmedCranedInfo

type TrimmedPartitionInfo_TrimmedCranedInfo struct {
	ResourceState   CranedResourceState `` /* 137-byte string literal not displayed */
	ControlState    CranedControlState  `` /* 133-byte string literal not displayed */
	Count           uint32              `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	CranedListRegex string              `protobuf:"bytes,4,opt,name=craned_list_regex,json=cranedListRegex,proto3" json:"craned_list_regex,omitempty"`
	// contains filtered or unexported fields
}

func (*TrimmedPartitionInfo_TrimmedCranedInfo) Descriptor deprecated

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

Deprecated: Use TrimmedPartitionInfo_TrimmedCranedInfo.ProtoReflect.Descriptor instead.

func (*TrimmedPartitionInfo_TrimmedCranedInfo) GetControlState

func (*TrimmedPartitionInfo_TrimmedCranedInfo) GetCount

func (*TrimmedPartitionInfo_TrimmedCranedInfo) GetCranedListRegex

func (x *TrimmedPartitionInfo_TrimmedCranedInfo) GetCranedListRegex() string

func (*TrimmedPartitionInfo_TrimmedCranedInfo) GetResourceState

func (*TrimmedPartitionInfo_TrimmedCranedInfo) ProtoMessage

func (*TrimmedPartitionInfo_TrimmedCranedInfo) ProtoReflect

func (*TrimmedPartitionInfo_TrimmedCranedInfo) Reset

func (*TrimmedPartitionInfo_TrimmedCranedInfo) String

type TypeCountMap

type TypeCountMap struct {
	TypeCountMap map[string]uint64 `` /* 188-byte string literal not displayed */
	Total        uint64            `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*TypeCountMap) Descriptor deprecated

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

Deprecated: Use TypeCountMap.ProtoReflect.Descriptor instead.

func (*TypeCountMap) GetTotal

func (x *TypeCountMap) GetTotal() uint64

func (*TypeCountMap) GetTypeCountMap

func (x *TypeCountMap) GetTypeCountMap() map[string]uint64

func (*TypeCountMap) ProtoMessage

func (*TypeCountMap) ProtoMessage()

func (*TypeCountMap) ProtoReflect

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

func (*TypeCountMap) Reset

func (x *TypeCountMap) Reset()

func (*TypeCountMap) String

func (x *TypeCountMap) String() string

type UnimplementedCraneCtldServer

type UnimplementedCraneCtldServer struct{}

UnimplementedCraneCtldServer 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 (UnimplementedCraneCtldServer) AddAccount

func (UnimplementedCraneCtldServer) AddQos

func (UnimplementedCraneCtldServer) AddUser

func (UnimplementedCraneCtldServer) BlockAccountOrUser

func (UnimplementedCraneCtldServer) CancelTask

func (UnimplementedCraneCtldServer) CranedRegister

func (UnimplementedCraneCtldServer) DeleteAccount

func (UnimplementedCraneCtldServer) DeleteQos

func (UnimplementedCraneCtldServer) DeleteUser

func (UnimplementedCraneCtldServer) ModifyAccount

func (UnimplementedCraneCtldServer) ModifyNode

func (UnimplementedCraneCtldServer) ModifyQos

func (UnimplementedCraneCtldServer) ModifyTask

func (UnimplementedCraneCtldServer) ModifyUser

func (UnimplementedCraneCtldServer) QueryAccountInfo

func (UnimplementedCraneCtldServer) QueryClusterInfo

func (UnimplementedCraneCtldServer) QueryCranedInfo

func (UnimplementedCraneCtldServer) QueryPartitionInfo

func (UnimplementedCraneCtldServer) QueryQosInfo

func (UnimplementedCraneCtldServer) QueryTasksInfo

func (UnimplementedCraneCtldServer) QueryUserInfo

func (UnimplementedCraneCtldServer) SubmitBatchTask

func (UnimplementedCraneCtldServer) SubmitBatchTasks

func (UnimplementedCraneCtldServer) TaskStatusChange

type UnimplementedCraneForeDServer

type UnimplementedCraneForeDServer struct{}

UnimplementedCraneForeDServer 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 (UnimplementedCraneForeDServer) QueryTaskIdFromPort

type UnimplementedCranePluginDServer

type UnimplementedCranePluginDServer struct{}

UnimplementedCranePluginDServer 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 (UnimplementedCranePluginDServer) CreateCgroupHook

func (UnimplementedCranePluginDServer) DestroyCgroupHook

func (UnimplementedCranePluginDServer) EndHook

func (UnimplementedCranePluginDServer) StartHook

type UnimplementedCranedServer

type UnimplementedCranedServer struct{}

UnimplementedCranedServer 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 (UnimplementedCranedServer) CheckTaskStatus

func (UnimplementedCranedServer) ExecuteTask

func (UnimplementedCranedServer) TerminateTasks

type UnsafeCraneCtldServer

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

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

type UnsafeCraneForeDServer

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

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

type UnsafeCranePluginDServer

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

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

type UnsafeCranedServer

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

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

type UserInfo

type UserInfo struct {
	Uid                     uint32                          `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name                    string                          `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Account                 string                          `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty"`
	Blocked                 bool                            `protobuf:"varint,4,opt,name=blocked,proto3" json:"blocked,omitempty"`
	AllowedPartitionQosList []*UserInfo_AllowedPartitionQos `` /* 134-byte string literal not displayed */
	CoordinatorAccounts     []string                        `protobuf:"bytes,6,rep,name=coordinator_accounts,json=coordinatorAccounts,proto3" json:"coordinator_accounts,omitempty"`
	AdminLevel              UserInfo_AdminLevel             `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

Note: UserInfo DIFFERS from the `User` struct in C++ code and database representation

and is ONLY used for communication between CraneCtld and cacctmgr command.
If an user belongs to multiple accounts, There will be multiple `UserInfo`
messages with `account` pointing to each account.
For example, if a user (uid=1) belongs to accounts `1,2,3`,
there will be three `UserInfo` messages: (uid=1, account=1), (uid=1, account=2),
(uid=1, account=3).
The c++ code and database representation use a Map<account name, AttrsInAccount> to contain
in ONE UserInfo message all the information belonging to different accounts.

func (*UserInfo) Descriptor deprecated

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

Deprecated: Use UserInfo.ProtoReflect.Descriptor instead.

func (*UserInfo) GetAccount

func (x *UserInfo) GetAccount() string

func (*UserInfo) GetAdminLevel

func (x *UserInfo) GetAdminLevel() UserInfo_AdminLevel

func (*UserInfo) GetAllowedPartitionQosList

func (x *UserInfo) GetAllowedPartitionQosList() []*UserInfo_AllowedPartitionQos

func (*UserInfo) GetBlocked

func (x *UserInfo) GetBlocked() bool

func (*UserInfo) GetCoordinatorAccounts

func (x *UserInfo) GetCoordinatorAccounts() []string

func (*UserInfo) GetName

func (x *UserInfo) GetName() string

func (*UserInfo) GetUid

func (x *UserInfo) GetUid() uint32

func (*UserInfo) ProtoMessage

func (*UserInfo) ProtoMessage()

func (*UserInfo) ProtoReflect

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

func (*UserInfo) Reset

func (x *UserInfo) Reset()

func (*UserInfo) String

func (x *UserInfo) String() string

type UserInfo_AdminLevel

type UserInfo_AdminLevel int32
const (
	UserInfo_None     UserInfo_AdminLevel = 0
	UserInfo_Operator UserInfo_AdminLevel = 1
	UserInfo_Admin    UserInfo_AdminLevel = 2
	UserInfo_Root     UserInfo_AdminLevel = 3
)

func (UserInfo_AdminLevel) Descriptor

func (UserInfo_AdminLevel) Enum

func (UserInfo_AdminLevel) EnumDescriptor deprecated

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

Deprecated: Use UserInfo_AdminLevel.Descriptor instead.

func (UserInfo_AdminLevel) Number

func (UserInfo_AdminLevel) String

func (x UserInfo_AdminLevel) String() string

func (UserInfo_AdminLevel) Type

type UserInfo_AllowedPartitionQos

type UserInfo_AllowedPartitionQos struct {
	PartitionName string   `protobuf:"bytes,1,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	QosList       []string `protobuf:"bytes,2,rep,name=qos_list,json=qosList,proto3" json:"qos_list,omitempty"`
	DefaultQos    string   `protobuf:"bytes,3,opt,name=default_qos,json=defaultQos,proto3" json:"default_qos,omitempty"`
	// contains filtered or unexported fields
}

func (*UserInfo_AllowedPartitionQos) Descriptor deprecated

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

Deprecated: Use UserInfo_AllowedPartitionQos.ProtoReflect.Descriptor instead.

func (*UserInfo_AllowedPartitionQos) GetDefaultQos

func (x *UserInfo_AllowedPartitionQos) GetDefaultQos() string

func (*UserInfo_AllowedPartitionQos) GetPartitionName

func (x *UserInfo_AllowedPartitionQos) GetPartitionName() string

func (*UserInfo_AllowedPartitionQos) GetQosList

func (x *UserInfo_AllowedPartitionQos) GetQosList() []string

func (*UserInfo_AllowedPartitionQos) ProtoMessage

func (*UserInfo_AllowedPartitionQos) ProtoMessage()

func (*UserInfo_AllowedPartitionQos) ProtoReflect

func (*UserInfo_AllowedPartitionQos) Reset

func (x *UserInfo_AllowedPartitionQos) Reset()

func (*UserInfo_AllowedPartitionQos) String

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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