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