1// Code generated by protoc-gen-gogo. DO NOT EDIT. 2// source: github.com/containerd/containerd/runtime/v1/shim/v1/shim.proto 3 4package shim 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 github_com_containerd_ttrpc "github.com/containerd/ttrpc" 12 proto "github.com/gogo/protobuf/proto" 13 github_com_gogo_protobuf_types "github.com/gogo/protobuf/types" 14 types1 "github.com/gogo/protobuf/types" 15 io "io" 16 math "math" 17 math_bits "math/bits" 18 reflect "reflect" 19 strings "strings" 20 time "time" 21) 22 23// Reference imports to suppress errors if they are not otherwise used. 24var _ = proto.Marshal 25var _ = fmt.Errorf 26var _ = math.Inf 27var _ = time.Kitchen 28 29// This is a compile-time assertion to ensure that this generated file 30// is compatible with the proto package it is being compiled against. 31// A compilation error at this line likely means your copy of the 32// proto package needs to be updated. 33const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package 34 35type CreateTaskRequest struct { 36 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 37 Bundle string `protobuf:"bytes,2,opt,name=bundle,proto3" json:"bundle,omitempty"` 38 Runtime string `protobuf:"bytes,3,opt,name=runtime,proto3" json:"runtime,omitempty"` 39 Rootfs []*types.Mount `protobuf:"bytes,4,rep,name=rootfs,proto3" json:"rootfs,omitempty"` 40 Terminal bool `protobuf:"varint,5,opt,name=terminal,proto3" json:"terminal,omitempty"` 41 Stdin string `protobuf:"bytes,6,opt,name=stdin,proto3" json:"stdin,omitempty"` 42 Stdout string `protobuf:"bytes,7,opt,name=stdout,proto3" json:"stdout,omitempty"` 43 Stderr string `protobuf:"bytes,8,opt,name=stderr,proto3" json:"stderr,omitempty"` 44 Checkpoint string `protobuf:"bytes,9,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"` 45 ParentCheckpoint string `protobuf:"bytes,10,opt,name=parent_checkpoint,json=parentCheckpoint,proto3" json:"parent_checkpoint,omitempty"` 46 Options *types1.Any `protobuf:"bytes,11,opt,name=options,proto3" json:"options,omitempty"` 47 XXX_NoUnkeyedLiteral struct{} `json:"-"` 48 XXX_unrecognized []byte `json:"-"` 49 XXX_sizecache int32 `json:"-"` 50} 51 52func (m *CreateTaskRequest) Reset() { *m = CreateTaskRequest{} } 53func (*CreateTaskRequest) ProtoMessage() {} 54func (*CreateTaskRequest) Descriptor() ([]byte, []int) { 55 return fileDescriptor_be1b2ef30ea3b8ef, []int{0} 56} 57func (m *CreateTaskRequest) XXX_Unmarshal(b []byte) error { 58 return m.Unmarshal(b) 59} 60func (m *CreateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 61 if deterministic { 62 return xxx_messageInfo_CreateTaskRequest.Marshal(b, m, deterministic) 63 } else { 64 b = b[:cap(b)] 65 n, err := m.MarshalToSizedBuffer(b) 66 if err != nil { 67 return nil, err 68 } 69 return b[:n], nil 70 } 71} 72func (m *CreateTaskRequest) XXX_Merge(src proto.Message) { 73 xxx_messageInfo_CreateTaskRequest.Merge(m, src) 74} 75func (m *CreateTaskRequest) XXX_Size() int { 76 return m.Size() 77} 78func (m *CreateTaskRequest) XXX_DiscardUnknown() { 79 xxx_messageInfo_CreateTaskRequest.DiscardUnknown(m) 80} 81 82var xxx_messageInfo_CreateTaskRequest proto.InternalMessageInfo 83 84type CreateTaskResponse struct { 85 Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` 86 XXX_NoUnkeyedLiteral struct{} `json:"-"` 87 XXX_unrecognized []byte `json:"-"` 88 XXX_sizecache int32 `json:"-"` 89} 90 91func (m *CreateTaskResponse) Reset() { *m = CreateTaskResponse{} } 92func (*CreateTaskResponse) ProtoMessage() {} 93func (*CreateTaskResponse) Descriptor() ([]byte, []int) { 94 return fileDescriptor_be1b2ef30ea3b8ef, []int{1} 95} 96func (m *CreateTaskResponse) XXX_Unmarshal(b []byte) error { 97 return m.Unmarshal(b) 98} 99func (m *CreateTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 100 if deterministic { 101 return xxx_messageInfo_CreateTaskResponse.Marshal(b, m, deterministic) 102 } else { 103 b = b[:cap(b)] 104 n, err := m.MarshalToSizedBuffer(b) 105 if err != nil { 106 return nil, err 107 } 108 return b[:n], nil 109 } 110} 111func (m *CreateTaskResponse) XXX_Merge(src proto.Message) { 112 xxx_messageInfo_CreateTaskResponse.Merge(m, src) 113} 114func (m *CreateTaskResponse) XXX_Size() int { 115 return m.Size() 116} 117func (m *CreateTaskResponse) XXX_DiscardUnknown() { 118 xxx_messageInfo_CreateTaskResponse.DiscardUnknown(m) 119} 120 121var xxx_messageInfo_CreateTaskResponse proto.InternalMessageInfo 122 123type DeleteResponse struct { 124 Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` 125 ExitStatus uint32 `protobuf:"varint,2,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"` 126 ExitedAt time.Time `protobuf:"bytes,3,opt,name=exited_at,json=exitedAt,proto3,stdtime" json:"exited_at"` 127 XXX_NoUnkeyedLiteral struct{} `json:"-"` 128 XXX_unrecognized []byte `json:"-"` 129 XXX_sizecache int32 `json:"-"` 130} 131 132func (m *DeleteResponse) Reset() { *m = DeleteResponse{} } 133func (*DeleteResponse) ProtoMessage() {} 134func (*DeleteResponse) Descriptor() ([]byte, []int) { 135 return fileDescriptor_be1b2ef30ea3b8ef, []int{2} 136} 137func (m *DeleteResponse) XXX_Unmarshal(b []byte) error { 138 return m.Unmarshal(b) 139} 140func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 141 if deterministic { 142 return xxx_messageInfo_DeleteResponse.Marshal(b, m, deterministic) 143 } else { 144 b = b[:cap(b)] 145 n, err := m.MarshalToSizedBuffer(b) 146 if err != nil { 147 return nil, err 148 } 149 return b[:n], nil 150 } 151} 152func (m *DeleteResponse) XXX_Merge(src proto.Message) { 153 xxx_messageInfo_DeleteResponse.Merge(m, src) 154} 155func (m *DeleteResponse) XXX_Size() int { 156 return m.Size() 157} 158func (m *DeleteResponse) XXX_DiscardUnknown() { 159 xxx_messageInfo_DeleteResponse.DiscardUnknown(m) 160} 161 162var xxx_messageInfo_DeleteResponse proto.InternalMessageInfo 163 164type DeleteProcessRequest struct { 165 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 166 XXX_NoUnkeyedLiteral struct{} `json:"-"` 167 XXX_unrecognized []byte `json:"-"` 168 XXX_sizecache int32 `json:"-"` 169} 170 171func (m *DeleteProcessRequest) Reset() { *m = DeleteProcessRequest{} } 172func (*DeleteProcessRequest) ProtoMessage() {} 173func (*DeleteProcessRequest) Descriptor() ([]byte, []int) { 174 return fileDescriptor_be1b2ef30ea3b8ef, []int{3} 175} 176func (m *DeleteProcessRequest) XXX_Unmarshal(b []byte) error { 177 return m.Unmarshal(b) 178} 179func (m *DeleteProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 180 if deterministic { 181 return xxx_messageInfo_DeleteProcessRequest.Marshal(b, m, deterministic) 182 } else { 183 b = b[:cap(b)] 184 n, err := m.MarshalToSizedBuffer(b) 185 if err != nil { 186 return nil, err 187 } 188 return b[:n], nil 189 } 190} 191func (m *DeleteProcessRequest) XXX_Merge(src proto.Message) { 192 xxx_messageInfo_DeleteProcessRequest.Merge(m, src) 193} 194func (m *DeleteProcessRequest) XXX_Size() int { 195 return m.Size() 196} 197func (m *DeleteProcessRequest) XXX_DiscardUnknown() { 198 xxx_messageInfo_DeleteProcessRequest.DiscardUnknown(m) 199} 200 201var xxx_messageInfo_DeleteProcessRequest proto.InternalMessageInfo 202 203type ExecProcessRequest struct { 204 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 205 Terminal bool `protobuf:"varint,2,opt,name=terminal,proto3" json:"terminal,omitempty"` 206 Stdin string `protobuf:"bytes,3,opt,name=stdin,proto3" json:"stdin,omitempty"` 207 Stdout string `protobuf:"bytes,4,opt,name=stdout,proto3" json:"stdout,omitempty"` 208 Stderr string `protobuf:"bytes,5,opt,name=stderr,proto3" json:"stderr,omitempty"` 209 Spec *types1.Any `protobuf:"bytes,6,opt,name=spec,proto3" json:"spec,omitempty"` 210 XXX_NoUnkeyedLiteral struct{} `json:"-"` 211 XXX_unrecognized []byte `json:"-"` 212 XXX_sizecache int32 `json:"-"` 213} 214 215func (m *ExecProcessRequest) Reset() { *m = ExecProcessRequest{} } 216func (*ExecProcessRequest) ProtoMessage() {} 217func (*ExecProcessRequest) Descriptor() ([]byte, []int) { 218 return fileDescriptor_be1b2ef30ea3b8ef, []int{4} 219} 220func (m *ExecProcessRequest) XXX_Unmarshal(b []byte) error { 221 return m.Unmarshal(b) 222} 223func (m *ExecProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 224 if deterministic { 225 return xxx_messageInfo_ExecProcessRequest.Marshal(b, m, deterministic) 226 } else { 227 b = b[:cap(b)] 228 n, err := m.MarshalToSizedBuffer(b) 229 if err != nil { 230 return nil, err 231 } 232 return b[:n], nil 233 } 234} 235func (m *ExecProcessRequest) XXX_Merge(src proto.Message) { 236 xxx_messageInfo_ExecProcessRequest.Merge(m, src) 237} 238func (m *ExecProcessRequest) XXX_Size() int { 239 return m.Size() 240} 241func (m *ExecProcessRequest) XXX_DiscardUnknown() { 242 xxx_messageInfo_ExecProcessRequest.DiscardUnknown(m) 243} 244 245var xxx_messageInfo_ExecProcessRequest proto.InternalMessageInfo 246 247type ExecProcessResponse struct { 248 XXX_NoUnkeyedLiteral struct{} `json:"-"` 249 XXX_unrecognized []byte `json:"-"` 250 XXX_sizecache int32 `json:"-"` 251} 252 253func (m *ExecProcessResponse) Reset() { *m = ExecProcessResponse{} } 254func (*ExecProcessResponse) ProtoMessage() {} 255func (*ExecProcessResponse) Descriptor() ([]byte, []int) { 256 return fileDescriptor_be1b2ef30ea3b8ef, []int{5} 257} 258func (m *ExecProcessResponse) XXX_Unmarshal(b []byte) error { 259 return m.Unmarshal(b) 260} 261func (m *ExecProcessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 262 if deterministic { 263 return xxx_messageInfo_ExecProcessResponse.Marshal(b, m, deterministic) 264 } else { 265 b = b[:cap(b)] 266 n, err := m.MarshalToSizedBuffer(b) 267 if err != nil { 268 return nil, err 269 } 270 return b[:n], nil 271 } 272} 273func (m *ExecProcessResponse) XXX_Merge(src proto.Message) { 274 xxx_messageInfo_ExecProcessResponse.Merge(m, src) 275} 276func (m *ExecProcessResponse) XXX_Size() int { 277 return m.Size() 278} 279func (m *ExecProcessResponse) XXX_DiscardUnknown() { 280 xxx_messageInfo_ExecProcessResponse.DiscardUnknown(m) 281} 282 283var xxx_messageInfo_ExecProcessResponse proto.InternalMessageInfo 284 285type ResizePtyRequest struct { 286 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 287 Width uint32 `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty"` 288 Height uint32 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"` 289 XXX_NoUnkeyedLiteral struct{} `json:"-"` 290 XXX_unrecognized []byte `json:"-"` 291 XXX_sizecache int32 `json:"-"` 292} 293 294func (m *ResizePtyRequest) Reset() { *m = ResizePtyRequest{} } 295func (*ResizePtyRequest) ProtoMessage() {} 296func (*ResizePtyRequest) Descriptor() ([]byte, []int) { 297 return fileDescriptor_be1b2ef30ea3b8ef, []int{6} 298} 299func (m *ResizePtyRequest) XXX_Unmarshal(b []byte) error { 300 return m.Unmarshal(b) 301} 302func (m *ResizePtyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 303 if deterministic { 304 return xxx_messageInfo_ResizePtyRequest.Marshal(b, m, deterministic) 305 } else { 306 b = b[:cap(b)] 307 n, err := m.MarshalToSizedBuffer(b) 308 if err != nil { 309 return nil, err 310 } 311 return b[:n], nil 312 } 313} 314func (m *ResizePtyRequest) XXX_Merge(src proto.Message) { 315 xxx_messageInfo_ResizePtyRequest.Merge(m, src) 316} 317func (m *ResizePtyRequest) XXX_Size() int { 318 return m.Size() 319} 320func (m *ResizePtyRequest) XXX_DiscardUnknown() { 321 xxx_messageInfo_ResizePtyRequest.DiscardUnknown(m) 322} 323 324var xxx_messageInfo_ResizePtyRequest proto.InternalMessageInfo 325 326type StateRequest struct { 327 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 328 XXX_NoUnkeyedLiteral struct{} `json:"-"` 329 XXX_unrecognized []byte `json:"-"` 330 XXX_sizecache int32 `json:"-"` 331} 332 333func (m *StateRequest) Reset() { *m = StateRequest{} } 334func (*StateRequest) ProtoMessage() {} 335func (*StateRequest) Descriptor() ([]byte, []int) { 336 return fileDescriptor_be1b2ef30ea3b8ef, []int{7} 337} 338func (m *StateRequest) XXX_Unmarshal(b []byte) error { 339 return m.Unmarshal(b) 340} 341func (m *StateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 342 if deterministic { 343 return xxx_messageInfo_StateRequest.Marshal(b, m, deterministic) 344 } else { 345 b = b[:cap(b)] 346 n, err := m.MarshalToSizedBuffer(b) 347 if err != nil { 348 return nil, err 349 } 350 return b[:n], nil 351 } 352} 353func (m *StateRequest) XXX_Merge(src proto.Message) { 354 xxx_messageInfo_StateRequest.Merge(m, src) 355} 356func (m *StateRequest) XXX_Size() int { 357 return m.Size() 358} 359func (m *StateRequest) XXX_DiscardUnknown() { 360 xxx_messageInfo_StateRequest.DiscardUnknown(m) 361} 362 363var xxx_messageInfo_StateRequest proto.InternalMessageInfo 364 365type StateResponse struct { 366 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 367 Bundle string `protobuf:"bytes,2,opt,name=bundle,proto3" json:"bundle,omitempty"` 368 Pid uint32 `protobuf:"varint,3,opt,name=pid,proto3" json:"pid,omitempty"` 369 Status task.Status `protobuf:"varint,4,opt,name=status,proto3,enum=containerd.v1.types.Status" json:"status,omitempty"` 370 Stdin string `protobuf:"bytes,5,opt,name=stdin,proto3" json:"stdin,omitempty"` 371 Stdout string `protobuf:"bytes,6,opt,name=stdout,proto3" json:"stdout,omitempty"` 372 Stderr string `protobuf:"bytes,7,opt,name=stderr,proto3" json:"stderr,omitempty"` 373 Terminal bool `protobuf:"varint,8,opt,name=terminal,proto3" json:"terminal,omitempty"` 374 ExitStatus uint32 `protobuf:"varint,9,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"` 375 ExitedAt time.Time `protobuf:"bytes,10,opt,name=exited_at,json=exitedAt,proto3,stdtime" json:"exited_at"` 376 XXX_NoUnkeyedLiteral struct{} `json:"-"` 377 XXX_unrecognized []byte `json:"-"` 378 XXX_sizecache int32 `json:"-"` 379} 380 381func (m *StateResponse) Reset() { *m = StateResponse{} } 382func (*StateResponse) ProtoMessage() {} 383func (*StateResponse) Descriptor() ([]byte, []int) { 384 return fileDescriptor_be1b2ef30ea3b8ef, []int{8} 385} 386func (m *StateResponse) XXX_Unmarshal(b []byte) error { 387 return m.Unmarshal(b) 388} 389func (m *StateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 390 if deterministic { 391 return xxx_messageInfo_StateResponse.Marshal(b, m, deterministic) 392 } else { 393 b = b[:cap(b)] 394 n, err := m.MarshalToSizedBuffer(b) 395 if err != nil { 396 return nil, err 397 } 398 return b[:n], nil 399 } 400} 401func (m *StateResponse) XXX_Merge(src proto.Message) { 402 xxx_messageInfo_StateResponse.Merge(m, src) 403} 404func (m *StateResponse) XXX_Size() int { 405 return m.Size() 406} 407func (m *StateResponse) XXX_DiscardUnknown() { 408 xxx_messageInfo_StateResponse.DiscardUnknown(m) 409} 410 411var xxx_messageInfo_StateResponse proto.InternalMessageInfo 412 413type KillRequest struct { 414 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 415 Signal uint32 `protobuf:"varint,2,opt,name=signal,proto3" json:"signal,omitempty"` 416 All bool `protobuf:"varint,3,opt,name=all,proto3" json:"all,omitempty"` 417 XXX_NoUnkeyedLiteral struct{} `json:"-"` 418 XXX_unrecognized []byte `json:"-"` 419 XXX_sizecache int32 `json:"-"` 420} 421 422func (m *KillRequest) Reset() { *m = KillRequest{} } 423func (*KillRequest) ProtoMessage() {} 424func (*KillRequest) Descriptor() ([]byte, []int) { 425 return fileDescriptor_be1b2ef30ea3b8ef, []int{9} 426} 427func (m *KillRequest) XXX_Unmarshal(b []byte) error { 428 return m.Unmarshal(b) 429} 430func (m *KillRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 431 if deterministic { 432 return xxx_messageInfo_KillRequest.Marshal(b, m, deterministic) 433 } else { 434 b = b[:cap(b)] 435 n, err := m.MarshalToSizedBuffer(b) 436 if err != nil { 437 return nil, err 438 } 439 return b[:n], nil 440 } 441} 442func (m *KillRequest) XXX_Merge(src proto.Message) { 443 xxx_messageInfo_KillRequest.Merge(m, src) 444} 445func (m *KillRequest) XXX_Size() int { 446 return m.Size() 447} 448func (m *KillRequest) XXX_DiscardUnknown() { 449 xxx_messageInfo_KillRequest.DiscardUnknown(m) 450} 451 452var xxx_messageInfo_KillRequest proto.InternalMessageInfo 453 454type CloseIORequest struct { 455 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 456 Stdin bool `protobuf:"varint,2,opt,name=stdin,proto3" json:"stdin,omitempty"` 457 XXX_NoUnkeyedLiteral struct{} `json:"-"` 458 XXX_unrecognized []byte `json:"-"` 459 XXX_sizecache int32 `json:"-"` 460} 461 462func (m *CloseIORequest) Reset() { *m = CloseIORequest{} } 463func (*CloseIORequest) ProtoMessage() {} 464func (*CloseIORequest) Descriptor() ([]byte, []int) { 465 return fileDescriptor_be1b2ef30ea3b8ef, []int{10} 466} 467func (m *CloseIORequest) XXX_Unmarshal(b []byte) error { 468 return m.Unmarshal(b) 469} 470func (m *CloseIORequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 471 if deterministic { 472 return xxx_messageInfo_CloseIORequest.Marshal(b, m, deterministic) 473 } else { 474 b = b[:cap(b)] 475 n, err := m.MarshalToSizedBuffer(b) 476 if err != nil { 477 return nil, err 478 } 479 return b[:n], nil 480 } 481} 482func (m *CloseIORequest) XXX_Merge(src proto.Message) { 483 xxx_messageInfo_CloseIORequest.Merge(m, src) 484} 485func (m *CloseIORequest) XXX_Size() int { 486 return m.Size() 487} 488func (m *CloseIORequest) XXX_DiscardUnknown() { 489 xxx_messageInfo_CloseIORequest.DiscardUnknown(m) 490} 491 492var xxx_messageInfo_CloseIORequest proto.InternalMessageInfo 493 494type ListPidsRequest struct { 495 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 496 XXX_NoUnkeyedLiteral struct{} `json:"-"` 497 XXX_unrecognized []byte `json:"-"` 498 XXX_sizecache int32 `json:"-"` 499} 500 501func (m *ListPidsRequest) Reset() { *m = ListPidsRequest{} } 502func (*ListPidsRequest) ProtoMessage() {} 503func (*ListPidsRequest) Descriptor() ([]byte, []int) { 504 return fileDescriptor_be1b2ef30ea3b8ef, []int{11} 505} 506func (m *ListPidsRequest) XXX_Unmarshal(b []byte) error { 507 return m.Unmarshal(b) 508} 509func (m *ListPidsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 510 if deterministic { 511 return xxx_messageInfo_ListPidsRequest.Marshal(b, m, deterministic) 512 } else { 513 b = b[:cap(b)] 514 n, err := m.MarshalToSizedBuffer(b) 515 if err != nil { 516 return nil, err 517 } 518 return b[:n], nil 519 } 520} 521func (m *ListPidsRequest) XXX_Merge(src proto.Message) { 522 xxx_messageInfo_ListPidsRequest.Merge(m, src) 523} 524func (m *ListPidsRequest) XXX_Size() int { 525 return m.Size() 526} 527func (m *ListPidsRequest) XXX_DiscardUnknown() { 528 xxx_messageInfo_ListPidsRequest.DiscardUnknown(m) 529} 530 531var xxx_messageInfo_ListPidsRequest proto.InternalMessageInfo 532 533type ListPidsResponse struct { 534 Processes []*task.ProcessInfo `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"` 535 XXX_NoUnkeyedLiteral struct{} `json:"-"` 536 XXX_unrecognized []byte `json:"-"` 537 XXX_sizecache int32 `json:"-"` 538} 539 540func (m *ListPidsResponse) Reset() { *m = ListPidsResponse{} } 541func (*ListPidsResponse) ProtoMessage() {} 542func (*ListPidsResponse) Descriptor() ([]byte, []int) { 543 return fileDescriptor_be1b2ef30ea3b8ef, []int{12} 544} 545func (m *ListPidsResponse) XXX_Unmarshal(b []byte) error { 546 return m.Unmarshal(b) 547} 548func (m *ListPidsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 549 if deterministic { 550 return xxx_messageInfo_ListPidsResponse.Marshal(b, m, deterministic) 551 } else { 552 b = b[:cap(b)] 553 n, err := m.MarshalToSizedBuffer(b) 554 if err != nil { 555 return nil, err 556 } 557 return b[:n], nil 558 } 559} 560func (m *ListPidsResponse) XXX_Merge(src proto.Message) { 561 xxx_messageInfo_ListPidsResponse.Merge(m, src) 562} 563func (m *ListPidsResponse) XXX_Size() int { 564 return m.Size() 565} 566func (m *ListPidsResponse) XXX_DiscardUnknown() { 567 xxx_messageInfo_ListPidsResponse.DiscardUnknown(m) 568} 569 570var xxx_messageInfo_ListPidsResponse proto.InternalMessageInfo 571 572type CheckpointTaskRequest struct { 573 Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` 574 Options *types1.Any `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` 575 XXX_NoUnkeyedLiteral struct{} `json:"-"` 576 XXX_unrecognized []byte `json:"-"` 577 XXX_sizecache int32 `json:"-"` 578} 579 580func (m *CheckpointTaskRequest) Reset() { *m = CheckpointTaskRequest{} } 581func (*CheckpointTaskRequest) ProtoMessage() {} 582func (*CheckpointTaskRequest) Descriptor() ([]byte, []int) { 583 return fileDescriptor_be1b2ef30ea3b8ef, []int{13} 584} 585func (m *CheckpointTaskRequest) XXX_Unmarshal(b []byte) error { 586 return m.Unmarshal(b) 587} 588func (m *CheckpointTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 589 if deterministic { 590 return xxx_messageInfo_CheckpointTaskRequest.Marshal(b, m, deterministic) 591 } else { 592 b = b[:cap(b)] 593 n, err := m.MarshalToSizedBuffer(b) 594 if err != nil { 595 return nil, err 596 } 597 return b[:n], nil 598 } 599} 600func (m *CheckpointTaskRequest) XXX_Merge(src proto.Message) { 601 xxx_messageInfo_CheckpointTaskRequest.Merge(m, src) 602} 603func (m *CheckpointTaskRequest) XXX_Size() int { 604 return m.Size() 605} 606func (m *CheckpointTaskRequest) XXX_DiscardUnknown() { 607 xxx_messageInfo_CheckpointTaskRequest.DiscardUnknown(m) 608} 609 610var xxx_messageInfo_CheckpointTaskRequest proto.InternalMessageInfo 611 612type ShimInfoResponse struct { 613 ShimPid uint32 `protobuf:"varint,1,opt,name=shim_pid,json=shimPid,proto3" json:"shim_pid,omitempty"` 614 XXX_NoUnkeyedLiteral struct{} `json:"-"` 615 XXX_unrecognized []byte `json:"-"` 616 XXX_sizecache int32 `json:"-"` 617} 618 619func (m *ShimInfoResponse) Reset() { *m = ShimInfoResponse{} } 620func (*ShimInfoResponse) ProtoMessage() {} 621func (*ShimInfoResponse) Descriptor() ([]byte, []int) { 622 return fileDescriptor_be1b2ef30ea3b8ef, []int{14} 623} 624func (m *ShimInfoResponse) XXX_Unmarshal(b []byte) error { 625 return m.Unmarshal(b) 626} 627func (m *ShimInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 628 if deterministic { 629 return xxx_messageInfo_ShimInfoResponse.Marshal(b, m, deterministic) 630 } else { 631 b = b[:cap(b)] 632 n, err := m.MarshalToSizedBuffer(b) 633 if err != nil { 634 return nil, err 635 } 636 return b[:n], nil 637 } 638} 639func (m *ShimInfoResponse) XXX_Merge(src proto.Message) { 640 xxx_messageInfo_ShimInfoResponse.Merge(m, src) 641} 642func (m *ShimInfoResponse) XXX_Size() int { 643 return m.Size() 644} 645func (m *ShimInfoResponse) XXX_DiscardUnknown() { 646 xxx_messageInfo_ShimInfoResponse.DiscardUnknown(m) 647} 648 649var xxx_messageInfo_ShimInfoResponse proto.InternalMessageInfo 650 651type UpdateTaskRequest struct { 652 Resources *types1.Any `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources,omitempty"` 653 XXX_NoUnkeyedLiteral struct{} `json:"-"` 654 XXX_unrecognized []byte `json:"-"` 655 XXX_sizecache int32 `json:"-"` 656} 657 658func (m *UpdateTaskRequest) Reset() { *m = UpdateTaskRequest{} } 659func (*UpdateTaskRequest) ProtoMessage() {} 660func (*UpdateTaskRequest) Descriptor() ([]byte, []int) { 661 return fileDescriptor_be1b2ef30ea3b8ef, []int{15} 662} 663func (m *UpdateTaskRequest) XXX_Unmarshal(b []byte) error { 664 return m.Unmarshal(b) 665} 666func (m *UpdateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 667 if deterministic { 668 return xxx_messageInfo_UpdateTaskRequest.Marshal(b, m, deterministic) 669 } else { 670 b = b[:cap(b)] 671 n, err := m.MarshalToSizedBuffer(b) 672 if err != nil { 673 return nil, err 674 } 675 return b[:n], nil 676 } 677} 678func (m *UpdateTaskRequest) XXX_Merge(src proto.Message) { 679 xxx_messageInfo_UpdateTaskRequest.Merge(m, src) 680} 681func (m *UpdateTaskRequest) XXX_Size() int { 682 return m.Size() 683} 684func (m *UpdateTaskRequest) XXX_DiscardUnknown() { 685 xxx_messageInfo_UpdateTaskRequest.DiscardUnknown(m) 686} 687 688var xxx_messageInfo_UpdateTaskRequest proto.InternalMessageInfo 689 690type StartRequest struct { 691 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 692 XXX_NoUnkeyedLiteral struct{} `json:"-"` 693 XXX_unrecognized []byte `json:"-"` 694 XXX_sizecache int32 `json:"-"` 695} 696 697func (m *StartRequest) Reset() { *m = StartRequest{} } 698func (*StartRequest) ProtoMessage() {} 699func (*StartRequest) Descriptor() ([]byte, []int) { 700 return fileDescriptor_be1b2ef30ea3b8ef, []int{16} 701} 702func (m *StartRequest) XXX_Unmarshal(b []byte) error { 703 return m.Unmarshal(b) 704} 705func (m *StartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 706 if deterministic { 707 return xxx_messageInfo_StartRequest.Marshal(b, m, deterministic) 708 } else { 709 b = b[:cap(b)] 710 n, err := m.MarshalToSizedBuffer(b) 711 if err != nil { 712 return nil, err 713 } 714 return b[:n], nil 715 } 716} 717func (m *StartRequest) XXX_Merge(src proto.Message) { 718 xxx_messageInfo_StartRequest.Merge(m, src) 719} 720func (m *StartRequest) XXX_Size() int { 721 return m.Size() 722} 723func (m *StartRequest) XXX_DiscardUnknown() { 724 xxx_messageInfo_StartRequest.DiscardUnknown(m) 725} 726 727var xxx_messageInfo_StartRequest proto.InternalMessageInfo 728 729type StartResponse struct { 730 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 731 Pid uint32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"` 732 XXX_NoUnkeyedLiteral struct{} `json:"-"` 733 XXX_unrecognized []byte `json:"-"` 734 XXX_sizecache int32 `json:"-"` 735} 736 737func (m *StartResponse) Reset() { *m = StartResponse{} } 738func (*StartResponse) ProtoMessage() {} 739func (*StartResponse) Descriptor() ([]byte, []int) { 740 return fileDescriptor_be1b2ef30ea3b8ef, []int{17} 741} 742func (m *StartResponse) XXX_Unmarshal(b []byte) error { 743 return m.Unmarshal(b) 744} 745func (m *StartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 746 if deterministic { 747 return xxx_messageInfo_StartResponse.Marshal(b, m, deterministic) 748 } else { 749 b = b[:cap(b)] 750 n, err := m.MarshalToSizedBuffer(b) 751 if err != nil { 752 return nil, err 753 } 754 return b[:n], nil 755 } 756} 757func (m *StartResponse) XXX_Merge(src proto.Message) { 758 xxx_messageInfo_StartResponse.Merge(m, src) 759} 760func (m *StartResponse) XXX_Size() int { 761 return m.Size() 762} 763func (m *StartResponse) XXX_DiscardUnknown() { 764 xxx_messageInfo_StartResponse.DiscardUnknown(m) 765} 766 767var xxx_messageInfo_StartResponse proto.InternalMessageInfo 768 769type WaitRequest struct { 770 ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 771 XXX_NoUnkeyedLiteral struct{} `json:"-"` 772 XXX_unrecognized []byte `json:"-"` 773 XXX_sizecache int32 `json:"-"` 774} 775 776func (m *WaitRequest) Reset() { *m = WaitRequest{} } 777func (*WaitRequest) ProtoMessage() {} 778func (*WaitRequest) Descriptor() ([]byte, []int) { 779 return fileDescriptor_be1b2ef30ea3b8ef, []int{18} 780} 781func (m *WaitRequest) XXX_Unmarshal(b []byte) error { 782 return m.Unmarshal(b) 783} 784func (m *WaitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 785 if deterministic { 786 return xxx_messageInfo_WaitRequest.Marshal(b, m, deterministic) 787 } else { 788 b = b[:cap(b)] 789 n, err := m.MarshalToSizedBuffer(b) 790 if err != nil { 791 return nil, err 792 } 793 return b[:n], nil 794 } 795} 796func (m *WaitRequest) XXX_Merge(src proto.Message) { 797 xxx_messageInfo_WaitRequest.Merge(m, src) 798} 799func (m *WaitRequest) XXX_Size() int { 800 return m.Size() 801} 802func (m *WaitRequest) XXX_DiscardUnknown() { 803 xxx_messageInfo_WaitRequest.DiscardUnknown(m) 804} 805 806var xxx_messageInfo_WaitRequest proto.InternalMessageInfo 807 808type WaitResponse struct { 809 ExitStatus uint32 `protobuf:"varint,1,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"` 810 ExitedAt time.Time `protobuf:"bytes,2,opt,name=exited_at,json=exitedAt,proto3,stdtime" json:"exited_at"` 811 XXX_NoUnkeyedLiteral struct{} `json:"-"` 812 XXX_unrecognized []byte `json:"-"` 813 XXX_sizecache int32 `json:"-"` 814} 815 816func (m *WaitResponse) Reset() { *m = WaitResponse{} } 817func (*WaitResponse) ProtoMessage() {} 818func (*WaitResponse) Descriptor() ([]byte, []int) { 819 return fileDescriptor_be1b2ef30ea3b8ef, []int{19} 820} 821func (m *WaitResponse) XXX_Unmarshal(b []byte) error { 822 return m.Unmarshal(b) 823} 824func (m *WaitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 825 if deterministic { 826 return xxx_messageInfo_WaitResponse.Marshal(b, m, deterministic) 827 } else { 828 b = b[:cap(b)] 829 n, err := m.MarshalToSizedBuffer(b) 830 if err != nil { 831 return nil, err 832 } 833 return b[:n], nil 834 } 835} 836func (m *WaitResponse) XXX_Merge(src proto.Message) { 837 xxx_messageInfo_WaitResponse.Merge(m, src) 838} 839func (m *WaitResponse) XXX_Size() int { 840 return m.Size() 841} 842func (m *WaitResponse) XXX_DiscardUnknown() { 843 xxx_messageInfo_WaitResponse.DiscardUnknown(m) 844} 845 846var xxx_messageInfo_WaitResponse proto.InternalMessageInfo 847 848func init() { 849 proto.RegisterType((*CreateTaskRequest)(nil), "containerd.runtime.linux.shim.v1.CreateTaskRequest") 850 proto.RegisterType((*CreateTaskResponse)(nil), "containerd.runtime.linux.shim.v1.CreateTaskResponse") 851 proto.RegisterType((*DeleteResponse)(nil), "containerd.runtime.linux.shim.v1.DeleteResponse") 852 proto.RegisterType((*DeleteProcessRequest)(nil), "containerd.runtime.linux.shim.v1.DeleteProcessRequest") 853 proto.RegisterType((*ExecProcessRequest)(nil), "containerd.runtime.linux.shim.v1.ExecProcessRequest") 854 proto.RegisterType((*ExecProcessResponse)(nil), "containerd.runtime.linux.shim.v1.ExecProcessResponse") 855 proto.RegisterType((*ResizePtyRequest)(nil), "containerd.runtime.linux.shim.v1.ResizePtyRequest") 856 proto.RegisterType((*StateRequest)(nil), "containerd.runtime.linux.shim.v1.StateRequest") 857 proto.RegisterType((*StateResponse)(nil), "containerd.runtime.linux.shim.v1.StateResponse") 858 proto.RegisterType((*KillRequest)(nil), "containerd.runtime.linux.shim.v1.KillRequest") 859 proto.RegisterType((*CloseIORequest)(nil), "containerd.runtime.linux.shim.v1.CloseIORequest") 860 proto.RegisterType((*ListPidsRequest)(nil), "containerd.runtime.linux.shim.v1.ListPidsRequest") 861 proto.RegisterType((*ListPidsResponse)(nil), "containerd.runtime.linux.shim.v1.ListPidsResponse") 862 proto.RegisterType((*CheckpointTaskRequest)(nil), "containerd.runtime.linux.shim.v1.CheckpointTaskRequest") 863 proto.RegisterType((*ShimInfoResponse)(nil), "containerd.runtime.linux.shim.v1.ShimInfoResponse") 864 proto.RegisterType((*UpdateTaskRequest)(nil), "containerd.runtime.linux.shim.v1.UpdateTaskRequest") 865 proto.RegisterType((*StartRequest)(nil), "containerd.runtime.linux.shim.v1.StartRequest") 866 proto.RegisterType((*StartResponse)(nil), "containerd.runtime.linux.shim.v1.StartResponse") 867 proto.RegisterType((*WaitRequest)(nil), "containerd.runtime.linux.shim.v1.WaitRequest") 868 proto.RegisterType((*WaitResponse)(nil), "containerd.runtime.linux.shim.v1.WaitResponse") 869} 870 871func init() { 872 proto.RegisterFile("github.com/containerd/containerd/runtime/v1/shim/v1/shim.proto", fileDescriptor_be1b2ef30ea3b8ef) 873} 874 875var fileDescriptor_be1b2ef30ea3b8ef = []byte{ 876 // 1133 bytes of a gzipped FileDescriptorProto 877 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x57, 0x4f, 0x4f, 0x1b, 0x47, 878 0x14, 0x67, 0x17, 0xff, 0x7d, 0x8e, 0x29, 0x4c, 0x09, 0xdd, 0x38, 0x92, 0xb1, 0x56, 0x6a, 0x44, 879 0x55, 0x65, 0x5d, 0x4c, 0x95, 0xa4, 0xad, 0x84, 0x04, 0x24, 0xaa, 0x50, 0x1b, 0x05, 0x2d, 0xa4, 880 0x89, 0x5a, 0x55, 0x68, 0xf1, 0x0e, 0xf6, 0x08, 0x7b, 0x67, 0xb3, 0x33, 0x4b, 0xa1, 0xa7, 0x9e, 881 0x7a, 0xee, 0xc7, 0xe9, 0x47, 0xe0, 0x90, 0x43, 0x8f, 0x3d, 0xa5, 0x0d, 0xf7, 0x7e, 0x87, 0x6a, 882 0xfe, 0x18, 0xaf, 0x6d, 0x36, 0xbb, 0x70, 0xc1, 0xfb, 0x66, 0x7e, 0x6f, 0xe6, 0xcd, 0xfb, 0xfd, 883 0xe6, 0xbd, 0x01, 0x36, 0x7b, 0x84, 0xf7, 0xe3, 0x23, 0xa7, 0x4b, 0x87, 0xed, 0x2e, 0x0d, 0xb8, 884 0x47, 0x02, 0x1c, 0xf9, 0xc9, 0xcf, 0x28, 0x0e, 0x38, 0x19, 0xe2, 0xf6, 0xe9, 0x7a, 0x9b, 0xf5, 885 0xc9, 0x70, 0xf4, 0xeb, 0x84, 0x11, 0xe5, 0x14, 0xb5, 0xc6, 0x48, 0x47, 0x23, 0x9d, 0x01, 0x09, 886 0xe2, 0x33, 0x47, 0x82, 0x4e, 0xd7, 0x1b, 0xf7, 0x7a, 0x94, 0xf6, 0x06, 0xb8, 0x2d, 0xf1, 0x47, 887 0xf1, 0x71, 0xdb, 0x0b, 0xce, 0x95, 0x73, 0xe3, 0xfe, 0xf4, 0x14, 0x1e, 0x86, 0x7c, 0x34, 0xb9, 888 0xdc, 0xa3, 0x3d, 0x2a, 0x3f, 0xdb, 0xe2, 0x4b, 0x8f, 0xae, 0x4e, 0xbb, 0x88, 0x1d, 0x19, 0xf7, 889 0x86, 0xa1, 0x06, 0x3c, 0xca, 0x3c, 0x90, 0x17, 0x92, 0x36, 0x3f, 0x0f, 0x31, 0x6b, 0x0f, 0x69, 890 0x1c, 0x70, 0xed, 0xf7, 0xf5, 0x0d, 0xfc, 0xb8, 0xc7, 0x4e, 0xe4, 0x1f, 0xe5, 0x6b, 0xff, 0x67, 891 0xc2, 0xd2, 0x4e, 0x84, 0x3d, 0x8e, 0x0f, 0x3c, 0x76, 0xe2, 0xe2, 0x37, 0x31, 0x66, 0x1c, 0xad, 892 0x80, 0x49, 0x7c, 0xcb, 0x68, 0x19, 0x6b, 0xd5, 0xed, 0xd2, 0xe5, 0xbb, 0x55, 0x73, 0xf7, 0xa9, 893 0x6b, 0x12, 0x1f, 0xad, 0x40, 0xe9, 0x28, 0x0e, 0xfc, 0x01, 0xb6, 0x4c, 0x31, 0xe7, 0x6a, 0x0b, 894 0x59, 0x50, 0xd6, 0x19, 0xb4, 0xe6, 0xe5, 0xc4, 0xc8, 0x44, 0x6d, 0x28, 0x45, 0x94, 0xf2, 0x63, 895 0x66, 0x15, 0x5a, 0xf3, 0x6b, 0xb5, 0xce, 0x27, 0x4e, 0x22, 0xeb, 0x32, 0x24, 0xe7, 0xb9, 0x38, 896 0x8a, 0xab, 0x61, 0xa8, 0x01, 0x15, 0x8e, 0xa3, 0x21, 0x09, 0xbc, 0x81, 0x55, 0x6c, 0x19, 0x6b, 897 0x15, 0xf7, 0xca, 0x46, 0xcb, 0x50, 0x64, 0xdc, 0x27, 0x81, 0x55, 0x92, 0x9b, 0x28, 0x43, 0x04, 898 0xc5, 0xb8, 0x4f, 0x63, 0x6e, 0x95, 0x55, 0x50, 0xca, 0xd2, 0xe3, 0x38, 0x8a, 0xac, 0xca, 0xd5, 899 0x38, 0x8e, 0x22, 0xd4, 0x04, 0xe8, 0xf6, 0x71, 0xf7, 0x24, 0xa4, 0x24, 0xe0, 0x56, 0x55, 0xce, 900 0x25, 0x46, 0xd0, 0xe7, 0xb0, 0x14, 0x7a, 0x11, 0x0e, 0xf8, 0x61, 0x02, 0x06, 0x12, 0xb6, 0xa8, 901 0x26, 0x76, 0xc6, 0x60, 0x07, 0xca, 0x34, 0xe4, 0x84, 0x06, 0xcc, 0xaa, 0xb5, 0x8c, 0xb5, 0x5a, 902 0x67, 0xd9, 0x51, 0x34, 0x3b, 0x23, 0x9a, 0x9d, 0xad, 0xe0, 0xdc, 0x1d, 0x81, 0xec, 0x07, 0x80, 903 0x92, 0xe9, 0x66, 0x21, 0x0d, 0x18, 0x46, 0x8b, 0x30, 0x1f, 0xea, 0x84, 0xd7, 0x5d, 0xf1, 0x69, 904 0xff, 0x6e, 0xc0, 0xc2, 0x53, 0x3c, 0xc0, 0x1c, 0xa7, 0x83, 0xd0, 0x2a, 0xd4, 0xf0, 0x19, 0xe1, 905 0x87, 0x8c, 0x7b, 0x3c, 0x66, 0x92, 0x93, 0xba, 0x0b, 0x62, 0x68, 0x5f, 0x8e, 0xa0, 0x2d, 0xa8, 906 0x0a, 0x0b, 0xfb, 0x87, 0x1e, 0x97, 0xcc, 0xd4, 0x3a, 0x8d, 0x99, 0xf8, 0x0e, 0x46, 0x32, 0xdc, 907 0xae, 0x5c, 0xbc, 0x5b, 0x9d, 0xfb, 0xe3, 0x9f, 0x55, 0xc3, 0xad, 0x28, 0xb7, 0x2d, 0x6e, 0x3b, 908 0xb0, 0xac, 0xe2, 0xd8, 0x8b, 0x68, 0x17, 0x33, 0x96, 0x21, 0x11, 0xfb, 0x4f, 0x03, 0xd0, 0xb3, 909 0x33, 0xdc, 0xcd, 0x07, 0x9f, 0xa0, 0xdb, 0x4c, 0xa3, 0x7b, 0xfe, 0x7a, 0xba, 0x0b, 0x29, 0x74, 910 0x17, 0x27, 0xe8, 0x5e, 0x83, 0x02, 0x0b, 0x71, 0x57, 0x6a, 0x26, 0x8d, 0x1e, 0x89, 0xb0, 0xef, 911 0xc2, 0xc7, 0x13, 0x91, 0xab, 0xbc, 0xdb, 0xaf, 0x61, 0xd1, 0xc5, 0x8c, 0xfc, 0x8a, 0xf7, 0xf8, 912 0x79, 0xd6, 0x71, 0x96, 0xa1, 0xf8, 0x0b, 0xf1, 0x79, 0x5f, 0x73, 0xa1, 0x0c, 0x11, 0x5a, 0x1f, 913 0x93, 0x5e, 0x5f, 0x71, 0x50, 0x77, 0xb5, 0x65, 0x3f, 0x80, 0x3b, 0x82, 0x28, 0x9c, 0x95, 0xd3, 914 0xb7, 0x26, 0xd4, 0x35, 0x50, 0x6b, 0xe1, 0xa6, 0x17, 0x54, 0x6b, 0x67, 0x7e, 0xac, 0x9d, 0x0d, 915 0x91, 0x2e, 0x29, 0x1b, 0x91, 0xc6, 0x85, 0xce, 0xfd, 0xe4, 0xc5, 0x3c, 0x5d, 0xd7, 0x77, 0x53, 916 0xe9, 0xc8, 0xd5, 0xd0, 0x31, 0x23, 0xc5, 0xeb, 0x19, 0x29, 0xa5, 0x30, 0x52, 0x9e, 0x60, 0x24, 917 0xc9, 0x79, 0x65, 0x8a, 0xf3, 0x29, 0x49, 0x57, 0x3f, 0x2c, 0x69, 0xb8, 0x95, 0xa4, 0x5f, 0x40, 918 0xed, 0x3b, 0x32, 0x18, 0xe4, 0x28, 0x76, 0x8c, 0xf4, 0x46, 0xc2, 0xac, 0xbb, 0xda, 0x12, 0xb9, 919 0xf4, 0x06, 0x03, 0x99, 0xcb, 0x8a, 0x2b, 0x3e, 0xed, 0x4d, 0x58, 0xd8, 0x19, 0x50, 0x86, 0x77, 920 0x5f, 0xe4, 0xd0, 0x87, 0x4a, 0xa0, 0xd2, 0xba, 0x32, 0xec, 0xcf, 0xe0, 0xa3, 0xef, 0x09, 0xe3, 921 0x7b, 0xc4, 0xcf, 0xbc, 0x5e, 0x2e, 0x2c, 0x8e, 0xa1, 0x5a, 0x0c, 0x9b, 0x50, 0x0d, 0x95, 0x66, 922 0x31, 0xb3, 0x0c, 0x59, 0x66, 0x5b, 0xd7, 0xb2, 0xa9, 0x95, 0xbd, 0x1b, 0x1c, 0x53, 0x77, 0xec, 923 0x62, 0xff, 0x04, 0x77, 0xc7, 0x15, 0x2d, 0xd9, 0x06, 0x10, 0x14, 0x42, 0x8f, 0xf7, 0x55, 0x18, 924 0xae, 0xfc, 0x4e, 0x16, 0x3c, 0x33, 0x4f, 0xc1, 0x7b, 0x08, 0x8b, 0xfb, 0x7d, 0x32, 0x94, 0x7b, 925 0x8e, 0x02, 0xbe, 0x07, 0x15, 0xd1, 0x62, 0x0f, 0xc7, 0xe5, 0xac, 0x2c, 0xec, 0x3d, 0xe2, 0xdb, 926 0xdf, 0xc2, 0xd2, 0xcb, 0xd0, 0x9f, 0x6a, 0x47, 0x1d, 0xa8, 0x46, 0x98, 0xd1, 0x38, 0xea, 0xca, 927 0x03, 0xa6, 0xef, 0x3a, 0x86, 0xe9, 0xbb, 0x15, 0xf1, 0xac, 0x84, 0x7e, 0x25, 0xaf, 0x96, 0xc0, 928 0x65, 0x5c, 0x2d, 0x7d, 0x85, 0xcc, 0x71, 0x8d, 0xfe, 0x14, 0x6a, 0xaf, 0x3c, 0x92, 0xb9, 0x43, 929 0x04, 0x77, 0x14, 0x4c, 0x6f, 0x30, 0x25, 0x71, 0xe3, 0xc3, 0x12, 0x37, 0x6f, 0x23, 0xf1, 0xce, 930 0xdb, 0x1a, 0x14, 0x44, 0xda, 0x51, 0x1f, 0x8a, 0xb2, 0x72, 0x20, 0xc7, 0xc9, 0x7a, 0xee, 0x38, 931 0xc9, 0x5a, 0xd4, 0x68, 0xe7, 0xc6, 0xeb, 0x63, 0x31, 0x28, 0xa9, 0xce, 0x86, 0x36, 0xb2, 0x5d, 932 0x67, 0x9e, 0x1c, 0x8d, 0x2f, 0x6f, 0xe6, 0xa4, 0x37, 0x55, 0xc7, 0x8b, 0x78, 0xce, 0xe3, 0x5d, 933 0xc9, 0x21, 0xe7, 0xf1, 0x12, 0xb2, 0x70, 0xa1, 0xa4, 0xfa, 0x20, 0x5a, 0x99, 0xe1, 0xe2, 0x99, 934 0x78, 0xfb, 0x35, 0xbe, 0xc8, 0x5e, 0x72, 0xaa, 0xa3, 0x9f, 0x43, 0x7d, 0xa2, 0xb7, 0xa2, 0x47, 935 0x79, 0x97, 0x98, 0xec, 0xae, 0xb7, 0xd8, 0xfa, 0x0d, 0x54, 0x46, 0x75, 0x04, 0xad, 0x67, 0x7b, 936 0x4f, 0x95, 0xa7, 0x46, 0xe7, 0x26, 0x2e, 0x7a, 0xcb, 0xc7, 0x50, 0xdc, 0xf3, 0x62, 0x96, 0x9e, 937 0xc0, 0x94, 0x71, 0xf4, 0x04, 0x4a, 0x2e, 0x66, 0xf1, 0xf0, 0xe6, 0x9e, 0x3f, 0x03, 0x24, 0xde, 938 0x6a, 0x8f, 0x73, 0x48, 0xec, 0xba, 0x3a, 0x98, 0xba, 0xfc, 0x73, 0x28, 0x88, 0x46, 0x82, 0x1e, 939 0x66, 0x2f, 0x9c, 0x68, 0x38, 0xa9, 0xcb, 0x1d, 0x40, 0x41, 0xbc, 0x3f, 0x50, 0x8e, 0xab, 0x30, 940 0xfb, 0xc2, 0x4a, 0x5d, 0xf5, 0x15, 0x54, 0xaf, 0x9e, 0x2f, 0x28, 0x07, 0x6f, 0xd3, 0x6f, 0x9d, 941 0xd4, 0x85, 0xf7, 0xa1, 0xac, 0xbb, 0x1e, 0xca, 0xa1, 0xbf, 0xc9, 0x06, 0x99, 0xba, 0xe8, 0x0f, 942 0x50, 0x19, 0xb5, 0x8b, 0x54, 0xb6, 0x73, 0x1c, 0x62, 0xa6, 0xe5, 0xbc, 0x84, 0x92, 0xea, 0x2b, 943 0x79, 0xaa, 0xd3, 0x4c, 0x07, 0x4a, 0x0d, 0x17, 0x43, 0x41, 0xd4, 0xf6, 0x3c, 0x0a, 0x48, 0xb4, 944 0x8a, 0x86, 0x93, 0x17, 0xae, 0xa2, 0xdf, 0x76, 0x2f, 0xde, 0x37, 0xe7, 0xfe, 0x7e, 0xdf, 0x9c, 945 0xfb, 0xed, 0xb2, 0x69, 0x5c, 0x5c, 0x36, 0x8d, 0xbf, 0x2e, 0x9b, 0xc6, 0xbf, 0x97, 0x4d, 0xe3, 946 0xc7, 0x27, 0xb7, 0xf8, 0x27, 0xf8, 0x1b, 0xf1, 0xfb, 0xda, 0x3c, 0x2a, 0xc9, 0xc3, 0x6c, 0xfc, 947 0x1f, 0x00, 0x00, 0xff, 0xff, 0x64, 0x52, 0x86, 0xc0, 0x49, 0x0f, 0x00, 0x00, 948} 949 950func (m *CreateTaskRequest) Marshal() (dAtA []byte, err error) { 951 size := m.Size() 952 dAtA = make([]byte, size) 953 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 954 if err != nil { 955 return nil, err 956 } 957 return dAtA[:n], nil 958} 959 960func (m *CreateTaskRequest) MarshalTo(dAtA []byte) (int, error) { 961 size := m.Size() 962 return m.MarshalToSizedBuffer(dAtA[:size]) 963} 964 965func (m *CreateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 966 i := len(dAtA) 967 _ = i 968 var l int 969 _ = l 970 if m.XXX_unrecognized != nil { 971 i -= len(m.XXX_unrecognized) 972 copy(dAtA[i:], m.XXX_unrecognized) 973 } 974 if m.Options != nil { 975 { 976 size, err := m.Options.MarshalToSizedBuffer(dAtA[:i]) 977 if err != nil { 978 return 0, err 979 } 980 i -= size 981 i = encodeVarintShim(dAtA, i, uint64(size)) 982 } 983 i-- 984 dAtA[i] = 0x5a 985 } 986 if len(m.ParentCheckpoint) > 0 { 987 i -= len(m.ParentCheckpoint) 988 copy(dAtA[i:], m.ParentCheckpoint) 989 i = encodeVarintShim(dAtA, i, uint64(len(m.ParentCheckpoint))) 990 i-- 991 dAtA[i] = 0x52 992 } 993 if len(m.Checkpoint) > 0 { 994 i -= len(m.Checkpoint) 995 copy(dAtA[i:], m.Checkpoint) 996 i = encodeVarintShim(dAtA, i, uint64(len(m.Checkpoint))) 997 i-- 998 dAtA[i] = 0x4a 999 } 1000 if len(m.Stderr) > 0 { 1001 i -= len(m.Stderr) 1002 copy(dAtA[i:], m.Stderr) 1003 i = encodeVarintShim(dAtA, i, uint64(len(m.Stderr))) 1004 i-- 1005 dAtA[i] = 0x42 1006 } 1007 if len(m.Stdout) > 0 { 1008 i -= len(m.Stdout) 1009 copy(dAtA[i:], m.Stdout) 1010 i = encodeVarintShim(dAtA, i, uint64(len(m.Stdout))) 1011 i-- 1012 dAtA[i] = 0x3a 1013 } 1014 if len(m.Stdin) > 0 { 1015 i -= len(m.Stdin) 1016 copy(dAtA[i:], m.Stdin) 1017 i = encodeVarintShim(dAtA, i, uint64(len(m.Stdin))) 1018 i-- 1019 dAtA[i] = 0x32 1020 } 1021 if m.Terminal { 1022 i-- 1023 if m.Terminal { 1024 dAtA[i] = 1 1025 } else { 1026 dAtA[i] = 0 1027 } 1028 i-- 1029 dAtA[i] = 0x28 1030 } 1031 if len(m.Rootfs) > 0 { 1032 for iNdEx := len(m.Rootfs) - 1; iNdEx >= 0; iNdEx-- { 1033 { 1034 size, err := m.Rootfs[iNdEx].MarshalToSizedBuffer(dAtA[:i]) 1035 if err != nil { 1036 return 0, err 1037 } 1038 i -= size 1039 i = encodeVarintShim(dAtA, i, uint64(size)) 1040 } 1041 i-- 1042 dAtA[i] = 0x22 1043 } 1044 } 1045 if len(m.Runtime) > 0 { 1046 i -= len(m.Runtime) 1047 copy(dAtA[i:], m.Runtime) 1048 i = encodeVarintShim(dAtA, i, uint64(len(m.Runtime))) 1049 i-- 1050 dAtA[i] = 0x1a 1051 } 1052 if len(m.Bundle) > 0 { 1053 i -= len(m.Bundle) 1054 copy(dAtA[i:], m.Bundle) 1055 i = encodeVarintShim(dAtA, i, uint64(len(m.Bundle))) 1056 i-- 1057 dAtA[i] = 0x12 1058 } 1059 if len(m.ID) > 0 { 1060 i -= len(m.ID) 1061 copy(dAtA[i:], m.ID) 1062 i = encodeVarintShim(dAtA, i, uint64(len(m.ID))) 1063 i-- 1064 dAtA[i] = 0xa 1065 } 1066 return len(dAtA) - i, nil 1067} 1068 1069func (m *CreateTaskResponse) Marshal() (dAtA []byte, err error) { 1070 size := m.Size() 1071 dAtA = make([]byte, size) 1072 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1073 if err != nil { 1074 return nil, err 1075 } 1076 return dAtA[:n], nil 1077} 1078 1079func (m *CreateTaskResponse) MarshalTo(dAtA []byte) (int, error) { 1080 size := m.Size() 1081 return m.MarshalToSizedBuffer(dAtA[:size]) 1082} 1083 1084func (m *CreateTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1085 i := len(dAtA) 1086 _ = i 1087 var l int 1088 _ = l 1089 if m.XXX_unrecognized != nil { 1090 i -= len(m.XXX_unrecognized) 1091 copy(dAtA[i:], m.XXX_unrecognized) 1092 } 1093 if m.Pid != 0 { 1094 i = encodeVarintShim(dAtA, i, uint64(m.Pid)) 1095 i-- 1096 dAtA[i] = 0x8 1097 } 1098 return len(dAtA) - i, nil 1099} 1100 1101func (m *DeleteResponse) Marshal() (dAtA []byte, err error) { 1102 size := m.Size() 1103 dAtA = make([]byte, size) 1104 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1105 if err != nil { 1106 return nil, err 1107 } 1108 return dAtA[:n], nil 1109} 1110 1111func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error) { 1112 size := m.Size() 1113 return m.MarshalToSizedBuffer(dAtA[:size]) 1114} 1115 1116func (m *DeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1117 i := len(dAtA) 1118 _ = i 1119 var l int 1120 _ = l 1121 if m.XXX_unrecognized != nil { 1122 i -= len(m.XXX_unrecognized) 1123 copy(dAtA[i:], m.XXX_unrecognized) 1124 } 1125 n2, err2 := github_com_gogo_protobuf_types.StdTimeMarshalTo(m.ExitedAt, dAtA[i-github_com_gogo_protobuf_types.SizeOfStdTime(m.ExitedAt):]) 1126 if err2 != nil { 1127 return 0, err2 1128 } 1129 i -= n2 1130 i = encodeVarintShim(dAtA, i, uint64(n2)) 1131 i-- 1132 dAtA[i] = 0x1a 1133 if m.ExitStatus != 0 { 1134 i = encodeVarintShim(dAtA, i, uint64(m.ExitStatus)) 1135 i-- 1136 dAtA[i] = 0x10 1137 } 1138 if m.Pid != 0 { 1139 i = encodeVarintShim(dAtA, i, uint64(m.Pid)) 1140 i-- 1141 dAtA[i] = 0x8 1142 } 1143 return len(dAtA) - i, nil 1144} 1145 1146func (m *DeleteProcessRequest) Marshal() (dAtA []byte, err error) { 1147 size := m.Size() 1148 dAtA = make([]byte, size) 1149 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1150 if err != nil { 1151 return nil, err 1152 } 1153 return dAtA[:n], nil 1154} 1155 1156func (m *DeleteProcessRequest) MarshalTo(dAtA []byte) (int, error) { 1157 size := m.Size() 1158 return m.MarshalToSizedBuffer(dAtA[:size]) 1159} 1160 1161func (m *DeleteProcessRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1162 i := len(dAtA) 1163 _ = i 1164 var l int 1165 _ = l 1166 if m.XXX_unrecognized != nil { 1167 i -= len(m.XXX_unrecognized) 1168 copy(dAtA[i:], m.XXX_unrecognized) 1169 } 1170 if len(m.ID) > 0 { 1171 i -= len(m.ID) 1172 copy(dAtA[i:], m.ID) 1173 i = encodeVarintShim(dAtA, i, uint64(len(m.ID))) 1174 i-- 1175 dAtA[i] = 0xa 1176 } 1177 return len(dAtA) - i, nil 1178} 1179 1180func (m *ExecProcessRequest) Marshal() (dAtA []byte, err error) { 1181 size := m.Size() 1182 dAtA = make([]byte, size) 1183 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1184 if err != nil { 1185 return nil, err 1186 } 1187 return dAtA[:n], nil 1188} 1189 1190func (m *ExecProcessRequest) MarshalTo(dAtA []byte) (int, error) { 1191 size := m.Size() 1192 return m.MarshalToSizedBuffer(dAtA[:size]) 1193} 1194 1195func (m *ExecProcessRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1196 i := len(dAtA) 1197 _ = i 1198 var l int 1199 _ = l 1200 if m.XXX_unrecognized != nil { 1201 i -= len(m.XXX_unrecognized) 1202 copy(dAtA[i:], m.XXX_unrecognized) 1203 } 1204 if m.Spec != nil { 1205 { 1206 size, err := m.Spec.MarshalToSizedBuffer(dAtA[:i]) 1207 if err != nil { 1208 return 0, err 1209 } 1210 i -= size 1211 i = encodeVarintShim(dAtA, i, uint64(size)) 1212 } 1213 i-- 1214 dAtA[i] = 0x32 1215 } 1216 if len(m.Stderr) > 0 { 1217 i -= len(m.Stderr) 1218 copy(dAtA[i:], m.Stderr) 1219 i = encodeVarintShim(dAtA, i, uint64(len(m.Stderr))) 1220 i-- 1221 dAtA[i] = 0x2a 1222 } 1223 if len(m.Stdout) > 0 { 1224 i -= len(m.Stdout) 1225 copy(dAtA[i:], m.Stdout) 1226 i = encodeVarintShim(dAtA, i, uint64(len(m.Stdout))) 1227 i-- 1228 dAtA[i] = 0x22 1229 } 1230 if len(m.Stdin) > 0 { 1231 i -= len(m.Stdin) 1232 copy(dAtA[i:], m.Stdin) 1233 i = encodeVarintShim(dAtA, i, uint64(len(m.Stdin))) 1234 i-- 1235 dAtA[i] = 0x1a 1236 } 1237 if m.Terminal { 1238 i-- 1239 if m.Terminal { 1240 dAtA[i] = 1 1241 } else { 1242 dAtA[i] = 0 1243 } 1244 i-- 1245 dAtA[i] = 0x10 1246 } 1247 if len(m.ID) > 0 { 1248 i -= len(m.ID) 1249 copy(dAtA[i:], m.ID) 1250 i = encodeVarintShim(dAtA, i, uint64(len(m.ID))) 1251 i-- 1252 dAtA[i] = 0xa 1253 } 1254 return len(dAtA) - i, nil 1255} 1256 1257func (m *ExecProcessResponse) Marshal() (dAtA []byte, err error) { 1258 size := m.Size() 1259 dAtA = make([]byte, size) 1260 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1261 if err != nil { 1262 return nil, err 1263 } 1264 return dAtA[:n], nil 1265} 1266 1267func (m *ExecProcessResponse) MarshalTo(dAtA []byte) (int, error) { 1268 size := m.Size() 1269 return m.MarshalToSizedBuffer(dAtA[:size]) 1270} 1271 1272func (m *ExecProcessResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1273 i := len(dAtA) 1274 _ = i 1275 var l int 1276 _ = l 1277 if m.XXX_unrecognized != nil { 1278 i -= len(m.XXX_unrecognized) 1279 copy(dAtA[i:], m.XXX_unrecognized) 1280 } 1281 return len(dAtA) - i, nil 1282} 1283 1284func (m *ResizePtyRequest) Marshal() (dAtA []byte, err error) { 1285 size := m.Size() 1286 dAtA = make([]byte, size) 1287 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1288 if err != nil { 1289 return nil, err 1290 } 1291 return dAtA[:n], nil 1292} 1293 1294func (m *ResizePtyRequest) MarshalTo(dAtA []byte) (int, error) { 1295 size := m.Size() 1296 return m.MarshalToSizedBuffer(dAtA[:size]) 1297} 1298 1299func (m *ResizePtyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1300 i := len(dAtA) 1301 _ = i 1302 var l int 1303 _ = l 1304 if m.XXX_unrecognized != nil { 1305 i -= len(m.XXX_unrecognized) 1306 copy(dAtA[i:], m.XXX_unrecognized) 1307 } 1308 if m.Height != 0 { 1309 i = encodeVarintShim(dAtA, i, uint64(m.Height)) 1310 i-- 1311 dAtA[i] = 0x18 1312 } 1313 if m.Width != 0 { 1314 i = encodeVarintShim(dAtA, i, uint64(m.Width)) 1315 i-- 1316 dAtA[i] = 0x10 1317 } 1318 if len(m.ID) > 0 { 1319 i -= len(m.ID) 1320 copy(dAtA[i:], m.ID) 1321 i = encodeVarintShim(dAtA, i, uint64(len(m.ID))) 1322 i-- 1323 dAtA[i] = 0xa 1324 } 1325 return len(dAtA) - i, nil 1326} 1327 1328func (m *StateRequest) Marshal() (dAtA []byte, err error) { 1329 size := m.Size() 1330 dAtA = make([]byte, size) 1331 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1332 if err != nil { 1333 return nil, err 1334 } 1335 return dAtA[:n], nil 1336} 1337 1338func (m *StateRequest) MarshalTo(dAtA []byte) (int, error) { 1339 size := m.Size() 1340 return m.MarshalToSizedBuffer(dAtA[:size]) 1341} 1342 1343func (m *StateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1344 i := len(dAtA) 1345 _ = i 1346 var l int 1347 _ = l 1348 if m.XXX_unrecognized != nil { 1349 i -= len(m.XXX_unrecognized) 1350 copy(dAtA[i:], m.XXX_unrecognized) 1351 } 1352 if len(m.ID) > 0 { 1353 i -= len(m.ID) 1354 copy(dAtA[i:], m.ID) 1355 i = encodeVarintShim(dAtA, i, uint64(len(m.ID))) 1356 i-- 1357 dAtA[i] = 0xa 1358 } 1359 return len(dAtA) - i, nil 1360} 1361 1362func (m *StateResponse) Marshal() (dAtA []byte, err error) { 1363 size := m.Size() 1364 dAtA = make([]byte, size) 1365 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1366 if err != nil { 1367 return nil, err 1368 } 1369 return dAtA[:n], nil 1370} 1371 1372func (m *StateResponse) MarshalTo(dAtA []byte) (int, error) { 1373 size := m.Size() 1374 return m.MarshalToSizedBuffer(dAtA[:size]) 1375} 1376 1377func (m *StateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1378 i := len(dAtA) 1379 _ = i 1380 var l int 1381 _ = l 1382 if m.XXX_unrecognized != nil { 1383 i -= len(m.XXX_unrecognized) 1384 copy(dAtA[i:], m.XXX_unrecognized) 1385 } 1386 n4, err4 := github_com_gogo_protobuf_types.StdTimeMarshalTo(m.ExitedAt, dAtA[i-github_com_gogo_protobuf_types.SizeOfStdTime(m.ExitedAt):]) 1387 if err4 != nil { 1388 return 0, err4 1389 } 1390 i -= n4 1391 i = encodeVarintShim(dAtA, i, uint64(n4)) 1392 i-- 1393 dAtA[i] = 0x52 1394 if m.ExitStatus != 0 { 1395 i = encodeVarintShim(dAtA, i, uint64(m.ExitStatus)) 1396 i-- 1397 dAtA[i] = 0x48 1398 } 1399 if m.Terminal { 1400 i-- 1401 if m.Terminal { 1402 dAtA[i] = 1 1403 } else { 1404 dAtA[i] = 0 1405 } 1406 i-- 1407 dAtA[i] = 0x40 1408 } 1409 if len(m.Stderr) > 0 { 1410 i -= len(m.Stderr) 1411 copy(dAtA[i:], m.Stderr) 1412 i = encodeVarintShim(dAtA, i, uint64(len(m.Stderr))) 1413 i-- 1414 dAtA[i] = 0x3a 1415 } 1416 if len(m.Stdout) > 0 { 1417 i -= len(m.Stdout) 1418 copy(dAtA[i:], m.Stdout) 1419 i = encodeVarintShim(dAtA, i, uint64(len(m.Stdout))) 1420 i-- 1421 dAtA[i] = 0x32 1422 } 1423 if len(m.Stdin) > 0 { 1424 i -= len(m.Stdin) 1425 copy(dAtA[i:], m.Stdin) 1426 i = encodeVarintShim(dAtA, i, uint64(len(m.Stdin))) 1427 i-- 1428 dAtA[i] = 0x2a 1429 } 1430 if m.Status != 0 { 1431 i = encodeVarintShim(dAtA, i, uint64(m.Status)) 1432 i-- 1433 dAtA[i] = 0x20 1434 } 1435 if m.Pid != 0 { 1436 i = encodeVarintShim(dAtA, i, uint64(m.Pid)) 1437 i-- 1438 dAtA[i] = 0x18 1439 } 1440 if len(m.Bundle) > 0 { 1441 i -= len(m.Bundle) 1442 copy(dAtA[i:], m.Bundle) 1443 i = encodeVarintShim(dAtA, i, uint64(len(m.Bundle))) 1444 i-- 1445 dAtA[i] = 0x12 1446 } 1447 if len(m.ID) > 0 { 1448 i -= len(m.ID) 1449 copy(dAtA[i:], m.ID) 1450 i = encodeVarintShim(dAtA, i, uint64(len(m.ID))) 1451 i-- 1452 dAtA[i] = 0xa 1453 } 1454 return len(dAtA) - i, nil 1455} 1456 1457func (m *KillRequest) Marshal() (dAtA []byte, err error) { 1458 size := m.Size() 1459 dAtA = make([]byte, size) 1460 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1461 if err != nil { 1462 return nil, err 1463 } 1464 return dAtA[:n], nil 1465} 1466 1467func (m *KillRequest) MarshalTo(dAtA []byte) (int, error) { 1468 size := m.Size() 1469 return m.MarshalToSizedBuffer(dAtA[:size]) 1470} 1471 1472func (m *KillRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1473 i := len(dAtA) 1474 _ = i 1475 var l int 1476 _ = l 1477 if m.XXX_unrecognized != nil { 1478 i -= len(m.XXX_unrecognized) 1479 copy(dAtA[i:], m.XXX_unrecognized) 1480 } 1481 if m.All { 1482 i-- 1483 if m.All { 1484 dAtA[i] = 1 1485 } else { 1486 dAtA[i] = 0 1487 } 1488 i-- 1489 dAtA[i] = 0x18 1490 } 1491 if m.Signal != 0 { 1492 i = encodeVarintShim(dAtA, i, uint64(m.Signal)) 1493 i-- 1494 dAtA[i] = 0x10 1495 } 1496 if len(m.ID) > 0 { 1497 i -= len(m.ID) 1498 copy(dAtA[i:], m.ID) 1499 i = encodeVarintShim(dAtA, i, uint64(len(m.ID))) 1500 i-- 1501 dAtA[i] = 0xa 1502 } 1503 return len(dAtA) - i, nil 1504} 1505 1506func (m *CloseIORequest) Marshal() (dAtA []byte, err error) { 1507 size := m.Size() 1508 dAtA = make([]byte, size) 1509 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1510 if err != nil { 1511 return nil, err 1512 } 1513 return dAtA[:n], nil 1514} 1515 1516func (m *CloseIORequest) MarshalTo(dAtA []byte) (int, error) { 1517 size := m.Size() 1518 return m.MarshalToSizedBuffer(dAtA[:size]) 1519} 1520 1521func (m *CloseIORequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1522 i := len(dAtA) 1523 _ = i 1524 var l int 1525 _ = l 1526 if m.XXX_unrecognized != nil { 1527 i -= len(m.XXX_unrecognized) 1528 copy(dAtA[i:], m.XXX_unrecognized) 1529 } 1530 if m.Stdin { 1531 i-- 1532 if m.Stdin { 1533 dAtA[i] = 1 1534 } else { 1535 dAtA[i] = 0 1536 } 1537 i-- 1538 dAtA[i] = 0x10 1539 } 1540 if len(m.ID) > 0 { 1541 i -= len(m.ID) 1542 copy(dAtA[i:], m.ID) 1543 i = encodeVarintShim(dAtA, i, uint64(len(m.ID))) 1544 i-- 1545 dAtA[i] = 0xa 1546 } 1547 return len(dAtA) - i, nil 1548} 1549 1550func (m *ListPidsRequest) Marshal() (dAtA []byte, err error) { 1551 size := m.Size() 1552 dAtA = make([]byte, size) 1553 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1554 if err != nil { 1555 return nil, err 1556 } 1557 return dAtA[:n], nil 1558} 1559 1560func (m *ListPidsRequest) MarshalTo(dAtA []byte) (int, error) { 1561 size := m.Size() 1562 return m.MarshalToSizedBuffer(dAtA[:size]) 1563} 1564 1565func (m *ListPidsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1566 i := len(dAtA) 1567 _ = i 1568 var l int 1569 _ = l 1570 if m.XXX_unrecognized != nil { 1571 i -= len(m.XXX_unrecognized) 1572 copy(dAtA[i:], m.XXX_unrecognized) 1573 } 1574 if len(m.ID) > 0 { 1575 i -= len(m.ID) 1576 copy(dAtA[i:], m.ID) 1577 i = encodeVarintShim(dAtA, i, uint64(len(m.ID))) 1578 i-- 1579 dAtA[i] = 0xa 1580 } 1581 return len(dAtA) - i, nil 1582} 1583 1584func (m *ListPidsResponse) Marshal() (dAtA []byte, err error) { 1585 size := m.Size() 1586 dAtA = make([]byte, size) 1587 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1588 if err != nil { 1589 return nil, err 1590 } 1591 return dAtA[:n], nil 1592} 1593 1594func (m *ListPidsResponse) MarshalTo(dAtA []byte) (int, error) { 1595 size := m.Size() 1596 return m.MarshalToSizedBuffer(dAtA[:size]) 1597} 1598 1599func (m *ListPidsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1600 i := len(dAtA) 1601 _ = i 1602 var l int 1603 _ = l 1604 if m.XXX_unrecognized != nil { 1605 i -= len(m.XXX_unrecognized) 1606 copy(dAtA[i:], m.XXX_unrecognized) 1607 } 1608 if len(m.Processes) > 0 { 1609 for iNdEx := len(m.Processes) - 1; iNdEx >= 0; iNdEx-- { 1610 { 1611 size, err := m.Processes[iNdEx].MarshalToSizedBuffer(dAtA[:i]) 1612 if err != nil { 1613 return 0, err 1614 } 1615 i -= size 1616 i = encodeVarintShim(dAtA, i, uint64(size)) 1617 } 1618 i-- 1619 dAtA[i] = 0xa 1620 } 1621 } 1622 return len(dAtA) - i, nil 1623} 1624 1625func (m *CheckpointTaskRequest) Marshal() (dAtA []byte, err error) { 1626 size := m.Size() 1627 dAtA = make([]byte, size) 1628 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1629 if err != nil { 1630 return nil, err 1631 } 1632 return dAtA[:n], nil 1633} 1634 1635func (m *CheckpointTaskRequest) MarshalTo(dAtA []byte) (int, error) { 1636 size := m.Size() 1637 return m.MarshalToSizedBuffer(dAtA[:size]) 1638} 1639 1640func (m *CheckpointTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1641 i := len(dAtA) 1642 _ = i 1643 var l int 1644 _ = l 1645 if m.XXX_unrecognized != nil { 1646 i -= len(m.XXX_unrecognized) 1647 copy(dAtA[i:], m.XXX_unrecognized) 1648 } 1649 if m.Options != nil { 1650 { 1651 size, err := m.Options.MarshalToSizedBuffer(dAtA[:i]) 1652 if err != nil { 1653 return 0, err 1654 } 1655 i -= size 1656 i = encodeVarintShim(dAtA, i, uint64(size)) 1657 } 1658 i-- 1659 dAtA[i] = 0x12 1660 } 1661 if len(m.Path) > 0 { 1662 i -= len(m.Path) 1663 copy(dAtA[i:], m.Path) 1664 i = encodeVarintShim(dAtA, i, uint64(len(m.Path))) 1665 i-- 1666 dAtA[i] = 0xa 1667 } 1668 return len(dAtA) - i, nil 1669} 1670 1671func (m *ShimInfoResponse) Marshal() (dAtA []byte, err error) { 1672 size := m.Size() 1673 dAtA = make([]byte, size) 1674 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1675 if err != nil { 1676 return nil, err 1677 } 1678 return dAtA[:n], nil 1679} 1680 1681func (m *ShimInfoResponse) MarshalTo(dAtA []byte) (int, error) { 1682 size := m.Size() 1683 return m.MarshalToSizedBuffer(dAtA[:size]) 1684} 1685 1686func (m *ShimInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1687 i := len(dAtA) 1688 _ = i 1689 var l int 1690 _ = l 1691 if m.XXX_unrecognized != nil { 1692 i -= len(m.XXX_unrecognized) 1693 copy(dAtA[i:], m.XXX_unrecognized) 1694 } 1695 if m.ShimPid != 0 { 1696 i = encodeVarintShim(dAtA, i, uint64(m.ShimPid)) 1697 i-- 1698 dAtA[i] = 0x8 1699 } 1700 return len(dAtA) - i, nil 1701} 1702 1703func (m *UpdateTaskRequest) Marshal() (dAtA []byte, err error) { 1704 size := m.Size() 1705 dAtA = make([]byte, size) 1706 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1707 if err != nil { 1708 return nil, err 1709 } 1710 return dAtA[:n], nil 1711} 1712 1713func (m *UpdateTaskRequest) MarshalTo(dAtA []byte) (int, error) { 1714 size := m.Size() 1715 return m.MarshalToSizedBuffer(dAtA[:size]) 1716} 1717 1718func (m *UpdateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1719 i := len(dAtA) 1720 _ = i 1721 var l int 1722 _ = l 1723 if m.XXX_unrecognized != nil { 1724 i -= len(m.XXX_unrecognized) 1725 copy(dAtA[i:], m.XXX_unrecognized) 1726 } 1727 if m.Resources != nil { 1728 { 1729 size, err := m.Resources.MarshalToSizedBuffer(dAtA[:i]) 1730 if err != nil { 1731 return 0, err 1732 } 1733 i -= size 1734 i = encodeVarintShim(dAtA, i, uint64(size)) 1735 } 1736 i-- 1737 dAtA[i] = 0xa 1738 } 1739 return len(dAtA) - i, nil 1740} 1741 1742func (m *StartRequest) Marshal() (dAtA []byte, err error) { 1743 size := m.Size() 1744 dAtA = make([]byte, size) 1745 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1746 if err != nil { 1747 return nil, err 1748 } 1749 return dAtA[:n], nil 1750} 1751 1752func (m *StartRequest) MarshalTo(dAtA []byte) (int, error) { 1753 size := m.Size() 1754 return m.MarshalToSizedBuffer(dAtA[:size]) 1755} 1756 1757func (m *StartRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1758 i := len(dAtA) 1759 _ = i 1760 var l int 1761 _ = l 1762 if m.XXX_unrecognized != nil { 1763 i -= len(m.XXX_unrecognized) 1764 copy(dAtA[i:], m.XXX_unrecognized) 1765 } 1766 if len(m.ID) > 0 { 1767 i -= len(m.ID) 1768 copy(dAtA[i:], m.ID) 1769 i = encodeVarintShim(dAtA, i, uint64(len(m.ID))) 1770 i-- 1771 dAtA[i] = 0xa 1772 } 1773 return len(dAtA) - i, nil 1774} 1775 1776func (m *StartResponse) Marshal() (dAtA []byte, err error) { 1777 size := m.Size() 1778 dAtA = make([]byte, size) 1779 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1780 if err != nil { 1781 return nil, err 1782 } 1783 return dAtA[:n], nil 1784} 1785 1786func (m *StartResponse) MarshalTo(dAtA []byte) (int, error) { 1787 size := m.Size() 1788 return m.MarshalToSizedBuffer(dAtA[:size]) 1789} 1790 1791func (m *StartResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1792 i := len(dAtA) 1793 _ = i 1794 var l int 1795 _ = l 1796 if m.XXX_unrecognized != nil { 1797 i -= len(m.XXX_unrecognized) 1798 copy(dAtA[i:], m.XXX_unrecognized) 1799 } 1800 if m.Pid != 0 { 1801 i = encodeVarintShim(dAtA, i, uint64(m.Pid)) 1802 i-- 1803 dAtA[i] = 0x10 1804 } 1805 if len(m.ID) > 0 { 1806 i -= len(m.ID) 1807 copy(dAtA[i:], m.ID) 1808 i = encodeVarintShim(dAtA, i, uint64(len(m.ID))) 1809 i-- 1810 dAtA[i] = 0xa 1811 } 1812 return len(dAtA) - i, nil 1813} 1814 1815func (m *WaitRequest) Marshal() (dAtA []byte, err error) { 1816 size := m.Size() 1817 dAtA = make([]byte, size) 1818 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1819 if err != nil { 1820 return nil, err 1821 } 1822 return dAtA[:n], nil 1823} 1824 1825func (m *WaitRequest) MarshalTo(dAtA []byte) (int, error) { 1826 size := m.Size() 1827 return m.MarshalToSizedBuffer(dAtA[:size]) 1828} 1829 1830func (m *WaitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1831 i := len(dAtA) 1832 _ = i 1833 var l int 1834 _ = l 1835 if m.XXX_unrecognized != nil { 1836 i -= len(m.XXX_unrecognized) 1837 copy(dAtA[i:], m.XXX_unrecognized) 1838 } 1839 if len(m.ID) > 0 { 1840 i -= len(m.ID) 1841 copy(dAtA[i:], m.ID) 1842 i = encodeVarintShim(dAtA, i, uint64(len(m.ID))) 1843 i-- 1844 dAtA[i] = 0xa 1845 } 1846 return len(dAtA) - i, nil 1847} 1848 1849func (m *WaitResponse) Marshal() (dAtA []byte, err error) { 1850 size := m.Size() 1851 dAtA = make([]byte, size) 1852 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1853 if err != nil { 1854 return nil, err 1855 } 1856 return dAtA[:n], nil 1857} 1858 1859func (m *WaitResponse) MarshalTo(dAtA []byte) (int, error) { 1860 size := m.Size() 1861 return m.MarshalToSizedBuffer(dAtA[:size]) 1862} 1863 1864func (m *WaitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1865 i := len(dAtA) 1866 _ = i 1867 var l int 1868 _ = l 1869 if m.XXX_unrecognized != nil { 1870 i -= len(m.XXX_unrecognized) 1871 copy(dAtA[i:], m.XXX_unrecognized) 1872 } 1873 n7, err7 := github_com_gogo_protobuf_types.StdTimeMarshalTo(m.ExitedAt, dAtA[i-github_com_gogo_protobuf_types.SizeOfStdTime(m.ExitedAt):]) 1874 if err7 != nil { 1875 return 0, err7 1876 } 1877 i -= n7 1878 i = encodeVarintShim(dAtA, i, uint64(n7)) 1879 i-- 1880 dAtA[i] = 0x12 1881 if m.ExitStatus != 0 { 1882 i = encodeVarintShim(dAtA, i, uint64(m.ExitStatus)) 1883 i-- 1884 dAtA[i] = 0x8 1885 } 1886 return len(dAtA) - i, nil 1887} 1888 1889func encodeVarintShim(dAtA []byte, offset int, v uint64) int { 1890 offset -= sovShim(v) 1891 base := offset 1892 for v >= 1<<7 { 1893 dAtA[offset] = uint8(v&0x7f | 0x80) 1894 v >>= 7 1895 offset++ 1896 } 1897 dAtA[offset] = uint8(v) 1898 return base 1899} 1900func (m *CreateTaskRequest) Size() (n int) { 1901 if m == nil { 1902 return 0 1903 } 1904 var l int 1905 _ = l 1906 l = len(m.ID) 1907 if l > 0 { 1908 n += 1 + l + sovShim(uint64(l)) 1909 } 1910 l = len(m.Bundle) 1911 if l > 0 { 1912 n += 1 + l + sovShim(uint64(l)) 1913 } 1914 l = len(m.Runtime) 1915 if l > 0 { 1916 n += 1 + l + sovShim(uint64(l)) 1917 } 1918 if len(m.Rootfs) > 0 { 1919 for _, e := range m.Rootfs { 1920 l = e.Size() 1921 n += 1 + l + sovShim(uint64(l)) 1922 } 1923 } 1924 if m.Terminal { 1925 n += 2 1926 } 1927 l = len(m.Stdin) 1928 if l > 0 { 1929 n += 1 + l + sovShim(uint64(l)) 1930 } 1931 l = len(m.Stdout) 1932 if l > 0 { 1933 n += 1 + l + sovShim(uint64(l)) 1934 } 1935 l = len(m.Stderr) 1936 if l > 0 { 1937 n += 1 + l + sovShim(uint64(l)) 1938 } 1939 l = len(m.Checkpoint) 1940 if l > 0 { 1941 n += 1 + l + sovShim(uint64(l)) 1942 } 1943 l = len(m.ParentCheckpoint) 1944 if l > 0 { 1945 n += 1 + l + sovShim(uint64(l)) 1946 } 1947 if m.Options != nil { 1948 l = m.Options.Size() 1949 n += 1 + l + sovShim(uint64(l)) 1950 } 1951 if m.XXX_unrecognized != nil { 1952 n += len(m.XXX_unrecognized) 1953 } 1954 return n 1955} 1956 1957func (m *CreateTaskResponse) Size() (n int) { 1958 if m == nil { 1959 return 0 1960 } 1961 var l int 1962 _ = l 1963 if m.Pid != 0 { 1964 n += 1 + sovShim(uint64(m.Pid)) 1965 } 1966 if m.XXX_unrecognized != nil { 1967 n += len(m.XXX_unrecognized) 1968 } 1969 return n 1970} 1971 1972func (m *DeleteResponse) Size() (n int) { 1973 if m == nil { 1974 return 0 1975 } 1976 var l int 1977 _ = l 1978 if m.Pid != 0 { 1979 n += 1 + sovShim(uint64(m.Pid)) 1980 } 1981 if m.ExitStatus != 0 { 1982 n += 1 + sovShim(uint64(m.ExitStatus)) 1983 } 1984 l = github_com_gogo_protobuf_types.SizeOfStdTime(m.ExitedAt) 1985 n += 1 + l + sovShim(uint64(l)) 1986 if m.XXX_unrecognized != nil { 1987 n += len(m.XXX_unrecognized) 1988 } 1989 return n 1990} 1991 1992func (m *DeleteProcessRequest) Size() (n int) { 1993 if m == nil { 1994 return 0 1995 } 1996 var l int 1997 _ = l 1998 l = len(m.ID) 1999 if l > 0 { 2000 n += 1 + l + sovShim(uint64(l)) 2001 } 2002 if m.XXX_unrecognized != nil { 2003 n += len(m.XXX_unrecognized) 2004 } 2005 return n 2006} 2007 2008func (m *ExecProcessRequest) Size() (n int) { 2009 if m == nil { 2010 return 0 2011 } 2012 var l int 2013 _ = l 2014 l = len(m.ID) 2015 if l > 0 { 2016 n += 1 + l + sovShim(uint64(l)) 2017 } 2018 if m.Terminal { 2019 n += 2 2020 } 2021 l = len(m.Stdin) 2022 if l > 0 { 2023 n += 1 + l + sovShim(uint64(l)) 2024 } 2025 l = len(m.Stdout) 2026 if l > 0 { 2027 n += 1 + l + sovShim(uint64(l)) 2028 } 2029 l = len(m.Stderr) 2030 if l > 0 { 2031 n += 1 + l + sovShim(uint64(l)) 2032 } 2033 if m.Spec != nil { 2034 l = m.Spec.Size() 2035 n += 1 + l + sovShim(uint64(l)) 2036 } 2037 if m.XXX_unrecognized != nil { 2038 n += len(m.XXX_unrecognized) 2039 } 2040 return n 2041} 2042 2043func (m *ExecProcessResponse) Size() (n int) { 2044 if m == nil { 2045 return 0 2046 } 2047 var l int 2048 _ = l 2049 if m.XXX_unrecognized != nil { 2050 n += len(m.XXX_unrecognized) 2051 } 2052 return n 2053} 2054 2055func (m *ResizePtyRequest) Size() (n int) { 2056 if m == nil { 2057 return 0 2058 } 2059 var l int 2060 _ = l 2061 l = len(m.ID) 2062 if l > 0 { 2063 n += 1 + l + sovShim(uint64(l)) 2064 } 2065 if m.Width != 0 { 2066 n += 1 + sovShim(uint64(m.Width)) 2067 } 2068 if m.Height != 0 { 2069 n += 1 + sovShim(uint64(m.Height)) 2070 } 2071 if m.XXX_unrecognized != nil { 2072 n += len(m.XXX_unrecognized) 2073 } 2074 return n 2075} 2076 2077func (m *StateRequest) Size() (n int) { 2078 if m == nil { 2079 return 0 2080 } 2081 var l int 2082 _ = l 2083 l = len(m.ID) 2084 if l > 0 { 2085 n += 1 + l + sovShim(uint64(l)) 2086 } 2087 if m.XXX_unrecognized != nil { 2088 n += len(m.XXX_unrecognized) 2089 } 2090 return n 2091} 2092 2093func (m *StateResponse) Size() (n int) { 2094 if m == nil { 2095 return 0 2096 } 2097 var l int 2098 _ = l 2099 l = len(m.ID) 2100 if l > 0 { 2101 n += 1 + l + sovShim(uint64(l)) 2102 } 2103 l = len(m.Bundle) 2104 if l > 0 { 2105 n += 1 + l + sovShim(uint64(l)) 2106 } 2107 if m.Pid != 0 { 2108 n += 1 + sovShim(uint64(m.Pid)) 2109 } 2110 if m.Status != 0 { 2111 n += 1 + sovShim(uint64(m.Status)) 2112 } 2113 l = len(m.Stdin) 2114 if l > 0 { 2115 n += 1 + l + sovShim(uint64(l)) 2116 } 2117 l = len(m.Stdout) 2118 if l > 0 { 2119 n += 1 + l + sovShim(uint64(l)) 2120 } 2121 l = len(m.Stderr) 2122 if l > 0 { 2123 n += 1 + l + sovShim(uint64(l)) 2124 } 2125 if m.Terminal { 2126 n += 2 2127 } 2128 if m.ExitStatus != 0 { 2129 n += 1 + sovShim(uint64(m.ExitStatus)) 2130 } 2131 l = github_com_gogo_protobuf_types.SizeOfStdTime(m.ExitedAt) 2132 n += 1 + l + sovShim(uint64(l)) 2133 if m.XXX_unrecognized != nil { 2134 n += len(m.XXX_unrecognized) 2135 } 2136 return n 2137} 2138 2139func (m *KillRequest) Size() (n int) { 2140 if m == nil { 2141 return 0 2142 } 2143 var l int 2144 _ = l 2145 l = len(m.ID) 2146 if l > 0 { 2147 n += 1 + l + sovShim(uint64(l)) 2148 } 2149 if m.Signal != 0 { 2150 n += 1 + sovShim(uint64(m.Signal)) 2151 } 2152 if m.All { 2153 n += 2 2154 } 2155 if m.XXX_unrecognized != nil { 2156 n += len(m.XXX_unrecognized) 2157 } 2158 return n 2159} 2160 2161func (m *CloseIORequest) Size() (n int) { 2162 if m == nil { 2163 return 0 2164 } 2165 var l int 2166 _ = l 2167 l = len(m.ID) 2168 if l > 0 { 2169 n += 1 + l + sovShim(uint64(l)) 2170 } 2171 if m.Stdin { 2172 n += 2 2173 } 2174 if m.XXX_unrecognized != nil { 2175 n += len(m.XXX_unrecognized) 2176 } 2177 return n 2178} 2179 2180func (m *ListPidsRequest) Size() (n int) { 2181 if m == nil { 2182 return 0 2183 } 2184 var l int 2185 _ = l 2186 l = len(m.ID) 2187 if l > 0 { 2188 n += 1 + l + sovShim(uint64(l)) 2189 } 2190 if m.XXX_unrecognized != nil { 2191 n += len(m.XXX_unrecognized) 2192 } 2193 return n 2194} 2195 2196func (m *ListPidsResponse) Size() (n int) { 2197 if m == nil { 2198 return 0 2199 } 2200 var l int 2201 _ = l 2202 if len(m.Processes) > 0 { 2203 for _, e := range m.Processes { 2204 l = e.Size() 2205 n += 1 + l + sovShim(uint64(l)) 2206 } 2207 } 2208 if m.XXX_unrecognized != nil { 2209 n += len(m.XXX_unrecognized) 2210 } 2211 return n 2212} 2213 2214func (m *CheckpointTaskRequest) Size() (n int) { 2215 if m == nil { 2216 return 0 2217 } 2218 var l int 2219 _ = l 2220 l = len(m.Path) 2221 if l > 0 { 2222 n += 1 + l + sovShim(uint64(l)) 2223 } 2224 if m.Options != nil { 2225 l = m.Options.Size() 2226 n += 1 + l + sovShim(uint64(l)) 2227 } 2228 if m.XXX_unrecognized != nil { 2229 n += len(m.XXX_unrecognized) 2230 } 2231 return n 2232} 2233 2234func (m *ShimInfoResponse) Size() (n int) { 2235 if m == nil { 2236 return 0 2237 } 2238 var l int 2239 _ = l 2240 if m.ShimPid != 0 { 2241 n += 1 + sovShim(uint64(m.ShimPid)) 2242 } 2243 if m.XXX_unrecognized != nil { 2244 n += len(m.XXX_unrecognized) 2245 } 2246 return n 2247} 2248 2249func (m *UpdateTaskRequest) Size() (n int) { 2250 if m == nil { 2251 return 0 2252 } 2253 var l int 2254 _ = l 2255 if m.Resources != nil { 2256 l = m.Resources.Size() 2257 n += 1 + l + sovShim(uint64(l)) 2258 } 2259 if m.XXX_unrecognized != nil { 2260 n += len(m.XXX_unrecognized) 2261 } 2262 return n 2263} 2264 2265func (m *StartRequest) Size() (n int) { 2266 if m == nil { 2267 return 0 2268 } 2269 var l int 2270 _ = l 2271 l = len(m.ID) 2272 if l > 0 { 2273 n += 1 + l + sovShim(uint64(l)) 2274 } 2275 if m.XXX_unrecognized != nil { 2276 n += len(m.XXX_unrecognized) 2277 } 2278 return n 2279} 2280 2281func (m *StartResponse) Size() (n int) { 2282 if m == nil { 2283 return 0 2284 } 2285 var l int 2286 _ = l 2287 l = len(m.ID) 2288 if l > 0 { 2289 n += 1 + l + sovShim(uint64(l)) 2290 } 2291 if m.Pid != 0 { 2292 n += 1 + sovShim(uint64(m.Pid)) 2293 } 2294 if m.XXX_unrecognized != nil { 2295 n += len(m.XXX_unrecognized) 2296 } 2297 return n 2298} 2299 2300func (m *WaitRequest) Size() (n int) { 2301 if m == nil { 2302 return 0 2303 } 2304 var l int 2305 _ = l 2306 l = len(m.ID) 2307 if l > 0 { 2308 n += 1 + l + sovShim(uint64(l)) 2309 } 2310 if m.XXX_unrecognized != nil { 2311 n += len(m.XXX_unrecognized) 2312 } 2313 return n 2314} 2315 2316func (m *WaitResponse) Size() (n int) { 2317 if m == nil { 2318 return 0 2319 } 2320 var l int 2321 _ = l 2322 if m.ExitStatus != 0 { 2323 n += 1 + sovShim(uint64(m.ExitStatus)) 2324 } 2325 l = github_com_gogo_protobuf_types.SizeOfStdTime(m.ExitedAt) 2326 n += 1 + l + sovShim(uint64(l)) 2327 if m.XXX_unrecognized != nil { 2328 n += len(m.XXX_unrecognized) 2329 } 2330 return n 2331} 2332 2333func sovShim(x uint64) (n int) { 2334 return (math_bits.Len64(x|1) + 6) / 7 2335} 2336func sozShim(x uint64) (n int) { 2337 return sovShim(uint64((x << 1) ^ uint64((int64(x) >> 63)))) 2338} 2339func (this *CreateTaskRequest) String() string { 2340 if this == nil { 2341 return "nil" 2342 } 2343 repeatedStringForRootfs := "[]*Mount{" 2344 for _, f := range this.Rootfs { 2345 repeatedStringForRootfs += strings.Replace(fmt.Sprintf("%v", f), "Mount", "types.Mount", 1) + "," 2346 } 2347 repeatedStringForRootfs += "}" 2348 s := strings.Join([]string{`&CreateTaskRequest{`, 2349 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 2350 `Bundle:` + fmt.Sprintf("%v", this.Bundle) + `,`, 2351 `Runtime:` + fmt.Sprintf("%v", this.Runtime) + `,`, 2352 `Rootfs:` + repeatedStringForRootfs + `,`, 2353 `Terminal:` + fmt.Sprintf("%v", this.Terminal) + `,`, 2354 `Stdin:` + fmt.Sprintf("%v", this.Stdin) + `,`, 2355 `Stdout:` + fmt.Sprintf("%v", this.Stdout) + `,`, 2356 `Stderr:` + fmt.Sprintf("%v", this.Stderr) + `,`, 2357 `Checkpoint:` + fmt.Sprintf("%v", this.Checkpoint) + `,`, 2358 `ParentCheckpoint:` + fmt.Sprintf("%v", this.ParentCheckpoint) + `,`, 2359 `Options:` + strings.Replace(fmt.Sprintf("%v", this.Options), "Any", "types1.Any", 1) + `,`, 2360 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2361 `}`, 2362 }, "") 2363 return s 2364} 2365func (this *CreateTaskResponse) String() string { 2366 if this == nil { 2367 return "nil" 2368 } 2369 s := strings.Join([]string{`&CreateTaskResponse{`, 2370 `Pid:` + fmt.Sprintf("%v", this.Pid) + `,`, 2371 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2372 `}`, 2373 }, "") 2374 return s 2375} 2376func (this *DeleteResponse) String() string { 2377 if this == nil { 2378 return "nil" 2379 } 2380 s := strings.Join([]string{`&DeleteResponse{`, 2381 `Pid:` + fmt.Sprintf("%v", this.Pid) + `,`, 2382 `ExitStatus:` + fmt.Sprintf("%v", this.ExitStatus) + `,`, 2383 `ExitedAt:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.ExitedAt), "Timestamp", "types1.Timestamp", 1), `&`, ``, 1) + `,`, 2384 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2385 `}`, 2386 }, "") 2387 return s 2388} 2389func (this *DeleteProcessRequest) String() string { 2390 if this == nil { 2391 return "nil" 2392 } 2393 s := strings.Join([]string{`&DeleteProcessRequest{`, 2394 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 2395 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2396 `}`, 2397 }, "") 2398 return s 2399} 2400func (this *ExecProcessRequest) String() string { 2401 if this == nil { 2402 return "nil" 2403 } 2404 s := strings.Join([]string{`&ExecProcessRequest{`, 2405 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 2406 `Terminal:` + fmt.Sprintf("%v", this.Terminal) + `,`, 2407 `Stdin:` + fmt.Sprintf("%v", this.Stdin) + `,`, 2408 `Stdout:` + fmt.Sprintf("%v", this.Stdout) + `,`, 2409 `Stderr:` + fmt.Sprintf("%v", this.Stderr) + `,`, 2410 `Spec:` + strings.Replace(fmt.Sprintf("%v", this.Spec), "Any", "types1.Any", 1) + `,`, 2411 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2412 `}`, 2413 }, "") 2414 return s 2415} 2416func (this *ExecProcessResponse) String() string { 2417 if this == nil { 2418 return "nil" 2419 } 2420 s := strings.Join([]string{`&ExecProcessResponse{`, 2421 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2422 `}`, 2423 }, "") 2424 return s 2425} 2426func (this *ResizePtyRequest) String() string { 2427 if this == nil { 2428 return "nil" 2429 } 2430 s := strings.Join([]string{`&ResizePtyRequest{`, 2431 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 2432 `Width:` + fmt.Sprintf("%v", this.Width) + `,`, 2433 `Height:` + fmt.Sprintf("%v", this.Height) + `,`, 2434 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2435 `}`, 2436 }, "") 2437 return s 2438} 2439func (this *StateRequest) String() string { 2440 if this == nil { 2441 return "nil" 2442 } 2443 s := strings.Join([]string{`&StateRequest{`, 2444 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 2445 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2446 `}`, 2447 }, "") 2448 return s 2449} 2450func (this *StateResponse) String() string { 2451 if this == nil { 2452 return "nil" 2453 } 2454 s := strings.Join([]string{`&StateResponse{`, 2455 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 2456 `Bundle:` + fmt.Sprintf("%v", this.Bundle) + `,`, 2457 `Pid:` + fmt.Sprintf("%v", this.Pid) + `,`, 2458 `Status:` + fmt.Sprintf("%v", this.Status) + `,`, 2459 `Stdin:` + fmt.Sprintf("%v", this.Stdin) + `,`, 2460 `Stdout:` + fmt.Sprintf("%v", this.Stdout) + `,`, 2461 `Stderr:` + fmt.Sprintf("%v", this.Stderr) + `,`, 2462 `Terminal:` + fmt.Sprintf("%v", this.Terminal) + `,`, 2463 `ExitStatus:` + fmt.Sprintf("%v", this.ExitStatus) + `,`, 2464 `ExitedAt:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.ExitedAt), "Timestamp", "types1.Timestamp", 1), `&`, ``, 1) + `,`, 2465 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2466 `}`, 2467 }, "") 2468 return s 2469} 2470func (this *KillRequest) String() string { 2471 if this == nil { 2472 return "nil" 2473 } 2474 s := strings.Join([]string{`&KillRequest{`, 2475 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 2476 `Signal:` + fmt.Sprintf("%v", this.Signal) + `,`, 2477 `All:` + fmt.Sprintf("%v", this.All) + `,`, 2478 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2479 `}`, 2480 }, "") 2481 return s 2482} 2483func (this *CloseIORequest) String() string { 2484 if this == nil { 2485 return "nil" 2486 } 2487 s := strings.Join([]string{`&CloseIORequest{`, 2488 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 2489 `Stdin:` + fmt.Sprintf("%v", this.Stdin) + `,`, 2490 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2491 `}`, 2492 }, "") 2493 return s 2494} 2495func (this *ListPidsRequest) String() string { 2496 if this == nil { 2497 return "nil" 2498 } 2499 s := strings.Join([]string{`&ListPidsRequest{`, 2500 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 2501 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2502 `}`, 2503 }, "") 2504 return s 2505} 2506func (this *ListPidsResponse) String() string { 2507 if this == nil { 2508 return "nil" 2509 } 2510 repeatedStringForProcesses := "[]*ProcessInfo{" 2511 for _, f := range this.Processes { 2512 repeatedStringForProcesses += strings.Replace(fmt.Sprintf("%v", f), "ProcessInfo", "task.ProcessInfo", 1) + "," 2513 } 2514 repeatedStringForProcesses += "}" 2515 s := strings.Join([]string{`&ListPidsResponse{`, 2516 `Processes:` + repeatedStringForProcesses + `,`, 2517 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2518 `}`, 2519 }, "") 2520 return s 2521} 2522func (this *CheckpointTaskRequest) String() string { 2523 if this == nil { 2524 return "nil" 2525 } 2526 s := strings.Join([]string{`&CheckpointTaskRequest{`, 2527 `Path:` + fmt.Sprintf("%v", this.Path) + `,`, 2528 `Options:` + strings.Replace(fmt.Sprintf("%v", this.Options), "Any", "types1.Any", 1) + `,`, 2529 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2530 `}`, 2531 }, "") 2532 return s 2533} 2534func (this *ShimInfoResponse) String() string { 2535 if this == nil { 2536 return "nil" 2537 } 2538 s := strings.Join([]string{`&ShimInfoResponse{`, 2539 `ShimPid:` + fmt.Sprintf("%v", this.ShimPid) + `,`, 2540 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2541 `}`, 2542 }, "") 2543 return s 2544} 2545func (this *UpdateTaskRequest) String() string { 2546 if this == nil { 2547 return "nil" 2548 } 2549 s := strings.Join([]string{`&UpdateTaskRequest{`, 2550 `Resources:` + strings.Replace(fmt.Sprintf("%v", this.Resources), "Any", "types1.Any", 1) + `,`, 2551 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2552 `}`, 2553 }, "") 2554 return s 2555} 2556func (this *StartRequest) String() string { 2557 if this == nil { 2558 return "nil" 2559 } 2560 s := strings.Join([]string{`&StartRequest{`, 2561 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 2562 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2563 `}`, 2564 }, "") 2565 return s 2566} 2567func (this *StartResponse) String() string { 2568 if this == nil { 2569 return "nil" 2570 } 2571 s := strings.Join([]string{`&StartResponse{`, 2572 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 2573 `Pid:` + fmt.Sprintf("%v", this.Pid) + `,`, 2574 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2575 `}`, 2576 }, "") 2577 return s 2578} 2579func (this *WaitRequest) String() string { 2580 if this == nil { 2581 return "nil" 2582 } 2583 s := strings.Join([]string{`&WaitRequest{`, 2584 `ID:` + fmt.Sprintf("%v", this.ID) + `,`, 2585 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2586 `}`, 2587 }, "") 2588 return s 2589} 2590func (this *WaitResponse) String() string { 2591 if this == nil { 2592 return "nil" 2593 } 2594 s := strings.Join([]string{`&WaitResponse{`, 2595 `ExitStatus:` + fmt.Sprintf("%v", this.ExitStatus) + `,`, 2596 `ExitedAt:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.ExitedAt), "Timestamp", "types1.Timestamp", 1), `&`, ``, 1) + `,`, 2597 `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`, 2598 `}`, 2599 }, "") 2600 return s 2601} 2602func valueToStringShim(v interface{}) string { 2603 rv := reflect.ValueOf(v) 2604 if rv.IsNil() { 2605 return "nil" 2606 } 2607 pv := reflect.Indirect(rv).Interface() 2608 return fmt.Sprintf("*%v", pv) 2609} 2610 2611type ShimService interface { 2612 State(ctx context.Context, req *StateRequest) (*StateResponse, error) 2613 Create(ctx context.Context, req *CreateTaskRequest) (*CreateTaskResponse, error) 2614 Start(ctx context.Context, req *StartRequest) (*StartResponse, error) 2615 Delete(ctx context.Context, req *types1.Empty) (*DeleteResponse, error) 2616 DeleteProcess(ctx context.Context, req *DeleteProcessRequest) (*DeleteResponse, error) 2617 ListPids(ctx context.Context, req *ListPidsRequest) (*ListPidsResponse, error) 2618 Pause(ctx context.Context, req *types1.Empty) (*types1.Empty, error) 2619 Resume(ctx context.Context, req *types1.Empty) (*types1.Empty, error) 2620 Checkpoint(ctx context.Context, req *CheckpointTaskRequest) (*types1.Empty, error) 2621 Kill(ctx context.Context, req *KillRequest) (*types1.Empty, error) 2622 Exec(ctx context.Context, req *ExecProcessRequest) (*types1.Empty, error) 2623 ResizePty(ctx context.Context, req *ResizePtyRequest) (*types1.Empty, error) 2624 CloseIO(ctx context.Context, req *CloseIORequest) (*types1.Empty, error) 2625 ShimInfo(ctx context.Context, req *types1.Empty) (*ShimInfoResponse, error) 2626 Update(ctx context.Context, req *UpdateTaskRequest) (*types1.Empty, error) 2627 Wait(ctx context.Context, req *WaitRequest) (*WaitResponse, error) 2628} 2629 2630func RegisterShimService(srv *github_com_containerd_ttrpc.Server, svc ShimService) { 2631 srv.Register("containerd.runtime.linux.shim.v1.Shim", map[string]github_com_containerd_ttrpc.Method{ 2632 "State": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2633 var req StateRequest 2634 if err := unmarshal(&req); err != nil { 2635 return nil, err 2636 } 2637 return svc.State(ctx, &req) 2638 }, 2639 "Create": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2640 var req CreateTaskRequest 2641 if err := unmarshal(&req); err != nil { 2642 return nil, err 2643 } 2644 return svc.Create(ctx, &req) 2645 }, 2646 "Start": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2647 var req StartRequest 2648 if err := unmarshal(&req); err != nil { 2649 return nil, err 2650 } 2651 return svc.Start(ctx, &req) 2652 }, 2653 "Delete": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2654 var req types1.Empty 2655 if err := unmarshal(&req); err != nil { 2656 return nil, err 2657 } 2658 return svc.Delete(ctx, &req) 2659 }, 2660 "DeleteProcess": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2661 var req DeleteProcessRequest 2662 if err := unmarshal(&req); err != nil { 2663 return nil, err 2664 } 2665 return svc.DeleteProcess(ctx, &req) 2666 }, 2667 "ListPids": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2668 var req ListPidsRequest 2669 if err := unmarshal(&req); err != nil { 2670 return nil, err 2671 } 2672 return svc.ListPids(ctx, &req) 2673 }, 2674 "Pause": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2675 var req types1.Empty 2676 if err := unmarshal(&req); err != nil { 2677 return nil, err 2678 } 2679 return svc.Pause(ctx, &req) 2680 }, 2681 "Resume": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2682 var req types1.Empty 2683 if err := unmarshal(&req); err != nil { 2684 return nil, err 2685 } 2686 return svc.Resume(ctx, &req) 2687 }, 2688 "Checkpoint": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2689 var req CheckpointTaskRequest 2690 if err := unmarshal(&req); err != nil { 2691 return nil, err 2692 } 2693 return svc.Checkpoint(ctx, &req) 2694 }, 2695 "Kill": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2696 var req KillRequest 2697 if err := unmarshal(&req); err != nil { 2698 return nil, err 2699 } 2700 return svc.Kill(ctx, &req) 2701 }, 2702 "Exec": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2703 var req ExecProcessRequest 2704 if err := unmarshal(&req); err != nil { 2705 return nil, err 2706 } 2707 return svc.Exec(ctx, &req) 2708 }, 2709 "ResizePty": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2710 var req ResizePtyRequest 2711 if err := unmarshal(&req); err != nil { 2712 return nil, err 2713 } 2714 return svc.ResizePty(ctx, &req) 2715 }, 2716 "CloseIO": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2717 var req CloseIORequest 2718 if err := unmarshal(&req); err != nil { 2719 return nil, err 2720 } 2721 return svc.CloseIO(ctx, &req) 2722 }, 2723 "ShimInfo": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2724 var req types1.Empty 2725 if err := unmarshal(&req); err != nil { 2726 return nil, err 2727 } 2728 return svc.ShimInfo(ctx, &req) 2729 }, 2730 "Update": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2731 var req UpdateTaskRequest 2732 if err := unmarshal(&req); err != nil { 2733 return nil, err 2734 } 2735 return svc.Update(ctx, &req) 2736 }, 2737 "Wait": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { 2738 var req WaitRequest 2739 if err := unmarshal(&req); err != nil { 2740 return nil, err 2741 } 2742 return svc.Wait(ctx, &req) 2743 }, 2744 }) 2745} 2746 2747type shimClient struct { 2748 client *github_com_containerd_ttrpc.Client 2749} 2750 2751func NewShimClient(client *github_com_containerd_ttrpc.Client) ShimService { 2752 return &shimClient{ 2753 client: client, 2754 } 2755} 2756 2757func (c *shimClient) State(ctx context.Context, req *StateRequest) (*StateResponse, error) { 2758 var resp StateResponse 2759 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "State", req, &resp); err != nil { 2760 return nil, err 2761 } 2762 return &resp, nil 2763} 2764 2765func (c *shimClient) Create(ctx context.Context, req *CreateTaskRequest) (*CreateTaskResponse, error) { 2766 var resp CreateTaskResponse 2767 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "Create", req, &resp); err != nil { 2768 return nil, err 2769 } 2770 return &resp, nil 2771} 2772 2773func (c *shimClient) Start(ctx context.Context, req *StartRequest) (*StartResponse, error) { 2774 var resp StartResponse 2775 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "Start", req, &resp); err != nil { 2776 return nil, err 2777 } 2778 return &resp, nil 2779} 2780 2781func (c *shimClient) Delete(ctx context.Context, req *types1.Empty) (*DeleteResponse, error) { 2782 var resp DeleteResponse 2783 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "Delete", req, &resp); err != nil { 2784 return nil, err 2785 } 2786 return &resp, nil 2787} 2788 2789func (c *shimClient) DeleteProcess(ctx context.Context, req *DeleteProcessRequest) (*DeleteResponse, error) { 2790 var resp DeleteResponse 2791 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "DeleteProcess", req, &resp); err != nil { 2792 return nil, err 2793 } 2794 return &resp, nil 2795} 2796 2797func (c *shimClient) ListPids(ctx context.Context, req *ListPidsRequest) (*ListPidsResponse, error) { 2798 var resp ListPidsResponse 2799 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "ListPids", req, &resp); err != nil { 2800 return nil, err 2801 } 2802 return &resp, nil 2803} 2804 2805func (c *shimClient) Pause(ctx context.Context, req *types1.Empty) (*types1.Empty, error) { 2806 var resp types1.Empty 2807 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "Pause", req, &resp); err != nil { 2808 return nil, err 2809 } 2810 return &resp, nil 2811} 2812 2813func (c *shimClient) Resume(ctx context.Context, req *types1.Empty) (*types1.Empty, error) { 2814 var resp types1.Empty 2815 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "Resume", req, &resp); err != nil { 2816 return nil, err 2817 } 2818 return &resp, nil 2819} 2820 2821func (c *shimClient) Checkpoint(ctx context.Context, req *CheckpointTaskRequest) (*types1.Empty, error) { 2822 var resp types1.Empty 2823 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "Checkpoint", req, &resp); err != nil { 2824 return nil, err 2825 } 2826 return &resp, nil 2827} 2828 2829func (c *shimClient) Kill(ctx context.Context, req *KillRequest) (*types1.Empty, error) { 2830 var resp types1.Empty 2831 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "Kill", req, &resp); err != nil { 2832 return nil, err 2833 } 2834 return &resp, nil 2835} 2836 2837func (c *shimClient) Exec(ctx context.Context, req *ExecProcessRequest) (*types1.Empty, error) { 2838 var resp types1.Empty 2839 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "Exec", req, &resp); err != nil { 2840 return nil, err 2841 } 2842 return &resp, nil 2843} 2844 2845func (c *shimClient) ResizePty(ctx context.Context, req *ResizePtyRequest) (*types1.Empty, error) { 2846 var resp types1.Empty 2847 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "ResizePty", req, &resp); err != nil { 2848 return nil, err 2849 } 2850 return &resp, nil 2851} 2852 2853func (c *shimClient) CloseIO(ctx context.Context, req *CloseIORequest) (*types1.Empty, error) { 2854 var resp types1.Empty 2855 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "CloseIO", req, &resp); err != nil { 2856 return nil, err 2857 } 2858 return &resp, nil 2859} 2860 2861func (c *shimClient) ShimInfo(ctx context.Context, req *types1.Empty) (*ShimInfoResponse, error) { 2862 var resp ShimInfoResponse 2863 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "ShimInfo", req, &resp); err != nil { 2864 return nil, err 2865 } 2866 return &resp, nil 2867} 2868 2869func (c *shimClient) Update(ctx context.Context, req *UpdateTaskRequest) (*types1.Empty, error) { 2870 var resp types1.Empty 2871 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "Update", req, &resp); err != nil { 2872 return nil, err 2873 } 2874 return &resp, nil 2875} 2876 2877func (c *shimClient) Wait(ctx context.Context, req *WaitRequest) (*WaitResponse, error) { 2878 var resp WaitResponse 2879 if err := c.client.Call(ctx, "containerd.runtime.linux.shim.v1.Shim", "Wait", req, &resp); err != nil { 2880 return nil, err 2881 } 2882 return &resp, nil 2883} 2884func (m *CreateTaskRequest) Unmarshal(dAtA []byte) error { 2885 l := len(dAtA) 2886 iNdEx := 0 2887 for iNdEx < l { 2888 preIndex := iNdEx 2889 var wire uint64 2890 for shift := uint(0); ; shift += 7 { 2891 if shift >= 64 { 2892 return ErrIntOverflowShim 2893 } 2894 if iNdEx >= l { 2895 return io.ErrUnexpectedEOF 2896 } 2897 b := dAtA[iNdEx] 2898 iNdEx++ 2899 wire |= uint64(b&0x7F) << shift 2900 if b < 0x80 { 2901 break 2902 } 2903 } 2904 fieldNum := int32(wire >> 3) 2905 wireType := int(wire & 0x7) 2906 if wireType == 4 { 2907 return fmt.Errorf("proto: CreateTaskRequest: wiretype end group for non-group") 2908 } 2909 if fieldNum <= 0 { 2910 return fmt.Errorf("proto: CreateTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) 2911 } 2912 switch fieldNum { 2913 case 1: 2914 if wireType != 2 { 2915 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 2916 } 2917 var stringLen uint64 2918 for shift := uint(0); ; shift += 7 { 2919 if shift >= 64 { 2920 return ErrIntOverflowShim 2921 } 2922 if iNdEx >= l { 2923 return io.ErrUnexpectedEOF 2924 } 2925 b := dAtA[iNdEx] 2926 iNdEx++ 2927 stringLen |= uint64(b&0x7F) << shift 2928 if b < 0x80 { 2929 break 2930 } 2931 } 2932 intStringLen := int(stringLen) 2933 if intStringLen < 0 { 2934 return ErrInvalidLengthShim 2935 } 2936 postIndex := iNdEx + intStringLen 2937 if postIndex < 0 { 2938 return ErrInvalidLengthShim 2939 } 2940 if postIndex > l { 2941 return io.ErrUnexpectedEOF 2942 } 2943 m.ID = string(dAtA[iNdEx:postIndex]) 2944 iNdEx = postIndex 2945 case 2: 2946 if wireType != 2 { 2947 return fmt.Errorf("proto: wrong wireType = %d for field Bundle", wireType) 2948 } 2949 var stringLen uint64 2950 for shift := uint(0); ; shift += 7 { 2951 if shift >= 64 { 2952 return ErrIntOverflowShim 2953 } 2954 if iNdEx >= l { 2955 return io.ErrUnexpectedEOF 2956 } 2957 b := dAtA[iNdEx] 2958 iNdEx++ 2959 stringLen |= uint64(b&0x7F) << shift 2960 if b < 0x80 { 2961 break 2962 } 2963 } 2964 intStringLen := int(stringLen) 2965 if intStringLen < 0 { 2966 return ErrInvalidLengthShim 2967 } 2968 postIndex := iNdEx + intStringLen 2969 if postIndex < 0 { 2970 return ErrInvalidLengthShim 2971 } 2972 if postIndex > l { 2973 return io.ErrUnexpectedEOF 2974 } 2975 m.Bundle = string(dAtA[iNdEx:postIndex]) 2976 iNdEx = postIndex 2977 case 3: 2978 if wireType != 2 { 2979 return fmt.Errorf("proto: wrong wireType = %d for field Runtime", wireType) 2980 } 2981 var stringLen uint64 2982 for shift := uint(0); ; shift += 7 { 2983 if shift >= 64 { 2984 return ErrIntOverflowShim 2985 } 2986 if iNdEx >= l { 2987 return io.ErrUnexpectedEOF 2988 } 2989 b := dAtA[iNdEx] 2990 iNdEx++ 2991 stringLen |= uint64(b&0x7F) << shift 2992 if b < 0x80 { 2993 break 2994 } 2995 } 2996 intStringLen := int(stringLen) 2997 if intStringLen < 0 { 2998 return ErrInvalidLengthShim 2999 } 3000 postIndex := iNdEx + intStringLen 3001 if postIndex < 0 { 3002 return ErrInvalidLengthShim 3003 } 3004 if postIndex > l { 3005 return io.ErrUnexpectedEOF 3006 } 3007 m.Runtime = string(dAtA[iNdEx:postIndex]) 3008 iNdEx = postIndex 3009 case 4: 3010 if wireType != 2 { 3011 return fmt.Errorf("proto: wrong wireType = %d for field Rootfs", wireType) 3012 } 3013 var msglen int 3014 for shift := uint(0); ; shift += 7 { 3015 if shift >= 64 { 3016 return ErrIntOverflowShim 3017 } 3018 if iNdEx >= l { 3019 return io.ErrUnexpectedEOF 3020 } 3021 b := dAtA[iNdEx] 3022 iNdEx++ 3023 msglen |= int(b&0x7F) << shift 3024 if b < 0x80 { 3025 break 3026 } 3027 } 3028 if msglen < 0 { 3029 return ErrInvalidLengthShim 3030 } 3031 postIndex := iNdEx + msglen 3032 if postIndex < 0 { 3033 return ErrInvalidLengthShim 3034 } 3035 if postIndex > l { 3036 return io.ErrUnexpectedEOF 3037 } 3038 m.Rootfs = append(m.Rootfs, &types.Mount{}) 3039 if err := m.Rootfs[len(m.Rootfs)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 3040 return err 3041 } 3042 iNdEx = postIndex 3043 case 5: 3044 if wireType != 0 { 3045 return fmt.Errorf("proto: wrong wireType = %d for field Terminal", wireType) 3046 } 3047 var v int 3048 for shift := uint(0); ; shift += 7 { 3049 if shift >= 64 { 3050 return ErrIntOverflowShim 3051 } 3052 if iNdEx >= l { 3053 return io.ErrUnexpectedEOF 3054 } 3055 b := dAtA[iNdEx] 3056 iNdEx++ 3057 v |= int(b&0x7F) << shift 3058 if b < 0x80 { 3059 break 3060 } 3061 } 3062 m.Terminal = bool(v != 0) 3063 case 6: 3064 if wireType != 2 { 3065 return fmt.Errorf("proto: wrong wireType = %d for field Stdin", wireType) 3066 } 3067 var stringLen uint64 3068 for shift := uint(0); ; shift += 7 { 3069 if shift >= 64 { 3070 return ErrIntOverflowShim 3071 } 3072 if iNdEx >= l { 3073 return io.ErrUnexpectedEOF 3074 } 3075 b := dAtA[iNdEx] 3076 iNdEx++ 3077 stringLen |= uint64(b&0x7F) << shift 3078 if b < 0x80 { 3079 break 3080 } 3081 } 3082 intStringLen := int(stringLen) 3083 if intStringLen < 0 { 3084 return ErrInvalidLengthShim 3085 } 3086 postIndex := iNdEx + intStringLen 3087 if postIndex < 0 { 3088 return ErrInvalidLengthShim 3089 } 3090 if postIndex > l { 3091 return io.ErrUnexpectedEOF 3092 } 3093 m.Stdin = string(dAtA[iNdEx:postIndex]) 3094 iNdEx = postIndex 3095 case 7: 3096 if wireType != 2 { 3097 return fmt.Errorf("proto: wrong wireType = %d for field Stdout", wireType) 3098 } 3099 var stringLen uint64 3100 for shift := uint(0); ; shift += 7 { 3101 if shift >= 64 { 3102 return ErrIntOverflowShim 3103 } 3104 if iNdEx >= l { 3105 return io.ErrUnexpectedEOF 3106 } 3107 b := dAtA[iNdEx] 3108 iNdEx++ 3109 stringLen |= uint64(b&0x7F) << shift 3110 if b < 0x80 { 3111 break 3112 } 3113 } 3114 intStringLen := int(stringLen) 3115 if intStringLen < 0 { 3116 return ErrInvalidLengthShim 3117 } 3118 postIndex := iNdEx + intStringLen 3119 if postIndex < 0 { 3120 return ErrInvalidLengthShim 3121 } 3122 if postIndex > l { 3123 return io.ErrUnexpectedEOF 3124 } 3125 m.Stdout = string(dAtA[iNdEx:postIndex]) 3126 iNdEx = postIndex 3127 case 8: 3128 if wireType != 2 { 3129 return fmt.Errorf("proto: wrong wireType = %d for field Stderr", wireType) 3130 } 3131 var stringLen uint64 3132 for shift := uint(0); ; shift += 7 { 3133 if shift >= 64 { 3134 return ErrIntOverflowShim 3135 } 3136 if iNdEx >= l { 3137 return io.ErrUnexpectedEOF 3138 } 3139 b := dAtA[iNdEx] 3140 iNdEx++ 3141 stringLen |= uint64(b&0x7F) << shift 3142 if b < 0x80 { 3143 break 3144 } 3145 } 3146 intStringLen := int(stringLen) 3147 if intStringLen < 0 { 3148 return ErrInvalidLengthShim 3149 } 3150 postIndex := iNdEx + intStringLen 3151 if postIndex < 0 { 3152 return ErrInvalidLengthShim 3153 } 3154 if postIndex > l { 3155 return io.ErrUnexpectedEOF 3156 } 3157 m.Stderr = string(dAtA[iNdEx:postIndex]) 3158 iNdEx = postIndex 3159 case 9: 3160 if wireType != 2 { 3161 return fmt.Errorf("proto: wrong wireType = %d for field Checkpoint", wireType) 3162 } 3163 var stringLen uint64 3164 for shift := uint(0); ; shift += 7 { 3165 if shift >= 64 { 3166 return ErrIntOverflowShim 3167 } 3168 if iNdEx >= l { 3169 return io.ErrUnexpectedEOF 3170 } 3171 b := dAtA[iNdEx] 3172 iNdEx++ 3173 stringLen |= uint64(b&0x7F) << shift 3174 if b < 0x80 { 3175 break 3176 } 3177 } 3178 intStringLen := int(stringLen) 3179 if intStringLen < 0 { 3180 return ErrInvalidLengthShim 3181 } 3182 postIndex := iNdEx + intStringLen 3183 if postIndex < 0 { 3184 return ErrInvalidLengthShim 3185 } 3186 if postIndex > l { 3187 return io.ErrUnexpectedEOF 3188 } 3189 m.Checkpoint = string(dAtA[iNdEx:postIndex]) 3190 iNdEx = postIndex 3191 case 10: 3192 if wireType != 2 { 3193 return fmt.Errorf("proto: wrong wireType = %d for field ParentCheckpoint", wireType) 3194 } 3195 var stringLen uint64 3196 for shift := uint(0); ; shift += 7 { 3197 if shift >= 64 { 3198 return ErrIntOverflowShim 3199 } 3200 if iNdEx >= l { 3201 return io.ErrUnexpectedEOF 3202 } 3203 b := dAtA[iNdEx] 3204 iNdEx++ 3205 stringLen |= uint64(b&0x7F) << shift 3206 if b < 0x80 { 3207 break 3208 } 3209 } 3210 intStringLen := int(stringLen) 3211 if intStringLen < 0 { 3212 return ErrInvalidLengthShim 3213 } 3214 postIndex := iNdEx + intStringLen 3215 if postIndex < 0 { 3216 return ErrInvalidLengthShim 3217 } 3218 if postIndex > l { 3219 return io.ErrUnexpectedEOF 3220 } 3221 m.ParentCheckpoint = string(dAtA[iNdEx:postIndex]) 3222 iNdEx = postIndex 3223 case 11: 3224 if wireType != 2 { 3225 return fmt.Errorf("proto: wrong wireType = %d for field Options", wireType) 3226 } 3227 var msglen int 3228 for shift := uint(0); ; shift += 7 { 3229 if shift >= 64 { 3230 return ErrIntOverflowShim 3231 } 3232 if iNdEx >= l { 3233 return io.ErrUnexpectedEOF 3234 } 3235 b := dAtA[iNdEx] 3236 iNdEx++ 3237 msglen |= int(b&0x7F) << shift 3238 if b < 0x80 { 3239 break 3240 } 3241 } 3242 if msglen < 0 { 3243 return ErrInvalidLengthShim 3244 } 3245 postIndex := iNdEx + msglen 3246 if postIndex < 0 { 3247 return ErrInvalidLengthShim 3248 } 3249 if postIndex > l { 3250 return io.ErrUnexpectedEOF 3251 } 3252 if m.Options == nil { 3253 m.Options = &types1.Any{} 3254 } 3255 if err := m.Options.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 3256 return err 3257 } 3258 iNdEx = postIndex 3259 default: 3260 iNdEx = preIndex 3261 skippy, err := skipShim(dAtA[iNdEx:]) 3262 if err != nil { 3263 return err 3264 } 3265 if skippy < 0 { 3266 return ErrInvalidLengthShim 3267 } 3268 if (iNdEx + skippy) < 0 { 3269 return ErrInvalidLengthShim 3270 } 3271 if (iNdEx + skippy) > l { 3272 return io.ErrUnexpectedEOF 3273 } 3274 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 3275 iNdEx += skippy 3276 } 3277 } 3278 3279 if iNdEx > l { 3280 return io.ErrUnexpectedEOF 3281 } 3282 return nil 3283} 3284func (m *CreateTaskResponse) Unmarshal(dAtA []byte) error { 3285 l := len(dAtA) 3286 iNdEx := 0 3287 for iNdEx < l { 3288 preIndex := iNdEx 3289 var wire uint64 3290 for shift := uint(0); ; shift += 7 { 3291 if shift >= 64 { 3292 return ErrIntOverflowShim 3293 } 3294 if iNdEx >= l { 3295 return io.ErrUnexpectedEOF 3296 } 3297 b := dAtA[iNdEx] 3298 iNdEx++ 3299 wire |= uint64(b&0x7F) << shift 3300 if b < 0x80 { 3301 break 3302 } 3303 } 3304 fieldNum := int32(wire >> 3) 3305 wireType := int(wire & 0x7) 3306 if wireType == 4 { 3307 return fmt.Errorf("proto: CreateTaskResponse: wiretype end group for non-group") 3308 } 3309 if fieldNum <= 0 { 3310 return fmt.Errorf("proto: CreateTaskResponse: illegal tag %d (wire type %d)", fieldNum, wire) 3311 } 3312 switch fieldNum { 3313 case 1: 3314 if wireType != 0 { 3315 return fmt.Errorf("proto: wrong wireType = %d for field Pid", wireType) 3316 } 3317 m.Pid = 0 3318 for shift := uint(0); ; shift += 7 { 3319 if shift >= 64 { 3320 return ErrIntOverflowShim 3321 } 3322 if iNdEx >= l { 3323 return io.ErrUnexpectedEOF 3324 } 3325 b := dAtA[iNdEx] 3326 iNdEx++ 3327 m.Pid |= uint32(b&0x7F) << shift 3328 if b < 0x80 { 3329 break 3330 } 3331 } 3332 default: 3333 iNdEx = preIndex 3334 skippy, err := skipShim(dAtA[iNdEx:]) 3335 if err != nil { 3336 return err 3337 } 3338 if skippy < 0 { 3339 return ErrInvalidLengthShim 3340 } 3341 if (iNdEx + skippy) < 0 { 3342 return ErrInvalidLengthShim 3343 } 3344 if (iNdEx + skippy) > l { 3345 return io.ErrUnexpectedEOF 3346 } 3347 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 3348 iNdEx += skippy 3349 } 3350 } 3351 3352 if iNdEx > l { 3353 return io.ErrUnexpectedEOF 3354 } 3355 return nil 3356} 3357func (m *DeleteResponse) Unmarshal(dAtA []byte) error { 3358 l := len(dAtA) 3359 iNdEx := 0 3360 for iNdEx < l { 3361 preIndex := iNdEx 3362 var wire uint64 3363 for shift := uint(0); ; shift += 7 { 3364 if shift >= 64 { 3365 return ErrIntOverflowShim 3366 } 3367 if iNdEx >= l { 3368 return io.ErrUnexpectedEOF 3369 } 3370 b := dAtA[iNdEx] 3371 iNdEx++ 3372 wire |= uint64(b&0x7F) << shift 3373 if b < 0x80 { 3374 break 3375 } 3376 } 3377 fieldNum := int32(wire >> 3) 3378 wireType := int(wire & 0x7) 3379 if wireType == 4 { 3380 return fmt.Errorf("proto: DeleteResponse: wiretype end group for non-group") 3381 } 3382 if fieldNum <= 0 { 3383 return fmt.Errorf("proto: DeleteResponse: illegal tag %d (wire type %d)", fieldNum, wire) 3384 } 3385 switch fieldNum { 3386 case 1: 3387 if wireType != 0 { 3388 return fmt.Errorf("proto: wrong wireType = %d for field Pid", wireType) 3389 } 3390 m.Pid = 0 3391 for shift := uint(0); ; shift += 7 { 3392 if shift >= 64 { 3393 return ErrIntOverflowShim 3394 } 3395 if iNdEx >= l { 3396 return io.ErrUnexpectedEOF 3397 } 3398 b := dAtA[iNdEx] 3399 iNdEx++ 3400 m.Pid |= uint32(b&0x7F) << shift 3401 if b < 0x80 { 3402 break 3403 } 3404 } 3405 case 2: 3406 if wireType != 0 { 3407 return fmt.Errorf("proto: wrong wireType = %d for field ExitStatus", wireType) 3408 } 3409 m.ExitStatus = 0 3410 for shift := uint(0); ; shift += 7 { 3411 if shift >= 64 { 3412 return ErrIntOverflowShim 3413 } 3414 if iNdEx >= l { 3415 return io.ErrUnexpectedEOF 3416 } 3417 b := dAtA[iNdEx] 3418 iNdEx++ 3419 m.ExitStatus |= uint32(b&0x7F) << shift 3420 if b < 0x80 { 3421 break 3422 } 3423 } 3424 case 3: 3425 if wireType != 2 { 3426 return fmt.Errorf("proto: wrong wireType = %d for field ExitedAt", wireType) 3427 } 3428 var msglen int 3429 for shift := uint(0); ; shift += 7 { 3430 if shift >= 64 { 3431 return ErrIntOverflowShim 3432 } 3433 if iNdEx >= l { 3434 return io.ErrUnexpectedEOF 3435 } 3436 b := dAtA[iNdEx] 3437 iNdEx++ 3438 msglen |= int(b&0x7F) << shift 3439 if b < 0x80 { 3440 break 3441 } 3442 } 3443 if msglen < 0 { 3444 return ErrInvalidLengthShim 3445 } 3446 postIndex := iNdEx + msglen 3447 if postIndex < 0 { 3448 return ErrInvalidLengthShim 3449 } 3450 if postIndex > l { 3451 return io.ErrUnexpectedEOF 3452 } 3453 if err := github_com_gogo_protobuf_types.StdTimeUnmarshal(&m.ExitedAt, dAtA[iNdEx:postIndex]); err != nil { 3454 return err 3455 } 3456 iNdEx = postIndex 3457 default: 3458 iNdEx = preIndex 3459 skippy, err := skipShim(dAtA[iNdEx:]) 3460 if err != nil { 3461 return err 3462 } 3463 if skippy < 0 { 3464 return ErrInvalidLengthShim 3465 } 3466 if (iNdEx + skippy) < 0 { 3467 return ErrInvalidLengthShim 3468 } 3469 if (iNdEx + skippy) > l { 3470 return io.ErrUnexpectedEOF 3471 } 3472 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 3473 iNdEx += skippy 3474 } 3475 } 3476 3477 if iNdEx > l { 3478 return io.ErrUnexpectedEOF 3479 } 3480 return nil 3481} 3482func (m *DeleteProcessRequest) Unmarshal(dAtA []byte) error { 3483 l := len(dAtA) 3484 iNdEx := 0 3485 for iNdEx < l { 3486 preIndex := iNdEx 3487 var wire uint64 3488 for shift := uint(0); ; shift += 7 { 3489 if shift >= 64 { 3490 return ErrIntOverflowShim 3491 } 3492 if iNdEx >= l { 3493 return io.ErrUnexpectedEOF 3494 } 3495 b := dAtA[iNdEx] 3496 iNdEx++ 3497 wire |= uint64(b&0x7F) << shift 3498 if b < 0x80 { 3499 break 3500 } 3501 } 3502 fieldNum := int32(wire >> 3) 3503 wireType := int(wire & 0x7) 3504 if wireType == 4 { 3505 return fmt.Errorf("proto: DeleteProcessRequest: wiretype end group for non-group") 3506 } 3507 if fieldNum <= 0 { 3508 return fmt.Errorf("proto: DeleteProcessRequest: illegal tag %d (wire type %d)", fieldNum, wire) 3509 } 3510 switch fieldNum { 3511 case 1: 3512 if wireType != 2 { 3513 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 3514 } 3515 var stringLen uint64 3516 for shift := uint(0); ; shift += 7 { 3517 if shift >= 64 { 3518 return ErrIntOverflowShim 3519 } 3520 if iNdEx >= l { 3521 return io.ErrUnexpectedEOF 3522 } 3523 b := dAtA[iNdEx] 3524 iNdEx++ 3525 stringLen |= uint64(b&0x7F) << shift 3526 if b < 0x80 { 3527 break 3528 } 3529 } 3530 intStringLen := int(stringLen) 3531 if intStringLen < 0 { 3532 return ErrInvalidLengthShim 3533 } 3534 postIndex := iNdEx + intStringLen 3535 if postIndex < 0 { 3536 return ErrInvalidLengthShim 3537 } 3538 if postIndex > l { 3539 return io.ErrUnexpectedEOF 3540 } 3541 m.ID = string(dAtA[iNdEx:postIndex]) 3542 iNdEx = postIndex 3543 default: 3544 iNdEx = preIndex 3545 skippy, err := skipShim(dAtA[iNdEx:]) 3546 if err != nil { 3547 return err 3548 } 3549 if skippy < 0 { 3550 return ErrInvalidLengthShim 3551 } 3552 if (iNdEx + skippy) < 0 { 3553 return ErrInvalidLengthShim 3554 } 3555 if (iNdEx + skippy) > l { 3556 return io.ErrUnexpectedEOF 3557 } 3558 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 3559 iNdEx += skippy 3560 } 3561 } 3562 3563 if iNdEx > l { 3564 return io.ErrUnexpectedEOF 3565 } 3566 return nil 3567} 3568func (m *ExecProcessRequest) Unmarshal(dAtA []byte) error { 3569 l := len(dAtA) 3570 iNdEx := 0 3571 for iNdEx < l { 3572 preIndex := iNdEx 3573 var wire uint64 3574 for shift := uint(0); ; shift += 7 { 3575 if shift >= 64 { 3576 return ErrIntOverflowShim 3577 } 3578 if iNdEx >= l { 3579 return io.ErrUnexpectedEOF 3580 } 3581 b := dAtA[iNdEx] 3582 iNdEx++ 3583 wire |= uint64(b&0x7F) << shift 3584 if b < 0x80 { 3585 break 3586 } 3587 } 3588 fieldNum := int32(wire >> 3) 3589 wireType := int(wire & 0x7) 3590 if wireType == 4 { 3591 return fmt.Errorf("proto: ExecProcessRequest: wiretype end group for non-group") 3592 } 3593 if fieldNum <= 0 { 3594 return fmt.Errorf("proto: ExecProcessRequest: illegal tag %d (wire type %d)", fieldNum, wire) 3595 } 3596 switch fieldNum { 3597 case 1: 3598 if wireType != 2 { 3599 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 3600 } 3601 var stringLen uint64 3602 for shift := uint(0); ; shift += 7 { 3603 if shift >= 64 { 3604 return ErrIntOverflowShim 3605 } 3606 if iNdEx >= l { 3607 return io.ErrUnexpectedEOF 3608 } 3609 b := dAtA[iNdEx] 3610 iNdEx++ 3611 stringLen |= uint64(b&0x7F) << shift 3612 if b < 0x80 { 3613 break 3614 } 3615 } 3616 intStringLen := int(stringLen) 3617 if intStringLen < 0 { 3618 return ErrInvalidLengthShim 3619 } 3620 postIndex := iNdEx + intStringLen 3621 if postIndex < 0 { 3622 return ErrInvalidLengthShim 3623 } 3624 if postIndex > l { 3625 return io.ErrUnexpectedEOF 3626 } 3627 m.ID = string(dAtA[iNdEx:postIndex]) 3628 iNdEx = postIndex 3629 case 2: 3630 if wireType != 0 { 3631 return fmt.Errorf("proto: wrong wireType = %d for field Terminal", wireType) 3632 } 3633 var v int 3634 for shift := uint(0); ; shift += 7 { 3635 if shift >= 64 { 3636 return ErrIntOverflowShim 3637 } 3638 if iNdEx >= l { 3639 return io.ErrUnexpectedEOF 3640 } 3641 b := dAtA[iNdEx] 3642 iNdEx++ 3643 v |= int(b&0x7F) << shift 3644 if b < 0x80 { 3645 break 3646 } 3647 } 3648 m.Terminal = bool(v != 0) 3649 case 3: 3650 if wireType != 2 { 3651 return fmt.Errorf("proto: wrong wireType = %d for field Stdin", wireType) 3652 } 3653 var stringLen uint64 3654 for shift := uint(0); ; shift += 7 { 3655 if shift >= 64 { 3656 return ErrIntOverflowShim 3657 } 3658 if iNdEx >= l { 3659 return io.ErrUnexpectedEOF 3660 } 3661 b := dAtA[iNdEx] 3662 iNdEx++ 3663 stringLen |= uint64(b&0x7F) << shift 3664 if b < 0x80 { 3665 break 3666 } 3667 } 3668 intStringLen := int(stringLen) 3669 if intStringLen < 0 { 3670 return ErrInvalidLengthShim 3671 } 3672 postIndex := iNdEx + intStringLen 3673 if postIndex < 0 { 3674 return ErrInvalidLengthShim 3675 } 3676 if postIndex > l { 3677 return io.ErrUnexpectedEOF 3678 } 3679 m.Stdin = string(dAtA[iNdEx:postIndex]) 3680 iNdEx = postIndex 3681 case 4: 3682 if wireType != 2 { 3683 return fmt.Errorf("proto: wrong wireType = %d for field Stdout", wireType) 3684 } 3685 var stringLen uint64 3686 for shift := uint(0); ; shift += 7 { 3687 if shift >= 64 { 3688 return ErrIntOverflowShim 3689 } 3690 if iNdEx >= l { 3691 return io.ErrUnexpectedEOF 3692 } 3693 b := dAtA[iNdEx] 3694 iNdEx++ 3695 stringLen |= uint64(b&0x7F) << shift 3696 if b < 0x80 { 3697 break 3698 } 3699 } 3700 intStringLen := int(stringLen) 3701 if intStringLen < 0 { 3702 return ErrInvalidLengthShim 3703 } 3704 postIndex := iNdEx + intStringLen 3705 if postIndex < 0 { 3706 return ErrInvalidLengthShim 3707 } 3708 if postIndex > l { 3709 return io.ErrUnexpectedEOF 3710 } 3711 m.Stdout = string(dAtA[iNdEx:postIndex]) 3712 iNdEx = postIndex 3713 case 5: 3714 if wireType != 2 { 3715 return fmt.Errorf("proto: wrong wireType = %d for field Stderr", wireType) 3716 } 3717 var stringLen uint64 3718 for shift := uint(0); ; shift += 7 { 3719 if shift >= 64 { 3720 return ErrIntOverflowShim 3721 } 3722 if iNdEx >= l { 3723 return io.ErrUnexpectedEOF 3724 } 3725 b := dAtA[iNdEx] 3726 iNdEx++ 3727 stringLen |= uint64(b&0x7F) << shift 3728 if b < 0x80 { 3729 break 3730 } 3731 } 3732 intStringLen := int(stringLen) 3733 if intStringLen < 0 { 3734 return ErrInvalidLengthShim 3735 } 3736 postIndex := iNdEx + intStringLen 3737 if postIndex < 0 { 3738 return ErrInvalidLengthShim 3739 } 3740 if postIndex > l { 3741 return io.ErrUnexpectedEOF 3742 } 3743 m.Stderr = string(dAtA[iNdEx:postIndex]) 3744 iNdEx = postIndex 3745 case 6: 3746 if wireType != 2 { 3747 return fmt.Errorf("proto: wrong wireType = %d for field Spec", wireType) 3748 } 3749 var msglen int 3750 for shift := uint(0); ; shift += 7 { 3751 if shift >= 64 { 3752 return ErrIntOverflowShim 3753 } 3754 if iNdEx >= l { 3755 return io.ErrUnexpectedEOF 3756 } 3757 b := dAtA[iNdEx] 3758 iNdEx++ 3759 msglen |= int(b&0x7F) << shift 3760 if b < 0x80 { 3761 break 3762 } 3763 } 3764 if msglen < 0 { 3765 return ErrInvalidLengthShim 3766 } 3767 postIndex := iNdEx + msglen 3768 if postIndex < 0 { 3769 return ErrInvalidLengthShim 3770 } 3771 if postIndex > l { 3772 return io.ErrUnexpectedEOF 3773 } 3774 if m.Spec == nil { 3775 m.Spec = &types1.Any{} 3776 } 3777 if err := m.Spec.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 3778 return err 3779 } 3780 iNdEx = postIndex 3781 default: 3782 iNdEx = preIndex 3783 skippy, err := skipShim(dAtA[iNdEx:]) 3784 if err != nil { 3785 return err 3786 } 3787 if skippy < 0 { 3788 return ErrInvalidLengthShim 3789 } 3790 if (iNdEx + skippy) < 0 { 3791 return ErrInvalidLengthShim 3792 } 3793 if (iNdEx + skippy) > l { 3794 return io.ErrUnexpectedEOF 3795 } 3796 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 3797 iNdEx += skippy 3798 } 3799 } 3800 3801 if iNdEx > l { 3802 return io.ErrUnexpectedEOF 3803 } 3804 return nil 3805} 3806func (m *ExecProcessResponse) Unmarshal(dAtA []byte) error { 3807 l := len(dAtA) 3808 iNdEx := 0 3809 for iNdEx < l { 3810 preIndex := iNdEx 3811 var wire uint64 3812 for shift := uint(0); ; shift += 7 { 3813 if shift >= 64 { 3814 return ErrIntOverflowShim 3815 } 3816 if iNdEx >= l { 3817 return io.ErrUnexpectedEOF 3818 } 3819 b := dAtA[iNdEx] 3820 iNdEx++ 3821 wire |= uint64(b&0x7F) << shift 3822 if b < 0x80 { 3823 break 3824 } 3825 } 3826 fieldNum := int32(wire >> 3) 3827 wireType := int(wire & 0x7) 3828 if wireType == 4 { 3829 return fmt.Errorf("proto: ExecProcessResponse: wiretype end group for non-group") 3830 } 3831 if fieldNum <= 0 { 3832 return fmt.Errorf("proto: ExecProcessResponse: illegal tag %d (wire type %d)", fieldNum, wire) 3833 } 3834 switch fieldNum { 3835 default: 3836 iNdEx = preIndex 3837 skippy, err := skipShim(dAtA[iNdEx:]) 3838 if err != nil { 3839 return err 3840 } 3841 if skippy < 0 { 3842 return ErrInvalidLengthShim 3843 } 3844 if (iNdEx + skippy) < 0 { 3845 return ErrInvalidLengthShim 3846 } 3847 if (iNdEx + skippy) > l { 3848 return io.ErrUnexpectedEOF 3849 } 3850 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 3851 iNdEx += skippy 3852 } 3853 } 3854 3855 if iNdEx > l { 3856 return io.ErrUnexpectedEOF 3857 } 3858 return nil 3859} 3860func (m *ResizePtyRequest) Unmarshal(dAtA []byte) error { 3861 l := len(dAtA) 3862 iNdEx := 0 3863 for iNdEx < l { 3864 preIndex := iNdEx 3865 var wire uint64 3866 for shift := uint(0); ; shift += 7 { 3867 if shift >= 64 { 3868 return ErrIntOverflowShim 3869 } 3870 if iNdEx >= l { 3871 return io.ErrUnexpectedEOF 3872 } 3873 b := dAtA[iNdEx] 3874 iNdEx++ 3875 wire |= uint64(b&0x7F) << shift 3876 if b < 0x80 { 3877 break 3878 } 3879 } 3880 fieldNum := int32(wire >> 3) 3881 wireType := int(wire & 0x7) 3882 if wireType == 4 { 3883 return fmt.Errorf("proto: ResizePtyRequest: wiretype end group for non-group") 3884 } 3885 if fieldNum <= 0 { 3886 return fmt.Errorf("proto: ResizePtyRequest: illegal tag %d (wire type %d)", fieldNum, wire) 3887 } 3888 switch fieldNum { 3889 case 1: 3890 if wireType != 2 { 3891 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 3892 } 3893 var stringLen uint64 3894 for shift := uint(0); ; shift += 7 { 3895 if shift >= 64 { 3896 return ErrIntOverflowShim 3897 } 3898 if iNdEx >= l { 3899 return io.ErrUnexpectedEOF 3900 } 3901 b := dAtA[iNdEx] 3902 iNdEx++ 3903 stringLen |= uint64(b&0x7F) << shift 3904 if b < 0x80 { 3905 break 3906 } 3907 } 3908 intStringLen := int(stringLen) 3909 if intStringLen < 0 { 3910 return ErrInvalidLengthShim 3911 } 3912 postIndex := iNdEx + intStringLen 3913 if postIndex < 0 { 3914 return ErrInvalidLengthShim 3915 } 3916 if postIndex > l { 3917 return io.ErrUnexpectedEOF 3918 } 3919 m.ID = string(dAtA[iNdEx:postIndex]) 3920 iNdEx = postIndex 3921 case 2: 3922 if wireType != 0 { 3923 return fmt.Errorf("proto: wrong wireType = %d for field Width", wireType) 3924 } 3925 m.Width = 0 3926 for shift := uint(0); ; shift += 7 { 3927 if shift >= 64 { 3928 return ErrIntOverflowShim 3929 } 3930 if iNdEx >= l { 3931 return io.ErrUnexpectedEOF 3932 } 3933 b := dAtA[iNdEx] 3934 iNdEx++ 3935 m.Width |= uint32(b&0x7F) << shift 3936 if b < 0x80 { 3937 break 3938 } 3939 } 3940 case 3: 3941 if wireType != 0 { 3942 return fmt.Errorf("proto: wrong wireType = %d for field Height", wireType) 3943 } 3944 m.Height = 0 3945 for shift := uint(0); ; shift += 7 { 3946 if shift >= 64 { 3947 return ErrIntOverflowShim 3948 } 3949 if iNdEx >= l { 3950 return io.ErrUnexpectedEOF 3951 } 3952 b := dAtA[iNdEx] 3953 iNdEx++ 3954 m.Height |= uint32(b&0x7F) << shift 3955 if b < 0x80 { 3956 break 3957 } 3958 } 3959 default: 3960 iNdEx = preIndex 3961 skippy, err := skipShim(dAtA[iNdEx:]) 3962 if err != nil { 3963 return err 3964 } 3965 if skippy < 0 { 3966 return ErrInvalidLengthShim 3967 } 3968 if (iNdEx + skippy) < 0 { 3969 return ErrInvalidLengthShim 3970 } 3971 if (iNdEx + skippy) > l { 3972 return io.ErrUnexpectedEOF 3973 } 3974 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 3975 iNdEx += skippy 3976 } 3977 } 3978 3979 if iNdEx > l { 3980 return io.ErrUnexpectedEOF 3981 } 3982 return nil 3983} 3984func (m *StateRequest) Unmarshal(dAtA []byte) error { 3985 l := len(dAtA) 3986 iNdEx := 0 3987 for iNdEx < l { 3988 preIndex := iNdEx 3989 var wire uint64 3990 for shift := uint(0); ; shift += 7 { 3991 if shift >= 64 { 3992 return ErrIntOverflowShim 3993 } 3994 if iNdEx >= l { 3995 return io.ErrUnexpectedEOF 3996 } 3997 b := dAtA[iNdEx] 3998 iNdEx++ 3999 wire |= uint64(b&0x7F) << shift 4000 if b < 0x80 { 4001 break 4002 } 4003 } 4004 fieldNum := int32(wire >> 3) 4005 wireType := int(wire & 0x7) 4006 if wireType == 4 { 4007 return fmt.Errorf("proto: StateRequest: wiretype end group for non-group") 4008 } 4009 if fieldNum <= 0 { 4010 return fmt.Errorf("proto: StateRequest: illegal tag %d (wire type %d)", fieldNum, wire) 4011 } 4012 switch fieldNum { 4013 case 1: 4014 if wireType != 2 { 4015 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 4016 } 4017 var stringLen uint64 4018 for shift := uint(0); ; shift += 7 { 4019 if shift >= 64 { 4020 return ErrIntOverflowShim 4021 } 4022 if iNdEx >= l { 4023 return io.ErrUnexpectedEOF 4024 } 4025 b := dAtA[iNdEx] 4026 iNdEx++ 4027 stringLen |= uint64(b&0x7F) << shift 4028 if b < 0x80 { 4029 break 4030 } 4031 } 4032 intStringLen := int(stringLen) 4033 if intStringLen < 0 { 4034 return ErrInvalidLengthShim 4035 } 4036 postIndex := iNdEx + intStringLen 4037 if postIndex < 0 { 4038 return ErrInvalidLengthShim 4039 } 4040 if postIndex > l { 4041 return io.ErrUnexpectedEOF 4042 } 4043 m.ID = string(dAtA[iNdEx:postIndex]) 4044 iNdEx = postIndex 4045 default: 4046 iNdEx = preIndex 4047 skippy, err := skipShim(dAtA[iNdEx:]) 4048 if err != nil { 4049 return err 4050 } 4051 if skippy < 0 { 4052 return ErrInvalidLengthShim 4053 } 4054 if (iNdEx + skippy) < 0 { 4055 return ErrInvalidLengthShim 4056 } 4057 if (iNdEx + skippy) > l { 4058 return io.ErrUnexpectedEOF 4059 } 4060 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4061 iNdEx += skippy 4062 } 4063 } 4064 4065 if iNdEx > l { 4066 return io.ErrUnexpectedEOF 4067 } 4068 return nil 4069} 4070func (m *StateResponse) Unmarshal(dAtA []byte) error { 4071 l := len(dAtA) 4072 iNdEx := 0 4073 for iNdEx < l { 4074 preIndex := iNdEx 4075 var wire uint64 4076 for shift := uint(0); ; shift += 7 { 4077 if shift >= 64 { 4078 return ErrIntOverflowShim 4079 } 4080 if iNdEx >= l { 4081 return io.ErrUnexpectedEOF 4082 } 4083 b := dAtA[iNdEx] 4084 iNdEx++ 4085 wire |= uint64(b&0x7F) << shift 4086 if b < 0x80 { 4087 break 4088 } 4089 } 4090 fieldNum := int32(wire >> 3) 4091 wireType := int(wire & 0x7) 4092 if wireType == 4 { 4093 return fmt.Errorf("proto: StateResponse: wiretype end group for non-group") 4094 } 4095 if fieldNum <= 0 { 4096 return fmt.Errorf("proto: StateResponse: illegal tag %d (wire type %d)", fieldNum, wire) 4097 } 4098 switch fieldNum { 4099 case 1: 4100 if wireType != 2 { 4101 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 4102 } 4103 var stringLen uint64 4104 for shift := uint(0); ; shift += 7 { 4105 if shift >= 64 { 4106 return ErrIntOverflowShim 4107 } 4108 if iNdEx >= l { 4109 return io.ErrUnexpectedEOF 4110 } 4111 b := dAtA[iNdEx] 4112 iNdEx++ 4113 stringLen |= uint64(b&0x7F) << shift 4114 if b < 0x80 { 4115 break 4116 } 4117 } 4118 intStringLen := int(stringLen) 4119 if intStringLen < 0 { 4120 return ErrInvalidLengthShim 4121 } 4122 postIndex := iNdEx + intStringLen 4123 if postIndex < 0 { 4124 return ErrInvalidLengthShim 4125 } 4126 if postIndex > l { 4127 return io.ErrUnexpectedEOF 4128 } 4129 m.ID = string(dAtA[iNdEx:postIndex]) 4130 iNdEx = postIndex 4131 case 2: 4132 if wireType != 2 { 4133 return fmt.Errorf("proto: wrong wireType = %d for field Bundle", wireType) 4134 } 4135 var stringLen uint64 4136 for shift := uint(0); ; shift += 7 { 4137 if shift >= 64 { 4138 return ErrIntOverflowShim 4139 } 4140 if iNdEx >= l { 4141 return io.ErrUnexpectedEOF 4142 } 4143 b := dAtA[iNdEx] 4144 iNdEx++ 4145 stringLen |= uint64(b&0x7F) << shift 4146 if b < 0x80 { 4147 break 4148 } 4149 } 4150 intStringLen := int(stringLen) 4151 if intStringLen < 0 { 4152 return ErrInvalidLengthShim 4153 } 4154 postIndex := iNdEx + intStringLen 4155 if postIndex < 0 { 4156 return ErrInvalidLengthShim 4157 } 4158 if postIndex > l { 4159 return io.ErrUnexpectedEOF 4160 } 4161 m.Bundle = string(dAtA[iNdEx:postIndex]) 4162 iNdEx = postIndex 4163 case 3: 4164 if wireType != 0 { 4165 return fmt.Errorf("proto: wrong wireType = %d for field Pid", wireType) 4166 } 4167 m.Pid = 0 4168 for shift := uint(0); ; shift += 7 { 4169 if shift >= 64 { 4170 return ErrIntOverflowShim 4171 } 4172 if iNdEx >= l { 4173 return io.ErrUnexpectedEOF 4174 } 4175 b := dAtA[iNdEx] 4176 iNdEx++ 4177 m.Pid |= uint32(b&0x7F) << shift 4178 if b < 0x80 { 4179 break 4180 } 4181 } 4182 case 4: 4183 if wireType != 0 { 4184 return fmt.Errorf("proto: wrong wireType = %d for field Status", wireType) 4185 } 4186 m.Status = 0 4187 for shift := uint(0); ; shift += 7 { 4188 if shift >= 64 { 4189 return ErrIntOverflowShim 4190 } 4191 if iNdEx >= l { 4192 return io.ErrUnexpectedEOF 4193 } 4194 b := dAtA[iNdEx] 4195 iNdEx++ 4196 m.Status |= task.Status(b&0x7F) << shift 4197 if b < 0x80 { 4198 break 4199 } 4200 } 4201 case 5: 4202 if wireType != 2 { 4203 return fmt.Errorf("proto: wrong wireType = %d for field Stdin", wireType) 4204 } 4205 var stringLen uint64 4206 for shift := uint(0); ; shift += 7 { 4207 if shift >= 64 { 4208 return ErrIntOverflowShim 4209 } 4210 if iNdEx >= l { 4211 return io.ErrUnexpectedEOF 4212 } 4213 b := dAtA[iNdEx] 4214 iNdEx++ 4215 stringLen |= uint64(b&0x7F) << shift 4216 if b < 0x80 { 4217 break 4218 } 4219 } 4220 intStringLen := int(stringLen) 4221 if intStringLen < 0 { 4222 return ErrInvalidLengthShim 4223 } 4224 postIndex := iNdEx + intStringLen 4225 if postIndex < 0 { 4226 return ErrInvalidLengthShim 4227 } 4228 if postIndex > l { 4229 return io.ErrUnexpectedEOF 4230 } 4231 m.Stdin = string(dAtA[iNdEx:postIndex]) 4232 iNdEx = postIndex 4233 case 6: 4234 if wireType != 2 { 4235 return fmt.Errorf("proto: wrong wireType = %d for field Stdout", wireType) 4236 } 4237 var stringLen uint64 4238 for shift := uint(0); ; shift += 7 { 4239 if shift >= 64 { 4240 return ErrIntOverflowShim 4241 } 4242 if iNdEx >= l { 4243 return io.ErrUnexpectedEOF 4244 } 4245 b := dAtA[iNdEx] 4246 iNdEx++ 4247 stringLen |= uint64(b&0x7F) << shift 4248 if b < 0x80 { 4249 break 4250 } 4251 } 4252 intStringLen := int(stringLen) 4253 if intStringLen < 0 { 4254 return ErrInvalidLengthShim 4255 } 4256 postIndex := iNdEx + intStringLen 4257 if postIndex < 0 { 4258 return ErrInvalidLengthShim 4259 } 4260 if postIndex > l { 4261 return io.ErrUnexpectedEOF 4262 } 4263 m.Stdout = string(dAtA[iNdEx:postIndex]) 4264 iNdEx = postIndex 4265 case 7: 4266 if wireType != 2 { 4267 return fmt.Errorf("proto: wrong wireType = %d for field Stderr", wireType) 4268 } 4269 var stringLen uint64 4270 for shift := uint(0); ; shift += 7 { 4271 if shift >= 64 { 4272 return ErrIntOverflowShim 4273 } 4274 if iNdEx >= l { 4275 return io.ErrUnexpectedEOF 4276 } 4277 b := dAtA[iNdEx] 4278 iNdEx++ 4279 stringLen |= uint64(b&0x7F) << shift 4280 if b < 0x80 { 4281 break 4282 } 4283 } 4284 intStringLen := int(stringLen) 4285 if intStringLen < 0 { 4286 return ErrInvalidLengthShim 4287 } 4288 postIndex := iNdEx + intStringLen 4289 if postIndex < 0 { 4290 return ErrInvalidLengthShim 4291 } 4292 if postIndex > l { 4293 return io.ErrUnexpectedEOF 4294 } 4295 m.Stderr = string(dAtA[iNdEx:postIndex]) 4296 iNdEx = postIndex 4297 case 8: 4298 if wireType != 0 { 4299 return fmt.Errorf("proto: wrong wireType = %d for field Terminal", wireType) 4300 } 4301 var v int 4302 for shift := uint(0); ; shift += 7 { 4303 if shift >= 64 { 4304 return ErrIntOverflowShim 4305 } 4306 if iNdEx >= l { 4307 return io.ErrUnexpectedEOF 4308 } 4309 b := dAtA[iNdEx] 4310 iNdEx++ 4311 v |= int(b&0x7F) << shift 4312 if b < 0x80 { 4313 break 4314 } 4315 } 4316 m.Terminal = bool(v != 0) 4317 case 9: 4318 if wireType != 0 { 4319 return fmt.Errorf("proto: wrong wireType = %d for field ExitStatus", wireType) 4320 } 4321 m.ExitStatus = 0 4322 for shift := uint(0); ; shift += 7 { 4323 if shift >= 64 { 4324 return ErrIntOverflowShim 4325 } 4326 if iNdEx >= l { 4327 return io.ErrUnexpectedEOF 4328 } 4329 b := dAtA[iNdEx] 4330 iNdEx++ 4331 m.ExitStatus |= uint32(b&0x7F) << shift 4332 if b < 0x80 { 4333 break 4334 } 4335 } 4336 case 10: 4337 if wireType != 2 { 4338 return fmt.Errorf("proto: wrong wireType = %d for field ExitedAt", wireType) 4339 } 4340 var msglen int 4341 for shift := uint(0); ; shift += 7 { 4342 if shift >= 64 { 4343 return ErrIntOverflowShim 4344 } 4345 if iNdEx >= l { 4346 return io.ErrUnexpectedEOF 4347 } 4348 b := dAtA[iNdEx] 4349 iNdEx++ 4350 msglen |= int(b&0x7F) << shift 4351 if b < 0x80 { 4352 break 4353 } 4354 } 4355 if msglen < 0 { 4356 return ErrInvalidLengthShim 4357 } 4358 postIndex := iNdEx + msglen 4359 if postIndex < 0 { 4360 return ErrInvalidLengthShim 4361 } 4362 if postIndex > l { 4363 return io.ErrUnexpectedEOF 4364 } 4365 if err := github_com_gogo_protobuf_types.StdTimeUnmarshal(&m.ExitedAt, dAtA[iNdEx:postIndex]); err != nil { 4366 return err 4367 } 4368 iNdEx = postIndex 4369 default: 4370 iNdEx = preIndex 4371 skippy, err := skipShim(dAtA[iNdEx:]) 4372 if err != nil { 4373 return err 4374 } 4375 if skippy < 0 { 4376 return ErrInvalidLengthShim 4377 } 4378 if (iNdEx + skippy) < 0 { 4379 return ErrInvalidLengthShim 4380 } 4381 if (iNdEx + skippy) > l { 4382 return io.ErrUnexpectedEOF 4383 } 4384 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4385 iNdEx += skippy 4386 } 4387 } 4388 4389 if iNdEx > l { 4390 return io.ErrUnexpectedEOF 4391 } 4392 return nil 4393} 4394func (m *KillRequest) Unmarshal(dAtA []byte) error { 4395 l := len(dAtA) 4396 iNdEx := 0 4397 for iNdEx < l { 4398 preIndex := iNdEx 4399 var wire uint64 4400 for shift := uint(0); ; shift += 7 { 4401 if shift >= 64 { 4402 return ErrIntOverflowShim 4403 } 4404 if iNdEx >= l { 4405 return io.ErrUnexpectedEOF 4406 } 4407 b := dAtA[iNdEx] 4408 iNdEx++ 4409 wire |= uint64(b&0x7F) << shift 4410 if b < 0x80 { 4411 break 4412 } 4413 } 4414 fieldNum := int32(wire >> 3) 4415 wireType := int(wire & 0x7) 4416 if wireType == 4 { 4417 return fmt.Errorf("proto: KillRequest: wiretype end group for non-group") 4418 } 4419 if fieldNum <= 0 { 4420 return fmt.Errorf("proto: KillRequest: illegal tag %d (wire type %d)", fieldNum, wire) 4421 } 4422 switch fieldNum { 4423 case 1: 4424 if wireType != 2 { 4425 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 4426 } 4427 var stringLen uint64 4428 for shift := uint(0); ; shift += 7 { 4429 if shift >= 64 { 4430 return ErrIntOverflowShim 4431 } 4432 if iNdEx >= l { 4433 return io.ErrUnexpectedEOF 4434 } 4435 b := dAtA[iNdEx] 4436 iNdEx++ 4437 stringLen |= uint64(b&0x7F) << shift 4438 if b < 0x80 { 4439 break 4440 } 4441 } 4442 intStringLen := int(stringLen) 4443 if intStringLen < 0 { 4444 return ErrInvalidLengthShim 4445 } 4446 postIndex := iNdEx + intStringLen 4447 if postIndex < 0 { 4448 return ErrInvalidLengthShim 4449 } 4450 if postIndex > l { 4451 return io.ErrUnexpectedEOF 4452 } 4453 m.ID = string(dAtA[iNdEx:postIndex]) 4454 iNdEx = postIndex 4455 case 2: 4456 if wireType != 0 { 4457 return fmt.Errorf("proto: wrong wireType = %d for field Signal", wireType) 4458 } 4459 m.Signal = 0 4460 for shift := uint(0); ; shift += 7 { 4461 if shift >= 64 { 4462 return ErrIntOverflowShim 4463 } 4464 if iNdEx >= l { 4465 return io.ErrUnexpectedEOF 4466 } 4467 b := dAtA[iNdEx] 4468 iNdEx++ 4469 m.Signal |= uint32(b&0x7F) << shift 4470 if b < 0x80 { 4471 break 4472 } 4473 } 4474 case 3: 4475 if wireType != 0 { 4476 return fmt.Errorf("proto: wrong wireType = %d for field All", wireType) 4477 } 4478 var v int 4479 for shift := uint(0); ; shift += 7 { 4480 if shift >= 64 { 4481 return ErrIntOverflowShim 4482 } 4483 if iNdEx >= l { 4484 return io.ErrUnexpectedEOF 4485 } 4486 b := dAtA[iNdEx] 4487 iNdEx++ 4488 v |= int(b&0x7F) << shift 4489 if b < 0x80 { 4490 break 4491 } 4492 } 4493 m.All = bool(v != 0) 4494 default: 4495 iNdEx = preIndex 4496 skippy, err := skipShim(dAtA[iNdEx:]) 4497 if err != nil { 4498 return err 4499 } 4500 if skippy < 0 { 4501 return ErrInvalidLengthShim 4502 } 4503 if (iNdEx + skippy) < 0 { 4504 return ErrInvalidLengthShim 4505 } 4506 if (iNdEx + skippy) > l { 4507 return io.ErrUnexpectedEOF 4508 } 4509 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4510 iNdEx += skippy 4511 } 4512 } 4513 4514 if iNdEx > l { 4515 return io.ErrUnexpectedEOF 4516 } 4517 return nil 4518} 4519func (m *CloseIORequest) Unmarshal(dAtA []byte) error { 4520 l := len(dAtA) 4521 iNdEx := 0 4522 for iNdEx < l { 4523 preIndex := iNdEx 4524 var wire uint64 4525 for shift := uint(0); ; shift += 7 { 4526 if shift >= 64 { 4527 return ErrIntOverflowShim 4528 } 4529 if iNdEx >= l { 4530 return io.ErrUnexpectedEOF 4531 } 4532 b := dAtA[iNdEx] 4533 iNdEx++ 4534 wire |= uint64(b&0x7F) << shift 4535 if b < 0x80 { 4536 break 4537 } 4538 } 4539 fieldNum := int32(wire >> 3) 4540 wireType := int(wire & 0x7) 4541 if wireType == 4 { 4542 return fmt.Errorf("proto: CloseIORequest: wiretype end group for non-group") 4543 } 4544 if fieldNum <= 0 { 4545 return fmt.Errorf("proto: CloseIORequest: illegal tag %d (wire type %d)", fieldNum, wire) 4546 } 4547 switch fieldNum { 4548 case 1: 4549 if wireType != 2 { 4550 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 4551 } 4552 var stringLen uint64 4553 for shift := uint(0); ; shift += 7 { 4554 if shift >= 64 { 4555 return ErrIntOverflowShim 4556 } 4557 if iNdEx >= l { 4558 return io.ErrUnexpectedEOF 4559 } 4560 b := dAtA[iNdEx] 4561 iNdEx++ 4562 stringLen |= uint64(b&0x7F) << shift 4563 if b < 0x80 { 4564 break 4565 } 4566 } 4567 intStringLen := int(stringLen) 4568 if intStringLen < 0 { 4569 return ErrInvalidLengthShim 4570 } 4571 postIndex := iNdEx + intStringLen 4572 if postIndex < 0 { 4573 return ErrInvalidLengthShim 4574 } 4575 if postIndex > l { 4576 return io.ErrUnexpectedEOF 4577 } 4578 m.ID = string(dAtA[iNdEx:postIndex]) 4579 iNdEx = postIndex 4580 case 2: 4581 if wireType != 0 { 4582 return fmt.Errorf("proto: wrong wireType = %d for field Stdin", wireType) 4583 } 4584 var v int 4585 for shift := uint(0); ; shift += 7 { 4586 if shift >= 64 { 4587 return ErrIntOverflowShim 4588 } 4589 if iNdEx >= l { 4590 return io.ErrUnexpectedEOF 4591 } 4592 b := dAtA[iNdEx] 4593 iNdEx++ 4594 v |= int(b&0x7F) << shift 4595 if b < 0x80 { 4596 break 4597 } 4598 } 4599 m.Stdin = bool(v != 0) 4600 default: 4601 iNdEx = preIndex 4602 skippy, err := skipShim(dAtA[iNdEx:]) 4603 if err != nil { 4604 return err 4605 } 4606 if skippy < 0 { 4607 return ErrInvalidLengthShim 4608 } 4609 if (iNdEx + skippy) < 0 { 4610 return ErrInvalidLengthShim 4611 } 4612 if (iNdEx + skippy) > l { 4613 return io.ErrUnexpectedEOF 4614 } 4615 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4616 iNdEx += skippy 4617 } 4618 } 4619 4620 if iNdEx > l { 4621 return io.ErrUnexpectedEOF 4622 } 4623 return nil 4624} 4625func (m *ListPidsRequest) Unmarshal(dAtA []byte) error { 4626 l := len(dAtA) 4627 iNdEx := 0 4628 for iNdEx < l { 4629 preIndex := iNdEx 4630 var wire uint64 4631 for shift := uint(0); ; shift += 7 { 4632 if shift >= 64 { 4633 return ErrIntOverflowShim 4634 } 4635 if iNdEx >= l { 4636 return io.ErrUnexpectedEOF 4637 } 4638 b := dAtA[iNdEx] 4639 iNdEx++ 4640 wire |= uint64(b&0x7F) << shift 4641 if b < 0x80 { 4642 break 4643 } 4644 } 4645 fieldNum := int32(wire >> 3) 4646 wireType := int(wire & 0x7) 4647 if wireType == 4 { 4648 return fmt.Errorf("proto: ListPidsRequest: wiretype end group for non-group") 4649 } 4650 if fieldNum <= 0 { 4651 return fmt.Errorf("proto: ListPidsRequest: illegal tag %d (wire type %d)", fieldNum, wire) 4652 } 4653 switch fieldNum { 4654 case 1: 4655 if wireType != 2 { 4656 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 4657 } 4658 var stringLen uint64 4659 for shift := uint(0); ; shift += 7 { 4660 if shift >= 64 { 4661 return ErrIntOverflowShim 4662 } 4663 if iNdEx >= l { 4664 return io.ErrUnexpectedEOF 4665 } 4666 b := dAtA[iNdEx] 4667 iNdEx++ 4668 stringLen |= uint64(b&0x7F) << shift 4669 if b < 0x80 { 4670 break 4671 } 4672 } 4673 intStringLen := int(stringLen) 4674 if intStringLen < 0 { 4675 return ErrInvalidLengthShim 4676 } 4677 postIndex := iNdEx + intStringLen 4678 if postIndex < 0 { 4679 return ErrInvalidLengthShim 4680 } 4681 if postIndex > l { 4682 return io.ErrUnexpectedEOF 4683 } 4684 m.ID = string(dAtA[iNdEx:postIndex]) 4685 iNdEx = postIndex 4686 default: 4687 iNdEx = preIndex 4688 skippy, err := skipShim(dAtA[iNdEx:]) 4689 if err != nil { 4690 return err 4691 } 4692 if skippy < 0 { 4693 return ErrInvalidLengthShim 4694 } 4695 if (iNdEx + skippy) < 0 { 4696 return ErrInvalidLengthShim 4697 } 4698 if (iNdEx + skippy) > l { 4699 return io.ErrUnexpectedEOF 4700 } 4701 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4702 iNdEx += skippy 4703 } 4704 } 4705 4706 if iNdEx > l { 4707 return io.ErrUnexpectedEOF 4708 } 4709 return nil 4710} 4711func (m *ListPidsResponse) Unmarshal(dAtA []byte) error { 4712 l := len(dAtA) 4713 iNdEx := 0 4714 for iNdEx < l { 4715 preIndex := iNdEx 4716 var wire uint64 4717 for shift := uint(0); ; shift += 7 { 4718 if shift >= 64 { 4719 return ErrIntOverflowShim 4720 } 4721 if iNdEx >= l { 4722 return io.ErrUnexpectedEOF 4723 } 4724 b := dAtA[iNdEx] 4725 iNdEx++ 4726 wire |= uint64(b&0x7F) << shift 4727 if b < 0x80 { 4728 break 4729 } 4730 } 4731 fieldNum := int32(wire >> 3) 4732 wireType := int(wire & 0x7) 4733 if wireType == 4 { 4734 return fmt.Errorf("proto: ListPidsResponse: wiretype end group for non-group") 4735 } 4736 if fieldNum <= 0 { 4737 return fmt.Errorf("proto: ListPidsResponse: illegal tag %d (wire type %d)", fieldNum, wire) 4738 } 4739 switch fieldNum { 4740 case 1: 4741 if wireType != 2 { 4742 return fmt.Errorf("proto: wrong wireType = %d for field Processes", wireType) 4743 } 4744 var msglen int 4745 for shift := uint(0); ; shift += 7 { 4746 if shift >= 64 { 4747 return ErrIntOverflowShim 4748 } 4749 if iNdEx >= l { 4750 return io.ErrUnexpectedEOF 4751 } 4752 b := dAtA[iNdEx] 4753 iNdEx++ 4754 msglen |= int(b&0x7F) << shift 4755 if b < 0x80 { 4756 break 4757 } 4758 } 4759 if msglen < 0 { 4760 return ErrInvalidLengthShim 4761 } 4762 postIndex := iNdEx + msglen 4763 if postIndex < 0 { 4764 return ErrInvalidLengthShim 4765 } 4766 if postIndex > l { 4767 return io.ErrUnexpectedEOF 4768 } 4769 m.Processes = append(m.Processes, &task.ProcessInfo{}) 4770 if err := m.Processes[len(m.Processes)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 4771 return err 4772 } 4773 iNdEx = postIndex 4774 default: 4775 iNdEx = preIndex 4776 skippy, err := skipShim(dAtA[iNdEx:]) 4777 if err != nil { 4778 return err 4779 } 4780 if skippy < 0 { 4781 return ErrInvalidLengthShim 4782 } 4783 if (iNdEx + skippy) < 0 { 4784 return ErrInvalidLengthShim 4785 } 4786 if (iNdEx + skippy) > l { 4787 return io.ErrUnexpectedEOF 4788 } 4789 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4790 iNdEx += skippy 4791 } 4792 } 4793 4794 if iNdEx > l { 4795 return io.ErrUnexpectedEOF 4796 } 4797 return nil 4798} 4799func (m *CheckpointTaskRequest) Unmarshal(dAtA []byte) error { 4800 l := len(dAtA) 4801 iNdEx := 0 4802 for iNdEx < l { 4803 preIndex := iNdEx 4804 var wire uint64 4805 for shift := uint(0); ; shift += 7 { 4806 if shift >= 64 { 4807 return ErrIntOverflowShim 4808 } 4809 if iNdEx >= l { 4810 return io.ErrUnexpectedEOF 4811 } 4812 b := dAtA[iNdEx] 4813 iNdEx++ 4814 wire |= uint64(b&0x7F) << shift 4815 if b < 0x80 { 4816 break 4817 } 4818 } 4819 fieldNum := int32(wire >> 3) 4820 wireType := int(wire & 0x7) 4821 if wireType == 4 { 4822 return fmt.Errorf("proto: CheckpointTaskRequest: wiretype end group for non-group") 4823 } 4824 if fieldNum <= 0 { 4825 return fmt.Errorf("proto: CheckpointTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) 4826 } 4827 switch fieldNum { 4828 case 1: 4829 if wireType != 2 { 4830 return fmt.Errorf("proto: wrong wireType = %d for field Path", wireType) 4831 } 4832 var stringLen uint64 4833 for shift := uint(0); ; shift += 7 { 4834 if shift >= 64 { 4835 return ErrIntOverflowShim 4836 } 4837 if iNdEx >= l { 4838 return io.ErrUnexpectedEOF 4839 } 4840 b := dAtA[iNdEx] 4841 iNdEx++ 4842 stringLen |= uint64(b&0x7F) << shift 4843 if b < 0x80 { 4844 break 4845 } 4846 } 4847 intStringLen := int(stringLen) 4848 if intStringLen < 0 { 4849 return ErrInvalidLengthShim 4850 } 4851 postIndex := iNdEx + intStringLen 4852 if postIndex < 0 { 4853 return ErrInvalidLengthShim 4854 } 4855 if postIndex > l { 4856 return io.ErrUnexpectedEOF 4857 } 4858 m.Path = string(dAtA[iNdEx:postIndex]) 4859 iNdEx = postIndex 4860 case 2: 4861 if wireType != 2 { 4862 return fmt.Errorf("proto: wrong wireType = %d for field Options", wireType) 4863 } 4864 var msglen int 4865 for shift := uint(0); ; shift += 7 { 4866 if shift >= 64 { 4867 return ErrIntOverflowShim 4868 } 4869 if iNdEx >= l { 4870 return io.ErrUnexpectedEOF 4871 } 4872 b := dAtA[iNdEx] 4873 iNdEx++ 4874 msglen |= int(b&0x7F) << shift 4875 if b < 0x80 { 4876 break 4877 } 4878 } 4879 if msglen < 0 { 4880 return ErrInvalidLengthShim 4881 } 4882 postIndex := iNdEx + msglen 4883 if postIndex < 0 { 4884 return ErrInvalidLengthShim 4885 } 4886 if postIndex > l { 4887 return io.ErrUnexpectedEOF 4888 } 4889 if m.Options == nil { 4890 m.Options = &types1.Any{} 4891 } 4892 if err := m.Options.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 4893 return err 4894 } 4895 iNdEx = postIndex 4896 default: 4897 iNdEx = preIndex 4898 skippy, err := skipShim(dAtA[iNdEx:]) 4899 if err != nil { 4900 return err 4901 } 4902 if skippy < 0 { 4903 return ErrInvalidLengthShim 4904 } 4905 if (iNdEx + skippy) < 0 { 4906 return ErrInvalidLengthShim 4907 } 4908 if (iNdEx + skippy) > l { 4909 return io.ErrUnexpectedEOF 4910 } 4911 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4912 iNdEx += skippy 4913 } 4914 } 4915 4916 if iNdEx > l { 4917 return io.ErrUnexpectedEOF 4918 } 4919 return nil 4920} 4921func (m *ShimInfoResponse) Unmarshal(dAtA []byte) error { 4922 l := len(dAtA) 4923 iNdEx := 0 4924 for iNdEx < l { 4925 preIndex := iNdEx 4926 var wire uint64 4927 for shift := uint(0); ; shift += 7 { 4928 if shift >= 64 { 4929 return ErrIntOverflowShim 4930 } 4931 if iNdEx >= l { 4932 return io.ErrUnexpectedEOF 4933 } 4934 b := dAtA[iNdEx] 4935 iNdEx++ 4936 wire |= uint64(b&0x7F) << shift 4937 if b < 0x80 { 4938 break 4939 } 4940 } 4941 fieldNum := int32(wire >> 3) 4942 wireType := int(wire & 0x7) 4943 if wireType == 4 { 4944 return fmt.Errorf("proto: ShimInfoResponse: wiretype end group for non-group") 4945 } 4946 if fieldNum <= 0 { 4947 return fmt.Errorf("proto: ShimInfoResponse: illegal tag %d (wire type %d)", fieldNum, wire) 4948 } 4949 switch fieldNum { 4950 case 1: 4951 if wireType != 0 { 4952 return fmt.Errorf("proto: wrong wireType = %d for field ShimPid", wireType) 4953 } 4954 m.ShimPid = 0 4955 for shift := uint(0); ; shift += 7 { 4956 if shift >= 64 { 4957 return ErrIntOverflowShim 4958 } 4959 if iNdEx >= l { 4960 return io.ErrUnexpectedEOF 4961 } 4962 b := dAtA[iNdEx] 4963 iNdEx++ 4964 m.ShimPid |= uint32(b&0x7F) << shift 4965 if b < 0x80 { 4966 break 4967 } 4968 } 4969 default: 4970 iNdEx = preIndex 4971 skippy, err := skipShim(dAtA[iNdEx:]) 4972 if err != nil { 4973 return err 4974 } 4975 if skippy < 0 { 4976 return ErrInvalidLengthShim 4977 } 4978 if (iNdEx + skippy) < 0 { 4979 return ErrInvalidLengthShim 4980 } 4981 if (iNdEx + skippy) > l { 4982 return io.ErrUnexpectedEOF 4983 } 4984 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 4985 iNdEx += skippy 4986 } 4987 } 4988 4989 if iNdEx > l { 4990 return io.ErrUnexpectedEOF 4991 } 4992 return nil 4993} 4994func (m *UpdateTaskRequest) Unmarshal(dAtA []byte) error { 4995 l := len(dAtA) 4996 iNdEx := 0 4997 for iNdEx < l { 4998 preIndex := iNdEx 4999 var wire uint64 5000 for shift := uint(0); ; shift += 7 { 5001 if shift >= 64 { 5002 return ErrIntOverflowShim 5003 } 5004 if iNdEx >= l { 5005 return io.ErrUnexpectedEOF 5006 } 5007 b := dAtA[iNdEx] 5008 iNdEx++ 5009 wire |= uint64(b&0x7F) << shift 5010 if b < 0x80 { 5011 break 5012 } 5013 } 5014 fieldNum := int32(wire >> 3) 5015 wireType := int(wire & 0x7) 5016 if wireType == 4 { 5017 return fmt.Errorf("proto: UpdateTaskRequest: wiretype end group for non-group") 5018 } 5019 if fieldNum <= 0 { 5020 return fmt.Errorf("proto: UpdateTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) 5021 } 5022 switch fieldNum { 5023 case 1: 5024 if wireType != 2 { 5025 return fmt.Errorf("proto: wrong wireType = %d for field Resources", wireType) 5026 } 5027 var msglen int 5028 for shift := uint(0); ; shift += 7 { 5029 if shift >= 64 { 5030 return ErrIntOverflowShim 5031 } 5032 if iNdEx >= l { 5033 return io.ErrUnexpectedEOF 5034 } 5035 b := dAtA[iNdEx] 5036 iNdEx++ 5037 msglen |= int(b&0x7F) << shift 5038 if b < 0x80 { 5039 break 5040 } 5041 } 5042 if msglen < 0 { 5043 return ErrInvalidLengthShim 5044 } 5045 postIndex := iNdEx + msglen 5046 if postIndex < 0 { 5047 return ErrInvalidLengthShim 5048 } 5049 if postIndex > l { 5050 return io.ErrUnexpectedEOF 5051 } 5052 if m.Resources == nil { 5053 m.Resources = &types1.Any{} 5054 } 5055 if err := m.Resources.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 5056 return err 5057 } 5058 iNdEx = postIndex 5059 default: 5060 iNdEx = preIndex 5061 skippy, err := skipShim(dAtA[iNdEx:]) 5062 if err != nil { 5063 return err 5064 } 5065 if skippy < 0 { 5066 return ErrInvalidLengthShim 5067 } 5068 if (iNdEx + skippy) < 0 { 5069 return ErrInvalidLengthShim 5070 } 5071 if (iNdEx + skippy) > l { 5072 return io.ErrUnexpectedEOF 5073 } 5074 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5075 iNdEx += skippy 5076 } 5077 } 5078 5079 if iNdEx > l { 5080 return io.ErrUnexpectedEOF 5081 } 5082 return nil 5083} 5084func (m *StartRequest) Unmarshal(dAtA []byte) error { 5085 l := len(dAtA) 5086 iNdEx := 0 5087 for iNdEx < l { 5088 preIndex := iNdEx 5089 var wire uint64 5090 for shift := uint(0); ; shift += 7 { 5091 if shift >= 64 { 5092 return ErrIntOverflowShim 5093 } 5094 if iNdEx >= l { 5095 return io.ErrUnexpectedEOF 5096 } 5097 b := dAtA[iNdEx] 5098 iNdEx++ 5099 wire |= uint64(b&0x7F) << shift 5100 if b < 0x80 { 5101 break 5102 } 5103 } 5104 fieldNum := int32(wire >> 3) 5105 wireType := int(wire & 0x7) 5106 if wireType == 4 { 5107 return fmt.Errorf("proto: StartRequest: wiretype end group for non-group") 5108 } 5109 if fieldNum <= 0 { 5110 return fmt.Errorf("proto: StartRequest: illegal tag %d (wire type %d)", fieldNum, wire) 5111 } 5112 switch fieldNum { 5113 case 1: 5114 if wireType != 2 { 5115 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 5116 } 5117 var stringLen uint64 5118 for shift := uint(0); ; shift += 7 { 5119 if shift >= 64 { 5120 return ErrIntOverflowShim 5121 } 5122 if iNdEx >= l { 5123 return io.ErrUnexpectedEOF 5124 } 5125 b := dAtA[iNdEx] 5126 iNdEx++ 5127 stringLen |= uint64(b&0x7F) << shift 5128 if b < 0x80 { 5129 break 5130 } 5131 } 5132 intStringLen := int(stringLen) 5133 if intStringLen < 0 { 5134 return ErrInvalidLengthShim 5135 } 5136 postIndex := iNdEx + intStringLen 5137 if postIndex < 0 { 5138 return ErrInvalidLengthShim 5139 } 5140 if postIndex > l { 5141 return io.ErrUnexpectedEOF 5142 } 5143 m.ID = string(dAtA[iNdEx:postIndex]) 5144 iNdEx = postIndex 5145 default: 5146 iNdEx = preIndex 5147 skippy, err := skipShim(dAtA[iNdEx:]) 5148 if err != nil { 5149 return err 5150 } 5151 if skippy < 0 { 5152 return ErrInvalidLengthShim 5153 } 5154 if (iNdEx + skippy) < 0 { 5155 return ErrInvalidLengthShim 5156 } 5157 if (iNdEx + skippy) > l { 5158 return io.ErrUnexpectedEOF 5159 } 5160 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5161 iNdEx += skippy 5162 } 5163 } 5164 5165 if iNdEx > l { 5166 return io.ErrUnexpectedEOF 5167 } 5168 return nil 5169} 5170func (m *StartResponse) Unmarshal(dAtA []byte) error { 5171 l := len(dAtA) 5172 iNdEx := 0 5173 for iNdEx < l { 5174 preIndex := iNdEx 5175 var wire uint64 5176 for shift := uint(0); ; shift += 7 { 5177 if shift >= 64 { 5178 return ErrIntOverflowShim 5179 } 5180 if iNdEx >= l { 5181 return io.ErrUnexpectedEOF 5182 } 5183 b := dAtA[iNdEx] 5184 iNdEx++ 5185 wire |= uint64(b&0x7F) << shift 5186 if b < 0x80 { 5187 break 5188 } 5189 } 5190 fieldNum := int32(wire >> 3) 5191 wireType := int(wire & 0x7) 5192 if wireType == 4 { 5193 return fmt.Errorf("proto: StartResponse: wiretype end group for non-group") 5194 } 5195 if fieldNum <= 0 { 5196 return fmt.Errorf("proto: StartResponse: illegal tag %d (wire type %d)", fieldNum, wire) 5197 } 5198 switch fieldNum { 5199 case 1: 5200 if wireType != 2 { 5201 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 5202 } 5203 var stringLen uint64 5204 for shift := uint(0); ; shift += 7 { 5205 if shift >= 64 { 5206 return ErrIntOverflowShim 5207 } 5208 if iNdEx >= l { 5209 return io.ErrUnexpectedEOF 5210 } 5211 b := dAtA[iNdEx] 5212 iNdEx++ 5213 stringLen |= uint64(b&0x7F) << shift 5214 if b < 0x80 { 5215 break 5216 } 5217 } 5218 intStringLen := int(stringLen) 5219 if intStringLen < 0 { 5220 return ErrInvalidLengthShim 5221 } 5222 postIndex := iNdEx + intStringLen 5223 if postIndex < 0 { 5224 return ErrInvalidLengthShim 5225 } 5226 if postIndex > l { 5227 return io.ErrUnexpectedEOF 5228 } 5229 m.ID = string(dAtA[iNdEx:postIndex]) 5230 iNdEx = postIndex 5231 case 2: 5232 if wireType != 0 { 5233 return fmt.Errorf("proto: wrong wireType = %d for field Pid", wireType) 5234 } 5235 m.Pid = 0 5236 for shift := uint(0); ; shift += 7 { 5237 if shift >= 64 { 5238 return ErrIntOverflowShim 5239 } 5240 if iNdEx >= l { 5241 return io.ErrUnexpectedEOF 5242 } 5243 b := dAtA[iNdEx] 5244 iNdEx++ 5245 m.Pid |= uint32(b&0x7F) << shift 5246 if b < 0x80 { 5247 break 5248 } 5249 } 5250 default: 5251 iNdEx = preIndex 5252 skippy, err := skipShim(dAtA[iNdEx:]) 5253 if err != nil { 5254 return err 5255 } 5256 if skippy < 0 { 5257 return ErrInvalidLengthShim 5258 } 5259 if (iNdEx + skippy) < 0 { 5260 return ErrInvalidLengthShim 5261 } 5262 if (iNdEx + skippy) > l { 5263 return io.ErrUnexpectedEOF 5264 } 5265 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5266 iNdEx += skippy 5267 } 5268 } 5269 5270 if iNdEx > l { 5271 return io.ErrUnexpectedEOF 5272 } 5273 return nil 5274} 5275func (m *WaitRequest) Unmarshal(dAtA []byte) error { 5276 l := len(dAtA) 5277 iNdEx := 0 5278 for iNdEx < l { 5279 preIndex := iNdEx 5280 var wire uint64 5281 for shift := uint(0); ; shift += 7 { 5282 if shift >= 64 { 5283 return ErrIntOverflowShim 5284 } 5285 if iNdEx >= l { 5286 return io.ErrUnexpectedEOF 5287 } 5288 b := dAtA[iNdEx] 5289 iNdEx++ 5290 wire |= uint64(b&0x7F) << shift 5291 if b < 0x80 { 5292 break 5293 } 5294 } 5295 fieldNum := int32(wire >> 3) 5296 wireType := int(wire & 0x7) 5297 if wireType == 4 { 5298 return fmt.Errorf("proto: WaitRequest: wiretype end group for non-group") 5299 } 5300 if fieldNum <= 0 { 5301 return fmt.Errorf("proto: WaitRequest: illegal tag %d (wire type %d)", fieldNum, wire) 5302 } 5303 switch fieldNum { 5304 case 1: 5305 if wireType != 2 { 5306 return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) 5307 } 5308 var stringLen uint64 5309 for shift := uint(0); ; shift += 7 { 5310 if shift >= 64 { 5311 return ErrIntOverflowShim 5312 } 5313 if iNdEx >= l { 5314 return io.ErrUnexpectedEOF 5315 } 5316 b := dAtA[iNdEx] 5317 iNdEx++ 5318 stringLen |= uint64(b&0x7F) << shift 5319 if b < 0x80 { 5320 break 5321 } 5322 } 5323 intStringLen := int(stringLen) 5324 if intStringLen < 0 { 5325 return ErrInvalidLengthShim 5326 } 5327 postIndex := iNdEx + intStringLen 5328 if postIndex < 0 { 5329 return ErrInvalidLengthShim 5330 } 5331 if postIndex > l { 5332 return io.ErrUnexpectedEOF 5333 } 5334 m.ID = string(dAtA[iNdEx:postIndex]) 5335 iNdEx = postIndex 5336 default: 5337 iNdEx = preIndex 5338 skippy, err := skipShim(dAtA[iNdEx:]) 5339 if err != nil { 5340 return err 5341 } 5342 if skippy < 0 { 5343 return ErrInvalidLengthShim 5344 } 5345 if (iNdEx + skippy) < 0 { 5346 return ErrInvalidLengthShim 5347 } 5348 if (iNdEx + skippy) > l { 5349 return io.ErrUnexpectedEOF 5350 } 5351 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5352 iNdEx += skippy 5353 } 5354 } 5355 5356 if iNdEx > l { 5357 return io.ErrUnexpectedEOF 5358 } 5359 return nil 5360} 5361func (m *WaitResponse) Unmarshal(dAtA []byte) error { 5362 l := len(dAtA) 5363 iNdEx := 0 5364 for iNdEx < l { 5365 preIndex := iNdEx 5366 var wire uint64 5367 for shift := uint(0); ; shift += 7 { 5368 if shift >= 64 { 5369 return ErrIntOverflowShim 5370 } 5371 if iNdEx >= l { 5372 return io.ErrUnexpectedEOF 5373 } 5374 b := dAtA[iNdEx] 5375 iNdEx++ 5376 wire |= uint64(b&0x7F) << shift 5377 if b < 0x80 { 5378 break 5379 } 5380 } 5381 fieldNum := int32(wire >> 3) 5382 wireType := int(wire & 0x7) 5383 if wireType == 4 { 5384 return fmt.Errorf("proto: WaitResponse: wiretype end group for non-group") 5385 } 5386 if fieldNum <= 0 { 5387 return fmt.Errorf("proto: WaitResponse: illegal tag %d (wire type %d)", fieldNum, wire) 5388 } 5389 switch fieldNum { 5390 case 1: 5391 if wireType != 0 { 5392 return fmt.Errorf("proto: wrong wireType = %d for field ExitStatus", wireType) 5393 } 5394 m.ExitStatus = 0 5395 for shift := uint(0); ; shift += 7 { 5396 if shift >= 64 { 5397 return ErrIntOverflowShim 5398 } 5399 if iNdEx >= l { 5400 return io.ErrUnexpectedEOF 5401 } 5402 b := dAtA[iNdEx] 5403 iNdEx++ 5404 m.ExitStatus |= uint32(b&0x7F) << shift 5405 if b < 0x80 { 5406 break 5407 } 5408 } 5409 case 2: 5410 if wireType != 2 { 5411 return fmt.Errorf("proto: wrong wireType = %d for field ExitedAt", wireType) 5412 } 5413 var msglen int 5414 for shift := uint(0); ; shift += 7 { 5415 if shift >= 64 { 5416 return ErrIntOverflowShim 5417 } 5418 if iNdEx >= l { 5419 return io.ErrUnexpectedEOF 5420 } 5421 b := dAtA[iNdEx] 5422 iNdEx++ 5423 msglen |= int(b&0x7F) << shift 5424 if b < 0x80 { 5425 break 5426 } 5427 } 5428 if msglen < 0 { 5429 return ErrInvalidLengthShim 5430 } 5431 postIndex := iNdEx + msglen 5432 if postIndex < 0 { 5433 return ErrInvalidLengthShim 5434 } 5435 if postIndex > l { 5436 return io.ErrUnexpectedEOF 5437 } 5438 if err := github_com_gogo_protobuf_types.StdTimeUnmarshal(&m.ExitedAt, dAtA[iNdEx:postIndex]); err != nil { 5439 return err 5440 } 5441 iNdEx = postIndex 5442 default: 5443 iNdEx = preIndex 5444 skippy, err := skipShim(dAtA[iNdEx:]) 5445 if err != nil { 5446 return err 5447 } 5448 if skippy < 0 { 5449 return ErrInvalidLengthShim 5450 } 5451 if (iNdEx + skippy) < 0 { 5452 return ErrInvalidLengthShim 5453 } 5454 if (iNdEx + skippy) > l { 5455 return io.ErrUnexpectedEOF 5456 } 5457 m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) 5458 iNdEx += skippy 5459 } 5460 } 5461 5462 if iNdEx > l { 5463 return io.ErrUnexpectedEOF 5464 } 5465 return nil 5466} 5467func skipShim(dAtA []byte) (n int, err error) { 5468 l := len(dAtA) 5469 iNdEx := 0 5470 depth := 0 5471 for iNdEx < l { 5472 var wire uint64 5473 for shift := uint(0); ; shift += 7 { 5474 if shift >= 64 { 5475 return 0, ErrIntOverflowShim 5476 } 5477 if iNdEx >= l { 5478 return 0, io.ErrUnexpectedEOF 5479 } 5480 b := dAtA[iNdEx] 5481 iNdEx++ 5482 wire |= (uint64(b) & 0x7F) << shift 5483 if b < 0x80 { 5484 break 5485 } 5486 } 5487 wireType := int(wire & 0x7) 5488 switch wireType { 5489 case 0: 5490 for shift := uint(0); ; shift += 7 { 5491 if shift >= 64 { 5492 return 0, ErrIntOverflowShim 5493 } 5494 if iNdEx >= l { 5495 return 0, io.ErrUnexpectedEOF 5496 } 5497 iNdEx++ 5498 if dAtA[iNdEx-1] < 0x80 { 5499 break 5500 } 5501 } 5502 case 1: 5503 iNdEx += 8 5504 case 2: 5505 var length int 5506 for shift := uint(0); ; shift += 7 { 5507 if shift >= 64 { 5508 return 0, ErrIntOverflowShim 5509 } 5510 if iNdEx >= l { 5511 return 0, io.ErrUnexpectedEOF 5512 } 5513 b := dAtA[iNdEx] 5514 iNdEx++ 5515 length |= (int(b) & 0x7F) << shift 5516 if b < 0x80 { 5517 break 5518 } 5519 } 5520 if length < 0 { 5521 return 0, ErrInvalidLengthShim 5522 } 5523 iNdEx += length 5524 case 3: 5525 depth++ 5526 case 4: 5527 if depth == 0 { 5528 return 0, ErrUnexpectedEndOfGroupShim 5529 } 5530 depth-- 5531 case 5: 5532 iNdEx += 4 5533 default: 5534 return 0, fmt.Errorf("proto: illegal wireType %d", wireType) 5535 } 5536 if iNdEx < 0 { 5537 return 0, ErrInvalidLengthShim 5538 } 5539 if depth == 0 { 5540 return iNdEx, nil 5541 } 5542 } 5543 return 0, io.ErrUnexpectedEOF 5544} 5545 5546var ( 5547 ErrInvalidLengthShim = fmt.Errorf("proto: negative length found during unmarshaling") 5548 ErrIntOverflowShim = fmt.Errorf("proto: integer overflow") 5549 ErrUnexpectedEndOfGroupShim = fmt.Errorf("proto: unexpected end of group") 5550) 5551