1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: drivers/shared/executor/proto/executor.proto 3 4package proto 5 6import ( 7 context "context" 8 fmt "fmt" 9 proto "github.com/golang/protobuf/proto" 10 timestamp "github.com/golang/protobuf/ptypes/timestamp" 11 proto1 "github.com/hashicorp/nomad/plugins/drivers/proto" 12 grpc "google.golang.org/grpc" 13 codes "google.golang.org/grpc/codes" 14 status "google.golang.org/grpc/status" 15 math "math" 16) 17 18// Reference imports to suppress errors if they are not otherwise used. 19var _ = proto.Marshal 20var _ = fmt.Errorf 21var _ = math.Inf 22 23// This is a compile-time assertion to ensure that this generated file 24// is compatible with the proto package it is being compiled against. 25// A compilation error at this line likely means your copy of the 26// proto package needs to be updated. 27const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 28 29type LaunchRequest struct { 30 Cmd string `protobuf:"bytes,1,opt,name=cmd,proto3" json:"cmd,omitempty"` 31 Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"` 32 Resources *proto1.Resources `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"` 33 StdoutPath string `protobuf:"bytes,4,opt,name=stdout_path,json=stdoutPath,proto3" json:"stdout_path,omitempty"` 34 StderrPath string `protobuf:"bytes,5,opt,name=stderr_path,json=stderrPath,proto3" json:"stderr_path,omitempty"` 35 Env []string `protobuf:"bytes,6,rep,name=env,proto3" json:"env,omitempty"` 36 User string `protobuf:"bytes,7,opt,name=user,proto3" json:"user,omitempty"` 37 TaskDir string `protobuf:"bytes,8,opt,name=task_dir,json=taskDir,proto3" json:"task_dir,omitempty"` 38 ResourceLimits bool `protobuf:"varint,9,opt,name=resource_limits,json=resourceLimits,proto3" json:"resource_limits,omitempty"` 39 BasicProcessCgroup bool `protobuf:"varint,10,opt,name=basic_process_cgroup,json=basicProcessCgroup,proto3" json:"basic_process_cgroup,omitempty"` 40 Mounts []*proto1.Mount `protobuf:"bytes,11,rep,name=mounts,proto3" json:"mounts,omitempty"` 41 Devices []*proto1.Device `protobuf:"bytes,12,rep,name=devices,proto3" json:"devices,omitempty"` 42 NetworkIsolation *proto1.NetworkIsolationSpec `protobuf:"bytes,13,opt,name=network_isolation,json=networkIsolation,proto3" json:"network_isolation,omitempty"` 43 NoPivotRoot bool `protobuf:"varint,14,opt,name=no_pivot_root,json=noPivotRoot,proto3" json:"no_pivot_root,omitempty"` 44 DefaultPidMode string `protobuf:"bytes,15,opt,name=default_pid_mode,json=defaultPidMode,proto3" json:"default_pid_mode,omitempty"` 45 DefaultIpcMode string `protobuf:"bytes,16,opt,name=default_ipc_mode,json=defaultIpcMode,proto3" json:"default_ipc_mode,omitempty"` 46 CpusetCgroup string `protobuf:"bytes,17,opt,name=cpuset_cgroup,json=cpusetCgroup,proto3" json:"cpuset_cgroup,omitempty"` 47 AllowCaps []string `protobuf:"bytes,18,rep,name=allow_caps,json=allowCaps,proto3" json:"allow_caps,omitempty"` 48 Capabilities []string `protobuf:"bytes,19,rep,name=capabilities,proto3" json:"capabilities,omitempty"` 49 XXX_NoUnkeyedLiteral struct{} `json:"-"` 50 XXX_unrecognized []byte `json:"-"` 51 XXX_sizecache int32 `json:"-"` 52} 53 54func (m *LaunchRequest) Reset() { *m = LaunchRequest{} } 55func (m *LaunchRequest) String() string { return proto.CompactTextString(m) } 56func (*LaunchRequest) ProtoMessage() {} 57func (*LaunchRequest) Descriptor() ([]byte, []int) { 58 return fileDescriptor_66b85426380683f3, []int{0} 59} 60 61func (m *LaunchRequest) XXX_Unmarshal(b []byte) error { 62 return xxx_messageInfo_LaunchRequest.Unmarshal(m, b) 63} 64func (m *LaunchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 65 return xxx_messageInfo_LaunchRequest.Marshal(b, m, deterministic) 66} 67func (m *LaunchRequest) XXX_Merge(src proto.Message) { 68 xxx_messageInfo_LaunchRequest.Merge(m, src) 69} 70func (m *LaunchRequest) XXX_Size() int { 71 return xxx_messageInfo_LaunchRequest.Size(m) 72} 73func (m *LaunchRequest) XXX_DiscardUnknown() { 74 xxx_messageInfo_LaunchRequest.DiscardUnknown(m) 75} 76 77var xxx_messageInfo_LaunchRequest proto.InternalMessageInfo 78 79func (m *LaunchRequest) GetCmd() string { 80 if m != nil { 81 return m.Cmd 82 } 83 return "" 84} 85 86func (m *LaunchRequest) GetArgs() []string { 87 if m != nil { 88 return m.Args 89 } 90 return nil 91} 92 93func (m *LaunchRequest) GetResources() *proto1.Resources { 94 if m != nil { 95 return m.Resources 96 } 97 return nil 98} 99 100func (m *LaunchRequest) GetStdoutPath() string { 101 if m != nil { 102 return m.StdoutPath 103 } 104 return "" 105} 106 107func (m *LaunchRequest) GetStderrPath() string { 108 if m != nil { 109 return m.StderrPath 110 } 111 return "" 112} 113 114func (m *LaunchRequest) GetEnv() []string { 115 if m != nil { 116 return m.Env 117 } 118 return nil 119} 120 121func (m *LaunchRequest) GetUser() string { 122 if m != nil { 123 return m.User 124 } 125 return "" 126} 127 128func (m *LaunchRequest) GetTaskDir() string { 129 if m != nil { 130 return m.TaskDir 131 } 132 return "" 133} 134 135func (m *LaunchRequest) GetResourceLimits() bool { 136 if m != nil { 137 return m.ResourceLimits 138 } 139 return false 140} 141 142func (m *LaunchRequest) GetBasicProcessCgroup() bool { 143 if m != nil { 144 return m.BasicProcessCgroup 145 } 146 return false 147} 148 149func (m *LaunchRequest) GetMounts() []*proto1.Mount { 150 if m != nil { 151 return m.Mounts 152 } 153 return nil 154} 155 156func (m *LaunchRequest) GetDevices() []*proto1.Device { 157 if m != nil { 158 return m.Devices 159 } 160 return nil 161} 162 163func (m *LaunchRequest) GetNetworkIsolation() *proto1.NetworkIsolationSpec { 164 if m != nil { 165 return m.NetworkIsolation 166 } 167 return nil 168} 169 170func (m *LaunchRequest) GetNoPivotRoot() bool { 171 if m != nil { 172 return m.NoPivotRoot 173 } 174 return false 175} 176 177func (m *LaunchRequest) GetDefaultPidMode() string { 178 if m != nil { 179 return m.DefaultPidMode 180 } 181 return "" 182} 183 184func (m *LaunchRequest) GetDefaultIpcMode() string { 185 if m != nil { 186 return m.DefaultIpcMode 187 } 188 return "" 189} 190 191func (m *LaunchRequest) GetCpusetCgroup() string { 192 if m != nil { 193 return m.CpusetCgroup 194 } 195 return "" 196} 197 198func (m *LaunchRequest) GetAllowCaps() []string { 199 if m != nil { 200 return m.AllowCaps 201 } 202 return nil 203} 204 205func (m *LaunchRequest) GetCapabilities() []string { 206 if m != nil { 207 return m.Capabilities 208 } 209 return nil 210} 211 212type LaunchResponse struct { 213 Process *ProcessState `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"` 214 XXX_NoUnkeyedLiteral struct{} `json:"-"` 215 XXX_unrecognized []byte `json:"-"` 216 XXX_sizecache int32 `json:"-"` 217} 218 219func (m *LaunchResponse) Reset() { *m = LaunchResponse{} } 220func (m *LaunchResponse) String() string { return proto.CompactTextString(m) } 221func (*LaunchResponse) ProtoMessage() {} 222func (*LaunchResponse) Descriptor() ([]byte, []int) { 223 return fileDescriptor_66b85426380683f3, []int{1} 224} 225 226func (m *LaunchResponse) XXX_Unmarshal(b []byte) error { 227 return xxx_messageInfo_LaunchResponse.Unmarshal(m, b) 228} 229func (m *LaunchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 230 return xxx_messageInfo_LaunchResponse.Marshal(b, m, deterministic) 231} 232func (m *LaunchResponse) XXX_Merge(src proto.Message) { 233 xxx_messageInfo_LaunchResponse.Merge(m, src) 234} 235func (m *LaunchResponse) XXX_Size() int { 236 return xxx_messageInfo_LaunchResponse.Size(m) 237} 238func (m *LaunchResponse) XXX_DiscardUnknown() { 239 xxx_messageInfo_LaunchResponse.DiscardUnknown(m) 240} 241 242var xxx_messageInfo_LaunchResponse proto.InternalMessageInfo 243 244func (m *LaunchResponse) GetProcess() *ProcessState { 245 if m != nil { 246 return m.Process 247 } 248 return nil 249} 250 251type WaitRequest struct { 252 XXX_NoUnkeyedLiteral struct{} `json:"-"` 253 XXX_unrecognized []byte `json:"-"` 254 XXX_sizecache int32 `json:"-"` 255} 256 257func (m *WaitRequest) Reset() { *m = WaitRequest{} } 258func (m *WaitRequest) String() string { return proto.CompactTextString(m) } 259func (*WaitRequest) ProtoMessage() {} 260func (*WaitRequest) Descriptor() ([]byte, []int) { 261 return fileDescriptor_66b85426380683f3, []int{2} 262} 263 264func (m *WaitRequest) XXX_Unmarshal(b []byte) error { 265 return xxx_messageInfo_WaitRequest.Unmarshal(m, b) 266} 267func (m *WaitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 268 return xxx_messageInfo_WaitRequest.Marshal(b, m, deterministic) 269} 270func (m *WaitRequest) XXX_Merge(src proto.Message) { 271 xxx_messageInfo_WaitRequest.Merge(m, src) 272} 273func (m *WaitRequest) XXX_Size() int { 274 return xxx_messageInfo_WaitRequest.Size(m) 275} 276func (m *WaitRequest) XXX_DiscardUnknown() { 277 xxx_messageInfo_WaitRequest.DiscardUnknown(m) 278} 279 280var xxx_messageInfo_WaitRequest proto.InternalMessageInfo 281 282type WaitResponse struct { 283 Process *ProcessState `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"` 284 XXX_NoUnkeyedLiteral struct{} `json:"-"` 285 XXX_unrecognized []byte `json:"-"` 286 XXX_sizecache int32 `json:"-"` 287} 288 289func (m *WaitResponse) Reset() { *m = WaitResponse{} } 290func (m *WaitResponse) String() string { return proto.CompactTextString(m) } 291func (*WaitResponse) ProtoMessage() {} 292func (*WaitResponse) Descriptor() ([]byte, []int) { 293 return fileDescriptor_66b85426380683f3, []int{3} 294} 295 296func (m *WaitResponse) XXX_Unmarshal(b []byte) error { 297 return xxx_messageInfo_WaitResponse.Unmarshal(m, b) 298} 299func (m *WaitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 300 return xxx_messageInfo_WaitResponse.Marshal(b, m, deterministic) 301} 302func (m *WaitResponse) XXX_Merge(src proto.Message) { 303 xxx_messageInfo_WaitResponse.Merge(m, src) 304} 305func (m *WaitResponse) XXX_Size() int { 306 return xxx_messageInfo_WaitResponse.Size(m) 307} 308func (m *WaitResponse) XXX_DiscardUnknown() { 309 xxx_messageInfo_WaitResponse.DiscardUnknown(m) 310} 311 312var xxx_messageInfo_WaitResponse proto.InternalMessageInfo 313 314func (m *WaitResponse) GetProcess() *ProcessState { 315 if m != nil { 316 return m.Process 317 } 318 return nil 319} 320 321type ShutdownRequest struct { 322 Signal string `protobuf:"bytes,1,opt,name=signal,proto3" json:"signal,omitempty"` 323 GracePeriod int64 `protobuf:"varint,2,opt,name=grace_period,json=gracePeriod,proto3" json:"grace_period,omitempty"` 324 XXX_NoUnkeyedLiteral struct{} `json:"-"` 325 XXX_unrecognized []byte `json:"-"` 326 XXX_sizecache int32 `json:"-"` 327} 328 329func (m *ShutdownRequest) Reset() { *m = ShutdownRequest{} } 330func (m *ShutdownRequest) String() string { return proto.CompactTextString(m) } 331func (*ShutdownRequest) ProtoMessage() {} 332func (*ShutdownRequest) Descriptor() ([]byte, []int) { 333 return fileDescriptor_66b85426380683f3, []int{4} 334} 335 336func (m *ShutdownRequest) XXX_Unmarshal(b []byte) error { 337 return xxx_messageInfo_ShutdownRequest.Unmarshal(m, b) 338} 339func (m *ShutdownRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 340 return xxx_messageInfo_ShutdownRequest.Marshal(b, m, deterministic) 341} 342func (m *ShutdownRequest) XXX_Merge(src proto.Message) { 343 xxx_messageInfo_ShutdownRequest.Merge(m, src) 344} 345func (m *ShutdownRequest) XXX_Size() int { 346 return xxx_messageInfo_ShutdownRequest.Size(m) 347} 348func (m *ShutdownRequest) XXX_DiscardUnknown() { 349 xxx_messageInfo_ShutdownRequest.DiscardUnknown(m) 350} 351 352var xxx_messageInfo_ShutdownRequest proto.InternalMessageInfo 353 354func (m *ShutdownRequest) GetSignal() string { 355 if m != nil { 356 return m.Signal 357 } 358 return "" 359} 360 361func (m *ShutdownRequest) GetGracePeriod() int64 { 362 if m != nil { 363 return m.GracePeriod 364 } 365 return 0 366} 367 368type ShutdownResponse struct { 369 XXX_NoUnkeyedLiteral struct{} `json:"-"` 370 XXX_unrecognized []byte `json:"-"` 371 XXX_sizecache int32 `json:"-"` 372} 373 374func (m *ShutdownResponse) Reset() { *m = ShutdownResponse{} } 375func (m *ShutdownResponse) String() string { return proto.CompactTextString(m) } 376func (*ShutdownResponse) ProtoMessage() {} 377func (*ShutdownResponse) Descriptor() ([]byte, []int) { 378 return fileDescriptor_66b85426380683f3, []int{5} 379} 380 381func (m *ShutdownResponse) XXX_Unmarshal(b []byte) error { 382 return xxx_messageInfo_ShutdownResponse.Unmarshal(m, b) 383} 384func (m *ShutdownResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 385 return xxx_messageInfo_ShutdownResponse.Marshal(b, m, deterministic) 386} 387func (m *ShutdownResponse) XXX_Merge(src proto.Message) { 388 xxx_messageInfo_ShutdownResponse.Merge(m, src) 389} 390func (m *ShutdownResponse) XXX_Size() int { 391 return xxx_messageInfo_ShutdownResponse.Size(m) 392} 393func (m *ShutdownResponse) XXX_DiscardUnknown() { 394 xxx_messageInfo_ShutdownResponse.DiscardUnknown(m) 395} 396 397var xxx_messageInfo_ShutdownResponse proto.InternalMessageInfo 398 399type UpdateResourcesRequest struct { 400 Resources *proto1.Resources `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources,omitempty"` 401 XXX_NoUnkeyedLiteral struct{} `json:"-"` 402 XXX_unrecognized []byte `json:"-"` 403 XXX_sizecache int32 `json:"-"` 404} 405 406func (m *UpdateResourcesRequest) Reset() { *m = UpdateResourcesRequest{} } 407func (m *UpdateResourcesRequest) String() string { return proto.CompactTextString(m) } 408func (*UpdateResourcesRequest) ProtoMessage() {} 409func (*UpdateResourcesRequest) Descriptor() ([]byte, []int) { 410 return fileDescriptor_66b85426380683f3, []int{6} 411} 412 413func (m *UpdateResourcesRequest) XXX_Unmarshal(b []byte) error { 414 return xxx_messageInfo_UpdateResourcesRequest.Unmarshal(m, b) 415} 416func (m *UpdateResourcesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 417 return xxx_messageInfo_UpdateResourcesRequest.Marshal(b, m, deterministic) 418} 419func (m *UpdateResourcesRequest) XXX_Merge(src proto.Message) { 420 xxx_messageInfo_UpdateResourcesRequest.Merge(m, src) 421} 422func (m *UpdateResourcesRequest) XXX_Size() int { 423 return xxx_messageInfo_UpdateResourcesRequest.Size(m) 424} 425func (m *UpdateResourcesRequest) XXX_DiscardUnknown() { 426 xxx_messageInfo_UpdateResourcesRequest.DiscardUnknown(m) 427} 428 429var xxx_messageInfo_UpdateResourcesRequest proto.InternalMessageInfo 430 431func (m *UpdateResourcesRequest) GetResources() *proto1.Resources { 432 if m != nil { 433 return m.Resources 434 } 435 return nil 436} 437 438type UpdateResourcesResponse struct { 439 XXX_NoUnkeyedLiteral struct{} `json:"-"` 440 XXX_unrecognized []byte `json:"-"` 441 XXX_sizecache int32 `json:"-"` 442} 443 444func (m *UpdateResourcesResponse) Reset() { *m = UpdateResourcesResponse{} } 445func (m *UpdateResourcesResponse) String() string { return proto.CompactTextString(m) } 446func (*UpdateResourcesResponse) ProtoMessage() {} 447func (*UpdateResourcesResponse) Descriptor() ([]byte, []int) { 448 return fileDescriptor_66b85426380683f3, []int{7} 449} 450 451func (m *UpdateResourcesResponse) XXX_Unmarshal(b []byte) error { 452 return xxx_messageInfo_UpdateResourcesResponse.Unmarshal(m, b) 453} 454func (m *UpdateResourcesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 455 return xxx_messageInfo_UpdateResourcesResponse.Marshal(b, m, deterministic) 456} 457func (m *UpdateResourcesResponse) XXX_Merge(src proto.Message) { 458 xxx_messageInfo_UpdateResourcesResponse.Merge(m, src) 459} 460func (m *UpdateResourcesResponse) XXX_Size() int { 461 return xxx_messageInfo_UpdateResourcesResponse.Size(m) 462} 463func (m *UpdateResourcesResponse) XXX_DiscardUnknown() { 464 xxx_messageInfo_UpdateResourcesResponse.DiscardUnknown(m) 465} 466 467var xxx_messageInfo_UpdateResourcesResponse proto.InternalMessageInfo 468 469type VersionRequest struct { 470 XXX_NoUnkeyedLiteral struct{} `json:"-"` 471 XXX_unrecognized []byte `json:"-"` 472 XXX_sizecache int32 `json:"-"` 473} 474 475func (m *VersionRequest) Reset() { *m = VersionRequest{} } 476func (m *VersionRequest) String() string { return proto.CompactTextString(m) } 477func (*VersionRequest) ProtoMessage() {} 478func (*VersionRequest) Descriptor() ([]byte, []int) { 479 return fileDescriptor_66b85426380683f3, []int{8} 480} 481 482func (m *VersionRequest) XXX_Unmarshal(b []byte) error { 483 return xxx_messageInfo_VersionRequest.Unmarshal(m, b) 484} 485func (m *VersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 486 return xxx_messageInfo_VersionRequest.Marshal(b, m, deterministic) 487} 488func (m *VersionRequest) XXX_Merge(src proto.Message) { 489 xxx_messageInfo_VersionRequest.Merge(m, src) 490} 491func (m *VersionRequest) XXX_Size() int { 492 return xxx_messageInfo_VersionRequest.Size(m) 493} 494func (m *VersionRequest) XXX_DiscardUnknown() { 495 xxx_messageInfo_VersionRequest.DiscardUnknown(m) 496} 497 498var xxx_messageInfo_VersionRequest proto.InternalMessageInfo 499 500type VersionResponse struct { 501 Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` 502 XXX_NoUnkeyedLiteral struct{} `json:"-"` 503 XXX_unrecognized []byte `json:"-"` 504 XXX_sizecache int32 `json:"-"` 505} 506 507func (m *VersionResponse) Reset() { *m = VersionResponse{} } 508func (m *VersionResponse) String() string { return proto.CompactTextString(m) } 509func (*VersionResponse) ProtoMessage() {} 510func (*VersionResponse) Descriptor() ([]byte, []int) { 511 return fileDescriptor_66b85426380683f3, []int{9} 512} 513 514func (m *VersionResponse) XXX_Unmarshal(b []byte) error { 515 return xxx_messageInfo_VersionResponse.Unmarshal(m, b) 516} 517func (m *VersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 518 return xxx_messageInfo_VersionResponse.Marshal(b, m, deterministic) 519} 520func (m *VersionResponse) XXX_Merge(src proto.Message) { 521 xxx_messageInfo_VersionResponse.Merge(m, src) 522} 523func (m *VersionResponse) XXX_Size() int { 524 return xxx_messageInfo_VersionResponse.Size(m) 525} 526func (m *VersionResponse) XXX_DiscardUnknown() { 527 xxx_messageInfo_VersionResponse.DiscardUnknown(m) 528} 529 530var xxx_messageInfo_VersionResponse proto.InternalMessageInfo 531 532func (m *VersionResponse) GetVersion() string { 533 if m != nil { 534 return m.Version 535 } 536 return "" 537} 538 539type StatsRequest struct { 540 Interval int64 `protobuf:"varint,1,opt,name=interval,proto3" json:"interval,omitempty"` 541 XXX_NoUnkeyedLiteral struct{} `json:"-"` 542 XXX_unrecognized []byte `json:"-"` 543 XXX_sizecache int32 `json:"-"` 544} 545 546func (m *StatsRequest) Reset() { *m = StatsRequest{} } 547func (m *StatsRequest) String() string { return proto.CompactTextString(m) } 548func (*StatsRequest) ProtoMessage() {} 549func (*StatsRequest) Descriptor() ([]byte, []int) { 550 return fileDescriptor_66b85426380683f3, []int{10} 551} 552 553func (m *StatsRequest) XXX_Unmarshal(b []byte) error { 554 return xxx_messageInfo_StatsRequest.Unmarshal(m, b) 555} 556func (m *StatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 557 return xxx_messageInfo_StatsRequest.Marshal(b, m, deterministic) 558} 559func (m *StatsRequest) XXX_Merge(src proto.Message) { 560 xxx_messageInfo_StatsRequest.Merge(m, src) 561} 562func (m *StatsRequest) XXX_Size() int { 563 return xxx_messageInfo_StatsRequest.Size(m) 564} 565func (m *StatsRequest) XXX_DiscardUnknown() { 566 xxx_messageInfo_StatsRequest.DiscardUnknown(m) 567} 568 569var xxx_messageInfo_StatsRequest proto.InternalMessageInfo 570 571func (m *StatsRequest) GetInterval() int64 { 572 if m != nil { 573 return m.Interval 574 } 575 return 0 576} 577 578type StatsResponse struct { 579 Stats *proto1.TaskStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` 580 XXX_NoUnkeyedLiteral struct{} `json:"-"` 581 XXX_unrecognized []byte `json:"-"` 582 XXX_sizecache int32 `json:"-"` 583} 584 585func (m *StatsResponse) Reset() { *m = StatsResponse{} } 586func (m *StatsResponse) String() string { return proto.CompactTextString(m) } 587func (*StatsResponse) ProtoMessage() {} 588func (*StatsResponse) Descriptor() ([]byte, []int) { 589 return fileDescriptor_66b85426380683f3, []int{11} 590} 591 592func (m *StatsResponse) XXX_Unmarshal(b []byte) error { 593 return xxx_messageInfo_StatsResponse.Unmarshal(m, b) 594} 595func (m *StatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 596 return xxx_messageInfo_StatsResponse.Marshal(b, m, deterministic) 597} 598func (m *StatsResponse) XXX_Merge(src proto.Message) { 599 xxx_messageInfo_StatsResponse.Merge(m, src) 600} 601func (m *StatsResponse) XXX_Size() int { 602 return xxx_messageInfo_StatsResponse.Size(m) 603} 604func (m *StatsResponse) XXX_DiscardUnknown() { 605 xxx_messageInfo_StatsResponse.DiscardUnknown(m) 606} 607 608var xxx_messageInfo_StatsResponse proto.InternalMessageInfo 609 610func (m *StatsResponse) GetStats() *proto1.TaskStats { 611 if m != nil { 612 return m.Stats 613 } 614 return nil 615} 616 617type SignalRequest struct { 618 Signal int32 `protobuf:"varint,1,opt,name=signal,proto3" json:"signal,omitempty"` 619 XXX_NoUnkeyedLiteral struct{} `json:"-"` 620 XXX_unrecognized []byte `json:"-"` 621 XXX_sizecache int32 `json:"-"` 622} 623 624func (m *SignalRequest) Reset() { *m = SignalRequest{} } 625func (m *SignalRequest) String() string { return proto.CompactTextString(m) } 626func (*SignalRequest) ProtoMessage() {} 627func (*SignalRequest) Descriptor() ([]byte, []int) { 628 return fileDescriptor_66b85426380683f3, []int{12} 629} 630 631func (m *SignalRequest) XXX_Unmarshal(b []byte) error { 632 return xxx_messageInfo_SignalRequest.Unmarshal(m, b) 633} 634func (m *SignalRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 635 return xxx_messageInfo_SignalRequest.Marshal(b, m, deterministic) 636} 637func (m *SignalRequest) XXX_Merge(src proto.Message) { 638 xxx_messageInfo_SignalRequest.Merge(m, src) 639} 640func (m *SignalRequest) XXX_Size() int { 641 return xxx_messageInfo_SignalRequest.Size(m) 642} 643func (m *SignalRequest) XXX_DiscardUnknown() { 644 xxx_messageInfo_SignalRequest.DiscardUnknown(m) 645} 646 647var xxx_messageInfo_SignalRequest proto.InternalMessageInfo 648 649func (m *SignalRequest) GetSignal() int32 { 650 if m != nil { 651 return m.Signal 652 } 653 return 0 654} 655 656type SignalResponse struct { 657 XXX_NoUnkeyedLiteral struct{} `json:"-"` 658 XXX_unrecognized []byte `json:"-"` 659 XXX_sizecache int32 `json:"-"` 660} 661 662func (m *SignalResponse) Reset() { *m = SignalResponse{} } 663func (m *SignalResponse) String() string { return proto.CompactTextString(m) } 664func (*SignalResponse) ProtoMessage() {} 665func (*SignalResponse) Descriptor() ([]byte, []int) { 666 return fileDescriptor_66b85426380683f3, []int{13} 667} 668 669func (m *SignalResponse) XXX_Unmarshal(b []byte) error { 670 return xxx_messageInfo_SignalResponse.Unmarshal(m, b) 671} 672func (m *SignalResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 673 return xxx_messageInfo_SignalResponse.Marshal(b, m, deterministic) 674} 675func (m *SignalResponse) XXX_Merge(src proto.Message) { 676 xxx_messageInfo_SignalResponse.Merge(m, src) 677} 678func (m *SignalResponse) XXX_Size() int { 679 return xxx_messageInfo_SignalResponse.Size(m) 680} 681func (m *SignalResponse) XXX_DiscardUnknown() { 682 xxx_messageInfo_SignalResponse.DiscardUnknown(m) 683} 684 685var xxx_messageInfo_SignalResponse proto.InternalMessageInfo 686 687type ExecRequest struct { 688 Deadline *timestamp.Timestamp `protobuf:"bytes,1,opt,name=deadline,proto3" json:"deadline,omitempty"` 689 Cmd string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"` 690 Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"` 691 XXX_NoUnkeyedLiteral struct{} `json:"-"` 692 XXX_unrecognized []byte `json:"-"` 693 XXX_sizecache int32 `json:"-"` 694} 695 696func (m *ExecRequest) Reset() { *m = ExecRequest{} } 697func (m *ExecRequest) String() string { return proto.CompactTextString(m) } 698func (*ExecRequest) ProtoMessage() {} 699func (*ExecRequest) Descriptor() ([]byte, []int) { 700 return fileDescriptor_66b85426380683f3, []int{14} 701} 702 703func (m *ExecRequest) XXX_Unmarshal(b []byte) error { 704 return xxx_messageInfo_ExecRequest.Unmarshal(m, b) 705} 706func (m *ExecRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 707 return xxx_messageInfo_ExecRequest.Marshal(b, m, deterministic) 708} 709func (m *ExecRequest) XXX_Merge(src proto.Message) { 710 xxx_messageInfo_ExecRequest.Merge(m, src) 711} 712func (m *ExecRequest) XXX_Size() int { 713 return xxx_messageInfo_ExecRequest.Size(m) 714} 715func (m *ExecRequest) XXX_DiscardUnknown() { 716 xxx_messageInfo_ExecRequest.DiscardUnknown(m) 717} 718 719var xxx_messageInfo_ExecRequest proto.InternalMessageInfo 720 721func (m *ExecRequest) GetDeadline() *timestamp.Timestamp { 722 if m != nil { 723 return m.Deadline 724 } 725 return nil 726} 727 728func (m *ExecRequest) GetCmd() string { 729 if m != nil { 730 return m.Cmd 731 } 732 return "" 733} 734 735func (m *ExecRequest) GetArgs() []string { 736 if m != nil { 737 return m.Args 738 } 739 return nil 740} 741 742type ExecResponse struct { 743 Output []byte `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"` 744 ExitCode int32 `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"` 745 XXX_NoUnkeyedLiteral struct{} `json:"-"` 746 XXX_unrecognized []byte `json:"-"` 747 XXX_sizecache int32 `json:"-"` 748} 749 750func (m *ExecResponse) Reset() { *m = ExecResponse{} } 751func (m *ExecResponse) String() string { return proto.CompactTextString(m) } 752func (*ExecResponse) ProtoMessage() {} 753func (*ExecResponse) Descriptor() ([]byte, []int) { 754 return fileDescriptor_66b85426380683f3, []int{15} 755} 756 757func (m *ExecResponse) XXX_Unmarshal(b []byte) error { 758 return xxx_messageInfo_ExecResponse.Unmarshal(m, b) 759} 760func (m *ExecResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 761 return xxx_messageInfo_ExecResponse.Marshal(b, m, deterministic) 762} 763func (m *ExecResponse) XXX_Merge(src proto.Message) { 764 xxx_messageInfo_ExecResponse.Merge(m, src) 765} 766func (m *ExecResponse) XXX_Size() int { 767 return xxx_messageInfo_ExecResponse.Size(m) 768} 769func (m *ExecResponse) XXX_DiscardUnknown() { 770 xxx_messageInfo_ExecResponse.DiscardUnknown(m) 771} 772 773var xxx_messageInfo_ExecResponse proto.InternalMessageInfo 774 775func (m *ExecResponse) GetOutput() []byte { 776 if m != nil { 777 return m.Output 778 } 779 return nil 780} 781 782func (m *ExecResponse) GetExitCode() int32 { 783 if m != nil { 784 return m.ExitCode 785 } 786 return 0 787} 788 789type ProcessState struct { 790 Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` 791 ExitCode int32 `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"` 792 Signal int32 `protobuf:"varint,3,opt,name=signal,proto3" json:"signal,omitempty"` 793 Time *timestamp.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"` 794 XXX_NoUnkeyedLiteral struct{} `json:"-"` 795 XXX_unrecognized []byte `json:"-"` 796 XXX_sizecache int32 `json:"-"` 797} 798 799func (m *ProcessState) Reset() { *m = ProcessState{} } 800func (m *ProcessState) String() string { return proto.CompactTextString(m) } 801func (*ProcessState) ProtoMessage() {} 802func (*ProcessState) Descriptor() ([]byte, []int) { 803 return fileDescriptor_66b85426380683f3, []int{16} 804} 805 806func (m *ProcessState) XXX_Unmarshal(b []byte) error { 807 return xxx_messageInfo_ProcessState.Unmarshal(m, b) 808} 809func (m *ProcessState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 810 return xxx_messageInfo_ProcessState.Marshal(b, m, deterministic) 811} 812func (m *ProcessState) XXX_Merge(src proto.Message) { 813 xxx_messageInfo_ProcessState.Merge(m, src) 814} 815func (m *ProcessState) XXX_Size() int { 816 return xxx_messageInfo_ProcessState.Size(m) 817} 818func (m *ProcessState) XXX_DiscardUnknown() { 819 xxx_messageInfo_ProcessState.DiscardUnknown(m) 820} 821 822var xxx_messageInfo_ProcessState proto.InternalMessageInfo 823 824func (m *ProcessState) GetPid() int32 { 825 if m != nil { 826 return m.Pid 827 } 828 return 0 829} 830 831func (m *ProcessState) GetExitCode() int32 { 832 if m != nil { 833 return m.ExitCode 834 } 835 return 0 836} 837 838func (m *ProcessState) GetSignal() int32 { 839 if m != nil { 840 return m.Signal 841 } 842 return 0 843} 844 845func (m *ProcessState) GetTime() *timestamp.Timestamp { 846 if m != nil { 847 return m.Time 848 } 849 return nil 850} 851 852func init() { 853 proto.RegisterType((*LaunchRequest)(nil), "hashicorp.nomad.plugins.executor.proto.LaunchRequest") 854 proto.RegisterType((*LaunchResponse)(nil), "hashicorp.nomad.plugins.executor.proto.LaunchResponse") 855 proto.RegisterType((*WaitRequest)(nil), "hashicorp.nomad.plugins.executor.proto.WaitRequest") 856 proto.RegisterType((*WaitResponse)(nil), "hashicorp.nomad.plugins.executor.proto.WaitResponse") 857 proto.RegisterType((*ShutdownRequest)(nil), "hashicorp.nomad.plugins.executor.proto.ShutdownRequest") 858 proto.RegisterType((*ShutdownResponse)(nil), "hashicorp.nomad.plugins.executor.proto.ShutdownResponse") 859 proto.RegisterType((*UpdateResourcesRequest)(nil), "hashicorp.nomad.plugins.executor.proto.UpdateResourcesRequest") 860 proto.RegisterType((*UpdateResourcesResponse)(nil), "hashicorp.nomad.plugins.executor.proto.UpdateResourcesResponse") 861 proto.RegisterType((*VersionRequest)(nil), "hashicorp.nomad.plugins.executor.proto.VersionRequest") 862 proto.RegisterType((*VersionResponse)(nil), "hashicorp.nomad.plugins.executor.proto.VersionResponse") 863 proto.RegisterType((*StatsRequest)(nil), "hashicorp.nomad.plugins.executor.proto.StatsRequest") 864 proto.RegisterType((*StatsResponse)(nil), "hashicorp.nomad.plugins.executor.proto.StatsResponse") 865 proto.RegisterType((*SignalRequest)(nil), "hashicorp.nomad.plugins.executor.proto.SignalRequest") 866 proto.RegisterType((*SignalResponse)(nil), "hashicorp.nomad.plugins.executor.proto.SignalResponse") 867 proto.RegisterType((*ExecRequest)(nil), "hashicorp.nomad.plugins.executor.proto.ExecRequest") 868 proto.RegisterType((*ExecResponse)(nil), "hashicorp.nomad.plugins.executor.proto.ExecResponse") 869 proto.RegisterType((*ProcessState)(nil), "hashicorp.nomad.plugins.executor.proto.ProcessState") 870} 871 872func init() { 873 proto.RegisterFile("drivers/shared/executor/proto/executor.proto", fileDescriptor_66b85426380683f3) 874} 875 876var fileDescriptor_66b85426380683f3 = []byte{ 877 // 1058 bytes of a gzipped FileDescriptorProto 878 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x55, 0x6d, 0x6f, 0x1b, 0x45, 879 0x10, 0xee, 0xc5, 0x89, 0x5f, 0xc6, 0x76, 0xe2, 0x2e, 0xa8, 0x5c, 0x8d, 0x50, 0xcd, 0x21, 0x51, 880 0x0b, 0xca, 0x25, 0x4a, 0xdf, 0x90, 0x90, 0x28, 0x22, 0x2d, 0xa8, 0x52, 0x1a, 0x45, 0x97, 0x42, 881 0x25, 0x3e, 0x70, 0x6c, 0xee, 0xb6, 0xf6, 0x2a, 0xf6, 0xed, 0xb2, 0xbb, 0xe7, 0x04, 0x09, 0x89, 882 0x4f, 0xfc, 0x03, 0x90, 0xf8, 0x31, 0xfc, 0x38, 0xb4, 0x6f, 0x17, 0x3b, 0x2d, 0xd5, 0xb9, 0x88, 883 0x4f, 0xbe, 0x1d, 0x3f, 0xcf, 0xcc, 0xec, 0xce, 0xcc, 0x33, 0x70, 0x27, 0x17, 0x74, 0x41, 0x84, 884 0xdc, 0x95, 0x53, 0x2c, 0x48, 0xbe, 0x4b, 0x2e, 0x48, 0x56, 0x2a, 0x26, 0x76, 0xb9, 0x60, 0x8a, 885 0x55, 0xc7, 0xd8, 0x1c, 0xd1, 0xc7, 0x53, 0x2c, 0xa7, 0x34, 0x63, 0x82, 0xc7, 0x05, 0x9b, 0xe3, 886 0x3c, 0xe6, 0xb3, 0x72, 0x42, 0x0b, 0x19, 0xaf, 0xe2, 0x86, 0xb7, 0x26, 0x8c, 0x4d, 0x66, 0xc4, 887 0x3a, 0x39, 0x2d, 0x5f, 0xee, 0x2a, 0x3a, 0x27, 0x52, 0xe1, 0x39, 0x77, 0x80, 0xc8, 0x11, 0x77, 888 0x7d, 0x78, 0x1b, 0xce, 0x9e, 0x2c, 0x26, 0xfa, 0xbb, 0x09, 0xfd, 0x43, 0x5c, 0x16, 0xd9, 0x34, 889 0x21, 0x3f, 0x97, 0x44, 0x2a, 0x34, 0x80, 0x46, 0x36, 0xcf, 0xc3, 0x60, 0x14, 0x8c, 0x3b, 0x89, 890 0xfe, 0x44, 0x08, 0x36, 0xb1, 0x98, 0xc8, 0x70, 0x63, 0xd4, 0x18, 0x77, 0x12, 0xf3, 0x8d, 0x8e, 891 0xa0, 0x23, 0x88, 0x64, 0xa5, 0xc8, 0x88, 0x0c, 0x1b, 0xa3, 0x60, 0xdc, 0xdd, 0xdf, 0x8b, 0xff, 892 0x2d, 0x71, 0x17, 0xdf, 0x86, 0x8c, 0x13, 0xcf, 0x4b, 0x2e, 0x5d, 0xa0, 0x5b, 0xd0, 0x95, 0x2a, 893 0x67, 0xa5, 0x4a, 0x39, 0x56, 0xd3, 0x70, 0xd3, 0x44, 0x07, 0x6b, 0x3a, 0xc6, 0x6a, 0xea, 0x00, 894 0x44, 0x08, 0x0b, 0xd8, 0xaa, 0x00, 0x44, 0x08, 0x03, 0x18, 0x40, 0x83, 0x14, 0x8b, 0xb0, 0x69, 895 0x92, 0xd4, 0x9f, 0x3a, 0xef, 0x52, 0x12, 0x11, 0xb6, 0x0c, 0xd6, 0x7c, 0xa3, 0x9b, 0xd0, 0x56, 896 0x58, 0x9e, 0xa5, 0x39, 0x15, 0x61, 0xdb, 0xd8, 0x5b, 0xfa, 0xfc, 0x98, 0x0a, 0x74, 0x1b, 0x76, 897 0x7c, 0x3e, 0xe9, 0x8c, 0xce, 0xa9, 0x92, 0x61, 0x67, 0x14, 0x8c, 0xdb, 0xc9, 0xb6, 0x37, 0x1f, 898 0x1a, 0x2b, 0xda, 0x83, 0x77, 0x4f, 0xb1, 0xa4, 0x59, 0xca, 0x05, 0xcb, 0x88, 0x94, 0x69, 0x36, 899 0x11, 0xac, 0xe4, 0x21, 0x18, 0x34, 0x32, 0xff, 0x1d, 0xdb, 0xbf, 0x0e, 0xcc, 0x3f, 0xe8, 0x31, 900 0x34, 0xe7, 0xac, 0x2c, 0x94, 0x0c, 0xbb, 0xa3, 0xc6, 0xb8, 0xbb, 0x7f, 0xa7, 0xe6, 0x53, 0x3d, 901 0xd3, 0xa4, 0xc4, 0x71, 0xd1, 0xb7, 0xd0, 0xca, 0xc9, 0x82, 0xea, 0x17, 0xef, 0x19, 0x37, 0x9f, 902 0xd5, 0x74, 0xf3, 0xd8, 0xb0, 0x12, 0xcf, 0x46, 0x53, 0xb8, 0x5e, 0x10, 0x75, 0xce, 0xc4, 0x59, 903 0x4a, 0x25, 0x9b, 0x61, 0x45, 0x59, 0x11, 0xf6, 0x4d, 0x11, 0xbf, 0xa8, 0xe9, 0xf2, 0xc8, 0xf2, 904 0x9f, 0x7a, 0xfa, 0x09, 0x27, 0x59, 0x32, 0x28, 0xae, 0x58, 0x51, 0x04, 0xfd, 0x82, 0xa5, 0x9c, 905 0x2e, 0x98, 0x4a, 0x05, 0x63, 0x2a, 0xdc, 0x36, 0x6f, 0xd4, 0x2d, 0xd8, 0xb1, 0xb6, 0x25, 0x8c, 906 0x29, 0x34, 0x86, 0x41, 0x4e, 0x5e, 0xe2, 0x72, 0xa6, 0x52, 0x4e, 0xf3, 0x74, 0xce, 0x72, 0x12, 907 0xee, 0x98, 0xd2, 0x6c, 0x3b, 0xfb, 0x31, 0xcd, 0x9f, 0xb1, 0x9c, 0x2c, 0x23, 0x29, 0xcf, 0x2c, 908 0x72, 0xb0, 0x82, 0x7c, 0xca, 0x33, 0x83, 0xfc, 0x08, 0xfa, 0x19, 0x2f, 0x25, 0x51, 0xbe, 0x36, 909 0xd7, 0x0d, 0xac, 0x67, 0x8d, 0xae, 0x2a, 0x1f, 0x00, 0xe0, 0xd9, 0x8c, 0x9d, 0xa7, 0x19, 0xe6, 910 0x32, 0x44, 0xa6, 0x71, 0x3a, 0xc6, 0x72, 0x80, 0xb9, 0x44, 0x11, 0xf4, 0x32, 0xcc, 0xf1, 0x29, 911 0x9d, 0x51, 0x45, 0x89, 0x0c, 0xdf, 0x31, 0x80, 0x15, 0x5b, 0xf4, 0x13, 0x6c, 0xfb, 0xe9, 0x91, 912 0x9c, 0x15, 0x92, 0xa0, 0x23, 0x68, 0xb9, 0xb6, 0x30, 0x23, 0xd4, 0xdd, 0xbf, 0x17, 0xd7, 0x9b, 913 0xe7, 0xd8, 0xb5, 0xcc, 0x89, 0xc2, 0x8a, 0x24, 0xde, 0x49, 0xd4, 0x87, 0xee, 0x0b, 0x4c, 0x95, 914 0x9b, 0xce, 0xe8, 0x47, 0xe8, 0xd9, 0xe3, 0xff, 0x14, 0xee, 0x10, 0x76, 0x4e, 0xa6, 0xa5, 0xca, 915 0xd9, 0x79, 0xe1, 0x05, 0xe1, 0x06, 0x34, 0x25, 0x9d, 0x14, 0x78, 0xe6, 0x34, 0xc1, 0x9d, 0xd0, 916 0x87, 0xd0, 0x9b, 0x08, 0x9c, 0x91, 0x94, 0x13, 0x41, 0x59, 0x1e, 0x6e, 0x8c, 0x82, 0x71, 0x23, 917 0xe9, 0x1a, 0xdb, 0xb1, 0x31, 0x45, 0x08, 0x06, 0x97, 0xde, 0x6c, 0xc6, 0xd1, 0x14, 0x6e, 0x7c, 918 0xc7, 0x73, 0x1d, 0xb4, 0xd2, 0x01, 0x17, 0x68, 0x45, 0x53, 0x82, 0xff, 0xac, 0x29, 0xd1, 0x4d, 919 0x78, 0xef, 0x95, 0x48, 0x2e, 0x89, 0x01, 0x6c, 0x7f, 0x4f, 0x84, 0xa4, 0xcc, 0xdf, 0x32, 0xfa, 920 0x14, 0x76, 0x2a, 0x8b, 0x7b, 0xdb, 0x10, 0x5a, 0x0b, 0x6b, 0x72, 0x37, 0xf7, 0xc7, 0xe8, 0x13, 921 0xe8, 0xe9, 0x77, 0xab, 0x32, 0x1f, 0x42, 0x9b, 0x16, 0x8a, 0x88, 0x85, 0x7b, 0xa4, 0x46, 0x52, 922 0x9d, 0xa3, 0x17, 0xd0, 0x77, 0x58, 0xe7, 0xf6, 0x1b, 0xd8, 0x92, 0xda, 0xb0, 0xe6, 0x15, 0x9f, 923 0x63, 0x79, 0x66, 0x1d, 0x59, 0x7a, 0x74, 0x1b, 0xfa, 0x27, 0xa6, 0x12, 0xaf, 0x2f, 0xd4, 0x96, 924 0x2f, 0x94, 0xbe, 0xac, 0x07, 0xba, 0xeb, 0x9f, 0x41, 0xf7, 0xc9, 0x05, 0xc9, 0x3c, 0xf1, 0x01, 925 0xb4, 0x73, 0x82, 0xf3, 0x19, 0x2d, 0x88, 0x4b, 0x6a, 0x18, 0xdb, 0xe5, 0x12, 0xfb, 0xe5, 0x12, 926 0x3f, 0xf7, 0xcb, 0x25, 0xa9, 0xb0, 0x7e, 0x55, 0x6c, 0xbc, 0xba, 0x2a, 0x1a, 0x97, 0xab, 0x22, 927 0x3a, 0x80, 0x9e, 0x0d, 0xe6, 0xee, 0x7f, 0x03, 0x9a, 0xac, 0x54, 0xbc, 0x54, 0x26, 0x56, 0x2f, 928 0x71, 0x27, 0xf4, 0x3e, 0x74, 0xc8, 0x05, 0x55, 0x69, 0xa6, 0xc7, 0x7a, 0xc3, 0xdc, 0xa0, 0xad, 929 0x0d, 0x07, 0x2c, 0x27, 0xd1, 0xef, 0x01, 0xf4, 0x96, 0x3b, 0x56, 0xc7, 0xe6, 0x34, 0x77, 0x37, 930 0xd5, 0x9f, 0x6f, 0xe4, 0x2f, 0xbd, 0x4d, 0x63, 0xf9, 0x6d, 0x50, 0x0c, 0x9b, 0x7a, 0x6d, 0x9a, 931 0x85, 0xf3, 0xe6, 0x6b, 0x1b, 0xdc, 0xfe, 0x9f, 0x1d, 0x68, 0x3f, 0x71, 0x83, 0x84, 0x7e, 0x81, 932 0xa6, 0x9d, 0x7e, 0x74, 0xbf, 0xee, 0xd4, 0xad, 0xec, 0xda, 0xe1, 0x83, 0x75, 0x69, 0xae, 0x7e, 933 0xd7, 0x90, 0x84, 0x4d, 0xad, 0x03, 0xe8, 0x6e, 0x5d, 0x0f, 0x4b, 0x22, 0x32, 0xbc, 0xb7, 0x1e, 934 0xa9, 0x0a, 0xfa, 0x1b, 0xb4, 0xfd, 0x38, 0xa3, 0x87, 0x75, 0x7d, 0x5c, 0x91, 0x93, 0xe1, 0xe7, 935 0xeb, 0x13, 0xab, 0x04, 0xfe, 0x08, 0x60, 0xe7, 0xca, 0x48, 0xa3, 0x2f, 0xeb, 0xfa, 0x7b, 0xbd, 936 0xea, 0x0c, 0x1f, 0xbd, 0x35, 0xbf, 0x4a, 0xeb, 0x57, 0x68, 0x39, 0xed, 0x40, 0xb5, 0x2b, 0xba, 937 0x2a, 0x3f, 0xc3, 0x87, 0x6b, 0xf3, 0xaa, 0xe8, 0x17, 0xb0, 0x65, 0x74, 0x01, 0xd5, 0x2e, 0xeb, 938 0xb2, 0x76, 0x0d, 0xef, 0xaf, 0xc9, 0xf2, 0x71, 0xf7, 0x02, 0xdd, 0xff, 0x56, 0x58, 0xea, 0xf7, 939 0xff, 0x8a, 0x62, 0xd5, 0xef, 0xff, 0x2b, 0xfa, 0x65, 0xfa, 0x5f, 0x8f, 0x61, 0xfd, 0xfe, 0x5f, 940 0xd2, 0xbb, 0xfa, 0xfd, 0xbf, 0xac, 0x5b, 0xd1, 0x35, 0xf4, 0x57, 0x00, 0x7d, 0x6d, 0x3a, 0x51, 941 0x82, 0xe0, 0x39, 0x2d, 0x26, 0xe8, 0x51, 0x4d, 0xf1, 0xd6, 0x2c, 0x2b, 0xe0, 0x8e, 0xe9, 0x53, 942 0xf9, 0xea, 0xed, 0x1d, 0xf8, 0xb4, 0xc6, 0xc1, 0x5e, 0xf0, 0x75, 0xeb, 0x87, 0x2d, 0xab, 0x59, 943 0x4d, 0xf3, 0x73, 0xf7, 0x9f, 0x00, 0x00, 0x00, 0xff, 0xff, 0x2e, 0x63, 0xc4, 0xd3, 0x74, 0x0c, 944 0x00, 0x00, 945} 946 947// Reference imports to suppress errors if they are not otherwise used. 948var _ context.Context 949var _ grpc.ClientConnInterface 950 951// This is a compile-time assertion to ensure that this generated file 952// is compatible with the grpc package it is being compiled against. 953const _ = grpc.SupportPackageIsVersion6 954 955// ExecutorClient is the client API for Executor service. 956// 957// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 958type ExecutorClient interface { 959 Launch(ctx context.Context, in *LaunchRequest, opts ...grpc.CallOption) (*LaunchResponse, error) 960 Wait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error) 961 Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error) 962 UpdateResources(ctx context.Context, in *UpdateResourcesRequest, opts ...grpc.CallOption) (*UpdateResourcesResponse, error) 963 Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error) 964 Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (Executor_StatsClient, error) 965 Signal(ctx context.Context, in *SignalRequest, opts ...grpc.CallOption) (*SignalResponse, error) 966 Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error) 967 // buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE 968 ExecStreaming(ctx context.Context, opts ...grpc.CallOption) (Executor_ExecStreamingClient, error) 969} 970 971type executorClient struct { 972 cc grpc.ClientConnInterface 973} 974 975func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient { 976 return &executorClient{cc} 977} 978 979func (c *executorClient) Launch(ctx context.Context, in *LaunchRequest, opts ...grpc.CallOption) (*LaunchResponse, error) { 980 out := new(LaunchResponse) 981 err := c.cc.Invoke(ctx, "/hashicorp.nomad.plugins.executor.proto.Executor/Launch", in, out, opts...) 982 if err != nil { 983 return nil, err 984 } 985 return out, nil 986} 987 988func (c *executorClient) Wait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error) { 989 out := new(WaitResponse) 990 err := c.cc.Invoke(ctx, "/hashicorp.nomad.plugins.executor.proto.Executor/Wait", in, out, opts...) 991 if err != nil { 992 return nil, err 993 } 994 return out, nil 995} 996 997func (c *executorClient) Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error) { 998 out := new(ShutdownResponse) 999 err := c.cc.Invoke(ctx, "/hashicorp.nomad.plugins.executor.proto.Executor/Shutdown", in, out, opts...) 1000 if err != nil { 1001 return nil, err 1002 } 1003 return out, nil 1004} 1005 1006func (c *executorClient) UpdateResources(ctx context.Context, in *UpdateResourcesRequest, opts ...grpc.CallOption) (*UpdateResourcesResponse, error) { 1007 out := new(UpdateResourcesResponse) 1008 err := c.cc.Invoke(ctx, "/hashicorp.nomad.plugins.executor.proto.Executor/UpdateResources", in, out, opts...) 1009 if err != nil { 1010 return nil, err 1011 } 1012 return out, nil 1013} 1014 1015func (c *executorClient) Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error) { 1016 out := new(VersionResponse) 1017 err := c.cc.Invoke(ctx, "/hashicorp.nomad.plugins.executor.proto.Executor/Version", in, out, opts...) 1018 if err != nil { 1019 return nil, err 1020 } 1021 return out, nil 1022} 1023 1024func (c *executorClient) Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (Executor_StatsClient, error) { 1025 stream, err := c.cc.NewStream(ctx, &_Executor_serviceDesc.Streams[0], "/hashicorp.nomad.plugins.executor.proto.Executor/Stats", opts...) 1026 if err != nil { 1027 return nil, err 1028 } 1029 x := &executorStatsClient{stream} 1030 if err := x.ClientStream.SendMsg(in); err != nil { 1031 return nil, err 1032 } 1033 if err := x.ClientStream.CloseSend(); err != nil { 1034 return nil, err 1035 } 1036 return x, nil 1037} 1038 1039type Executor_StatsClient interface { 1040 Recv() (*StatsResponse, error) 1041 grpc.ClientStream 1042} 1043 1044type executorStatsClient struct { 1045 grpc.ClientStream 1046} 1047 1048func (x *executorStatsClient) Recv() (*StatsResponse, error) { 1049 m := new(StatsResponse) 1050 if err := x.ClientStream.RecvMsg(m); err != nil { 1051 return nil, err 1052 } 1053 return m, nil 1054} 1055 1056func (c *executorClient) Signal(ctx context.Context, in *SignalRequest, opts ...grpc.CallOption) (*SignalResponse, error) { 1057 out := new(SignalResponse) 1058 err := c.cc.Invoke(ctx, "/hashicorp.nomad.plugins.executor.proto.Executor/Signal", in, out, opts...) 1059 if err != nil { 1060 return nil, err 1061 } 1062 return out, nil 1063} 1064 1065func (c *executorClient) Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error) { 1066 out := new(ExecResponse) 1067 err := c.cc.Invoke(ctx, "/hashicorp.nomad.plugins.executor.proto.Executor/Exec", in, out, opts...) 1068 if err != nil { 1069 return nil, err 1070 } 1071 return out, nil 1072} 1073 1074func (c *executorClient) ExecStreaming(ctx context.Context, opts ...grpc.CallOption) (Executor_ExecStreamingClient, error) { 1075 stream, err := c.cc.NewStream(ctx, &_Executor_serviceDesc.Streams[1], "/hashicorp.nomad.plugins.executor.proto.Executor/ExecStreaming", opts...) 1076 if err != nil { 1077 return nil, err 1078 } 1079 x := &executorExecStreamingClient{stream} 1080 return x, nil 1081} 1082 1083type Executor_ExecStreamingClient interface { 1084 Send(*proto1.ExecTaskStreamingRequest) error 1085 Recv() (*proto1.ExecTaskStreamingResponse, error) 1086 grpc.ClientStream 1087} 1088 1089type executorExecStreamingClient struct { 1090 grpc.ClientStream 1091} 1092 1093func (x *executorExecStreamingClient) Send(m *proto1.ExecTaskStreamingRequest) error { 1094 return x.ClientStream.SendMsg(m) 1095} 1096 1097func (x *executorExecStreamingClient) Recv() (*proto1.ExecTaskStreamingResponse, error) { 1098 m := new(proto1.ExecTaskStreamingResponse) 1099 if err := x.ClientStream.RecvMsg(m); err != nil { 1100 return nil, err 1101 } 1102 return m, nil 1103} 1104 1105// ExecutorServer is the server API for Executor service. 1106type ExecutorServer interface { 1107 Launch(context.Context, *LaunchRequest) (*LaunchResponse, error) 1108 Wait(context.Context, *WaitRequest) (*WaitResponse, error) 1109 Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error) 1110 UpdateResources(context.Context, *UpdateResourcesRequest) (*UpdateResourcesResponse, error) 1111 Version(context.Context, *VersionRequest) (*VersionResponse, error) 1112 Stats(*StatsRequest, Executor_StatsServer) error 1113 Signal(context.Context, *SignalRequest) (*SignalResponse, error) 1114 Exec(context.Context, *ExecRequest) (*ExecResponse, error) 1115 // buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE 1116 ExecStreaming(Executor_ExecStreamingServer) error 1117} 1118 1119// UnimplementedExecutorServer can be embedded to have forward compatible implementations. 1120type UnimplementedExecutorServer struct { 1121} 1122 1123func (*UnimplementedExecutorServer) Launch(ctx context.Context, req *LaunchRequest) (*LaunchResponse, error) { 1124 return nil, status.Errorf(codes.Unimplemented, "method Launch not implemented") 1125} 1126func (*UnimplementedExecutorServer) Wait(ctx context.Context, req *WaitRequest) (*WaitResponse, error) { 1127 return nil, status.Errorf(codes.Unimplemented, "method Wait not implemented") 1128} 1129func (*UnimplementedExecutorServer) Shutdown(ctx context.Context, req *ShutdownRequest) (*ShutdownResponse, error) { 1130 return nil, status.Errorf(codes.Unimplemented, "method Shutdown not implemented") 1131} 1132func (*UnimplementedExecutorServer) UpdateResources(ctx context.Context, req *UpdateResourcesRequest) (*UpdateResourcesResponse, error) { 1133 return nil, status.Errorf(codes.Unimplemented, "method UpdateResources not implemented") 1134} 1135func (*UnimplementedExecutorServer) Version(ctx context.Context, req *VersionRequest) (*VersionResponse, error) { 1136 return nil, status.Errorf(codes.Unimplemented, "method Version not implemented") 1137} 1138func (*UnimplementedExecutorServer) Stats(req *StatsRequest, srv Executor_StatsServer) error { 1139 return status.Errorf(codes.Unimplemented, "method Stats not implemented") 1140} 1141func (*UnimplementedExecutorServer) Signal(ctx context.Context, req *SignalRequest) (*SignalResponse, error) { 1142 return nil, status.Errorf(codes.Unimplemented, "method Signal not implemented") 1143} 1144func (*UnimplementedExecutorServer) Exec(ctx context.Context, req *ExecRequest) (*ExecResponse, error) { 1145 return nil, status.Errorf(codes.Unimplemented, "method Exec not implemented") 1146} 1147func (*UnimplementedExecutorServer) ExecStreaming(srv Executor_ExecStreamingServer) error { 1148 return status.Errorf(codes.Unimplemented, "method ExecStreaming not implemented") 1149} 1150 1151func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer) { 1152 s.RegisterService(&_Executor_serviceDesc, srv) 1153} 1154 1155func _Executor_Launch_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1156 in := new(LaunchRequest) 1157 if err := dec(in); err != nil { 1158 return nil, err 1159 } 1160 if interceptor == nil { 1161 return srv.(ExecutorServer).Launch(ctx, in) 1162 } 1163 info := &grpc.UnaryServerInfo{ 1164 Server: srv, 1165 FullMethod: "/hashicorp.nomad.plugins.executor.proto.Executor/Launch", 1166 } 1167 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1168 return srv.(ExecutorServer).Launch(ctx, req.(*LaunchRequest)) 1169 } 1170 return interceptor(ctx, in, info, handler) 1171} 1172 1173func _Executor_Wait_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1174 in := new(WaitRequest) 1175 if err := dec(in); err != nil { 1176 return nil, err 1177 } 1178 if interceptor == nil { 1179 return srv.(ExecutorServer).Wait(ctx, in) 1180 } 1181 info := &grpc.UnaryServerInfo{ 1182 Server: srv, 1183 FullMethod: "/hashicorp.nomad.plugins.executor.proto.Executor/Wait", 1184 } 1185 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1186 return srv.(ExecutorServer).Wait(ctx, req.(*WaitRequest)) 1187 } 1188 return interceptor(ctx, in, info, handler) 1189} 1190 1191func _Executor_Shutdown_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1192 in := new(ShutdownRequest) 1193 if err := dec(in); err != nil { 1194 return nil, err 1195 } 1196 if interceptor == nil { 1197 return srv.(ExecutorServer).Shutdown(ctx, in) 1198 } 1199 info := &grpc.UnaryServerInfo{ 1200 Server: srv, 1201 FullMethod: "/hashicorp.nomad.plugins.executor.proto.Executor/Shutdown", 1202 } 1203 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1204 return srv.(ExecutorServer).Shutdown(ctx, req.(*ShutdownRequest)) 1205 } 1206 return interceptor(ctx, in, info, handler) 1207} 1208 1209func _Executor_UpdateResources_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1210 in := new(UpdateResourcesRequest) 1211 if err := dec(in); err != nil { 1212 return nil, err 1213 } 1214 if interceptor == nil { 1215 return srv.(ExecutorServer).UpdateResources(ctx, in) 1216 } 1217 info := &grpc.UnaryServerInfo{ 1218 Server: srv, 1219 FullMethod: "/hashicorp.nomad.plugins.executor.proto.Executor/UpdateResources", 1220 } 1221 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1222 return srv.(ExecutorServer).UpdateResources(ctx, req.(*UpdateResourcesRequest)) 1223 } 1224 return interceptor(ctx, in, info, handler) 1225} 1226 1227func _Executor_Version_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1228 in := new(VersionRequest) 1229 if err := dec(in); err != nil { 1230 return nil, err 1231 } 1232 if interceptor == nil { 1233 return srv.(ExecutorServer).Version(ctx, in) 1234 } 1235 info := &grpc.UnaryServerInfo{ 1236 Server: srv, 1237 FullMethod: "/hashicorp.nomad.plugins.executor.proto.Executor/Version", 1238 } 1239 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1240 return srv.(ExecutorServer).Version(ctx, req.(*VersionRequest)) 1241 } 1242 return interceptor(ctx, in, info, handler) 1243} 1244 1245func _Executor_Stats_Handler(srv interface{}, stream grpc.ServerStream) error { 1246 m := new(StatsRequest) 1247 if err := stream.RecvMsg(m); err != nil { 1248 return err 1249 } 1250 return srv.(ExecutorServer).Stats(m, &executorStatsServer{stream}) 1251} 1252 1253type Executor_StatsServer interface { 1254 Send(*StatsResponse) error 1255 grpc.ServerStream 1256} 1257 1258type executorStatsServer struct { 1259 grpc.ServerStream 1260} 1261 1262func (x *executorStatsServer) Send(m *StatsResponse) error { 1263 return x.ServerStream.SendMsg(m) 1264} 1265 1266func _Executor_Signal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1267 in := new(SignalRequest) 1268 if err := dec(in); err != nil { 1269 return nil, err 1270 } 1271 if interceptor == nil { 1272 return srv.(ExecutorServer).Signal(ctx, in) 1273 } 1274 info := &grpc.UnaryServerInfo{ 1275 Server: srv, 1276 FullMethod: "/hashicorp.nomad.plugins.executor.proto.Executor/Signal", 1277 } 1278 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1279 return srv.(ExecutorServer).Signal(ctx, req.(*SignalRequest)) 1280 } 1281 return interceptor(ctx, in, info, handler) 1282} 1283 1284func _Executor_Exec_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1285 in := new(ExecRequest) 1286 if err := dec(in); err != nil { 1287 return nil, err 1288 } 1289 if interceptor == nil { 1290 return srv.(ExecutorServer).Exec(ctx, in) 1291 } 1292 info := &grpc.UnaryServerInfo{ 1293 Server: srv, 1294 FullMethod: "/hashicorp.nomad.plugins.executor.proto.Executor/Exec", 1295 } 1296 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1297 return srv.(ExecutorServer).Exec(ctx, req.(*ExecRequest)) 1298 } 1299 return interceptor(ctx, in, info, handler) 1300} 1301 1302func _Executor_ExecStreaming_Handler(srv interface{}, stream grpc.ServerStream) error { 1303 return srv.(ExecutorServer).ExecStreaming(&executorExecStreamingServer{stream}) 1304} 1305 1306type Executor_ExecStreamingServer interface { 1307 Send(*proto1.ExecTaskStreamingResponse) error 1308 Recv() (*proto1.ExecTaskStreamingRequest, error) 1309 grpc.ServerStream 1310} 1311 1312type executorExecStreamingServer struct { 1313 grpc.ServerStream 1314} 1315 1316func (x *executorExecStreamingServer) Send(m *proto1.ExecTaskStreamingResponse) error { 1317 return x.ServerStream.SendMsg(m) 1318} 1319 1320func (x *executorExecStreamingServer) Recv() (*proto1.ExecTaskStreamingRequest, error) { 1321 m := new(proto1.ExecTaskStreamingRequest) 1322 if err := x.ServerStream.RecvMsg(m); err != nil { 1323 return nil, err 1324 } 1325 return m, nil 1326} 1327 1328var _Executor_serviceDesc = grpc.ServiceDesc{ 1329 ServiceName: "hashicorp.nomad.plugins.executor.proto.Executor", 1330 HandlerType: (*ExecutorServer)(nil), 1331 Methods: []grpc.MethodDesc{ 1332 { 1333 MethodName: "Launch", 1334 Handler: _Executor_Launch_Handler, 1335 }, 1336 { 1337 MethodName: "Wait", 1338 Handler: _Executor_Wait_Handler, 1339 }, 1340 { 1341 MethodName: "Shutdown", 1342 Handler: _Executor_Shutdown_Handler, 1343 }, 1344 { 1345 MethodName: "UpdateResources", 1346 Handler: _Executor_UpdateResources_Handler, 1347 }, 1348 { 1349 MethodName: "Version", 1350 Handler: _Executor_Version_Handler, 1351 }, 1352 { 1353 MethodName: "Signal", 1354 Handler: _Executor_Signal_Handler, 1355 }, 1356 { 1357 MethodName: "Exec", 1358 Handler: _Executor_Exec_Handler, 1359 }, 1360 }, 1361 Streams: []grpc.StreamDesc{ 1362 { 1363 StreamName: "Stats", 1364 Handler: _Executor_Stats_Handler, 1365 ServerStreams: true, 1366 }, 1367 { 1368 StreamName: "ExecStreaming", 1369 Handler: _Executor_ExecStreaming_Handler, 1370 ServerStreams: true, 1371 ClientStreams: true, 1372 }, 1373 }, 1374 Metadata: "drivers/shared/executor/proto/executor.proto", 1375} 1376