1// Code generated by protoc-gen-gogo. DO NOT EDIT. 2// source: github.com/containerd/containerd/api/services/tasks/v1/tasks.proto 3 4package tasks 5 6import ( 7 context "context" 8 fmt "fmt" 9 types "github.com/containerd/containerd/api/types" 10 task "github.com/containerd/containerd/api/types/task" 11 proto "github.com/gogo/protobuf/proto" 12 github_com_gogo_protobuf_types "github.com/gogo/protobuf/types" 13 types1 "github.com/gogo/protobuf/types" 14 github_com_opencontainers_go_digest "github.com/opencontainers/go-digest" 15 grpc "google.golang.org/grpc" 16 codes "google.golang.org/grpc/codes" 17 status "google.golang.org/grpc/status" 18 io "io" 19 math "math" 20 math_bits "math/bits" 21 reflect "reflect" 22 strings "strings" 23 time "time" 24) 25 26// Reference imports to suppress errors if they are not otherwise used. 27var _ = proto.Marshal 28var _ = fmt.Errorf 29var _ = math.Inf 30var _ = time.Kitchen 31 32// This is a compile-time assertion to ensure that this generated file 33// is compatible with the proto package it is being compiled against. 34// A compilation error at this line likely means your copy of the 35// proto package needs to be updated. 36const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package 37 38type CreateTaskRequest struct { 39 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 40 // RootFS provides the pre-chroot mounts to perform in the shim before 41 // executing the container task. 42 // 43 // These are for mounts that cannot be performed in the user namespace. 44 // Typically, these mounts should be resolved from snapshots specified on 45 // the container object. 46 Rootfs []*types.Mount `protobuf:"bytes,3,rep,name=rootfs,proto3" json:"rootfs,omitempty"` 47 Stdin string `protobuf:"bytes,4,opt,name=stdin,proto3" json:"stdin,omitempty"` 48 Stdout string `protobuf:"bytes,5,opt,name=stdout,proto3" json:"stdout,omitempty"` 49 Stderr string `protobuf:"bytes,6,opt,name=stderr,proto3" json:"stderr,omitempty"` 50 Terminal bool `protobuf:"varint,7,opt,name=terminal,proto3" json:"terminal,omitempty"` 51 Checkpoint *types.Descriptor `protobuf:"bytes,8,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"` 52 Options *types1.Any `protobuf:"bytes,9,opt,name=options,proto3" json:"options,omitempty"` 53 XXX_NoUnkeyedLiteral struct{} `json:"-"` 54 XXX_unrecognized []byte `json:"-"` 55 XXX_sizecache int32 `json:"-"` 56} 57 58func (m *CreateTaskRequest) Reset() { *m = CreateTaskRequest{} } 59func (*CreateTaskRequest) ProtoMessage() {} 60func (*CreateTaskRequest) Descriptor() ([]byte, []int) { 61 return fileDescriptor_310e7127b8a26f14, []int{0} 62} 63func (m *CreateTaskRequest) XXX_Unmarshal(b []byte) error { 64 return m.Unmarshal(b) 65} 66func (m *CreateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 67 if deterministic { 68 return xxx_messageInfo_CreateTaskRequest.Marshal(b, m, deterministic) 69 } else { 70 b = b[:cap(b)] 71 n, err := m.MarshalToSizedBuffer(b) 72 if err != nil { 73 return nil, err 74 } 75 return b[:n], nil 76 } 77} 78func (m *CreateTaskRequest) XXX_Merge(src proto.Message) { 79 xxx_messageInfo_CreateTaskRequest.Merge(m, src) 80} 81func (m *CreateTaskRequest) XXX_Size() int { 82 return m.Size() 83} 84func (m *CreateTaskRequest) XXX_DiscardUnknown() { 85 xxx_messageInfo_CreateTaskRequest.DiscardUnknown(m) 86} 87 88var xxx_messageInfo_CreateTaskRequest proto.InternalMessageInfo 89 90type CreateTaskResponse struct { 91 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 92 Pid uint32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"` 93 XXX_NoUnkeyedLiteral struct{} `json:"-"` 94 XXX_unrecognized []byte `json:"-"` 95 XXX_sizecache int32 `json:"-"` 96} 97 98func (m *CreateTaskResponse) Reset() { *m = CreateTaskResponse{} } 99func (*CreateTaskResponse) ProtoMessage() {} 100func (*CreateTaskResponse) Descriptor() ([]byte, []int) { 101 return fileDescriptor_310e7127b8a26f14, []int{1} 102} 103func (m *CreateTaskResponse) XXX_Unmarshal(b []byte) error { 104 return m.Unmarshal(b) 105} 106func (m *CreateTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 107 if deterministic { 108 return xxx_messageInfo_CreateTaskResponse.Marshal(b, m, deterministic) 109 } else { 110 b = b[:cap(b)] 111 n, err := m.MarshalToSizedBuffer(b) 112 if err != nil { 113 return nil, err 114 } 115 return b[:n], nil 116 } 117} 118func (m *CreateTaskResponse) XXX_Merge(src proto.Message) { 119 xxx_messageInfo_CreateTaskResponse.Merge(m, src) 120} 121func (m *CreateTaskResponse) XXX_Size() int { 122 return m.Size() 123} 124func (m *CreateTaskResponse) XXX_DiscardUnknown() { 125 xxx_messageInfo_CreateTaskResponse.DiscardUnknown(m) 126} 127 128var xxx_messageInfo_CreateTaskResponse proto.InternalMessageInfo 129 130type StartRequest struct { 131 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 132 ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"` 133 XXX_NoUnkeyedLiteral struct{} `json:"-"` 134 XXX_unrecognized []byte `json:"-"` 135 XXX_sizecache int32 `json:"-"` 136} 137 138func (m *StartRequest) Reset() { *m = StartRequest{} } 139func (*StartRequest) ProtoMessage() {} 140func (*StartRequest) Descriptor() ([]byte, []int) { 141 return fileDescriptor_310e7127b8a26f14, []int{2} 142} 143func (m *StartRequest) XXX_Unmarshal(b []byte) error { 144 return m.Unmarshal(b) 145} 146func (m *StartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 147 if deterministic { 148 return xxx_messageInfo_StartRequest.Marshal(b, m, deterministic) 149 } else { 150 b = b[:cap(b)] 151 n, err := m.MarshalToSizedBuffer(b) 152 if err != nil { 153 return nil, err 154 } 155 return b[:n], nil 156 } 157} 158func (m *StartRequest) XXX_Merge(src proto.Message) { 159 xxx_messageInfo_StartRequest.Merge(m, src) 160} 161func (m *StartRequest) XXX_Size() int { 162 return m.Size() 163} 164func (m *StartRequest) XXX_DiscardUnknown() { 165 xxx_messageInfo_StartRequest.DiscardUnknown(m) 166} 167 168var xxx_messageInfo_StartRequest proto.InternalMessageInfo 169 170type StartResponse struct { 171 Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` 172 XXX_NoUnkeyedLiteral struct{} `json:"-"` 173 XXX_unrecognized []byte `json:"-"` 174 XXX_sizecache int32 `json:"-"` 175} 176 177func (m *StartResponse) Reset() { *m = StartResponse{} } 178func (*StartResponse) ProtoMessage() {} 179func (*StartResponse) Descriptor() ([]byte, []int) { 180 return fileDescriptor_310e7127b8a26f14, []int{3} 181} 182func (m *StartResponse) XXX_Unmarshal(b []byte) error { 183 return m.Unmarshal(b) 184} 185func (m *StartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 186 if deterministic { 187 return xxx_messageInfo_StartResponse.Marshal(b, m, deterministic) 188 } else { 189 b = b[:cap(b)] 190 n, err := m.MarshalToSizedBuffer(b) 191 if err != nil { 192 return nil, err 193 } 194 return b[:n], nil 195 } 196} 197func (m *StartResponse) XXX_Merge(src proto.Message) { 198 xxx_messageInfo_StartResponse.Merge(m, src) 199} 200func (m *StartResponse) XXX_Size() int { 201 return m.Size() 202} 203func (m *StartResponse) XXX_DiscardUnknown() { 204 xxx_messageInfo_StartResponse.DiscardUnknown(m) 205} 206 207var xxx_messageInfo_StartResponse proto.InternalMessageInfo 208 209type DeleteTaskRequest struct { 210 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 211 XXX_NoUnkeyedLiteral struct{} `json:"-"` 212 XXX_unrecognized []byte `json:"-"` 213 XXX_sizecache int32 `json:"-"` 214} 215 216func (m *DeleteTaskRequest) Reset() { *m = DeleteTaskRequest{} } 217func (*DeleteTaskRequest) ProtoMessage() {} 218func (*DeleteTaskRequest) Descriptor() ([]byte, []int) { 219 return fileDescriptor_310e7127b8a26f14, []int{4} 220} 221func (m *DeleteTaskRequest) XXX_Unmarshal(b []byte) error { 222 return m.Unmarshal(b) 223} 224func (m *DeleteTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 225 if deterministic { 226 return xxx_messageInfo_DeleteTaskRequest.Marshal(b, m, deterministic) 227 } else { 228 b = b[:cap(b)] 229 n, err := m.MarshalToSizedBuffer(b) 230 if err != nil { 231 return nil, err 232 } 233 return b[:n], nil 234 } 235} 236func (m *DeleteTaskRequest) XXX_Merge(src proto.Message) { 237 xxx_messageInfo_DeleteTaskRequest.Merge(m, src) 238} 239func (m *DeleteTaskRequest) XXX_Size() int { 240 return m.Size() 241} 242func (m *DeleteTaskRequest) XXX_DiscardUnknown() { 243 xxx_messageInfo_DeleteTaskRequest.DiscardUnknown(m) 244} 245 246var xxx_messageInfo_DeleteTaskRequest proto.InternalMessageInfo 247 248type DeleteResponse struct { 249 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 250 Pid uint32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"` 251 ExitStatus uint32 `protobuf:"varint,3,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"` 252 ExitedAt time.Time `protobuf:"bytes,4,opt,name=exited_at,json=exitedAt,proto3,stdtime" json:"exited_at"` 253 XXX_NoUnkeyedLiteral struct{} `json:"-"` 254 XXX_unrecognized []byte `json:"-"` 255 XXX_sizecache int32 `json:"-"` 256} 257 258func (m *DeleteResponse) Reset() { *m = DeleteResponse{} } 259func (*DeleteResponse) ProtoMessage() {} 260func (*DeleteResponse) Descriptor() ([]byte, []int) { 261 return fileDescriptor_310e7127b8a26f14, []int{5} 262} 263func (m *DeleteResponse) XXX_Unmarshal(b []byte) error { 264 return m.Unmarshal(b) 265} 266func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 267 if deterministic { 268 return xxx_messageInfo_DeleteResponse.Marshal(b, m, deterministic) 269 } else { 270 b = b[:cap(b)] 271 n, err := m.MarshalToSizedBuffer(b) 272 if err != nil { 273 return nil, err 274 } 275 return b[:n], nil 276 } 277} 278func (m *DeleteResponse) XXX_Merge(src proto.Message) { 279 xxx_messageInfo_DeleteResponse.Merge(m, src) 280} 281func (m *DeleteResponse) XXX_Size() int { 282 return m.Size() 283} 284func (m *DeleteResponse) XXX_DiscardUnknown() { 285 xxx_messageInfo_DeleteResponse.DiscardUnknown(m) 286} 287 288var xxx_messageInfo_DeleteResponse proto.InternalMessageInfo 289 290type DeleteProcessRequest struct { 291 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 292 ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"` 293 XXX_NoUnkeyedLiteral struct{} `json:"-"` 294 XXX_unrecognized []byte `json:"-"` 295 XXX_sizecache int32 `json:"-"` 296} 297 298func (m *DeleteProcessRequest) Reset() { *m = DeleteProcessRequest{} } 299func (*DeleteProcessRequest) ProtoMessage() {} 300func (*DeleteProcessRequest) Descriptor() ([]byte, []int) { 301 return fileDescriptor_310e7127b8a26f14, []int{6} 302} 303func (m *DeleteProcessRequest) XXX_Unmarshal(b []byte) error { 304 return m.Unmarshal(b) 305} 306func (m *DeleteProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 307 if deterministic { 308 return xxx_messageInfo_DeleteProcessRequest.Marshal(b, m, deterministic) 309 } else { 310 b = b[:cap(b)] 311 n, err := m.MarshalToSizedBuffer(b) 312 if err != nil { 313 return nil, err 314 } 315 return b[:n], nil 316 } 317} 318func (m *DeleteProcessRequest) XXX_Merge(src proto.Message) { 319 xxx_messageInfo_DeleteProcessRequest.Merge(m, src) 320} 321func (m *DeleteProcessRequest) XXX_Size() int { 322 return m.Size() 323} 324func (m *DeleteProcessRequest) XXX_DiscardUnknown() { 325 xxx_messageInfo_DeleteProcessRequest.DiscardUnknown(m) 326} 327 328var xxx_messageInfo_DeleteProcessRequest proto.InternalMessageInfo 329 330type GetRequest struct { 331 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 332 ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"` 333 XXX_NoUnkeyedLiteral struct{} `json:"-"` 334 XXX_unrecognized []byte `json:"-"` 335 XXX_sizecache int32 `json:"-"` 336} 337 338func (m *GetRequest) Reset() { *m = GetRequest{} } 339func (*GetRequest) ProtoMessage() {} 340func (*GetRequest) Descriptor() ([]byte, []int) { 341 return fileDescriptor_310e7127b8a26f14, []int{7} 342} 343func (m *GetRequest) XXX_Unmarshal(b []byte) error { 344 return m.Unmarshal(b) 345} 346func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 347 if deterministic { 348 return xxx_messageInfo_GetRequest.Marshal(b, m, deterministic) 349 } else { 350 b = b[:cap(b)] 351 n, err := m.MarshalToSizedBuffer(b) 352 if err != nil { 353 return nil, err 354 } 355 return b[:n], nil 356 } 357} 358func (m *GetRequest) XXX_Merge(src proto.Message) { 359 xxx_messageInfo_GetRequest.Merge(m, src) 360} 361func (m *GetRequest) XXX_Size() int { 362 return m.Size() 363} 364func (m *GetRequest) XXX_DiscardUnknown() { 365 xxx_messageInfo_GetRequest.DiscardUnknown(m) 366} 367 368var xxx_messageInfo_GetRequest proto.InternalMessageInfo 369 370type GetResponse struct { 371 Process *task.Process `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"` 372 XXX_NoUnkeyedLiteral struct{} `json:"-"` 373 XXX_unrecognized []byte `json:"-"` 374 XXX_sizecache int32 `json:"-"` 375} 376 377func (m *GetResponse) Reset() { *m = GetResponse{} } 378func (*GetResponse) ProtoMessage() {} 379func (*GetResponse) Descriptor() ([]byte, []int) { 380 return fileDescriptor_310e7127b8a26f14, []int{8} 381} 382func (m *GetResponse) XXX_Unmarshal(b []byte) error { 383 return m.Unmarshal(b) 384} 385func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 386 if deterministic { 387 return xxx_messageInfo_GetResponse.Marshal(b, m, deterministic) 388 } else { 389 b = b[:cap(b)] 390 n, err := m.MarshalToSizedBuffer(b) 391 if err != nil { 392 return nil, err 393 } 394 return b[:n], nil 395 } 396} 397func (m *GetResponse) XXX_Merge(src proto.Message) { 398 xxx_messageInfo_GetResponse.Merge(m, src) 399} 400func (m *GetResponse) XXX_Size() int { 401 return m.Size() 402} 403func (m *GetResponse) XXX_DiscardUnknown() { 404 xxx_messageInfo_GetResponse.DiscardUnknown(m) 405} 406 407var xxx_messageInfo_GetResponse proto.InternalMessageInfo 408 409type ListTasksRequest struct { 410 Filter string `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` 411 XXX_NoUnkeyedLiteral struct{} `json:"-"` 412 XXX_unrecognized []byte `json:"-"` 413 XXX_sizecache int32 `json:"-"` 414} 415 416func (m *ListTasksRequest) Reset() { *m = ListTasksRequest{} } 417func (*ListTasksRequest) ProtoMessage() {} 418func (*ListTasksRequest) Descriptor() ([]byte, []int) { 419 return fileDescriptor_310e7127b8a26f14, []int{9} 420} 421func (m *ListTasksRequest) XXX_Unmarshal(b []byte) error { 422 return m.Unmarshal(b) 423} 424func (m *ListTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 425 if deterministic { 426 return xxx_messageInfo_ListTasksRequest.Marshal(b, m, deterministic) 427 } else { 428 b = b[:cap(b)] 429 n, err := m.MarshalToSizedBuffer(b) 430 if err != nil { 431 return nil, err 432 } 433 return b[:n], nil 434 } 435} 436func (m *ListTasksRequest) XXX_Merge(src proto.Message) { 437 xxx_messageInfo_ListTasksRequest.Merge(m, src) 438} 439func (m *ListTasksRequest) XXX_Size() int { 440 return m.Size() 441} 442func (m *ListTasksRequest) XXX_DiscardUnknown() { 443 xxx_messageInfo_ListTasksRequest.DiscardUnknown(m) 444} 445 446var xxx_messageInfo_ListTasksRequest proto.InternalMessageInfo 447 448type ListTasksResponse struct { 449 Tasks []*task.Process `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"` 450 XXX_NoUnkeyedLiteral struct{} `json:"-"` 451 XXX_unrecognized []byte `json:"-"` 452 XXX_sizecache int32 `json:"-"` 453} 454 455func (m *ListTasksResponse) Reset() { *m = ListTasksResponse{} } 456func (*ListTasksResponse) ProtoMessage() {} 457func (*ListTasksResponse) Descriptor() ([]byte, []int) { 458 return fileDescriptor_310e7127b8a26f14, []int{10} 459} 460func (m *ListTasksResponse) XXX_Unmarshal(b []byte) error { 461 return m.Unmarshal(b) 462} 463func (m *ListTasksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 464 if deterministic { 465 return xxx_messageInfo_ListTasksResponse.Marshal(b, m, deterministic) 466 } else { 467 b = b[:cap(b)] 468 n, err := m.MarshalToSizedBuffer(b) 469 if err != nil { 470 return nil, err 471 } 472 return b[:n], nil 473 } 474} 475func (m *ListTasksResponse) XXX_Merge(src proto.Message) { 476 xxx_messageInfo_ListTasksResponse.Merge(m, src) 477} 478func (m *ListTasksResponse) XXX_Size() int { 479 return m.Size() 480} 481func (m *ListTasksResponse) XXX_DiscardUnknown() { 482 xxx_messageInfo_ListTasksResponse.DiscardUnknown(m) 483} 484 485var xxx_messageInfo_ListTasksResponse proto.InternalMessageInfo 486 487type KillRequest struct { 488 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 489 ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"` 490 Signal uint32 `protobuf:"varint,3,opt,name=signal,proto3" json:"signal,omitempty"` 491 All bool `protobuf:"varint,4,opt,name=all,proto3" json:"all,omitempty"` 492 XXX_NoUnkeyedLiteral struct{} `json:"-"` 493 XXX_unrecognized []byte `json:"-"` 494 XXX_sizecache int32 `json:"-"` 495} 496 497func (m *KillRequest) Reset() { *m = KillRequest{} } 498func (*KillRequest) ProtoMessage() {} 499func (*KillRequest) Descriptor() ([]byte, []int) { 500 return fileDescriptor_310e7127b8a26f14, []int{11} 501} 502func (m *KillRequest) XXX_Unmarshal(b []byte) error { 503 return m.Unmarshal(b) 504} 505func (m *KillRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 506 if deterministic { 507 return xxx_messageInfo_KillRequest.Marshal(b, m, deterministic) 508 } else { 509 b = b[:cap(b)] 510 n, err := m.MarshalToSizedBuffer(b) 511 if err != nil { 512 return nil, err 513 } 514 return b[:n], nil 515 } 516} 517func (m *KillRequest) XXX_Merge(src proto.Message) { 518 xxx_messageInfo_KillRequest.Merge(m, src) 519} 520func (m *KillRequest) XXX_Size() int { 521 return m.Size() 522} 523func (m *KillRequest) XXX_DiscardUnknown() { 524 xxx_messageInfo_KillRequest.DiscardUnknown(m) 525} 526 527var xxx_messageInfo_KillRequest proto.InternalMessageInfo 528 529type ExecProcessRequest struct { 530 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 531 Stdin string `protobuf:"bytes,2,opt,name=stdin,proto3" json:"stdin,omitempty"` 532 Stdout string `protobuf:"bytes,3,opt,name=stdout,proto3" json:"stdout,omitempty"` 533 Stderr string `protobuf:"bytes,4,opt,name=stderr,proto3" json:"stderr,omitempty"` 534 Terminal bool `protobuf:"varint,5,opt,name=terminal,proto3" json:"terminal,omitempty"` 535 // Spec for starting a process in the target container. 536 // 537 // For runc, this is a process spec, for example. 538 Spec *types1.Any `protobuf:"bytes,6,opt,name=spec,proto3" json:"spec,omitempty"` 539 // id of the exec process 540 ExecID string `protobuf:"bytes,7,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"` 541 XXX_NoUnkeyedLiteral struct{} `json:"-"` 542 XXX_unrecognized []byte `json:"-"` 543 XXX_sizecache int32 `json:"-"` 544} 545 546func (m *ExecProcessRequest) Reset() { *m = ExecProcessRequest{} } 547func (*ExecProcessRequest) ProtoMessage() {} 548func (*ExecProcessRequest) Descriptor() ([]byte, []int) { 549 return fileDescriptor_310e7127b8a26f14, []int{12} 550} 551func (m *ExecProcessRequest) XXX_Unmarshal(b []byte) error { 552 return m.Unmarshal(b) 553} 554func (m *ExecProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 555 if deterministic { 556 return xxx_messageInfo_ExecProcessRequest.Marshal(b, m, deterministic) 557 } else { 558 b = b[:cap(b)] 559 n, err := m.MarshalToSizedBuffer(b) 560 if err != nil { 561 return nil, err 562 } 563 return b[:n], nil 564 } 565} 566func (m *ExecProcessRequest) XXX_Merge(src proto.Message) { 567 xxx_messageInfo_ExecProcessRequest.Merge(m, src) 568} 569func (m *ExecProcessRequest) XXX_Size() int { 570 return m.Size() 571} 572func (m *ExecProcessRequest) XXX_DiscardUnknown() { 573 xxx_messageInfo_ExecProcessRequest.DiscardUnknown(m) 574} 575 576var xxx_messageInfo_ExecProcessRequest proto.InternalMessageInfo 577 578type ExecProcessResponse struct { 579 XXX_NoUnkeyedLiteral struct{} `json:"-"` 580 XXX_unrecognized []byte `json:"-"` 581 XXX_sizecache int32 `json:"-"` 582} 583 584func (m *ExecProcessResponse) Reset() { *m = ExecProcessResponse{} } 585func (*ExecProcessResponse) ProtoMessage() {} 586func (*ExecProcessResponse) Descriptor() ([]byte, []int) { 587 return fileDescriptor_310e7127b8a26f14, []int{13} 588} 589func (m *ExecProcessResponse) XXX_Unmarshal(b []byte) error { 590 return m.Unmarshal(b) 591} 592func (m *ExecProcessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 593 if deterministic { 594 return xxx_messageInfo_ExecProcessResponse.Marshal(b, m, deterministic) 595 } else { 596 b = b[:cap(b)] 597 n, err := m.MarshalToSizedBuffer(b) 598 if err != nil { 599 return nil, err 600 } 601 return b[:n], nil 602 } 603} 604func (m *ExecProcessResponse) XXX_Merge(src proto.Message) { 605 xxx_messageInfo_ExecProcessResponse.Merge(m, src) 606} 607func (m *ExecProcessResponse) XXX_Size() int { 608 return m.Size() 609} 610func (m *ExecProcessResponse) XXX_DiscardUnknown() { 611 xxx_messageInfo_ExecProcessResponse.DiscardUnknown(m) 612} 613 614var xxx_messageInfo_ExecProcessResponse proto.InternalMessageInfo 615 616type ResizePtyRequest struct { 617 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 618 ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"` 619 Width uint32 `protobuf:"varint,3,opt,name=width,proto3" json:"width,omitempty"` 620 Height uint32 `protobuf:"varint,4,opt,name=height,proto3" json:"height,omitempty"` 621 XXX_NoUnkeyedLiteral struct{} `json:"-"` 622 XXX_unrecognized []byte `json:"-"` 623 XXX_sizecache int32 `json:"-"` 624} 625 626func (m *ResizePtyRequest) Reset() { *m = ResizePtyRequest{} } 627func (*ResizePtyRequest) ProtoMessage() {} 628func (*ResizePtyRequest) Descriptor() ([]byte, []int) { 629 return fileDescriptor_310e7127b8a26f14, []int{14} 630} 631func (m *ResizePtyRequest) XXX_Unmarshal(b []byte) error { 632 return m.Unmarshal(b) 633} 634func (m *ResizePtyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 635 if deterministic { 636 return xxx_messageInfo_ResizePtyRequest.Marshal(b, m, deterministic) 637 } else { 638 b = b[:cap(b)] 639 n, err := m.MarshalToSizedBuffer(b) 640 if err != nil { 641 return nil, err 642 } 643 return b[:n], nil 644 } 645} 646func (m *ResizePtyRequest) XXX_Merge(src proto.Message) { 647 xxx_messageInfo_ResizePtyRequest.Merge(m, src) 648} 649func (m *ResizePtyRequest) XXX_Size() int { 650 return m.Size() 651} 652func (m *ResizePtyRequest) XXX_DiscardUnknown() { 653 xxx_messageInfo_ResizePtyRequest.DiscardUnknown(m) 654} 655 656var xxx_messageInfo_ResizePtyRequest proto.InternalMessageInfo 657 658type CloseIORequest struct { 659 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 660 ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"` 661 Stdin bool `protobuf:"varint,3,opt,name=stdin,proto3" json:"stdin,omitempty"` 662 XXX_NoUnkeyedLiteral struct{} `json:"-"` 663 XXX_unrecognized []byte `json:"-"` 664 XXX_sizecache int32 `json:"-"` 665} 666 667func (m *CloseIORequest) Reset() { *m = CloseIORequest{} } 668func (*CloseIORequest) ProtoMessage() {} 669func (*CloseIORequest) Descriptor() ([]byte, []int) { 670 return fileDescriptor_310e7127b8a26f14, []int{15} 671} 672func (m *CloseIORequest) XXX_Unmarshal(b []byte) error { 673 return m.Unmarshal(b) 674} 675func (m *CloseIORequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 676 if deterministic { 677 return xxx_messageInfo_CloseIORequest.Marshal(b, m, deterministic) 678 } else { 679 b = b[:cap(b)] 680 n, err := m.MarshalToSizedBuffer(b) 681 if err != nil { 682 return nil, err 683 } 684 return b[:n], nil 685 } 686} 687func (m *CloseIORequest) XXX_Merge(src proto.Message) { 688 xxx_messageInfo_CloseIORequest.Merge(m, src) 689} 690func (m *CloseIORequest) XXX_Size() int { 691 return m.Size() 692} 693func (m *CloseIORequest) XXX_DiscardUnknown() { 694 xxx_messageInfo_CloseIORequest.DiscardUnknown(m) 695} 696 697var xxx_messageInfo_CloseIORequest proto.InternalMessageInfo 698 699type PauseTaskRequest struct { 700 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 701 XXX_NoUnkeyedLiteral struct{} `json:"-"` 702 XXX_unrecognized []byte `json:"-"` 703 XXX_sizecache int32 `json:"-"` 704} 705 706func (m *PauseTaskRequest) Reset() { *m = PauseTaskRequest{} } 707func (*PauseTaskRequest) ProtoMessage() {} 708func (*PauseTaskRequest) Descriptor() ([]byte, []int) { 709 return fileDescriptor_310e7127b8a26f14, []int{16} 710} 711func (m *PauseTaskRequest) XXX_Unmarshal(b []byte) error { 712 return m.Unmarshal(b) 713} 714func (m *PauseTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 715 if deterministic { 716 return xxx_messageInfo_PauseTaskRequest.Marshal(b, m, deterministic) 717 } else { 718 b = b[:cap(b)] 719 n, err := m.MarshalToSizedBuffer(b) 720 if err != nil { 721 return nil, err 722 } 723 return b[:n], nil 724 } 725} 726func (m *PauseTaskRequest) XXX_Merge(src proto.Message) { 727 xxx_messageInfo_PauseTaskRequest.Merge(m, src) 728} 729func (m *PauseTaskRequest) XXX_Size() int { 730 return m.Size() 731} 732func (m *PauseTaskRequest) XXX_DiscardUnknown() { 733 xxx_messageInfo_PauseTaskRequest.DiscardUnknown(m) 734} 735 736var xxx_messageInfo_PauseTaskRequest proto.InternalMessageInfo 737 738type ResumeTaskRequest struct { 739 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 740 XXX_NoUnkeyedLiteral struct{} `json:"-"` 741 XXX_unrecognized []byte `json:"-"` 742 XXX_sizecache int32 `json:"-"` 743} 744 745func (m *ResumeTaskRequest) Reset() { *m = ResumeTaskRequest{} } 746func (*ResumeTaskRequest) ProtoMessage() {} 747func (*ResumeTaskRequest) Descriptor() ([]byte, []int) { 748 return fileDescriptor_310e7127b8a26f14, []int{17} 749} 750func (m *ResumeTaskRequest) XXX_Unmarshal(b []byte) error { 751 return m.Unmarshal(b) 752} 753func (m *ResumeTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 754 if deterministic { 755 return xxx_messageInfo_ResumeTaskRequest.Marshal(b, m, deterministic) 756 } else { 757 b = b[:cap(b)] 758 n, err := m.MarshalToSizedBuffer(b) 759 if err != nil { 760 return nil, err 761 } 762 return b[:n], nil 763 } 764} 765func (m *ResumeTaskRequest) XXX_Merge(src proto.Message) { 766 xxx_messageInfo_ResumeTaskRequest.Merge(m, src) 767} 768func (m *ResumeTaskRequest) XXX_Size() int { 769 return m.Size() 770} 771func (m *ResumeTaskRequest) XXX_DiscardUnknown() { 772 xxx_messageInfo_ResumeTaskRequest.DiscardUnknown(m) 773} 774 775var xxx_messageInfo_ResumeTaskRequest proto.InternalMessageInfo 776 777type ListPidsRequest struct { 778 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 779 XXX_NoUnkeyedLiteral struct{} `json:"-"` 780 XXX_unrecognized []byte `json:"-"` 781 XXX_sizecache int32 `json:"-"` 782} 783 784func (m *ListPidsRequest) Reset() { *m = ListPidsRequest{} } 785func (*ListPidsRequest) ProtoMessage() {} 786func (*ListPidsRequest) Descriptor() ([]byte, []int) { 787 return fileDescriptor_310e7127b8a26f14, []int{18} 788} 789func (m *ListPidsRequest) XXX_Unmarshal(b []byte) error { 790 return m.Unmarshal(b) 791} 792func (m *ListPidsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 793 if deterministic { 794 return xxx_messageInfo_ListPidsRequest.Marshal(b, m, deterministic) 795 } else { 796 b = b[:cap(b)] 797 n, err := m.MarshalToSizedBuffer(b) 798 if err != nil { 799 return nil, err 800 } 801 return b[:n], nil 802 } 803} 804func (m *ListPidsRequest) XXX_Merge(src proto.Message) { 805 xxx_messageInfo_ListPidsRequest.Merge(m, src) 806} 807func (m *ListPidsRequest) XXX_Size() int { 808 return m.Size() 809} 810func (m *ListPidsRequest) XXX_DiscardUnknown() { 811 xxx_messageInfo_ListPidsRequest.DiscardUnknown(m) 812} 813 814var xxx_messageInfo_ListPidsRequest proto.InternalMessageInfo 815 816type ListPidsResponse struct { 817 // Processes includes the process ID and additional process information 818 Processes []*task.ProcessInfo `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"` 819 XXX_NoUnkeyedLiteral struct{} `json:"-"` 820 XXX_unrecognized []byte `json:"-"` 821 XXX_sizecache int32 `json:"-"` 822} 823 824func (m *ListPidsResponse) Reset() { *m = ListPidsResponse{} } 825func (*ListPidsResponse) ProtoMessage() {} 826func (*ListPidsResponse) Descriptor() ([]byte, []int) { 827 return fileDescriptor_310e7127b8a26f14, []int{19} 828} 829func (m *ListPidsResponse) XXX_Unmarshal(b []byte) error { 830 return m.Unmarshal(b) 831} 832func (m *ListPidsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 833 if deterministic { 834 return xxx_messageInfo_ListPidsResponse.Marshal(b, m, deterministic) 835 } else { 836 b = b[:cap(b)] 837 n, err := m.MarshalToSizedBuffer(b) 838 if err != nil { 839 return nil, err 840 } 841 return b[:n], nil 842 } 843} 844func (m *ListPidsResponse) XXX_Merge(src proto.Message) { 845 xxx_messageInfo_ListPidsResponse.Merge(m, src) 846} 847func (m *ListPidsResponse) XXX_Size() int { 848 return m.Size() 849} 850func (m *ListPidsResponse) XXX_DiscardUnknown() { 851 xxx_messageInfo_ListPidsResponse.DiscardUnknown(m) 852} 853 854var xxx_messageInfo_ListPidsResponse proto.InternalMessageInfo 855 856type CheckpointTaskRequest struct { 857 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 858 ParentCheckpoint github_com_opencontainers_go_digest.Digest `protobuf:"bytes,2,opt,name=parent_checkpoint,json=parentCheckpoint,proto3,customtype=github.com/opencontainers/go-digest.Digest" json:"parent_checkpoint"` 859 Options *types1.Any `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"` 860 XXX_NoUnkeyedLiteral struct{} `json:"-"` 861 XXX_unrecognized []byte `json:"-"` 862 XXX_sizecache int32 `json:"-"` 863} 864 865func (m *CheckpointTaskRequest) Reset() { *m = CheckpointTaskRequest{} } 866func (*CheckpointTaskRequest) ProtoMessage() {} 867func (*CheckpointTaskRequest) Descriptor() ([]byte, []int) { 868 return fileDescriptor_310e7127b8a26f14, []int{20} 869} 870func (m *CheckpointTaskRequest) XXX_Unmarshal(b []byte) error { 871 return m.Unmarshal(b) 872} 873func (m *CheckpointTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 874 if deterministic { 875 return xxx_messageInfo_CheckpointTaskRequest.Marshal(b, m, deterministic) 876 } else { 877 b = b[:cap(b)] 878 n, err := m.MarshalToSizedBuffer(b) 879 if err != nil { 880 return nil, err 881 } 882 return b[:n], nil 883 } 884} 885func (m *CheckpointTaskRequest) XXX_Merge(src proto.Message) { 886 xxx_messageInfo_CheckpointTaskRequest.Merge(m, src) 887} 888func (m *CheckpointTaskRequest) XXX_Size() int { 889 return m.Size() 890} 891func (m *CheckpointTaskRequest) XXX_DiscardUnknown() { 892 xxx_messageInfo_CheckpointTaskRequest.DiscardUnknown(m) 893} 894 895var xxx_messageInfo_CheckpointTaskRequest proto.InternalMessageInfo 896 897type CheckpointTaskResponse struct { 898 Descriptors []*types.Descriptor `protobuf:"bytes,1,rep,name=descriptors,proto3" json:"descriptors,omitempty"` 899 XXX_NoUnkeyedLiteral struct{} `json:"-"` 900 XXX_unrecognized []byte `json:"-"` 901 XXX_sizecache int32 `json:"-"` 902} 903 904func (m *CheckpointTaskResponse) Reset() { *m = CheckpointTaskResponse{} } 905func (*CheckpointTaskResponse) ProtoMessage() {} 906func (*CheckpointTaskResponse) Descriptor() ([]byte, []int) { 907 return fileDescriptor_310e7127b8a26f14, []int{21} 908} 909func (m *CheckpointTaskResponse) XXX_Unmarshal(b []byte) error { 910 return m.Unmarshal(b) 911} 912func (m *CheckpointTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 913 if deterministic { 914 return xxx_messageInfo_CheckpointTaskResponse.Marshal(b, m, deterministic) 915 } else { 916 b = b[:cap(b)] 917 n, err := m.MarshalToSizedBuffer(b) 918 if err != nil { 919 return nil, err 920 } 921 return b[:n], nil 922 } 923} 924func (m *CheckpointTaskResponse) XXX_Merge(src proto.Message) { 925 xxx_messageInfo_CheckpointTaskResponse.Merge(m, src) 926} 927func (m *CheckpointTaskResponse) XXX_Size() int { 928 return m.Size() 929} 930func (m *CheckpointTaskResponse) XXX_DiscardUnknown() { 931 xxx_messageInfo_CheckpointTaskResponse.DiscardUnknown(m) 932} 933 934var xxx_messageInfo_CheckpointTaskResponse proto.InternalMessageInfo 935 936type UpdateTaskRequest struct { 937 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 938 Resources *types1.Any `protobuf:"bytes,2,opt,name=resources,proto3" json:"resources,omitempty"` 939 XXX_NoUnkeyedLiteral struct{} `json:"-"` 940 XXX_unrecognized []byte `json:"-"` 941 XXX_sizecache int32 `json:"-"` 942} 943 944func (m *UpdateTaskRequest) Reset() { *m = UpdateTaskRequest{} } 945func (*UpdateTaskRequest) ProtoMessage() {} 946func (*UpdateTaskRequest) Descriptor() ([]byte, []int) { 947 return fileDescriptor_310e7127b8a26f14, []int{22} 948} 949func (m *UpdateTaskRequest) XXX_Unmarshal(b []byte) error { 950 return m.Unmarshal(b) 951} 952func (m *UpdateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 953 if deterministic { 954 return xxx_messageInfo_UpdateTaskRequest.Marshal(b, m, deterministic) 955 } else { 956 b = b[:cap(b)] 957 n, err := m.MarshalToSizedBuffer(b) 958 if err != nil { 959 return nil, err 960 } 961 return b[:n], nil 962 } 963} 964func (m *UpdateTaskRequest) XXX_Merge(src proto.Message) { 965 xxx_messageInfo_UpdateTaskRequest.Merge(m, src) 966} 967func (m *UpdateTaskRequest) XXX_Size() int { 968 return m.Size() 969} 970func (m *UpdateTaskRequest) XXX_DiscardUnknown() { 971 xxx_messageInfo_UpdateTaskRequest.DiscardUnknown(m) 972} 973 974var xxx_messageInfo_UpdateTaskRequest proto.InternalMessageInfo 975 976type MetricsRequest struct { 977 Filters []string `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"` 978 XXX_NoUnkeyedLiteral struct{} `json:"-"` 979 XXX_unrecognized []byte `json:"-"` 980 XXX_sizecache int32 `json:"-"` 981} 982 983func (m *MetricsRequest) Reset() { *m = MetricsRequest{} } 984func (*MetricsRequest) ProtoMessage() {} 985func (*MetricsRequest) Descriptor() ([]byte, []int) { 986 return fileDescriptor_310e7127b8a26f14, []int{23} 987} 988func (m *MetricsRequest) XXX_Unmarshal(b []byte) error { 989 return m.Unmarshal(b) 990} 991func (m *MetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 992 if deterministic { 993 return xxx_messageInfo_MetricsRequest.Marshal(b, m, deterministic) 994 } else { 995 b = b[:cap(b)] 996 n, err := m.MarshalToSizedBuffer(b) 997 if err != nil { 998 return nil, err 999 } 1000 return b[:n], nil 1001 } 1002} 1003func (m *MetricsRequest) XXX_Merge(src proto.Message) { 1004 xxx_messageInfo_MetricsRequest.Merge(m, src) 1005} 1006func (m *MetricsRequest) XXX_Size() int { 1007 return m.Size() 1008} 1009func (m *MetricsRequest) XXX_DiscardUnknown() { 1010 xxx_messageInfo_MetricsRequest.DiscardUnknown(m) 1011} 1012 1013var xxx_messageInfo_MetricsRequest proto.InternalMessageInfo 1014 1015type MetricsResponse struct { 1016 Metrics []*types.Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"` 1017 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1018 XXX_unrecognized []byte `json:"-"` 1019 XXX_sizecache int32 `json:"-"` 1020} 1021 1022func (m *MetricsResponse) Reset() { *m = MetricsResponse{} } 1023func (*MetricsResponse) ProtoMessage() {} 1024func (*MetricsResponse) Descriptor() ([]byte, []int) { 1025 return fileDescriptor_310e7127b8a26f14, []int{24} 1026} 1027func (m *MetricsResponse) XXX_Unmarshal(b []byte) error { 1028 return m.Unmarshal(b) 1029} 1030func (m *MetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1031 if deterministic { 1032 return xxx_messageInfo_MetricsResponse.Marshal(b, m, deterministic) 1033 } else { 1034 b = b[:cap(b)] 1035 n, err := m.MarshalToSizedBuffer(b) 1036 if err != nil { 1037 return nil, err 1038 } 1039 return b[:n], nil 1040 } 1041} 1042func (m *MetricsResponse) XXX_Merge(src proto.Message) { 1043 xxx_messageInfo_MetricsResponse.Merge(m, src) 1044} 1045func (m *MetricsResponse) XXX_Size() int { 1046 return m.Size() 1047} 1048func (m *MetricsResponse) XXX_DiscardUnknown() { 1049 xxx_messageInfo_MetricsResponse.DiscardUnknown(m) 1050} 1051 1052var xxx_messageInfo_MetricsResponse proto.InternalMessageInfo 1053 1054type WaitRequest struct { 1055 ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` 1056 ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"` 1057 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1058 XXX_unrecognized []byte `json:"-"` 1059 XXX_sizecache int32 `json:"-"` 1060} 1061 1062func (m *WaitRequest) Reset() { *m = WaitRequest{} } 1063func (*WaitRequest) ProtoMessage() {} 1064func (*WaitRequest) Descriptor() ([]byte, []int) { 1065 return fileDescriptor_310e7127b8a26f14, []int{25} 1066} 1067func (m *WaitRequest) XXX_Unmarshal(b []byte) error { 1068 return m.Unmarshal(b) 1069} 1070func (m *WaitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1071 if deterministic { 1072 return xxx_messageInfo_WaitRequest.Marshal(b, m, deterministic) 1073 } else { 1074 b = b[:cap(b)] 1075 n, err := m.MarshalToSizedBuffer(b) 1076 if err != nil { 1077 return nil, err 1078 } 1079 return b[:n], nil 1080 } 1081} 1082func (m *WaitRequest) XXX_Merge(src proto.Message) { 1083 xxx_messageInfo_WaitRequest.Merge(m, src) 1084} 1085func (m *WaitRequest) XXX_Size() int { 1086 return m.Size() 1087} 1088func (m *WaitRequest) XXX_DiscardUnknown() { 1089 xxx_messageInfo_WaitRequest.DiscardUnknown(m) 1090} 1091 1092var xxx_messageInfo_WaitRequest proto.InternalMessageInfo 1093 1094type WaitResponse struct { 1095 ExitStatus uint32 `protobuf:"varint,1,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"` 1096 ExitedAt time.Time `protobuf:"bytes,2,opt,name=exited_at,json=exitedAt,proto3,stdtime" json:"exited_at"` 1097 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1098 XXX_unrecognized []byte `json:"-"` 1099 XXX_sizecache int32 `json:"-"` 1100} 1101 1102func (m *WaitResponse) Reset() { *m = WaitResponse{} } 1103func (*WaitResponse) ProtoMessage() {} 1104func (*WaitResponse) Descriptor() ([]byte, []int) { 1105 return fileDescriptor_310e7127b8a26f14, []int{26} 1106} 1107func (m *WaitResponse) XXX_Unmarshal(b []byte) error { 1108 return m.Unmarshal(b) 1109} 1110func (m *WaitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1111 if deterministic { 1112 return xxx_messageInfo_WaitResponse.Marshal(b, m, deterministic) 1113 } else { 1114 b = b[:cap(b)] 1115 n, err := m.MarshalToSizedBuffer(b) 1116 if err != nil { 1117 return nil, err 1118 } 1119 return b[:n], nil 1120 } 1121} 1122func (m *WaitResponse) XXX_Merge(src proto.Message) { 1123 xxx_messageInfo_WaitResponse.Merge(m, src) 1124} 1125func (m *WaitResponse) XXX_Size() int { 1126 return m.Size() 1127} 1128func (m *WaitResponse) XXX_DiscardUnknown() { 1129 xxx_messageInfo_WaitResponse.DiscardUnknown(m) 1130} 1131 1132var xxx_messageInfo_WaitResponse proto.InternalMessageInfo 1133 1134func init() { 1135 proto.RegisterType((*CreateTaskRequest)(nil), "containerd.services.tasks.v1.CreateTaskRequest") 1136 proto.RegisterType((*CreateTaskResponse)(nil), "containerd.services.tasks.v1.CreateTaskResponse") 1137 proto.RegisterType((*StartRequest)(nil), "containerd.services.tasks.v1.StartRequest") 1138 proto.RegisterType((*StartResponse)(nil), "containerd.services.tasks.v1.StartResponse") 1139 proto.RegisterType((*DeleteTaskRequest)(nil), "containerd.services.tasks.v1.DeleteTaskRequest") 1140 proto.RegisterType((*DeleteResponse)(nil), "containerd.services.tasks.v1.DeleteResponse") 1141 proto.RegisterType((*DeleteProcessRequest)(nil), "containerd.services.tasks.v1.DeleteProcessRequest") 1142 proto.RegisterType((*GetRequest)(nil), "containerd.services.tasks.v1.GetRequest") 1143 proto.RegisterType((*GetResponse)(nil), "containerd.services.tasks.v1.GetResponse") 1144 proto.RegisterType((*ListTasksRequest)(nil), "containerd.services.tasks.v1.ListTasksRequest") 1145 proto.RegisterType((*ListTasksResponse)(nil), "containerd.services.tasks.v1.ListTasksResponse") 1146 proto.RegisterType((*KillRequest)(nil), "containerd.services.tasks.v1.KillRequest") 1147 proto.RegisterType((*ExecProcessRequest)(nil), "containerd.services.tasks.v1.ExecProcessRequest") 1148 proto.RegisterType((*ExecProcessResponse)(nil), "containerd.services.tasks.v1.ExecProcessResponse") 1149 proto.RegisterType((*ResizePtyRequest)(nil), "containerd.services.tasks.v1.ResizePtyRequest") 1150 proto.RegisterType((*CloseIORequest)(nil), "containerd.services.tasks.v1.CloseIORequest") 1151 proto.RegisterType((*PauseTaskRequest)(nil), "containerd.services.tasks.v1.PauseTaskRequest") 1152 proto.RegisterType((*ResumeTaskRequest)(nil), "containerd.services.tasks.v1.ResumeTaskRequest") 1153 proto.RegisterType((*ListPidsRequest)(nil), "containerd.services.tasks.v1.ListPidsRequest") 1154 proto.RegisterType((*ListPidsResponse)(nil), "containerd.services.tasks.v1.ListPidsResponse") 1155 proto.RegisterType((*CheckpointTaskRequest)(nil), "containerd.services.tasks.v1.CheckpointTaskRequest") 1156 proto.RegisterType((*CheckpointTaskResponse)(nil), "containerd.services.tasks.v1.CheckpointTaskResponse") 1157 proto.RegisterType((*UpdateTaskRequest)(nil), "containerd.services.tasks.v1.UpdateTaskRequest") 1158 proto.RegisterType((*MetricsRequest)(nil), "containerd.services.tasks.v1.MetricsRequest") 1159 proto.RegisterType((*MetricsResponse)(nil), "containerd.services.tasks.v1.MetricsResponse") 1160 proto.RegisterType((*WaitRequest)(nil), "containerd.services.tasks.v1.WaitRequest") 1161 proto.RegisterType((*WaitResponse)(nil), "containerd.services.tasks.v1.WaitResponse") 1162} 1163 1164func init() { 1165 proto.RegisterFile("github.com/containerd/containerd/api/services/tasks/v1/tasks.proto", fileDescriptor_310e7127b8a26f14) 1166} 1167 1168var fileDescriptor_310e7127b8a26f14 = []byte{ 1169 // 1318 bytes of a gzipped FileDescriptorProto 1170 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x58, 0x4b, 0x6f, 0x1b, 0x45, 1171 0x1c, 0xef, 0xfa, 0xed, 0xbf, 0x93, 0x36, 0x59, 0xd2, 0x60, 0x96, 0x2a, 0x0e, 0xcb, 0xc5, 0x04, 1172 0xba, 0x4b, 0x5d, 0x54, 0x21, 0x5a, 0x21, 0x35, 0x0f, 0x22, 0x0b, 0xaa, 0xa6, 0xdb, 0x02, 0x55, 1173 0x25, 0x14, 0xb6, 0xbb, 0x13, 0x67, 0x14, 0x7b, 0x67, 0xbb, 0x33, 0x4e, 0x1b, 0x38, 0xc0, 0x47, 1174 0xe8, 0x95, 0x0b, 0x9f, 0x27, 0x47, 0x8e, 0x08, 0x55, 0x81, 0xfa, 0x5b, 0x70, 0x43, 0xf3, 0xd8, 1175 0xcd, 0xc6, 0x8e, 0xbd, 0x4e, 0xd3, 0x70, 0x69, 0x67, 0x66, 0xff, 0xaf, 0xf9, 0xcd, 0xff, 0xf1, 1176 0x73, 0x60, 0xb5, 0x83, 0xd9, 0x6e, 0xff, 0xa9, 0xe5, 0x91, 0x9e, 0xed, 0x91, 0x80, 0xb9, 0x38, 1177 0x40, 0x91, 0x9f, 0x5e, 0xba, 0x21, 0xb6, 0x29, 0x8a, 0xf6, 0xb1, 0x87, 0xa8, 0xcd, 0x5c, 0xba, 1178 0x47, 0xed, 0xfd, 0x1b, 0x72, 0x61, 0x85, 0x11, 0x61, 0x44, 0xbf, 0x76, 0x2c, 0x6d, 0xc5, 0x92, 1179 0x96, 0x14, 0xd8, 0xbf, 0x61, 0xbc, 0xdf, 0x21, 0xa4, 0xd3, 0x45, 0xb6, 0x90, 0x7d, 0xda, 0xdf, 1180 0xb1, 0x51, 0x2f, 0x64, 0x07, 0x52, 0xd5, 0x78, 0x6f, 0xf8, 0xa3, 0x1b, 0xc4, 0x9f, 0x16, 0x3a, 1181 0xa4, 0x43, 0xc4, 0xd2, 0xe6, 0x2b, 0x75, 0x7a, 0x6b, 0xaa, 0x78, 0xd9, 0x41, 0x88, 0xa8, 0xdd, 1182 0x23, 0xfd, 0x80, 0x29, 0xbd, 0xcf, 0xcf, 0xa2, 0x87, 0x58, 0x84, 0x3d, 0x75, 0x3b, 0xe3, 0xf6, 1183 0x19, 0x34, 0x7d, 0x44, 0xbd, 0x08, 0x87, 0x8c, 0x44, 0x4a, 0xf9, 0x8b, 0x33, 0x28, 0x73, 0xc4, 1184 0xc4, 0x3f, 0x4a, 0xb7, 0x31, 0x8c, 0x0d, 0xc3, 0x3d, 0x44, 0x99, 0xdb, 0x0b, 0xa5, 0x80, 0x79, 1185 0x98, 0x83, 0xf9, 0xb5, 0x08, 0xb9, 0x0c, 0x3d, 0x72, 0xe9, 0x9e, 0x83, 0x9e, 0xf5, 0x11, 0x65, 1186 0x7a, 0x0b, 0x66, 0x12, 0xf3, 0xdb, 0xd8, 0xaf, 0x6b, 0xcb, 0x5a, 0xb3, 0xba, 0x7a, 0x65, 0x70, 1187 0xd4, 0xa8, 0xad, 0xc5, 0xe7, 0xed, 0x75, 0xa7, 0x96, 0x08, 0xb5, 0x7d, 0xdd, 0x86, 0x52, 0x44, 1188 0x08, 0xdb, 0xa1, 0xf5, 0xfc, 0x72, 0xbe, 0x59, 0x6b, 0xbd, 0x6b, 0xa5, 0x9e, 0x54, 0x44, 0x67, 1189 0xdd, 0xe3, 0x60, 0x3a, 0x4a, 0x4c, 0x5f, 0x80, 0x22, 0x65, 0x3e, 0x0e, 0xea, 0x05, 0x6e, 0xdd, 1190 0x91, 0x1b, 0x7d, 0x11, 0x4a, 0x94, 0xf9, 0xa4, 0xcf, 0xea, 0x45, 0x71, 0xac, 0x76, 0xea, 0x1c, 1191 0x45, 0x51, 0xbd, 0x94, 0x9c, 0xa3, 0x28, 0xd2, 0x0d, 0xa8, 0x30, 0x14, 0xf5, 0x70, 0xe0, 0x76, 1192 0xeb, 0xe5, 0x65, 0xad, 0x59, 0x71, 0x92, 0xbd, 0x7e, 0x07, 0xc0, 0xdb, 0x45, 0xde, 0x5e, 0x48, 1193 0x70, 0xc0, 0xea, 0x95, 0x65, 0xad, 0x59, 0x6b, 0x5d, 0x1b, 0x0d, 0x6b, 0x3d, 0x41, 0xdc, 0x49, 1194 0xc9, 0xeb, 0x16, 0x94, 0x49, 0xc8, 0x30, 0x09, 0x68, 0xbd, 0x2a, 0x54, 0x17, 0x2c, 0x89, 0xa6, 1195 0x15, 0xa3, 0x69, 0xdd, 0x0d, 0x0e, 0x9c, 0x58, 0xc8, 0x7c, 0x02, 0x7a, 0x1a, 0x49, 0x1a, 0x92, 1196 0x80, 0xa2, 0x37, 0x82, 0x72, 0x0e, 0xf2, 0x21, 0xf6, 0xeb, 0xb9, 0x65, 0xad, 0x39, 0xeb, 0xf0, 1197 0xa5, 0xd9, 0x81, 0x99, 0x87, 0xcc, 0x8d, 0xd8, 0x79, 0x1e, 0xe8, 0x43, 0x28, 0xa3, 0x17, 0xc8, 1198 0xdb, 0x56, 0x96, 0xab, 0xab, 0x30, 0x38, 0x6a, 0x94, 0x36, 0x5e, 0x20, 0xaf, 0xbd, 0xee, 0x94, 1199 0xf8, 0xa7, 0xb6, 0x6f, 0x7e, 0x00, 0xb3, 0xca, 0x91, 0x8a, 0x5f, 0xc5, 0xa2, 0x1d, 0xc7, 0xb2, 1200 0x09, 0xf3, 0xeb, 0xa8, 0x8b, 0xce, 0x9d, 0x31, 0xe6, 0xef, 0x1a, 0x5c, 0x96, 0x96, 0x12, 0x6f, 1201 0x8b, 0x90, 0x4b, 0x94, 0x4b, 0x83, 0xa3, 0x46, 0xae, 0xbd, 0xee, 0xe4, 0xf0, 0x29, 0x88, 0xe8, 1202 0x0d, 0xa8, 0xa1, 0x17, 0x98, 0x6d, 0x53, 0xe6, 0xb2, 0x3e, 0xcf, 0x39, 0xfe, 0x05, 0xf8, 0xd1, 1203 0x43, 0x71, 0xa2, 0xdf, 0x85, 0x2a, 0xdf, 0x21, 0x7f, 0xdb, 0x65, 0x22, 0xc5, 0x6a, 0x2d, 0x63, 1204 0xe4, 0x01, 0x1f, 0xc5, 0xe5, 0xb0, 0x5a, 0x39, 0x3c, 0x6a, 0x5c, 0x7a, 0xf9, 0x77, 0x43, 0x73, 1205 0x2a, 0x52, 0xed, 0x2e, 0x33, 0x09, 0x2c, 0xc8, 0xf8, 0xb6, 0x22, 0xe2, 0x21, 0x4a, 0x2f, 0x1c, 1206 0x7d, 0x04, 0xb0, 0x89, 0x2e, 0xfe, 0x91, 0x37, 0xa0, 0x26, 0xdc, 0x28, 0xd0, 0x6f, 0x41, 0x39, 1207 0x94, 0x17, 0x14, 0x2e, 0x86, 0x6a, 0x64, 0xff, 0x86, 0x2a, 0x93, 0x18, 0x84, 0x58, 0xd8, 0x5c, 1208 0x81, 0xb9, 0x6f, 0x30, 0x65, 0x3c, 0x0d, 0x12, 0x68, 0x16, 0xa1, 0xb4, 0x83, 0xbb, 0x0c, 0x45, 1209 0x32, 0x5a, 0x47, 0xed, 0x78, 0xd2, 0xa4, 0x64, 0x93, 0xda, 0x28, 0x8a, 0x16, 0x5f, 0xd7, 0x44, 1210 0xc7, 0x98, 0xec, 0x56, 0x8a, 0x9a, 0x2f, 0x35, 0xa8, 0x7d, 0x8d, 0xbb, 0xdd, 0x8b, 0x06, 0x49, 1211 0x34, 0x1c, 0xdc, 0xe1, 0x6d, 0x45, 0xe6, 0x96, 0xda, 0xf1, 0x54, 0x74, 0xbb, 0x5d, 0x91, 0x51, 1212 0x15, 0x87, 0x2f, 0xcd, 0x7f, 0x35, 0xd0, 0xb9, 0xf2, 0x5b, 0xc8, 0x92, 0xa4, 0x27, 0xe6, 0x4e, 1213 0xef, 0x89, 0xf9, 0x31, 0x3d, 0xb1, 0x30, 0xb6, 0x27, 0x16, 0x87, 0x7a, 0x62, 0x13, 0x0a, 0x34, 1214 0x44, 0x9e, 0xe8, 0xa2, 0xe3, 0x5a, 0x9a, 0x90, 0x48, 0xa3, 0x54, 0x1e, 0x9b, 0x4a, 0x57, 0xe1, 1215 0x9d, 0x13, 0x57, 0x97, 0x2f, 0x6b, 0xfe, 0xa6, 0xc1, 0x9c, 0x83, 0x28, 0xfe, 0x09, 0x6d, 0xb1, 1216 0x83, 0x0b, 0x7f, 0xaa, 0x05, 0x28, 0x3e, 0xc7, 0x3e, 0xdb, 0x55, 0x2f, 0x25, 0x37, 0x1c, 0x9d, 1217 0x5d, 0x84, 0x3b, 0xbb, 0xb2, 0xfa, 0x67, 0x1d, 0xb5, 0x33, 0x7f, 0x81, 0xcb, 0x6b, 0x5d, 0x42, 1218 0x51, 0xfb, 0xfe, 0xff, 0x11, 0x98, 0x7c, 0xce, 0xbc, 0x78, 0x05, 0xb9, 0x31, 0xbf, 0x82, 0xb9, 1219 0x2d, 0xb7, 0x4f, 0xcf, 0xdd, 0x3f, 0x37, 0x61, 0xde, 0x41, 0xb4, 0xdf, 0x3b, 0xb7, 0xa1, 0x0d, 1220 0xb8, 0xc2, 0x8b, 0x73, 0x0b, 0xfb, 0xe7, 0x49, 0x5e, 0xd3, 0x91, 0xfd, 0x40, 0x9a, 0x51, 0x25, 1221 0xfe, 0x25, 0x54, 0x55, 0xbb, 0x40, 0x71, 0x99, 0x2f, 0x4f, 0x2a, 0xf3, 0x76, 0xb0, 0x43, 0x9c, 1222 0x63, 0x15, 0xf3, 0x95, 0x06, 0x57, 0xd7, 0x92, 0x99, 0x7c, 0x5e, 0x8e, 0xb2, 0x0d, 0xf3, 0xa1, 1223 0x1b, 0xa1, 0x80, 0x6d, 0xa7, 0x78, 0x81, 0x7c, 0xbe, 0x16, 0xef, 0xff, 0x7f, 0x1d, 0x35, 0x56, 1224 0x52, 0x6c, 0x8b, 0x84, 0x28, 0x48, 0xd4, 0xa9, 0xdd, 0x21, 0xd7, 0x7d, 0xdc, 0x41, 0x94, 0x59, 1225 0xeb, 0xe2, 0x3f, 0x67, 0x4e, 0x1a, 0x5b, 0x3b, 0x95, 0x33, 0xe4, 0xa7, 0xe1, 0x0c, 0x8f, 0x61, 1226 0x71, 0xf8, 0x76, 0x09, 0x70, 0xb5, 0x63, 0x26, 0x78, 0x6a, 0x87, 0x1c, 0x21, 0x2f, 0x69, 0x05, 1227 0xf3, 0x67, 0x98, 0xff, 0x36, 0xf4, 0xdf, 0x02, 0xaf, 0x6b, 0x41, 0x35, 0x42, 0x94, 0xf4, 0x23, 1228 0x0f, 0x51, 0x81, 0xd5, 0xb8, 0x4b, 0x1d, 0x8b, 0x99, 0x2b, 0x70, 0xf9, 0x9e, 0x24, 0xc0, 0xb1, 1229 0xe7, 0x3a, 0x94, 0xe5, 0x24, 0x90, 0x57, 0xa9, 0x3a, 0xf1, 0x96, 0x27, 0x5f, 0x22, 0x9b, 0xcc, 1230 0x85, 0xb2, 0xe2, 0xcf, 0xea, 0xde, 0xf5, 0x53, 0xb8, 0xa4, 0x10, 0x70, 0x62, 0x41, 0x73, 0x07, 1231 0x6a, 0xdf, 0xbb, 0xf8, 0xe2, 0x67, 0x67, 0x04, 0x33, 0xd2, 0x8f, 0x8a, 0x75, 0x88, 0x87, 0x68, 1232 0x93, 0x79, 0x48, 0xee, 0x4d, 0x78, 0x48, 0xeb, 0xd5, 0x0c, 0x14, 0xc5, 0xe4, 0xd4, 0xf7, 0xa0, 1233 0x24, 0x39, 0xa6, 0x6e, 0x5b, 0x93, 0x7e, 0x31, 0x59, 0x23, 0x9c, 0xde, 0xf8, 0x74, 0x7a, 0x05, 1234 0x75, 0xb5, 0x1f, 0xa1, 0x28, 0xb8, 0xa0, 0xbe, 0x32, 0x59, 0x35, 0xcd, 0x4c, 0x8d, 0x8f, 0xa7, 1235 0x92, 0x55, 0x1e, 0x3a, 0x50, 0x92, 0x04, 0x2b, 0xeb, 0x3a, 0x23, 0x84, 0xd3, 0xf8, 0x64, 0x1a, 1236 0x85, 0xc4, 0xd1, 0x33, 0x98, 0x3d, 0xc1, 0xe4, 0xf4, 0xd6, 0x34, 0xea, 0x27, 0x07, 0xfa, 0x19, 1237 0x5d, 0x3e, 0x81, 0xfc, 0x26, 0x62, 0x7a, 0x73, 0xb2, 0xd2, 0x31, 0xdd, 0x33, 0x3e, 0x9a, 0x42, 1238 0x32, 0xc1, 0xad, 0xc0, 0x3b, 0xad, 0x6e, 0x4d, 0x56, 0x19, 0x66, 0x67, 0x86, 0x3d, 0xb5, 0xbc, 1239 0x72, 0xd4, 0x86, 0x02, 0x27, 0x5b, 0x7a, 0x46, 0x6c, 0x29, 0x42, 0x66, 0x2c, 0x8e, 0x24, 0xf7, 1240 0x06, 0xff, 0xb1, 0xae, 0x6f, 0x41, 0x81, 0x97, 0x92, 0x9e, 0x91, 0x87, 0xa3, 0x44, 0x6a, 0xac, 1241 0xc5, 0x87, 0x50, 0x4d, 0x38, 0x46, 0x16, 0x14, 0xc3, 0x64, 0x64, 0xac, 0xd1, 0xfb, 0x50, 0x56, 1242 0xec, 0x40, 0xcf, 0x78, 0xef, 0x93, 0x24, 0x62, 0x82, 0xc1, 0xa2, 0x98, 0xf6, 0x59, 0x11, 0x0e, 1243 0x53, 0x82, 0xb1, 0x06, 0x1f, 0x40, 0x49, 0x8e, 0xfd, 0xac, 0xa2, 0x19, 0x21, 0x07, 0x63, 0x4d, 1244 0x62, 0xa8, 0xc4, 0x93, 0x5b, 0xbf, 0x9e, 0x9d, 0x23, 0x29, 0xa2, 0x60, 0x58, 0xd3, 0x8a, 0xab, 1245 0x8c, 0x7a, 0x0e, 0x90, 0x9a, 0x97, 0x37, 0x33, 0x20, 0x3e, 0x6d, 0xf2, 0x1b, 0x9f, 0x9d, 0x4d, 1246 0x49, 0x39, 0x7e, 0x00, 0x25, 0x39, 0x10, 0xb3, 0x60, 0x1b, 0x19, 0x9b, 0x63, 0x61, 0xdb, 0x81, 1247 0xb2, 0x1a, 0x5d, 0x59, 0xb9, 0x72, 0x72, 0x1a, 0x1a, 0xd7, 0xa7, 0x94, 0x56, 0xa1, 0xff, 0x00, 1248 0x05, 0x3e, 0x73, 0xb2, 0xaa, 0x30, 0x35, 0xff, 0x8c, 0x95, 0x69, 0x44, 0xa5, 0xf9, 0xd5, 0xef, 1249 0x0e, 0x5f, 0x2f, 0x5d, 0xfa, 0xf3, 0xf5, 0xd2, 0xa5, 0x5f, 0x07, 0x4b, 0xda, 0xe1, 0x60, 0x49, 1250 0xfb, 0x63, 0xb0, 0xa4, 0xfd, 0x33, 0x58, 0xd2, 0x9e, 0xdc, 0x79, 0xb3, 0xbf, 0xec, 0xdd, 0x16, 1251 0x8b, 0xc7, 0xb9, 0xa7, 0x25, 0x01, 0xd8, 0xcd, 0xff, 0x02, 0x00, 0x00, 0xff, 0xff, 0x85, 0xa2, 1252 0x4f, 0xd1, 0x22, 0x14, 0x00, 0x00, 1253} 1254 1255// Reference imports to suppress errors if they are not otherwise used. 1256var _ context.Context 1257var _ grpc.ClientConn 1258 1259// This is a compile-time assertion to ensure that this generated file 1260// is compatible with the grpc package it is being compiled against. 1261const _ = grpc.SupportPackageIsVersion4 1262 1263// TasksClient is the client API for Tasks service. 1264// 1265// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1266type TasksClient interface { 1267 // Create a task. 1268 Create(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskResponse, error) 1269 // Start a process. 1270 Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) 1271 // Delete a task and on disk state. 1272 Delete(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteResponse, error) 1273 DeleteProcess(ctx context.Context, in *DeleteProcessRequest, opts ...grpc.CallOption) (*DeleteResponse, error) 1274 Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) 1275 List(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) 1276 // Kill a task or process. 1277 Kill(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*types1.Empty, error) 1278 Exec(ctx context.Context, in *ExecProcessRequest, opts ...grpc.CallOption) (*types1.Empty, error) 1279 ResizePty(ctx context.Context, in *ResizePtyRequest, opts ...grpc.CallOption) (*types1.Empty, error) 1280 CloseIO(ctx context.Context, in *CloseIORequest, opts ...grpc.CallOption) (*types1.Empty, error) 1281 Pause(ctx context.Context, in *PauseTaskRequest, opts ...grpc.CallOption) (*types1.Empty, error) 1282 Resume(ctx context.Context, in *ResumeTaskRequest, opts ...grpc.CallOption) (*types1.Empty, error) 1283 ListPids(ctx context.Context, in *ListPidsRequest, opts ...grpc.CallOption) (*ListPidsResponse, error) 1284 Checkpoint(ctx context.Context, in *CheckpointTaskRequest, opts ...grpc.CallOption) (*CheckpointTaskResponse, error) 1285 Update(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*types1.Empty, error) 1286 Metrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*MetricsResponse, error) 1287 Wait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error) 1288} 1289 1290type tasksClient struct { 1291 cc *grpc.ClientConn 1292} 1293 1294func NewTasksClient(cc *grpc.ClientConn) TasksClient { 1295 return &tasksClient{cc} 1296} 1297 1298func (c *tasksClient) Create(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskResponse, error) { 1299 out := new(CreateTaskResponse) 1300 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Create", in, out, opts...) 1301 if err != nil { 1302 return nil, err 1303 } 1304 return out, nil 1305} 1306 1307func (c *tasksClient) Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) { 1308 out := new(StartResponse) 1309 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Start", in, out, opts...) 1310 if err != nil { 1311 return nil, err 1312 } 1313 return out, nil 1314} 1315 1316func (c *tasksClient) Delete(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteResponse, error) { 1317 out := new(DeleteResponse) 1318 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Delete", in, out, opts...) 1319 if err != nil { 1320 return nil, err 1321 } 1322 return out, nil 1323} 1324 1325func (c *tasksClient) DeleteProcess(ctx context.Context, in *DeleteProcessRequest, opts ...grpc.CallOption) (*DeleteResponse, error) { 1326 out := new(DeleteResponse) 1327 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/DeleteProcess", in, out, opts...) 1328 if err != nil { 1329 return nil, err 1330 } 1331 return out, nil 1332} 1333 1334func (c *tasksClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) { 1335 out := new(GetResponse) 1336 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Get", in, out, opts...) 1337 if err != nil { 1338 return nil, err 1339 } 1340 return out, nil 1341} 1342 1343func (c *tasksClient) List(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) { 1344 out := new(ListTasksResponse) 1345 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/List", in, out, opts...) 1346 if err != nil { 1347 return nil, err 1348 } 1349 return out, nil 1350} 1351 1352func (c *tasksClient) Kill(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*types1.Empty, error) { 1353 out := new(types1.Empty) 1354 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Kill", in, out, opts...) 1355 if err != nil { 1356 return nil, err 1357 } 1358 return out, nil 1359} 1360 1361func (c *tasksClient) Exec(ctx context.Context, in *ExecProcessRequest, opts ...grpc.CallOption) (*types1.Empty, error) { 1362 out := new(types1.Empty) 1363 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Exec", in, out, opts...) 1364 if err != nil { 1365 return nil, err 1366 } 1367 return out, nil 1368} 1369 1370func (c *tasksClient) ResizePty(ctx context.Context, in *ResizePtyRequest, opts ...grpc.CallOption) (*types1.Empty, error) { 1371 out := new(types1.Empty) 1372 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/ResizePty", in, out, opts...) 1373 if err != nil { 1374 return nil, err 1375 } 1376 return out, nil 1377} 1378 1379func (c *tasksClient) CloseIO(ctx context.Context, in *CloseIORequest, opts ...grpc.CallOption) (*types1.Empty, error) { 1380 out := new(types1.Empty) 1381 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/CloseIO", in, out, opts...) 1382 if err != nil { 1383 return nil, err 1384 } 1385 return out, nil 1386} 1387 1388func (c *tasksClient) Pause(ctx context.Context, in *PauseTaskRequest, opts ...grpc.CallOption) (*types1.Empty, error) { 1389 out := new(types1.Empty) 1390 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Pause", in, out, opts...) 1391 if err != nil { 1392 return nil, err 1393 } 1394 return out, nil 1395} 1396 1397func (c *tasksClient) Resume(ctx context.Context, in *ResumeTaskRequest, opts ...grpc.CallOption) (*types1.Empty, error) { 1398 out := new(types1.Empty) 1399 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Resume", in, out, opts...) 1400 if err != nil { 1401 return nil, err 1402 } 1403 return out, nil 1404} 1405 1406func (c *tasksClient) ListPids(ctx context.Context, in *ListPidsRequest, opts ...grpc.CallOption) (*ListPidsResponse, error) { 1407 out := new(ListPidsResponse) 1408 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/ListPids", in, out, opts...) 1409 if err != nil { 1410 return nil, err 1411 } 1412 return out, nil 1413} 1414 1415func (c *tasksClient) Checkpoint(ctx context.Context, in *CheckpointTaskRequest, opts ...grpc.CallOption) (*CheckpointTaskResponse, error) { 1416 out := new(CheckpointTaskResponse) 1417 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Checkpoint", in, out, opts...) 1418 if err != nil { 1419 return nil, err 1420 } 1421 return out, nil 1422} 1423 1424func (c *tasksClient) Update(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*types1.Empty, error) { 1425 out := new(types1.Empty) 1426 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Update", in, out, opts...) 1427 if err != nil { 1428 return nil, err 1429 } 1430 return out, nil 1431} 1432 1433func (c *tasksClient) Metrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*MetricsResponse, error) { 1434 out := new(MetricsResponse) 1435 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Metrics", in, out, opts...) 1436 if err != nil { 1437 return nil, err 1438 } 1439 return out, nil 1440} 1441 1442func (c *tasksClient) Wait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error) { 1443 out := new(WaitResponse) 1444 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Wait", in, out, opts...) 1445 if err != nil { 1446 return nil, err 1447 } 1448 return out, nil 1449} 1450 1451// TasksServer is the server API for Tasks service. 1452type TasksServer interface { 1453 // Create a task. 1454 Create(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error) 1455 // Start a process. 1456 Start(context.Context, *StartRequest) (*StartResponse, error) 1457 // Delete a task and on disk state. 1458 Delete(context.Context, *DeleteTaskRequest) (*DeleteResponse, error) 1459 DeleteProcess(context.Context, *DeleteProcessRequest) (*DeleteResponse, error) 1460 Get(context.Context, *GetRequest) (*GetResponse, error) 1461 List(context.Context, *ListTasksRequest) (*ListTasksResponse, error) 1462 // Kill a task or process. 1463 Kill(context.Context, *KillRequest) (*types1.Empty, error) 1464 Exec(context.Context, *ExecProcessRequest) (*types1.Empty, error) 1465 ResizePty(context.Context, *ResizePtyRequest) (*types1.Empty, error) 1466 CloseIO(context.Context, *CloseIORequest) (*types1.Empty, error) 1467 Pause(context.Context, *PauseTaskRequest) (*types1.Empty, error) 1468 Resume(context.Context, *ResumeTaskRequest) (*types1.Empty, error) 1469 ListPids(context.Context, *ListPidsRequest) (*ListPidsResponse, error) 1470 Checkpoint(context.Context, *CheckpointTaskRequest) (*CheckpointTaskResponse, error) 1471 Update(context.Context, *UpdateTaskRequest) (*types1.Empty, error) 1472 Metrics(context.Context, *MetricsRequest) (*MetricsResponse, error) 1473 Wait(context.Context, *WaitRequest) (*WaitResponse, error) 1474} 1475 1476// UnimplementedTasksServer can be embedded to have forward compatible implementations. 1477type UnimplementedTasksServer struct { 1478} 1479 1480func (*UnimplementedTasksServer) Create(ctx context.Context, req *CreateTaskRequest) (*CreateTaskResponse, error) { 1481 return nil, status.Errorf(codes.Unimplemented, "method Create not implemented") 1482} 1483func (*UnimplementedTasksServer) Start(ctx context.Context, req *StartRequest) (*StartResponse, error) { 1484 return nil, status.Errorf(codes.Unimplemented, "method Start not implemented") 1485} 1486func (*UnimplementedTasksServer) Delete(ctx context.Context, req *DeleteTaskRequest) (*DeleteResponse, error) { 1487 return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented") 1488} 1489func (*UnimplementedTasksServer) DeleteProcess(ctx context.Context, req *DeleteProcessRequest) (*DeleteResponse, error) { 1490 return nil, status.Errorf(codes.Unimplemented, "method DeleteProcess not implemented") 1491} 1492func (*UnimplementedTasksServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error) { 1493 return nil, status.Errorf(codes.Unimplemented, "method Get not implemented") 1494} 1495func (*UnimplementedTasksServer) List(ctx context.Context, req *ListTasksRequest) (*ListTasksResponse, error) { 1496 return nil, status.Errorf(codes.Unimplemented, "method List not implemented") 1497} 1498func (*UnimplementedTasksServer) Kill(ctx context.Context, req *KillRequest) (*types1.Empty, error) { 1499 return nil, status.Errorf(codes.Unimplemented, "method Kill not implemented") 1500} 1501func (*UnimplementedTasksServer) Exec(ctx context.Context, req *ExecProcessRequest) (*types1.Empty, error) { 1502 return nil, status.Errorf(codes.Unimplemented, "method Exec not implemented") 1503} 1504func (*UnimplementedTasksServer) ResizePty(ctx context.Context, req *ResizePtyRequest) (*types1.Empty, error) { 1505 return nil, status.Errorf(codes.Unimplemented, "method ResizePty not implemented") 1506} 1507func (*UnimplementedTasksServer) CloseIO(ctx context.Context, req *CloseIORequest) (*types1.Empty, error) { 1508 return nil, status.Errorf(codes.Unimplemented, "method CloseIO not implemented") 1509} 1510func (*UnimplementedTasksServer) Pause(ctx context.Context, req *PauseTaskRequest) (*types1.Empty, error) { 1511 return nil, status.Errorf(codes.Unimplemented, "method Pause not implemented") 1512} 1513func (*UnimplementedTasksServer) Resume(ctx context.Context, req *ResumeTaskRequest) (*types1.Empty, error) { 1514 return nil, status.Errorf(codes.Unimplemented, "method Resume not implemented") 1515} 1516func (*UnimplementedTasksServer) ListPids(ctx context.Context, req *ListPidsRequest) (*ListPidsResponse, error) { 1517 return nil, status.Errorf(codes.Unimplemented, "method ListPids not implemented") 1518} 1519func (*UnimplementedTasksServer) Checkpoint(ctx context.Context, req *CheckpointTaskRequest) (*CheckpointTaskResponse, error) { 1520 return nil, status.Errorf(codes.Unimplemented, "method Checkpoint not implemented") 1521} 1522func (*UnimplementedTasksServer) Update(ctx context.Context, req *UpdateTaskRequest) (*types1.Empty, error) { 1523 return nil, status.Errorf(codes.Unimplemented, "method Update not implemented") 1524} 1525func (*UnimplementedTasksServer) Metrics(ctx context.Context, req *MetricsRequest) (*MetricsResponse, error) { 1526 return nil, status.Errorf(codes.Unimplemented, "method Metrics not implemented") 1527} 1528func (*UnimplementedTasksServer) Wait(ctx context.Context, req *WaitRequest) (*WaitResponse, error) { 1529 return nil, status.Errorf(codes.Unimplemented, "method Wait not implemented") 1530} 1531 1532func RegisterTasksServer(s *grpc.Server, srv TasksServer) { 1533 s.RegisterService(&_Tasks_serviceDesc, srv) 1534} 1535 1536func _Tasks_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1537 in := new(CreateTaskRequest) 1538 if err := dec(in); err != nil { 1539 return nil, err 1540 } 1541 if interceptor == nil { 1542 return srv.(TasksServer).Create(ctx, in) 1543 } 1544 info := &grpc.UnaryServerInfo{ 1545 Server: srv, 1546 FullMethod: "/containerd.services.tasks.v1.Tasks/Create", 1547 } 1548 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1549 return srv.(TasksServer).Create(ctx, req.(*CreateTaskRequest)) 1550 } 1551 return interceptor(ctx, in, info, handler) 1552} 1553 1554func _Tasks_Start_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1555 in := new(StartRequest) 1556 if err := dec(in); err != nil { 1557 return nil, err 1558 } 1559 if interceptor == nil { 1560 return srv.(TasksServer).Start(ctx, in) 1561 } 1562 info := &grpc.UnaryServerInfo{ 1563 Server: srv, 1564 FullMethod: "/containerd.services.tasks.v1.Tasks/Start", 1565 } 1566 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1567 return srv.(TasksServer).Start(ctx, req.(*StartRequest)) 1568 } 1569 return interceptor(ctx, in, info, handler) 1570} 1571 1572func _Tasks_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1573 in := new(DeleteTaskRequest) 1574 if err := dec(in); err != nil { 1575 return nil, err 1576 } 1577 if interceptor == nil { 1578 return srv.(TasksServer).Delete(ctx, in) 1579 } 1580 info := &grpc.UnaryServerInfo{ 1581 Server: srv, 1582 FullMethod: "/containerd.services.tasks.v1.Tasks/Delete", 1583 } 1584 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1585 return srv.(TasksServer).Delete(ctx, req.(*DeleteTaskRequest)) 1586 } 1587 return interceptor(ctx, in, info, handler) 1588} 1589 1590func _Tasks_DeleteProcess_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1591 in := new(DeleteProcessRequest) 1592 if err := dec(in); err != nil { 1593 return nil, err 1594 } 1595 if interceptor == nil { 1596 return srv.(TasksServer).DeleteProcess(ctx, in) 1597 } 1598 info := &grpc.UnaryServerInfo{ 1599 Server: srv, 1600 FullMethod: "/containerd.services.tasks.v1.Tasks/DeleteProcess", 1601 } 1602 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1603 return srv.(TasksServer).DeleteProcess(ctx, req.(*DeleteProcessRequest)) 1604 } 1605 return interceptor(ctx, in, info, handler) 1606} 1607 1608func _Tasks_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1609 in := new(GetRequest) 1610 if err := dec(in); err != nil { 1611 return nil, err 1612 } 1613 if interceptor == nil { 1614 return srv.(TasksServer).Get(ctx, in) 1615 } 1616 info := &grpc.UnaryServerInfo{ 1617 Server: srv, 1618 FullMethod: "/containerd.services.tasks.v1.Tasks/Get", 1619 } 1620 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1621 return srv.(TasksServer).Get(ctx, req.(*GetRequest)) 1622 } 1623 return interceptor(ctx, in, info, handler) 1624} 1625 1626func _Tasks_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1627 in := new(ListTasksRequest) 1628 if err := dec(in); err != nil { 1629 return nil, err 1630 } 1631 if interceptor == nil { 1632 return srv.(TasksServer).List(ctx, in) 1633 } 1634 info := &grpc.UnaryServerInfo{ 1635 Server: srv, 1636 FullMethod: "/containerd.services.tasks.v1.Tasks/List", 1637 } 1638 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1639 return srv.(TasksServer).List(ctx, req.(*ListTasksRequest)) 1640 } 1641 return interceptor(ctx, in, info, handler) 1642} 1643 1644func _Tasks_Kill_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1645 in := new(KillRequest) 1646 if err := dec(in); err != nil { 1647 return nil, err 1648 } 1649 if interceptor == nil { 1650 return srv.(TasksServer).Kill(ctx, in) 1651 } 1652 info := &grpc.UnaryServerInfo{ 1653 Server: srv, 1654 FullMethod: "/containerd.services.tasks.v1.Tasks/Kill", 1655 } 1656 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1657 return srv.(TasksServer).Kill(ctx, req.(*KillRequest)) 1658 } 1659 return interceptor(ctx, in, info, handler) 1660} 1661 1662func _Tasks_Exec_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1663 in := new(ExecProcessRequest) 1664 if err := dec(in); err != nil { 1665 return nil, err 1666 } 1667 if interceptor == nil { 1668 return srv.(TasksServer).Exec(ctx, in) 1669 } 1670 info := &grpc.UnaryServerInfo{ 1671 Server: srv, 1672 FullMethod: "/containerd.services.tasks.v1.Tasks/Exec", 1673 } 1674 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1675 return srv.(TasksServer).Exec(ctx, req.(*ExecProcessRequest)) 1676 } 1677 return interceptor(ctx, in, info, handler) 1678} 1679 1680func _Tasks_ResizePty_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1681 in := new(ResizePtyRequest) 1682 if err := dec(in); err != nil { 1683 return nil, err 1684 } 1685 if interceptor == nil { 1686 return srv.(TasksServer).ResizePty(ctx, in) 1687 } 1688 info := &grpc.UnaryServerInfo{ 1689 Server: srv, 1690 FullMethod: "/containerd.services.tasks.v1.Tasks/ResizePty", 1691 } 1692 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1693 return srv.(TasksServer).ResizePty(ctx, req.(*ResizePtyRequest)) 1694 } 1695 return interceptor(ctx, in, info, handler) 1696} 1697 1698func _Tasks_CloseIO_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1699 in := new(CloseIORequest) 1700 if err := dec(in); err != nil { 1701 return nil, err 1702 } 1703 if interceptor == nil { 1704 return srv.(TasksServer).CloseIO(ctx, in) 1705 } 1706 info := &grpc.UnaryServerInfo{ 1707 Server: srv, 1708 FullMethod: "/containerd.services.tasks.v1.Tasks/CloseIO", 1709 } 1710 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1711 return srv.(TasksServer).CloseIO(ctx, req.(*CloseIORequest)) 1712 } 1713 return interceptor(ctx, in, info, handler) 1714} 1715 1716func _Tasks_Pause_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1717 in := new(PauseTaskRequest) 1718 if err := dec(in); err != nil { 1719 return nil, err 1720 } 1721 if interceptor == nil { 1722 return srv.(TasksServer).Pause(ctx, in) 1723 } 1724 info := &grpc.UnaryServerInfo{ 1725 Server: srv, 1726 FullMethod: "/containerd.services.tasks.v1.Tasks/Pause", 1727 } 1728 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1729 return srv.(TasksServer).Pause(ctx, req.(*PauseTaskRequest)) 1730 } 1731 return interceptor(ctx, in, info, handler) 1732} 1733 1734func _Tasks_Resume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1735 in := new(ResumeTaskRequest) 1736 if err := dec(in); err != nil { 1737 return nil, err 1738 } 1739 if interceptor == nil { 1740 return srv.(TasksServer).Resume(ctx, in) 1741 } 1742 info := &grpc.UnaryServerInfo{ 1743 Server: srv, 1744 FullMethod: "/containerd.services.tasks.v1.Tasks/Resume", 1745 } 1746 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1747 return srv.(TasksServer).Resume(ctx, req.(*ResumeTaskRequest)) 1748 } 1749 return interceptor(ctx, in, info, handler) 1750} 1751 1752func _Tasks_ListPids_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1753 in := new(ListPidsRequest) 1754 if err := dec(in); err != nil { 1755 return nil, err 1756 } 1757 if interceptor == nil { 1758 return srv.(TasksServer).ListPids(ctx, in) 1759 } 1760 info := &grpc.UnaryServerInfo{ 1761 Server: srv, 1762 FullMethod: "/containerd.services.tasks.v1.Tasks/ListPids", 1763 } 1764 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1765 return srv.(TasksServer).ListPids(ctx, req.(*ListPidsRequest)) 1766 } 1767 return interceptor(ctx, in, info, handler) 1768} 1769 1770func _Tasks_Checkpoint_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1771 in := new(CheckpointTaskRequest) 1772 if err := dec(in); err != nil { 1773 return nil, err 1774 } 1775 if interceptor == nil { 1776 return srv.(TasksServer).Checkpoint(ctx, in) 1777 } 1778 info := &grpc.UnaryServerInfo{ 1779 Server: srv, 1780 FullMethod: "/containerd.services.tasks.v1.Tasks/Checkpoint", 1781 } 1782 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1783 return srv.(TasksServer).Checkpoint(ctx, req.(*CheckpointTaskRequest)) 1784 } 1785 return interceptor(ctx, in, info, handler) 1786} 1787 1788func _Tasks_Update_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1789 in := new(UpdateTaskRequest) 1790 if err := dec(in); err != nil { 1791 return nil, err 1792 } 1793 if interceptor == nil { 1794 return srv.(TasksServer).Update(ctx, in) 1795 } 1796 info := &grpc.UnaryServerInfo{ 1797 Server: srv, 1798 FullMethod: "/containerd.services.tasks.v1.Tasks/Update", 1799 } 1800 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1801 return srv.(TasksServer).Update(ctx, req.(*UpdateTaskRequest)) 1802 } 1803 return interceptor(ctx, in, info, handler) 1804} 1805 1806func _Tasks_Metrics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1807 in := new(MetricsRequest) 1808 if err := dec(in); err != nil { 1809 return nil, err 1810 } 1811 if interceptor == nil { 1812 return srv.(TasksServer).Metrics(ctx, in) 1813 } 1814 info := &grpc.UnaryServerInfo{ 1815 Server: srv, 1816 FullMethod: "/containerd.services.tasks.v1.Tasks/Metrics", 1817 } 1818 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1819 return srv.(TasksServer).Metrics(ctx, req.(*MetricsRequest)) 1820 } 1821 return interceptor(ctx, in, info, handler) 1822} 1823 1824func _Tasks_Wait_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1825 in := new(WaitRequest) 1826 if err := dec(in); err != nil { 1827 return nil, err 1828 } 1829 if interceptor == nil { 1830 return srv.(TasksServer).Wait(ctx, in) 1831 } 1832 info := &grpc.UnaryServerInfo{ 1833 Server: srv, 1834 FullMethod: "/containerd.services.tasks.v1.Tasks/Wait", 1835 } 1836 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1837 return srv.(TasksServer).Wait(ctx, req.(*WaitRequest)) 1838 } 1839 return interceptor(ctx, in, info, handler) 1840} 1841 1842var _Tasks_serviceDesc = grpc.ServiceDesc{ 1843 ServiceName: "containerd.services.tasks.v1.Tasks", 1844 HandlerType: (*TasksServer)(nil), 1845 Methods: []grpc.MethodDesc{ 1846 { 1847 MethodName: "Create", 1848 Handler: _Tasks_Create_Handler, 1849 }, 1850 { 1851 MethodName: "Start", 1852 Handler: _Tasks_Start_Handler, 1853 }, 1854 { 1855 MethodName: "Delete", 1856 Handler: _Tasks_Delete_Handler, 1857 }, 1858 { 1859 MethodName: "DeleteProcess", 1860 Handler: _Tasks_DeleteProcess_Handler, 1861 }, 1862 { 1863 MethodName: "Get", 1864 Handler: _Tasks_Get_Handler, 1865 }, 1866 { 1867 MethodName: "List", 1868 Handler: _Tasks_List_Handler, 1869 }, 1870 { 1871 MethodName: "Kill", 1872 Handler: _Tasks_Kill_Handler, 1873 }, 1874 { 1875 MethodName: "Exec", 1876 Handler: _Tasks_Exec_Handler, 1877 }, 1878 { 1879 MethodName: "ResizePty", 1880 Handler: _Tasks_ResizePty_Handler, 1881 }, 1882 { 1883 MethodName: "CloseIO", 1884 Handler: _Tasks_CloseIO_Handler, 1885 }, 1886 { 1887 MethodName: "Pause", 1888 Handler: _Tasks_Pause_Handler, 1889 }, 1890 { 1891 MethodName: "Resume", 1892 Handler: _Tasks_Resume_Handler, 1893 }, 1894 { 1895 MethodName: "ListPids", 1896 Handler: _Tasks_ListPids_Handler, 1897 }, 1898 { 1899 MethodName: "Checkpoint", 1900 Handler: _Tasks_Checkpoint_Handler, 1901 }, 1902 { 1903 MethodName: "Update", 1904 Handler: _Tasks_Update_Handler, 1905 }, 1906 { 1907 MethodName: "Metrics", 1908 Handler: _Tasks_Metrics_Handler, 1909 }, 1910 { 1911 MethodName: "Wait", 1912 Handler: _Tasks_Wait_Handler, 1913 }, 1914 }, 1915 Streams: []grpc.StreamDesc{}, 1916 Metadata: "github.com/containerd/containerd/api/services/tasks/v1/tasks.proto", 1917} 1918 1919func (m *CreateTaskRequest) Marshal() (dAtA []byte, err error) { 1920 size := m.Size() 1921 dAtA = make([]byte, size) 1922 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1923 if err != nil { 1924 return nil, err 1925 } 1926 return dAtA[:n], nil 1927} 1928 1929func (m *CreateTaskRequest) MarshalTo(dAtA []byte) (int, error) { 1930 size := m.Size() 1931 return m.MarshalToSizedBuffer(dAtA[:size]) 1932} 1933 1934func (m *CreateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1935 i := len(dAtA) 1936 _ = i 1937 var l int 1938 _ = l 1939 if m.XXX_unrecognized != nil { 1940 i -= len(m.XXX_unrecognized) 1941 copy(dAtA[i:], m.XXX_unrecognized) 1942 } 1943 if m.Options != nil { 1944 { 1945 size, err := m.Options.MarshalToSizedBuffer(dAtA[:i]) 1946 if err != nil { 1947 return 0, err 1948 } 1949 i -= size 1950 i = encodeVarintTasks(dAtA, i, uint64(size)) 1951 } 1952 i-- 1953 dAtA[i] = 0x4a 1954 } 1955 if m.Checkpoint != nil { 1956 { 1957 size, err := m.Checkpoint.MarshalToSizedBuffer(dAtA[:i]) 1958 if err != nil { 1959 return 0, err 1960 } 1961 i -= size 1962 i = encodeVarintTasks(dAtA, i, uint64(size)) 1963 } 1964 i-- 1965 dAtA[i] = 0x42 1966 } 1967 if m.Terminal { 1968 i-- 1969 if m.Terminal { 1970 dAtA[i] = 1 1971 } else { 1972 dAtA[i] = 0 1973 } 1974 i-- 1975 dAtA[i] = 0x38 1976 } 1977 if len(m.Stderr) > 0 { 1978 i -= len(m.Stderr) 1979 copy(dAtA[i:], m.Stderr) 1980 i = encodeVarintTasks(dAtA, i, uint64(len(m.Stderr))) 1981 i-- 1982 dAtA[i] = 0x32 1983 } 1984 if len(m.Stdout) > 0 { 1985 i -= len(m.Stdout) 1986 copy(dAtA[i:], m.Stdout) 1987 i = encodeVarintTasks(dAtA, i, uint64(len(m.Stdout))) 1988 i-- 1989 dAtA[i] = 0x2a 1990 } 1991 if len(m.Stdin) > 0 { 1992 i -= len(m.Stdin) 1993 copy(dAtA[i:], m.Stdin) 1994 i = encodeVarintTasks(dAtA, i, uint64(len(m.Stdin))) 1995 i-- 1996 dAtA[i] = 0x22 1997 } 1998 if len(m.Rootfs) > 0 { 1999 for iNdEx := len(m.Rootfs) - 1; iNdEx >= 0; iNdEx-- { 2000 { 2001 size, err := m.Rootfs[iNdEx].MarshalToSizedBuffer(dAtA[:i]) 2002 if err != nil { 2003 return 0, err 2004 } 2005 i -= size 2006 i = encodeVarintTasks(dAtA, i, uint64(size)) 2007 } 2008 i-- 2009 dAtA[i] = 0x1a 2010 } 2011 } 2012 if len(m.ContainerID) > 0 { 2013 i -= len(m.ContainerID) 2014 copy(dAtA[i:], m.ContainerID) 2015 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2016 i-- 2017 dAtA[i] = 0xa 2018 } 2019 return len(dAtA) - i, nil 2020} 2021 2022func (m *CreateTaskResponse) Marshal() (dAtA []byte, err error) { 2023 size := m.Size() 2024 dAtA = make([]byte, size) 2025 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2026 if err != nil { 2027 return nil, err 2028 } 2029 return dAtA[:n], nil 2030} 2031 2032func (m *CreateTaskResponse) MarshalTo(dAtA []byte) (int, error) { 2033 size := m.Size() 2034 return m.MarshalToSizedBuffer(dAtA[:size]) 2035} 2036 2037func (m *CreateTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2038 i := len(dAtA) 2039 _ = i 2040 var l int 2041 _ = l 2042 if m.XXX_unrecognized != nil { 2043 i -= len(m.XXX_unrecognized) 2044 copy(dAtA[i:], m.XXX_unrecognized) 2045 } 2046 if m.Pid != 0 { 2047 i = encodeVarintTasks(dAtA, i, uint64(m.Pid)) 2048 i-- 2049 dAtA[i] = 0x10 2050 } 2051 if len(m.ContainerID) > 0 { 2052 i -= len(m.ContainerID) 2053 copy(dAtA[i:], m.ContainerID) 2054 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2055 i-- 2056 dAtA[i] = 0xa 2057 } 2058 return len(dAtA) - i, nil 2059} 2060 2061func (m *StartRequest) Marshal() (dAtA []byte, err error) { 2062 size := m.Size() 2063 dAtA = make([]byte, size) 2064 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2065 if err != nil { 2066 return nil, err 2067 } 2068 return dAtA[:n], nil 2069} 2070 2071func (m *StartRequest) MarshalTo(dAtA []byte) (int, error) { 2072 size := m.Size() 2073 return m.MarshalToSizedBuffer(dAtA[:size]) 2074} 2075 2076func (m *StartRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2077 i := len(dAtA) 2078 _ = i 2079 var l int 2080 _ = l 2081 if m.XXX_unrecognized != nil { 2082 i -= len(m.XXX_unrecognized) 2083 copy(dAtA[i:], m.XXX_unrecognized) 2084 } 2085 if len(m.ExecID) > 0 { 2086 i -= len(m.ExecID) 2087 copy(dAtA[i:], m.ExecID) 2088 i = encodeVarintTasks(dAtA, i, uint64(len(m.ExecID))) 2089 i-- 2090 dAtA[i] = 0x12 2091 } 2092 if len(m.ContainerID) > 0 { 2093 i -= len(m.ContainerID) 2094 copy(dAtA[i:], m.ContainerID) 2095 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2096 i-- 2097 dAtA[i] = 0xa 2098 } 2099 return len(dAtA) - i, nil 2100} 2101 2102func (m *StartResponse) Marshal() (dAtA []byte, err error) { 2103 size := m.Size() 2104 dAtA = make([]byte, size) 2105 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2106 if err != nil { 2107 return nil, err 2108 } 2109 return dAtA[:n], nil 2110} 2111 2112func (m *StartResponse) MarshalTo(dAtA []byte) (int, error) { 2113 size := m.Size() 2114 return m.MarshalToSizedBuffer(dAtA[:size]) 2115} 2116 2117func (m *StartResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2118 i := len(dAtA) 2119 _ = i 2120 var l int 2121 _ = l 2122 if m.XXX_unrecognized != nil { 2123 i -= len(m.XXX_unrecognized) 2124 copy(dAtA[i:], m.XXX_unrecognized) 2125 } 2126 if m.Pid != 0 { 2127 i = encodeVarintTasks(dAtA, i, uint64(m.Pid)) 2128 i-- 2129 dAtA[i] = 0x8 2130 } 2131 return len(dAtA) - i, nil 2132} 2133 2134func (m *DeleteTaskRequest) Marshal() (dAtA []byte, err error) { 2135 size := m.Size() 2136 dAtA = make([]byte, size) 2137 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2138 if err != nil { 2139 return nil, err 2140 } 2141 return dAtA[:n], nil 2142} 2143 2144func (m *DeleteTaskRequest) MarshalTo(dAtA []byte) (int, error) { 2145 size := m.Size() 2146 return m.MarshalToSizedBuffer(dAtA[:size]) 2147} 2148 2149func (m *DeleteTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2150 i := len(dAtA) 2151 _ = i 2152 var l int 2153 _ = l 2154 if m.XXX_unrecognized != nil { 2155 i -= len(m.XXX_unrecognized) 2156 copy(dAtA[i:], m.XXX_unrecognized) 2157 } 2158 if len(m.ContainerID) > 0 { 2159 i -= len(m.ContainerID) 2160 copy(dAtA[i:], m.ContainerID) 2161 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2162 i-- 2163 dAtA[i] = 0xa 2164 } 2165 return len(dAtA) - i, nil 2166} 2167 2168func (m *DeleteResponse) Marshal() (dAtA []byte, err error) { 2169 size := m.Size() 2170 dAtA = make([]byte, size) 2171 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2172 if err != nil { 2173 return nil, err 2174 } 2175 return dAtA[:n], nil 2176} 2177 2178func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error) { 2179 size := m.Size() 2180 return m.MarshalToSizedBuffer(dAtA[:size]) 2181} 2182 2183func (m *DeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2184 i := len(dAtA) 2185 _ = i 2186 var l int 2187 _ = l 2188 if m.XXX_unrecognized != nil { 2189 i -= len(m.XXX_unrecognized) 2190 copy(dAtA[i:], m.XXX_unrecognized) 2191 } 2192 n3, err3 := github_com_gogo_protobuf_types.StdTimeMarshalTo(m.ExitedAt, dAtA[i-github_com_gogo_protobuf_types.SizeOfStdTime(m.ExitedAt):]) 2193 if err3 != nil { 2194 return 0, err3 2195 } 2196 i -= n3 2197 i = encodeVarintTasks(dAtA, i, uint64(n3)) 2198 i-- 2199 dAtA[i] = 0x22 2200 if m.ExitStatus != 0 { 2201 i = encodeVarintTasks(dAtA, i, uint64(m.ExitStatus)) 2202 i-- 2203 dAtA[i] = 0x18 2204 } 2205 if m.Pid != 0 { 2206 i = encodeVarintTasks(dAtA, i, uint64(m.Pid)) 2207 i-- 2208 dAtA[i] = 0x10 2209 } 2210 if len(m.ID) > 0 { 2211 i -= len(m.ID) 2212 copy(dAtA[i:], m.ID) 2213 i = encodeVarintTasks(dAtA, i, uint64(len(m.ID))) 2214 i-- 2215 dAtA[i] = 0xa 2216 } 2217 return len(dAtA) - i, nil 2218} 2219 2220func (m *DeleteProcessRequest) Marshal() (dAtA []byte, err error) { 2221 size := m.Size() 2222 dAtA = make([]byte, size) 2223 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2224 if err != nil { 2225 return nil, err 2226 } 2227 return dAtA[:n], nil 2228} 2229 2230func (m *DeleteProcessRequest) MarshalTo(dAtA []byte) (int, error) { 2231 size := m.Size() 2232 return m.MarshalToSizedBuffer(dAtA[:size]) 2233} 2234 2235func (m *DeleteProcessRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2236 i := len(dAtA) 2237 _ = i 2238 var l int 2239 _ = l 2240 if m.XXX_unrecognized != nil { 2241 i -= len(m.XXX_unrecognized) 2242 copy(dAtA[i:], m.XXX_unrecognized) 2243 } 2244 if len(m.ExecID) > 0 { 2245 i -= len(m.ExecID) 2246 copy(dAtA[i:], m.ExecID) 2247 i = encodeVarintTasks(dAtA, i, uint64(len(m.ExecID))) 2248 i-- 2249 dAtA[i] = 0x12 2250 } 2251 if len(m.ContainerID) > 0 { 2252 i -= len(m.ContainerID) 2253 copy(dAtA[i:], m.ContainerID) 2254 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2255 i-- 2256 dAtA[i] = 0xa 2257 } 2258 return len(dAtA) - i, nil 2259} 2260 2261func (m *GetRequest) Marshal() (dAtA []byte, err error) { 2262 size := m.Size() 2263 dAtA = make([]byte, size) 2264 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2265 if err != nil { 2266 return nil, err 2267 } 2268 return dAtA[:n], nil 2269} 2270 2271func (m *GetRequest) MarshalTo(dAtA []byte) (int, error) { 2272 size := m.Size() 2273 return m.MarshalToSizedBuffer(dAtA[:size]) 2274} 2275 2276func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2277 i := len(dAtA) 2278 _ = i 2279 var l int 2280 _ = l 2281 if m.XXX_unrecognized != nil { 2282 i -= len(m.XXX_unrecognized) 2283 copy(dAtA[i:], m.XXX_unrecognized) 2284 } 2285 if len(m.ExecID) > 0 { 2286 i -= len(m.ExecID) 2287 copy(dAtA[i:], m.ExecID) 2288 i = encodeVarintTasks(dAtA, i, uint64(len(m.ExecID))) 2289 i-- 2290 dAtA[i] = 0x12 2291 } 2292 if len(m.ContainerID) > 0 { 2293 i -= len(m.ContainerID) 2294 copy(dAtA[i:], m.ContainerID) 2295 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2296 i-- 2297 dAtA[i] = 0xa 2298 } 2299 return len(dAtA) - i, nil 2300} 2301 2302func (m *GetResponse) Marshal() (dAtA []byte, err error) { 2303 size := m.Size() 2304 dAtA = make([]byte, size) 2305 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2306 if err != nil { 2307 return nil, err 2308 } 2309 return dAtA[:n], nil 2310} 2311 2312func (m *GetResponse) MarshalTo(dAtA []byte) (int, error) { 2313 size := m.Size() 2314 return m.MarshalToSizedBuffer(dAtA[:size]) 2315} 2316 2317func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2318 i := len(dAtA) 2319 _ = i 2320 var l int 2321 _ = l 2322 if m.XXX_unrecognized != nil { 2323 i -= len(m.XXX_unrecognized) 2324 copy(dAtA[i:], m.XXX_unrecognized) 2325 } 2326 if m.Process != nil { 2327 { 2328 size, err := m.Process.MarshalToSizedBuffer(dAtA[:i]) 2329 if err != nil { 2330 return 0, err 2331 } 2332 i -= size 2333 i = encodeVarintTasks(dAtA, i, uint64(size)) 2334 } 2335 i-- 2336 dAtA[i] = 0xa 2337 } 2338 return len(dAtA) - i, nil 2339} 2340 2341func (m *ListTasksRequest) Marshal() (dAtA []byte, err error) { 2342 size := m.Size() 2343 dAtA = make([]byte, size) 2344 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2345 if err != nil { 2346 return nil, err 2347 } 2348 return dAtA[:n], nil 2349} 2350 2351func (m *ListTasksRequest) MarshalTo(dAtA []byte) (int, error) { 2352 size := m.Size() 2353 return m.MarshalToSizedBuffer(dAtA[:size]) 2354} 2355 2356func (m *ListTasksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2357 i := len(dAtA) 2358 _ = i 2359 var l int 2360 _ = l 2361 if m.XXX_unrecognized != nil { 2362 i -= len(m.XXX_unrecognized) 2363 copy(dAtA[i:], m.XXX_unrecognized) 2364 } 2365 if len(m.Filter) > 0 { 2366 i -= len(m.Filter) 2367 copy(dAtA[i:], m.Filter) 2368 i = encodeVarintTasks(dAtA, i, uint64(len(m.Filter))) 2369 i-- 2370 dAtA[i] = 0xa 2371 } 2372 return len(dAtA) - i, nil 2373} 2374 2375func (m *ListTasksResponse) Marshal() (dAtA []byte, err error) { 2376 size := m.Size() 2377 dAtA = make([]byte, size) 2378 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2379 if err != nil { 2380 return nil, err 2381 } 2382 return dAtA[:n], nil 2383} 2384 2385func (m *ListTasksResponse) MarshalTo(dAtA []byte) (int, error) { 2386 size := m.Size() 2387 return m.MarshalToSizedBuffer(dAtA[:size]) 2388} 2389 2390func (m *ListTasksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2391 i := len(dAtA) 2392 _ = i 2393 var l int 2394 _ = l 2395 if m.XXX_unrecognized != nil { 2396 i -= len(m.XXX_unrecognized) 2397 copy(dAtA[i:], m.XXX_unrecognized) 2398 } 2399 if len(m.Tasks) > 0 { 2400 for iNdEx := len(m.Tasks) - 1; iNdEx >= 0; iNdEx-- { 2401 { 2402 size, err := m.Tasks[iNdEx].MarshalToSizedBuffer(dAtA[:i]) 2403 if err != nil { 2404 return 0, err 2405 } 2406 i -= size 2407 i = encodeVarintTasks(dAtA, i, uint64(size)) 2408 } 2409 i-- 2410 dAtA[i] = 0xa 2411 } 2412 } 2413 return len(dAtA) - i, nil 2414} 2415 2416func (m *KillRequest) Marshal() (dAtA []byte, err error) { 2417 size := m.Size() 2418 dAtA = make([]byte, size) 2419 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2420 if err != nil { 2421 return nil, err 2422 } 2423 return dAtA[:n], nil 2424} 2425 2426func (m *KillRequest) MarshalTo(dAtA []byte) (int, error) { 2427 size := m.Size() 2428 return m.MarshalToSizedBuffer(dAtA[:size]) 2429} 2430 2431func (m *KillRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2432 i := len(dAtA) 2433 _ = i 2434 var l int 2435 _ = l 2436 if m.XXX_unrecognized != nil { 2437 i -= len(m.XXX_unrecognized) 2438 copy(dAtA[i:], m.XXX_unrecognized) 2439 } 2440 if m.All { 2441 i-- 2442 if m.All { 2443 dAtA[i] = 1 2444 } else { 2445 dAtA[i] = 0 2446 } 2447 i-- 2448 dAtA[i] = 0x20 2449 } 2450 if m.Signal != 0 { 2451 i = encodeVarintTasks(dAtA, i, uint64(m.Signal)) 2452 i-- 2453 dAtA[i] = 0x18 2454 } 2455 if len(m.ExecID) > 0 { 2456 i -= len(m.ExecID) 2457 copy(dAtA[i:], m.ExecID) 2458 i = encodeVarintTasks(dAtA, i, uint64(len(m.ExecID))) 2459 i-- 2460 dAtA[i] = 0x12 2461 } 2462 if len(m.ContainerID) > 0 { 2463 i -= len(m.ContainerID) 2464 copy(dAtA[i:], m.ContainerID) 2465 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2466 i-- 2467 dAtA[i] = 0xa 2468 } 2469 return len(dAtA) - i, nil 2470} 2471 2472func (m *ExecProcessRequest) Marshal() (dAtA []byte, err error) { 2473 size := m.Size() 2474 dAtA = make([]byte, size) 2475 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2476 if err != nil { 2477 return nil, err 2478 } 2479 return dAtA[:n], nil 2480} 2481 2482func (m *ExecProcessRequest) MarshalTo(dAtA []byte) (int, error) { 2483 size := m.Size() 2484 return m.MarshalToSizedBuffer(dAtA[:size]) 2485} 2486 2487func (m *ExecProcessRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2488 i := len(dAtA) 2489 _ = i 2490 var l int 2491 _ = l 2492 if m.XXX_unrecognized != nil { 2493 i -= len(m.XXX_unrecognized) 2494 copy(dAtA[i:], m.XXX_unrecognized) 2495 } 2496 if len(m.ExecID) > 0 { 2497 i -= len(m.ExecID) 2498 copy(dAtA[i:], m.ExecID) 2499 i = encodeVarintTasks(dAtA, i, uint64(len(m.ExecID))) 2500 i-- 2501 dAtA[i] = 0x3a 2502 } 2503 if m.Spec != nil { 2504 { 2505 size, err := m.Spec.MarshalToSizedBuffer(dAtA[:i]) 2506 if err != nil { 2507 return 0, err 2508 } 2509 i -= size 2510 i = encodeVarintTasks(dAtA, i, uint64(size)) 2511 } 2512 i-- 2513 dAtA[i] = 0x32 2514 } 2515 if m.Terminal { 2516 i-- 2517 if m.Terminal { 2518 dAtA[i] = 1 2519 } else { 2520 dAtA[i] = 0 2521 } 2522 i-- 2523 dAtA[i] = 0x28 2524 } 2525 if len(m.Stderr) > 0 { 2526 i -= len(m.Stderr) 2527 copy(dAtA[i:], m.Stderr) 2528 i = encodeVarintTasks(dAtA, i, uint64(len(m.Stderr))) 2529 i-- 2530 dAtA[i] = 0x22 2531 } 2532 if len(m.Stdout) > 0 { 2533 i -= len(m.Stdout) 2534 copy(dAtA[i:], m.Stdout) 2535 i = encodeVarintTasks(dAtA, i, uint64(len(m.Stdout))) 2536 i-- 2537 dAtA[i] = 0x1a 2538 } 2539 if len(m.Stdin) > 0 { 2540 i -= len(m.Stdin) 2541 copy(dAtA[i:], m.Stdin) 2542 i = encodeVarintTasks(dAtA, i, uint64(len(m.Stdin))) 2543 i-- 2544 dAtA[i] = 0x12 2545 } 2546 if len(m.ContainerID) > 0 { 2547 i -= len(m.ContainerID) 2548 copy(dAtA[i:], m.ContainerID) 2549 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2550 i-- 2551 dAtA[i] = 0xa 2552 } 2553 return len(dAtA) - i, nil 2554} 2555 2556func (m *ExecProcessResponse) Marshal() (dAtA []byte, err error) { 2557 size := m.Size() 2558 dAtA = make([]byte, size) 2559 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2560 if err != nil { 2561 return nil, err 2562 } 2563 return dAtA[:n], nil 2564} 2565 2566func (m *ExecProcessResponse) MarshalTo(dAtA []byte) (int, error) { 2567 size := m.Size() 2568 return m.MarshalToSizedBuffer(dAtA[:size]) 2569} 2570 2571func (m *ExecProcessResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2572 i := len(dAtA) 2573 _ = i 2574 var l int 2575 _ = l 2576 if m.XXX_unrecognized != nil { 2577 i -= len(m.XXX_unrecognized) 2578 copy(dAtA[i:], m.XXX_unrecognized) 2579 } 2580 return len(dAtA) - i, nil 2581} 2582 2583func (m *ResizePtyRequest) Marshal() (dAtA []byte, err error) { 2584 size := m.Size() 2585 dAtA = make([]byte, size) 2586 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2587 if err != nil { 2588 return nil, err 2589 } 2590 return dAtA[:n], nil 2591} 2592 2593func (m *ResizePtyRequest) MarshalTo(dAtA []byte) (int, error) { 2594 size := m.Size() 2595 return m.MarshalToSizedBuffer(dAtA[:size]) 2596} 2597 2598func (m *ResizePtyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2599 i := len(dAtA) 2600 _ = i 2601 var l int 2602 _ = l 2603 if m.XXX_unrecognized != nil { 2604 i -= len(m.XXX_unrecognized) 2605 copy(dAtA[i:], m.XXX_unrecognized) 2606 } 2607 if m.Height != 0 { 2608 i = encodeVarintTasks(dAtA, i, uint64(m.Height)) 2609 i-- 2610 dAtA[i] = 0x20 2611 } 2612 if m.Width != 0 { 2613 i = encodeVarintTasks(dAtA, i, uint64(m.Width)) 2614 i-- 2615 dAtA[i] = 0x18 2616 } 2617 if len(m.ExecID) > 0 { 2618 i -= len(m.ExecID) 2619 copy(dAtA[i:], m.ExecID) 2620 i = encodeVarintTasks(dAtA, i, uint64(len(m.ExecID))) 2621 i-- 2622 dAtA[i] = 0x12 2623 } 2624 if len(m.ContainerID) > 0 { 2625 i -= len(m.ContainerID) 2626 copy(dAtA[i:], m.ContainerID) 2627 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2628 i-- 2629 dAtA[i] = 0xa 2630 } 2631 return len(dAtA) - i, nil 2632} 2633 2634func (m *CloseIORequest) Marshal() (dAtA []byte, err error) { 2635 size := m.Size() 2636 dAtA = make([]byte, size) 2637 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2638 if err != nil { 2639 return nil, err 2640 } 2641 return dAtA[:n], nil 2642} 2643 2644func (m *CloseIORequest) MarshalTo(dAtA []byte) (int, error) { 2645 size := m.Size() 2646 return m.MarshalToSizedBuffer(dAtA[:size]) 2647} 2648 2649func (m *CloseIORequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2650 i := len(dAtA) 2651 _ = i 2652 var l int 2653 _ = l 2654 if m.XXX_unrecognized != nil { 2655 i -= len(m.XXX_unrecognized) 2656 copy(dAtA[i:], m.XXX_unrecognized) 2657 } 2658 if m.Stdin { 2659 i-- 2660 if m.Stdin { 2661 dAtA[i] = 1 2662 } else { 2663 dAtA[i] = 0 2664 } 2665 i-- 2666 dAtA[i] = 0x18 2667 } 2668 if len(m.ExecID) > 0 { 2669 i -= len(m.ExecID) 2670 copy(dAtA[i:], m.ExecID) 2671 i = encodeVarintTasks(dAtA, i, uint64(len(m.ExecID))) 2672 i-- 2673 dAtA[i] = 0x12 2674 } 2675 if len(m.ContainerID) > 0 { 2676 i -= len(m.ContainerID) 2677 copy(dAtA[i:], m.ContainerID) 2678 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2679 i-- 2680 dAtA[i] = 0xa 2681 } 2682 return len(dAtA) - i, nil 2683} 2684 2685func (m *PauseTaskRequest) Marshal() (dAtA []byte, err error) { 2686 size := m.Size() 2687 dAtA = make([]byte, size) 2688 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2689 if err != nil { 2690 return nil, err 2691 } 2692 return dAtA[:n], nil 2693} 2694 2695func (m *PauseTaskRequest) MarshalTo(dAtA []byte) (int, error) { 2696 size := m.Size() 2697 return m.MarshalToSizedBuffer(dAtA[:size]) 2698} 2699 2700func (m *PauseTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2701 i := len(dAtA) 2702 _ = i 2703 var l int 2704 _ = l 2705 if m.XXX_unrecognized != nil { 2706 i -= len(m.XXX_unrecognized) 2707 copy(dAtA[i:], m.XXX_unrecognized) 2708 } 2709 if len(m.ContainerID) > 0 { 2710 i -= len(m.ContainerID) 2711 copy(dAtA[i:], m.ContainerID) 2712 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2713 i-- 2714 dAtA[i] = 0xa 2715 } 2716 return len(dAtA) - i, nil 2717} 2718 2719func (m *ResumeTaskRequest) Marshal() (dAtA []byte, err error) { 2720 size := m.Size() 2721 dAtA = make([]byte, size) 2722 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2723 if err != nil { 2724 return nil, err 2725 } 2726 return dAtA[:n], nil 2727} 2728 2729func (m *ResumeTaskRequest) MarshalTo(dAtA []byte) (int, error) { 2730 size := m.Size() 2731 return m.MarshalToSizedBuffer(dAtA[:size]) 2732} 2733 2734func (m *ResumeTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2735 i := len(dAtA) 2736 _ = i 2737 var l int 2738 _ = l 2739 if m.XXX_unrecognized != nil { 2740 i -= len(m.XXX_unrecognized) 2741 copy(dAtA[i:], m.XXX_unrecognized) 2742 } 2743 if len(m.ContainerID) > 0 { 2744 i -= len(m.ContainerID) 2745 copy(dAtA[i:], m.ContainerID) 2746 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2747 i-- 2748 dAtA[i] = 0xa 2749 } 2750 return len(dAtA) - i, nil 2751} 2752 2753func (m *ListPidsRequest) Marshal() (dAtA []byte, err error) { 2754 size := m.Size() 2755 dAtA = make([]byte, size) 2756 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2757 if err != nil { 2758 return nil, err 2759 } 2760 return dAtA[:n], nil 2761} 2762 2763func (m *ListPidsRequest) MarshalTo(dAtA []byte) (int, error) { 2764 size := m.Size() 2765 return m.MarshalToSizedBuffer(dAtA[:size]) 2766} 2767 2768func (m *ListPidsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2769 i := len(dAtA) 2770 _ = i 2771 var l int 2772 _ = l 2773 if m.XXX_unrecognized != nil { 2774 i -= len(m.XXX_unrecognized) 2775 copy(dAtA[i:], m.XXX_unrecognized) 2776 } 2777 if len(m.ContainerID) > 0 { 2778 i -= len(m.ContainerID) 2779 copy(dAtA[i:], m.ContainerID) 2780 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2781 i-- 2782 dAtA[i] = 0xa 2783 } 2784 return len(dAtA) - i, nil 2785} 2786 2787func (m *ListPidsResponse) Marshal() (dAtA []byte, err error) { 2788 size := m.Size() 2789 dAtA = make([]byte, size) 2790 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2791 if err != nil { 2792 return nil, err 2793 } 2794 return dAtA[:n], nil 2795} 2796 2797func (m *ListPidsResponse) MarshalTo(dAtA []byte) (int, error) { 2798 size := m.Size() 2799 return m.MarshalToSizedBuffer(dAtA[:size]) 2800} 2801 2802func (m *ListPidsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2803 i := len(dAtA) 2804 _ = i 2805 var l int 2806 _ = l 2807 if m.XXX_unrecognized != nil { 2808 i -= len(m.XXX_unrecognized) 2809 copy(dAtA[i:], m.XXX_unrecognized) 2810 } 2811 if len(m.Processes) > 0 { 2812 for iNdEx := len(m.Processes) - 1; iNdEx >= 0; iNdEx-- { 2813 { 2814 size, err := m.Processes[iNdEx].MarshalToSizedBuffer(dAtA[:i]) 2815 if err != nil { 2816 return 0, err 2817 } 2818 i -= size 2819 i = encodeVarintTasks(dAtA, i, uint64(size)) 2820 } 2821 i-- 2822 dAtA[i] = 0xa 2823 } 2824 } 2825 return len(dAtA) - i, nil 2826} 2827 2828func (m *CheckpointTaskRequest) Marshal() (dAtA []byte, err error) { 2829 size := m.Size() 2830 dAtA = make([]byte, size) 2831 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2832 if err != nil { 2833 return nil, err 2834 } 2835 return dAtA[:n], nil 2836} 2837 2838func (m *CheckpointTaskRequest) MarshalTo(dAtA []byte) (int, error) { 2839 size := m.Size() 2840 return m.MarshalToSizedBuffer(dAtA[:size]) 2841} 2842 2843func (m *CheckpointTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2844 i := len(dAtA) 2845 _ = i 2846 var l int 2847 _ = l 2848 if m.XXX_unrecognized != nil { 2849 i -= len(m.XXX_unrecognized) 2850 copy(dAtA[i:], m.XXX_unrecognized) 2851 } 2852 if m.Options != nil { 2853 { 2854 size, err := m.Options.MarshalToSizedBuffer(dAtA[:i]) 2855 if err != nil { 2856 return 0, err 2857 } 2858 i -= size 2859 i = encodeVarintTasks(dAtA, i, uint64(size)) 2860 } 2861 i-- 2862 dAtA[i] = 0x1a 2863 } 2864 if len(m.ParentCheckpoint) > 0 { 2865 i -= len(m.ParentCheckpoint) 2866 copy(dAtA[i:], m.ParentCheckpoint) 2867 i = encodeVarintTasks(dAtA, i, uint64(len(m.ParentCheckpoint))) 2868 i-- 2869 dAtA[i] = 0x12 2870 } 2871 if len(m.ContainerID) > 0 { 2872 i -= len(m.ContainerID) 2873 copy(dAtA[i:], m.ContainerID) 2874 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2875 i-- 2876 dAtA[i] = 0xa 2877 } 2878 return len(dAtA) - i, nil 2879} 2880 2881func (m *CheckpointTaskResponse) Marshal() (dAtA []byte, err error) { 2882 size := m.Size() 2883 dAtA = make([]byte, size) 2884 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2885 if err != nil { 2886 return nil, err 2887 } 2888 return dAtA[:n], nil 2889} 2890 2891func (m *CheckpointTaskResponse) MarshalTo(dAtA []byte) (int, error) { 2892 size := m.Size() 2893 return m.MarshalToSizedBuffer(dAtA[:size]) 2894} 2895 2896func (m *CheckpointTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2897 i := len(dAtA) 2898 _ = i 2899 var l int 2900 _ = l 2901 if m.XXX_unrecognized != nil { 2902 i -= len(m.XXX_unrecognized) 2903 copy(dAtA[i:], m.XXX_unrecognized) 2904 } 2905 if len(m.Descriptors) > 0 { 2906 for iNdEx := len(m.Descriptors) - 1; iNdEx >= 0; iNdEx-- { 2907 { 2908 size, err := m.Descriptors[iNdEx].MarshalToSizedBuffer(dAtA[:i]) 2909 if err != nil { 2910 return 0, err 2911 } 2912 i -= size 2913 i = encodeVarintTasks(dAtA, i, uint64(size)) 2914 } 2915 i-- 2916 dAtA[i] = 0xa 2917 } 2918 } 2919 return len(dAtA) - i, nil 2920} 2921 2922func (m *UpdateTaskRequest) Marshal() (dAtA []byte, err error) { 2923 size := m.Size() 2924 dAtA = make([]byte, size) 2925 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2926 if err != nil { 2927 return nil, err 2928 } 2929 return dAtA[:n], nil 2930} 2931 2932func (m *UpdateTaskRequest) MarshalTo(dAtA []byte) (int, error) { 2933 size := m.Size() 2934 return m.MarshalToSizedBuffer(dAtA[:size]) 2935} 2936 2937func (m *UpdateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2938 i := len(dAtA) 2939 _ = i 2940 var l int 2941 _ = l 2942 if m.XXX_unrecognized != nil { 2943 i -= len(m.XXX_unrecognized) 2944 copy(dAtA[i:], m.XXX_unrecognized) 2945 } 2946 if m.Resources != nil { 2947 { 2948 size, err := m.Resources.MarshalToSizedBuffer(dAtA[:i]) 2949 if err != nil { 2950 return 0, err 2951 } 2952 i -= size 2953 i = encodeVarintTasks(dAtA, i, uint64(size)) 2954 } 2955 i-- 2956 dAtA[i] = 0x12 2957 } 2958 if len(m.ContainerID) > 0 { 2959 i -= len(m.ContainerID) 2960 copy(dAtA[i:], m.ContainerID) 2961 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 2962 i-- 2963 dAtA[i] = 0xa 2964 } 2965 return len(dAtA) - i, nil 2966} 2967 2968func (m *MetricsRequest) Marshal() (dAtA []byte, err error) { 2969 size := m.Size() 2970 dAtA = make([]byte, size) 2971 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 2972 if err != nil { 2973 return nil, err 2974 } 2975 return dAtA[:n], nil 2976} 2977 2978func (m *MetricsRequest) MarshalTo(dAtA []byte) (int, error) { 2979 size := m.Size() 2980 return m.MarshalToSizedBuffer(dAtA[:size]) 2981} 2982 2983func (m *MetricsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 2984 i := len(dAtA) 2985 _ = i 2986 var l int 2987 _ = l 2988 if m.XXX_unrecognized != nil { 2989 i -= len(m.XXX_unrecognized) 2990 copy(dAtA[i:], m.XXX_unrecognized) 2991 } 2992 if len(m.Filters) > 0 { 2993 for iNdEx := len(m.Filters) - 1; iNdEx >= 0; iNdEx-- { 2994 i -= len(m.Filters[iNdEx]) 2995 copy(dAtA[i:], m.Filters[iNdEx]) 2996 i = encodeVarintTasks(dAtA, i, uint64(len(m.Filters[iNdEx]))) 2997 i-- 2998 dAtA[i] = 0xa 2999 } 3000 } 3001 return len(dAtA) - i, nil 3002} 3003 3004func (m *MetricsResponse) Marshal() (dAtA []byte, err error) { 3005 size := m.Size() 3006 dAtA = make([]byte, size) 3007 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 3008 if err != nil { 3009 return nil, err 3010 } 3011 return dAtA[:n], nil 3012} 3013 3014func (m *MetricsResponse) MarshalTo(dAtA []byte) (int, error) { 3015 size := m.Size() 3016 return m.MarshalToSizedBuffer(dAtA[:size]) 3017} 3018 3019func (m *MetricsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 3020 i := len(dAtA) 3021 _ = i 3022 var l int 3023 _ = l 3024 if m.XXX_unrecognized != nil { 3025 i -= len(m.XXX_unrecognized) 3026 copy(dAtA[i:], m.XXX_unrecognized) 3027 } 3028 if len(m.Metrics) > 0 { 3029 for iNdEx := len(m.Metrics) - 1; iNdEx >= 0; iNdEx-- { 3030 { 3031 size, err := m.Metrics[iNdEx].MarshalToSizedBuffer(dAtA[:i]) 3032 if err != nil { 3033 return 0, err 3034 } 3035 i -= size 3036 i = encodeVarintTasks(dAtA, i, uint64(size)) 3037 } 3038 i-- 3039 dAtA[i] = 0xa 3040 } 3041 } 3042 return len(dAtA) - i, nil 3043} 3044 3045func (m *WaitRequest) Marshal() (dAtA []byte, err error) { 3046 size := m.Size() 3047 dAtA = make([]byte, size) 3048 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 3049 if err != nil { 3050 return nil, err 3051 } 3052 return dAtA[:n], nil 3053} 3054 3055func (m *WaitRequest) MarshalTo(dAtA []byte) (int, error) { 3056 size := m.Size() 3057 return m.MarshalToSizedBuffer(dAtA[:size]) 3058} 3059 3060func (m *WaitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 3061 i := len(dAtA) 3062 _ = i 3063 var l int 3064 _ = l 3065 if m.XXX_unrecognized != nil { 3066 i -= len(m.XXX_unrecognized) 3067 copy(dAtA[i:], m.XXX_unrecognized) 3068 } 3069 if len(m.ExecID) > 0 { 3070 i -= len(m.ExecID) 3071 copy(dAtA[i:], m.ExecID) 3072 i = encodeVarintTasks(dAtA, i, uint64(len(m.ExecID))) 3073 i-- 3074 dAtA[i] = 0x12 3075 } 3076 if len(m.ContainerID) > 0 { 3077 i -= len(m.ContainerID) 3078 copy(dAtA[i:], m.ContainerID) 3079 i = encodeVarintTasks(dAtA, i, uint64(len(m.ContainerID))) 3080 i-- 3081 dAtA[i] = 0xa 3082 } 3083 return len(dAtA) - i, nil 3084} 3085 3086func (m *WaitResponse) Marshal() (dAtA []byte, err error) { 3087 size := m.Size() 3088 dAtA = make([]byte, size) 3089 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 3090 if err != nil { 3091 return nil, err 3092 } 3093 return dAtA[:n], nil 3094} 3095 3096func (m *WaitResponse) MarshalTo(dAtA []byte) (int, error) { 3097 size := m.Size() 3098 return m.MarshalToSizedBuffer(dAtA[:size]) 3099} 3100 3101func (m *WaitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 3102 i := len(dAtA) 3103 _ = i 3104 var l int 3105 _ = l 3106 if m.XXX_unrecognized != nil { 3107 i -= len(m.XXX_unrecognized) 3108 copy(dAtA[i:], m.XXX_unrecognized) 3109 } 3110 n8, err8 := github_com_gogo_protobuf_types.StdTimeMarshalTo(m.ExitedAt, dAtA[i-github_com_gogo_protobuf_types.SizeOfStdTime(m.ExitedAt):]) 3111 if err8 != nil { 3112 return 0, err8 3113 } 3114 i -= n8 3115 i = encodeVarintTasks(dAtA, i, uint64(n8)) 3116 i-- 3117 dAtA[i] = 0x12 3118 if m.ExitStatus != 0 { 3119 i = encodeVarintTasks(dAtA, i, uint64(m.ExitStatus)) 3120 i-- 3121 dAtA[i] = 0x8 3122 } 3123 return len(dAtA) - i, nil 3124} 3125 3126func encodeVarintTasks(dAtA []byte, offset int, v uint64) int { 3127 offset -= sovTasks(v) 3128 base := offset 3129 for v >= 1<<7 { 3130 dAtA[offset] = uint8(v&0x7f | 0x80) 3131 v >>= 7 3132 offset++ 3133 } 3134 dAtA[offset] = uint8(v) 3135 return base 3136} 3137func (m *CreateTaskRequest) Size() (n int) { 3138 if m == nil { 3139 return 0 3140 } 3141 var l int 3142 _ = l 3143 l = len(m.ContainerID) 3144 if l > 0 { 3145 n += 1 + l + sovTasks(uint64(l)) 3146 } 3147 if len(m.Rootfs) > 0 { 3148 for _, e := range m.Rootfs { 3149 l = e.Size() 3150 n += 1 + l + sovTasks(uint64(l)) 3151 } 3152 } 3153 l = len(m.Stdin) 3154 if l > 0 { 3155 n += 1 + l + sovTasks(uint64(l)) 3156 } 3157 l = len(m.Stdout) 3158 if l > 0 { 3159 n += 1 + l + sovTasks(uint64(l)) 3160 } 3161 l = len(m.Stderr) 3162 if l > 0 { 3163 n += 1 + l + sovTasks(uint64(l)) 3164 } 3165 if m.Terminal { 3166 n += 2 3167 } 3168 if m.Checkpoint != nil { 3169 l = m.Checkpoint.Size() 3170 n += 1 + l + sovTasks(uint64(l)) 3171 } 3172 if m.Options != nil { 3173 l = m.Options.Size() 3174 n += 1 + l + sovTasks(uint64(l)) 3175 } 3176 if m.XXX_unrecognized != nil { 3177 n += len(m.XXX_unrecognized) 3178 } 3179 return n 3180} 3181 3182func (m *CreateTaskResponse) Size() (n int) { 3183 if m == nil { 3184 return 0 3185 } 3186 var l int 3187 _ = l 3188 l = len(m.ContainerID) 3189 if l > 0 { 3190 n += 1 + l + sovTasks(uint64(l)) 3191 } 3192 if m.Pid != 0 { 3193 n += 1 + sovTasks(uint64(m.Pid)) 3194 } 3195 if m.XXX_unrecognized != nil { 3196 n += len(m.XXX_unrecognized) 3197 } 3198 return n 3199} 3200 3201func (m *StartRequest) Size() (n int) { 3202 if m == nil { 3203 return 0 3204 } 3205 var l int 3206 _ = l 3207 l = len(m.ContainerID) 3208 if l > 0 { 3209 n += 1 + l + sovTasks(uint64(l)) 3210 } 3211 l = len(m.ExecID) 3212 if l > 0 { 3213 n += 1 + l + sovTasks(uint64(l)) 3214 } 3215 if m.XXX_unrecognized != nil { 3216 n += len(m.XXX_unrecognized) 3217 } 3218 return n 3219} 3220 3221func (m *StartResponse) Size() (n int) { 3222 if m == nil { 3223 return 0 3224 } 3225 var l int 3226 _ = l 3227 if m.Pid != 0 { 3228 n += 1 + sovTasks(uint64(m.Pid)) 3229 } 3230 if m.XXX_unrecognized != nil { 3231 n += len(m.XXX_unrecognized) 3232 } 3233 return n 3234} 3235 3236func (m *DeleteTaskRequest) Size() (n int) { 3237 if m == nil { 3238 return 0 3239 } 3240 var l int 3241 _ = l 3242 l = len(m.ContainerID) 3243 if l > 0 { 3244 n += 1 + l + sovTasks(uint64(l)) 3245 } 3246 if m.XXX_unrecognized != nil { 3247 n += len(m.XXX_unrecognized) 3248 } 3249 return n 3250} 3251 3252func (m *DeleteResponse) Size() (n int) { 3253 if m == nil { 3254 return 0 3255 } 3256 var l int 3257 _ = l 3258 l = len(m.ID) 3259 if l > 0 { 3260 n += 1 + l + sovTasks(uint64(l)) 3261 } 3262 if m.Pid != 0 { 3263 n += 1 + sovTasks(uint64(m.Pid)) 3264 } 3265 if m.ExitStatus != 0 { 3266 n += 1 + sovTasks(uint64(m.ExitStatus)) 3267 } 3268 l = github_com_gogo_protobuf_types.SizeOfStdTime(m.ExitedAt) 3269 n += 1 + l + sovTasks(uint64(l)) 3270 if m.XXX_unrecognized != nil { 3271 n += len(m.XXX_unrecognized) 3272 } 3273 return n 3274} 3275 3276func (m *DeleteProcessRequest) Size() (n int) { 3277 if m == nil { 3278 return 0 3279 } 3280 var l int 3281 _ = l 3282 l = len(m.ContainerID) 3283 if l > 0 { 3284 n += 1 + l + sovTasks(uint64(l)) 3285 } 3286 l = len(m.ExecID) 3287 if l > 0 { 3288 n += 1 + l + sovTasks(uint64(l)) 3289 } 3290 if m.XXX_unrecognized != nil { 3291 n += len(m.XXX_unrecognized) 3292 } 3293 return n 3294} 3295 3296func (m *GetRequest) Size() (n int) { 3297 if m == nil { 3298 return 0 3299 } 3300 var l int 3301 _ = l 3302 l = len(m.ContainerID) 3303 if l > 0 { 3304 n += 1 + l + sovTasks(uint64(l)) 3305 } 3306 l = len(m.ExecID) 3307 if l > 0 { 3308 n += 1 + l + sovTasks(uint64(l)) 3309 } 3310 if m.XXX_unrecognized != nil { 3311 n += len(m.XXX_unrecognized) 3312 } 3313 return n 3314} 3315 3316func (m *GetResponse) Size() (n int) { 3317 if m == nil { 3318 return 0 3319 } 3320 var l int 3321 _ = l 3322 if m.Process != nil { 3323 l = m.Process.Size() 3324 n += 1 + l + sovTasks(uint64(l)) 3325 } 3326 if m.XXX_unrecognized != nil { 3327 n += len(m.XXX_unrecognized) 3328 } 3329 return n 3330} 3331 3332func (m *ListTasksRequest) Size() (n int) { 3333 if m == nil { 3334 return 0 3335 } 3336 var l int 3337 _ = l 3338 l = len(m.Filter) 3339 if l > 0 { 3340 n += 1 + l + sovTasks(uint64(l)) 3341 } 3342 if m.XXX_unrecognized != nil { 3343 n += len(m.XXX_unrecognized) 3344 } 3345 return n 3346} 3347 3348func (m *ListTasksResponse) Size() (n int) { 3349 if m == nil { 3350 return 0 3351 } 3352 var l int 3353 _ = l 3354 if len(m.Tasks) > 0 { 3355 for _, e := range m.Tasks { 3356 l = e.Size() 3357 n += 1 + l + sovTasks(uint64(l)) 3358 } 3359 } 3360 if m.XXX_unrecognized != nil { 3361 n += len(m.XXX_unrecognized) 3362 } 3363 return n 3364} 3365 3366func (m *KillRequest) Size() (n int) { 3367 if m == nil { 3368 return 0 3369 } 3370 var l int 3371 _ = l 3372 l = len(m.ContainerID) 3373 if l > 0 { 3374 n += 1 + l + sovTasks(uint64(l)) 3375 } 3376 l = len(m.ExecID) 3377 if l > 0 { 3378 n += 1 + l + sovTasks(uint64(l)) 3379 } 3380 if m.Signal != 0 { 3381 n += 1 + sovTasks(uint64(m.Signal)) 3382 } 3383 if m.All { 3384 n += 2 3385 } 3386 if m.XXX_unrecognized != nil { 3387 n += len(m.XXX_unrecognized) 3388 } 3389 return n 3390} 3391 3392func (m *ExecProcessRequest) Size() (n int) { 3393 if m == nil { 3394 return 0 3395 } 3396 var l int 3397 _ = l 3398 l = len(m.ContainerID) 3399 if l > 0 { 3400 n += 1 + l + sovTasks(uint64(l)) 3401 } 3402 l = len(m.Stdin) 3403 if l > 0 { 3404 n += 1 + l + sovTasks(uint64(l)) 3405 } 3406 l = len(m.Stdout) 3407 if l > 0 { 3408 n += 1 + l + sovTasks(uint64(l)) 3409 } 3410 l = len(m.Stderr) 3411 if l > 0 { 3412 n += 1 + l + sovTasks(uint64(l)) 3413 } 3414 if m.Terminal { 3415 n += 2 3416 } 3417 if m.Spec != nil { 3418 l = m.Spec.Size() 3419 n += 1 + l + sovTasks(uint64(l)) 3420 } 3421 l = len(m.ExecID) 3422 if l > 0 { 3423 n += 1 + l + sovTasks(uint64(l)) 3424 } 3425 if m.XXX_unrecognized != nil { 3426 n += len(m.XXX_unrecognized) 3427 } 3428 return n 3429} 3430 3431func (m *ExecProcessResponse) Size() (n int) { 3432 if m == nil { 3433 return 0 3434 } 3435 var l int 3436 _ = l 3437 if m.XXX_unrecognized != nil { 3438 n += len(m.XXX_unrecognized) 3439 } 3440 return n 3441} 3442 3443func (m *ResizePtyRequest) Size() (n int) { 3444 if m == nil { 3445 return 0 3446 } 3447 var l int 3448 _ = l 3449 l = len(m.ContainerID) 3450 if l > 0 { 3451 n += 1 + l + sovTasks(uint64(l)) 3452 } 3453 l = len(m.ExecID) 3454 if l > 0 { 3455 n += 1 + l + sovTasks(uint64(l)) 3456 } 3457 if m.Width != 0 { 3458 n += 1 + sovTasks(uint64(m.Width)) 3459 } 3460 if m.Height != 0 { 3461 n += 1 + sovTasks(uint64(m.Height)) 3462 } 3463 if m.XXX_unrecognized != nil { 3464 n += len(m.XXX_unrecognized) 3465 } 3466 return n 3467} 3468 3469func (m *CloseIORequest) Size() (n int) { 3470 if m == nil { 3471 return 0 3472 } 3473 var l int 3474 _ = l 3475 l = len(m.ContainerID) 3476 if l > 0 { 3477 n += 1 + l + sovTasks(uint64(l)) 3478 } 3479 l = len(m.ExecID) 3480 if l > 0 { 3481 n += 1 + l + sovTasks(uint64(l)) 3482 } 3483 if m.Stdin { 3484 n += 2 3485 } 3486 if m.XXX_unrecognized != nil { 3487 n += len(m.XXX_unrecognized) 3488 } 3489 return n 3490} 3491 3492func (m *PauseTaskRequest) Size() (n int) { 3493 if m == nil { 3494 return 0 3495 } 3496 var l int 3497 _ = l 3498 l = len(m.ContainerID) 3499 if l > 0 { 3500 n += 1 + l + sovTasks(uint64(l)) 3501 } 3502 if m.XXX_unrecognized != nil { 3503 n += len(m.XXX_unrecognized) 3504 } 3505 return n 3506} 3507 3508func (m *ResumeTaskRequest) Size() (n int) { 3509 if m == nil { 3510 return 0 3511 } 3512 var l int 3513 _ = l 3514 l = len(m.ContainerID) 3515 if l > 0 { 3516 n += 1 + l + sovTasks(uint64(l)) 3517 } 3518 if m.XXX_unrecognized != nil { 3519 n += len(m.XXX_unrecognized) 3520 } 3521 return n 3522} 3523 3524func (m *ListPidsRequest) Size() (n int) { 3525 if m == nil { 3526 return 0 3527 } 3528 var l int 3529 _ = l 3530 l = len(m.ContainerID) 3531 if l > 0 { 3532 n += 1 + l + sovTasks(uint64(l)) 3533 } 3534 if m.XXX_unrecognized != nil { 3535 n += len(m.XXX_unrecognized) 3536 } 3537 return n 3538} 3539 3540func (m *ListPidsResponse) Size() (n int) { 3541 if m == nil { 3542 return 0 3543 } 3544 var l int 3545 _ = l 3546 if len(m.Processes) > 0 { 3547 for _, e := range m.Processes { 3548 l = e.Size() 3549 n += 1 + l + sovTasks(uint64(l)) 3550 } 3551 } 3552 if m.XXX_unrecognized != nil { 3553 n += len(m.XXX_unrecognized) 3554 } 3555 return n 3556} 3557 3558func (m *CheckpointTaskRequest) Size() (n int) { 3559 if m == nil { 3560 return 0 3561 } 3562 var l int 3563 _ = l 3564 l = len(m.ContainerID) 3565 if l > 0 { 3566 n += 1 + l + sovTasks(uint64(l)) 3567 } 3568 l = len(m.ParentCheckpoint) 3569 if l > 0 { 3570 n += 1 + l + sovTasks(uint64(l)) 3571 } 3572 if m.Options != nil { 3573 l = m.Options.Size() 3574 n += 1 + l + sovTasks(uint64(l)) 3575 } 3576 if m.XXX_unrecognized != nil { 3577 n += len(m.XXX_unrecognized) 3578 } 3579 return n 3580} 3581 3582func (m *CheckpointTaskResponse) Size() (n int) { 3583 if m == nil { 3584 return 0 3585 } 3586 var l int 3587 _ = l 3588 if len(m.Descriptors) > 0 { 3589 for _, e := range m.Descriptors { 3590 l = e.Size() 3591 n += 1 + l + sovTasks(uint64(l)) 3592 } 3593 } 3594 if m.XXX_unrecognized != nil { 3595 n += len(m.XXX_unrecognized) 3596 } 3597 return n 3598} 3599 3600func (m *UpdateTaskRequest) Size() (n int) { 3601 if m == nil { 3602 return 0 3603 } 3604 var l int 3605 _ = l 3606 l = len(m.ContainerID) 3607 if l > 0 { 3608 n += 1 + l + sovTasks(uint64(l)) 3609 } 3610 if m.Resources != nil { 3611 l = m.Resources.Size() 3612 n += 1 + l + sovTasks(uint64(l)) 3613 } 3614 if m.XXX_unrecognized != nil { 3615 n += len(m.XXX_unrecognized) 3616 } 3617 return n 3618} 3619 3620func (m *MetricsRequest) Size() (n int) { 3621 if m == nil { 3622 return 0 3623 } 3624 var l int 3625 _ = l 3626 if len(m.Filters) > 0 { 3627 for _, s := range m.Filters { 3628 l = len(s) 3629 n += 1 + l + sovTasks(uint64(l)) 3630 } 3631 } 3632 if m.XXX_unrecognized != nil { 3633 n += len(m.XXX_unrecognized) 3634 } 3635 return n 3636} 3637 3638func (m *MetricsResponse) Size() (n int) { 3639 if m == nil { 3640 return 0 3641 } 3642 var l int 3643 _ = l 3644 if len(m.Metrics) > 0 { 3645 for _, e := range m.Metrics { 3646 l = e.Size() 3647 n += 1 + l + sovTasks(uint64(l)) 3648 } 3649 } 3650 if m.XXX_unrecognized != nil { 3651 n += len(m.XXX_unrecognized) 3652 } 3653 return n 3654} 3655 3656func (m *WaitRequest) Size() (n int) { 3657 if m == nil { 3658 return 0 3659 } 3660 var l int 3661 _ = l 3662 l = len(m.ContainerID) 3663 if l > 0 { 3664 n += 1 + l + sovTasks(uint64(l)) 3665 } 3666 l = len(m.ExecID) 3667 if l > 0 { 3668 n += 1 + l + sovTasks(uint64(l)) 3669 } 3670 if m.XXX_unrecognized != nil { 3671 n += len(m.XXX_unrecognized) 3672 } 3673 return n 3674} 3675 3676func (m *WaitResponse) Size() (n int) { 3677 if m == nil { 3678 return 0 3679 } 3680 var l int 3681 _ = l 3682 if m.ExitStatus != 0 { 3683 n += 1 + sovTasks(uint64(m.ExitStatus)) 3684 } 3685 l = github_com_gogo_protobuf_types.SizeOfStdTime(m.ExitedAt) 3686 n += 1 + l + sovTasks(uint64(l)) 3687 if m.XXX_unrecognized != nil { 3688 n += len(m.XXX_unrecognized) 3689 } 3690 return n 3691} 3692 3693func sovTasks(x uint64) (n int) { 3694 return (math_bits.Len64(x|1) + 6) / 7 3695} 3696func sozTasks(x uint64) (n int) { 3697 return sovTasks(uint64((x << 1) ^ uint64((int64(x) >> 63)))) 3698} 3699func (this *CreateTaskRequest) String() string { 3700 if this == nil { 3701 return "nil" 3702 } 3703 repeatedStringForRootfs := "[]*Mount{" 3704 for _, f := range this.Rootfs { 3705 repeatedStringForRootfs += strings.Replace(fmt.Sprintf("%v", f), "Mount", "types.Mount", 1) + "," 3706 } 3707 repeatedStringForRootfs += "}" 3708 s := strings.Join([]string{`&CreateTaskRequest{`, 3709 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3710 `Rootfs:` + repeatedStringForRootfs + `,`, 3711 `Stdin:` + fmt.Sprintf("%v", this.Stdin) + `,`, 3712 `Stdout:` + fmt.Sprintf("%v", this.Stdout) + `,`, 3713 `Stderr:` + fmt.Sprintf("%v", this.Stderr) + `,`, 3714 `Terminal:` + fmt.Sprintf("%v", this.Terminal) + `,`, 3715 `Checkpoint:` + strings.Replace(fmt.Sprintf("%v", this.Checkpoint), "Descriptor", "types.Descriptor", 1) + `,`, 3716 `Options:` + strings.Replace(fmt.Sprintf("%v", this.Options), "Any", "types1.Any", 1) + `,`, 3717 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3718 `}`, 3719 }, "") 3720 return s 3721} 3722func (this *CreateTaskResponse) String() string { 3723 if this == nil { 3724 return "nil" 3725 } 3726 s := strings.Join([]string{`&CreateTaskResponse{`, 3727 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3728 `Pid:` + fmt.Sprintf("%v", this.Pid) + `,`, 3729 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3730 `}`, 3731 }, "") 3732 return s 3733} 3734func (this *StartRequest) String() string { 3735 if this == nil { 3736 return "nil" 3737 } 3738 s := strings.Join([]string{`&StartRequest{`, 3739 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3740 `ExecID:` + fmt.Sprintf("%v", this.ExecID) + `,`, 3741 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3742 `}`, 3743 }, "") 3744 return s 3745} 3746func (this *StartResponse) String() string { 3747 if this == nil { 3748 return "nil" 3749 } 3750 s := strings.Join([]string{`&StartResponse{`, 3751 `Pid:` + fmt.Sprintf("%v", this.Pid) + `,`, 3752 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3753 `}`, 3754 }, "") 3755 return s 3756} 3757func (this *DeleteTaskRequest) String() string { 3758 if this == nil { 3759 return "nil" 3760 } 3761 s := strings.Join([]string{`&DeleteTaskRequest{`, 3762 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3763 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3764 `}`, 3765 }, "") 3766 return s 3767} 3768func (this *DeleteResponse) String() string { 3769 if this == nil { 3770 return "nil" 3771 } 3772 s := strings.Join([]string{`&DeleteResponse{`, 3773 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 3774 `Pid:` + fmt.Sprintf("%v", this.Pid) + `,`, 3775 `ExitStatus:` + fmt.Sprintf("%v", this.ExitStatus) + `,`, 3776 `ExitedAt:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.ExitedAt), "Timestamp", "types1.Timestamp", 1), `&`, ``, 1) + `,`, 3777 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3778 `}`, 3779 }, "") 3780 return s 3781} 3782func (this *DeleteProcessRequest) String() string { 3783 if this == nil { 3784 return "nil" 3785 } 3786 s := strings.Join([]string{`&DeleteProcessRequest{`, 3787 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3788 `ExecID:` + fmt.Sprintf("%v", this.ExecID) + `,`, 3789 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3790 `}`, 3791 }, "") 3792 return s 3793} 3794func (this *GetRequest) String() string { 3795 if this == nil { 3796 return "nil" 3797 } 3798 s := strings.Join([]string{`&GetRequest{`, 3799 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3800 `ExecID:` + fmt.Sprintf("%v", this.ExecID) + `,`, 3801 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3802 `}`, 3803 }, "") 3804 return s 3805} 3806func (this *GetResponse) String() string { 3807 if this == nil { 3808 return "nil" 3809 } 3810 s := strings.Join([]string{`&GetResponse{`, 3811 `Process:` + strings.Replace(fmt.Sprintf("%v", this.Process), "Process", "task.Process", 1) + `,`, 3812 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3813 `}`, 3814 }, "") 3815 return s 3816} 3817func (this *ListTasksRequest) String() string { 3818 if this == nil { 3819 return "nil" 3820 } 3821 s := strings.Join([]string{`&ListTasksRequest{`, 3822 `Filter:` + fmt.Sprintf("%v", this.Filter) + `,`, 3823 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3824 `}`, 3825 }, "") 3826 return s 3827} 3828func (this *ListTasksResponse) String() string { 3829 if this == nil { 3830 return "nil" 3831 } 3832 repeatedStringForTasks := "[]*Process{" 3833 for _, f := range this.Tasks { 3834 repeatedStringForTasks += strings.Replace(fmt.Sprintf("%v", f), "Process", "task.Process", 1) + "," 3835 } 3836 repeatedStringForTasks += "}" 3837 s := strings.Join([]string{`&ListTasksResponse{`, 3838 `Tasks:` + repeatedStringForTasks + `,`, 3839 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3840 `}`, 3841 }, "") 3842 return s 3843} 3844func (this *KillRequest) String() string { 3845 if this == nil { 3846 return "nil" 3847 } 3848 s := strings.Join([]string{`&KillRequest{`, 3849 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3850 `ExecID:` + fmt.Sprintf("%v", this.ExecID) + `,`, 3851 `Signal:` + fmt.Sprintf("%v", this.Signal) + `,`, 3852 `All:` + fmt.Sprintf("%v", this.All) + `,`, 3853 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3854 `}`, 3855 }, "") 3856 return s 3857} 3858func (this *ExecProcessRequest) String() string { 3859 if this == nil { 3860 return "nil" 3861 } 3862 s := strings.Join([]string{`&ExecProcessRequest{`, 3863 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3864 `Stdin:` + fmt.Sprintf("%v", this.Stdin) + `,`, 3865 `Stdout:` + fmt.Sprintf("%v", this.Stdout) + `,`, 3866 `Stderr:` + fmt.Sprintf("%v", this.Stderr) + `,`, 3867 `Terminal:` + fmt.Sprintf("%v", this.Terminal) + `,`, 3868 `Spec:` + strings.Replace(fmt.Sprintf("%v", this.Spec), "Any", "types1.Any", 1) + `,`, 3869 `ExecID:` + fmt.Sprintf("%v", this.ExecID) + `,`, 3870 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3871 `}`, 3872 }, "") 3873 return s 3874} 3875func (this *ExecProcessResponse) String() string { 3876 if this == nil { 3877 return "nil" 3878 } 3879 s := strings.Join([]string{`&ExecProcessResponse{`, 3880 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3881 `}`, 3882 }, "") 3883 return s 3884} 3885func (this *ResizePtyRequest) String() string { 3886 if this == nil { 3887 return "nil" 3888 } 3889 s := strings.Join([]string{`&ResizePtyRequest{`, 3890 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3891 `ExecID:` + fmt.Sprintf("%v", this.ExecID) + `,`, 3892 `Width:` + fmt.Sprintf("%v", this.Width) + `,`, 3893 `Height:` + fmt.Sprintf("%v", this.Height) + `,`, 3894 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3895 `}`, 3896 }, "") 3897 return s 3898} 3899func (this *CloseIORequest) String() string { 3900 if this == nil { 3901 return "nil" 3902 } 3903 s := strings.Join([]string{`&CloseIORequest{`, 3904 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3905 `ExecID:` + fmt.Sprintf("%v", this.ExecID) + `,`, 3906 `Stdin:` + fmt.Sprintf("%v", this.Stdin) + `,`, 3907 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3908 `}`, 3909 }, "") 3910 return s 3911} 3912func (this *PauseTaskRequest) String() string { 3913 if this == nil { 3914 return "nil" 3915 } 3916 s := strings.Join([]string{`&PauseTaskRequest{`, 3917 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3918 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3919 `}`, 3920 }, "") 3921 return s 3922} 3923func (this *ResumeTaskRequest) String() string { 3924 if this == nil { 3925 return "nil" 3926 } 3927 s := strings.Join([]string{`&ResumeTaskRequest{`, 3928 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3929 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3930 `}`, 3931 }, "") 3932 return s 3933} 3934func (this *ListPidsRequest) String() string { 3935 if this == nil { 3936 return "nil" 3937 } 3938 s := strings.Join([]string{`&ListPidsRequest{`, 3939 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3940 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3941 `}`, 3942 }, "") 3943 return s 3944} 3945func (this *ListPidsResponse) String() string { 3946 if this == nil { 3947 return "nil" 3948 } 3949 repeatedStringForProcesses := "[]*ProcessInfo{" 3950 for _, f := range this.Processes { 3951 repeatedStringForProcesses += strings.Replace(fmt.Sprintf("%v", f), "ProcessInfo", "task.ProcessInfo", 1) + "," 3952 } 3953 repeatedStringForProcesses += "}" 3954 s := strings.Join([]string{`&ListPidsResponse{`, 3955 `Processes:` + repeatedStringForProcesses + `,`, 3956 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3957 `}`, 3958 }, "") 3959 return s 3960} 3961func (this *CheckpointTaskRequest) String() string { 3962 if this == nil { 3963 return "nil" 3964 } 3965 s := strings.Join([]string{`&CheckpointTaskRequest{`, 3966 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3967 `ParentCheckpoint:` + fmt.Sprintf("%v", this.ParentCheckpoint) + `,`, 3968 `Options:` + strings.Replace(fmt.Sprintf("%v", this.Options), "Any", "types1.Any", 1) + `,`, 3969 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3970 `}`, 3971 }, "") 3972 return s 3973} 3974func (this *CheckpointTaskResponse) String() string { 3975 if this == nil { 3976 return "nil" 3977 } 3978 repeatedStringForDescriptors := "[]*Descriptor{" 3979 for _, f := range this.Descriptors { 3980 repeatedStringForDescriptors += strings.Replace(fmt.Sprintf("%v", f), "Descriptor", "types.Descriptor", 1) + "," 3981 } 3982 repeatedStringForDescriptors += "}" 3983 s := strings.Join([]string{`&CheckpointTaskResponse{`, 3984 `Descriptors:` + repeatedStringForDescriptors + `,`, 3985 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3986 `}`, 3987 }, "") 3988 return s 3989} 3990func (this *UpdateTaskRequest) String() string { 3991 if this == nil { 3992 return "nil" 3993 } 3994 s := strings.Join([]string{`&UpdateTaskRequest{`, 3995 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 3996 `Resources:` + strings.Replace(fmt.Sprintf("%v", this.Resources), "Any", "types1.Any", 1) + `,`, 3997 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 3998 `}`, 3999 }, "") 4000 return s 4001} 4002func (this *MetricsRequest) String() string { 4003 if this == nil { 4004 return "nil" 4005 } 4006 s := strings.Join([]string{`&MetricsRequest{`, 4007 `Filters:` + fmt.Sprintf("%v", this.Filters) + `,`, 4008 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 4009 `}`, 4010 }, "") 4011 return s 4012} 4013func (this *MetricsResponse) String() string { 4014 if this == nil { 4015 return "nil" 4016 } 4017 repeatedStringForMetrics := "[]*Metric{" 4018 for _, f := range this.Metrics { 4019 repeatedStringForMetrics += strings.Replace(fmt.Sprintf("%v", f), "Metric", "types.Metric", 1) + "," 4020 } 4021 repeatedStringForMetrics += "}" 4022 s := strings.Join([]string{`&MetricsResponse{`, 4023 `Metrics:` + repeatedStringForMetrics + `,`, 4024 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 4025 `}`, 4026 }, "") 4027 return s 4028} 4029func (this *WaitRequest) String() string { 4030 if this == nil { 4031 return "nil" 4032 } 4033 s := strings.Join([]string{`&WaitRequest{`, 4034 `ContainerID:` + fmt.Sprintf("%v", this.ContainerID) + `,`, 4035 `ExecID:` + fmt.Sprintf("%v", this.ExecID) + `,`, 4036 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 4037 `}`, 4038 }, "") 4039 return s 4040} 4041func (this *WaitResponse) String() string { 4042 if this == nil { 4043 return "nil" 4044 } 4045 s := strings.Join([]string{`&WaitResponse{`, 4046 `ExitStatus:` + fmt.Sprintf("%v", this.ExitStatus) + `,`, 4047 `ExitedAt:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.ExitedAt), "Timestamp", "types1.Timestamp", 1), `&`, ``, 1) + `,`, 4048 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 4049 `}`, 4050 }, "") 4051 return s 4052} 4053func valueToStringTasks(v interface{}) string { 4054 rv := reflect.ValueOf(v) 4055 if rv.IsNil() { 4056 return "nil" 4057 } 4058 pv := reflect.Indirect(rv).Interface() 4059 return fmt.Sprintf("*%v", pv) 4060} 4061func (m *CreateTaskRequest) Unmarshal(dAtA []byte) error { 4062 l := len(dAtA) 4063 iNdEx := 0 4064 for iNdEx < l { 4065 preIndex := iNdEx 4066 var wire uint64 4067 for shift := uint(0); ; shift += 7 { 4068 if shift >= 64 { 4069 return ErrIntOverflowTasks 4070 } 4071 if iNdEx >= l { 4072 return io.ErrUnexpectedEOF 4073 } 4074 b := dAtA[iNdEx] 4075 iNdEx++ 4076 wire |= uint64(b&0x7F) << shift 4077 if b < 0x80 { 4078 break 4079 } 4080 } 4081 fieldNum := int32(wire >> 3) 4082 wireType := int(wire & 0x7) 4083 if wireType == 4 { 4084 return fmt.Errorf("proto: CreateTaskRequest: wiretype end group for non-group") 4085 } 4086 if fieldNum <= 0 { 4087 return fmt.Errorf("proto: CreateTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) 4088 } 4089 switch fieldNum { 4090 case 1: 4091 if wireType != 2 { 4092 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 4093 } 4094 var stringLen uint64 4095 for shift := uint(0); ; shift += 7 { 4096 if shift >= 64 { 4097 return ErrIntOverflowTasks 4098 } 4099 if iNdEx >= l { 4100 return io.ErrUnexpectedEOF 4101 } 4102 b := dAtA[iNdEx] 4103 iNdEx++ 4104 stringLen |= uint64(b&0x7F) << shift 4105 if b < 0x80 { 4106 break 4107 } 4108 } 4109 intStringLen := int(stringLen) 4110 if intStringLen < 0 { 4111 return ErrInvalidLengthTasks 4112 } 4113 postIndex := iNdEx + intStringLen 4114 if postIndex < 0 { 4115 return ErrInvalidLengthTasks 4116 } 4117 if postIndex > l { 4118 return io.ErrUnexpectedEOF 4119 } 4120 m.ContainerID = string(dAtA[iNdEx:postIndex]) 4121 iNdEx = postIndex 4122 case 3: 4123 if wireType != 2 { 4124 return fmt.Errorf("proto: wrong wireType = %d for field Rootfs", wireType) 4125 } 4126 var msglen int 4127 for shift := uint(0); ; shift += 7 { 4128 if shift >= 64 { 4129 return ErrIntOverflowTasks 4130 } 4131 if iNdEx >= l { 4132 return io.ErrUnexpectedEOF 4133 } 4134 b := dAtA[iNdEx] 4135 iNdEx++ 4136 msglen |= int(b&0x7F) << shift 4137 if b < 0x80 { 4138 break 4139 } 4140 } 4141 if msglen < 0 { 4142 return ErrInvalidLengthTasks 4143 } 4144 postIndex := iNdEx + msglen 4145 if postIndex < 0 { 4146 return ErrInvalidLengthTasks 4147 } 4148 if postIndex > l { 4149 return io.ErrUnexpectedEOF 4150 } 4151 m.Rootfs = append(m.Rootfs, &types.Mount{}) 4152 if err := m.Rootfs[len(m.Rootfs)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 4153 return err 4154 } 4155 iNdEx = postIndex 4156 case 4: 4157 if wireType != 2 { 4158 return fmt.Errorf("proto: wrong wireType = %d for field Stdin", wireType) 4159 } 4160 var stringLen uint64 4161 for shift := uint(0); ; shift += 7 { 4162 if shift >= 64 { 4163 return ErrIntOverflowTasks 4164 } 4165 if iNdEx >= l { 4166 return io.ErrUnexpectedEOF 4167 } 4168 b := dAtA[iNdEx] 4169 iNdEx++ 4170 stringLen |= uint64(b&0x7F) << shift 4171 if b < 0x80 { 4172 break 4173 } 4174 } 4175 intStringLen := int(stringLen) 4176 if intStringLen < 0 { 4177 return ErrInvalidLengthTasks 4178 } 4179 postIndex := iNdEx + intStringLen 4180 if postIndex < 0 { 4181 return ErrInvalidLengthTasks 4182 } 4183 if postIndex > l { 4184 return io.ErrUnexpectedEOF 4185 } 4186 m.Stdin = string(dAtA[iNdEx:postIndex]) 4187 iNdEx = postIndex 4188 case 5: 4189 if wireType != 2 { 4190 return fmt.Errorf("proto: wrong wireType = %d for field Stdout", wireType) 4191 } 4192 var stringLen uint64 4193 for shift := uint(0); ; shift += 7 { 4194 if shift >= 64 { 4195 return ErrIntOverflowTasks 4196 } 4197 if iNdEx >= l { 4198 return io.ErrUnexpectedEOF 4199 } 4200 b := dAtA[iNdEx] 4201 iNdEx++ 4202 stringLen |= uint64(b&0x7F) << shift 4203 if b < 0x80 { 4204 break 4205 } 4206 } 4207 intStringLen := int(stringLen) 4208 if intStringLen < 0 { 4209 return ErrInvalidLengthTasks 4210 } 4211 postIndex := iNdEx + intStringLen 4212 if postIndex < 0 { 4213 return ErrInvalidLengthTasks 4214 } 4215 if postIndex > l { 4216 return io.ErrUnexpectedEOF 4217 } 4218 m.Stdout = string(dAtA[iNdEx:postIndex]) 4219 iNdEx = postIndex 4220 case 6: 4221 if wireType != 2 { 4222 return fmt.Errorf("proto: wrong wireType = %d for field Stderr", wireType) 4223 } 4224 var stringLen uint64 4225 for shift := uint(0); ; shift += 7 { 4226 if shift >= 64 { 4227 return ErrIntOverflowTasks 4228 } 4229 if iNdEx >= l { 4230 return io.ErrUnexpectedEOF 4231 } 4232 b := dAtA[iNdEx] 4233 iNdEx++ 4234 stringLen |= uint64(b&0x7F) << shift 4235 if b < 0x80 { 4236 break 4237 } 4238 } 4239 intStringLen := int(stringLen) 4240 if intStringLen < 0 { 4241 return ErrInvalidLengthTasks 4242 } 4243 postIndex := iNdEx + intStringLen 4244 if postIndex < 0 { 4245 return ErrInvalidLengthTasks 4246 } 4247 if postIndex > l { 4248 return io.ErrUnexpectedEOF 4249 } 4250 m.Stderr = string(dAtA[iNdEx:postIndex]) 4251 iNdEx = postIndex 4252 case 7: 4253 if wireType != 0 { 4254 return fmt.Errorf("proto: wrong wireType = %d for field Terminal", wireType) 4255 } 4256 var v int 4257 for shift := uint(0); ; shift += 7 { 4258 if shift >= 64 { 4259 return ErrIntOverflowTasks 4260 } 4261 if iNdEx >= l { 4262 return io.ErrUnexpectedEOF 4263 } 4264 b := dAtA[iNdEx] 4265 iNdEx++ 4266 v |= int(b&0x7F) << shift 4267 if b < 0x80 { 4268 break 4269 } 4270 } 4271 m.Terminal = bool(v != 0) 4272 case 8: 4273 if wireType != 2 { 4274 return fmt.Errorf("proto: wrong wireType = %d for field Checkpoint", wireType) 4275 } 4276 var msglen int 4277 for shift := uint(0); ; shift += 7 { 4278 if shift >= 64 { 4279 return ErrIntOverflowTasks 4280 } 4281 if iNdEx >= l { 4282 return io.ErrUnexpectedEOF 4283 } 4284 b := dAtA[iNdEx] 4285 iNdEx++ 4286 msglen |= int(b&0x7F) << shift 4287 if b < 0x80 { 4288 break 4289 } 4290 } 4291 if msglen < 0 { 4292 return ErrInvalidLengthTasks 4293 } 4294 postIndex := iNdEx + msglen 4295 if postIndex < 0 { 4296 return ErrInvalidLengthTasks 4297 } 4298 if postIndex > l { 4299 return io.ErrUnexpectedEOF 4300 } 4301 if m.Checkpoint == nil { 4302 m.Checkpoint = &types.Descriptor{} 4303 } 4304 if err := m.Checkpoint.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 4305 return err 4306 } 4307 iNdEx = postIndex 4308 case 9: 4309 if wireType != 2 { 4310 return fmt.Errorf("proto: wrong wireType = %d for field Options", wireType) 4311 } 4312 var msglen int 4313 for shift := uint(0); ; shift += 7 { 4314 if shift >= 64 { 4315 return ErrIntOverflowTasks 4316 } 4317 if iNdEx >= l { 4318 return io.ErrUnexpectedEOF 4319 } 4320 b := dAtA[iNdEx] 4321 iNdEx++ 4322 msglen |= int(b&0x7F) << shift 4323 if b < 0x80 { 4324 break 4325 } 4326 } 4327 if msglen < 0 { 4328 return ErrInvalidLengthTasks 4329 } 4330 postIndex := iNdEx + msglen 4331 if postIndex < 0 { 4332 return ErrInvalidLengthTasks 4333 } 4334 if postIndex > l { 4335 return io.ErrUnexpectedEOF 4336 } 4337 if m.Options == nil { 4338 m.Options = &types1.Any{} 4339 } 4340 if err := m.Options.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 4341 return err 4342 } 4343 iNdEx = postIndex 4344 default: 4345 iNdEx = preIndex 4346 skippy, err := skipTasks(dAtA[iNdEx:]) 4347 if err != nil { 4348 return err 4349 } 4350 if (skippy < 0) || (iNdEx+skippy) < 0 { 4351 return ErrInvalidLengthTasks 4352 } 4353 if (iNdEx + skippy) > l { 4354 return io.ErrUnexpectedEOF 4355 } 4356 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4357 iNdEx += skippy 4358 } 4359 } 4360 4361 if iNdEx > l { 4362 return io.ErrUnexpectedEOF 4363 } 4364 return nil 4365} 4366func (m *CreateTaskResponse) Unmarshal(dAtA []byte) error { 4367 l := len(dAtA) 4368 iNdEx := 0 4369 for iNdEx < l { 4370 preIndex := iNdEx 4371 var wire uint64 4372 for shift := uint(0); ; shift += 7 { 4373 if shift >= 64 { 4374 return ErrIntOverflowTasks 4375 } 4376 if iNdEx >= l { 4377 return io.ErrUnexpectedEOF 4378 } 4379 b := dAtA[iNdEx] 4380 iNdEx++ 4381 wire |= uint64(b&0x7F) << shift 4382 if b < 0x80 { 4383 break 4384 } 4385 } 4386 fieldNum := int32(wire >> 3) 4387 wireType := int(wire & 0x7) 4388 if wireType == 4 { 4389 return fmt.Errorf("proto: CreateTaskResponse: wiretype end group for non-group") 4390 } 4391 if fieldNum <= 0 { 4392 return fmt.Errorf("proto: CreateTaskResponse: illegal tag %d (wire type %d)", fieldNum, wire) 4393 } 4394 switch fieldNum { 4395 case 1: 4396 if wireType != 2 { 4397 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 4398 } 4399 var stringLen uint64 4400 for shift := uint(0); ; shift += 7 { 4401 if shift >= 64 { 4402 return ErrIntOverflowTasks 4403 } 4404 if iNdEx >= l { 4405 return io.ErrUnexpectedEOF 4406 } 4407 b := dAtA[iNdEx] 4408 iNdEx++ 4409 stringLen |= uint64(b&0x7F) << shift 4410 if b < 0x80 { 4411 break 4412 } 4413 } 4414 intStringLen := int(stringLen) 4415 if intStringLen < 0 { 4416 return ErrInvalidLengthTasks 4417 } 4418 postIndex := iNdEx + intStringLen 4419 if postIndex < 0 { 4420 return ErrInvalidLengthTasks 4421 } 4422 if postIndex > l { 4423 return io.ErrUnexpectedEOF 4424 } 4425 m.ContainerID = string(dAtA[iNdEx:postIndex]) 4426 iNdEx = postIndex 4427 case 2: 4428 if wireType != 0 { 4429 return fmt.Errorf("proto: wrong wireType = %d for field Pid", wireType) 4430 } 4431 m.Pid = 0 4432 for shift := uint(0); ; shift += 7 { 4433 if shift >= 64 { 4434 return ErrIntOverflowTasks 4435 } 4436 if iNdEx >= l { 4437 return io.ErrUnexpectedEOF 4438 } 4439 b := dAtA[iNdEx] 4440 iNdEx++ 4441 m.Pid |= uint32(b&0x7F) << shift 4442 if b < 0x80 { 4443 break 4444 } 4445 } 4446 default: 4447 iNdEx = preIndex 4448 skippy, err := skipTasks(dAtA[iNdEx:]) 4449 if err != nil { 4450 return err 4451 } 4452 if (skippy < 0) || (iNdEx+skippy) < 0 { 4453 return ErrInvalidLengthTasks 4454 } 4455 if (iNdEx + skippy) > l { 4456 return io.ErrUnexpectedEOF 4457 } 4458 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4459 iNdEx += skippy 4460 } 4461 } 4462 4463 if iNdEx > l { 4464 return io.ErrUnexpectedEOF 4465 } 4466 return nil 4467} 4468func (m *StartRequest) Unmarshal(dAtA []byte) error { 4469 l := len(dAtA) 4470 iNdEx := 0 4471 for iNdEx < l { 4472 preIndex := iNdEx 4473 var wire uint64 4474 for shift := uint(0); ; shift += 7 { 4475 if shift >= 64 { 4476 return ErrIntOverflowTasks 4477 } 4478 if iNdEx >= l { 4479 return io.ErrUnexpectedEOF 4480 } 4481 b := dAtA[iNdEx] 4482 iNdEx++ 4483 wire |= uint64(b&0x7F) << shift 4484 if b < 0x80 { 4485 break 4486 } 4487 } 4488 fieldNum := int32(wire >> 3) 4489 wireType := int(wire & 0x7) 4490 if wireType == 4 { 4491 return fmt.Errorf("proto: StartRequest: wiretype end group for non-group") 4492 } 4493 if fieldNum <= 0 { 4494 return fmt.Errorf("proto: StartRequest: illegal tag %d (wire type %d)", fieldNum, wire) 4495 } 4496 switch fieldNum { 4497 case 1: 4498 if wireType != 2 { 4499 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 4500 } 4501 var stringLen uint64 4502 for shift := uint(0); ; shift += 7 { 4503 if shift >= 64 { 4504 return ErrIntOverflowTasks 4505 } 4506 if iNdEx >= l { 4507 return io.ErrUnexpectedEOF 4508 } 4509 b := dAtA[iNdEx] 4510 iNdEx++ 4511 stringLen |= uint64(b&0x7F) << shift 4512 if b < 0x80 { 4513 break 4514 } 4515 } 4516 intStringLen := int(stringLen) 4517 if intStringLen < 0 { 4518 return ErrInvalidLengthTasks 4519 } 4520 postIndex := iNdEx + intStringLen 4521 if postIndex < 0 { 4522 return ErrInvalidLengthTasks 4523 } 4524 if postIndex > l { 4525 return io.ErrUnexpectedEOF 4526 } 4527 m.ContainerID = string(dAtA[iNdEx:postIndex]) 4528 iNdEx = postIndex 4529 case 2: 4530 if wireType != 2 { 4531 return fmt.Errorf("proto: wrong wireType = %d for field ExecID", wireType) 4532 } 4533 var stringLen uint64 4534 for shift := uint(0); ; shift += 7 { 4535 if shift >= 64 { 4536 return ErrIntOverflowTasks 4537 } 4538 if iNdEx >= l { 4539 return io.ErrUnexpectedEOF 4540 } 4541 b := dAtA[iNdEx] 4542 iNdEx++ 4543 stringLen |= uint64(b&0x7F) << shift 4544 if b < 0x80 { 4545 break 4546 } 4547 } 4548 intStringLen := int(stringLen) 4549 if intStringLen < 0 { 4550 return ErrInvalidLengthTasks 4551 } 4552 postIndex := iNdEx + intStringLen 4553 if postIndex < 0 { 4554 return ErrInvalidLengthTasks 4555 } 4556 if postIndex > l { 4557 return io.ErrUnexpectedEOF 4558 } 4559 m.ExecID = string(dAtA[iNdEx:postIndex]) 4560 iNdEx = postIndex 4561 default: 4562 iNdEx = preIndex 4563 skippy, err := skipTasks(dAtA[iNdEx:]) 4564 if err != nil { 4565 return err 4566 } 4567 if (skippy < 0) || (iNdEx+skippy) < 0 { 4568 return ErrInvalidLengthTasks 4569 } 4570 if (iNdEx + skippy) > l { 4571 return io.ErrUnexpectedEOF 4572 } 4573 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4574 iNdEx += skippy 4575 } 4576 } 4577 4578 if iNdEx > l { 4579 return io.ErrUnexpectedEOF 4580 } 4581 return nil 4582} 4583func (m *StartResponse) Unmarshal(dAtA []byte) error { 4584 l := len(dAtA) 4585 iNdEx := 0 4586 for iNdEx < l { 4587 preIndex := iNdEx 4588 var wire uint64 4589 for shift := uint(0); ; shift += 7 { 4590 if shift >= 64 { 4591 return ErrIntOverflowTasks 4592 } 4593 if iNdEx >= l { 4594 return io.ErrUnexpectedEOF 4595 } 4596 b := dAtA[iNdEx] 4597 iNdEx++ 4598 wire |= uint64(b&0x7F) << shift 4599 if b < 0x80 { 4600 break 4601 } 4602 } 4603 fieldNum := int32(wire >> 3) 4604 wireType := int(wire & 0x7) 4605 if wireType == 4 { 4606 return fmt.Errorf("proto: StartResponse: wiretype end group for non-group") 4607 } 4608 if fieldNum <= 0 { 4609 return fmt.Errorf("proto: StartResponse: illegal tag %d (wire type %d)", fieldNum, wire) 4610 } 4611 switch fieldNum { 4612 case 1: 4613 if wireType != 0 { 4614 return fmt.Errorf("proto: wrong wireType = %d for field Pid", wireType) 4615 } 4616 m.Pid = 0 4617 for shift := uint(0); ; shift += 7 { 4618 if shift >= 64 { 4619 return ErrIntOverflowTasks 4620 } 4621 if iNdEx >= l { 4622 return io.ErrUnexpectedEOF 4623 } 4624 b := dAtA[iNdEx] 4625 iNdEx++ 4626 m.Pid |= uint32(b&0x7F) << shift 4627 if b < 0x80 { 4628 break 4629 } 4630 } 4631 default: 4632 iNdEx = preIndex 4633 skippy, err := skipTasks(dAtA[iNdEx:]) 4634 if err != nil { 4635 return err 4636 } 4637 if (skippy < 0) || (iNdEx+skippy) < 0 { 4638 return ErrInvalidLengthTasks 4639 } 4640 if (iNdEx + skippy) > l { 4641 return io.ErrUnexpectedEOF 4642 } 4643 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4644 iNdEx += skippy 4645 } 4646 } 4647 4648 if iNdEx > l { 4649 return io.ErrUnexpectedEOF 4650 } 4651 return nil 4652} 4653func (m *DeleteTaskRequest) Unmarshal(dAtA []byte) error { 4654 l := len(dAtA) 4655 iNdEx := 0 4656 for iNdEx < l { 4657 preIndex := iNdEx 4658 var wire uint64 4659 for shift := uint(0); ; shift += 7 { 4660 if shift >= 64 { 4661 return ErrIntOverflowTasks 4662 } 4663 if iNdEx >= l { 4664 return io.ErrUnexpectedEOF 4665 } 4666 b := dAtA[iNdEx] 4667 iNdEx++ 4668 wire |= uint64(b&0x7F) << shift 4669 if b < 0x80 { 4670 break 4671 } 4672 } 4673 fieldNum := int32(wire >> 3) 4674 wireType := int(wire & 0x7) 4675 if wireType == 4 { 4676 return fmt.Errorf("proto: DeleteTaskRequest: wiretype end group for non-group") 4677 } 4678 if fieldNum <= 0 { 4679 return fmt.Errorf("proto: DeleteTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) 4680 } 4681 switch fieldNum { 4682 case 1: 4683 if wireType != 2 { 4684 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 4685 } 4686 var stringLen uint64 4687 for shift := uint(0); ; shift += 7 { 4688 if shift >= 64 { 4689 return ErrIntOverflowTasks 4690 } 4691 if iNdEx >= l { 4692 return io.ErrUnexpectedEOF 4693 } 4694 b := dAtA[iNdEx] 4695 iNdEx++ 4696 stringLen |= uint64(b&0x7F) << shift 4697 if b < 0x80 { 4698 break 4699 } 4700 } 4701 intStringLen := int(stringLen) 4702 if intStringLen < 0 { 4703 return ErrInvalidLengthTasks 4704 } 4705 postIndex := iNdEx + intStringLen 4706 if postIndex < 0 { 4707 return ErrInvalidLengthTasks 4708 } 4709 if postIndex > l { 4710 return io.ErrUnexpectedEOF 4711 } 4712 m.ContainerID = string(dAtA[iNdEx:postIndex]) 4713 iNdEx = postIndex 4714 default: 4715 iNdEx = preIndex 4716 skippy, err := skipTasks(dAtA[iNdEx:]) 4717 if err != nil { 4718 return err 4719 } 4720 if (skippy < 0) || (iNdEx+skippy) < 0 { 4721 return ErrInvalidLengthTasks 4722 } 4723 if (iNdEx + skippy) > l { 4724 return io.ErrUnexpectedEOF 4725 } 4726 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4727 iNdEx += skippy 4728 } 4729 } 4730 4731 if iNdEx > l { 4732 return io.ErrUnexpectedEOF 4733 } 4734 return nil 4735} 4736func (m *DeleteResponse) Unmarshal(dAtA []byte) error { 4737 l := len(dAtA) 4738 iNdEx := 0 4739 for iNdEx < l { 4740 preIndex := iNdEx 4741 var wire uint64 4742 for shift := uint(0); ; shift += 7 { 4743 if shift >= 64 { 4744 return ErrIntOverflowTasks 4745 } 4746 if iNdEx >= l { 4747 return io.ErrUnexpectedEOF 4748 } 4749 b := dAtA[iNdEx] 4750 iNdEx++ 4751 wire |= uint64(b&0x7F) << shift 4752 if b < 0x80 { 4753 break 4754 } 4755 } 4756 fieldNum := int32(wire >> 3) 4757 wireType := int(wire & 0x7) 4758 if wireType == 4 { 4759 return fmt.Errorf("proto: DeleteResponse: wiretype end group for non-group") 4760 } 4761 if fieldNum <= 0 { 4762 return fmt.Errorf("proto: DeleteResponse: illegal tag %d (wire type %d)", fieldNum, wire) 4763 } 4764 switch fieldNum { 4765 case 1: 4766 if wireType != 2 { 4767 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 4768 } 4769 var stringLen uint64 4770 for shift := uint(0); ; shift += 7 { 4771 if shift >= 64 { 4772 return ErrIntOverflowTasks 4773 } 4774 if iNdEx >= l { 4775 return io.ErrUnexpectedEOF 4776 } 4777 b := dAtA[iNdEx] 4778 iNdEx++ 4779 stringLen |= uint64(b&0x7F) << shift 4780 if b < 0x80 { 4781 break 4782 } 4783 } 4784 intStringLen := int(stringLen) 4785 if intStringLen < 0 { 4786 return ErrInvalidLengthTasks 4787 } 4788 postIndex := iNdEx + intStringLen 4789 if postIndex < 0 { 4790 return ErrInvalidLengthTasks 4791 } 4792 if postIndex > l { 4793 return io.ErrUnexpectedEOF 4794 } 4795 m.ID = string(dAtA[iNdEx:postIndex]) 4796 iNdEx = postIndex 4797 case 2: 4798 if wireType != 0 { 4799 return fmt.Errorf("proto: wrong wireType = %d for field Pid", wireType) 4800 } 4801 m.Pid = 0 4802 for shift := uint(0); ; shift += 7 { 4803 if shift >= 64 { 4804 return ErrIntOverflowTasks 4805 } 4806 if iNdEx >= l { 4807 return io.ErrUnexpectedEOF 4808 } 4809 b := dAtA[iNdEx] 4810 iNdEx++ 4811 m.Pid |= uint32(b&0x7F) << shift 4812 if b < 0x80 { 4813 break 4814 } 4815 } 4816 case 3: 4817 if wireType != 0 { 4818 return fmt.Errorf("proto: wrong wireType = %d for field ExitStatus", wireType) 4819 } 4820 m.ExitStatus = 0 4821 for shift := uint(0); ; shift += 7 { 4822 if shift >= 64 { 4823 return ErrIntOverflowTasks 4824 } 4825 if iNdEx >= l { 4826 return io.ErrUnexpectedEOF 4827 } 4828 b := dAtA[iNdEx] 4829 iNdEx++ 4830 m.ExitStatus |= uint32(b&0x7F) << shift 4831 if b < 0x80 { 4832 break 4833 } 4834 } 4835 case 4: 4836 if wireType != 2 { 4837 return fmt.Errorf("proto: wrong wireType = %d for field ExitedAt", wireType) 4838 } 4839 var msglen int 4840 for shift := uint(0); ; shift += 7 { 4841 if shift >= 64 { 4842 return ErrIntOverflowTasks 4843 } 4844 if iNdEx >= l { 4845 return io.ErrUnexpectedEOF 4846 } 4847 b := dAtA[iNdEx] 4848 iNdEx++ 4849 msglen |= int(b&0x7F) << shift 4850 if b < 0x80 { 4851 break 4852 } 4853 } 4854 if msglen < 0 { 4855 return ErrInvalidLengthTasks 4856 } 4857 postIndex := iNdEx + msglen 4858 if postIndex < 0 { 4859 return ErrInvalidLengthTasks 4860 } 4861 if postIndex > l { 4862 return io.ErrUnexpectedEOF 4863 } 4864 if err := github_com_gogo_protobuf_types.StdTimeUnmarshal(&m.ExitedAt, dAtA[iNdEx:postIndex]); err != nil { 4865 return err 4866 } 4867 iNdEx = postIndex 4868 default: 4869 iNdEx = preIndex 4870 skippy, err := skipTasks(dAtA[iNdEx:]) 4871 if err != nil { 4872 return err 4873 } 4874 if (skippy < 0) || (iNdEx+skippy) < 0 { 4875 return ErrInvalidLengthTasks 4876 } 4877 if (iNdEx + skippy) > l { 4878 return io.ErrUnexpectedEOF 4879 } 4880 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4881 iNdEx += skippy 4882 } 4883 } 4884 4885 if iNdEx > l { 4886 return io.ErrUnexpectedEOF 4887 } 4888 return nil 4889} 4890func (m *DeleteProcessRequest) Unmarshal(dAtA []byte) error { 4891 l := len(dAtA) 4892 iNdEx := 0 4893 for iNdEx < l { 4894 preIndex := iNdEx 4895 var wire uint64 4896 for shift := uint(0); ; shift += 7 { 4897 if shift >= 64 { 4898 return ErrIntOverflowTasks 4899 } 4900 if iNdEx >= l { 4901 return io.ErrUnexpectedEOF 4902 } 4903 b := dAtA[iNdEx] 4904 iNdEx++ 4905 wire |= uint64(b&0x7F) << shift 4906 if b < 0x80 { 4907 break 4908 } 4909 } 4910 fieldNum := int32(wire >> 3) 4911 wireType := int(wire & 0x7) 4912 if wireType == 4 { 4913 return fmt.Errorf("proto: DeleteProcessRequest: wiretype end group for non-group") 4914 } 4915 if fieldNum <= 0 { 4916 return fmt.Errorf("proto: DeleteProcessRequest: illegal tag %d (wire type %d)", fieldNum, wire) 4917 } 4918 switch fieldNum { 4919 case 1: 4920 if wireType != 2 { 4921 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 4922 } 4923 var stringLen uint64 4924 for shift := uint(0); ; shift += 7 { 4925 if shift >= 64 { 4926 return ErrIntOverflowTasks 4927 } 4928 if iNdEx >= l { 4929 return io.ErrUnexpectedEOF 4930 } 4931 b := dAtA[iNdEx] 4932 iNdEx++ 4933 stringLen |= uint64(b&0x7F) << shift 4934 if b < 0x80 { 4935 break 4936 } 4937 } 4938 intStringLen := int(stringLen) 4939 if intStringLen < 0 { 4940 return ErrInvalidLengthTasks 4941 } 4942 postIndex := iNdEx + intStringLen 4943 if postIndex < 0 { 4944 return ErrInvalidLengthTasks 4945 } 4946 if postIndex > l { 4947 return io.ErrUnexpectedEOF 4948 } 4949 m.ContainerID = string(dAtA[iNdEx:postIndex]) 4950 iNdEx = postIndex 4951 case 2: 4952 if wireType != 2 { 4953 return fmt.Errorf("proto: wrong wireType = %d for field ExecID", wireType) 4954 } 4955 var stringLen uint64 4956 for shift := uint(0); ; shift += 7 { 4957 if shift >= 64 { 4958 return ErrIntOverflowTasks 4959 } 4960 if iNdEx >= l { 4961 return io.ErrUnexpectedEOF 4962 } 4963 b := dAtA[iNdEx] 4964 iNdEx++ 4965 stringLen |= uint64(b&0x7F) << shift 4966 if b < 0x80 { 4967 break 4968 } 4969 } 4970 intStringLen := int(stringLen) 4971 if intStringLen < 0 { 4972 return ErrInvalidLengthTasks 4973 } 4974 postIndex := iNdEx + intStringLen 4975 if postIndex < 0 { 4976 return ErrInvalidLengthTasks 4977 } 4978 if postIndex > l { 4979 return io.ErrUnexpectedEOF 4980 } 4981 m.ExecID = string(dAtA[iNdEx:postIndex]) 4982 iNdEx = postIndex 4983 default: 4984 iNdEx = preIndex 4985 skippy, err := skipTasks(dAtA[iNdEx:]) 4986 if err != nil { 4987 return err 4988 } 4989 if (skippy < 0) || (iNdEx+skippy) < 0 { 4990 return ErrInvalidLengthTasks 4991 } 4992 if (iNdEx + skippy) > l { 4993 return io.ErrUnexpectedEOF 4994 } 4995 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4996 iNdEx += skippy 4997 } 4998 } 4999 5000 if iNdEx > l { 5001 return io.ErrUnexpectedEOF 5002 } 5003 return nil 5004} 5005func (m *GetRequest) Unmarshal(dAtA []byte) error { 5006 l := len(dAtA) 5007 iNdEx := 0 5008 for iNdEx < l { 5009 preIndex := iNdEx 5010 var wire uint64 5011 for shift := uint(0); ; shift += 7 { 5012 if shift >= 64 { 5013 return ErrIntOverflowTasks 5014 } 5015 if iNdEx >= l { 5016 return io.ErrUnexpectedEOF 5017 } 5018 b := dAtA[iNdEx] 5019 iNdEx++ 5020 wire |= uint64(b&0x7F) << shift 5021 if b < 0x80 { 5022 break 5023 } 5024 } 5025 fieldNum := int32(wire >> 3) 5026 wireType := int(wire & 0x7) 5027 if wireType == 4 { 5028 return fmt.Errorf("proto: GetRequest: wiretype end group for non-group") 5029 } 5030 if fieldNum <= 0 { 5031 return fmt.Errorf("proto: GetRequest: illegal tag %d (wire type %d)", fieldNum, wire) 5032 } 5033 switch fieldNum { 5034 case 1: 5035 if wireType != 2 { 5036 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 5037 } 5038 var stringLen uint64 5039 for shift := uint(0); ; shift += 7 { 5040 if shift >= 64 { 5041 return ErrIntOverflowTasks 5042 } 5043 if iNdEx >= l { 5044 return io.ErrUnexpectedEOF 5045 } 5046 b := dAtA[iNdEx] 5047 iNdEx++ 5048 stringLen |= uint64(b&0x7F) << shift 5049 if b < 0x80 { 5050 break 5051 } 5052 } 5053 intStringLen := int(stringLen) 5054 if intStringLen < 0 { 5055 return ErrInvalidLengthTasks 5056 } 5057 postIndex := iNdEx + intStringLen 5058 if postIndex < 0 { 5059 return ErrInvalidLengthTasks 5060 } 5061 if postIndex > l { 5062 return io.ErrUnexpectedEOF 5063 } 5064 m.ContainerID = string(dAtA[iNdEx:postIndex]) 5065 iNdEx = postIndex 5066 case 2: 5067 if wireType != 2 { 5068 return fmt.Errorf("proto: wrong wireType = %d for field ExecID", wireType) 5069 } 5070 var stringLen uint64 5071 for shift := uint(0); ; shift += 7 { 5072 if shift >= 64 { 5073 return ErrIntOverflowTasks 5074 } 5075 if iNdEx >= l { 5076 return io.ErrUnexpectedEOF 5077 } 5078 b := dAtA[iNdEx] 5079 iNdEx++ 5080 stringLen |= uint64(b&0x7F) << shift 5081 if b < 0x80 { 5082 break 5083 } 5084 } 5085 intStringLen := int(stringLen) 5086 if intStringLen < 0 { 5087 return ErrInvalidLengthTasks 5088 } 5089 postIndex := iNdEx + intStringLen 5090 if postIndex < 0 { 5091 return ErrInvalidLengthTasks 5092 } 5093 if postIndex > l { 5094 return io.ErrUnexpectedEOF 5095 } 5096 m.ExecID = string(dAtA[iNdEx:postIndex]) 5097 iNdEx = postIndex 5098 default: 5099 iNdEx = preIndex 5100 skippy, err := skipTasks(dAtA[iNdEx:]) 5101 if err != nil { 5102 return err 5103 } 5104 if (skippy < 0) || (iNdEx+skippy) < 0 { 5105 return ErrInvalidLengthTasks 5106 } 5107 if (iNdEx + skippy) > l { 5108 return io.ErrUnexpectedEOF 5109 } 5110 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5111 iNdEx += skippy 5112 } 5113 } 5114 5115 if iNdEx > l { 5116 return io.ErrUnexpectedEOF 5117 } 5118 return nil 5119} 5120func (m *GetResponse) Unmarshal(dAtA []byte) error { 5121 l := len(dAtA) 5122 iNdEx := 0 5123 for iNdEx < l { 5124 preIndex := iNdEx 5125 var wire uint64 5126 for shift := uint(0); ; shift += 7 { 5127 if shift >= 64 { 5128 return ErrIntOverflowTasks 5129 } 5130 if iNdEx >= l { 5131 return io.ErrUnexpectedEOF 5132 } 5133 b := dAtA[iNdEx] 5134 iNdEx++ 5135 wire |= uint64(b&0x7F) << shift 5136 if b < 0x80 { 5137 break 5138 } 5139 } 5140 fieldNum := int32(wire >> 3) 5141 wireType := int(wire & 0x7) 5142 if wireType == 4 { 5143 return fmt.Errorf("proto: GetResponse: wiretype end group for non-group") 5144 } 5145 if fieldNum <= 0 { 5146 return fmt.Errorf("proto: GetResponse: illegal tag %d (wire type %d)", fieldNum, wire) 5147 } 5148 switch fieldNum { 5149 case 1: 5150 if wireType != 2 { 5151 return fmt.Errorf("proto: wrong wireType = %d for field Process", wireType) 5152 } 5153 var msglen int 5154 for shift := uint(0); ; shift += 7 { 5155 if shift >= 64 { 5156 return ErrIntOverflowTasks 5157 } 5158 if iNdEx >= l { 5159 return io.ErrUnexpectedEOF 5160 } 5161 b := dAtA[iNdEx] 5162 iNdEx++ 5163 msglen |= int(b&0x7F) << shift 5164 if b < 0x80 { 5165 break 5166 } 5167 } 5168 if msglen < 0 { 5169 return ErrInvalidLengthTasks 5170 } 5171 postIndex := iNdEx + msglen 5172 if postIndex < 0 { 5173 return ErrInvalidLengthTasks 5174 } 5175 if postIndex > l { 5176 return io.ErrUnexpectedEOF 5177 } 5178 if m.Process == nil { 5179 m.Process = &task.Process{} 5180 } 5181 if err := m.Process.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 5182 return err 5183 } 5184 iNdEx = postIndex 5185 default: 5186 iNdEx = preIndex 5187 skippy, err := skipTasks(dAtA[iNdEx:]) 5188 if err != nil { 5189 return err 5190 } 5191 if (skippy < 0) || (iNdEx+skippy) < 0 { 5192 return ErrInvalidLengthTasks 5193 } 5194 if (iNdEx + skippy) > l { 5195 return io.ErrUnexpectedEOF 5196 } 5197 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5198 iNdEx += skippy 5199 } 5200 } 5201 5202 if iNdEx > l { 5203 return io.ErrUnexpectedEOF 5204 } 5205 return nil 5206} 5207func (m *ListTasksRequest) Unmarshal(dAtA []byte) error { 5208 l := len(dAtA) 5209 iNdEx := 0 5210 for iNdEx < l { 5211 preIndex := iNdEx 5212 var wire uint64 5213 for shift := uint(0); ; shift += 7 { 5214 if shift >= 64 { 5215 return ErrIntOverflowTasks 5216 } 5217 if iNdEx >= l { 5218 return io.ErrUnexpectedEOF 5219 } 5220 b := dAtA[iNdEx] 5221 iNdEx++ 5222 wire |= uint64(b&0x7F) << shift 5223 if b < 0x80 { 5224 break 5225 } 5226 } 5227 fieldNum := int32(wire >> 3) 5228 wireType := int(wire & 0x7) 5229 if wireType == 4 { 5230 return fmt.Errorf("proto: ListTasksRequest: wiretype end group for non-group") 5231 } 5232 if fieldNum <= 0 { 5233 return fmt.Errorf("proto: ListTasksRequest: illegal tag %d (wire type %d)", fieldNum, wire) 5234 } 5235 switch fieldNum { 5236 case 1: 5237 if wireType != 2 { 5238 return fmt.Errorf("proto: wrong wireType = %d for field Filter", wireType) 5239 } 5240 var stringLen uint64 5241 for shift := uint(0); ; shift += 7 { 5242 if shift >= 64 { 5243 return ErrIntOverflowTasks 5244 } 5245 if iNdEx >= l { 5246 return io.ErrUnexpectedEOF 5247 } 5248 b := dAtA[iNdEx] 5249 iNdEx++ 5250 stringLen |= uint64(b&0x7F) << shift 5251 if b < 0x80 { 5252 break 5253 } 5254 } 5255 intStringLen := int(stringLen) 5256 if intStringLen < 0 { 5257 return ErrInvalidLengthTasks 5258 } 5259 postIndex := iNdEx + intStringLen 5260 if postIndex < 0 { 5261 return ErrInvalidLengthTasks 5262 } 5263 if postIndex > l { 5264 return io.ErrUnexpectedEOF 5265 } 5266 m.Filter = string(dAtA[iNdEx:postIndex]) 5267 iNdEx = postIndex 5268 default: 5269 iNdEx = preIndex 5270 skippy, err := skipTasks(dAtA[iNdEx:]) 5271 if err != nil { 5272 return err 5273 } 5274 if (skippy < 0) || (iNdEx+skippy) < 0 { 5275 return ErrInvalidLengthTasks 5276 } 5277 if (iNdEx + skippy) > l { 5278 return io.ErrUnexpectedEOF 5279 } 5280 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5281 iNdEx += skippy 5282 } 5283 } 5284 5285 if iNdEx > l { 5286 return io.ErrUnexpectedEOF 5287 } 5288 return nil 5289} 5290func (m *ListTasksResponse) Unmarshal(dAtA []byte) error { 5291 l := len(dAtA) 5292 iNdEx := 0 5293 for iNdEx < l { 5294 preIndex := iNdEx 5295 var wire uint64 5296 for shift := uint(0); ; shift += 7 { 5297 if shift >= 64 { 5298 return ErrIntOverflowTasks 5299 } 5300 if iNdEx >= l { 5301 return io.ErrUnexpectedEOF 5302 } 5303 b := dAtA[iNdEx] 5304 iNdEx++ 5305 wire |= uint64(b&0x7F) << shift 5306 if b < 0x80 { 5307 break 5308 } 5309 } 5310 fieldNum := int32(wire >> 3) 5311 wireType := int(wire & 0x7) 5312 if wireType == 4 { 5313 return fmt.Errorf("proto: ListTasksResponse: wiretype end group for non-group") 5314 } 5315 if fieldNum <= 0 { 5316 return fmt.Errorf("proto: ListTasksResponse: illegal tag %d (wire type %d)", fieldNum, wire) 5317 } 5318 switch fieldNum { 5319 case 1: 5320 if wireType != 2 { 5321 return fmt.Errorf("proto: wrong wireType = %d for field Tasks", wireType) 5322 } 5323 var msglen int 5324 for shift := uint(0); ; shift += 7 { 5325 if shift >= 64 { 5326 return ErrIntOverflowTasks 5327 } 5328 if iNdEx >= l { 5329 return io.ErrUnexpectedEOF 5330 } 5331 b := dAtA[iNdEx] 5332 iNdEx++ 5333 msglen |= int(b&0x7F) << shift 5334 if b < 0x80 { 5335 break 5336 } 5337 } 5338 if msglen < 0 { 5339 return ErrInvalidLengthTasks 5340 } 5341 postIndex := iNdEx + msglen 5342 if postIndex < 0 { 5343 return ErrInvalidLengthTasks 5344 } 5345 if postIndex > l { 5346 return io.ErrUnexpectedEOF 5347 } 5348 m.Tasks = append(m.Tasks, &task.Process{}) 5349 if err := m.Tasks[len(m.Tasks)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 5350 return err 5351 } 5352 iNdEx = postIndex 5353 default: 5354 iNdEx = preIndex 5355 skippy, err := skipTasks(dAtA[iNdEx:]) 5356 if err != nil { 5357 return err 5358 } 5359 if (skippy < 0) || (iNdEx+skippy) < 0 { 5360 return ErrInvalidLengthTasks 5361 } 5362 if (iNdEx + skippy) > l { 5363 return io.ErrUnexpectedEOF 5364 } 5365 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5366 iNdEx += skippy 5367 } 5368 } 5369 5370 if iNdEx > l { 5371 return io.ErrUnexpectedEOF 5372 } 5373 return nil 5374} 5375func (m *KillRequest) Unmarshal(dAtA []byte) error { 5376 l := len(dAtA) 5377 iNdEx := 0 5378 for iNdEx < l { 5379 preIndex := iNdEx 5380 var wire uint64 5381 for shift := uint(0); ; shift += 7 { 5382 if shift >= 64 { 5383 return ErrIntOverflowTasks 5384 } 5385 if iNdEx >= l { 5386 return io.ErrUnexpectedEOF 5387 } 5388 b := dAtA[iNdEx] 5389 iNdEx++ 5390 wire |= uint64(b&0x7F) << shift 5391 if b < 0x80 { 5392 break 5393 } 5394 } 5395 fieldNum := int32(wire >> 3) 5396 wireType := int(wire & 0x7) 5397 if wireType == 4 { 5398 return fmt.Errorf("proto: KillRequest: wiretype end group for non-group") 5399 } 5400 if fieldNum <= 0 { 5401 return fmt.Errorf("proto: KillRequest: illegal tag %d (wire type %d)", fieldNum, wire) 5402 } 5403 switch fieldNum { 5404 case 1: 5405 if wireType != 2 { 5406 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 5407 } 5408 var stringLen uint64 5409 for shift := uint(0); ; shift += 7 { 5410 if shift >= 64 { 5411 return ErrIntOverflowTasks 5412 } 5413 if iNdEx >= l { 5414 return io.ErrUnexpectedEOF 5415 } 5416 b := dAtA[iNdEx] 5417 iNdEx++ 5418 stringLen |= uint64(b&0x7F) << shift 5419 if b < 0x80 { 5420 break 5421 } 5422 } 5423 intStringLen := int(stringLen) 5424 if intStringLen < 0 { 5425 return ErrInvalidLengthTasks 5426 } 5427 postIndex := iNdEx + intStringLen 5428 if postIndex < 0 { 5429 return ErrInvalidLengthTasks 5430 } 5431 if postIndex > l { 5432 return io.ErrUnexpectedEOF 5433 } 5434 m.ContainerID = string(dAtA[iNdEx:postIndex]) 5435 iNdEx = postIndex 5436 case 2: 5437 if wireType != 2 { 5438 return fmt.Errorf("proto: wrong wireType = %d for field ExecID", wireType) 5439 } 5440 var stringLen uint64 5441 for shift := uint(0); ; shift += 7 { 5442 if shift >= 64 { 5443 return ErrIntOverflowTasks 5444 } 5445 if iNdEx >= l { 5446 return io.ErrUnexpectedEOF 5447 } 5448 b := dAtA[iNdEx] 5449 iNdEx++ 5450 stringLen |= uint64(b&0x7F) << shift 5451 if b < 0x80 { 5452 break 5453 } 5454 } 5455 intStringLen := int(stringLen) 5456 if intStringLen < 0 { 5457 return ErrInvalidLengthTasks 5458 } 5459 postIndex := iNdEx + intStringLen 5460 if postIndex < 0 { 5461 return ErrInvalidLengthTasks 5462 } 5463 if postIndex > l { 5464 return io.ErrUnexpectedEOF 5465 } 5466 m.ExecID = string(dAtA[iNdEx:postIndex]) 5467 iNdEx = postIndex 5468 case 3: 5469 if wireType != 0 { 5470 return fmt.Errorf("proto: wrong wireType = %d for field Signal", wireType) 5471 } 5472 m.Signal = 0 5473 for shift := uint(0); ; shift += 7 { 5474 if shift >= 64 { 5475 return ErrIntOverflowTasks 5476 } 5477 if iNdEx >= l { 5478 return io.ErrUnexpectedEOF 5479 } 5480 b := dAtA[iNdEx] 5481 iNdEx++ 5482 m.Signal |= uint32(b&0x7F) << shift 5483 if b < 0x80 { 5484 break 5485 } 5486 } 5487 case 4: 5488 if wireType != 0 { 5489 return fmt.Errorf("proto: wrong wireType = %d for field All", wireType) 5490 } 5491 var v int 5492 for shift := uint(0); ; shift += 7 { 5493 if shift >= 64 { 5494 return ErrIntOverflowTasks 5495 } 5496 if iNdEx >= l { 5497 return io.ErrUnexpectedEOF 5498 } 5499 b := dAtA[iNdEx] 5500 iNdEx++ 5501 v |= int(b&0x7F) << shift 5502 if b < 0x80 { 5503 break 5504 } 5505 } 5506 m.All = bool(v != 0) 5507 default: 5508 iNdEx = preIndex 5509 skippy, err := skipTasks(dAtA[iNdEx:]) 5510 if err != nil { 5511 return err 5512 } 5513 if (skippy < 0) || (iNdEx+skippy) < 0 { 5514 return ErrInvalidLengthTasks 5515 } 5516 if (iNdEx + skippy) > l { 5517 return io.ErrUnexpectedEOF 5518 } 5519 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5520 iNdEx += skippy 5521 } 5522 } 5523 5524 if iNdEx > l { 5525 return io.ErrUnexpectedEOF 5526 } 5527 return nil 5528} 5529func (m *ExecProcessRequest) Unmarshal(dAtA []byte) error { 5530 l := len(dAtA) 5531 iNdEx := 0 5532 for iNdEx < l { 5533 preIndex := iNdEx 5534 var wire uint64 5535 for shift := uint(0); ; shift += 7 { 5536 if shift >= 64 { 5537 return ErrIntOverflowTasks 5538 } 5539 if iNdEx >= l { 5540 return io.ErrUnexpectedEOF 5541 } 5542 b := dAtA[iNdEx] 5543 iNdEx++ 5544 wire |= uint64(b&0x7F) << shift 5545 if b < 0x80 { 5546 break 5547 } 5548 } 5549 fieldNum := int32(wire >> 3) 5550 wireType := int(wire & 0x7) 5551 if wireType == 4 { 5552 return fmt.Errorf("proto: ExecProcessRequest: wiretype end group for non-group") 5553 } 5554 if fieldNum <= 0 { 5555 return fmt.Errorf("proto: ExecProcessRequest: illegal tag %d (wire type %d)", fieldNum, wire) 5556 } 5557 switch fieldNum { 5558 case 1: 5559 if wireType != 2 { 5560 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 5561 } 5562 var stringLen uint64 5563 for shift := uint(0); ; shift += 7 { 5564 if shift >= 64 { 5565 return ErrIntOverflowTasks 5566 } 5567 if iNdEx >= l { 5568 return io.ErrUnexpectedEOF 5569 } 5570 b := dAtA[iNdEx] 5571 iNdEx++ 5572 stringLen |= uint64(b&0x7F) << shift 5573 if b < 0x80 { 5574 break 5575 } 5576 } 5577 intStringLen := int(stringLen) 5578 if intStringLen < 0 { 5579 return ErrInvalidLengthTasks 5580 } 5581 postIndex := iNdEx + intStringLen 5582 if postIndex < 0 { 5583 return ErrInvalidLengthTasks 5584 } 5585 if postIndex > l { 5586 return io.ErrUnexpectedEOF 5587 } 5588 m.ContainerID = string(dAtA[iNdEx:postIndex]) 5589 iNdEx = postIndex 5590 case 2: 5591 if wireType != 2 { 5592 return fmt.Errorf("proto: wrong wireType = %d for field Stdin", wireType) 5593 } 5594 var stringLen uint64 5595 for shift := uint(0); ; shift += 7 { 5596 if shift >= 64 { 5597 return ErrIntOverflowTasks 5598 } 5599 if iNdEx >= l { 5600 return io.ErrUnexpectedEOF 5601 } 5602 b := dAtA[iNdEx] 5603 iNdEx++ 5604 stringLen |= uint64(b&0x7F) << shift 5605 if b < 0x80 { 5606 break 5607 } 5608 } 5609 intStringLen := int(stringLen) 5610 if intStringLen < 0 { 5611 return ErrInvalidLengthTasks 5612 } 5613 postIndex := iNdEx + intStringLen 5614 if postIndex < 0 { 5615 return ErrInvalidLengthTasks 5616 } 5617 if postIndex > l { 5618 return io.ErrUnexpectedEOF 5619 } 5620 m.Stdin = string(dAtA[iNdEx:postIndex]) 5621 iNdEx = postIndex 5622 case 3: 5623 if wireType != 2 { 5624 return fmt.Errorf("proto: wrong wireType = %d for field Stdout", wireType) 5625 } 5626 var stringLen uint64 5627 for shift := uint(0); ; shift += 7 { 5628 if shift >= 64 { 5629 return ErrIntOverflowTasks 5630 } 5631 if iNdEx >= l { 5632 return io.ErrUnexpectedEOF 5633 } 5634 b := dAtA[iNdEx] 5635 iNdEx++ 5636 stringLen |= uint64(b&0x7F) << shift 5637 if b < 0x80 { 5638 break 5639 } 5640 } 5641 intStringLen := int(stringLen) 5642 if intStringLen < 0 { 5643 return ErrInvalidLengthTasks 5644 } 5645 postIndex := iNdEx + intStringLen 5646 if postIndex < 0 { 5647 return ErrInvalidLengthTasks 5648 } 5649 if postIndex > l { 5650 return io.ErrUnexpectedEOF 5651 } 5652 m.Stdout = string(dAtA[iNdEx:postIndex]) 5653 iNdEx = postIndex 5654 case 4: 5655 if wireType != 2 { 5656 return fmt.Errorf("proto: wrong wireType = %d for field Stderr", wireType) 5657 } 5658 var stringLen uint64 5659 for shift := uint(0); ; shift += 7 { 5660 if shift >= 64 { 5661 return ErrIntOverflowTasks 5662 } 5663 if iNdEx >= l { 5664 return io.ErrUnexpectedEOF 5665 } 5666 b := dAtA[iNdEx] 5667 iNdEx++ 5668 stringLen |= uint64(b&0x7F) << shift 5669 if b < 0x80 { 5670 break 5671 } 5672 } 5673 intStringLen := int(stringLen) 5674 if intStringLen < 0 { 5675 return ErrInvalidLengthTasks 5676 } 5677 postIndex := iNdEx + intStringLen 5678 if postIndex < 0 { 5679 return ErrInvalidLengthTasks 5680 } 5681 if postIndex > l { 5682 return io.ErrUnexpectedEOF 5683 } 5684 m.Stderr = string(dAtA[iNdEx:postIndex]) 5685 iNdEx = postIndex 5686 case 5: 5687 if wireType != 0 { 5688 return fmt.Errorf("proto: wrong wireType = %d for field Terminal", wireType) 5689 } 5690 var v int 5691 for shift := uint(0); ; shift += 7 { 5692 if shift >= 64 { 5693 return ErrIntOverflowTasks 5694 } 5695 if iNdEx >= l { 5696 return io.ErrUnexpectedEOF 5697 } 5698 b := dAtA[iNdEx] 5699 iNdEx++ 5700 v |= int(b&0x7F) << shift 5701 if b < 0x80 { 5702 break 5703 } 5704 } 5705 m.Terminal = bool(v != 0) 5706 case 6: 5707 if wireType != 2 { 5708 return fmt.Errorf("proto: wrong wireType = %d for field Spec", wireType) 5709 } 5710 var msglen int 5711 for shift := uint(0); ; shift += 7 { 5712 if shift >= 64 { 5713 return ErrIntOverflowTasks 5714 } 5715 if iNdEx >= l { 5716 return io.ErrUnexpectedEOF 5717 } 5718 b := dAtA[iNdEx] 5719 iNdEx++ 5720 msglen |= int(b&0x7F) << shift 5721 if b < 0x80 { 5722 break 5723 } 5724 } 5725 if msglen < 0 { 5726 return ErrInvalidLengthTasks 5727 } 5728 postIndex := iNdEx + msglen 5729 if postIndex < 0 { 5730 return ErrInvalidLengthTasks 5731 } 5732 if postIndex > l { 5733 return io.ErrUnexpectedEOF 5734 } 5735 if m.Spec == nil { 5736 m.Spec = &types1.Any{} 5737 } 5738 if err := m.Spec.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 5739 return err 5740 } 5741 iNdEx = postIndex 5742 case 7: 5743 if wireType != 2 { 5744 return fmt.Errorf("proto: wrong wireType = %d for field ExecID", wireType) 5745 } 5746 var stringLen uint64 5747 for shift := uint(0); ; shift += 7 { 5748 if shift >= 64 { 5749 return ErrIntOverflowTasks 5750 } 5751 if iNdEx >= l { 5752 return io.ErrUnexpectedEOF 5753 } 5754 b := dAtA[iNdEx] 5755 iNdEx++ 5756 stringLen |= uint64(b&0x7F) << shift 5757 if b < 0x80 { 5758 break 5759 } 5760 } 5761 intStringLen := int(stringLen) 5762 if intStringLen < 0 { 5763 return ErrInvalidLengthTasks 5764 } 5765 postIndex := iNdEx + intStringLen 5766 if postIndex < 0 { 5767 return ErrInvalidLengthTasks 5768 } 5769 if postIndex > l { 5770 return io.ErrUnexpectedEOF 5771 } 5772 m.ExecID = string(dAtA[iNdEx:postIndex]) 5773 iNdEx = postIndex 5774 default: 5775 iNdEx = preIndex 5776 skippy, err := skipTasks(dAtA[iNdEx:]) 5777 if err != nil { 5778 return err 5779 } 5780 if (skippy < 0) || (iNdEx+skippy) < 0 { 5781 return ErrInvalidLengthTasks 5782 } 5783 if (iNdEx + skippy) > l { 5784 return io.ErrUnexpectedEOF 5785 } 5786 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5787 iNdEx += skippy 5788 } 5789 } 5790 5791 if iNdEx > l { 5792 return io.ErrUnexpectedEOF 5793 } 5794 return nil 5795} 5796func (m *ExecProcessResponse) Unmarshal(dAtA []byte) error { 5797 l := len(dAtA) 5798 iNdEx := 0 5799 for iNdEx < l { 5800 preIndex := iNdEx 5801 var wire uint64 5802 for shift := uint(0); ; shift += 7 { 5803 if shift >= 64 { 5804 return ErrIntOverflowTasks 5805 } 5806 if iNdEx >= l { 5807 return io.ErrUnexpectedEOF 5808 } 5809 b := dAtA[iNdEx] 5810 iNdEx++ 5811 wire |= uint64(b&0x7F) << shift 5812 if b < 0x80 { 5813 break 5814 } 5815 } 5816 fieldNum := int32(wire >> 3) 5817 wireType := int(wire & 0x7) 5818 if wireType == 4 { 5819 return fmt.Errorf("proto: ExecProcessResponse: wiretype end group for non-group") 5820 } 5821 if fieldNum <= 0 { 5822 return fmt.Errorf("proto: ExecProcessResponse: illegal tag %d (wire type %d)", fieldNum, wire) 5823 } 5824 switch fieldNum { 5825 default: 5826 iNdEx = preIndex 5827 skippy, err := skipTasks(dAtA[iNdEx:]) 5828 if err != nil { 5829 return err 5830 } 5831 if (skippy < 0) || (iNdEx+skippy) < 0 { 5832 return ErrInvalidLengthTasks 5833 } 5834 if (iNdEx + skippy) > l { 5835 return io.ErrUnexpectedEOF 5836 } 5837 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5838 iNdEx += skippy 5839 } 5840 } 5841 5842 if iNdEx > l { 5843 return io.ErrUnexpectedEOF 5844 } 5845 return nil 5846} 5847func (m *ResizePtyRequest) Unmarshal(dAtA []byte) error { 5848 l := len(dAtA) 5849 iNdEx := 0 5850 for iNdEx < l { 5851 preIndex := iNdEx 5852 var wire uint64 5853 for shift := uint(0); ; shift += 7 { 5854 if shift >= 64 { 5855 return ErrIntOverflowTasks 5856 } 5857 if iNdEx >= l { 5858 return io.ErrUnexpectedEOF 5859 } 5860 b := dAtA[iNdEx] 5861 iNdEx++ 5862 wire |= uint64(b&0x7F) << shift 5863 if b < 0x80 { 5864 break 5865 } 5866 } 5867 fieldNum := int32(wire >> 3) 5868 wireType := int(wire & 0x7) 5869 if wireType == 4 { 5870 return fmt.Errorf("proto: ResizePtyRequest: wiretype end group for non-group") 5871 } 5872 if fieldNum <= 0 { 5873 return fmt.Errorf("proto: ResizePtyRequest: illegal tag %d (wire type %d)", fieldNum, wire) 5874 } 5875 switch fieldNum { 5876 case 1: 5877 if wireType != 2 { 5878 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 5879 } 5880 var stringLen uint64 5881 for shift := uint(0); ; shift += 7 { 5882 if shift >= 64 { 5883 return ErrIntOverflowTasks 5884 } 5885 if iNdEx >= l { 5886 return io.ErrUnexpectedEOF 5887 } 5888 b := dAtA[iNdEx] 5889 iNdEx++ 5890 stringLen |= uint64(b&0x7F) << shift 5891 if b < 0x80 { 5892 break 5893 } 5894 } 5895 intStringLen := int(stringLen) 5896 if intStringLen < 0 { 5897 return ErrInvalidLengthTasks 5898 } 5899 postIndex := iNdEx + intStringLen 5900 if postIndex < 0 { 5901 return ErrInvalidLengthTasks 5902 } 5903 if postIndex > l { 5904 return io.ErrUnexpectedEOF 5905 } 5906 m.ContainerID = string(dAtA[iNdEx:postIndex]) 5907 iNdEx = postIndex 5908 case 2: 5909 if wireType != 2 { 5910 return fmt.Errorf("proto: wrong wireType = %d for field ExecID", wireType) 5911 } 5912 var stringLen uint64 5913 for shift := uint(0); ; shift += 7 { 5914 if shift >= 64 { 5915 return ErrIntOverflowTasks 5916 } 5917 if iNdEx >= l { 5918 return io.ErrUnexpectedEOF 5919 } 5920 b := dAtA[iNdEx] 5921 iNdEx++ 5922 stringLen |= uint64(b&0x7F) << shift 5923 if b < 0x80 { 5924 break 5925 } 5926 } 5927 intStringLen := int(stringLen) 5928 if intStringLen < 0 { 5929 return ErrInvalidLengthTasks 5930 } 5931 postIndex := iNdEx + intStringLen 5932 if postIndex < 0 { 5933 return ErrInvalidLengthTasks 5934 } 5935 if postIndex > l { 5936 return io.ErrUnexpectedEOF 5937 } 5938 m.ExecID = string(dAtA[iNdEx:postIndex]) 5939 iNdEx = postIndex 5940 case 3: 5941 if wireType != 0 { 5942 return fmt.Errorf("proto: wrong wireType = %d for field Width", wireType) 5943 } 5944 m.Width = 0 5945 for shift := uint(0); ; shift += 7 { 5946 if shift >= 64 { 5947 return ErrIntOverflowTasks 5948 } 5949 if iNdEx >= l { 5950 return io.ErrUnexpectedEOF 5951 } 5952 b := dAtA[iNdEx] 5953 iNdEx++ 5954 m.Width |= uint32(b&0x7F) << shift 5955 if b < 0x80 { 5956 break 5957 } 5958 } 5959 case 4: 5960 if wireType != 0 { 5961 return fmt.Errorf("proto: wrong wireType = %d for field Height", wireType) 5962 } 5963 m.Height = 0 5964 for shift := uint(0); ; shift += 7 { 5965 if shift >= 64 { 5966 return ErrIntOverflowTasks 5967 } 5968 if iNdEx >= l { 5969 return io.ErrUnexpectedEOF 5970 } 5971 b := dAtA[iNdEx] 5972 iNdEx++ 5973 m.Height |= uint32(b&0x7F) << shift 5974 if b < 0x80 { 5975 break 5976 } 5977 } 5978 default: 5979 iNdEx = preIndex 5980 skippy, err := skipTasks(dAtA[iNdEx:]) 5981 if err != nil { 5982 return err 5983 } 5984 if (skippy < 0) || (iNdEx+skippy) < 0 { 5985 return ErrInvalidLengthTasks 5986 } 5987 if (iNdEx + skippy) > l { 5988 return io.ErrUnexpectedEOF 5989 } 5990 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5991 iNdEx += skippy 5992 } 5993 } 5994 5995 if iNdEx > l { 5996 return io.ErrUnexpectedEOF 5997 } 5998 return nil 5999} 6000func (m *CloseIORequest) Unmarshal(dAtA []byte) error { 6001 l := len(dAtA) 6002 iNdEx := 0 6003 for iNdEx < l { 6004 preIndex := iNdEx 6005 var wire uint64 6006 for shift := uint(0); ; shift += 7 { 6007 if shift >= 64 { 6008 return ErrIntOverflowTasks 6009 } 6010 if iNdEx >= l { 6011 return io.ErrUnexpectedEOF 6012 } 6013 b := dAtA[iNdEx] 6014 iNdEx++ 6015 wire |= uint64(b&0x7F) << shift 6016 if b < 0x80 { 6017 break 6018 } 6019 } 6020 fieldNum := int32(wire >> 3) 6021 wireType := int(wire & 0x7) 6022 if wireType == 4 { 6023 return fmt.Errorf("proto: CloseIORequest: wiretype end group for non-group") 6024 } 6025 if fieldNum <= 0 { 6026 return fmt.Errorf("proto: CloseIORequest: illegal tag %d (wire type %d)", fieldNum, wire) 6027 } 6028 switch fieldNum { 6029 case 1: 6030 if wireType != 2 { 6031 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 6032 } 6033 var stringLen uint64 6034 for shift := uint(0); ; shift += 7 { 6035 if shift >= 64 { 6036 return ErrIntOverflowTasks 6037 } 6038 if iNdEx >= l { 6039 return io.ErrUnexpectedEOF 6040 } 6041 b := dAtA[iNdEx] 6042 iNdEx++ 6043 stringLen |= uint64(b&0x7F) << shift 6044 if b < 0x80 { 6045 break 6046 } 6047 } 6048 intStringLen := int(stringLen) 6049 if intStringLen < 0 { 6050 return ErrInvalidLengthTasks 6051 } 6052 postIndex := iNdEx + intStringLen 6053 if postIndex < 0 { 6054 return ErrInvalidLengthTasks 6055 } 6056 if postIndex > l { 6057 return io.ErrUnexpectedEOF 6058 } 6059 m.ContainerID = string(dAtA[iNdEx:postIndex]) 6060 iNdEx = postIndex 6061 case 2: 6062 if wireType != 2 { 6063 return fmt.Errorf("proto: wrong wireType = %d for field ExecID", wireType) 6064 } 6065 var stringLen uint64 6066 for shift := uint(0); ; shift += 7 { 6067 if shift >= 64 { 6068 return ErrIntOverflowTasks 6069 } 6070 if iNdEx >= l { 6071 return io.ErrUnexpectedEOF 6072 } 6073 b := dAtA[iNdEx] 6074 iNdEx++ 6075 stringLen |= uint64(b&0x7F) << shift 6076 if b < 0x80 { 6077 break 6078 } 6079 } 6080 intStringLen := int(stringLen) 6081 if intStringLen < 0 { 6082 return ErrInvalidLengthTasks 6083 } 6084 postIndex := iNdEx + intStringLen 6085 if postIndex < 0 { 6086 return ErrInvalidLengthTasks 6087 } 6088 if postIndex > l { 6089 return io.ErrUnexpectedEOF 6090 } 6091 m.ExecID = string(dAtA[iNdEx:postIndex]) 6092 iNdEx = postIndex 6093 case 3: 6094 if wireType != 0 { 6095 return fmt.Errorf("proto: wrong wireType = %d for field Stdin", wireType) 6096 } 6097 var v int 6098 for shift := uint(0); ; shift += 7 { 6099 if shift >= 64 { 6100 return ErrIntOverflowTasks 6101 } 6102 if iNdEx >= l { 6103 return io.ErrUnexpectedEOF 6104 } 6105 b := dAtA[iNdEx] 6106 iNdEx++ 6107 v |= int(b&0x7F) << shift 6108 if b < 0x80 { 6109 break 6110 } 6111 } 6112 m.Stdin = bool(v != 0) 6113 default: 6114 iNdEx = preIndex 6115 skippy, err := skipTasks(dAtA[iNdEx:]) 6116 if err != nil { 6117 return err 6118 } 6119 if (skippy < 0) || (iNdEx+skippy) < 0 { 6120 return ErrInvalidLengthTasks 6121 } 6122 if (iNdEx + skippy) > l { 6123 return io.ErrUnexpectedEOF 6124 } 6125 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 6126 iNdEx += skippy 6127 } 6128 } 6129 6130 if iNdEx > l { 6131 return io.ErrUnexpectedEOF 6132 } 6133 return nil 6134} 6135func (m *PauseTaskRequest) Unmarshal(dAtA []byte) error { 6136 l := len(dAtA) 6137 iNdEx := 0 6138 for iNdEx < l { 6139 preIndex := iNdEx 6140 var wire uint64 6141 for shift := uint(0); ; shift += 7 { 6142 if shift >= 64 { 6143 return ErrIntOverflowTasks 6144 } 6145 if iNdEx >= l { 6146 return io.ErrUnexpectedEOF 6147 } 6148 b := dAtA[iNdEx] 6149 iNdEx++ 6150 wire |= uint64(b&0x7F) << shift 6151 if b < 0x80 { 6152 break 6153 } 6154 } 6155 fieldNum := int32(wire >> 3) 6156 wireType := int(wire & 0x7) 6157 if wireType == 4 { 6158 return fmt.Errorf("proto: PauseTaskRequest: wiretype end group for non-group") 6159 } 6160 if fieldNum <= 0 { 6161 return fmt.Errorf("proto: PauseTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) 6162 } 6163 switch fieldNum { 6164 case 1: 6165 if wireType != 2 { 6166 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 6167 } 6168 var stringLen uint64 6169 for shift := uint(0); ; shift += 7 { 6170 if shift >= 64 { 6171 return ErrIntOverflowTasks 6172 } 6173 if iNdEx >= l { 6174 return io.ErrUnexpectedEOF 6175 } 6176 b := dAtA[iNdEx] 6177 iNdEx++ 6178 stringLen |= uint64(b&0x7F) << shift 6179 if b < 0x80 { 6180 break 6181 } 6182 } 6183 intStringLen := int(stringLen) 6184 if intStringLen < 0 { 6185 return ErrInvalidLengthTasks 6186 } 6187 postIndex := iNdEx + intStringLen 6188 if postIndex < 0 { 6189 return ErrInvalidLengthTasks 6190 } 6191 if postIndex > l { 6192 return io.ErrUnexpectedEOF 6193 } 6194 m.ContainerID = string(dAtA[iNdEx:postIndex]) 6195 iNdEx = postIndex 6196 default: 6197 iNdEx = preIndex 6198 skippy, err := skipTasks(dAtA[iNdEx:]) 6199 if err != nil { 6200 return err 6201 } 6202 if (skippy < 0) || (iNdEx+skippy) < 0 { 6203 return ErrInvalidLengthTasks 6204 } 6205 if (iNdEx + skippy) > l { 6206 return io.ErrUnexpectedEOF 6207 } 6208 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 6209 iNdEx += skippy 6210 } 6211 } 6212 6213 if iNdEx > l { 6214 return io.ErrUnexpectedEOF 6215 } 6216 return nil 6217} 6218func (m *ResumeTaskRequest) Unmarshal(dAtA []byte) error { 6219 l := len(dAtA) 6220 iNdEx := 0 6221 for iNdEx < l { 6222 preIndex := iNdEx 6223 var wire uint64 6224 for shift := uint(0); ; shift += 7 { 6225 if shift >= 64 { 6226 return ErrIntOverflowTasks 6227 } 6228 if iNdEx >= l { 6229 return io.ErrUnexpectedEOF 6230 } 6231 b := dAtA[iNdEx] 6232 iNdEx++ 6233 wire |= uint64(b&0x7F) << shift 6234 if b < 0x80 { 6235 break 6236 } 6237 } 6238 fieldNum := int32(wire >> 3) 6239 wireType := int(wire & 0x7) 6240 if wireType == 4 { 6241 return fmt.Errorf("proto: ResumeTaskRequest: wiretype end group for non-group") 6242 } 6243 if fieldNum <= 0 { 6244 return fmt.Errorf("proto: ResumeTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) 6245 } 6246 switch fieldNum { 6247 case 1: 6248 if wireType != 2 { 6249 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 6250 } 6251 var stringLen uint64 6252 for shift := uint(0); ; shift += 7 { 6253 if shift >= 64 { 6254 return ErrIntOverflowTasks 6255 } 6256 if iNdEx >= l { 6257 return io.ErrUnexpectedEOF 6258 } 6259 b := dAtA[iNdEx] 6260 iNdEx++ 6261 stringLen |= uint64(b&0x7F) << shift 6262 if b < 0x80 { 6263 break 6264 } 6265 } 6266 intStringLen := int(stringLen) 6267 if intStringLen < 0 { 6268 return ErrInvalidLengthTasks 6269 } 6270 postIndex := iNdEx + intStringLen 6271 if postIndex < 0 { 6272 return ErrInvalidLengthTasks 6273 } 6274 if postIndex > l { 6275 return io.ErrUnexpectedEOF 6276 } 6277 m.ContainerID = string(dAtA[iNdEx:postIndex]) 6278 iNdEx = postIndex 6279 default: 6280 iNdEx = preIndex 6281 skippy, err := skipTasks(dAtA[iNdEx:]) 6282 if err != nil { 6283 return err 6284 } 6285 if (skippy < 0) || (iNdEx+skippy) < 0 { 6286 return ErrInvalidLengthTasks 6287 } 6288 if (iNdEx + skippy) > l { 6289 return io.ErrUnexpectedEOF 6290 } 6291 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 6292 iNdEx += skippy 6293 } 6294 } 6295 6296 if iNdEx > l { 6297 return io.ErrUnexpectedEOF 6298 } 6299 return nil 6300} 6301func (m *ListPidsRequest) Unmarshal(dAtA []byte) error { 6302 l := len(dAtA) 6303 iNdEx := 0 6304 for iNdEx < l { 6305 preIndex := iNdEx 6306 var wire uint64 6307 for shift := uint(0); ; shift += 7 { 6308 if shift >= 64 { 6309 return ErrIntOverflowTasks 6310 } 6311 if iNdEx >= l { 6312 return io.ErrUnexpectedEOF 6313 } 6314 b := dAtA[iNdEx] 6315 iNdEx++ 6316 wire |= uint64(b&0x7F) << shift 6317 if b < 0x80 { 6318 break 6319 } 6320 } 6321 fieldNum := int32(wire >> 3) 6322 wireType := int(wire & 0x7) 6323 if wireType == 4 { 6324 return fmt.Errorf("proto: ListPidsRequest: wiretype end group for non-group") 6325 } 6326 if fieldNum <= 0 { 6327 return fmt.Errorf("proto: ListPidsRequest: illegal tag %d (wire type %d)", fieldNum, wire) 6328 } 6329 switch fieldNum { 6330 case 1: 6331 if wireType != 2 { 6332 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 6333 } 6334 var stringLen uint64 6335 for shift := uint(0); ; shift += 7 { 6336 if shift >= 64 { 6337 return ErrIntOverflowTasks 6338 } 6339 if iNdEx >= l { 6340 return io.ErrUnexpectedEOF 6341 } 6342 b := dAtA[iNdEx] 6343 iNdEx++ 6344 stringLen |= uint64(b&0x7F) << shift 6345 if b < 0x80 { 6346 break 6347 } 6348 } 6349 intStringLen := int(stringLen) 6350 if intStringLen < 0 { 6351 return ErrInvalidLengthTasks 6352 } 6353 postIndex := iNdEx + intStringLen 6354 if postIndex < 0 { 6355 return ErrInvalidLengthTasks 6356 } 6357 if postIndex > l { 6358 return io.ErrUnexpectedEOF 6359 } 6360 m.ContainerID = string(dAtA[iNdEx:postIndex]) 6361 iNdEx = postIndex 6362 default: 6363 iNdEx = preIndex 6364 skippy, err := skipTasks(dAtA[iNdEx:]) 6365 if err != nil { 6366 return err 6367 } 6368 if (skippy < 0) || (iNdEx+skippy) < 0 { 6369 return ErrInvalidLengthTasks 6370 } 6371 if (iNdEx + skippy) > l { 6372 return io.ErrUnexpectedEOF 6373 } 6374 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 6375 iNdEx += skippy 6376 } 6377 } 6378 6379 if iNdEx > l { 6380 return io.ErrUnexpectedEOF 6381 } 6382 return nil 6383} 6384func (m *ListPidsResponse) Unmarshal(dAtA []byte) error { 6385 l := len(dAtA) 6386 iNdEx := 0 6387 for iNdEx < l { 6388 preIndex := iNdEx 6389 var wire uint64 6390 for shift := uint(0); ; shift += 7 { 6391 if shift >= 64 { 6392 return ErrIntOverflowTasks 6393 } 6394 if iNdEx >= l { 6395 return io.ErrUnexpectedEOF 6396 } 6397 b := dAtA[iNdEx] 6398 iNdEx++ 6399 wire |= uint64(b&0x7F) << shift 6400 if b < 0x80 { 6401 break 6402 } 6403 } 6404 fieldNum := int32(wire >> 3) 6405 wireType := int(wire & 0x7) 6406 if wireType == 4 { 6407 return fmt.Errorf("proto: ListPidsResponse: wiretype end group for non-group") 6408 } 6409 if fieldNum <= 0 { 6410 return fmt.Errorf("proto: ListPidsResponse: illegal tag %d (wire type %d)", fieldNum, wire) 6411 } 6412 switch fieldNum { 6413 case 1: 6414 if wireType != 2 { 6415 return fmt.Errorf("proto: wrong wireType = %d for field Processes", wireType) 6416 } 6417 var msglen int 6418 for shift := uint(0); ; shift += 7 { 6419 if shift >= 64 { 6420 return ErrIntOverflowTasks 6421 } 6422 if iNdEx >= l { 6423 return io.ErrUnexpectedEOF 6424 } 6425 b := dAtA[iNdEx] 6426 iNdEx++ 6427 msglen |= int(b&0x7F) << shift 6428 if b < 0x80 { 6429 break 6430 } 6431 } 6432 if msglen < 0 { 6433 return ErrInvalidLengthTasks 6434 } 6435 postIndex := iNdEx + msglen 6436 if postIndex < 0 { 6437 return ErrInvalidLengthTasks 6438 } 6439 if postIndex > l { 6440 return io.ErrUnexpectedEOF 6441 } 6442 m.Processes = append(m.Processes, &task.ProcessInfo{}) 6443 if err := m.Processes[len(m.Processes)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 6444 return err 6445 } 6446 iNdEx = postIndex 6447 default: 6448 iNdEx = preIndex 6449 skippy, err := skipTasks(dAtA[iNdEx:]) 6450 if err != nil { 6451 return err 6452 } 6453 if (skippy < 0) || (iNdEx+skippy) < 0 { 6454 return ErrInvalidLengthTasks 6455 } 6456 if (iNdEx + skippy) > l { 6457 return io.ErrUnexpectedEOF 6458 } 6459 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 6460 iNdEx += skippy 6461 } 6462 } 6463 6464 if iNdEx > l { 6465 return io.ErrUnexpectedEOF 6466 } 6467 return nil 6468} 6469func (m *CheckpointTaskRequest) Unmarshal(dAtA []byte) error { 6470 l := len(dAtA) 6471 iNdEx := 0 6472 for iNdEx < l { 6473 preIndex := iNdEx 6474 var wire uint64 6475 for shift := uint(0); ; shift += 7 { 6476 if shift >= 64 { 6477 return ErrIntOverflowTasks 6478 } 6479 if iNdEx >= l { 6480 return io.ErrUnexpectedEOF 6481 } 6482 b := dAtA[iNdEx] 6483 iNdEx++ 6484 wire |= uint64(b&0x7F) << shift 6485 if b < 0x80 { 6486 break 6487 } 6488 } 6489 fieldNum := int32(wire >> 3) 6490 wireType := int(wire & 0x7) 6491 if wireType == 4 { 6492 return fmt.Errorf("proto: CheckpointTaskRequest: wiretype end group for non-group") 6493 } 6494 if fieldNum <= 0 { 6495 return fmt.Errorf("proto: CheckpointTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) 6496 } 6497 switch fieldNum { 6498 case 1: 6499 if wireType != 2 { 6500 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 6501 } 6502 var stringLen uint64 6503 for shift := uint(0); ; shift += 7 { 6504 if shift >= 64 { 6505 return ErrIntOverflowTasks 6506 } 6507 if iNdEx >= l { 6508 return io.ErrUnexpectedEOF 6509 } 6510 b := dAtA[iNdEx] 6511 iNdEx++ 6512 stringLen |= uint64(b&0x7F) << shift 6513 if b < 0x80 { 6514 break 6515 } 6516 } 6517 intStringLen := int(stringLen) 6518 if intStringLen < 0 { 6519 return ErrInvalidLengthTasks 6520 } 6521 postIndex := iNdEx + intStringLen 6522 if postIndex < 0 { 6523 return ErrInvalidLengthTasks 6524 } 6525 if postIndex > l { 6526 return io.ErrUnexpectedEOF 6527 } 6528 m.ContainerID = string(dAtA[iNdEx:postIndex]) 6529 iNdEx = postIndex 6530 case 2: 6531 if wireType != 2 { 6532 return fmt.Errorf("proto: wrong wireType = %d for field ParentCheckpoint", wireType) 6533 } 6534 var stringLen uint64 6535 for shift := uint(0); ; shift += 7 { 6536 if shift >= 64 { 6537 return ErrIntOverflowTasks 6538 } 6539 if iNdEx >= l { 6540 return io.ErrUnexpectedEOF 6541 } 6542 b := dAtA[iNdEx] 6543 iNdEx++ 6544 stringLen |= uint64(b&0x7F) << shift 6545 if b < 0x80 { 6546 break 6547 } 6548 } 6549 intStringLen := int(stringLen) 6550 if intStringLen < 0 { 6551 return ErrInvalidLengthTasks 6552 } 6553 postIndex := iNdEx + intStringLen 6554 if postIndex < 0 { 6555 return ErrInvalidLengthTasks 6556 } 6557 if postIndex > l { 6558 return io.ErrUnexpectedEOF 6559 } 6560 m.ParentCheckpoint = github_com_opencontainers_go_digest.Digest(dAtA[iNdEx:postIndex]) 6561 iNdEx = postIndex 6562 case 3: 6563 if wireType != 2 { 6564 return fmt.Errorf("proto: wrong wireType = %d for field Options", wireType) 6565 } 6566 var msglen int 6567 for shift := uint(0); ; shift += 7 { 6568 if shift >= 64 { 6569 return ErrIntOverflowTasks 6570 } 6571 if iNdEx >= l { 6572 return io.ErrUnexpectedEOF 6573 } 6574 b := dAtA[iNdEx] 6575 iNdEx++ 6576 msglen |= int(b&0x7F) << shift 6577 if b < 0x80 { 6578 break 6579 } 6580 } 6581 if msglen < 0 { 6582 return ErrInvalidLengthTasks 6583 } 6584 postIndex := iNdEx + msglen 6585 if postIndex < 0 { 6586 return ErrInvalidLengthTasks 6587 } 6588 if postIndex > l { 6589 return io.ErrUnexpectedEOF 6590 } 6591 if m.Options == nil { 6592 m.Options = &types1.Any{} 6593 } 6594 if err := m.Options.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 6595 return err 6596 } 6597 iNdEx = postIndex 6598 default: 6599 iNdEx = preIndex 6600 skippy, err := skipTasks(dAtA[iNdEx:]) 6601 if err != nil { 6602 return err 6603 } 6604 if (skippy < 0) || (iNdEx+skippy) < 0 { 6605 return ErrInvalidLengthTasks 6606 } 6607 if (iNdEx + skippy) > l { 6608 return io.ErrUnexpectedEOF 6609 } 6610 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 6611 iNdEx += skippy 6612 } 6613 } 6614 6615 if iNdEx > l { 6616 return io.ErrUnexpectedEOF 6617 } 6618 return nil 6619} 6620func (m *CheckpointTaskResponse) Unmarshal(dAtA []byte) error { 6621 l := len(dAtA) 6622 iNdEx := 0 6623 for iNdEx < l { 6624 preIndex := iNdEx 6625 var wire uint64 6626 for shift := uint(0); ; shift += 7 { 6627 if shift >= 64 { 6628 return ErrIntOverflowTasks 6629 } 6630 if iNdEx >= l { 6631 return io.ErrUnexpectedEOF 6632 } 6633 b := dAtA[iNdEx] 6634 iNdEx++ 6635 wire |= uint64(b&0x7F) << shift 6636 if b < 0x80 { 6637 break 6638 } 6639 } 6640 fieldNum := int32(wire >> 3) 6641 wireType := int(wire & 0x7) 6642 if wireType == 4 { 6643 return fmt.Errorf("proto: CheckpointTaskResponse: wiretype end group for non-group") 6644 } 6645 if fieldNum <= 0 { 6646 return fmt.Errorf("proto: CheckpointTaskResponse: illegal tag %d (wire type %d)", fieldNum, wire) 6647 } 6648 switch fieldNum { 6649 case 1: 6650 if wireType != 2 { 6651 return fmt.Errorf("proto: wrong wireType = %d for field Descriptors", wireType) 6652 } 6653 var msglen int 6654 for shift := uint(0); ; shift += 7 { 6655 if shift >= 64 { 6656 return ErrIntOverflowTasks 6657 } 6658 if iNdEx >= l { 6659 return io.ErrUnexpectedEOF 6660 } 6661 b := dAtA[iNdEx] 6662 iNdEx++ 6663 msglen |= int(b&0x7F) << shift 6664 if b < 0x80 { 6665 break 6666 } 6667 } 6668 if msglen < 0 { 6669 return ErrInvalidLengthTasks 6670 } 6671 postIndex := iNdEx + msglen 6672 if postIndex < 0 { 6673 return ErrInvalidLengthTasks 6674 } 6675 if postIndex > l { 6676 return io.ErrUnexpectedEOF 6677 } 6678 m.Descriptors = append(m.Descriptors, &types.Descriptor{}) 6679 if err := m.Descriptors[len(m.Descriptors)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 6680 return err 6681 } 6682 iNdEx = postIndex 6683 default: 6684 iNdEx = preIndex 6685 skippy, err := skipTasks(dAtA[iNdEx:]) 6686 if err != nil { 6687 return err 6688 } 6689 if (skippy < 0) || (iNdEx+skippy) < 0 { 6690 return ErrInvalidLengthTasks 6691 } 6692 if (iNdEx + skippy) > l { 6693 return io.ErrUnexpectedEOF 6694 } 6695 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 6696 iNdEx += skippy 6697 } 6698 } 6699 6700 if iNdEx > l { 6701 return io.ErrUnexpectedEOF 6702 } 6703 return nil 6704} 6705func (m *UpdateTaskRequest) Unmarshal(dAtA []byte) error { 6706 l := len(dAtA) 6707 iNdEx := 0 6708 for iNdEx < l { 6709 preIndex := iNdEx 6710 var wire uint64 6711 for shift := uint(0); ; shift += 7 { 6712 if shift >= 64 { 6713 return ErrIntOverflowTasks 6714 } 6715 if iNdEx >= l { 6716 return io.ErrUnexpectedEOF 6717 } 6718 b := dAtA[iNdEx] 6719 iNdEx++ 6720 wire |= uint64(b&0x7F) << shift 6721 if b < 0x80 { 6722 break 6723 } 6724 } 6725 fieldNum := int32(wire >> 3) 6726 wireType := int(wire & 0x7) 6727 if wireType == 4 { 6728 return fmt.Errorf("proto: UpdateTaskRequest: wiretype end group for non-group") 6729 } 6730 if fieldNum <= 0 { 6731 return fmt.Errorf("proto: UpdateTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) 6732 } 6733 switch fieldNum { 6734 case 1: 6735 if wireType != 2 { 6736 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 6737 } 6738 var stringLen uint64 6739 for shift := uint(0); ; shift += 7 { 6740 if shift >= 64 { 6741 return ErrIntOverflowTasks 6742 } 6743 if iNdEx >= l { 6744 return io.ErrUnexpectedEOF 6745 } 6746 b := dAtA[iNdEx] 6747 iNdEx++ 6748 stringLen |= uint64(b&0x7F) << shift 6749 if b < 0x80 { 6750 break 6751 } 6752 } 6753 intStringLen := int(stringLen) 6754 if intStringLen < 0 { 6755 return ErrInvalidLengthTasks 6756 } 6757 postIndex := iNdEx + intStringLen 6758 if postIndex < 0 { 6759 return ErrInvalidLengthTasks 6760 } 6761 if postIndex > l { 6762 return io.ErrUnexpectedEOF 6763 } 6764 m.ContainerID = string(dAtA[iNdEx:postIndex]) 6765 iNdEx = postIndex 6766 case 2: 6767 if wireType != 2 { 6768 return fmt.Errorf("proto: wrong wireType = %d for field Resources", wireType) 6769 } 6770 var msglen int 6771 for shift := uint(0); ; shift += 7 { 6772 if shift >= 64 { 6773 return ErrIntOverflowTasks 6774 } 6775 if iNdEx >= l { 6776 return io.ErrUnexpectedEOF 6777 } 6778 b := dAtA[iNdEx] 6779 iNdEx++ 6780 msglen |= int(b&0x7F) << shift 6781 if b < 0x80 { 6782 break 6783 } 6784 } 6785 if msglen < 0 { 6786 return ErrInvalidLengthTasks 6787 } 6788 postIndex := iNdEx + msglen 6789 if postIndex < 0 { 6790 return ErrInvalidLengthTasks 6791 } 6792 if postIndex > l { 6793 return io.ErrUnexpectedEOF 6794 } 6795 if m.Resources == nil { 6796 m.Resources = &types1.Any{} 6797 } 6798 if err := m.Resources.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 6799 return err 6800 } 6801 iNdEx = postIndex 6802 default: 6803 iNdEx = preIndex 6804 skippy, err := skipTasks(dAtA[iNdEx:]) 6805 if err != nil { 6806 return err 6807 } 6808 if (skippy < 0) || (iNdEx+skippy) < 0 { 6809 return ErrInvalidLengthTasks 6810 } 6811 if (iNdEx + skippy) > l { 6812 return io.ErrUnexpectedEOF 6813 } 6814 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 6815 iNdEx += skippy 6816 } 6817 } 6818 6819 if iNdEx > l { 6820 return io.ErrUnexpectedEOF 6821 } 6822 return nil 6823} 6824func (m *MetricsRequest) Unmarshal(dAtA []byte) error { 6825 l := len(dAtA) 6826 iNdEx := 0 6827 for iNdEx < l { 6828 preIndex := iNdEx 6829 var wire uint64 6830 for shift := uint(0); ; shift += 7 { 6831 if shift >= 64 { 6832 return ErrIntOverflowTasks 6833 } 6834 if iNdEx >= l { 6835 return io.ErrUnexpectedEOF 6836 } 6837 b := dAtA[iNdEx] 6838 iNdEx++ 6839 wire |= uint64(b&0x7F) << shift 6840 if b < 0x80 { 6841 break 6842 } 6843 } 6844 fieldNum := int32(wire >> 3) 6845 wireType := int(wire & 0x7) 6846 if wireType == 4 { 6847 return fmt.Errorf("proto: MetricsRequest: wiretype end group for non-group") 6848 } 6849 if fieldNum <= 0 { 6850 return fmt.Errorf("proto: MetricsRequest: illegal tag %d (wire type %d)", fieldNum, wire) 6851 } 6852 switch fieldNum { 6853 case 1: 6854 if wireType != 2 { 6855 return fmt.Errorf("proto: wrong wireType = %d for field Filters", wireType) 6856 } 6857 var stringLen uint64 6858 for shift := uint(0); ; shift += 7 { 6859 if shift >= 64 { 6860 return ErrIntOverflowTasks 6861 } 6862 if iNdEx >= l { 6863 return io.ErrUnexpectedEOF 6864 } 6865 b := dAtA[iNdEx] 6866 iNdEx++ 6867 stringLen |= uint64(b&0x7F) << shift 6868 if b < 0x80 { 6869 break 6870 } 6871 } 6872 intStringLen := int(stringLen) 6873 if intStringLen < 0 { 6874 return ErrInvalidLengthTasks 6875 } 6876 postIndex := iNdEx + intStringLen 6877 if postIndex < 0 { 6878 return ErrInvalidLengthTasks 6879 } 6880 if postIndex > l { 6881 return io.ErrUnexpectedEOF 6882 } 6883 m.Filters = append(m.Filters, string(dAtA[iNdEx:postIndex])) 6884 iNdEx = postIndex 6885 default: 6886 iNdEx = preIndex 6887 skippy, err := skipTasks(dAtA[iNdEx:]) 6888 if err != nil { 6889 return err 6890 } 6891 if (skippy < 0) || (iNdEx+skippy) < 0 { 6892 return ErrInvalidLengthTasks 6893 } 6894 if (iNdEx + skippy) > l { 6895 return io.ErrUnexpectedEOF 6896 } 6897 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 6898 iNdEx += skippy 6899 } 6900 } 6901 6902 if iNdEx > l { 6903 return io.ErrUnexpectedEOF 6904 } 6905 return nil 6906} 6907func (m *MetricsResponse) Unmarshal(dAtA []byte) error { 6908 l := len(dAtA) 6909 iNdEx := 0 6910 for iNdEx < l { 6911 preIndex := iNdEx 6912 var wire uint64 6913 for shift := uint(0); ; shift += 7 { 6914 if shift >= 64 { 6915 return ErrIntOverflowTasks 6916 } 6917 if iNdEx >= l { 6918 return io.ErrUnexpectedEOF 6919 } 6920 b := dAtA[iNdEx] 6921 iNdEx++ 6922 wire |= uint64(b&0x7F) << shift 6923 if b < 0x80 { 6924 break 6925 } 6926 } 6927 fieldNum := int32(wire >> 3) 6928 wireType := int(wire & 0x7) 6929 if wireType == 4 { 6930 return fmt.Errorf("proto: MetricsResponse: wiretype end group for non-group") 6931 } 6932 if fieldNum <= 0 { 6933 return fmt.Errorf("proto: MetricsResponse: illegal tag %d (wire type %d)", fieldNum, wire) 6934 } 6935 switch fieldNum { 6936 case 1: 6937 if wireType != 2 { 6938 return fmt.Errorf("proto: wrong wireType = %d for field Metrics", wireType) 6939 } 6940 var msglen int 6941 for shift := uint(0); ; shift += 7 { 6942 if shift >= 64 { 6943 return ErrIntOverflowTasks 6944 } 6945 if iNdEx >= l { 6946 return io.ErrUnexpectedEOF 6947 } 6948 b := dAtA[iNdEx] 6949 iNdEx++ 6950 msglen |= int(b&0x7F) << shift 6951 if b < 0x80 { 6952 break 6953 } 6954 } 6955 if msglen < 0 { 6956 return ErrInvalidLengthTasks 6957 } 6958 postIndex := iNdEx + msglen 6959 if postIndex < 0 { 6960 return ErrInvalidLengthTasks 6961 } 6962 if postIndex > l { 6963 return io.ErrUnexpectedEOF 6964 } 6965 m.Metrics = append(m.Metrics, &types.Metric{}) 6966 if err := m.Metrics[len(m.Metrics)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 6967 return err 6968 } 6969 iNdEx = postIndex 6970 default: 6971 iNdEx = preIndex 6972 skippy, err := skipTasks(dAtA[iNdEx:]) 6973 if err != nil { 6974 return err 6975 } 6976 if (skippy < 0) || (iNdEx+skippy) < 0 { 6977 return ErrInvalidLengthTasks 6978 } 6979 if (iNdEx + skippy) > l { 6980 return io.ErrUnexpectedEOF 6981 } 6982 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 6983 iNdEx += skippy 6984 } 6985 } 6986 6987 if iNdEx > l { 6988 return io.ErrUnexpectedEOF 6989 } 6990 return nil 6991} 6992func (m *WaitRequest) Unmarshal(dAtA []byte) error { 6993 l := len(dAtA) 6994 iNdEx := 0 6995 for iNdEx < l { 6996 preIndex := iNdEx 6997 var wire uint64 6998 for shift := uint(0); ; shift += 7 { 6999 if shift >= 64 { 7000 return ErrIntOverflowTasks 7001 } 7002 if iNdEx >= l { 7003 return io.ErrUnexpectedEOF 7004 } 7005 b := dAtA[iNdEx] 7006 iNdEx++ 7007 wire |= uint64(b&0x7F) << shift 7008 if b < 0x80 { 7009 break 7010 } 7011 } 7012 fieldNum := int32(wire >> 3) 7013 wireType := int(wire & 0x7) 7014 if wireType == 4 { 7015 return fmt.Errorf("proto: WaitRequest: wiretype end group for non-group") 7016 } 7017 if fieldNum <= 0 { 7018 return fmt.Errorf("proto: WaitRequest: illegal tag %d (wire type %d)", fieldNum, wire) 7019 } 7020 switch fieldNum { 7021 case 1: 7022 if wireType != 2 { 7023 return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) 7024 } 7025 var stringLen uint64 7026 for shift := uint(0); ; shift += 7 { 7027 if shift >= 64 { 7028 return ErrIntOverflowTasks 7029 } 7030 if iNdEx >= l { 7031 return io.ErrUnexpectedEOF 7032 } 7033 b := dAtA[iNdEx] 7034 iNdEx++ 7035 stringLen |= uint64(b&0x7F) << shift 7036 if b < 0x80 { 7037 break 7038 } 7039 } 7040 intStringLen := int(stringLen) 7041 if intStringLen < 0 { 7042 return ErrInvalidLengthTasks 7043 } 7044 postIndex := iNdEx + intStringLen 7045 if postIndex < 0 { 7046 return ErrInvalidLengthTasks 7047 } 7048 if postIndex > l { 7049 return io.ErrUnexpectedEOF 7050 } 7051 m.ContainerID = string(dAtA[iNdEx:postIndex]) 7052 iNdEx = postIndex 7053 case 2: 7054 if wireType != 2 { 7055 return fmt.Errorf("proto: wrong wireType = %d for field ExecID", wireType) 7056 } 7057 var stringLen uint64 7058 for shift := uint(0); ; shift += 7 { 7059 if shift >= 64 { 7060 return ErrIntOverflowTasks 7061 } 7062 if iNdEx >= l { 7063 return io.ErrUnexpectedEOF 7064 } 7065 b := dAtA[iNdEx] 7066 iNdEx++ 7067 stringLen |= uint64(b&0x7F) << shift 7068 if b < 0x80 { 7069 break 7070 } 7071 } 7072 intStringLen := int(stringLen) 7073 if intStringLen < 0 { 7074 return ErrInvalidLengthTasks 7075 } 7076 postIndex := iNdEx + intStringLen 7077 if postIndex < 0 { 7078 return ErrInvalidLengthTasks 7079 } 7080 if postIndex > l { 7081 return io.ErrUnexpectedEOF 7082 } 7083 m.ExecID = string(dAtA[iNdEx:postIndex]) 7084 iNdEx = postIndex 7085 default: 7086 iNdEx = preIndex 7087 skippy, err := skipTasks(dAtA[iNdEx:]) 7088 if err != nil { 7089 return err 7090 } 7091 if (skippy < 0) || (iNdEx+skippy) < 0 { 7092 return ErrInvalidLengthTasks 7093 } 7094 if (iNdEx + skippy) > l { 7095 return io.ErrUnexpectedEOF 7096 } 7097 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 7098 iNdEx += skippy 7099 } 7100 } 7101 7102 if iNdEx > l { 7103 return io.ErrUnexpectedEOF 7104 } 7105 return nil 7106} 7107func (m *WaitResponse) Unmarshal(dAtA []byte) error { 7108 l := len(dAtA) 7109 iNdEx := 0 7110 for iNdEx < l { 7111 preIndex := iNdEx 7112 var wire uint64 7113 for shift := uint(0); ; shift += 7 { 7114 if shift >= 64 { 7115 return ErrIntOverflowTasks 7116 } 7117 if iNdEx >= l { 7118 return io.ErrUnexpectedEOF 7119 } 7120 b := dAtA[iNdEx] 7121 iNdEx++ 7122 wire |= uint64(b&0x7F) << shift 7123 if b < 0x80 { 7124 break 7125 } 7126 } 7127 fieldNum := int32(wire >> 3) 7128 wireType := int(wire & 0x7) 7129 if wireType == 4 { 7130 return fmt.Errorf("proto: WaitResponse: wiretype end group for non-group") 7131 } 7132 if fieldNum <= 0 { 7133 return fmt.Errorf("proto: WaitResponse: illegal tag %d (wire type %d)", fieldNum, wire) 7134 } 7135 switch fieldNum { 7136 case 1: 7137 if wireType != 0 { 7138 return fmt.Errorf("proto: wrong wireType = %d for field ExitStatus", wireType) 7139 } 7140 m.ExitStatus = 0 7141 for shift := uint(0); ; shift += 7 { 7142 if shift >= 64 { 7143 return ErrIntOverflowTasks 7144 } 7145 if iNdEx >= l { 7146 return io.ErrUnexpectedEOF 7147 } 7148 b := dAtA[iNdEx] 7149 iNdEx++ 7150 m.ExitStatus |= uint32(b&0x7F) << shift 7151 if b < 0x80 { 7152 break 7153 } 7154 } 7155 case 2: 7156 if wireType != 2 { 7157 return fmt.Errorf("proto: wrong wireType = %d for field ExitedAt", wireType) 7158 } 7159 var msglen int 7160 for shift := uint(0); ; shift += 7 { 7161 if shift >= 64 { 7162 return ErrIntOverflowTasks 7163 } 7164 if iNdEx >= l { 7165 return io.ErrUnexpectedEOF 7166 } 7167 b := dAtA[iNdEx] 7168 iNdEx++ 7169 msglen |= int(b&0x7F) << shift 7170 if b < 0x80 { 7171 break 7172 } 7173 } 7174 if msglen < 0 { 7175 return ErrInvalidLengthTasks 7176 } 7177 postIndex := iNdEx + msglen 7178 if postIndex < 0 { 7179 return ErrInvalidLengthTasks 7180 } 7181 if postIndex > l { 7182 return io.ErrUnexpectedEOF 7183 } 7184 if err := github_com_gogo_protobuf_types.StdTimeUnmarshal(&m.ExitedAt, dAtA[iNdEx:postIndex]); err != nil { 7185 return err 7186 } 7187 iNdEx = postIndex 7188 default: 7189 iNdEx = preIndex 7190 skippy, err := skipTasks(dAtA[iNdEx:]) 7191 if err != nil { 7192 return err 7193 } 7194 if (skippy < 0) || (iNdEx+skippy) < 0 { 7195 return ErrInvalidLengthTasks 7196 } 7197 if (iNdEx + skippy) > l { 7198 return io.ErrUnexpectedEOF 7199 } 7200 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 7201 iNdEx += skippy 7202 } 7203 } 7204 7205 if iNdEx > l { 7206 return io.ErrUnexpectedEOF 7207 } 7208 return nil 7209} 7210func skipTasks(dAtA []byte) (n int, err error) { 7211 l := len(dAtA) 7212 iNdEx := 0 7213 depth := 0 7214 for iNdEx < l { 7215 var wire uint64 7216 for shift := uint(0); ; shift += 7 { 7217 if shift >= 64 { 7218 return 0, ErrIntOverflowTasks 7219 } 7220 if iNdEx >= l { 7221 return 0, io.ErrUnexpectedEOF 7222 } 7223 b := dAtA[iNdEx] 7224 iNdEx++ 7225 wire |= (uint64(b) & 0x7F) << shift 7226 if b < 0x80 { 7227 break 7228 } 7229 } 7230 wireType := int(wire & 0x7) 7231 switch wireType { 7232 case 0: 7233 for shift := uint(0); ; shift += 7 { 7234 if shift >= 64 { 7235 return 0, ErrIntOverflowTasks 7236 } 7237 if iNdEx >= l { 7238 return 0, io.ErrUnexpectedEOF 7239 } 7240 iNdEx++ 7241 if dAtA[iNdEx-1] < 0x80 { 7242 break 7243 } 7244 } 7245 case 1: 7246 iNdEx += 8 7247 case 2: 7248 var length int 7249 for shift := uint(0); ; shift += 7 { 7250 if shift >= 64 { 7251 return 0, ErrIntOverflowTasks 7252 } 7253 if iNdEx >= l { 7254 return 0, io.ErrUnexpectedEOF 7255 } 7256 b := dAtA[iNdEx] 7257 iNdEx++ 7258 length |= (int(b) & 0x7F) << shift 7259 if b < 0x80 { 7260 break 7261 } 7262 } 7263 if length < 0 { 7264 return 0, ErrInvalidLengthTasks 7265 } 7266 iNdEx += length 7267 case 3: 7268 depth++ 7269 case 4: 7270 if depth == 0 { 7271 return 0, ErrUnexpectedEndOfGroupTasks 7272 } 7273 depth-- 7274 case 5: 7275 iNdEx += 4 7276 default: 7277 return 0, fmt.Errorf("proto: illegal wireType %d", wireType) 7278 } 7279 if iNdEx < 0 { 7280 return 0, ErrInvalidLengthTasks 7281 } 7282 if depth == 0 { 7283 return iNdEx, nil 7284 } 7285 } 7286 return 0, io.ErrUnexpectedEOF 7287} 7288 7289var ( 7290 ErrInvalidLengthTasks = fmt.Errorf("proto: negative length found during unmarshaling") 7291 ErrIntOverflowTasks = fmt.Errorf("proto: integer overflow") 7292 ErrUnexpectedEndOfGroupTasks = fmt.Errorf("proto: unexpected end of group") 7293) 7294