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