in internal/proto/schedulerx/worker.pb.go [4618:5279]
func file_worker_proto_init() {
if File_worker_proto != nil {
return
}
file_common_proto_init()
if !protoimpl.UnsafeEnabled {
file_worker_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerHeartBeatRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerHeartBeatResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MasterStartContainerRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MasterStartContainerResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MasterBatchStartContainersRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MasterBatchStartContainersResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MasterKillContainerRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MasterKillContainerResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MasterDestroyContainerPoolRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MasterDestroyContainerPoolResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MasterCheckWorkerAliveRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MasterCheckWorkerAliveResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerReportJobInstanceStatusRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerReportJobInstanceStatusResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerReportJobInstanceProgressRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerReportJobInstanceProgressResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerBatchUpdateTaskStatusRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerBatchUpdateTaskStatusResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerMapTaskRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerMapTaskResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerClearTasksRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerClearTasksResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerCreateTaskRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerCreateTaskResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerBatchCreateTasksRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerBatchCreateTasksResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerReportTaskStatusRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerReportTaskStatusResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerBatchReportTaskStatuesRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[29].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerBatchReportTaskStatuesResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[30].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*BatchTaskStatues); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[31].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerReportTaskListStatusRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[32].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerReportTaskListStatusResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[33].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerReportTaskProgressRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[34].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerReportTaskProgressResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[35].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*TaskMessage); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[36].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerPullTasksRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[37].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerPullTasksResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[38].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerQueryJobInstanceStatusRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[39].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerQueryJobInstanceStatusResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[40].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ContainerReportTaskStatusRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[41].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ContainerReportTaskStatusResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[42].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ContainerBatchReportTaskStatuesRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[43].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*TaskStatusInfo); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[44].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ContainerBatchReportTaskStatuesResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[45].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ContainerCheckZombieRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[46].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ContainerCheckZombieResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[47].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MasterNotifyWorkerPullRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[48].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MasterNotifyWorkerPullResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[49].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*PullTaskFromMasterRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[50].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*PullTaskFromMasterResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[51].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerOfflineRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_worker_proto_msgTypes[52].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerOfflineResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_worker_proto_rawDesc,
NumEnums: 0,
NumMessages: 53,
NumExtensions: 0,
NumServices: 0,
},
GoTypes: file_worker_proto_goTypes,
DependencyIndexes: file_worker_proto_depIdxs,
MessageInfos: file_worker_proto_msgTypes,
}.Build()
File_worker_proto = out.File
file_worker_proto_rawDesc = nil
file_worker_proto_goTypes = nil
file_worker_proto_depIdxs = nil
}