1// Copyright 2020 Google LLC 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// http://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14 15// Code generated by protoc-gen-go. DO NOT EDIT. 16// versions: 17// protoc-gen-go v1.26.0 18// protoc v3.12.2 19// source: google/cloud/workflows/executions/v1/executions.proto 20 21package executions 22 23import ( 24 context "context" 25 reflect "reflect" 26 sync "sync" 27 28 _ "google.golang.org/genproto/googleapis/api/annotations" 29 grpc "google.golang.org/grpc" 30 codes "google.golang.org/grpc/codes" 31 status "google.golang.org/grpc/status" 32 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 33 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 34 timestamppb "google.golang.org/protobuf/types/known/timestamppb" 35) 36 37const ( 38 // Verify that this generated code is sufficiently up-to-date. 39 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 40 // Verify that runtime/protoimpl is sufficiently up-to-date. 41 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 42) 43 44// Defines possible views for execution resource. 45type ExecutionView int32 46 47const ( 48 // The default / unset value. 49 ExecutionView_EXECUTION_VIEW_UNSPECIFIED ExecutionView = 0 50 // Includes only basic metadata about the execution. 51 // Following fields are returned: name, start_time, end_time, state 52 // and workflow_revision_id. 53 ExecutionView_BASIC ExecutionView = 1 54 // Includes all data. 55 ExecutionView_FULL ExecutionView = 2 56) 57 58// Enum value maps for ExecutionView. 59var ( 60 ExecutionView_name = map[int32]string{ 61 0: "EXECUTION_VIEW_UNSPECIFIED", 62 1: "BASIC", 63 2: "FULL", 64 } 65 ExecutionView_value = map[string]int32{ 66 "EXECUTION_VIEW_UNSPECIFIED": 0, 67 "BASIC": 1, 68 "FULL": 2, 69 } 70) 71 72func (x ExecutionView) Enum() *ExecutionView { 73 p := new(ExecutionView) 74 *p = x 75 return p 76} 77 78func (x ExecutionView) String() string { 79 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 80} 81 82func (ExecutionView) Descriptor() protoreflect.EnumDescriptor { 83 return file_google_cloud_workflows_executions_v1_executions_proto_enumTypes[0].Descriptor() 84} 85 86func (ExecutionView) Type() protoreflect.EnumType { 87 return &file_google_cloud_workflows_executions_v1_executions_proto_enumTypes[0] 88} 89 90func (x ExecutionView) Number() protoreflect.EnumNumber { 91 return protoreflect.EnumNumber(x) 92} 93 94// Deprecated: Use ExecutionView.Descriptor instead. 95func (ExecutionView) EnumDescriptor() ([]byte, []int) { 96 return file_google_cloud_workflows_executions_v1_executions_proto_rawDescGZIP(), []int{0} 97} 98 99// Describes the current state of the execution. More states may be added 100// in the future. 101type Execution_State int32 102 103const ( 104 // Invalid state. 105 Execution_STATE_UNSPECIFIED Execution_State = 0 106 // The execution is in progress. 107 Execution_ACTIVE Execution_State = 1 108 // The execution finished successfully. 109 Execution_SUCCEEDED Execution_State = 2 110 // The execution failed with an error. 111 Execution_FAILED Execution_State = 3 112 // The execution was stopped intentionally. 113 Execution_CANCELLED Execution_State = 4 114) 115 116// Enum value maps for Execution_State. 117var ( 118 Execution_State_name = map[int32]string{ 119 0: "STATE_UNSPECIFIED", 120 1: "ACTIVE", 121 2: "SUCCEEDED", 122 3: "FAILED", 123 4: "CANCELLED", 124 } 125 Execution_State_value = map[string]int32{ 126 "STATE_UNSPECIFIED": 0, 127 "ACTIVE": 1, 128 "SUCCEEDED": 2, 129 "FAILED": 3, 130 "CANCELLED": 4, 131 } 132) 133 134func (x Execution_State) Enum() *Execution_State { 135 p := new(Execution_State) 136 *p = x 137 return p 138} 139 140func (x Execution_State) String() string { 141 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 142} 143 144func (Execution_State) Descriptor() protoreflect.EnumDescriptor { 145 return file_google_cloud_workflows_executions_v1_executions_proto_enumTypes[1].Descriptor() 146} 147 148func (Execution_State) Type() protoreflect.EnumType { 149 return &file_google_cloud_workflows_executions_v1_executions_proto_enumTypes[1] 150} 151 152func (x Execution_State) Number() protoreflect.EnumNumber { 153 return protoreflect.EnumNumber(x) 154} 155 156// Deprecated: Use Execution_State.Descriptor instead. 157func (Execution_State) EnumDescriptor() ([]byte, []int) { 158 return file_google_cloud_workflows_executions_v1_executions_proto_rawDescGZIP(), []int{0, 0} 159} 160 161// A running instance of a 162// [Workflow](/workflows/docs/reference/rest/v1/projects.locations.workflows). 163type Execution struct { 164 state protoimpl.MessageState 165 sizeCache protoimpl.SizeCache 166 unknownFields protoimpl.UnknownFields 167 168 // Output only. The resource name of the execution. 169 // Format: 170 // projects/{project}/locations/{location}/workflows/{workflow}/executions/{execution} 171 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 172 // Output only. Marks the beginning of execution. 173 StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` 174 // Output only. Marks the end of execution, successful or not. 175 EndTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` 176 // Output only. Current state of the execution. 177 State Execution_State `protobuf:"varint,4,opt,name=state,proto3,enum=google.cloud.workflows.executions.v1.Execution_State" json:"state,omitempty"` 178 // Input parameters of the execution represented as a JSON string. 179 // The size limit is 32KB. 180 Argument string `protobuf:"bytes,5,opt,name=argument,proto3" json:"argument,omitempty"` 181 // Output only. Output of the execution represented as a JSON string. The 182 // value can only be present if the execution's state is `SUCCEEDED`. 183 Result string `protobuf:"bytes,6,opt,name=result,proto3" json:"result,omitempty"` 184 // Output only. The error which caused the execution to finish prematurely. 185 // The value is only present if the execution's state is `FAILED` 186 // or `CANCELLED`. 187 Error *Execution_Error `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"` 188 // Output only. Revision of the workflow this execution is using. 189 WorkflowRevisionId string `protobuf:"bytes,8,opt,name=workflow_revision_id,json=workflowRevisionId,proto3" json:"workflow_revision_id,omitempty"` 190} 191 192func (x *Execution) Reset() { 193 *x = Execution{} 194 if protoimpl.UnsafeEnabled { 195 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[0] 196 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 197 ms.StoreMessageInfo(mi) 198 } 199} 200 201func (x *Execution) String() string { 202 return protoimpl.X.MessageStringOf(x) 203} 204 205func (*Execution) ProtoMessage() {} 206 207func (x *Execution) ProtoReflect() protoreflect.Message { 208 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[0] 209 if protoimpl.UnsafeEnabled && x != nil { 210 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 211 if ms.LoadMessageInfo() == nil { 212 ms.StoreMessageInfo(mi) 213 } 214 return ms 215 } 216 return mi.MessageOf(x) 217} 218 219// Deprecated: Use Execution.ProtoReflect.Descriptor instead. 220func (*Execution) Descriptor() ([]byte, []int) { 221 return file_google_cloud_workflows_executions_v1_executions_proto_rawDescGZIP(), []int{0} 222} 223 224func (x *Execution) GetName() string { 225 if x != nil { 226 return x.Name 227 } 228 return "" 229} 230 231func (x *Execution) GetStartTime() *timestamppb.Timestamp { 232 if x != nil { 233 return x.StartTime 234 } 235 return nil 236} 237 238func (x *Execution) GetEndTime() *timestamppb.Timestamp { 239 if x != nil { 240 return x.EndTime 241 } 242 return nil 243} 244 245func (x *Execution) GetState() Execution_State { 246 if x != nil { 247 return x.State 248 } 249 return Execution_STATE_UNSPECIFIED 250} 251 252func (x *Execution) GetArgument() string { 253 if x != nil { 254 return x.Argument 255 } 256 return "" 257} 258 259func (x *Execution) GetResult() string { 260 if x != nil { 261 return x.Result 262 } 263 return "" 264} 265 266func (x *Execution) GetError() *Execution_Error { 267 if x != nil { 268 return x.Error 269 } 270 return nil 271} 272 273func (x *Execution) GetWorkflowRevisionId() string { 274 if x != nil { 275 return x.WorkflowRevisionId 276 } 277 return "" 278} 279 280// Request for the 281// [ListExecutions][] 282// method. 283type ListExecutionsRequest struct { 284 state protoimpl.MessageState 285 sizeCache protoimpl.SizeCache 286 unknownFields protoimpl.UnknownFields 287 288 // Required. Name of the workflow for which the executions should be listed. 289 // Format: projects/{project}/locations/{location}/workflows/{workflow} 290 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 291 // Maximum number of executions to return per call. 292 // Max supported value depends on the selected Execution view: it's 10000 for 293 // BASIC and 100 for FULL. The default value used if the field is not 294 // specified is 100, regardless of the selected view. Values greater than 295 // the max value will be coerced down to it. 296 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 297 // A page token, received from a previous `ListExecutions` call. 298 // Provide this to retrieve the subsequent page. 299 // 300 // When paginating, all other parameters provided to `ListExecutions` must 301 // match the call that provided the page token. 302 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 303 // Optional. A view defining which fields should be filled in the returned executions. 304 // The API will default to the BASIC view. 305 View ExecutionView `protobuf:"varint,4,opt,name=view,proto3,enum=google.cloud.workflows.executions.v1.ExecutionView" json:"view,omitempty"` 306} 307 308func (x *ListExecutionsRequest) Reset() { 309 *x = ListExecutionsRequest{} 310 if protoimpl.UnsafeEnabled { 311 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[1] 312 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 313 ms.StoreMessageInfo(mi) 314 } 315} 316 317func (x *ListExecutionsRequest) String() string { 318 return protoimpl.X.MessageStringOf(x) 319} 320 321func (*ListExecutionsRequest) ProtoMessage() {} 322 323func (x *ListExecutionsRequest) ProtoReflect() protoreflect.Message { 324 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[1] 325 if protoimpl.UnsafeEnabled && x != nil { 326 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 327 if ms.LoadMessageInfo() == nil { 328 ms.StoreMessageInfo(mi) 329 } 330 return ms 331 } 332 return mi.MessageOf(x) 333} 334 335// Deprecated: Use ListExecutionsRequest.ProtoReflect.Descriptor instead. 336func (*ListExecutionsRequest) Descriptor() ([]byte, []int) { 337 return file_google_cloud_workflows_executions_v1_executions_proto_rawDescGZIP(), []int{1} 338} 339 340func (x *ListExecutionsRequest) GetParent() string { 341 if x != nil { 342 return x.Parent 343 } 344 return "" 345} 346 347func (x *ListExecutionsRequest) GetPageSize() int32 { 348 if x != nil { 349 return x.PageSize 350 } 351 return 0 352} 353 354func (x *ListExecutionsRequest) GetPageToken() string { 355 if x != nil { 356 return x.PageToken 357 } 358 return "" 359} 360 361func (x *ListExecutionsRequest) GetView() ExecutionView { 362 if x != nil { 363 return x.View 364 } 365 return ExecutionView_EXECUTION_VIEW_UNSPECIFIED 366} 367 368// Response for the 369// [ListExecutions][google.cloud.workflows.executions.v1.Executions.ListExecutions] 370// method. 371type ListExecutionsResponse struct { 372 state protoimpl.MessageState 373 sizeCache protoimpl.SizeCache 374 unknownFields protoimpl.UnknownFields 375 376 // The executions which match the request. 377 Executions []*Execution `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"` 378 // A token, which can be sent as `page_token` to retrieve the next page. 379 // If this field is omitted, there are no subsequent pages. 380 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 381} 382 383func (x *ListExecutionsResponse) Reset() { 384 *x = ListExecutionsResponse{} 385 if protoimpl.UnsafeEnabled { 386 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[2] 387 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 388 ms.StoreMessageInfo(mi) 389 } 390} 391 392func (x *ListExecutionsResponse) String() string { 393 return protoimpl.X.MessageStringOf(x) 394} 395 396func (*ListExecutionsResponse) ProtoMessage() {} 397 398func (x *ListExecutionsResponse) ProtoReflect() protoreflect.Message { 399 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[2] 400 if protoimpl.UnsafeEnabled && x != nil { 401 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 402 if ms.LoadMessageInfo() == nil { 403 ms.StoreMessageInfo(mi) 404 } 405 return ms 406 } 407 return mi.MessageOf(x) 408} 409 410// Deprecated: Use ListExecutionsResponse.ProtoReflect.Descriptor instead. 411func (*ListExecutionsResponse) Descriptor() ([]byte, []int) { 412 return file_google_cloud_workflows_executions_v1_executions_proto_rawDescGZIP(), []int{2} 413} 414 415func (x *ListExecutionsResponse) GetExecutions() []*Execution { 416 if x != nil { 417 return x.Executions 418 } 419 return nil 420} 421 422func (x *ListExecutionsResponse) GetNextPageToken() string { 423 if x != nil { 424 return x.NextPageToken 425 } 426 return "" 427} 428 429// Request for the 430// [CreateExecution][google.cloud.workflows.executions.v1.Executions.CreateExecution] 431// method. 432type CreateExecutionRequest struct { 433 state protoimpl.MessageState 434 sizeCache protoimpl.SizeCache 435 unknownFields protoimpl.UnknownFields 436 437 // Required. Name of the workflow for which an execution should be created. 438 // Format: projects/{project}/locations/{location}/workflows/{workflow} 439 // The latest revision of the workflow will be used. 440 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 441 // Required. Execution to be created. 442 Execution *Execution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"` 443} 444 445func (x *CreateExecutionRequest) Reset() { 446 *x = CreateExecutionRequest{} 447 if protoimpl.UnsafeEnabled { 448 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[3] 449 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 450 ms.StoreMessageInfo(mi) 451 } 452} 453 454func (x *CreateExecutionRequest) String() string { 455 return protoimpl.X.MessageStringOf(x) 456} 457 458func (*CreateExecutionRequest) ProtoMessage() {} 459 460func (x *CreateExecutionRequest) ProtoReflect() protoreflect.Message { 461 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[3] 462 if protoimpl.UnsafeEnabled && x != nil { 463 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 464 if ms.LoadMessageInfo() == nil { 465 ms.StoreMessageInfo(mi) 466 } 467 return ms 468 } 469 return mi.MessageOf(x) 470} 471 472// Deprecated: Use CreateExecutionRequest.ProtoReflect.Descriptor instead. 473func (*CreateExecutionRequest) Descriptor() ([]byte, []int) { 474 return file_google_cloud_workflows_executions_v1_executions_proto_rawDescGZIP(), []int{3} 475} 476 477func (x *CreateExecutionRequest) GetParent() string { 478 if x != nil { 479 return x.Parent 480 } 481 return "" 482} 483 484func (x *CreateExecutionRequest) GetExecution() *Execution { 485 if x != nil { 486 return x.Execution 487 } 488 return nil 489} 490 491// Request for the 492// [GetExecution][google.cloud.workflows.executions.v1.Executions.GetExecution] 493// method. 494type GetExecutionRequest struct { 495 state protoimpl.MessageState 496 sizeCache protoimpl.SizeCache 497 unknownFields protoimpl.UnknownFields 498 499 // Required. Name of the execution to be retrieved. 500 // Format: 501 // projects/{project}/locations/{location}/workflows/{workflow}/executions/{execution} 502 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 503 // Optional. A view defining which fields should be filled in the returned execution. 504 // The API will default to the FULL view. 505 View ExecutionView `protobuf:"varint,2,opt,name=view,proto3,enum=google.cloud.workflows.executions.v1.ExecutionView" json:"view,omitempty"` 506} 507 508func (x *GetExecutionRequest) Reset() { 509 *x = GetExecutionRequest{} 510 if protoimpl.UnsafeEnabled { 511 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[4] 512 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 513 ms.StoreMessageInfo(mi) 514 } 515} 516 517func (x *GetExecutionRequest) String() string { 518 return protoimpl.X.MessageStringOf(x) 519} 520 521func (*GetExecutionRequest) ProtoMessage() {} 522 523func (x *GetExecutionRequest) ProtoReflect() protoreflect.Message { 524 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[4] 525 if protoimpl.UnsafeEnabled && x != nil { 526 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 527 if ms.LoadMessageInfo() == nil { 528 ms.StoreMessageInfo(mi) 529 } 530 return ms 531 } 532 return mi.MessageOf(x) 533} 534 535// Deprecated: Use GetExecutionRequest.ProtoReflect.Descriptor instead. 536func (*GetExecutionRequest) Descriptor() ([]byte, []int) { 537 return file_google_cloud_workflows_executions_v1_executions_proto_rawDescGZIP(), []int{4} 538} 539 540func (x *GetExecutionRequest) GetName() string { 541 if x != nil { 542 return x.Name 543 } 544 return "" 545} 546 547func (x *GetExecutionRequest) GetView() ExecutionView { 548 if x != nil { 549 return x.View 550 } 551 return ExecutionView_EXECUTION_VIEW_UNSPECIFIED 552} 553 554// Request for the 555// [CancelExecution][google.cloud.workflows.executions.v1.Executions.CancelExecution] 556// method. 557type CancelExecutionRequest struct { 558 state protoimpl.MessageState 559 sizeCache protoimpl.SizeCache 560 unknownFields protoimpl.UnknownFields 561 562 // Required. Name of the execution to be cancelled. 563 // Format: 564 // projects/{project}/locations/{location}/workflows/{workflow}/executions/{execution} 565 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 566} 567 568func (x *CancelExecutionRequest) Reset() { 569 *x = CancelExecutionRequest{} 570 if protoimpl.UnsafeEnabled { 571 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[5] 572 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 573 ms.StoreMessageInfo(mi) 574 } 575} 576 577func (x *CancelExecutionRequest) String() string { 578 return protoimpl.X.MessageStringOf(x) 579} 580 581func (*CancelExecutionRequest) ProtoMessage() {} 582 583func (x *CancelExecutionRequest) ProtoReflect() protoreflect.Message { 584 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[5] 585 if protoimpl.UnsafeEnabled && x != nil { 586 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 587 if ms.LoadMessageInfo() == nil { 588 ms.StoreMessageInfo(mi) 589 } 590 return ms 591 } 592 return mi.MessageOf(x) 593} 594 595// Deprecated: Use CancelExecutionRequest.ProtoReflect.Descriptor instead. 596func (*CancelExecutionRequest) Descriptor() ([]byte, []int) { 597 return file_google_cloud_workflows_executions_v1_executions_proto_rawDescGZIP(), []int{5} 598} 599 600func (x *CancelExecutionRequest) GetName() string { 601 if x != nil { 602 return x.Name 603 } 604 return "" 605} 606 607// Error describes why the execution was abnormally terminated. 608type Execution_Error struct { 609 state protoimpl.MessageState 610 sizeCache protoimpl.SizeCache 611 unknownFields protoimpl.UnknownFields 612 613 // Error payload returned by the execution, represented as a JSON string. 614 Payload string `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` 615 // Human readable error context, helpful for debugging purposes. 616 Context string `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"` 617} 618 619func (x *Execution_Error) Reset() { 620 *x = Execution_Error{} 621 if protoimpl.UnsafeEnabled { 622 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[6] 623 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 624 ms.StoreMessageInfo(mi) 625 } 626} 627 628func (x *Execution_Error) String() string { 629 return protoimpl.X.MessageStringOf(x) 630} 631 632func (*Execution_Error) ProtoMessage() {} 633 634func (x *Execution_Error) ProtoReflect() protoreflect.Message { 635 mi := &file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[6] 636 if protoimpl.UnsafeEnabled && x != nil { 637 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 638 if ms.LoadMessageInfo() == nil { 639 ms.StoreMessageInfo(mi) 640 } 641 return ms 642 } 643 return mi.MessageOf(x) 644} 645 646// Deprecated: Use Execution_Error.ProtoReflect.Descriptor instead. 647func (*Execution_Error) Descriptor() ([]byte, []int) { 648 return file_google_cloud_workflows_executions_v1_executions_proto_rawDescGZIP(), []int{0, 0} 649} 650 651func (x *Execution_Error) GetPayload() string { 652 if x != nil { 653 return x.Payload 654 } 655 return "" 656} 657 658func (x *Execution_Error) GetContext() string { 659 if x != nil { 660 return x.Context 661 } 662 return "" 663} 664 665var File_google_cloud_workflows_executions_v1_executions_proto protoreflect.FileDescriptor 666 667var file_google_cloud_workflows_executions_v1_executions_proto_rawDesc = []byte{ 668 0x0a, 0x35, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x77, 669 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 670 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x31, 0x2f, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 671 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x24, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 672 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2e, 673 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 0x31, 0x1a, 0x1c, 0x67, 674 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 675 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 676 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 677 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 678 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 679 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 680 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 681 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 682 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 683 0x6f, 0x22, 0xd0, 0x05, 0x0a, 0x09, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x12, 684 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 685 0x41, 0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x3e, 0x0a, 0x0a, 0x73, 0x74, 0x61, 0x72, 686 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 687 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 688 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x09, 0x73, 689 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x3a, 0x0a, 0x08, 0x65, 0x6e, 0x64, 0x5f, 690 0x74, 0x69, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 691 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 692 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x07, 0x65, 0x6e, 0x64, 693 0x54, 0x69, 0x6d, 0x65, 0x12, 0x50, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x04, 0x20, 694 0x01, 0x28, 0x0e, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 695 0x75, 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x65, 0x78, 0x65, 696 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 697 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 698 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x61, 0x72, 0x67, 0x75, 0x6d, 0x65, 699 0x6e, 0x74, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x61, 0x72, 0x67, 0x75, 0x6d, 0x65, 700 0x6e, 0x74, 0x12, 0x1b, 0x0a, 0x06, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x18, 0x06, 0x20, 0x01, 701 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x06, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 702 0x50, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x35, 703 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x77, 0x6f, 704 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 705 0x6e, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 706 0x45, 0x72, 0x72, 0x6f, 0x72, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 707 0x72, 0x12, 0x35, 0x0a, 0x14, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x5f, 0x72, 0x65, 708 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x42, 709 0x03, 0xe0, 0x41, 0x03, 0x52, 0x12, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x65, 710 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x1a, 0x3b, 0x0a, 0x05, 0x45, 0x72, 0x72, 0x6f, 711 0x72, 0x12, 0x18, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18, 0x01, 0x20, 0x01, 712 0x28, 0x09, 0x52, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x63, 713 0x6f, 0x6e, 0x74, 0x65, 0x78, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 714 0x6e, 0x74, 0x65, 0x78, 0x74, 0x22, 0x54, 0x0a, 0x05, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x15, 715 0x0a, 0x11, 0x53, 0x54, 0x41, 0x54, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 716 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x41, 0x43, 0x54, 0x49, 0x56, 0x45, 0x10, 717 0x01, 0x12, 0x0d, 0x0a, 0x09, 0x53, 0x55, 0x43, 0x43, 0x45, 0x45, 0x44, 0x45, 0x44, 0x10, 0x02, 718 0x12, 0x0a, 0x0a, 0x06, 0x46, 0x41, 0x49, 0x4c, 0x45, 0x44, 0x10, 0x03, 0x12, 0x0d, 0x0a, 0x09, 719 0x43, 0x41, 0x4e, 0x43, 0x45, 0x4c, 0x4c, 0x45, 0x44, 0x10, 0x04, 0x3a, 0x86, 0x01, 0xea, 0x41, 720 0x82, 0x01, 0x0a, 0x2b, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x65, 0x78, 0x65, 0x63, 721 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 722 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x12, 723 0x53, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 724 0x63, 0x74, 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 725 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 726 0x77, 0x73, 0x2f, 0x7b, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x7d, 0x2f, 0x65, 0x78, 727 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 728 0x69, 0x6f, 0x6e, 0x7d, 0x22, 0xe4, 0x01, 0x0a, 0x15, 0x4c, 0x69, 0x73, 0x74, 0x45, 0x78, 0x65, 729 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 730 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 731 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 732 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 733 0x2f, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 734 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x02, 735 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 736 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x03, 0x20, 0x01, 737 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x4c, 0x0a, 738 0x04, 0x76, 0x69, 0x65, 0x77, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x33, 0x2e, 0x67, 0x6f, 739 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 740 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 741 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x56, 0x69, 0x65, 0x77, 742 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x04, 0x76, 0x69, 0x65, 0x77, 0x22, 0x91, 0x01, 0x0a, 0x16, 743 0x4c, 0x69, 0x73, 0x74, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 744 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4f, 0x0a, 0x0a, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 745 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 746 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 747 0x6f, 0x77, 0x73, 0x2e, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 748 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0a, 0x65, 0x78, 0x65, 749 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 750 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 751 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 752 0xaf, 0x01, 0x0a, 0x16, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 753 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70, 0x61, 754 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 755 0x41, 0x23, 0x0a, 0x21, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x67, 0x6f, 756 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x6f, 0x72, 757 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x52, 0x0a, 758 0x09, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 759 0x32, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 760 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 761 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 762 0x6e, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x09, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 763 0x6e, 0x22, 0xac, 0x01, 0x0a, 0x13, 0x47, 0x65, 0x74, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 764 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x47, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 765 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x33, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2d, 0x0a, 766 0x2b, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 767 0x6f, 0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 768 0x6f, 0x6d, 0x2f, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x04, 0x6e, 0x61, 769 0x6d, 0x65, 0x12, 0x4c, 0x0a, 0x04, 0x76, 0x69, 0x65, 0x77, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 770 0x32, 0x33, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 771 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 772 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 773 0x6e, 0x56, 0x69, 0x65, 0x77, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x04, 0x76, 0x69, 0x65, 0x77, 774 0x22, 0x61, 0x0a, 0x16, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 775 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x47, 0x0a, 0x04, 0x6e, 0x61, 776 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x33, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2d, 777 0x0a, 0x2b, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 778 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 779 0x63, 0x6f, 0x6d, 0x2f, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x04, 0x6e, 780 0x61, 0x6d, 0x65, 0x2a, 0x44, 0x0a, 0x0d, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 781 0x56, 0x69, 0x65, 0x77, 0x12, 0x1e, 0x0a, 0x1a, 0x45, 0x58, 0x45, 0x43, 0x55, 0x54, 0x49, 0x4f, 782 0x4e, 0x5f, 0x56, 0x49, 0x45, 0x57, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 783 0x45, 0x44, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x42, 0x41, 0x53, 0x49, 0x43, 0x10, 0x01, 0x12, 784 0x08, 0x0a, 0x04, 0x46, 0x55, 0x4c, 0x4c, 0x10, 0x02, 0x32, 0xc3, 0x07, 0x0a, 0x0a, 0x45, 0x78, 785 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0xd8, 0x01, 0x0a, 0x0e, 0x4c, 0x69, 0x73, 786 0x74, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x3b, 0x2e, 0x67, 0x6f, 787 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 788 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 789 0x76, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 790 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 791 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 792 0x73, 0x2e, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 0x31, 0x2e, 793 0x4c, 0x69, 0x73, 0x74, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 794 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x4b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3c, 0x12, 0x3a, 795 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 796 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 797 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 798 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 799 0x65, 0x6e, 0x74, 0x12, 0xe2, 0x01, 0x0a, 0x0f, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x45, 0x78, 800 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x3c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 801 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 802 0x2e, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x43, 803 0x72, 0x65, 0x61, 0x74, 0x65, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 804 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 805 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x65, 806 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65, 807 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x60, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x47, 0x22, 0x3a, 808 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 809 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 810 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 811 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x3a, 0x09, 0x65, 0x78, 0x65, 0x63, 812 0x75, 0x74, 0x69, 0x6f, 0x6e, 0xda, 0x41, 0x10, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x65, 813 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0xc5, 0x01, 0x0a, 0x0c, 0x47, 0x65, 0x74, 814 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x39, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 815 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 816 0x77, 0x73, 0x2e, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 0x31, 817 0x2e, 0x47, 0x65, 0x74, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 818 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 819 0x6f, 0x75, 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x65, 0x78, 820 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 821 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x49, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3c, 0x12, 0x3a, 0x2f, 822 0x76, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 823 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 824 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x2a, 0x2f, 0x65, 0x78, 0x65, 0x63, 825 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 826 0x12, 0xd5, 0x01, 0x0a, 0x0f, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x45, 0x78, 0x65, 0x63, 0x75, 827 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x3c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 828 0x6f, 0x75, 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x65, 0x78, 829 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x61, 0x6e, 0x63, 830 0x65, 0x6c, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 831 0x73, 0x74, 0x1a, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 832 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x65, 0x78, 0x65, 0x63, 833 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 834 0x69, 0x6f, 0x6e, 0x22, 0x53, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x46, 0x22, 0x41, 0x2f, 0x76, 0x31, 835 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 836 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 837 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x2a, 0x2f, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 838 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x63, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x3a, 0x01, 839 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x1a, 0x55, 0xca, 0x41, 0x21, 0x77, 0x6f, 0x72, 840 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 841 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 842 0x2e, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 843 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 844 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x42, 845 0xf1, 0x01, 0x0a, 0x28, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 846 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x65, 847 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x76, 0x31, 0x42, 0x0f, 0x45, 0x78, 848 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 849 0x4e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 850 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 851 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x77, 0x6f, 0x72, 852 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 853 0x73, 0x2f, 0x76, 0x31, 0x3b, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0xea, 854 0x41, 0x61, 0x0a, 0x21, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2e, 0x67, 0x6f, 855 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x6f, 0x72, 856 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x12, 0x3c, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 857 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 858 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x77, 859 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x7b, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 860 0x6f, 0x77, 0x7d, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 861} 862 863var ( 864 file_google_cloud_workflows_executions_v1_executions_proto_rawDescOnce sync.Once 865 file_google_cloud_workflows_executions_v1_executions_proto_rawDescData = file_google_cloud_workflows_executions_v1_executions_proto_rawDesc 866) 867 868func file_google_cloud_workflows_executions_v1_executions_proto_rawDescGZIP() []byte { 869 file_google_cloud_workflows_executions_v1_executions_proto_rawDescOnce.Do(func() { 870 file_google_cloud_workflows_executions_v1_executions_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_workflows_executions_v1_executions_proto_rawDescData) 871 }) 872 return file_google_cloud_workflows_executions_v1_executions_proto_rawDescData 873} 874 875var file_google_cloud_workflows_executions_v1_executions_proto_enumTypes = make([]protoimpl.EnumInfo, 2) 876var file_google_cloud_workflows_executions_v1_executions_proto_msgTypes = make([]protoimpl.MessageInfo, 7) 877var file_google_cloud_workflows_executions_v1_executions_proto_goTypes = []interface{}{ 878 (ExecutionView)(0), // 0: google.cloud.workflows.executions.v1.ExecutionView 879 (Execution_State)(0), // 1: google.cloud.workflows.executions.v1.Execution.State 880 (*Execution)(nil), // 2: google.cloud.workflows.executions.v1.Execution 881 (*ListExecutionsRequest)(nil), // 3: google.cloud.workflows.executions.v1.ListExecutionsRequest 882 (*ListExecutionsResponse)(nil), // 4: google.cloud.workflows.executions.v1.ListExecutionsResponse 883 (*CreateExecutionRequest)(nil), // 5: google.cloud.workflows.executions.v1.CreateExecutionRequest 884 (*GetExecutionRequest)(nil), // 6: google.cloud.workflows.executions.v1.GetExecutionRequest 885 (*CancelExecutionRequest)(nil), // 7: google.cloud.workflows.executions.v1.CancelExecutionRequest 886 (*Execution_Error)(nil), // 8: google.cloud.workflows.executions.v1.Execution.Error 887 (*timestamppb.Timestamp)(nil), // 9: google.protobuf.Timestamp 888} 889var file_google_cloud_workflows_executions_v1_executions_proto_depIdxs = []int32{ 890 9, // 0: google.cloud.workflows.executions.v1.Execution.start_time:type_name -> google.protobuf.Timestamp 891 9, // 1: google.cloud.workflows.executions.v1.Execution.end_time:type_name -> google.protobuf.Timestamp 892 1, // 2: google.cloud.workflows.executions.v1.Execution.state:type_name -> google.cloud.workflows.executions.v1.Execution.State 893 8, // 3: google.cloud.workflows.executions.v1.Execution.error:type_name -> google.cloud.workflows.executions.v1.Execution.Error 894 0, // 4: google.cloud.workflows.executions.v1.ListExecutionsRequest.view:type_name -> google.cloud.workflows.executions.v1.ExecutionView 895 2, // 5: google.cloud.workflows.executions.v1.ListExecutionsResponse.executions:type_name -> google.cloud.workflows.executions.v1.Execution 896 2, // 6: google.cloud.workflows.executions.v1.CreateExecutionRequest.execution:type_name -> google.cloud.workflows.executions.v1.Execution 897 0, // 7: google.cloud.workflows.executions.v1.GetExecutionRequest.view:type_name -> google.cloud.workflows.executions.v1.ExecutionView 898 3, // 8: google.cloud.workflows.executions.v1.Executions.ListExecutions:input_type -> google.cloud.workflows.executions.v1.ListExecutionsRequest 899 5, // 9: google.cloud.workflows.executions.v1.Executions.CreateExecution:input_type -> google.cloud.workflows.executions.v1.CreateExecutionRequest 900 6, // 10: google.cloud.workflows.executions.v1.Executions.GetExecution:input_type -> google.cloud.workflows.executions.v1.GetExecutionRequest 901 7, // 11: google.cloud.workflows.executions.v1.Executions.CancelExecution:input_type -> google.cloud.workflows.executions.v1.CancelExecutionRequest 902 4, // 12: google.cloud.workflows.executions.v1.Executions.ListExecutions:output_type -> google.cloud.workflows.executions.v1.ListExecutionsResponse 903 2, // 13: google.cloud.workflows.executions.v1.Executions.CreateExecution:output_type -> google.cloud.workflows.executions.v1.Execution 904 2, // 14: google.cloud.workflows.executions.v1.Executions.GetExecution:output_type -> google.cloud.workflows.executions.v1.Execution 905 2, // 15: google.cloud.workflows.executions.v1.Executions.CancelExecution:output_type -> google.cloud.workflows.executions.v1.Execution 906 12, // [12:16] is the sub-list for method output_type 907 8, // [8:12] is the sub-list for method input_type 908 8, // [8:8] is the sub-list for extension type_name 909 8, // [8:8] is the sub-list for extension extendee 910 0, // [0:8] is the sub-list for field type_name 911} 912 913func init() { file_google_cloud_workflows_executions_v1_executions_proto_init() } 914func file_google_cloud_workflows_executions_v1_executions_proto_init() { 915 if File_google_cloud_workflows_executions_v1_executions_proto != nil { 916 return 917 } 918 if !protoimpl.UnsafeEnabled { 919 file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 920 switch v := v.(*Execution); i { 921 case 0: 922 return &v.state 923 case 1: 924 return &v.sizeCache 925 case 2: 926 return &v.unknownFields 927 default: 928 return nil 929 } 930 } 931 file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 932 switch v := v.(*ListExecutionsRequest); i { 933 case 0: 934 return &v.state 935 case 1: 936 return &v.sizeCache 937 case 2: 938 return &v.unknownFields 939 default: 940 return nil 941 } 942 } 943 file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 944 switch v := v.(*ListExecutionsResponse); i { 945 case 0: 946 return &v.state 947 case 1: 948 return &v.sizeCache 949 case 2: 950 return &v.unknownFields 951 default: 952 return nil 953 } 954 } 955 file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 956 switch v := v.(*CreateExecutionRequest); i { 957 case 0: 958 return &v.state 959 case 1: 960 return &v.sizeCache 961 case 2: 962 return &v.unknownFields 963 default: 964 return nil 965 } 966 } 967 file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 968 switch v := v.(*GetExecutionRequest); i { 969 case 0: 970 return &v.state 971 case 1: 972 return &v.sizeCache 973 case 2: 974 return &v.unknownFields 975 default: 976 return nil 977 } 978 } 979 file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 980 switch v := v.(*CancelExecutionRequest); i { 981 case 0: 982 return &v.state 983 case 1: 984 return &v.sizeCache 985 case 2: 986 return &v.unknownFields 987 default: 988 return nil 989 } 990 } 991 file_google_cloud_workflows_executions_v1_executions_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 992 switch v := v.(*Execution_Error); i { 993 case 0: 994 return &v.state 995 case 1: 996 return &v.sizeCache 997 case 2: 998 return &v.unknownFields 999 default: 1000 return nil 1001 } 1002 } 1003 } 1004 type x struct{} 1005 out := protoimpl.TypeBuilder{ 1006 File: protoimpl.DescBuilder{ 1007 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 1008 RawDescriptor: file_google_cloud_workflows_executions_v1_executions_proto_rawDesc, 1009 NumEnums: 2, 1010 NumMessages: 7, 1011 NumExtensions: 0, 1012 NumServices: 1, 1013 }, 1014 GoTypes: file_google_cloud_workflows_executions_v1_executions_proto_goTypes, 1015 DependencyIndexes: file_google_cloud_workflows_executions_v1_executions_proto_depIdxs, 1016 EnumInfos: file_google_cloud_workflows_executions_v1_executions_proto_enumTypes, 1017 MessageInfos: file_google_cloud_workflows_executions_v1_executions_proto_msgTypes, 1018 }.Build() 1019 File_google_cloud_workflows_executions_v1_executions_proto = out.File 1020 file_google_cloud_workflows_executions_v1_executions_proto_rawDesc = nil 1021 file_google_cloud_workflows_executions_v1_executions_proto_goTypes = nil 1022 file_google_cloud_workflows_executions_v1_executions_proto_depIdxs = nil 1023} 1024 1025// Reference imports to suppress errors if they are not otherwise used. 1026var _ context.Context 1027var _ grpc.ClientConnInterface 1028 1029// This is a compile-time assertion to ensure that this generated file 1030// is compatible with the grpc package it is being compiled against. 1031const _ = grpc.SupportPackageIsVersion6 1032 1033// ExecutionsClient is the client API for Executions service. 1034// 1035// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1036type ExecutionsClient interface { 1037 // Returns a list of executions which belong to the workflow with 1038 // the given name. The method returns executions of all workflow 1039 // revisions. Returned executions are ordered by their start time (newest 1040 // first). 1041 ListExecutions(ctx context.Context, in *ListExecutionsRequest, opts ...grpc.CallOption) (*ListExecutionsResponse, error) 1042 // Creates a new execution using the latest revision of the given workflow. 1043 CreateExecution(ctx context.Context, in *CreateExecutionRequest, opts ...grpc.CallOption) (*Execution, error) 1044 // Returns an execution of the given name. 1045 GetExecution(ctx context.Context, in *GetExecutionRequest, opts ...grpc.CallOption) (*Execution, error) 1046 // Cancels an execution of the given name. 1047 CancelExecution(ctx context.Context, in *CancelExecutionRequest, opts ...grpc.CallOption) (*Execution, error) 1048} 1049 1050type executionsClient struct { 1051 cc grpc.ClientConnInterface 1052} 1053 1054func NewExecutionsClient(cc grpc.ClientConnInterface) ExecutionsClient { 1055 return &executionsClient{cc} 1056} 1057 1058func (c *executionsClient) ListExecutions(ctx context.Context, in *ListExecutionsRequest, opts ...grpc.CallOption) (*ListExecutionsResponse, error) { 1059 out := new(ListExecutionsResponse) 1060 err := c.cc.Invoke(ctx, "/google.cloud.workflows.executions.v1.Executions/ListExecutions", in, out, opts...) 1061 if err != nil { 1062 return nil, err 1063 } 1064 return out, nil 1065} 1066 1067func (c *executionsClient) CreateExecution(ctx context.Context, in *CreateExecutionRequest, opts ...grpc.CallOption) (*Execution, error) { 1068 out := new(Execution) 1069 err := c.cc.Invoke(ctx, "/google.cloud.workflows.executions.v1.Executions/CreateExecution", in, out, opts...) 1070 if err != nil { 1071 return nil, err 1072 } 1073 return out, nil 1074} 1075 1076func (c *executionsClient) GetExecution(ctx context.Context, in *GetExecutionRequest, opts ...grpc.CallOption) (*Execution, error) { 1077 out := new(Execution) 1078 err := c.cc.Invoke(ctx, "/google.cloud.workflows.executions.v1.Executions/GetExecution", in, out, opts...) 1079 if err != nil { 1080 return nil, err 1081 } 1082 return out, nil 1083} 1084 1085func (c *executionsClient) CancelExecution(ctx context.Context, in *CancelExecutionRequest, opts ...grpc.CallOption) (*Execution, error) { 1086 out := new(Execution) 1087 err := c.cc.Invoke(ctx, "/google.cloud.workflows.executions.v1.Executions/CancelExecution", in, out, opts...) 1088 if err != nil { 1089 return nil, err 1090 } 1091 return out, nil 1092} 1093 1094// ExecutionsServer is the server API for Executions service. 1095type ExecutionsServer interface { 1096 // Returns a list of executions which belong to the workflow with 1097 // the given name. The method returns executions of all workflow 1098 // revisions. Returned executions are ordered by their start time (newest 1099 // first). 1100 ListExecutions(context.Context, *ListExecutionsRequest) (*ListExecutionsResponse, error) 1101 // Creates a new execution using the latest revision of the given workflow. 1102 CreateExecution(context.Context, *CreateExecutionRequest) (*Execution, error) 1103 // Returns an execution of the given name. 1104 GetExecution(context.Context, *GetExecutionRequest) (*Execution, error) 1105 // Cancels an execution of the given name. 1106 CancelExecution(context.Context, *CancelExecutionRequest) (*Execution, error) 1107} 1108 1109// UnimplementedExecutionsServer can be embedded to have forward compatible implementations. 1110type UnimplementedExecutionsServer struct { 1111} 1112 1113func (*UnimplementedExecutionsServer) ListExecutions(context.Context, *ListExecutionsRequest) (*ListExecutionsResponse, error) { 1114 return nil, status.Errorf(codes.Unimplemented, "method ListExecutions not implemented") 1115} 1116func (*UnimplementedExecutionsServer) CreateExecution(context.Context, *CreateExecutionRequest) (*Execution, error) { 1117 return nil, status.Errorf(codes.Unimplemented, "method CreateExecution not implemented") 1118} 1119func (*UnimplementedExecutionsServer) GetExecution(context.Context, *GetExecutionRequest) (*Execution, error) { 1120 return nil, status.Errorf(codes.Unimplemented, "method GetExecution not implemented") 1121} 1122func (*UnimplementedExecutionsServer) CancelExecution(context.Context, *CancelExecutionRequest) (*Execution, error) { 1123 return nil, status.Errorf(codes.Unimplemented, "method CancelExecution not implemented") 1124} 1125 1126func RegisterExecutionsServer(s *grpc.Server, srv ExecutionsServer) { 1127 s.RegisterService(&_Executions_serviceDesc, srv) 1128} 1129 1130func _Executions_ListExecutions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1131 in := new(ListExecutionsRequest) 1132 if err := dec(in); err != nil { 1133 return nil, err 1134 } 1135 if interceptor == nil { 1136 return srv.(ExecutionsServer).ListExecutions(ctx, in) 1137 } 1138 info := &grpc.UnaryServerInfo{ 1139 Server: srv, 1140 FullMethod: "/google.cloud.workflows.executions.v1.Executions/ListExecutions", 1141 } 1142 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1143 return srv.(ExecutionsServer).ListExecutions(ctx, req.(*ListExecutionsRequest)) 1144 } 1145 return interceptor(ctx, in, info, handler) 1146} 1147 1148func _Executions_CreateExecution_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1149 in := new(CreateExecutionRequest) 1150 if err := dec(in); err != nil { 1151 return nil, err 1152 } 1153 if interceptor == nil { 1154 return srv.(ExecutionsServer).CreateExecution(ctx, in) 1155 } 1156 info := &grpc.UnaryServerInfo{ 1157 Server: srv, 1158 FullMethod: "/google.cloud.workflows.executions.v1.Executions/CreateExecution", 1159 } 1160 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1161 return srv.(ExecutionsServer).CreateExecution(ctx, req.(*CreateExecutionRequest)) 1162 } 1163 return interceptor(ctx, in, info, handler) 1164} 1165 1166func _Executions_GetExecution_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1167 in := new(GetExecutionRequest) 1168 if err := dec(in); err != nil { 1169 return nil, err 1170 } 1171 if interceptor == nil { 1172 return srv.(ExecutionsServer).GetExecution(ctx, in) 1173 } 1174 info := &grpc.UnaryServerInfo{ 1175 Server: srv, 1176 FullMethod: "/google.cloud.workflows.executions.v1.Executions/GetExecution", 1177 } 1178 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1179 return srv.(ExecutionsServer).GetExecution(ctx, req.(*GetExecutionRequest)) 1180 } 1181 return interceptor(ctx, in, info, handler) 1182} 1183 1184func _Executions_CancelExecution_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1185 in := new(CancelExecutionRequest) 1186 if err := dec(in); err != nil { 1187 return nil, err 1188 } 1189 if interceptor == nil { 1190 return srv.(ExecutionsServer).CancelExecution(ctx, in) 1191 } 1192 info := &grpc.UnaryServerInfo{ 1193 Server: srv, 1194 FullMethod: "/google.cloud.workflows.executions.v1.Executions/CancelExecution", 1195 } 1196 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1197 return srv.(ExecutionsServer).CancelExecution(ctx, req.(*CancelExecutionRequest)) 1198 } 1199 return interceptor(ctx, in, info, handler) 1200} 1201 1202var _Executions_serviceDesc = grpc.ServiceDesc{ 1203 ServiceName: "google.cloud.workflows.executions.v1.Executions", 1204 HandlerType: (*ExecutionsServer)(nil), 1205 Methods: []grpc.MethodDesc{ 1206 { 1207 MethodName: "ListExecutions", 1208 Handler: _Executions_ListExecutions_Handler, 1209 }, 1210 { 1211 MethodName: "CreateExecution", 1212 Handler: _Executions_CreateExecution_Handler, 1213 }, 1214 { 1215 MethodName: "GetExecution", 1216 Handler: _Executions_GetExecution_Handler, 1217 }, 1218 { 1219 MethodName: "CancelExecution", 1220 Handler: _Executions_CancelExecution_Handler, 1221 }, 1222 }, 1223 Streams: []grpc.StreamDesc{}, 1224 Metadata: "google/cloud/workflows/executions/v1/executions.proto", 1225} 1226