Source file src/cloud.google.com/go/pubsub/apiv1/pubsubpb/schema.pb.go

Documentation: cloud.google.com/go/pubsub/apiv1/pubsubpb

     1  // Copyright 2023 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.33.0
    18  // 	protoc        v4.25.3
    19  // source: google/pubsub/v1/schema.proto
    20  
    21  package pubsubpb
    22  
    23  import (
    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  	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
    36  )
    37  
    38  const (
    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  // View of Schema object fields to be returned by GetSchema and ListSchemas.
    46  type SchemaView int32
    47  
    48  const (
    49  	// The default / unset value.
    50  	// The API will default to the BASIC view.
    51  	SchemaView_SCHEMA_VIEW_UNSPECIFIED SchemaView = 0
    52  	// Include the name and type of the schema, but not the definition.
    53  	SchemaView_BASIC SchemaView = 1
    54  	// Include all Schema object fields.
    55  	SchemaView_FULL SchemaView = 2
    56  )
    57  
    58  // Enum value maps for SchemaView.
    59  var (
    60  	SchemaView_name = map[int32]string{
    61  		0: "SCHEMA_VIEW_UNSPECIFIED",
    62  		1: "BASIC",
    63  		2: "FULL",
    64  	}
    65  	SchemaView_value = map[string]int32{
    66  		"SCHEMA_VIEW_UNSPECIFIED": 0,
    67  		"BASIC":                   1,
    68  		"FULL":                    2,
    69  	}
    70  )
    71  
    72  func (x SchemaView) Enum() *SchemaView {
    73  	p := new(SchemaView)
    74  	*p = x
    75  	return p
    76  }
    77  
    78  func (x SchemaView) String() string {
    79  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    80  }
    81  
    82  func (SchemaView) Descriptor() protoreflect.EnumDescriptor {
    83  	return file_google_pubsub_v1_schema_proto_enumTypes[0].Descriptor()
    84  }
    85  
    86  func (SchemaView) Type() protoreflect.EnumType {
    87  	return &file_google_pubsub_v1_schema_proto_enumTypes[0]
    88  }
    89  
    90  func (x SchemaView) Number() protoreflect.EnumNumber {
    91  	return protoreflect.EnumNumber(x)
    92  }
    93  
    94  // Deprecated: Use SchemaView.Descriptor instead.
    95  func (SchemaView) EnumDescriptor() ([]byte, []int) {
    96  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{0}
    97  }
    98  
    99  // Possible encoding types for messages.
   100  type Encoding int32
   101  
   102  const (
   103  	// Unspecified
   104  	Encoding_ENCODING_UNSPECIFIED Encoding = 0
   105  	// JSON encoding
   106  	Encoding_JSON Encoding = 1
   107  	// Binary encoding, as defined by the schema type. For some schema types,
   108  	// binary encoding may not be available.
   109  	Encoding_BINARY Encoding = 2
   110  )
   111  
   112  // Enum value maps for Encoding.
   113  var (
   114  	Encoding_name = map[int32]string{
   115  		0: "ENCODING_UNSPECIFIED",
   116  		1: "JSON",
   117  		2: "BINARY",
   118  	}
   119  	Encoding_value = map[string]int32{
   120  		"ENCODING_UNSPECIFIED": 0,
   121  		"JSON":                 1,
   122  		"BINARY":               2,
   123  	}
   124  )
   125  
   126  func (x Encoding) Enum() *Encoding {
   127  	p := new(Encoding)
   128  	*p = x
   129  	return p
   130  }
   131  
   132  func (x Encoding) String() string {
   133  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
   134  }
   135  
   136  func (Encoding) Descriptor() protoreflect.EnumDescriptor {
   137  	return file_google_pubsub_v1_schema_proto_enumTypes[1].Descriptor()
   138  }
   139  
   140  func (Encoding) Type() protoreflect.EnumType {
   141  	return &file_google_pubsub_v1_schema_proto_enumTypes[1]
   142  }
   143  
   144  func (x Encoding) Number() protoreflect.EnumNumber {
   145  	return protoreflect.EnumNumber(x)
   146  }
   147  
   148  // Deprecated: Use Encoding.Descriptor instead.
   149  func (Encoding) EnumDescriptor() ([]byte, []int) {
   150  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{1}
   151  }
   152  
   153  // Possible schema definition types.
   154  type Schema_Type int32
   155  
   156  const (
   157  	// Default value. This value is unused.
   158  	Schema_TYPE_UNSPECIFIED Schema_Type = 0
   159  	// A Protocol Buffer schema definition.
   160  	Schema_PROTOCOL_BUFFER Schema_Type = 1
   161  	// An Avro schema definition.
   162  	Schema_AVRO Schema_Type = 2
   163  )
   164  
   165  // Enum value maps for Schema_Type.
   166  var (
   167  	Schema_Type_name = map[int32]string{
   168  		0: "TYPE_UNSPECIFIED",
   169  		1: "PROTOCOL_BUFFER",
   170  		2: "AVRO",
   171  	}
   172  	Schema_Type_value = map[string]int32{
   173  		"TYPE_UNSPECIFIED": 0,
   174  		"PROTOCOL_BUFFER":  1,
   175  		"AVRO":             2,
   176  	}
   177  )
   178  
   179  func (x Schema_Type) Enum() *Schema_Type {
   180  	p := new(Schema_Type)
   181  	*p = x
   182  	return p
   183  }
   184  
   185  func (x Schema_Type) String() string {
   186  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
   187  }
   188  
   189  func (Schema_Type) Descriptor() protoreflect.EnumDescriptor {
   190  	return file_google_pubsub_v1_schema_proto_enumTypes[2].Descriptor()
   191  }
   192  
   193  func (Schema_Type) Type() protoreflect.EnumType {
   194  	return &file_google_pubsub_v1_schema_proto_enumTypes[2]
   195  }
   196  
   197  func (x Schema_Type) Number() protoreflect.EnumNumber {
   198  	return protoreflect.EnumNumber(x)
   199  }
   200  
   201  // Deprecated: Use Schema_Type.Descriptor instead.
   202  func (Schema_Type) EnumDescriptor() ([]byte, []int) {
   203  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{0, 0}
   204  }
   205  
   206  // A schema resource.
   207  type Schema struct {
   208  	state         protoimpl.MessageState
   209  	sizeCache     protoimpl.SizeCache
   210  	unknownFields protoimpl.UnknownFields
   211  
   212  	// Required. Name of the schema.
   213  	// Format is `projects/{project}/schemas/{schema}`.
   214  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   215  	// The type of the schema definition.
   216  	Type Schema_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.pubsub.v1.Schema_Type" json:"type,omitempty"`
   217  	// The definition of the schema. This should contain a string representing
   218  	// the full definition of the schema that is a valid schema definition of
   219  	// the type specified in `type`.
   220  	Definition string `protobuf:"bytes,3,opt,name=definition,proto3" json:"definition,omitempty"`
   221  	// Output only. Immutable. The revision ID of the schema.
   222  	RevisionId string `protobuf:"bytes,4,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"`
   223  	// Output only. The timestamp that the revision was created.
   224  	RevisionCreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=revision_create_time,json=revisionCreateTime,proto3" json:"revision_create_time,omitempty"`
   225  }
   226  
   227  func (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  
   236  func (x *Schema) String() string {
   237  	return protoimpl.X.MessageStringOf(x)
   238  }
   239  
   240  func (*Schema) ProtoMessage() {}
   241  
   242  func (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.
   255  func (*Schema) Descriptor() ([]byte, []int) {
   256  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{0}
   257  }
   258  
   259  func (x *Schema) GetName() string {
   260  	if x != nil {
   261  		return x.Name
   262  	}
   263  	return ""
   264  }
   265  
   266  func (x *Schema) GetType() Schema_Type {
   267  	if x != nil {
   268  		return x.Type
   269  	}
   270  	return Schema_TYPE_UNSPECIFIED
   271  }
   272  
   273  func (x *Schema) GetDefinition() string {
   274  	if x != nil {
   275  		return x.Definition
   276  	}
   277  	return ""
   278  }
   279  
   280  func (x *Schema) GetRevisionId() string {
   281  	if x != nil {
   282  		return x.RevisionId
   283  	}
   284  	return ""
   285  }
   286  
   287  func (x *Schema) GetRevisionCreateTime() *timestamppb.Timestamp {
   288  	if x != nil {
   289  		return x.RevisionCreateTime
   290  	}
   291  	return nil
   292  }
   293  
   294  // Request for the CreateSchema method.
   295  type CreateSchemaRequest struct {
   296  	state         protoimpl.MessageState
   297  	sizeCache     protoimpl.SizeCache
   298  	unknownFields protoimpl.UnknownFields
   299  
   300  	// Required. The name of the project in which to create the schema.
   301  	// Format is `projects/{project-id}`.
   302  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   303  	// Required. The schema object to create.
   304  	//
   305  	// This schema's `name` parameter is ignored. The schema object returned
   306  	// by CreateSchema will have a `name` made using the given `parent` and
   307  	// `schema_id`.
   308  	Schema *Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
   309  	// The ID to use for the schema, which will become the final component of
   310  	// the schema's resource name.
   311  	//
   312  	// See https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names for
   313  	// resource name constraints.
   314  	SchemaId string `protobuf:"bytes,3,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
   315  }
   316  
   317  func (x *CreateSchemaRequest) Reset() {
   318  	*x = CreateSchemaRequest{}
   319  	if protoimpl.UnsafeEnabled {
   320  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[1]
   321  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   322  		ms.StoreMessageInfo(mi)
   323  	}
   324  }
   325  
   326  func (x *CreateSchemaRequest) String() string {
   327  	return protoimpl.X.MessageStringOf(x)
   328  }
   329  
   330  func (*CreateSchemaRequest) ProtoMessage() {}
   331  
   332  func (x *CreateSchemaRequest) ProtoReflect() protoreflect.Message {
   333  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[1]
   334  	if protoimpl.UnsafeEnabled && x != nil {
   335  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   336  		if ms.LoadMessageInfo() == nil {
   337  			ms.StoreMessageInfo(mi)
   338  		}
   339  		return ms
   340  	}
   341  	return mi.MessageOf(x)
   342  }
   343  
   344  // Deprecated: Use CreateSchemaRequest.ProtoReflect.Descriptor instead.
   345  func (*CreateSchemaRequest) Descriptor() ([]byte, []int) {
   346  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{1}
   347  }
   348  
   349  func (x *CreateSchemaRequest) GetParent() string {
   350  	if x != nil {
   351  		return x.Parent
   352  	}
   353  	return ""
   354  }
   355  
   356  func (x *CreateSchemaRequest) GetSchema() *Schema {
   357  	if x != nil {
   358  		return x.Schema
   359  	}
   360  	return nil
   361  }
   362  
   363  func (x *CreateSchemaRequest) GetSchemaId() string {
   364  	if x != nil {
   365  		return x.SchemaId
   366  	}
   367  	return ""
   368  }
   369  
   370  // Request for the GetSchema method.
   371  type GetSchemaRequest struct {
   372  	state         protoimpl.MessageState
   373  	sizeCache     protoimpl.SizeCache
   374  	unknownFields protoimpl.UnknownFields
   375  
   376  	// Required. The name of the schema to get.
   377  	// Format is `projects/{project}/schemas/{schema}`.
   378  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   379  	// The set of fields to return in the response. If not set, returns a Schema
   380  	// with all fields filled out. Set to `BASIC` to omit the `definition`.
   381  	View SchemaView `protobuf:"varint,2,opt,name=view,proto3,enum=google.pubsub.v1.SchemaView" json:"view,omitempty"`
   382  }
   383  
   384  func (x *GetSchemaRequest) Reset() {
   385  	*x = GetSchemaRequest{}
   386  	if protoimpl.UnsafeEnabled {
   387  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[2]
   388  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   389  		ms.StoreMessageInfo(mi)
   390  	}
   391  }
   392  
   393  func (x *GetSchemaRequest) String() string {
   394  	return protoimpl.X.MessageStringOf(x)
   395  }
   396  
   397  func (*GetSchemaRequest) ProtoMessage() {}
   398  
   399  func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message {
   400  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[2]
   401  	if protoimpl.UnsafeEnabled && x != nil {
   402  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   403  		if ms.LoadMessageInfo() == nil {
   404  			ms.StoreMessageInfo(mi)
   405  		}
   406  		return ms
   407  	}
   408  	return mi.MessageOf(x)
   409  }
   410  
   411  // Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.
   412  func (*GetSchemaRequest) Descriptor() ([]byte, []int) {
   413  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{2}
   414  }
   415  
   416  func (x *GetSchemaRequest) GetName() string {
   417  	if x != nil {
   418  		return x.Name
   419  	}
   420  	return ""
   421  }
   422  
   423  func (x *GetSchemaRequest) GetView() SchemaView {
   424  	if x != nil {
   425  		return x.View
   426  	}
   427  	return SchemaView_SCHEMA_VIEW_UNSPECIFIED
   428  }
   429  
   430  // Request for the `ListSchemas` method.
   431  type ListSchemasRequest struct {
   432  	state         protoimpl.MessageState
   433  	sizeCache     protoimpl.SizeCache
   434  	unknownFields protoimpl.UnknownFields
   435  
   436  	// Required. The name of the project in which to list schemas.
   437  	// Format is `projects/{project-id}`.
   438  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   439  	// The set of Schema fields to return in the response. If not set, returns
   440  	// Schemas with `name` and `type`, but not `definition`. Set to `FULL` to
   441  	// retrieve all fields.
   442  	View SchemaView `protobuf:"varint,2,opt,name=view,proto3,enum=google.pubsub.v1.SchemaView" json:"view,omitempty"`
   443  	// Maximum number of schemas to return.
   444  	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
   445  	// The value returned by the last `ListSchemasResponse`; indicates that
   446  	// this is a continuation of a prior `ListSchemas` call, and that the
   447  	// system should return the next page of data.
   448  	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
   449  }
   450  
   451  func (x *ListSchemasRequest) Reset() {
   452  	*x = ListSchemasRequest{}
   453  	if protoimpl.UnsafeEnabled {
   454  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[3]
   455  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   456  		ms.StoreMessageInfo(mi)
   457  	}
   458  }
   459  
   460  func (x *ListSchemasRequest) String() string {
   461  	return protoimpl.X.MessageStringOf(x)
   462  }
   463  
   464  func (*ListSchemasRequest) ProtoMessage() {}
   465  
   466  func (x *ListSchemasRequest) ProtoReflect() protoreflect.Message {
   467  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[3]
   468  	if protoimpl.UnsafeEnabled && x != nil {
   469  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   470  		if ms.LoadMessageInfo() == nil {
   471  			ms.StoreMessageInfo(mi)
   472  		}
   473  		return ms
   474  	}
   475  	return mi.MessageOf(x)
   476  }
   477  
   478  // Deprecated: Use ListSchemasRequest.ProtoReflect.Descriptor instead.
   479  func (*ListSchemasRequest) Descriptor() ([]byte, []int) {
   480  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{3}
   481  }
   482  
   483  func (x *ListSchemasRequest) GetParent() string {
   484  	if x != nil {
   485  		return x.Parent
   486  	}
   487  	return ""
   488  }
   489  
   490  func (x *ListSchemasRequest) GetView() SchemaView {
   491  	if x != nil {
   492  		return x.View
   493  	}
   494  	return SchemaView_SCHEMA_VIEW_UNSPECIFIED
   495  }
   496  
   497  func (x *ListSchemasRequest) GetPageSize() int32 {
   498  	if x != nil {
   499  		return x.PageSize
   500  	}
   501  	return 0
   502  }
   503  
   504  func (x *ListSchemasRequest) GetPageToken() string {
   505  	if x != nil {
   506  		return x.PageToken
   507  	}
   508  	return ""
   509  }
   510  
   511  // Response for the `ListSchemas` method.
   512  type ListSchemasResponse struct {
   513  	state         protoimpl.MessageState
   514  	sizeCache     protoimpl.SizeCache
   515  	unknownFields protoimpl.UnknownFields
   516  
   517  	// The resulting schemas.
   518  	Schemas []*Schema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
   519  	// If not empty, indicates that there may be more schemas that match the
   520  	// request; this value should be passed in a new `ListSchemasRequest`.
   521  	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
   522  }
   523  
   524  func (x *ListSchemasResponse) Reset() {
   525  	*x = ListSchemasResponse{}
   526  	if protoimpl.UnsafeEnabled {
   527  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[4]
   528  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   529  		ms.StoreMessageInfo(mi)
   530  	}
   531  }
   532  
   533  func (x *ListSchemasResponse) String() string {
   534  	return protoimpl.X.MessageStringOf(x)
   535  }
   536  
   537  func (*ListSchemasResponse) ProtoMessage() {}
   538  
   539  func (x *ListSchemasResponse) ProtoReflect() protoreflect.Message {
   540  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[4]
   541  	if protoimpl.UnsafeEnabled && x != nil {
   542  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   543  		if ms.LoadMessageInfo() == nil {
   544  			ms.StoreMessageInfo(mi)
   545  		}
   546  		return ms
   547  	}
   548  	return mi.MessageOf(x)
   549  }
   550  
   551  // Deprecated: Use ListSchemasResponse.ProtoReflect.Descriptor instead.
   552  func (*ListSchemasResponse) Descriptor() ([]byte, []int) {
   553  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{4}
   554  }
   555  
   556  func (x *ListSchemasResponse) GetSchemas() []*Schema {
   557  	if x != nil {
   558  		return x.Schemas
   559  	}
   560  	return nil
   561  }
   562  
   563  func (x *ListSchemasResponse) GetNextPageToken() string {
   564  	if x != nil {
   565  		return x.NextPageToken
   566  	}
   567  	return ""
   568  }
   569  
   570  // Request for the `ListSchemaRevisions` method.
   571  type ListSchemaRevisionsRequest struct {
   572  	state         protoimpl.MessageState
   573  	sizeCache     protoimpl.SizeCache
   574  	unknownFields protoimpl.UnknownFields
   575  
   576  	// Required. The name of the schema to list revisions for.
   577  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   578  	// The set of Schema fields to return in the response. If not set, returns
   579  	// Schemas with `name` and `type`, but not `definition`. Set to `FULL` to
   580  	// retrieve all fields.
   581  	View SchemaView `protobuf:"varint,2,opt,name=view,proto3,enum=google.pubsub.v1.SchemaView" json:"view,omitempty"`
   582  	// The maximum number of revisions to return per page.
   583  	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
   584  	// The page token, received from a previous ListSchemaRevisions call.
   585  	// Provide this to retrieve the subsequent page.
   586  	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
   587  }
   588  
   589  func (x *ListSchemaRevisionsRequest) Reset() {
   590  	*x = ListSchemaRevisionsRequest{}
   591  	if protoimpl.UnsafeEnabled {
   592  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[5]
   593  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   594  		ms.StoreMessageInfo(mi)
   595  	}
   596  }
   597  
   598  func (x *ListSchemaRevisionsRequest) String() string {
   599  	return protoimpl.X.MessageStringOf(x)
   600  }
   601  
   602  func (*ListSchemaRevisionsRequest) ProtoMessage() {}
   603  
   604  func (x *ListSchemaRevisionsRequest) ProtoReflect() protoreflect.Message {
   605  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[5]
   606  	if protoimpl.UnsafeEnabled && x != nil {
   607  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   608  		if ms.LoadMessageInfo() == nil {
   609  			ms.StoreMessageInfo(mi)
   610  		}
   611  		return ms
   612  	}
   613  	return mi.MessageOf(x)
   614  }
   615  
   616  // Deprecated: Use ListSchemaRevisionsRequest.ProtoReflect.Descriptor instead.
   617  func (*ListSchemaRevisionsRequest) Descriptor() ([]byte, []int) {
   618  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{5}
   619  }
   620  
   621  func (x *ListSchemaRevisionsRequest) GetName() string {
   622  	if x != nil {
   623  		return x.Name
   624  	}
   625  	return ""
   626  }
   627  
   628  func (x *ListSchemaRevisionsRequest) GetView() SchemaView {
   629  	if x != nil {
   630  		return x.View
   631  	}
   632  	return SchemaView_SCHEMA_VIEW_UNSPECIFIED
   633  }
   634  
   635  func (x *ListSchemaRevisionsRequest) GetPageSize() int32 {
   636  	if x != nil {
   637  		return x.PageSize
   638  	}
   639  	return 0
   640  }
   641  
   642  func (x *ListSchemaRevisionsRequest) GetPageToken() string {
   643  	if x != nil {
   644  		return x.PageToken
   645  	}
   646  	return ""
   647  }
   648  
   649  // Response for the `ListSchemaRevisions` method.
   650  type ListSchemaRevisionsResponse struct {
   651  	state         protoimpl.MessageState
   652  	sizeCache     protoimpl.SizeCache
   653  	unknownFields protoimpl.UnknownFields
   654  
   655  	// The revisions of the schema.
   656  	Schemas []*Schema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
   657  	// A token that can be sent as `page_token` to retrieve the next page.
   658  	// If this field is empty, there are no subsequent pages.
   659  	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
   660  }
   661  
   662  func (x *ListSchemaRevisionsResponse) Reset() {
   663  	*x = ListSchemaRevisionsResponse{}
   664  	if protoimpl.UnsafeEnabled {
   665  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[6]
   666  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   667  		ms.StoreMessageInfo(mi)
   668  	}
   669  }
   670  
   671  func (x *ListSchemaRevisionsResponse) String() string {
   672  	return protoimpl.X.MessageStringOf(x)
   673  }
   674  
   675  func (*ListSchemaRevisionsResponse) ProtoMessage() {}
   676  
   677  func (x *ListSchemaRevisionsResponse) ProtoReflect() protoreflect.Message {
   678  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[6]
   679  	if protoimpl.UnsafeEnabled && x != nil {
   680  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   681  		if ms.LoadMessageInfo() == nil {
   682  			ms.StoreMessageInfo(mi)
   683  		}
   684  		return ms
   685  	}
   686  	return mi.MessageOf(x)
   687  }
   688  
   689  // Deprecated: Use ListSchemaRevisionsResponse.ProtoReflect.Descriptor instead.
   690  func (*ListSchemaRevisionsResponse) Descriptor() ([]byte, []int) {
   691  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{6}
   692  }
   693  
   694  func (x *ListSchemaRevisionsResponse) GetSchemas() []*Schema {
   695  	if x != nil {
   696  		return x.Schemas
   697  	}
   698  	return nil
   699  }
   700  
   701  func (x *ListSchemaRevisionsResponse) GetNextPageToken() string {
   702  	if x != nil {
   703  		return x.NextPageToken
   704  	}
   705  	return ""
   706  }
   707  
   708  // Request for CommitSchema method.
   709  type CommitSchemaRequest struct {
   710  	state         protoimpl.MessageState
   711  	sizeCache     protoimpl.SizeCache
   712  	unknownFields protoimpl.UnknownFields
   713  
   714  	// Required. The name of the schema we are revising.
   715  	// Format is `projects/{project}/schemas/{schema}`.
   716  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   717  	// Required. The schema revision to commit.
   718  	Schema *Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
   719  }
   720  
   721  func (x *CommitSchemaRequest) Reset() {
   722  	*x = CommitSchemaRequest{}
   723  	if protoimpl.UnsafeEnabled {
   724  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[7]
   725  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   726  		ms.StoreMessageInfo(mi)
   727  	}
   728  }
   729  
   730  func (x *CommitSchemaRequest) String() string {
   731  	return protoimpl.X.MessageStringOf(x)
   732  }
   733  
   734  func (*CommitSchemaRequest) ProtoMessage() {}
   735  
   736  func (x *CommitSchemaRequest) ProtoReflect() protoreflect.Message {
   737  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[7]
   738  	if protoimpl.UnsafeEnabled && x != nil {
   739  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   740  		if ms.LoadMessageInfo() == nil {
   741  			ms.StoreMessageInfo(mi)
   742  		}
   743  		return ms
   744  	}
   745  	return mi.MessageOf(x)
   746  }
   747  
   748  // Deprecated: Use CommitSchemaRequest.ProtoReflect.Descriptor instead.
   749  func (*CommitSchemaRequest) Descriptor() ([]byte, []int) {
   750  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{7}
   751  }
   752  
   753  func (x *CommitSchemaRequest) GetName() string {
   754  	if x != nil {
   755  		return x.Name
   756  	}
   757  	return ""
   758  }
   759  
   760  func (x *CommitSchemaRequest) GetSchema() *Schema {
   761  	if x != nil {
   762  		return x.Schema
   763  	}
   764  	return nil
   765  }
   766  
   767  // Request for the `RollbackSchema` method.
   768  type RollbackSchemaRequest struct {
   769  	state         protoimpl.MessageState
   770  	sizeCache     protoimpl.SizeCache
   771  	unknownFields protoimpl.UnknownFields
   772  
   773  	// Required. The schema being rolled back with revision id.
   774  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   775  	// Required. The revision ID to roll back to.
   776  	// It must be a revision of the same schema.
   777  	//
   778  	//	Example: c7cfa2a8
   779  	RevisionId string `protobuf:"bytes,2,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"`
   780  }
   781  
   782  func (x *RollbackSchemaRequest) Reset() {
   783  	*x = RollbackSchemaRequest{}
   784  	if protoimpl.UnsafeEnabled {
   785  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[8]
   786  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   787  		ms.StoreMessageInfo(mi)
   788  	}
   789  }
   790  
   791  func (x *RollbackSchemaRequest) String() string {
   792  	return protoimpl.X.MessageStringOf(x)
   793  }
   794  
   795  func (*RollbackSchemaRequest) ProtoMessage() {}
   796  
   797  func (x *RollbackSchemaRequest) ProtoReflect() protoreflect.Message {
   798  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[8]
   799  	if protoimpl.UnsafeEnabled && x != nil {
   800  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   801  		if ms.LoadMessageInfo() == nil {
   802  			ms.StoreMessageInfo(mi)
   803  		}
   804  		return ms
   805  	}
   806  	return mi.MessageOf(x)
   807  }
   808  
   809  // Deprecated: Use RollbackSchemaRequest.ProtoReflect.Descriptor instead.
   810  func (*RollbackSchemaRequest) Descriptor() ([]byte, []int) {
   811  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{8}
   812  }
   813  
   814  func (x *RollbackSchemaRequest) GetName() string {
   815  	if x != nil {
   816  		return x.Name
   817  	}
   818  	return ""
   819  }
   820  
   821  func (x *RollbackSchemaRequest) GetRevisionId() string {
   822  	if x != nil {
   823  		return x.RevisionId
   824  	}
   825  	return ""
   826  }
   827  
   828  // Request for the `DeleteSchemaRevision` method.
   829  type DeleteSchemaRevisionRequest struct {
   830  	state         protoimpl.MessageState
   831  	sizeCache     protoimpl.SizeCache
   832  	unknownFields protoimpl.UnknownFields
   833  
   834  	// Required. The name of the schema revision to be deleted, with a revision ID
   835  	// explicitly included.
   836  	//
   837  	// Example: `projects/123/schemas/my-schema@c7cfa2a8`
   838  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   839  	// Optional. This field is deprecated and should not be used for specifying
   840  	// the revision ID. The revision ID should be specified via the `name`
   841  	// parameter.
   842  	//
   843  	// Deprecated: Marked as deprecated in google/pubsub/v1/schema.proto.
   844  	RevisionId string `protobuf:"bytes,2,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"`
   845  }
   846  
   847  func (x *DeleteSchemaRevisionRequest) Reset() {
   848  	*x = DeleteSchemaRevisionRequest{}
   849  	if protoimpl.UnsafeEnabled {
   850  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[9]
   851  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   852  		ms.StoreMessageInfo(mi)
   853  	}
   854  }
   855  
   856  func (x *DeleteSchemaRevisionRequest) String() string {
   857  	return protoimpl.X.MessageStringOf(x)
   858  }
   859  
   860  func (*DeleteSchemaRevisionRequest) ProtoMessage() {}
   861  
   862  func (x *DeleteSchemaRevisionRequest) ProtoReflect() protoreflect.Message {
   863  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[9]
   864  	if protoimpl.UnsafeEnabled && x != nil {
   865  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   866  		if ms.LoadMessageInfo() == nil {
   867  			ms.StoreMessageInfo(mi)
   868  		}
   869  		return ms
   870  	}
   871  	return mi.MessageOf(x)
   872  }
   873  
   874  // Deprecated: Use DeleteSchemaRevisionRequest.ProtoReflect.Descriptor instead.
   875  func (*DeleteSchemaRevisionRequest) Descriptor() ([]byte, []int) {
   876  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{9}
   877  }
   878  
   879  func (x *DeleteSchemaRevisionRequest) GetName() string {
   880  	if x != nil {
   881  		return x.Name
   882  	}
   883  	return ""
   884  }
   885  
   886  // Deprecated: Marked as deprecated in google/pubsub/v1/schema.proto.
   887  func (x *DeleteSchemaRevisionRequest) GetRevisionId() string {
   888  	if x != nil {
   889  		return x.RevisionId
   890  	}
   891  	return ""
   892  }
   893  
   894  // Request for the `DeleteSchema` method.
   895  type DeleteSchemaRequest struct {
   896  	state         protoimpl.MessageState
   897  	sizeCache     protoimpl.SizeCache
   898  	unknownFields protoimpl.UnknownFields
   899  
   900  	// Required. Name of the schema to delete.
   901  	// Format is `projects/{project}/schemas/{schema}`.
   902  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   903  }
   904  
   905  func (x *DeleteSchemaRequest) Reset() {
   906  	*x = DeleteSchemaRequest{}
   907  	if protoimpl.UnsafeEnabled {
   908  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[10]
   909  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   910  		ms.StoreMessageInfo(mi)
   911  	}
   912  }
   913  
   914  func (x *DeleteSchemaRequest) String() string {
   915  	return protoimpl.X.MessageStringOf(x)
   916  }
   917  
   918  func (*DeleteSchemaRequest) ProtoMessage() {}
   919  
   920  func (x *DeleteSchemaRequest) ProtoReflect() protoreflect.Message {
   921  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[10]
   922  	if protoimpl.UnsafeEnabled && x != nil {
   923  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   924  		if ms.LoadMessageInfo() == nil {
   925  			ms.StoreMessageInfo(mi)
   926  		}
   927  		return ms
   928  	}
   929  	return mi.MessageOf(x)
   930  }
   931  
   932  // Deprecated: Use DeleteSchemaRequest.ProtoReflect.Descriptor instead.
   933  func (*DeleteSchemaRequest) Descriptor() ([]byte, []int) {
   934  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{10}
   935  }
   936  
   937  func (x *DeleteSchemaRequest) GetName() string {
   938  	if x != nil {
   939  		return x.Name
   940  	}
   941  	return ""
   942  }
   943  
   944  // Request for the `ValidateSchema` method.
   945  type ValidateSchemaRequest struct {
   946  	state         protoimpl.MessageState
   947  	sizeCache     protoimpl.SizeCache
   948  	unknownFields protoimpl.UnknownFields
   949  
   950  	// Required. The name of the project in which to validate schemas.
   951  	// Format is `projects/{project-id}`.
   952  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   953  	// Required. The schema object to validate.
   954  	Schema *Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
   955  }
   956  
   957  func (x *ValidateSchemaRequest) Reset() {
   958  	*x = ValidateSchemaRequest{}
   959  	if protoimpl.UnsafeEnabled {
   960  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[11]
   961  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   962  		ms.StoreMessageInfo(mi)
   963  	}
   964  }
   965  
   966  func (x *ValidateSchemaRequest) String() string {
   967  	return protoimpl.X.MessageStringOf(x)
   968  }
   969  
   970  func (*ValidateSchemaRequest) ProtoMessage() {}
   971  
   972  func (x *ValidateSchemaRequest) ProtoReflect() protoreflect.Message {
   973  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[11]
   974  	if protoimpl.UnsafeEnabled && x != nil {
   975  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   976  		if ms.LoadMessageInfo() == nil {
   977  			ms.StoreMessageInfo(mi)
   978  		}
   979  		return ms
   980  	}
   981  	return mi.MessageOf(x)
   982  }
   983  
   984  // Deprecated: Use ValidateSchemaRequest.ProtoReflect.Descriptor instead.
   985  func (*ValidateSchemaRequest) Descriptor() ([]byte, []int) {
   986  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{11}
   987  }
   988  
   989  func (x *ValidateSchemaRequest) GetParent() string {
   990  	if x != nil {
   991  		return x.Parent
   992  	}
   993  	return ""
   994  }
   995  
   996  func (x *ValidateSchemaRequest) GetSchema() *Schema {
   997  	if x != nil {
   998  		return x.Schema
   999  	}
  1000  	return nil
  1001  }
  1002  
  1003  // Response for the `ValidateSchema` method.
  1004  // Empty for now.
  1005  type ValidateSchemaResponse struct {
  1006  	state         protoimpl.MessageState
  1007  	sizeCache     protoimpl.SizeCache
  1008  	unknownFields protoimpl.UnknownFields
  1009  }
  1010  
  1011  func (x *ValidateSchemaResponse) Reset() {
  1012  	*x = ValidateSchemaResponse{}
  1013  	if protoimpl.UnsafeEnabled {
  1014  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[12]
  1015  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1016  		ms.StoreMessageInfo(mi)
  1017  	}
  1018  }
  1019  
  1020  func (x *ValidateSchemaResponse) String() string {
  1021  	return protoimpl.X.MessageStringOf(x)
  1022  }
  1023  
  1024  func (*ValidateSchemaResponse) ProtoMessage() {}
  1025  
  1026  func (x *ValidateSchemaResponse) ProtoReflect() protoreflect.Message {
  1027  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[12]
  1028  	if protoimpl.UnsafeEnabled && x != nil {
  1029  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1030  		if ms.LoadMessageInfo() == nil {
  1031  			ms.StoreMessageInfo(mi)
  1032  		}
  1033  		return ms
  1034  	}
  1035  	return mi.MessageOf(x)
  1036  }
  1037  
  1038  // Deprecated: Use ValidateSchemaResponse.ProtoReflect.Descriptor instead.
  1039  func (*ValidateSchemaResponse) Descriptor() ([]byte, []int) {
  1040  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{12}
  1041  }
  1042  
  1043  // Request for the `ValidateMessage` method.
  1044  type ValidateMessageRequest struct {
  1045  	state         protoimpl.MessageState
  1046  	sizeCache     protoimpl.SizeCache
  1047  	unknownFields protoimpl.UnknownFields
  1048  
  1049  	// Required. The name of the project in which to validate schemas.
  1050  	// Format is `projects/{project-id}`.
  1051  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
  1052  	// Types that are assignable to SchemaSpec:
  1053  	//
  1054  	//	*ValidateMessageRequest_Name
  1055  	//	*ValidateMessageRequest_Schema
  1056  	SchemaSpec isValidateMessageRequest_SchemaSpec `protobuf_oneof:"schema_spec"`
  1057  	// Message to validate against the provided `schema_spec`.
  1058  	Message []byte `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
  1059  	// The encoding expected for messages
  1060  	Encoding Encoding `protobuf:"varint,5,opt,name=encoding,proto3,enum=google.pubsub.v1.Encoding" json:"encoding,omitempty"`
  1061  }
  1062  
  1063  func (x *ValidateMessageRequest) Reset() {
  1064  	*x = ValidateMessageRequest{}
  1065  	if protoimpl.UnsafeEnabled {
  1066  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[13]
  1067  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1068  		ms.StoreMessageInfo(mi)
  1069  	}
  1070  }
  1071  
  1072  func (x *ValidateMessageRequest) String() string {
  1073  	return protoimpl.X.MessageStringOf(x)
  1074  }
  1075  
  1076  func (*ValidateMessageRequest) ProtoMessage() {}
  1077  
  1078  func (x *ValidateMessageRequest) ProtoReflect() protoreflect.Message {
  1079  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[13]
  1080  	if protoimpl.UnsafeEnabled && x != nil {
  1081  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1082  		if ms.LoadMessageInfo() == nil {
  1083  			ms.StoreMessageInfo(mi)
  1084  		}
  1085  		return ms
  1086  	}
  1087  	return mi.MessageOf(x)
  1088  }
  1089  
  1090  // Deprecated: Use ValidateMessageRequest.ProtoReflect.Descriptor instead.
  1091  func (*ValidateMessageRequest) Descriptor() ([]byte, []int) {
  1092  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{13}
  1093  }
  1094  
  1095  func (x *ValidateMessageRequest) GetParent() string {
  1096  	if x != nil {
  1097  		return x.Parent
  1098  	}
  1099  	return ""
  1100  }
  1101  
  1102  func (m *ValidateMessageRequest) GetSchemaSpec() isValidateMessageRequest_SchemaSpec {
  1103  	if m != nil {
  1104  		return m.SchemaSpec
  1105  	}
  1106  	return nil
  1107  }
  1108  
  1109  func (x *ValidateMessageRequest) GetName() string {
  1110  	if x, ok := x.GetSchemaSpec().(*ValidateMessageRequest_Name); ok {
  1111  		return x.Name
  1112  	}
  1113  	return ""
  1114  }
  1115  
  1116  func (x *ValidateMessageRequest) GetSchema() *Schema {
  1117  	if x, ok := x.GetSchemaSpec().(*ValidateMessageRequest_Schema); ok {
  1118  		return x.Schema
  1119  	}
  1120  	return nil
  1121  }
  1122  
  1123  func (x *ValidateMessageRequest) GetMessage() []byte {
  1124  	if x != nil {
  1125  		return x.Message
  1126  	}
  1127  	return nil
  1128  }
  1129  
  1130  func (x *ValidateMessageRequest) GetEncoding() Encoding {
  1131  	if x != nil {
  1132  		return x.Encoding
  1133  	}
  1134  	return Encoding_ENCODING_UNSPECIFIED
  1135  }
  1136  
  1137  type isValidateMessageRequest_SchemaSpec interface {
  1138  	isValidateMessageRequest_SchemaSpec()
  1139  }
  1140  
  1141  type ValidateMessageRequest_Name struct {
  1142  	// Name of the schema against which to validate.
  1143  	//
  1144  	// Format is `projects/{project}/schemas/{schema}`.
  1145  	Name string `protobuf:"bytes,2,opt,name=name,proto3,oneof"`
  1146  }
  1147  
  1148  type ValidateMessageRequest_Schema struct {
  1149  	// Ad-hoc schema against which to validate
  1150  	Schema *Schema `protobuf:"bytes,3,opt,name=schema,proto3,oneof"`
  1151  }
  1152  
  1153  func (*ValidateMessageRequest_Name) isValidateMessageRequest_SchemaSpec() {}
  1154  
  1155  func (*ValidateMessageRequest_Schema) isValidateMessageRequest_SchemaSpec() {}
  1156  
  1157  // Response for the `ValidateMessage` method.
  1158  // Empty for now.
  1159  type ValidateMessageResponse struct {
  1160  	state         protoimpl.MessageState
  1161  	sizeCache     protoimpl.SizeCache
  1162  	unknownFields protoimpl.UnknownFields
  1163  }
  1164  
  1165  func (x *ValidateMessageResponse) Reset() {
  1166  	*x = ValidateMessageResponse{}
  1167  	if protoimpl.UnsafeEnabled {
  1168  		mi := &file_google_pubsub_v1_schema_proto_msgTypes[14]
  1169  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1170  		ms.StoreMessageInfo(mi)
  1171  	}
  1172  }
  1173  
  1174  func (x *ValidateMessageResponse) String() string {
  1175  	return protoimpl.X.MessageStringOf(x)
  1176  }
  1177  
  1178  func (*ValidateMessageResponse) ProtoMessage() {}
  1179  
  1180  func (x *ValidateMessageResponse) ProtoReflect() protoreflect.Message {
  1181  	mi := &file_google_pubsub_v1_schema_proto_msgTypes[14]
  1182  	if protoimpl.UnsafeEnabled && x != nil {
  1183  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1184  		if ms.LoadMessageInfo() == nil {
  1185  			ms.StoreMessageInfo(mi)
  1186  		}
  1187  		return ms
  1188  	}
  1189  	return mi.MessageOf(x)
  1190  }
  1191  
  1192  // Deprecated: Use ValidateMessageResponse.ProtoReflect.Descriptor instead.
  1193  func (*ValidateMessageResponse) Descriptor() ([]byte, []int) {
  1194  	return file_google_pubsub_v1_schema_proto_rawDescGZIP(), []int{14}
  1195  }
  1196  
  1197  var File_google_pubsub_v1_schema_proto protoreflect.FileDescriptor
  1198  
  1199  var file_google_pubsub_v1_schema_proto_rawDesc = []byte{
  1200  	0x0a, 0x1d, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2f,
  1201  	0x76, 0x31, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12,
  1202  	0x10, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76,
  1203  	0x31, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e,
  1204  	0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a,
  1205  	0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65,
  1206  	0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1207  	0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76,
  1208  	0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1209  	0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70,
  1210  	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f,
  1211  	0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74,
  1212  	0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
  1213  	0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f,
  1214  	0x74, 0x6f, 0x22, 0xf5, 0x02, 0x0a, 0x06, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x17, 0x0a,
  1215  	0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x02,
  1216  	0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x31, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02,
  1217  	0x20, 0x01, 0x28, 0x0e, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75,
  1218  	0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x2e, 0x54,
  1219  	0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x64, 0x65, 0x66,
  1220  	0x69, 0x6e, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x64,
  1221  	0x65, 0x66, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x27, 0x0a, 0x0b, 0x72, 0x65, 0x76,
  1222  	0x69, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06,
  1223  	0xe0, 0x41, 0x05, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e,
  1224  	0x49, 0x64, 0x12, 0x51, 0x0a, 0x14, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x63,
  1225  	0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b,
  1226  	0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
  1227  	0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41,
  1228  	0x03, 0x52, 0x12, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x43, 0x72, 0x65, 0x61, 0x74,
  1229  	0x65, 0x54, 0x69, 0x6d, 0x65, 0x22, 0x3b, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 0x0a,
  1230  	0x10, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45,
  1231  	0x44, 0x10, 0x00, 0x12, 0x13, 0x0a, 0x0f, 0x50, 0x52, 0x4f, 0x54, 0x4f, 0x43, 0x4f, 0x4c, 0x5f,
  1232  	0x42, 0x55, 0x46, 0x46, 0x45, 0x52, 0x10, 0x01, 0x12, 0x08, 0x0a, 0x04, 0x41, 0x56, 0x52, 0x4f,
  1233  	0x10, 0x02, 0x3a, 0x46, 0xea, 0x41, 0x43, 0x0a, 0x1c, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e,
  1234  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53,
  1235  	0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x23, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f,
  1236  	0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1237  	0x73, 0x2f, 0x7b, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x7d, 0x22, 0xa7, 0x01, 0x0a, 0x13, 0x43,
  1238  	0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65,
  1239  	0x73, 0x74, 0x12, 0x3c, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01,
  1240  	0x28, 0x09, 0x42, 0x24, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x1e, 0x12, 0x1c, 0x70, 0x75, 0x62, 0x73,
  1241  	0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f,
  1242  	0x6d, 0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74,
  1243  	0x12, 0x35, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b,
  1244  	0x32, 0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62,
  1245  	0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52,
  1246  	0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x1b, 0x0a, 0x09, 0x73, 0x63, 0x68, 0x65, 0x6d,
  1247  	0x61, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x73, 0x63, 0x68, 0x65,
  1248  	0x6d, 0x61, 0x49, 0x64, 0x22, 0x7e, 0x0a, 0x10, 0x47, 0x65, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d,
  1249  	0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
  1250  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x24, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x1e, 0x0a, 0x1c,
  1251  	0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69,
  1252  	0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x04, 0x6e, 0x61,
  1253  	0x6d, 0x65, 0x12, 0x30, 0x0a, 0x04, 0x76, 0x69, 0x65, 0x77, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e,
  1254  	0x32, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62,
  1255  	0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x56, 0x69, 0x65, 0x77, 0x52, 0x04,
  1256  	0x76, 0x69, 0x65, 0x77, 0x22, 0xcf, 0x01, 0x0a, 0x12, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x63, 0x68,
  1257  	0x65, 0x6d, 0x61, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4b, 0x0a, 0x06, 0x70,
  1258  	0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x33, 0xe0, 0x41, 0x02,
  1259  	0xfa, 0x41, 0x2d, 0x0a, 0x2b, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72,
  1260  	0x63, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1261  	0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x50, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74,
  1262  	0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x30, 0x0a, 0x04, 0x76, 0x69, 0x65, 0x77,
  1263  	0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1264  	0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1265  	0x56, 0x69, 0x65, 0x77, 0x52, 0x04, 0x76, 0x69, 0x65, 0x77, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61,
  1266  	0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70,
  1267  	0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f,
  1268  	0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67,
  1269  	0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x71, 0x0a, 0x13, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x63,
  1270  	0x68, 0x65, 0x6d, 0x61, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x32, 0x0a,
  1271  	0x07, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x18,
  1272  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76,
  1273  	0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x07, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1274  	0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74,
  1275  	0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74,
  1276  	0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0xc4, 0x01, 0x0a, 0x1a, 0x4c, 0x69,
  1277  	0x73, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e,
  1278  	0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
  1279  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x24, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x1e, 0x0a, 0x1c,
  1280  	0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69,
  1281  	0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x04, 0x6e, 0x61,
  1282  	0x6d, 0x65, 0x12, 0x30, 0x0a, 0x04, 0x76, 0x69, 0x65, 0x77, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e,
  1283  	0x32, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62,
  1284  	0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x56, 0x69, 0x65, 0x77, 0x52, 0x04,
  1285  	0x76, 0x69, 0x65, 0x77, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a,
  1286  	0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a,
  1287  	0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18,
  1288  	0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e,
  1289  	0x22, 0x79, 0x0a, 0x1b, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65,
  1290  	0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12,
  1291  	0x32, 0x0a, 0x07, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b,
  1292  	0x32, 0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62,
  1293  	0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x07, 0x73, 0x63, 0x68, 0x65,
  1294  	0x6d, 0x61, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65,
  1295  	0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65,
  1296  	0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x86, 0x01, 0x0a, 0x13,
  1297  	0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x71, 0x75,
  1298  	0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
  1299  	0x09, 0x42, 0x24, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x1e, 0x0a, 0x1c, 0x70, 0x75, 0x62, 0x73, 0x75,
  1300  	0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d,
  1301  	0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x35, 0x0a,
  1302  	0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x18, 0x2e,
  1303  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31,
  1304  	0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x06, 0x73, 0x63,
  1305  	0x68, 0x65, 0x6d, 0x61, 0x22, 0x77, 0x0a, 0x15, 0x52, 0x6f, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b,
  1306  	0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a,
  1307  	0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x24, 0xe0, 0x41, 0x02,
  1308  	0xfa, 0x41, 0x1e, 0x0a, 0x1c, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1309  	0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d,
  1310  	0x61, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x24, 0x0a, 0x0b, 0x72, 0x65, 0x76, 0x69, 0x73,
  1311  	0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41,
  1312  	0x02, 0x52, 0x0a, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x22, 0x7f, 0x0a,
  1313  	0x1b, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x76,
  1314  	0x69, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x04,
  1315  	0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x24, 0xe0, 0x41, 0x02, 0xfa,
  1316  	0x41, 0x1e, 0x0a, 0x1c, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1317  	0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1318  	0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x26, 0x0a, 0x0b, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69,
  1319  	0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x05, 0xe0, 0x41, 0x01,
  1320  	0x18, 0x01, 0x52, 0x0a, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x22, 0x4f,
  1321  	0x0a, 0x13, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65,
  1322  	0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20,
  1323  	0x01, 0x28, 0x09, 0x42, 0x24, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x1e, 0x0a, 0x1c, 0x70, 0x75, 0x62,
  1324  	0x73, 0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63,
  1325  	0x6f, 0x6d, 0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22,
  1326  	0x9b, 0x01, 0x0a, 0x15, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65,
  1327  	0x6d, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4b, 0x0a, 0x06, 0x70, 0x61, 0x72,
  1328  	0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x33, 0xe0, 0x41, 0x02, 0xfa, 0x41,
  1329  	0x2d, 0x0a, 0x2b, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65,
  1330  	0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70,
  1331  	0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x50, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x52, 0x06,
  1332  	0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x35, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1333  	0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1334  	0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1335  	0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0x18, 0x0a,
  1336  	0x16, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52,
  1337  	0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xb3, 0x02, 0x0a, 0x16, 0x56, 0x61, 0x6c, 0x69,
  1338  	0x64, 0x61, 0x74, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
  1339  	0x73, 0x74, 0x12, 0x4b, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01,
  1340  	0x28, 0x09, 0x42, 0x33, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2d, 0x0a, 0x2b, 0x63, 0x6c, 0x6f, 0x75,
  1341  	0x64, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x72,
  1342  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
  1343  	0x50, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12,
  1344  	0x37, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x21, 0xfa,
  1345  	0x41, 0x1e, 0x0a, 0x1c, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1346  	0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1347  	0x48, 0x00, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x32, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65,
  1348  	0x6d, 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1349  	0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65,
  1350  	0x6d, 0x61, 0x48, 0x00, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x18, 0x0a, 0x07,
  1351  	0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x07, 0x6d,
  1352  	0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x36, 0x0a, 0x08, 0x65, 0x6e, 0x63, 0x6f, 0x64, 0x69,
  1353  	0x6e, 0x67, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1354  	0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x6e, 0x63, 0x6f,
  1355  	0x64, 0x69, 0x6e, 0x67, 0x52, 0x08, 0x65, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 0x42, 0x0d,
  1356  	0x0a, 0x0b, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x73, 0x70, 0x65, 0x63, 0x22, 0x19, 0x0a,
  1357  	0x17, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65,
  1358  	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2a, 0x3e, 0x0a, 0x0a, 0x53, 0x63, 0x68, 0x65,
  1359  	0x6d, 0x61, 0x56, 0x69, 0x65, 0x77, 0x12, 0x1b, 0x0a, 0x17, 0x53, 0x43, 0x48, 0x45, 0x4d, 0x41,
  1360  	0x5f, 0x56, 0x49, 0x45, 0x57, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45,
  1361  	0x44, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x42, 0x41, 0x53, 0x49, 0x43, 0x10, 0x01, 0x12, 0x08,
  1362  	0x0a, 0x04, 0x46, 0x55, 0x4c, 0x4c, 0x10, 0x02, 0x2a, 0x3a, 0x0a, 0x08, 0x45, 0x6e, 0x63, 0x6f,
  1363  	0x64, 0x69, 0x6e, 0x67, 0x12, 0x18, 0x0a, 0x14, 0x45, 0x4e, 0x43, 0x4f, 0x44, 0x49, 0x4e, 0x47,
  1364  	0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x08,
  1365  	0x0a, 0x04, 0x4a, 0x53, 0x4f, 0x4e, 0x10, 0x01, 0x12, 0x0a, 0x0a, 0x06, 0x42, 0x49, 0x4e, 0x41,
  1366  	0x52, 0x59, 0x10, 0x02, 0x32, 0x88, 0x0d, 0x0a, 0x0d, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x53,
  1367  	0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x9a, 0x01, 0x0a, 0x0c, 0x43, 0x72, 0x65, 0x61, 0x74,
  1368  	0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1369  	0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74,
  1370  	0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x18,
  1371  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76,
  1372  	0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0x49, 0xda, 0x41, 0x17, 0x70, 0x61, 0x72,
  1373  	0x65, 0x6e, 0x74, 0x2c, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x2c, 0x73, 0x63, 0x68, 0x65, 0x6d,
  1374  	0x61, 0x5f, 0x69, 0x64, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x29, 0x3a, 0x06, 0x73, 0x63, 0x68, 0x65,
  1375  	0x6d, 0x61, 0x22, 0x1f, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d,
  1376  	0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x73, 0x63, 0x68, 0x65,
  1377  	0x6d, 0x61, 0x73, 0x12, 0x79, 0x0a, 0x09, 0x47, 0x65, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1378  	0x12, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62,
  1379  	0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x71,
  1380  	0x75, 0x65, 0x73, 0x74, 0x1a, 0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75,
  1381  	0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0x2e,
  1382  	0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x21, 0x12, 0x1f, 0x2f,
  1383  	0x76, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74,
  1384  	0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x2f, 0x2a, 0x7d, 0x12, 0x8c,
  1385  	0x01, 0x0a, 0x0b, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x12, 0x24,
  1386  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76,
  1387  	0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x52, 0x65, 0x71,
  1388  	0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75,
  1389  	0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x63, 0x68, 0x65,
  1390  	0x6d, 0x61, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x30, 0xda, 0x41, 0x06,
  1391  	0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x21, 0x12, 0x1f, 0x2f, 0x76,
  1392  	0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
  1393  	0x74, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x12, 0xb0, 0x01,
  1394  	0x0a, 0x13, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x76, 0x69,
  1395  	0x73, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
  1396  	0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x63, 0x68,
  1397  	0x65, 0x6d, 0x61, 0x52, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75,
  1398  	0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62,
  1399  	0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d,
  1400  	0x61, 0x52, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
  1401  	0x73, 0x65, 0x22, 0x3c, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x82, 0xd3, 0xe4, 0x93, 0x02,
  1402  	0x2f, 0x12, 0x2d, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f,
  1403  	0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x2f,
  1404  	0x2a, 0x7d, 0x3a, 0x6c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x73,
  1405  	0x12, 0x90, 0x01, 0x0a, 0x0c, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d,
  1406  	0x61, 0x12, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75,
  1407  	0x62, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x53, 0x63, 0x68, 0x65, 0x6d,
  1408  	0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1409  	0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65,
  1410  	0x6d, 0x61, 0x22, 0x3f, 0xda, 0x41, 0x0b, 0x6e, 0x61, 0x6d, 0x65, 0x2c, 0x73, 0x63, 0x68, 0x65,
  1411  	0x6d, 0x61, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2b, 0x3a, 0x01, 0x2a, 0x22, 0x26, 0x2f, 0x76, 0x31,
  1412  	0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f,
  1413  	0x2a, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x63, 0x6f, 0x6d,
  1414  	0x6d, 0x69, 0x74, 0x12, 0x9b, 0x01, 0x0a, 0x0e, 0x52, 0x6f, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b,
  1415  	0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x27, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1416  	0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x6f, 0x6c, 0x6c, 0x62, 0x61,
  1417  	0x63, 0x6b, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
  1418  	0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e,
  1419  	0x76, 0x31, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0x46, 0xda, 0x41, 0x10, 0x6e, 0x61,
  1420  	0x6d, 0x65, 0x2c, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x82, 0xd3,
  1421  	0xe4, 0x93, 0x02, 0x2d, 0x3a, 0x01, 0x2a, 0x22, 0x28, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x6e, 0x61,
  1422  	0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x63,
  1423  	0x68, 0x65, 0x6d, 0x61, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x72, 0x6f, 0x6c, 0x6c, 0x62, 0x61, 0x63,
  1424  	0x6b, 0x12, 0xaa, 0x01, 0x0a, 0x14, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65,
  1425  	0x6d, 0x61, 0x52, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x2d, 0x2e, 0x67, 0x6f, 0x6f,
  1426  	0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x65,
  1427  	0x6c, 0x65, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x76, 0x69, 0x73, 0x69,
  1428  	0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x18, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1429  	0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x63, 0x68,
  1430  	0x65, 0x6d, 0x61, 0x22, 0x49, 0xda, 0x41, 0x10, 0x6e, 0x61, 0x6d, 0x65, 0x2c, 0x72, 0x65, 0x76,
  1431  	0x69, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x30, 0x2a, 0x2e,
  1432  	0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
  1433  	0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x2f, 0x2a, 0x7d, 0x3a,
  1434  	0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x7d,
  1435  	0x0a, 0x0c, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x25,
  1436  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76,
  1437  	0x31, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65,
  1438  	0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
  1439  	0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x2e, 0xda,
  1440  	0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x21, 0x2a, 0x1f, 0x2f, 0x76,
  1441  	0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73,
  1442  	0x2f, 0x2a, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x2f, 0x2a, 0x7d, 0x12, 0xa8, 0x01,
  1443  	0x0a, 0x0e, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1444  	0x12, 0x27, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62,
  1445  	0x2e, 0x76, 0x31, 0x2e, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65,
  1446  	0x6d, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1447  	0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x56, 0x61, 0x6c,
  1448  	0x69, 0x64, 0x61, 0x74, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f,
  1449  	0x6e, 0x73, 0x65, 0x22, 0x43, 0xda, 0x41, 0x0d, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x73,
  1450  	0x63, 0x68, 0x65, 0x6d, 0x61, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2d, 0x3a, 0x01, 0x2a, 0x22, 0x28,
  1451  	0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a,
  1452  	0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x3a,
  1453  	0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x12, 0xa2, 0x01, 0x0a, 0x0f, 0x56, 0x61, 0x6c,
  1454  	0x69, 0x64, 0x61, 0x74, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x28, 0x2e, 0x67,
  1455  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e,
  1456  	0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52,
  1457  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1458  	0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x2e, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61,
  1459  	0x74, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
  1460  	0x65, 0x22, 0x3a, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x3a, 0x01, 0x2a, 0x22, 0x2f, 0x2f, 0x76,
  1461  	0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
  1462  	0x74, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x73, 0x3a, 0x76, 0x61,
  1463  	0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x1a, 0x70, 0xca,
  1464  	0x41, 0x15, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61,
  1465  	0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x55, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a,
  1466  	0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73,
  1467  	0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d,
  1468  	0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2c, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f,
  1469  	0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e,
  1470  	0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x42,
  1471  	0xaa, 0x01, 0x0a, 0x14, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
  1472  	0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x42, 0x0b, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1473  	0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x32, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x67,
  1474  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x6f, 0x2f, 0x70, 0x75, 0x62,
  1475  	0x73, 0x75, 0x62, 0x2f, 0x61, 0x70, 0x69, 0x76, 0x31, 0x2f, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62,
  1476  	0x70, 0x62, 0x3b, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x70, 0x62, 0xf8, 0x01, 0x01, 0xaa, 0x02,
  1477  	0x16, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x50, 0x75,
  1478  	0x62, 0x53, 0x75, 0x62, 0x2e, 0x56, 0x31, 0xca, 0x02, 0x16, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1479  	0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x50, 0x75, 0x62, 0x53, 0x75, 0x62, 0x5c, 0x56, 0x31,
  1480  	0xea, 0x02, 0x19, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x3a, 0x3a, 0x43, 0x6c, 0x6f, 0x75, 0x64,
  1481  	0x3a, 0x3a, 0x50, 0x75, 0x62, 0x53, 0x75, 0x62, 0x3a, 0x3a, 0x56, 0x31, 0x62, 0x06, 0x70, 0x72,
  1482  	0x6f, 0x74, 0x6f, 0x33,
  1483  }
  1484  
  1485  var (
  1486  	file_google_pubsub_v1_schema_proto_rawDescOnce sync.Once
  1487  	file_google_pubsub_v1_schema_proto_rawDescData = file_google_pubsub_v1_schema_proto_rawDesc
  1488  )
  1489  
  1490  func file_google_pubsub_v1_schema_proto_rawDescGZIP() []byte {
  1491  	file_google_pubsub_v1_schema_proto_rawDescOnce.Do(func() {
  1492  		file_google_pubsub_v1_schema_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_pubsub_v1_schema_proto_rawDescData)
  1493  	})
  1494  	return file_google_pubsub_v1_schema_proto_rawDescData
  1495  }
  1496  
  1497  var file_google_pubsub_v1_schema_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
  1498  var file_google_pubsub_v1_schema_proto_msgTypes = make([]protoimpl.MessageInfo, 15)
  1499  var file_google_pubsub_v1_schema_proto_goTypes = []interface{}{
  1500  	(SchemaView)(0),                     // 0: google.pubsub.v1.SchemaView
  1501  	(Encoding)(0),                       // 1: google.pubsub.v1.Encoding
  1502  	(Schema_Type)(0),                    // 2: google.pubsub.v1.Schema.Type
  1503  	(*Schema)(nil),                      // 3: google.pubsub.v1.Schema
  1504  	(*CreateSchemaRequest)(nil),         // 4: google.pubsub.v1.CreateSchemaRequest
  1505  	(*GetSchemaRequest)(nil),            // 5: google.pubsub.v1.GetSchemaRequest
  1506  	(*ListSchemasRequest)(nil),          // 6: google.pubsub.v1.ListSchemasRequest
  1507  	(*ListSchemasResponse)(nil),         // 7: google.pubsub.v1.ListSchemasResponse
  1508  	(*ListSchemaRevisionsRequest)(nil),  // 8: google.pubsub.v1.ListSchemaRevisionsRequest
  1509  	(*ListSchemaRevisionsResponse)(nil), // 9: google.pubsub.v1.ListSchemaRevisionsResponse
  1510  	(*CommitSchemaRequest)(nil),         // 10: google.pubsub.v1.CommitSchemaRequest
  1511  	(*RollbackSchemaRequest)(nil),       // 11: google.pubsub.v1.RollbackSchemaRequest
  1512  	(*DeleteSchemaRevisionRequest)(nil), // 12: google.pubsub.v1.DeleteSchemaRevisionRequest
  1513  	(*DeleteSchemaRequest)(nil),         // 13: google.pubsub.v1.DeleteSchemaRequest
  1514  	(*ValidateSchemaRequest)(nil),       // 14: google.pubsub.v1.ValidateSchemaRequest
  1515  	(*ValidateSchemaResponse)(nil),      // 15: google.pubsub.v1.ValidateSchemaResponse
  1516  	(*ValidateMessageRequest)(nil),      // 16: google.pubsub.v1.ValidateMessageRequest
  1517  	(*ValidateMessageResponse)(nil),     // 17: google.pubsub.v1.ValidateMessageResponse
  1518  	(*timestamppb.Timestamp)(nil),       // 18: google.protobuf.Timestamp
  1519  	(*emptypb.Empty)(nil),               // 19: google.protobuf.Empty
  1520  }
  1521  var file_google_pubsub_v1_schema_proto_depIdxs = []int32{
  1522  	2,  // 0: google.pubsub.v1.Schema.type:type_name -> google.pubsub.v1.Schema.Type
  1523  	18, // 1: google.pubsub.v1.Schema.revision_create_time:type_name -> google.protobuf.Timestamp
  1524  	3,  // 2: google.pubsub.v1.CreateSchemaRequest.schema:type_name -> google.pubsub.v1.Schema
  1525  	0,  // 3: google.pubsub.v1.GetSchemaRequest.view:type_name -> google.pubsub.v1.SchemaView
  1526  	0,  // 4: google.pubsub.v1.ListSchemasRequest.view:type_name -> google.pubsub.v1.SchemaView
  1527  	3,  // 5: google.pubsub.v1.ListSchemasResponse.schemas:type_name -> google.pubsub.v1.Schema
  1528  	0,  // 6: google.pubsub.v1.ListSchemaRevisionsRequest.view:type_name -> google.pubsub.v1.SchemaView
  1529  	3,  // 7: google.pubsub.v1.ListSchemaRevisionsResponse.schemas:type_name -> google.pubsub.v1.Schema
  1530  	3,  // 8: google.pubsub.v1.CommitSchemaRequest.schema:type_name -> google.pubsub.v1.Schema
  1531  	3,  // 9: google.pubsub.v1.ValidateSchemaRequest.schema:type_name -> google.pubsub.v1.Schema
  1532  	3,  // 10: google.pubsub.v1.ValidateMessageRequest.schema:type_name -> google.pubsub.v1.Schema
  1533  	1,  // 11: google.pubsub.v1.ValidateMessageRequest.encoding:type_name -> google.pubsub.v1.Encoding
  1534  	4,  // 12: google.pubsub.v1.SchemaService.CreateSchema:input_type -> google.pubsub.v1.CreateSchemaRequest
  1535  	5,  // 13: google.pubsub.v1.SchemaService.GetSchema:input_type -> google.pubsub.v1.GetSchemaRequest
  1536  	6,  // 14: google.pubsub.v1.SchemaService.ListSchemas:input_type -> google.pubsub.v1.ListSchemasRequest
  1537  	8,  // 15: google.pubsub.v1.SchemaService.ListSchemaRevisions:input_type -> google.pubsub.v1.ListSchemaRevisionsRequest
  1538  	10, // 16: google.pubsub.v1.SchemaService.CommitSchema:input_type -> google.pubsub.v1.CommitSchemaRequest
  1539  	11, // 17: google.pubsub.v1.SchemaService.RollbackSchema:input_type -> google.pubsub.v1.RollbackSchemaRequest
  1540  	12, // 18: google.pubsub.v1.SchemaService.DeleteSchemaRevision:input_type -> google.pubsub.v1.DeleteSchemaRevisionRequest
  1541  	13, // 19: google.pubsub.v1.SchemaService.DeleteSchema:input_type -> google.pubsub.v1.DeleteSchemaRequest
  1542  	14, // 20: google.pubsub.v1.SchemaService.ValidateSchema:input_type -> google.pubsub.v1.ValidateSchemaRequest
  1543  	16, // 21: google.pubsub.v1.SchemaService.ValidateMessage:input_type -> google.pubsub.v1.ValidateMessageRequest
  1544  	3,  // 22: google.pubsub.v1.SchemaService.CreateSchema:output_type -> google.pubsub.v1.Schema
  1545  	3,  // 23: google.pubsub.v1.SchemaService.GetSchema:output_type -> google.pubsub.v1.Schema
  1546  	7,  // 24: google.pubsub.v1.SchemaService.ListSchemas:output_type -> google.pubsub.v1.ListSchemasResponse
  1547  	9,  // 25: google.pubsub.v1.SchemaService.ListSchemaRevisions:output_type -> google.pubsub.v1.ListSchemaRevisionsResponse
  1548  	3,  // 26: google.pubsub.v1.SchemaService.CommitSchema:output_type -> google.pubsub.v1.Schema
  1549  	3,  // 27: google.pubsub.v1.SchemaService.RollbackSchema:output_type -> google.pubsub.v1.Schema
  1550  	3,  // 28: google.pubsub.v1.SchemaService.DeleteSchemaRevision:output_type -> google.pubsub.v1.Schema
  1551  	19, // 29: google.pubsub.v1.SchemaService.DeleteSchema:output_type -> google.protobuf.Empty
  1552  	15, // 30: google.pubsub.v1.SchemaService.ValidateSchema:output_type -> google.pubsub.v1.ValidateSchemaResponse
  1553  	17, // 31: google.pubsub.v1.SchemaService.ValidateMessage:output_type -> google.pubsub.v1.ValidateMessageResponse
  1554  	22, // [22:32] is the sub-list for method output_type
  1555  	12, // [12:22] is the sub-list for method input_type
  1556  	12, // [12:12] is the sub-list for extension type_name
  1557  	12, // [12:12] is the sub-list for extension extendee
  1558  	0,  // [0:12] is the sub-list for field type_name
  1559  }
  1560  
  1561  func init() { file_google_pubsub_v1_schema_proto_init() }
  1562  func file_google_pubsub_v1_schema_proto_init() {
  1563  	if File_google_pubsub_v1_schema_proto != nil {
  1564  		return
  1565  	}
  1566  	if !protoimpl.UnsafeEnabled {
  1567  		file_google_pubsub_v1_schema_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  1568  			switch v := v.(*Schema); i {
  1569  			case 0:
  1570  				return &v.state
  1571  			case 1:
  1572  				return &v.sizeCache
  1573  			case 2:
  1574  				return &v.unknownFields
  1575  			default:
  1576  				return nil
  1577  			}
  1578  		}
  1579  		file_google_pubsub_v1_schema_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  1580  			switch v := v.(*CreateSchemaRequest); i {
  1581  			case 0:
  1582  				return &v.state
  1583  			case 1:
  1584  				return &v.sizeCache
  1585  			case 2:
  1586  				return &v.unknownFields
  1587  			default:
  1588  				return nil
  1589  			}
  1590  		}
  1591  		file_google_pubsub_v1_schema_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  1592  			switch v := v.(*GetSchemaRequest); i {
  1593  			case 0:
  1594  				return &v.state
  1595  			case 1:
  1596  				return &v.sizeCache
  1597  			case 2:
  1598  				return &v.unknownFields
  1599  			default:
  1600  				return nil
  1601  			}
  1602  		}
  1603  		file_google_pubsub_v1_schema_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  1604  			switch v := v.(*ListSchemasRequest); i {
  1605  			case 0:
  1606  				return &v.state
  1607  			case 1:
  1608  				return &v.sizeCache
  1609  			case 2:
  1610  				return &v.unknownFields
  1611  			default:
  1612  				return nil
  1613  			}
  1614  		}
  1615  		file_google_pubsub_v1_schema_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  1616  			switch v := v.(*ListSchemasResponse); i {
  1617  			case 0:
  1618  				return &v.state
  1619  			case 1:
  1620  				return &v.sizeCache
  1621  			case 2:
  1622  				return &v.unknownFields
  1623  			default:
  1624  				return nil
  1625  			}
  1626  		}
  1627  		file_google_pubsub_v1_schema_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  1628  			switch v := v.(*ListSchemaRevisionsRequest); i {
  1629  			case 0:
  1630  				return &v.state
  1631  			case 1:
  1632  				return &v.sizeCache
  1633  			case 2:
  1634  				return &v.unknownFields
  1635  			default:
  1636  				return nil
  1637  			}
  1638  		}
  1639  		file_google_pubsub_v1_schema_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  1640  			switch v := v.(*ListSchemaRevisionsResponse); i {
  1641  			case 0:
  1642  				return &v.state
  1643  			case 1:
  1644  				return &v.sizeCache
  1645  			case 2:
  1646  				return &v.unknownFields
  1647  			default:
  1648  				return nil
  1649  			}
  1650  		}
  1651  		file_google_pubsub_v1_schema_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  1652  			switch v := v.(*CommitSchemaRequest); i {
  1653  			case 0:
  1654  				return &v.state
  1655  			case 1:
  1656  				return &v.sizeCache
  1657  			case 2:
  1658  				return &v.unknownFields
  1659  			default:
  1660  				return nil
  1661  			}
  1662  		}
  1663  		file_google_pubsub_v1_schema_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  1664  			switch v := v.(*RollbackSchemaRequest); i {
  1665  			case 0:
  1666  				return &v.state
  1667  			case 1:
  1668  				return &v.sizeCache
  1669  			case 2:
  1670  				return &v.unknownFields
  1671  			default:
  1672  				return nil
  1673  			}
  1674  		}
  1675  		file_google_pubsub_v1_schema_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  1676  			switch v := v.(*DeleteSchemaRevisionRequest); i {
  1677  			case 0:
  1678  				return &v.state
  1679  			case 1:
  1680  				return &v.sizeCache
  1681  			case 2:
  1682  				return &v.unknownFields
  1683  			default:
  1684  				return nil
  1685  			}
  1686  		}
  1687  		file_google_pubsub_v1_schema_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  1688  			switch v := v.(*DeleteSchemaRequest); i {
  1689  			case 0:
  1690  				return &v.state
  1691  			case 1:
  1692  				return &v.sizeCache
  1693  			case 2:
  1694  				return &v.unknownFields
  1695  			default:
  1696  				return nil
  1697  			}
  1698  		}
  1699  		file_google_pubsub_v1_schema_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
  1700  			switch v := v.(*ValidateSchemaRequest); i {
  1701  			case 0:
  1702  				return &v.state
  1703  			case 1:
  1704  				return &v.sizeCache
  1705  			case 2:
  1706  				return &v.unknownFields
  1707  			default:
  1708  				return nil
  1709  			}
  1710  		}
  1711  		file_google_pubsub_v1_schema_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
  1712  			switch v := v.(*ValidateSchemaResponse); i {
  1713  			case 0:
  1714  				return &v.state
  1715  			case 1:
  1716  				return &v.sizeCache
  1717  			case 2:
  1718  				return &v.unknownFields
  1719  			default:
  1720  				return nil
  1721  			}
  1722  		}
  1723  		file_google_pubsub_v1_schema_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
  1724  			switch v := v.(*ValidateMessageRequest); i {
  1725  			case 0:
  1726  				return &v.state
  1727  			case 1:
  1728  				return &v.sizeCache
  1729  			case 2:
  1730  				return &v.unknownFields
  1731  			default:
  1732  				return nil
  1733  			}
  1734  		}
  1735  		file_google_pubsub_v1_schema_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
  1736  			switch v := v.(*ValidateMessageResponse); i {
  1737  			case 0:
  1738  				return &v.state
  1739  			case 1:
  1740  				return &v.sizeCache
  1741  			case 2:
  1742  				return &v.unknownFields
  1743  			default:
  1744  				return nil
  1745  			}
  1746  		}
  1747  	}
  1748  	file_google_pubsub_v1_schema_proto_msgTypes[13].OneofWrappers = []interface{}{
  1749  		(*ValidateMessageRequest_Name)(nil),
  1750  		(*ValidateMessageRequest_Schema)(nil),
  1751  	}
  1752  	type x struct{}
  1753  	out := protoimpl.TypeBuilder{
  1754  		File: protoimpl.DescBuilder{
  1755  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  1756  			RawDescriptor: file_google_pubsub_v1_schema_proto_rawDesc,
  1757  			NumEnums:      3,
  1758  			NumMessages:   15,
  1759  			NumExtensions: 0,
  1760  			NumServices:   1,
  1761  		},
  1762  		GoTypes:           file_google_pubsub_v1_schema_proto_goTypes,
  1763  		DependencyIndexes: file_google_pubsub_v1_schema_proto_depIdxs,
  1764  		EnumInfos:         file_google_pubsub_v1_schema_proto_enumTypes,
  1765  		MessageInfos:      file_google_pubsub_v1_schema_proto_msgTypes,
  1766  	}.Build()
  1767  	File_google_pubsub_v1_schema_proto = out.File
  1768  	file_google_pubsub_v1_schema_proto_rawDesc = nil
  1769  	file_google_pubsub_v1_schema_proto_goTypes = nil
  1770  	file_google_pubsub_v1_schema_proto_depIdxs = nil
  1771  }
  1772  
  1773  // Reference imports to suppress errors if they are not otherwise used.
  1774  var _ context.Context
  1775  var _ grpc.ClientConnInterface
  1776  
  1777  // This is a compile-time assertion to ensure that this generated file
  1778  // is compatible with the grpc package it is being compiled against.
  1779  const _ = grpc.SupportPackageIsVersion6
  1780  
  1781  // SchemaServiceClient is the client API for SchemaService service.
  1782  //
  1783  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  1784  type SchemaServiceClient interface {
  1785  	// Creates a schema.
  1786  	CreateSchema(ctx context.Context, in *CreateSchemaRequest, opts ...grpc.CallOption) (*Schema, error)
  1787  	// Gets a schema.
  1788  	GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*Schema, error)
  1789  	// Lists schemas in a project.
  1790  	ListSchemas(ctx context.Context, in *ListSchemasRequest, opts ...grpc.CallOption) (*ListSchemasResponse, error)
  1791  	// Lists all schema revisions for the named schema.
  1792  	ListSchemaRevisions(ctx context.Context, in *ListSchemaRevisionsRequest, opts ...grpc.CallOption) (*ListSchemaRevisionsResponse, error)
  1793  	// Commits a new schema revision to an existing schema.
  1794  	CommitSchema(ctx context.Context, in *CommitSchemaRequest, opts ...grpc.CallOption) (*Schema, error)
  1795  	// Creates a new schema revision that is a copy of the provided revision_id.
  1796  	RollbackSchema(ctx context.Context, in *RollbackSchemaRequest, opts ...grpc.CallOption) (*Schema, error)
  1797  	// Deletes a specific schema revision.
  1798  	DeleteSchemaRevision(ctx context.Context, in *DeleteSchemaRevisionRequest, opts ...grpc.CallOption) (*Schema, error)
  1799  	// Deletes a schema.
  1800  	DeleteSchema(ctx context.Context, in *DeleteSchemaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
  1801  	// Validates a schema.
  1802  	ValidateSchema(ctx context.Context, in *ValidateSchemaRequest, opts ...grpc.CallOption) (*ValidateSchemaResponse, error)
  1803  	// Validates a message against a schema.
  1804  	ValidateMessage(ctx context.Context, in *ValidateMessageRequest, opts ...grpc.CallOption) (*ValidateMessageResponse, error)
  1805  }
  1806  
  1807  type schemaServiceClient struct {
  1808  	cc grpc.ClientConnInterface
  1809  }
  1810  
  1811  func NewSchemaServiceClient(cc grpc.ClientConnInterface) SchemaServiceClient {
  1812  	return &schemaServiceClient{cc}
  1813  }
  1814  
  1815  func (c *schemaServiceClient) CreateSchema(ctx context.Context, in *CreateSchemaRequest, opts ...grpc.CallOption) (*Schema, error) {
  1816  	out := new(Schema)
  1817  	err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/CreateSchema", in, out, opts...)
  1818  	if err != nil {
  1819  		return nil, err
  1820  	}
  1821  	return out, nil
  1822  }
  1823  
  1824  func (c *schemaServiceClient) GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*Schema, error) {
  1825  	out := new(Schema)
  1826  	err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/GetSchema", in, out, opts...)
  1827  	if err != nil {
  1828  		return nil, err
  1829  	}
  1830  	return out, nil
  1831  }
  1832  
  1833  func (c *schemaServiceClient) ListSchemas(ctx context.Context, in *ListSchemasRequest, opts ...grpc.CallOption) (*ListSchemasResponse, error) {
  1834  	out := new(ListSchemasResponse)
  1835  	err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/ListSchemas", in, out, opts...)
  1836  	if err != nil {
  1837  		return nil, err
  1838  	}
  1839  	return out, nil
  1840  }
  1841  
  1842  func (c *schemaServiceClient) ListSchemaRevisions(ctx context.Context, in *ListSchemaRevisionsRequest, opts ...grpc.CallOption) (*ListSchemaRevisionsResponse, error) {
  1843  	out := new(ListSchemaRevisionsResponse)
  1844  	err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/ListSchemaRevisions", in, out, opts...)
  1845  	if err != nil {
  1846  		return nil, err
  1847  	}
  1848  	return out, nil
  1849  }
  1850  
  1851  func (c *schemaServiceClient) CommitSchema(ctx context.Context, in *CommitSchemaRequest, opts ...grpc.CallOption) (*Schema, error) {
  1852  	out := new(Schema)
  1853  	err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/CommitSchema", in, out, opts...)
  1854  	if err != nil {
  1855  		return nil, err
  1856  	}
  1857  	return out, nil
  1858  }
  1859  
  1860  func (c *schemaServiceClient) RollbackSchema(ctx context.Context, in *RollbackSchemaRequest, opts ...grpc.CallOption) (*Schema, error) {
  1861  	out := new(Schema)
  1862  	err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/RollbackSchema", in, out, opts...)
  1863  	if err != nil {
  1864  		return nil, err
  1865  	}
  1866  	return out, nil
  1867  }
  1868  
  1869  func (c *schemaServiceClient) DeleteSchemaRevision(ctx context.Context, in *DeleteSchemaRevisionRequest, opts ...grpc.CallOption) (*Schema, error) {
  1870  	out := new(Schema)
  1871  	err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/DeleteSchemaRevision", in, out, opts...)
  1872  	if err != nil {
  1873  		return nil, err
  1874  	}
  1875  	return out, nil
  1876  }
  1877  
  1878  func (c *schemaServiceClient) DeleteSchema(ctx context.Context, in *DeleteSchemaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  1879  	out := new(emptypb.Empty)
  1880  	err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/DeleteSchema", in, out, opts...)
  1881  	if err != nil {
  1882  		return nil, err
  1883  	}
  1884  	return out, nil
  1885  }
  1886  
  1887  func (c *schemaServiceClient) ValidateSchema(ctx context.Context, in *ValidateSchemaRequest, opts ...grpc.CallOption) (*ValidateSchemaResponse, error) {
  1888  	out := new(ValidateSchemaResponse)
  1889  	err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/ValidateSchema", in, out, opts...)
  1890  	if err != nil {
  1891  		return nil, err
  1892  	}
  1893  	return out, nil
  1894  }
  1895  
  1896  func (c *schemaServiceClient) ValidateMessage(ctx context.Context, in *ValidateMessageRequest, opts ...grpc.CallOption) (*ValidateMessageResponse, error) {
  1897  	out := new(ValidateMessageResponse)
  1898  	err := c.cc.Invoke(ctx, "/google.pubsub.v1.SchemaService/ValidateMessage", in, out, opts...)
  1899  	if err != nil {
  1900  		return nil, err
  1901  	}
  1902  	return out, nil
  1903  }
  1904  
  1905  // SchemaServiceServer is the server API for SchemaService service.
  1906  type SchemaServiceServer interface {
  1907  	// Creates a schema.
  1908  	CreateSchema(context.Context, *CreateSchemaRequest) (*Schema, error)
  1909  	// Gets a schema.
  1910  	GetSchema(context.Context, *GetSchemaRequest) (*Schema, error)
  1911  	// Lists schemas in a project.
  1912  	ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error)
  1913  	// Lists all schema revisions for the named schema.
  1914  	ListSchemaRevisions(context.Context, *ListSchemaRevisionsRequest) (*ListSchemaRevisionsResponse, error)
  1915  	// Commits a new schema revision to an existing schema.
  1916  	CommitSchema(context.Context, *CommitSchemaRequest) (*Schema, error)
  1917  	// Creates a new schema revision that is a copy of the provided revision_id.
  1918  	RollbackSchema(context.Context, *RollbackSchemaRequest) (*Schema, error)
  1919  	// Deletes a specific schema revision.
  1920  	DeleteSchemaRevision(context.Context, *DeleteSchemaRevisionRequest) (*Schema, error)
  1921  	// Deletes a schema.
  1922  	DeleteSchema(context.Context, *DeleteSchemaRequest) (*emptypb.Empty, error)
  1923  	// Validates a schema.
  1924  	ValidateSchema(context.Context, *ValidateSchemaRequest) (*ValidateSchemaResponse, error)
  1925  	// Validates a message against a schema.
  1926  	ValidateMessage(context.Context, *ValidateMessageRequest) (*ValidateMessageResponse, error)
  1927  }
  1928  
  1929  // UnimplementedSchemaServiceServer can be embedded to have forward compatible implementations.
  1930  type UnimplementedSchemaServiceServer struct {
  1931  }
  1932  
  1933  func (*UnimplementedSchemaServiceServer) CreateSchema(context.Context, *CreateSchemaRequest) (*Schema, error) {
  1934  	return nil, status.Errorf(codes.Unimplemented, "method CreateSchema not implemented")
  1935  }
  1936  func (*UnimplementedSchemaServiceServer) GetSchema(context.Context, *GetSchemaRequest) (*Schema, error) {
  1937  	return nil, status.Errorf(codes.Unimplemented, "method GetSchema not implemented")
  1938  }
  1939  func (*UnimplementedSchemaServiceServer) ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error) {
  1940  	return nil, status.Errorf(codes.Unimplemented, "method ListSchemas not implemented")
  1941  }
  1942  func (*UnimplementedSchemaServiceServer) ListSchemaRevisions(context.Context, *ListSchemaRevisionsRequest) (*ListSchemaRevisionsResponse, error) {
  1943  	return nil, status.Errorf(codes.Unimplemented, "method ListSchemaRevisions not implemented")
  1944  }
  1945  func (*UnimplementedSchemaServiceServer) CommitSchema(context.Context, *CommitSchemaRequest) (*Schema, error) {
  1946  	return nil, status.Errorf(codes.Unimplemented, "method CommitSchema not implemented")
  1947  }
  1948  func (*UnimplementedSchemaServiceServer) RollbackSchema(context.Context, *RollbackSchemaRequest) (*Schema, error) {
  1949  	return nil, status.Errorf(codes.Unimplemented, "method RollbackSchema not implemented")
  1950  }
  1951  func (*UnimplementedSchemaServiceServer) DeleteSchemaRevision(context.Context, *DeleteSchemaRevisionRequest) (*Schema, error) {
  1952  	return nil, status.Errorf(codes.Unimplemented, "method DeleteSchemaRevision not implemented")
  1953  }
  1954  func (*UnimplementedSchemaServiceServer) DeleteSchema(context.Context, *DeleteSchemaRequest) (*emptypb.Empty, error) {
  1955  	return nil, status.Errorf(codes.Unimplemented, "method DeleteSchema not implemented")
  1956  }
  1957  func (*UnimplementedSchemaServiceServer) ValidateSchema(context.Context, *ValidateSchemaRequest) (*ValidateSchemaResponse, error) {
  1958  	return nil, status.Errorf(codes.Unimplemented, "method ValidateSchema not implemented")
  1959  }
  1960  func (*UnimplementedSchemaServiceServer) ValidateMessage(context.Context, *ValidateMessageRequest) (*ValidateMessageResponse, error) {
  1961  	return nil, status.Errorf(codes.Unimplemented, "method ValidateMessage not implemented")
  1962  }
  1963  
  1964  func RegisterSchemaServiceServer(s *grpc.Server, srv SchemaServiceServer) {
  1965  	s.RegisterService(&_SchemaService_serviceDesc, srv)
  1966  }
  1967  
  1968  func _SchemaService_CreateSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1969  	in := new(CreateSchemaRequest)
  1970  	if err := dec(in); err != nil {
  1971  		return nil, err
  1972  	}
  1973  	if interceptor == nil {
  1974  		return srv.(SchemaServiceServer).CreateSchema(ctx, in)
  1975  	}
  1976  	info := &grpc.UnaryServerInfo{
  1977  		Server:     srv,
  1978  		FullMethod: "/google.pubsub.v1.SchemaService/CreateSchema",
  1979  	}
  1980  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1981  		return srv.(SchemaServiceServer).CreateSchema(ctx, req.(*CreateSchemaRequest))
  1982  	}
  1983  	return interceptor(ctx, in, info, handler)
  1984  }
  1985  
  1986  func _SchemaService_GetSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1987  	in := new(GetSchemaRequest)
  1988  	if err := dec(in); err != nil {
  1989  		return nil, err
  1990  	}
  1991  	if interceptor == nil {
  1992  		return srv.(SchemaServiceServer).GetSchema(ctx, in)
  1993  	}
  1994  	info := &grpc.UnaryServerInfo{
  1995  		Server:     srv,
  1996  		FullMethod: "/google.pubsub.v1.SchemaService/GetSchema",
  1997  	}
  1998  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1999  		return srv.(SchemaServiceServer).GetSchema(ctx, req.(*GetSchemaRequest))
  2000  	}
  2001  	return interceptor(ctx, in, info, handler)
  2002  }
  2003  
  2004  func _SchemaService_ListSchemas_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2005  	in := new(ListSchemasRequest)
  2006  	if err := dec(in); err != nil {
  2007  		return nil, err
  2008  	}
  2009  	if interceptor == nil {
  2010  		return srv.(SchemaServiceServer).ListSchemas(ctx, in)
  2011  	}
  2012  	info := &grpc.UnaryServerInfo{
  2013  		Server:     srv,
  2014  		FullMethod: "/google.pubsub.v1.SchemaService/ListSchemas",
  2015  	}
  2016  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2017  		return srv.(SchemaServiceServer).ListSchemas(ctx, req.(*ListSchemasRequest))
  2018  	}
  2019  	return interceptor(ctx, in, info, handler)
  2020  }
  2021  
  2022  func _SchemaService_ListSchemaRevisions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2023  	in := new(ListSchemaRevisionsRequest)
  2024  	if err := dec(in); err != nil {
  2025  		return nil, err
  2026  	}
  2027  	if interceptor == nil {
  2028  		return srv.(SchemaServiceServer).ListSchemaRevisions(ctx, in)
  2029  	}
  2030  	info := &grpc.UnaryServerInfo{
  2031  		Server:     srv,
  2032  		FullMethod: "/google.pubsub.v1.SchemaService/ListSchemaRevisions",
  2033  	}
  2034  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2035  		return srv.(SchemaServiceServer).ListSchemaRevisions(ctx, req.(*ListSchemaRevisionsRequest))
  2036  	}
  2037  	return interceptor(ctx, in, info, handler)
  2038  }
  2039  
  2040  func _SchemaService_CommitSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2041  	in := new(CommitSchemaRequest)
  2042  	if err := dec(in); err != nil {
  2043  		return nil, err
  2044  	}
  2045  	if interceptor == nil {
  2046  		return srv.(SchemaServiceServer).CommitSchema(ctx, in)
  2047  	}
  2048  	info := &grpc.UnaryServerInfo{
  2049  		Server:     srv,
  2050  		FullMethod: "/google.pubsub.v1.SchemaService/CommitSchema",
  2051  	}
  2052  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2053  		return srv.(SchemaServiceServer).CommitSchema(ctx, req.(*CommitSchemaRequest))
  2054  	}
  2055  	return interceptor(ctx, in, info, handler)
  2056  }
  2057  
  2058  func _SchemaService_RollbackSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2059  	in := new(RollbackSchemaRequest)
  2060  	if err := dec(in); err != nil {
  2061  		return nil, err
  2062  	}
  2063  	if interceptor == nil {
  2064  		return srv.(SchemaServiceServer).RollbackSchema(ctx, in)
  2065  	}
  2066  	info := &grpc.UnaryServerInfo{
  2067  		Server:     srv,
  2068  		FullMethod: "/google.pubsub.v1.SchemaService/RollbackSchema",
  2069  	}
  2070  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2071  		return srv.(SchemaServiceServer).RollbackSchema(ctx, req.(*RollbackSchemaRequest))
  2072  	}
  2073  	return interceptor(ctx, in, info, handler)
  2074  }
  2075  
  2076  func _SchemaService_DeleteSchemaRevision_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2077  	in := new(DeleteSchemaRevisionRequest)
  2078  	if err := dec(in); err != nil {
  2079  		return nil, err
  2080  	}
  2081  	if interceptor == nil {
  2082  		return srv.(SchemaServiceServer).DeleteSchemaRevision(ctx, in)
  2083  	}
  2084  	info := &grpc.UnaryServerInfo{
  2085  		Server:     srv,
  2086  		FullMethod: "/google.pubsub.v1.SchemaService/DeleteSchemaRevision",
  2087  	}
  2088  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2089  		return srv.(SchemaServiceServer).DeleteSchemaRevision(ctx, req.(*DeleteSchemaRevisionRequest))
  2090  	}
  2091  	return interceptor(ctx, in, info, handler)
  2092  }
  2093  
  2094  func _SchemaService_DeleteSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2095  	in := new(DeleteSchemaRequest)
  2096  	if err := dec(in); err != nil {
  2097  		return nil, err
  2098  	}
  2099  	if interceptor == nil {
  2100  		return srv.(SchemaServiceServer).DeleteSchema(ctx, in)
  2101  	}
  2102  	info := &grpc.UnaryServerInfo{
  2103  		Server:     srv,
  2104  		FullMethod: "/google.pubsub.v1.SchemaService/DeleteSchema",
  2105  	}
  2106  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2107  		return srv.(SchemaServiceServer).DeleteSchema(ctx, req.(*DeleteSchemaRequest))
  2108  	}
  2109  	return interceptor(ctx, in, info, handler)
  2110  }
  2111  
  2112  func _SchemaService_ValidateSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2113  	in := new(ValidateSchemaRequest)
  2114  	if err := dec(in); err != nil {
  2115  		return nil, err
  2116  	}
  2117  	if interceptor == nil {
  2118  		return srv.(SchemaServiceServer).ValidateSchema(ctx, in)
  2119  	}
  2120  	info := &grpc.UnaryServerInfo{
  2121  		Server:     srv,
  2122  		FullMethod: "/google.pubsub.v1.SchemaService/ValidateSchema",
  2123  	}
  2124  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2125  		return srv.(SchemaServiceServer).ValidateSchema(ctx, req.(*ValidateSchemaRequest))
  2126  	}
  2127  	return interceptor(ctx, in, info, handler)
  2128  }
  2129  
  2130  func _SchemaService_ValidateMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2131  	in := new(ValidateMessageRequest)
  2132  	if err := dec(in); err != nil {
  2133  		return nil, err
  2134  	}
  2135  	if interceptor == nil {
  2136  		return srv.(SchemaServiceServer).ValidateMessage(ctx, in)
  2137  	}
  2138  	info := &grpc.UnaryServerInfo{
  2139  		Server:     srv,
  2140  		FullMethod: "/google.pubsub.v1.SchemaService/ValidateMessage",
  2141  	}
  2142  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2143  		return srv.(SchemaServiceServer).ValidateMessage(ctx, req.(*ValidateMessageRequest))
  2144  	}
  2145  	return interceptor(ctx, in, info, handler)
  2146  }
  2147  
  2148  var _SchemaService_serviceDesc = grpc.ServiceDesc{
  2149  	ServiceName: "google.pubsub.v1.SchemaService",
  2150  	HandlerType: (*SchemaServiceServer)(nil),
  2151  	Methods: []grpc.MethodDesc{
  2152  		{
  2153  			MethodName: "CreateSchema",
  2154  			Handler:    _SchemaService_CreateSchema_Handler,
  2155  		},
  2156  		{
  2157  			MethodName: "GetSchema",
  2158  			Handler:    _SchemaService_GetSchema_Handler,
  2159  		},
  2160  		{
  2161  			MethodName: "ListSchemas",
  2162  			Handler:    _SchemaService_ListSchemas_Handler,
  2163  		},
  2164  		{
  2165  			MethodName: "ListSchemaRevisions",
  2166  			Handler:    _SchemaService_ListSchemaRevisions_Handler,
  2167  		},
  2168  		{
  2169  			MethodName: "CommitSchema",
  2170  			Handler:    _SchemaService_CommitSchema_Handler,
  2171  		},
  2172  		{
  2173  			MethodName: "RollbackSchema",
  2174  			Handler:    _SchemaService_RollbackSchema_Handler,
  2175  		},
  2176  		{
  2177  			MethodName: "DeleteSchemaRevision",
  2178  			Handler:    _SchemaService_DeleteSchemaRevision_Handler,
  2179  		},
  2180  		{
  2181  			MethodName: "DeleteSchema",
  2182  			Handler:    _SchemaService_DeleteSchema_Handler,
  2183  		},
  2184  		{
  2185  			MethodName: "ValidateSchema",
  2186  			Handler:    _SchemaService_ValidateSchema_Handler,
  2187  		},
  2188  		{
  2189  			MethodName: "ValidateMessage",
  2190  			Handler:    _SchemaService_ValidateMessage_Handler,
  2191  		},
  2192  	},
  2193  	Streams:  []grpc.StreamDesc{},
  2194  	Metadata: "google/pubsub/v1/schema.proto",
  2195  }
  2196  

View as plain text