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.25.0-devel 18// protoc v3.13.0 19// source: google/pubsub/v1/schema.proto 20 21package pubsub 22 23import ( 24 context "context" 25 reflect "reflect" 26 sync "sync" 27 28 proto "github.com/golang/protobuf/proto" 29 _ "google.golang.org/genproto/googleapis/api/annotations" 30 grpc "google.golang.org/grpc" 31 codes "google.golang.org/grpc/codes" 32 status "google.golang.org/grpc/status" 33 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 34 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 35 emptypb "google.golang.org/protobuf/types/known/emptypb" 36) 37 38const ( 39 // Verify that this generated code is sufficiently up-to-date. 40 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 41 // Verify that runtime/protoimpl is sufficiently up-to-date. 42 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 43) 44 45// This is a compile-time assertion that a sufficiently up-to-date version 46// of the legacy proto package is being used. 47const _ = proto.ProtoPackageIsVersion4 48 49// View of Schema object fields to be returned by GetSchema and ListSchemas. 50type SchemaView int32 51 52const ( 53 // The default / unset value. 54 // The API will default to the BASIC view. 55 SchemaView_SCHEMA_VIEW_UNSPECIFIED SchemaView = 0 56 // Include the name and type of the schema, but not the definition. 57 SchemaView_BASIC SchemaView = 1 58 // Include all Schema object fields. 59 SchemaView_FULL SchemaView = 2 60) 61 62// Enum value maps for SchemaView. 63var ( 64 SchemaView_name = map[int32]string{ 65 0: "SCHEMA_VIEW_UNSPECIFIED", 66 1: "BASIC", 67 2: "FULL", 68 } 69 SchemaView_value = map[string]int32{ 70 "SCHEMA_VIEW_UNSPECIFIED": 0, 71 "BASIC": 1, 72 "FULL": 2, 73 } 74) 75 76func (x SchemaView) Enum() *SchemaView { 77 p := new(SchemaView) 78 *p = x 79 return p 80} 81 82func (x SchemaView) String() string { 83 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 84} 85 86func (SchemaView) Descriptor() protoreflect.EnumDescriptor { 87 return file_google_pubsub_v1_schema_proto_enumTypes[0].Descriptor() 88} 89 90func (SchemaView) Type() protoreflect.EnumType { 91 return &file_google_pubsub_v1_schema_proto_enumTypes[0] 92} 93 94func (x SchemaView) Number() protoreflect.EnumNumber { 95 return protoreflect.EnumNumber(x) 96} 97 98// Deprecated: Use SchemaView.Descriptor instead. 99func (SchemaView) EnumDescriptor() ([]byte, []int) { 100 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{0} 101} 102 103// Possible encoding types for messages. 104type Encoding int32 105 106const ( 107 // Unspecified 108 Encoding_ENCODING_UNSPECIFIED Encoding = 0 109 // JSON encoding 110 Encoding_JSON Encoding = 1 111 // Binary encoding, as defined by the schema type. For some schema types, 112 // binary encoding may not be available. 113 Encoding_BINARY Encoding = 2 114) 115 116// Enum value maps for Encoding. 117var ( 118 Encoding_name = map[int32]string{ 119 0: "ENCODING_UNSPECIFIED", 120 1: "JSON", 121 2: "BINARY", 122 } 123 Encoding_value = map[string]int32{ 124 "ENCODING_UNSPECIFIED": 0, 125 "JSON": 1, 126 "BINARY": 2, 127 } 128) 129 130func (x Encoding) Enum() *Encoding { 131 p := new(Encoding) 132 *p = x 133 return p 134} 135 136func (x Encoding) String() string { 137 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 138} 139 140func (Encoding) Descriptor() protoreflect.EnumDescriptor { 141 return file_google_pubsub_v1_schema_proto_enumTypes[1].Descriptor() 142} 143 144func (Encoding) Type() protoreflect.EnumType { 145 return &file_google_pubsub_v1_schema_proto_enumTypes[1] 146} 147 148func (x Encoding) Number() protoreflect.EnumNumber { 149 return protoreflect.EnumNumber(x) 150} 151 152// Deprecated: Use Encoding.Descriptor instead. 153func (Encoding) EnumDescriptor() ([]byte, []int) { 154 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{1} 155} 156 157// Possible schema definition types. 158type Schema_Type int32 159 160const ( 161 // Default value. This value is unused. 162 Schema_TYPE_UNSPECIFIED Schema_Type = 0 163 // A Protocol Buffer schema definition. 164 Schema_PROTOCOL_BUFFER Schema_Type = 1 165 // An Avro schema definition. 166 Schema_AVRO Schema_Type = 2 167) 168 169// Enum value maps for Schema_Type. 170var ( 171 Schema_Type_name = map[int32]string{ 172 0: "TYPE_UNSPECIFIED", 173 1: "PROTOCOL_BUFFER", 174 2: "AVRO", 175 } 176 Schema_Type_value = map[string]int32{ 177 "TYPE_UNSPECIFIED": 0, 178 "PROTOCOL_BUFFER": 1, 179 "AVRO": 2, 180 } 181) 182 183func (x Schema_Type) Enum() *Schema_Type { 184 p := new(Schema_Type) 185 *p = x 186 return p 187} 188 189func (x Schema_Type) String() string { 190 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 191} 192 193func (Schema_Type) Descriptor() protoreflect.EnumDescriptor { 194 return file_google_pubsub_v1_schema_proto_enumTypes[2].Descriptor() 195} 196 197func (Schema_Type) Type() protoreflect.EnumType { 198 return &file_google_pubsub_v1_schema_proto_enumTypes[2] 199} 200 201func (x Schema_Type) Number() protoreflect.EnumNumber { 202 return protoreflect.EnumNumber(x) 203} 204 205// Deprecated: Use Schema_Type.Descriptor instead. 206func (Schema_Type) EnumDescriptor() ([]byte, []int) { 207 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{0, 0} 208} 209 210// A schema resource. 211type Schema struct { 212 state protoimpl.MessageState 213 sizeCache protoimpl.SizeCache 214 unknownFields protoimpl.UnknownFields 215 216 // Required. Name of the schema. 217 // Format is `projects/{project}/schemas/{schema}`. 218 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 219 // The type of the schema definition. 220 Type Schema_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.pubsub.v1.Schema_Type" json:"type,omitempty"` 221 // The definition of the schema. This should contain a string representing 222 // the full definition of the schema that is a valid schema definition of 223 // the type specified in `type`. 224 Definition string `protobuf:"bytes,3,opt,name=definition,proto3" json:"definition,omitempty"` 225} 226 227func (x *Schema) Reset() { 228 *x = Schema{} 229 if protoimpl.UnsafeEnabled { 230 mi := &file_google_pubsub_v1_schema_proto_msgTypes[0] 231 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 232 ms.StoreMessageInfo(mi) 233 } 234} 235 236func (x *Schema) String() string { 237 return protoimpl.X.MessageStringOf(x) 238} 239 240func (*Schema) ProtoMessage() {} 241 242func (x *Schema) ProtoReflect() protoreflect.Message { 243 mi := &file_google_pubsub_v1_schema_proto_msgTypes[0] 244 if protoimpl.UnsafeEnabled && x != nil { 245 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 246 if ms.LoadMessageInfo() == nil { 247 ms.StoreMessageInfo(mi) 248 } 249 return ms 250 } 251 return mi.MessageOf(x) 252} 253 254// Deprecated: Use Schema.ProtoReflect.Descriptor instead. 255func (*Schema) Descriptor() ([]byte, []int) { 256 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{0} 257} 258 259func (x *Schema) GetName() string { 260 if x != nil { 261 return x.Name 262 } 263 return "" 264} 265 266func (x *Schema) GetType() Schema_Type { 267 if x != nil { 268 return x.Type 269 } 270 return Schema_TYPE_UNSPECIFIED 271} 272 273func (x *Schema) GetDefinition() string { 274 if x != nil { 275 return x.Definition 276 } 277 return "" 278} 279 280// Request for the CreateSchema method. 281type CreateSchemaRequest struct { 282 state protoimpl.MessageState 283 sizeCache protoimpl.SizeCache 284 unknownFields protoimpl.UnknownFields 285 286 // Required. The name of the project in which to create the schema. 287 // Format is `projects/{project-id}`. 288 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 289 // Required. The schema object to create. 290 // 291 // This schema's `name` parameter is ignored. The schema object returned 292 // by CreateSchema will have a `name` made using the given `parent` and 293 // `schema_id`. 294 Schema *Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"` 295 // The ID to use for the schema, which will become the final component of 296 // the schema's resource name. 297 // 298 // See https://cloud.google.com/pubsub/docs/admin#resource_names for resource 299 // name constraints. 300 SchemaId string `protobuf:"bytes,3,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"` 301} 302 303func (x *CreateSchemaRequest) Reset() { 304 *x = CreateSchemaRequest{} 305 if protoimpl.UnsafeEnabled { 306 mi := &file_google_pubsub_v1_schema_proto_msgTypes[1] 307 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 308 ms.StoreMessageInfo(mi) 309 } 310} 311 312func (x *CreateSchemaRequest) String() string { 313 return protoimpl.X.MessageStringOf(x) 314} 315 316func (*CreateSchemaRequest) ProtoMessage() {} 317 318func (x *CreateSchemaRequest) ProtoReflect() protoreflect.Message { 319 mi := &file_google_pubsub_v1_schema_proto_msgTypes[1] 320 if protoimpl.UnsafeEnabled && x != nil { 321 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 322 if ms.LoadMessageInfo() == nil { 323 ms.StoreMessageInfo(mi) 324 } 325 return ms 326 } 327 return mi.MessageOf(x) 328} 329 330// Deprecated: Use CreateSchemaRequest.ProtoReflect.Descriptor instead. 331func (*CreateSchemaRequest) Descriptor() ([]byte, []int) { 332 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{1} 333} 334 335func (x *CreateSchemaRequest) GetParent() string { 336 if x != nil { 337 return x.Parent 338 } 339 return "" 340} 341 342func (x *CreateSchemaRequest) GetSchema() *Schema { 343 if x != nil { 344 return x.Schema 345 } 346 return nil 347} 348 349func (x *CreateSchemaRequest) GetSchemaId() string { 350 if x != nil { 351 return x.SchemaId 352 } 353 return "" 354} 355 356// Request for the GetSchema method. 357type GetSchemaRequest struct { 358 state protoimpl.MessageState 359 sizeCache protoimpl.SizeCache 360 unknownFields protoimpl.UnknownFields 361 362 // Required. The name of the schema to get. 363 // Format is `projects/{project}/schemas/{schema}`. 364 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 365 // The set of fields to return in the response. If not set, returns a Schema 366 // with `name` and `type`, but not `definition`. Set to `FULL` to retrieve all 367 // fields. 368 View SchemaView `protobuf:"varint,2,opt,name=view,proto3,enum=google.pubsub.v1.SchemaView" json:"view,omitempty"` 369} 370 371func (x *GetSchemaRequest) Reset() { 372 *x = GetSchemaRequest{} 373 if protoimpl.UnsafeEnabled { 374 mi := &file_google_pubsub_v1_schema_proto_msgTypes[2] 375 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 376 ms.StoreMessageInfo(mi) 377 } 378} 379 380func (x *GetSchemaRequest) String() string { 381 return protoimpl.X.MessageStringOf(x) 382} 383 384func (*GetSchemaRequest) ProtoMessage() {} 385 386func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message { 387 mi := &file_google_pubsub_v1_schema_proto_msgTypes[2] 388 if protoimpl.UnsafeEnabled && x != nil { 389 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 390 if ms.LoadMessageInfo() == nil { 391 ms.StoreMessageInfo(mi) 392 } 393 return ms 394 } 395 return mi.MessageOf(x) 396} 397 398// Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead. 399func (*GetSchemaRequest) Descriptor() ([]byte, []int) { 400 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{2} 401} 402 403func (x *GetSchemaRequest) GetName() string { 404 if x != nil { 405 return x.Name 406 } 407 return "" 408} 409 410func (x *GetSchemaRequest) GetView() SchemaView { 411 if x != nil { 412 return x.View 413 } 414 return SchemaView_SCHEMA_VIEW_UNSPECIFIED 415} 416 417// Request for the `ListSchemas` method. 418type ListSchemasRequest struct { 419 state protoimpl.MessageState 420 sizeCache protoimpl.SizeCache 421 unknownFields protoimpl.UnknownFields 422 423 // Required. The name of the project in which to list schemas. 424 // Format is `projects/{project-id}`. 425 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 426 // The set of Schema fields to return in the response. If not set, returns 427 // Schemas with `name` and `type`, but not `definition`. Set to `FULL` to 428 // retrieve all fields. 429 View SchemaView `protobuf:"varint,2,opt,name=view,proto3,enum=google.pubsub.v1.SchemaView" json:"view,omitempty"` 430 // Maximum number of schemas to return. 431 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 432 // The value returned by the last `ListSchemasResponse`; indicates that 433 // this is a continuation of a prior `ListSchemas` call, and that the 434 // system should return the next page of data. 435 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 436} 437 438func (x *ListSchemasRequest) Reset() { 439 *x = ListSchemasRequest{} 440 if protoimpl.UnsafeEnabled { 441 mi := &file_google_pubsub_v1_schema_proto_msgTypes[3] 442 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 443 ms.StoreMessageInfo(mi) 444 } 445} 446 447func (x *ListSchemasRequest) String() string { 448 return protoimpl.X.MessageStringOf(x) 449} 450 451func (*ListSchemasRequest) ProtoMessage() {} 452 453func (x *ListSchemasRequest) ProtoReflect() protoreflect.Message { 454 mi := &file_google_pubsub_v1_schema_proto_msgTypes[3] 455 if protoimpl.UnsafeEnabled && x != nil { 456 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 457 if ms.LoadMessageInfo() == nil { 458 ms.StoreMessageInfo(mi) 459 } 460 return ms 461 } 462 return mi.MessageOf(x) 463} 464 465// Deprecated: Use ListSchemasRequest.ProtoReflect.Descriptor instead. 466func (*ListSchemasRequest) Descriptor() ([]byte, []int) { 467 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{3} 468} 469 470func (x *ListSchemasRequest) GetParent() string { 471 if x != nil { 472 return x.Parent 473 } 474 return "" 475} 476 477func (x *ListSchemasRequest) GetView() SchemaView { 478 if x != nil { 479 return x.View 480 } 481 return SchemaView_SCHEMA_VIEW_UNSPECIFIED 482} 483 484func (x *ListSchemasRequest) GetPageSize() int32 { 485 if x != nil { 486 return x.PageSize 487 } 488 return 0 489} 490 491func (x *ListSchemasRequest) GetPageToken() string { 492 if x != nil { 493 return x.PageToken 494 } 495 return "" 496} 497 498// Response for the `ListSchemas` method. 499type ListSchemasResponse struct { 500 state protoimpl.MessageState 501 sizeCache protoimpl.SizeCache 502 unknownFields protoimpl.UnknownFields 503 504 // The resulting schemas. 505 Schemas []*Schema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"` 506 // If not empty, indicates that there may be more schemas that match the 507 // request; this value should be passed in a new `ListSchemasRequest`. 508 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 509} 510 511func (x *ListSchemasResponse) Reset() { 512 *x = ListSchemasResponse{} 513 if protoimpl.UnsafeEnabled { 514 mi := &file_google_pubsub_v1_schema_proto_msgTypes[4] 515 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 516 ms.StoreMessageInfo(mi) 517 } 518} 519 520func (x *ListSchemasResponse) String() string { 521 return protoimpl.X.MessageStringOf(x) 522} 523 524func (*ListSchemasResponse) ProtoMessage() {} 525 526func (x *ListSchemasResponse) ProtoReflect() protoreflect.Message { 527 mi := &file_google_pubsub_v1_schema_proto_msgTypes[4] 528 if protoimpl.UnsafeEnabled && x != nil { 529 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 530 if ms.LoadMessageInfo() == nil { 531 ms.StoreMessageInfo(mi) 532 } 533 return ms 534 } 535 return mi.MessageOf(x) 536} 537 538// Deprecated: Use ListSchemasResponse.ProtoReflect.Descriptor instead. 539func (*ListSchemasResponse) Descriptor() ([]byte, []int) { 540 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{4} 541} 542 543func (x *ListSchemasResponse) GetSchemas() []*Schema { 544 if x != nil { 545 return x.Schemas 546 } 547 return nil 548} 549 550func (x *ListSchemasResponse) GetNextPageToken() string { 551 if x != nil { 552 return x.NextPageToken 553 } 554 return "" 555} 556 557// Request for the `DeleteSchema` method. 558type DeleteSchemaRequest struct { 559 state protoimpl.MessageState 560 sizeCache protoimpl.SizeCache 561 unknownFields protoimpl.UnknownFields 562 563 // Required. Name of the schema to delete. 564 // Format is `projects/{project}/schemas/{schema}`. 565 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 566} 567 568func (x *DeleteSchemaRequest) Reset() { 569 *x = DeleteSchemaRequest{} 570 if protoimpl.UnsafeEnabled { 571 mi := &file_google_pubsub_v1_schema_proto_msgTypes[5] 572 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 573 ms.StoreMessageInfo(mi) 574 } 575} 576 577func (x *DeleteSchemaRequest) String() string { 578 return protoimpl.X.MessageStringOf(x) 579} 580 581func (*DeleteSchemaRequest) ProtoMessage() {} 582 583func (x *DeleteSchemaRequest) ProtoReflect() protoreflect.Message { 584 mi := &file_google_pubsub_v1_schema_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 DeleteSchemaRequest.ProtoReflect.Descriptor instead. 596func (*DeleteSchemaRequest) Descriptor() ([]byte, []int) { 597 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{5} 598} 599 600func (x *DeleteSchemaRequest) GetName() string { 601 if x != nil { 602 return x.Name 603 } 604 return "" 605} 606 607// Request for the `ValidateSchema` method. 608type ValidateSchemaRequest struct { 609 state protoimpl.MessageState 610 sizeCache protoimpl.SizeCache 611 unknownFields protoimpl.UnknownFields 612 613 // Required. The name of the project in which to validate schemas. 614 // Format is `projects/{project-id}`. 615 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 616 // Required. The schema object to validate. 617 Schema *Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"` 618} 619 620func (x *ValidateSchemaRequest) Reset() { 621 *x = ValidateSchemaRequest{} 622 if protoimpl.UnsafeEnabled { 623 mi := &file_google_pubsub_v1_schema_proto_msgTypes[6] 624 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 625 ms.StoreMessageInfo(mi) 626 } 627} 628 629func (x *ValidateSchemaRequest) String() string { 630 return protoimpl.X.MessageStringOf(x) 631} 632 633func (*ValidateSchemaRequest) ProtoMessage() {} 634 635func (x *ValidateSchemaRequest) ProtoReflect() protoreflect.Message { 636 mi := &file_google_pubsub_v1_schema_proto_msgTypes[6] 637 if protoimpl.UnsafeEnabled && x != nil { 638 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 639 if ms.LoadMessageInfo() == nil { 640 ms.StoreMessageInfo(mi) 641 } 642 return ms 643 } 644 return mi.MessageOf(x) 645} 646 647// Deprecated: Use ValidateSchemaRequest.ProtoReflect.Descriptor instead. 648func (*ValidateSchemaRequest) Descriptor() ([]byte, []int) { 649 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{6} 650} 651 652func (x *ValidateSchemaRequest) GetParent() string { 653 if x != nil { 654 return x.Parent 655 } 656 return "" 657} 658 659func (x *ValidateSchemaRequest) GetSchema() *Schema { 660 if x != nil { 661 return x.Schema 662 } 663 return nil 664} 665 666// Response for the `ValidateSchema` method. 667type ValidateSchemaResponse struct { 668 state protoimpl.MessageState 669 sizeCache protoimpl.SizeCache 670 unknownFields protoimpl.UnknownFields 671} 672 673func (x *ValidateSchemaResponse) Reset() { 674 *x = ValidateSchemaResponse{} 675 if protoimpl.UnsafeEnabled { 676 mi := &file_google_pubsub_v1_schema_proto_msgTypes[7] 677 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 678 ms.StoreMessageInfo(mi) 679 } 680} 681 682func (x *ValidateSchemaResponse) String() string { 683 return protoimpl.X.MessageStringOf(x) 684} 685 686func (*ValidateSchemaResponse) ProtoMessage() {} 687 688func (x *ValidateSchemaResponse) ProtoReflect() protoreflect.Message { 689 mi := &file_google_pubsub_v1_schema_proto_msgTypes[7] 690 if protoimpl.UnsafeEnabled && x != nil { 691 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 692 if ms.LoadMessageInfo() == nil { 693 ms.StoreMessageInfo(mi) 694 } 695 return ms 696 } 697 return mi.MessageOf(x) 698} 699 700// Deprecated: Use ValidateSchemaResponse.ProtoReflect.Descriptor instead. 701func (*ValidateSchemaResponse) Descriptor() ([]byte, []int) { 702 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{7} 703} 704 705// Request for the `ValidateMessage` method. 706type ValidateMessageRequest struct { 707 state protoimpl.MessageState 708 sizeCache protoimpl.SizeCache 709 unknownFields protoimpl.UnknownFields 710 711 // Required. The name of the project in which to validate schemas. 712 // Format is `projects/{project-id}`. 713 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 714 // Types that are assignable to SchemaSpec: 715 // *ValidateMessageRequest_Name 716 // *ValidateMessageRequest_Schema 717 SchemaSpec isValidateMessageRequest_SchemaSpec `protobuf_oneof:"schema_spec"` 718 // Message to validate against the provided `schema_spec`. 719 Message []byte `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"` 720 // The encoding expected for messages 721 Encoding Encoding `protobuf:"varint,5,opt,name=encoding,proto3,enum=google.pubsub.v1.Encoding" json:"encoding,omitempty"` 722} 723 724func (x *ValidateMessageRequest) Reset() { 725 *x = ValidateMessageRequest{} 726 if protoimpl.UnsafeEnabled { 727 mi := &file_google_pubsub_v1_schema_proto_msgTypes[8] 728 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 729 ms.StoreMessageInfo(mi) 730 } 731} 732 733func (x *ValidateMessageRequest) String() string { 734 return protoimpl.X.MessageStringOf(x) 735} 736 737func (*ValidateMessageRequest) ProtoMessage() {} 738 739func (x *ValidateMessageRequest) ProtoReflect() protoreflect.Message { 740 mi := &file_google_pubsub_v1_schema_proto_msgTypes[8] 741 if protoimpl.UnsafeEnabled && x != nil { 742 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 743 if ms.LoadMessageInfo() == nil { 744 ms.StoreMessageInfo(mi) 745 } 746 return ms 747 } 748 return mi.MessageOf(x) 749} 750 751// Deprecated: Use ValidateMessageRequest.ProtoReflect.Descriptor instead. 752func (*ValidateMessageRequest) Descriptor() ([]byte, []int) { 753 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{8} 754} 755 756func (x *ValidateMessageRequest) GetParent() string { 757 if x != nil { 758 return x.Parent 759 } 760 return "" 761} 762 763func (m *ValidateMessageRequest) GetSchemaSpec() isValidateMessageRequest_SchemaSpec { 764 if m != nil { 765 return m.SchemaSpec 766 } 767 return nil 768} 769 770func (x *ValidateMessageRequest) GetName() string { 771 if x, ok := x.GetSchemaSpec().(*ValidateMessageRequest_Name); ok { 772 return x.Name 773 } 774 return "" 775} 776 777func (x *ValidateMessageRequest) GetSchema() *Schema { 778 if x, ok := x.GetSchemaSpec().(*ValidateMessageRequest_Schema); ok { 779 return x.Schema 780 } 781 return nil 782} 783 784func (x *ValidateMessageRequest) GetMessage() []byte { 785 if x != nil { 786 return x.Message 787 } 788 return nil 789} 790 791func (x *ValidateMessageRequest) GetEncoding() Encoding { 792 if x != nil { 793 return x.Encoding 794 } 795 return Encoding_ENCODING_UNSPECIFIED 796} 797 798type isValidateMessageRequest_SchemaSpec interface { 799 isValidateMessageRequest_SchemaSpec() 800} 801 802type ValidateMessageRequest_Name struct { 803 // Name of the schema against which to validate. 804 // 805 // Format is `projects/{project}/schemas/{schema}`. 806 Name string `protobuf:"bytes,2,opt,name=name,proto3,oneof"` 807} 808 809type ValidateMessageRequest_Schema struct { 810 // Ad-hoc schema against which to validate 811 Schema *Schema `protobuf:"bytes,3,opt,name=schema,proto3,oneof"` 812} 813 814func (*ValidateMessageRequest_Name) isValidateMessageRequest_SchemaSpec() {} 815 816func (*ValidateMessageRequest_Schema) isValidateMessageRequest_SchemaSpec() {} 817 818// Response for the `ValidateMessage` method. 819type ValidateMessageResponse struct { 820 state protoimpl.MessageState 821 sizeCache protoimpl.SizeCache 822 unknownFields protoimpl.UnknownFields 823} 824 825func (x *ValidateMessageResponse) Reset() { 826 *x = ValidateMessageResponse{} 827 if protoimpl.UnsafeEnabled { 828 mi := &file_google_pubsub_v1_schema_proto_msgTypes[9] 829 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 830 ms.StoreMessageInfo(mi) 831 } 832} 833 834func (x *ValidateMessageResponse) String() string { 835 return protoimpl.X.MessageStringOf(x) 836} 837 838func (*ValidateMessageResponse) ProtoMessage() {} 839 840func (x *ValidateMessageResponse) ProtoReflect() protoreflect.Message { 841 mi := &file_google_pubsub_v1_schema_proto_msgTypes[9] 842 if protoimpl.UnsafeEnabled && x != nil { 843 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 844 if ms.LoadMessageInfo() == nil { 845 ms.StoreMessageInfo(mi) 846 } 847 return ms 848 } 849 return mi.MessageOf(x) 850} 851 852// Deprecated: Use ValidateMessageResponse.ProtoReflect.Descriptor instead. 853func (*ValidateMessageResponse) Descriptor() ([]byte, []int) { 854 return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{9} 855} 856 857var File_google_pubsub_v1_schema_proto protoreflect.FileDescriptor 858 859var file_google_pubsub_v1_schema_proto_rawDesc = []byte{ 860 0x0a, 0x1d, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2f, 861 0x76, 0x31, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 862 0x10, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 863 0x31, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 864 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 865 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 866 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 867 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 868 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 869 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 870 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 871 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 872 0x6f, 0x22, 0xf9, 0x01, 0x0a, 0x06, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x17, 0x0a, 0x04, 873 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 874 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x31, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, 875 0x01, 0x28, 0x0e, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 876 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x2e, 0x54, 0x79, 877 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x64, 0x65, 0x66, 0x69, 878 0x6e, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x64, 0x65, 879 0x66, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x3b, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 880 0x12, 0x14, 0x0a, 0x10, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 881 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x13, 0x0a, 0x0f, 0x50, 0x52, 0x4f, 0x54, 0x4f, 0x43, 882 0x4f, 0x4c, 0x5f, 0x42, 0x55, 0x46, 0x46, 0x45, 0x52, 0x10, 0x01, 0x12, 0x08, 0x0a, 0x04, 0x41, 883 0x56, 0x52, 0x4f, 0x10, 0x02, 0x3a, 0x46, 0xea, 0x41, 0x43, 0x0a, 0x1c, 0x70, 0x75, 0x62, 0x73, 884 0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 885 0x6d, 0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x23, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 886 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x73, 0x63, 0x68, 887 0x65, 0x6d, 0x61, 0x73, 0x2f, 0x7b, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x7d, 0x22, 0xa7, 0x01, 888 0x0a, 0x13, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 889 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3c, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 890 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x24, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x1e, 0x12, 0x1c, 0x70, 891 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 892 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x06, 0x70, 0x61, 0x72, 893 0x65, 0x6e, 0x74, 0x12, 0x35, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x02, 0x20, 894 0x01, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 895 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 896 0x41, 0x02, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x1b, 0x0a, 0x09, 0x73, 0x63, 897 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x73, 898 0x63, 0x68, 0x65, 0x6d, 0x61, 0x49, 0x64, 0x22, 0x7e, 0x0a, 0x10, 0x47, 0x65, 0x74, 0x53, 0x63, 899 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x04, 0x6e, 900 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x24, 0xe0, 0x41, 0x02, 0xfa, 0x41, 901 0x1e, 0x0a, 0x1c, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 902 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 903 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x30, 0x0a, 0x04, 0x76, 0x69, 0x65, 0x77, 0x18, 0x02, 0x20, 904 0x01, 0x28, 0x0e, 0x32, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 905 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x56, 0x69, 0x65, 906 0x77, 0x52, 0x04, 0x76, 0x69, 0x65, 0x77, 0x22, 0xcf, 0x01, 0x0a, 0x12, 0x4c, 0x69, 0x73, 0x74, 907 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4b, 908 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x33, 909 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2d, 0x0a, 0x2b, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x72, 0x65, 0x73, 910 0x6f, 0x75, 0x72, 0x63, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 911 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x50, 0x72, 0x6f, 0x6a, 912 0x65, 0x63, 0x74, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x30, 0x0a, 0x04, 0x76, 913 0x69, 0x65, 0x77, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 914 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 915 0x65, 0x6d, 0x61, 0x56, 0x69, 0x65, 0x77, 0x52, 0x04, 0x76, 0x69, 0x65, 0x77, 0x12, 0x1b, 0x0a, 916 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 917 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 918 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 919 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x71, 0x0a, 0x13, 0x4c, 0x69, 0x73, 920 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 921 0x12, 0x32, 0x0a, 0x07, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 922 0x0b, 0x32, 0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 923 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x07, 0x73, 0x63, 0x68, 924 0x65, 0x6d, 0x61, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 925 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 926 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x4f, 0x0a, 0x13, 927 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x71, 0x75, 928 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 929 0x09, 0x42, 0x24, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x1e, 0x0a, 0x1c, 0x70, 0x75, 0x62, 0x73, 0x75, 930 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 931 0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x9b, 0x01, 932 0x0a, 0x15, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 933 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4b, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 934 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x33, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2d, 0x0a, 935 0x2b, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x6d, 0x61, 936 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 937 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x50, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x52, 0x06, 0x70, 0x61, 938 0x72, 0x65, 0x6e, 0x74, 0x12, 0x35, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x02, 939 0x20, 0x01, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 940 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 941 0xe0, 0x41, 0x02, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0x18, 0x0a, 0x16, 0x56, 942 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x73, 943 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xb3, 0x02, 0x0a, 0x16, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 944 0x74, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 945 0x12, 0x4b, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 946 0x42, 0x33, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2d, 0x0a, 0x2b, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x72, 947 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x67, 948 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x50, 0x72, 949 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x37, 0x0a, 950 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x21, 0xfa, 0x41, 0x1e, 951 0x0a, 0x1c, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 952 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x48, 0x00, 953 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x32, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 954 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 955 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 956 0x48, 0x00, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 957 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x07, 0x6d, 0x65, 0x73, 958 0x73, 0x61, 0x67, 0x65, 0x12, 0x36, 0x0a, 0x08, 0x65, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 959 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 960 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x6e, 0x63, 0x6f, 0x64, 0x69, 961 0x6e, 0x67, 0x52, 0x08, 0x65, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 0x42, 0x0d, 0x0a, 0x0b, 962 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x73, 0x70, 0x65, 0x63, 0x22, 0x19, 0x0a, 0x17, 0x56, 963 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, 964 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2a, 0x3e, 0x0a, 0x0a, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 965 0x56, 0x69, 0x65, 0x77, 0x12, 0x1b, 0x0a, 0x17, 0x53, 0x43, 0x48, 0x45, 0x4d, 0x41, 0x5f, 0x56, 966 0x49, 0x45, 0x57, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 967 0x00, 0x12, 0x09, 0x0a, 0x05, 0x42, 0x41, 0x53, 0x49, 0x43, 0x10, 0x01, 0x12, 0x08, 0x0a, 0x04, 968 0x46, 0x55, 0x4c, 0x4c, 0x10, 0x02, 0x2a, 0x3a, 0x0a, 0x08, 0x45, 0x6e, 0x63, 0x6f, 0x64, 0x69, 969 0x6e, 0x67, 0x12, 0x18, 0x0a, 0x14, 0x45, 0x4e, 0x43, 0x4f, 0x44, 0x49, 0x4e, 0x47, 0x5f, 0x55, 970 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 971 0x4a, 0x53, 0x4f, 0x4e, 0x10, 0x01, 0x12, 0x0a, 0x0a, 0x06, 0x42, 0x49, 0x4e, 0x41, 0x52, 0x59, 972 0x10, 0x02, 0x32, 0xf7, 0x07, 0x0a, 0x0d, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x53, 0x65, 0x72, 973 0x76, 0x69, 0x63, 0x65, 0x12, 0x9a, 0x01, 0x0a, 0x0c, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 974 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 975 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 976 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x18, 0x2e, 0x67, 977 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 978 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0x49, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x29, 0x22, 0x1f, 979 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 980 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x3a, 981 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0xda, 0x41, 0x17, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 982 0x2c, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x2c, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x69, 983 0x64, 0x12, 0x79, 0x0a, 0x09, 0x47, 0x65, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x22, 984 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 985 0x31, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 986 0x73, 0x74, 0x1a, 0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 987 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0x2e, 0x82, 0xd3, 988 0xe4, 0x93, 0x02, 0x21, 0x12, 0x1f, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 989 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 990 0x61, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x8c, 0x01, 0x0a, 991 0x0b, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x12, 0x24, 0x2e, 0x67, 992 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 993 0x4c, 0x69, 0x73, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 994 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 995 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 996 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x30, 0x82, 0xd3, 0xe4, 0x93, 0x02, 997 0x21, 0x12, 0x1f, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 998 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 999 0x61, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x7d, 0x0a, 0x0c, 0x44, 1000 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x25, 0x2e, 0x67, 0x6f, 1001 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x44, 1002 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 1003 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 1004 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x2e, 0x82, 0xd3, 0xe4, 0x93, 1005 0x02, 0x21, 0x2a, 0x1f, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 1006 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 1007 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xa8, 0x01, 0x0a, 0x0e, 0x56, 1008 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x27, 0x2e, 1009 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 1010 0x2e, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 1011 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 1012 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 1013 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 1014 0x22, 0x43, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2d, 0x22, 0x28, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x70, 1015 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 1016 0x7d, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x3a, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 1017 0x74, 0x65, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x0d, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x73, 1018 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0xa2, 0x01, 0x0a, 0x0f, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 1019 0x74, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 1020 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x56, 0x61, 0x6c, 1021 0x69, 0x64, 0x61, 0x74, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 1022 0x65, 0x73, 0x74, 0x1a, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 1023 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x4d, 1024 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x3a, 1025 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x22, 0x2f, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 1026 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 1027 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x3a, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 1028 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x3a, 0x01, 0x2a, 0x1a, 0x70, 0xca, 0x41, 0x15, 0x70, 1029 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 1030 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x55, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 1031 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 1032 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 1033 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2c, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 1034 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 1035 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x42, 0xae, 0x01, 0x0a, 1036 0x14, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 1037 0x75, 0x62, 0x2e, 0x76, 0x31, 0x42, 0x0b, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x50, 0x72, 0x6f, 1038 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x36, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 1039 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 1040 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x70, 0x75, 0x62, 0x73, 1041 0x75, 0x62, 0x2f, 0x76, 0x31, 0x3b, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0xf8, 0x01, 0x01, 0xaa, 1042 0x02, 0x16, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x50, 1043 0x75, 0x62, 0x53, 0x75, 0x62, 0x2e, 0x56, 0x31, 0xca, 0x02, 0x16, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 1044 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x50, 0x75, 0x62, 0x53, 0x75, 0x62, 0x5c, 0x56, 1045 0x31, 0xea, 0x02, 0x19, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x3a, 0x3a, 0x43, 0x6c, 0x6f, 0x75, 1046 0x64, 0x3a, 0x3a, 0x50, 0x75, 0x62, 0x53, 0x75, 0x62, 0x3a, 0x3a, 0x56, 0x31, 0x62, 0x06, 0x70, 1047 0x72, 0x6f, 0x74, 0x6f, 0x33, 1048} 1049 1050var ( 1051 file_google_pubsub_v1_schema_proto_rawDescOnce sync.Once 1052 file_google_pubsub_v1_schema_proto_rawDescData = file_google_pubsub_v1_schema_proto_rawDesc 1053) 1054 1055func file_google_pubsub_v1_schema_proto_rawDescGZIP() []byte { 1056 file_google_pubsub_v1_schema_proto_rawDescOnce.Do(func() { 1057 file_google_pubsub_v1_schema_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_pubsub_v1_schema_proto_rawDescData) 1058 }) 1059 return file_google_pubsub_v1_schema_proto_rawDescData 1060} 1061 1062var file_google_pubsub_v1_schema_proto_enumTypes = make([]protoimpl.EnumInfo, 3) 1063var file_google_pubsub_v1_schema_proto_msgTypes = make([]protoimpl.MessageInfo, 10) 1064var file_google_pubsub_v1_schema_proto_goTypes = []interface{}{ 1065 (SchemaView)(0), // 0: google.pubsub.v1.SchemaView 1066 (Encoding)(0), // 1: google.pubsub.v1.Encoding 1067 (Schema_Type)(0), // 2: google.pubsub.v1.Schema.Type 1068 (*Schema)(nil), // 3: google.pubsub.v1.Schema 1069 (*CreateSchemaRequest)(nil), // 4: google.pubsub.v1.CreateSchemaRequest 1070 (*GetSchemaRequest)(nil), // 5: google.pubsub.v1.GetSchemaRequest 1071 (*ListSchemasRequest)(nil), // 6: google.pubsub.v1.ListSchemasRequest 1072 (*ListSchemasResponse)(nil), // 7: google.pubsub.v1.ListSchemasResponse 1073 (*DeleteSchemaRequest)(nil), // 8: google.pubsub.v1.DeleteSchemaRequest 1074 (*ValidateSchemaRequest)(nil), // 9: google.pubsub.v1.ValidateSchemaRequest 1075 (*ValidateSchemaResponse)(nil), // 10: google.pubsub.v1.ValidateSchemaResponse 1076 (*ValidateMessageRequest)(nil), // 11: google.pubsub.v1.ValidateMessageRequest 1077 (*ValidateMessageResponse)(nil), // 12: google.pubsub.v1.ValidateMessageResponse 1078 (*emptypb.Empty)(nil), // 13: google.protobuf.Empty 1079} 1080var file_google_pubsub_v1_schema_proto_depIdxs = []int32{ 1081 2, // 0: google.pubsub.v1.Schema.type:type_name -> google.pubsub.v1.Schema.Type 1082 3, // 1: google.pubsub.v1.CreateSchemaRequest.schema:type_name -> google.pubsub.v1.Schema 1083 0, // 2: google.pubsub.v1.GetSchemaRequest.view:type_name -> google.pubsub.v1.SchemaView 1084 0, // 3: google.pubsub.v1.ListSchemasRequest.view:type_name -> google.pubsub.v1.SchemaView 1085 3, // 4: google.pubsub.v1.ListSchemasResponse.schemas:type_name -> google.pubsub.v1.Schema 1086 3, // 5: google.pubsub.v1.ValidateSchemaRequest.schema:type_name -> google.pubsub.v1.Schema 1087 3, // 6: google.pubsub.v1.ValidateMessageRequest.schema:type_name -> google.pubsub.v1.Schema 1088 1, // 7: google.pubsub.v1.ValidateMessageRequest.encoding:type_name -> google.pubsub.v1.Encoding 1089 4, // 8: google.pubsub.v1.SchemaService.CreateSchema:input_type -> google.pubsub.v1.CreateSchemaRequest 1090 5, // 9: google.pubsub.v1.SchemaService.GetSchema:input_type -> google.pubsub.v1.GetSchemaRequest 1091 6, // 10: google.pubsub.v1.SchemaService.ListSchemas:input_type -> google.pubsub.v1.ListSchemasRequest 1092 8, // 11: google.pubsub.v1.SchemaService.DeleteSchema:input_type -> google.pubsub.v1.DeleteSchemaRequest 1093 9, // 12: google.pubsub.v1.SchemaService.ValidateSchema:input_type -> google.pubsub.v1.ValidateSchemaRequest 1094 11, // 13: google.pubsub.v1.SchemaService.ValidateMessage:input_type -> google.pubsub.v1.ValidateMessageRequest 1095 3, // 14: google.pubsub.v1.SchemaService.CreateSchema:output_type -> google.pubsub.v1.Schema 1096 3, // 15: google.pubsub.v1.SchemaService.GetSchema:output_type -> google.pubsub.v1.Schema 1097 7, // 16: google.pubsub.v1.SchemaService.ListSchemas:output_type -> google.pubsub.v1.ListSchemasResponse 1098 13, // 17: google.pubsub.v1.SchemaService.DeleteSchema:output_type -> google.protobuf.Empty 1099 10, // 18: google.pubsub.v1.SchemaService.ValidateSchema:output_type -> google.pubsub.v1.ValidateSchemaResponse 1100 12, // 19: google.pubsub.v1.SchemaService.ValidateMessage:output_type -> google.pubsub.v1.ValidateMessageResponse 1101 14, // [14:20] is the sub-list for method output_type 1102 8, // [8:14] is the sub-list for method input_type 1103 8, // [8:8] is the sub-list for extension type_name 1104 8, // [8:8] is the sub-list for extension extendee 1105 0, // [0:8] is the sub-list for field type_name 1106} 1107 1108func init() { file_google_pubsub_v1_schema_proto_init() } 1109func file_google_pubsub_v1_schema_proto_init() { 1110 if File_google_pubsub_v1_schema_proto != nil { 1111 return 1112 } 1113 if !protoimpl.UnsafeEnabled { 1114 file_google_pubsub_v1_schema_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 1115 switch v := v.(*Schema); i { 1116 case 0: 1117 return &v.state 1118 case 1: 1119 return &v.sizeCache 1120 case 2: 1121 return &v.unknownFields 1122 default: 1123 return nil 1124 } 1125 } 1126 file_google_pubsub_v1_schema_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 1127 switch v := v.(*CreateSchemaRequest); i { 1128 case 0: 1129 return &v.state 1130 case 1: 1131 return &v.sizeCache 1132 case 2: 1133 return &v.unknownFields 1134 default: 1135 return nil 1136 } 1137 } 1138 file_google_pubsub_v1_schema_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 1139 switch v := v.(*GetSchemaRequest); i { 1140 case 0: 1141 return &v.state 1142 case 1: 1143 return &v.sizeCache 1144 case 2: 1145 return &v.unknownFields 1146 default: 1147 return nil 1148 } 1149 } 1150 file_google_pubsub_v1_schema_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 1151 switch v := v.(*ListSchemasRequest); i { 1152 case 0: 1153 return &v.state 1154 case 1: 1155 return &v.sizeCache 1156 case 2: 1157 return &v.unknownFields 1158 default: 1159 return nil 1160 } 1161 } 1162 file_google_pubsub_v1_schema_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 1163 switch v := v.(*ListSchemasResponse); i { 1164 case 0: 1165 return &v.state 1166 case 1: 1167 return &v.sizeCache 1168 case 2: 1169 return &v.unknownFields 1170 default: 1171 return nil 1172 } 1173 } 1174 file_google_pubsub_v1_schema_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 1175 switch v := v.(*DeleteSchemaRequest); i { 1176 case 0: 1177 return &v.state 1178 case 1: 1179 return &v.sizeCache 1180 case 2: 1181 return &v.unknownFields 1182 default: 1183 return nil 1184 } 1185 } 1186 file_google_pubsub_v1_schema_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 1187 switch v := v.(*ValidateSchemaRequest); i { 1188 case 0: 1189 return &v.state 1190 case 1: 1191 return &v.sizeCache 1192 case 2: 1193 return &v.unknownFields 1194 default: 1195 return nil 1196 } 1197 } 1198 file_google_pubsub_v1_schema_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 1199 switch v := v.(*ValidateSchemaResponse); i { 1200 case 0: 1201 return &v.state 1202 case 1: 1203 return &v.sizeCache 1204 case 2: 1205 return &v.unknownFields 1206 default: 1207 return nil 1208 } 1209 } 1210 file_google_pubsub_v1_schema_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 1211 switch v := v.(*ValidateMessageRequest); i { 1212 case 0: 1213 return &v.state 1214 case 1: 1215 return &v.sizeCache 1216 case 2: 1217 return &v.unknownFields 1218 default: 1219 return nil 1220 } 1221 } 1222 file_google_pubsub_v1_schema_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { 1223 switch v := v.(*ValidateMessageResponse); i { 1224 case 0: 1225 return &v.state 1226 case 1: 1227 return &v.sizeCache 1228 case 2: 1229 return &v.unknownFields 1230 default: 1231 return nil 1232 } 1233 } 1234 } 1235 file_google_pubsub_v1_schema_proto_msgTypes[8].OneofWrappers = []interface{}{ 1236 (*ValidateMessageRequest_Name)(nil), 1237 (*ValidateMessageRequest_Schema)(nil), 1238 } 1239 type x struct{} 1240 out := protoimpl.TypeBuilder{ 1241 File: protoimpl.DescBuilder{ 1242 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 1243 RawDescriptor: file_google_pubsub_v1_schema_proto_rawDesc, 1244 NumEnums: 3, 1245 NumMessages: 10, 1246 NumExtensions: 0, 1247 NumServices: 1, 1248 }, 1249 GoTypes: file_google_pubsub_v1_schema_proto_goTypes, 1250 DependencyIndexes: file_google_pubsub_v1_schema_proto_depIdxs, 1251 EnumInfos: file_google_pubsub_v1_schema_proto_enumTypes, 1252 MessageInfos: file_google_pubsub_v1_schema_proto_msgTypes, 1253 }.Build() 1254 File_google_pubsub_v1_schema_proto = out.File 1255 file_google_pubsub_v1_schema_proto_rawDesc = nil 1256 file_google_pubsub_v1_schema_proto_goTypes = nil 1257 file_google_pubsub_v1_schema_proto_depIdxs = nil 1258} 1259 1260// Reference imports to suppress errors if they are not otherwise used. 1261var _ context.Context 1262var _ grpc.ClientConnInterface 1263 1264// This is a compile-time assertion to ensure that this generated file 1265// is compatible with the grpc package it is being compiled against. 1266const _ = grpc.SupportPackageIsVersion6 1267 1268// SchemaServiceClient is the client API for SchemaService service. 1269// 1270// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1271type SchemaServiceClient interface { 1272 // Creates a schema. 1273 CreateSchema(ctx context.Context, in *CreateSchemaRequest, opts ...grpc.CallOption) (*Schema, error) 1274 // Gets a schema. 1275 GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*Schema, error) 1276 // Lists schemas in a project. 1277 ListSchemas(ctx context.Context, in *ListSchemasRequest, opts ...grpc.CallOption) (*ListSchemasResponse, error) 1278 // Deletes a schema. 1279 DeleteSchema(ctx context.Context, in *DeleteSchemaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 1280 // Validates a schema. 1281 ValidateSchema(ctx context.Context, in *ValidateSchemaRequest, opts ...grpc.CallOption) (*ValidateSchemaResponse, error) 1282 // Validates a message against a schema. 1283 ValidateMessage(ctx context.Context, in *ValidateMessageRequest, opts ...grpc.CallOption) (*ValidateMessageResponse, error) 1284} 1285 1286type schemaServiceClient struct { 1287 cc grpc.ClientConnInterface 1288} 1289 1290func NewSchemaServiceClient(cc grpc.ClientConnInterface) SchemaServiceClient { 1291 return &schemaServiceClient{cc} 1292} 1293 1294func (c *schemaServiceClient) CreateSchema(ctx context.Context, in *CreateSchemaRequest, opts ...grpc.CallOption) (*Schema, error) { 1295 out := new(Schema) 1296 err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/CreateSchema", in, out, opts...) 1297 if err != nil { 1298 return nil, err 1299 } 1300 return out, nil 1301} 1302 1303func (c *schemaServiceClient) GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*Schema, error) { 1304 out := new(Schema) 1305 err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/GetSchema", in, out, opts...) 1306 if err != nil { 1307 return nil, err 1308 } 1309 return out, nil 1310} 1311 1312func (c *schemaServiceClient) ListSchemas(ctx context.Context, in *ListSchemasRequest, opts ...grpc.CallOption) (*ListSchemasResponse, error) { 1313 out := new(ListSchemasResponse) 1314 err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/ListSchemas", in, out, opts...) 1315 if err != nil { 1316 return nil, err 1317 } 1318 return out, nil 1319} 1320 1321func (c *schemaServiceClient) DeleteSchema(ctx context.Context, in *DeleteSchemaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1322 out := new(emptypb.Empty) 1323 err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/DeleteSchema", in, out, opts...) 1324 if err != nil { 1325 return nil, err 1326 } 1327 return out, nil 1328} 1329 1330func (c *schemaServiceClient) ValidateSchema(ctx context.Context, in *ValidateSchemaRequest, opts ...grpc.CallOption) (*ValidateSchemaResponse, error) { 1331 out := new(ValidateSchemaResponse) 1332 err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/ValidateSchema", in, out, opts...) 1333 if err != nil { 1334 return nil, err 1335 } 1336 return out, nil 1337} 1338 1339func (c *schemaServiceClient) ValidateMessage(ctx context.Context, in *ValidateMessageRequest, opts ...grpc.CallOption) (*ValidateMessageResponse, error) { 1340 out := new(ValidateMessageResponse) 1341 err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/ValidateMessage", in, out, opts...) 1342 if err != nil { 1343 return nil, err 1344 } 1345 return out, nil 1346} 1347 1348// SchemaServiceServer is the server API for SchemaService service. 1349type SchemaServiceServer interface { 1350 // Creates a schema. 1351 CreateSchema(context.Context, *CreateSchemaRequest) (*Schema, error) 1352 // Gets a schema. 1353 GetSchema(context.Context, *GetSchemaRequest) (*Schema, error) 1354 // Lists schemas in a project. 1355 ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error) 1356 // Deletes a schema. 1357 DeleteSchema(context.Context, *DeleteSchemaRequest) (*emptypb.Empty, error) 1358 // Validates a schema. 1359 ValidateSchema(context.Context, *ValidateSchemaRequest) (*ValidateSchemaResponse, error) 1360 // Validates a message against a schema. 1361 ValidateMessage(context.Context, *ValidateMessageRequest) (*ValidateMessageResponse, error) 1362} 1363 1364// UnimplementedSchemaServiceServer can be embedded to have forward compatible implementations. 1365type UnimplementedSchemaServiceServer struct { 1366} 1367 1368func (*UnimplementedSchemaServiceServer) CreateSchema(context.Context, *CreateSchemaRequest) (*Schema, error) { 1369 return nil, status.Errorf(codes.Unimplemented, "method CreateSchema not implemented") 1370} 1371func (*UnimplementedSchemaServiceServer) GetSchema(context.Context, *GetSchemaRequest) (*Schema, error) { 1372 return nil, status.Errorf(codes.Unimplemented, "method GetSchema not implemented") 1373} 1374func (*UnimplementedSchemaServiceServer) ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error) { 1375 return nil, status.Errorf(codes.Unimplemented, "method ListSchemas not implemented") 1376} 1377func (*UnimplementedSchemaServiceServer) DeleteSchema(context.Context, *DeleteSchemaRequest) (*emptypb.Empty, error) { 1378 return nil, status.Errorf(codes.Unimplemented, "method DeleteSchema not implemented") 1379} 1380func (*UnimplementedSchemaServiceServer) ValidateSchema(context.Context, *ValidateSchemaRequest) (*ValidateSchemaResponse, error) { 1381 return nil, status.Errorf(codes.Unimplemented, "method ValidateSchema not implemented") 1382} 1383func (*UnimplementedSchemaServiceServer) ValidateMessage(context.Context, *ValidateMessageRequest) (*ValidateMessageResponse, error) { 1384 return nil, status.Errorf(codes.Unimplemented, "method ValidateMessage not implemented") 1385} 1386 1387func RegisterSchemaServiceServer(s *grpc.Server, srv SchemaServiceServer) { 1388 s.RegisterService(&_SchemaService_serviceDesc, srv) 1389} 1390 1391func _SchemaService_CreateSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1392 in := new(CreateSchemaRequest) 1393 if err := dec(in); err != nil { 1394 return nil, err 1395 } 1396 if interceptor == nil { 1397 return srv.(SchemaServiceServer).CreateSchema(ctx, in) 1398 } 1399 info := &grpc.UnaryServerInfo{ 1400 Server: srv, 1401 FullMethod: "/google.pubsub.v1.SchemaService/CreateSchema", 1402 } 1403 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1404 return srv.(SchemaServiceServer).CreateSchema(ctx, req.(*CreateSchemaRequest)) 1405 } 1406 return interceptor(ctx, in, info, handler) 1407} 1408 1409func _SchemaService_GetSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1410 in := new(GetSchemaRequest) 1411 if err := dec(in); err != nil { 1412 return nil, err 1413 } 1414 if interceptor == nil { 1415 return srv.(SchemaServiceServer).GetSchema(ctx, in) 1416 } 1417 info := &grpc.UnaryServerInfo{ 1418 Server: srv, 1419 FullMethod: "/google.pubsub.v1.SchemaService/GetSchema", 1420 } 1421 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1422 return srv.(SchemaServiceServer).GetSchema(ctx, req.(*GetSchemaRequest)) 1423 } 1424 return interceptor(ctx, in, info, handler) 1425} 1426 1427func _SchemaService_ListSchemas_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1428 in := new(ListSchemasRequest) 1429 if err := dec(in); err != nil { 1430 return nil, err 1431 } 1432 if interceptor == nil { 1433 return srv.(SchemaServiceServer).ListSchemas(ctx, in) 1434 } 1435 info := &grpc.UnaryServerInfo{ 1436 Server: srv, 1437 FullMethod: "/google.pubsub.v1.SchemaService/ListSchemas", 1438 } 1439 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1440 return srv.(SchemaServiceServer).ListSchemas(ctx, req.(*ListSchemasRequest)) 1441 } 1442 return interceptor(ctx, in, info, handler) 1443} 1444 1445func _SchemaService_DeleteSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1446 in := new(DeleteSchemaRequest) 1447 if err := dec(in); err != nil { 1448 return nil, err 1449 } 1450 if interceptor == nil { 1451 return srv.(SchemaServiceServer).DeleteSchema(ctx, in) 1452 } 1453 info := &grpc.UnaryServerInfo{ 1454 Server: srv, 1455 FullMethod: "/google.pubsub.v1.SchemaService/DeleteSchema", 1456 } 1457 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1458 return srv.(SchemaServiceServer).DeleteSchema(ctx, req.(*DeleteSchemaRequest)) 1459 } 1460 return interceptor(ctx, in, info, handler) 1461} 1462 1463func _SchemaService_ValidateSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1464 in := new(ValidateSchemaRequest) 1465 if err := dec(in); err != nil { 1466 return nil, err 1467 } 1468 if interceptor == nil { 1469 return srv.(SchemaServiceServer).ValidateSchema(ctx, in) 1470 } 1471 info := &grpc.UnaryServerInfo{ 1472 Server: srv, 1473 FullMethod: "/google.pubsub.v1.SchemaService/ValidateSchema", 1474 } 1475 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1476 return srv.(SchemaServiceServer).ValidateSchema(ctx, req.(*ValidateSchemaRequest)) 1477 } 1478 return interceptor(ctx, in, info, handler) 1479} 1480 1481func _SchemaService_ValidateMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1482 in := new(ValidateMessageRequest) 1483 if err := dec(in); err != nil { 1484 return nil, err 1485 } 1486 if interceptor == nil { 1487 return srv.(SchemaServiceServer).ValidateMessage(ctx, in) 1488 } 1489 info := &grpc.UnaryServerInfo{ 1490 Server: srv, 1491 FullMethod: "/google.pubsub.v1.SchemaService/ValidateMessage", 1492 } 1493 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1494 return srv.(SchemaServiceServer).ValidateMessage(ctx, req.(*ValidateMessageRequest)) 1495 } 1496 return interceptor(ctx, in, info, handler) 1497} 1498 1499var _SchemaService_serviceDesc = grpc.ServiceDesc{ 1500 ServiceName: "google.pubsub.v1.SchemaService", 1501 HandlerType: (*SchemaServiceServer)(nil), 1502 Methods: []grpc.MethodDesc{ 1503 { 1504 MethodName: "CreateSchema", 1505 Handler: _SchemaService_CreateSchema_Handler, 1506 }, 1507 { 1508 MethodName: "GetSchema", 1509 Handler: _SchemaService_GetSchema_Handler, 1510 }, 1511 { 1512 MethodName: "ListSchemas", 1513 Handler: _SchemaService_ListSchemas_Handler, 1514 }, 1515 { 1516 MethodName: "DeleteSchema", 1517 Handler: _SchemaService_DeleteSchema_Handler, 1518 }, 1519 { 1520 MethodName: "ValidateSchema", 1521 Handler: _SchemaService_ValidateSchema_Handler, 1522 }, 1523 { 1524 MethodName: "ValidateMessage", 1525 Handler: _SchemaService_ValidateMessage_Handler, 1526 }, 1527 }, 1528 Streams: []grpc.StreamDesc{}, 1529 Metadata: "google/pubsub/v1/schema.proto", 1530} 1531