pubsub.pb.go

Documentation: cloud.google.com/go/pubsub/internal/benchwrapper/proto

     1  // Copyright 2019 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.31.0
    18  // 	protoc        v4.25.3
    19  // source: pubsub.proto
    20  
    21  package pubsub_bench
    22  
    23  import (
    24  	reflect "reflect"
    25  	sync "sync"
    26  
    27  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    28  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    29  )
    30  
    31  const (
    32  	// Verify that this generated code is sufficiently up-to-date.
    33  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    34  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    35  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    36  )
    37  
    38  type PubsubRecv struct {
    39  	state         protoimpl.MessageState
    40  	sizeCache     protoimpl.SizeCache
    41  	unknownFields protoimpl.UnknownFields
    42  
    43  	// The subscription identifier corresponding to number of messages sent.
    44  	SubName string `protobuf:"bytes,1,opt,name=sub_name,json=subName,proto3" json:"sub_name,omitempty"`
    45  }
    46  
    47  func (x *PubsubRecv) Reset() {
    48  	*x = PubsubRecv{}
    49  	if protoimpl.UnsafeEnabled {
    50  		mi := &file_pubsub_proto_msgTypes[0]
    51  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    52  		ms.StoreMessageInfo(mi)
    53  	}
    54  }
    55  
    56  func (x *PubsubRecv) String() string {
    57  	return protoimpl.X.MessageStringOf(x)
    58  }
    59  
    60  func (*PubsubRecv) ProtoMessage() {}
    61  
    62  func (x *PubsubRecv) ProtoReflect() protoreflect.Message {
    63  	mi := &file_pubsub_proto_msgTypes[0]
    64  	if protoimpl.UnsafeEnabled && x != nil {
    65  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    66  		if ms.LoadMessageInfo() == nil {
    67  			ms.StoreMessageInfo(mi)
    68  		}
    69  		return ms
    70  	}
    71  	return mi.MessageOf(x)
    72  }
    73  
    74  // Deprecated: Use PubsubRecv.ProtoReflect.Descriptor instead.
    75  func (*PubsubRecv) Descriptor() ([]byte, []int) {
    76  	return file_pubsub_proto_rawDescGZIP(), []int{0}
    77  }
    78  
    79  func (x *PubsubRecv) GetSubName() string {
    80  	if x != nil {
    81  		return x.SubName
    82  	}
    83  	return ""
    84  }
    85  
    86  // TODO(deklerk): Replace with Google's canonical Empty.
    87  type EmptyResponse struct {
    88  	state         protoimpl.MessageState
    89  	sizeCache     protoimpl.SizeCache
    90  	unknownFields protoimpl.UnknownFields
    91  }
    92  
    93  func (x *EmptyResponse) Reset() {
    94  	*x = EmptyResponse{}
    95  	if protoimpl.UnsafeEnabled {
    96  		mi := &file_pubsub_proto_msgTypes[1]
    97  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    98  		ms.StoreMessageInfo(mi)
    99  	}
   100  }
   101  
   102  func (x *EmptyResponse) String() string {
   103  	return protoimpl.X.MessageStringOf(x)
   104  }
   105  
   106  func (*EmptyResponse) ProtoMessage() {}
   107  
   108  func (x *EmptyResponse) ProtoReflect() protoreflect.Message {
   109  	mi := &file_pubsub_proto_msgTypes[1]
   110  	if protoimpl.UnsafeEnabled && x != nil {
   111  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   112  		if ms.LoadMessageInfo() == nil {
   113  			ms.StoreMessageInfo(mi)
   114  		}
   115  		return ms
   116  	}
   117  	return mi.MessageOf(x)
   118  }
   119  
   120  // Deprecated: Use EmptyResponse.ProtoReflect.Descriptor instead.
   121  func (*EmptyResponse) Descriptor() ([]byte, []int) {
   122  	return file_pubsub_proto_rawDescGZIP(), []int{1}
   123  }
   124  
   125  var File_pubsub_proto protoreflect.FileDescriptor
   126  
   127  var file_pubsub_proto_rawDesc = []byte{
   128  	0x0a, 0x0c, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0c,
   129  	0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x5f, 0x62, 0x65, 0x6e, 0x63, 0x68, 0x22, 0x27, 0x0a, 0x0a,
   130  	0x50, 0x75, 0x62, 0x73, 0x75, 0x62, 0x52, 0x65, 0x63, 0x76, 0x12, 0x19, 0x0a, 0x08, 0x73, 0x75,
   131  	0x62, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, 0x75,
   132  	0x62, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x0f, 0x0a, 0x0d, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x52, 0x65,
   133  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x32, 0x55, 0x0a, 0x12, 0x50, 0x75, 0x62, 0x73, 0x75, 0x62,
   134  	0x42, 0x65, 0x6e, 0x63, 0x68, 0x57, 0x72, 0x61, 0x70, 0x70, 0x65, 0x72, 0x12, 0x3f, 0x0a, 0x04,
   135  	0x52, 0x65, 0x63, 0x76, 0x12, 0x18, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x5f, 0x62, 0x65,
   136  	0x6e, 0x63, 0x68, 0x2e, 0x50, 0x75, 0x62, 0x73, 0x75, 0x62, 0x52, 0x65, 0x63, 0x76, 0x1a, 0x1b,
   137  	0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x5f, 0x62, 0x65, 0x6e, 0x63, 0x68, 0x2e, 0x45, 0x6d,
   138  	0x70, 0x74, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x47, 0x50,
   139  	0x01, 0x5a, 0x43, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
   140  	0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x6f, 0x2f, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2f, 0x69, 0x6e,
   141  	0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x2f, 0x62, 0x65, 0x6e, 0x63, 0x68, 0x77, 0x72, 0x61, 0x70,
   142  	0x70, 0x65, 0x72, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x3b, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62,
   143  	0x5f, 0x62, 0x65, 0x6e, 0x63, 0x68, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   144  }
   145  
   146  var (
   147  	file_pubsub_proto_rawDescOnce sync.Once
   148  	file_pubsub_proto_rawDescData = file_pubsub_proto_rawDesc
   149  )
   150  
   151  func file_pubsub_proto_rawDescGZIP() []byte {
   152  	file_pubsub_proto_rawDescOnce.Do(func() {
   153  		file_pubsub_proto_rawDescData = protoimpl.X.CompressGZIP(file_pubsub_proto_rawDescData)
   154  	})
   155  	return file_pubsub_proto_rawDescData
   156  }
   157  
   158  var file_pubsub_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
   159  var file_pubsub_proto_goTypes = []interface{}{
   160  	(*PubsubRecv)(nil),    // 0: pubsub_bench.PubsubRecv
   161  	(*EmptyResponse)(nil), // 1: pubsub_bench.EmptyResponse
   162  }
   163  var file_pubsub_proto_depIdxs = []int32{
   164  	0, // 0: pubsub_bench.PubsubBenchWrapper.Recv:input_type -> pubsub_bench.PubsubRecv
   165  	1, // 1: pubsub_bench.PubsubBenchWrapper.Recv:output_type -> pubsub_bench.EmptyResponse
   166  	1, // [1:2] is the sub-list for method output_type
   167  	0, // [0:1] is the sub-list for method input_type
   168  	0, // [0:0] is the sub-list for extension type_name
   169  	0, // [0:0] is the sub-list for extension extendee
   170  	0, // [0:0] is the sub-list for field type_name
   171  }
   172  
   173  func init() { file_pubsub_proto_init() }
   174  func file_pubsub_proto_init() {
   175  	if File_pubsub_proto != nil {
   176  		return
   177  	}
   178  	if !protoimpl.UnsafeEnabled {
   179  		file_pubsub_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   180  			switch v := v.(*PubsubRecv); i {
   181  			case 0:
   182  				return &v.state
   183  			case 1:
   184  				return &v.sizeCache
   185  			case 2:
   186  				return &v.unknownFields
   187  			default:
   188  				return nil
   189  			}
   190  		}
   191  		file_pubsub_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   192  			switch v := v.(*EmptyResponse); i {
   193  			case 0:
   194  				return &v.state
   195  			case 1:
   196  				return &v.sizeCache
   197  			case 2:
   198  				return &v.unknownFields
   199  			default:
   200  				return nil
   201  			}
   202  		}
   203  	}
   204  	type x struct{}
   205  	out := protoimpl.TypeBuilder{
   206  		File: protoimpl.DescBuilder{
   207  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   208  			RawDescriptor: file_pubsub_proto_rawDesc,
   209  			NumEnums:      0,
   210  			NumMessages:   2,
   211  			NumExtensions: 0,
   212  			NumServices:   1,
   213  		},
   214  		GoTypes:           file_pubsub_proto_goTypes,
   215  		DependencyIndexes: file_pubsub_proto_depIdxs,
   216  		MessageInfos:      file_pubsub_proto_msgTypes,
   217  	}.Build()
   218  	File_pubsub_proto = out.File
   219  	file_pubsub_proto_rawDesc = nil
   220  	file_pubsub_proto_goTypes = nil
   221  	file_pubsub_proto_depIdxs = nil
   222  }
   223
View as plain text