loadtest.pb.go

Documentation: cloud.google.com/go/pubsub/loadtest/pb

     1  // Copyright 2024 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: loadtest.proto
    20  
    21  package google_pubsub_loadtest
    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  	durationpb "google.golang.org/protobuf/types/known/durationpb"
    30  	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
    31  )
    32  
    33  const (
    34  	// Verify that this generated code is sufficiently up-to-date.
    35  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    36  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    37  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    38  )
    39  
    40  type StartRequest struct {
    41  	state         protoimpl.MessageState
    42  	sizeCache     protoimpl.SizeCache
    43  	unknownFields protoimpl.UnknownFields
    44  
    45  	// The GCP project.
    46  	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
    47  	// The Pub/Sub topic name.
    48  	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
    49  	// The time at which the load test should start. If this is less than the current time, we start immediately.
    50  	StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
    51  	// The duration the load test should run for.
    52  	TestDuration *durationpb.Duration `protobuf:"bytes,4,opt,name=test_duration,json=testDuration,proto3" json:"test_duration,omitempty"`
    53  	// Whether to include ids in check responses.
    54  	IncludeIds bool `protobuf:"varint,5,opt,name=include_ids,json=includeIds,proto3" json:"include_ids,omitempty"`
    55  	// Types that are assignable to Options:
    56  	//
    57  	//	*StartRequest_PubsubOptions
    58  	Options isStartRequest_Options `protobuf_oneof:"options"`
    59  	// Types that are assignable to ClientOptions:
    60  	//
    61  	//	*StartRequest_PublisherOptions
    62  	//	*StartRequest_SubscriberOptions
    63  	ClientOptions isStartRequest_ClientOptions `protobuf_oneof:"client_options"`
    64  	// The cpu scaling of the worker.  A multiple of the number of logical processors
    65  	// on the machine.  The number of threads for the worker is calculated by
    66  	// max((numCpus * cpu_scaling), 1) for languages which use thread parallelism.
    67  	// Languages which use process parallelism ignore this setting.
    68  	CpuScaling int32 `protobuf:"varint,10,opt,name=cpu_scaling,json=cpuScaling,proto3" json:"cpu_scaling,omitempty"`
    69  }
    70  
    71  func (x *StartRequest) Reset() {
    72  	*x = StartRequest{}
    73  	if protoimpl.UnsafeEnabled {
    74  		mi := &file_loadtest_proto_msgTypes[0]
    75  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    76  		ms.StoreMessageInfo(mi)
    77  	}
    78  }
    79  
    80  func (x *StartRequest) String() string {
    81  	return protoimpl.X.MessageStringOf(x)
    82  }
    83  
    84  func (*StartRequest) ProtoMessage() {}
    85  
    86  func (x *StartRequest) ProtoReflect() protoreflect.Message {
    87  	mi := &file_loadtest_proto_msgTypes[0]
    88  	if protoimpl.UnsafeEnabled && x != nil {
    89  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    90  		if ms.LoadMessageInfo() == nil {
    91  			ms.StoreMessageInfo(mi)
    92  		}
    93  		return ms
    94  	}
    95  	return mi.MessageOf(x)
    96  }
    97  
    98  // Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.
    99  func (*StartRequest) Descriptor() ([]byte, []int) {
   100  	return file_loadtest_proto_rawDescGZIP(), []int{0}
   101  }
   102  
   103  func (x *StartRequest) GetProject() string {
   104  	if x != nil {
   105  		return x.Project
   106  	}
   107  	return ""
   108  }
   109  
   110  func (x *StartRequest) GetTopic() string {
   111  	if x != nil {
   112  		return x.Topic
   113  	}
   114  	return ""
   115  }
   116  
   117  func (x *StartRequest) GetStartTime() *timestamppb.Timestamp {
   118  	if x != nil {
   119  		return x.StartTime
   120  	}
   121  	return nil
   122  }
   123  
   124  func (x *StartRequest) GetTestDuration() *durationpb.Duration {
   125  	if x != nil {
   126  		return x.TestDuration
   127  	}
   128  	return nil
   129  }
   130  
   131  func (x *StartRequest) GetIncludeIds() bool {
   132  	if x != nil {
   133  		return x.IncludeIds
   134  	}
   135  	return false
   136  }
   137  
   138  func (m *StartRequest) GetOptions() isStartRequest_Options {
   139  	if m != nil {
   140  		return m.Options
   141  	}
   142  	return nil
   143  }
   144  
   145  func (x *StartRequest) GetPubsubOptions() *PubsubOptions {
   146  	if x, ok := x.GetOptions().(*StartRequest_PubsubOptions); ok {
   147  		return x.PubsubOptions
   148  	}
   149  	return nil
   150  }
   151  
   152  func (m *StartRequest) GetClientOptions() isStartRequest_ClientOptions {
   153  	if m != nil {
   154  		return m.ClientOptions
   155  	}
   156  	return nil
   157  }
   158  
   159  func (x *StartRequest) GetPublisherOptions() *PublisherOptions {
   160  	if x, ok := x.GetClientOptions().(*StartRequest_PublisherOptions); ok {
   161  		return x.PublisherOptions
   162  	}
   163  	return nil
   164  }
   165  
   166  func (x *StartRequest) GetSubscriberOptions() *SubscriberOptions {
   167  	if x, ok := x.GetClientOptions().(*StartRequest_SubscriberOptions); ok {
   168  		return x.SubscriberOptions
   169  	}
   170  	return nil
   171  }
   172  
   173  func (x *StartRequest) GetCpuScaling() int32 {
   174  	if x != nil {
   175  		return x.CpuScaling
   176  	}
   177  	return 0
   178  }
   179  
   180  type isStartRequest_Options interface {
   181  	isStartRequest_Options()
   182  }
   183  
   184  type StartRequest_PubsubOptions struct {
   185  	PubsubOptions *PubsubOptions `protobuf:"bytes,6,opt,name=pubsub_options,json=pubsubOptions,proto3,oneof"`
   186  }
   187  
   188  func (*StartRequest_PubsubOptions) isStartRequest_Options() {}
   189  
   190  type isStartRequest_ClientOptions interface {
   191  	isStartRequest_ClientOptions()
   192  }
   193  
   194  type StartRequest_PublisherOptions struct {
   195  	PublisherOptions *PublisherOptions `protobuf:"bytes,8,opt,name=publisher_options,json=publisherOptions,proto3,oneof"`
   196  }
   197  
   198  type StartRequest_SubscriberOptions struct {
   199  	SubscriberOptions *SubscriberOptions `protobuf:"bytes,9,opt,name=subscriber_options,json=subscriberOptions,proto3,oneof"`
   200  }
   201  
   202  func (*StartRequest_PublisherOptions) isStartRequest_ClientOptions() {}
   203  
   204  func (*StartRequest_SubscriberOptions) isStartRequest_ClientOptions() {}
   205  
   206  type StartResponse struct {
   207  	state         protoimpl.MessageState
   208  	sizeCache     protoimpl.SizeCache
   209  	unknownFields protoimpl.UnknownFields
   210  }
   211  
   212  func (x *StartResponse) Reset() {
   213  	*x = StartResponse{}
   214  	if protoimpl.UnsafeEnabled {
   215  		mi := &file_loadtest_proto_msgTypes[1]
   216  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   217  		ms.StoreMessageInfo(mi)
   218  	}
   219  }
   220  
   221  func (x *StartResponse) String() string {
   222  	return protoimpl.X.MessageStringOf(x)
   223  }
   224  
   225  func (*StartResponse) ProtoMessage() {}
   226  
   227  func (x *StartResponse) ProtoReflect() protoreflect.Message {
   228  	mi := &file_loadtest_proto_msgTypes[1]
   229  	if protoimpl.UnsafeEnabled && x != nil {
   230  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   231  		if ms.LoadMessageInfo() == nil {
   232  			ms.StoreMessageInfo(mi)
   233  		}
   234  		return ms
   235  	}
   236  	return mi.MessageOf(x)
   237  }
   238  
   239  // Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.
   240  func (*StartResponse) Descriptor() ([]byte, []int) {
   241  	return file_loadtest_proto_rawDescGZIP(), []int{1}
   242  }
   243  
   244  type PublisherOptions struct {
   245  	state         protoimpl.MessageState
   246  	sizeCache     protoimpl.SizeCache
   247  	unknownFields protoimpl.UnknownFields
   248  
   249  	// The max messages-per-second publishing rate.  If unset, no rate limit will
   250  	// be imposed.
   251  	Rate float32 `protobuf:"fixed32,1,opt,name=rate,proto3" json:"rate,omitempty"`
   252  	// The max duration for coalescing a batch of published messages.
   253  	BatchDuration *durationpb.Duration `protobuf:"bytes,2,opt,name=batch_duration,json=batchDuration,proto3" json:"batch_duration,omitempty"`
   254  	// The number of user messages of size message_size to publish together.
   255  	BatchSize int32 `protobuf:"varint,3,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
   256  	// The size in bytes of messages to publish
   257  	MessageSize int32 `protobuf:"varint,4,opt,name=message_size,json=messageSize,proto3" json:"message_size,omitempty"`
   258  }
   259  
   260  func (x *PublisherOptions) Reset() {
   261  	*x = PublisherOptions{}
   262  	if protoimpl.UnsafeEnabled {
   263  		mi := &file_loadtest_proto_msgTypes[2]
   264  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   265  		ms.StoreMessageInfo(mi)
   266  	}
   267  }
   268  
   269  func (x *PublisherOptions) String() string {
   270  	return protoimpl.X.MessageStringOf(x)
   271  }
   272  
   273  func (*PublisherOptions) ProtoMessage() {}
   274  
   275  func (x *PublisherOptions) ProtoReflect() protoreflect.Message {
   276  	mi := &file_loadtest_proto_msgTypes[2]
   277  	if protoimpl.UnsafeEnabled && x != nil {
   278  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   279  		if ms.LoadMessageInfo() == nil {
   280  			ms.StoreMessageInfo(mi)
   281  		}
   282  		return ms
   283  	}
   284  	return mi.MessageOf(x)
   285  }
   286  
   287  // Deprecated: Use PublisherOptions.ProtoReflect.Descriptor instead.
   288  func (*PublisherOptions) Descriptor() ([]byte, []int) {
   289  	return file_loadtest_proto_rawDescGZIP(), []int{2}
   290  }
   291  
   292  func (x *PublisherOptions) GetRate() float32 {
   293  	if x != nil {
   294  		return x.Rate
   295  	}
   296  	return 0
   297  }
   298  
   299  func (x *PublisherOptions) GetBatchDuration() *durationpb.Duration {
   300  	if x != nil {
   301  		return x.BatchDuration
   302  	}
   303  	return nil
   304  }
   305  
   306  func (x *PublisherOptions) GetBatchSize() int32 {
   307  	if x != nil {
   308  		return x.BatchSize
   309  	}
   310  	return 0
   311  }
   312  
   313  func (x *PublisherOptions) GetMessageSize() int32 {
   314  	if x != nil {
   315  		return x.MessageSize
   316  	}
   317  	return 0
   318  }
   319  
   320  type SubscriberOptions struct {
   321  	state         protoimpl.MessageState
   322  	sizeCache     protoimpl.SizeCache
   323  	unknownFields protoimpl.UnknownFields
   324  }
   325  
   326  func (x *SubscriberOptions) Reset() {
   327  	*x = SubscriberOptions{}
   328  	if protoimpl.UnsafeEnabled {
   329  		mi := &file_loadtest_proto_msgTypes[3]
   330  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   331  		ms.StoreMessageInfo(mi)
   332  	}
   333  }
   334  
   335  func (x *SubscriberOptions) String() string {
   336  	return protoimpl.X.MessageStringOf(x)
   337  }
   338  
   339  func (*SubscriberOptions) ProtoMessage() {}
   340  
   341  func (x *SubscriberOptions) ProtoReflect() protoreflect.Message {
   342  	mi := &file_loadtest_proto_msgTypes[3]
   343  	if protoimpl.UnsafeEnabled && x != nil {
   344  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   345  		if ms.LoadMessageInfo() == nil {
   346  			ms.StoreMessageInfo(mi)
   347  		}
   348  		return ms
   349  	}
   350  	return mi.MessageOf(x)
   351  }
   352  
   353  // Deprecated: Use SubscriberOptions.ProtoReflect.Descriptor instead.
   354  func (*SubscriberOptions) Descriptor() ([]byte, []int) {
   355  	return file_loadtest_proto_rawDescGZIP(), []int{3}
   356  }
   357  
   358  type PubsubOptions struct {
   359  	state         protoimpl.MessageState
   360  	sizeCache     protoimpl.SizeCache
   361  	unknownFields protoimpl.UnknownFields
   362  
   363  	// The Cloud Pub/Sub subscription name
   364  	Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
   365  }
   366  
   367  func (x *PubsubOptions) Reset() {
   368  	*x = PubsubOptions{}
   369  	if protoimpl.UnsafeEnabled {
   370  		mi := &file_loadtest_proto_msgTypes[4]
   371  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   372  		ms.StoreMessageInfo(mi)
   373  	}
   374  }
   375  
   376  func (x *PubsubOptions) String() string {
   377  	return protoimpl.X.MessageStringOf(x)
   378  }
   379  
   380  func (*PubsubOptions) ProtoMessage() {}
   381  
   382  func (x *PubsubOptions) ProtoReflect() protoreflect.Message {
   383  	mi := &file_loadtest_proto_msgTypes[4]
   384  	if protoimpl.UnsafeEnabled && x != nil {
   385  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   386  		if ms.LoadMessageInfo() == nil {
   387  			ms.StoreMessageInfo(mi)
   388  		}
   389  		return ms
   390  	}
   391  	return mi.MessageOf(x)
   392  }
   393  
   394  // Deprecated: Use PubsubOptions.ProtoReflect.Descriptor instead.
   395  func (*PubsubOptions) Descriptor() ([]byte, []int) {
   396  	return file_loadtest_proto_rawDescGZIP(), []int{4}
   397  }
   398  
   399  func (x *PubsubOptions) GetSubscription() string {
   400  	if x != nil {
   401  		return x.Subscription
   402  	}
   403  	return ""
   404  }
   405  
   406  type MessageIdentifier struct {
   407  	state         protoimpl.MessageState
   408  	sizeCache     protoimpl.SizeCache
   409  	unknownFields protoimpl.UnknownFields
   410  
   411  	// The unique id of the client that published the message.
   412  	PublisherClientId int64 `protobuf:"varint,1,opt,name=publisher_client_id,json=publisherClientId,proto3" json:"publisher_client_id,omitempty"`
   413  	// Sequence number of the published message with the given publish_client_id.
   414  	SequenceNumber int32 `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
   415  }
   416  
   417  func (x *MessageIdentifier) Reset() {
   418  	*x = MessageIdentifier{}
   419  	if protoimpl.UnsafeEnabled {
   420  		mi := &file_loadtest_proto_msgTypes[5]
   421  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   422  		ms.StoreMessageInfo(mi)
   423  	}
   424  }
   425  
   426  func (x *MessageIdentifier) String() string {
   427  	return protoimpl.X.MessageStringOf(x)
   428  }
   429  
   430  func (*MessageIdentifier) ProtoMessage() {}
   431  
   432  func (x *MessageIdentifier) ProtoReflect() protoreflect.Message {
   433  	mi := &file_loadtest_proto_msgTypes[5]
   434  	if protoimpl.UnsafeEnabled && x != nil {
   435  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   436  		if ms.LoadMessageInfo() == nil {
   437  			ms.StoreMessageInfo(mi)
   438  		}
   439  		return ms
   440  	}
   441  	return mi.MessageOf(x)
   442  }
   443  
   444  // Deprecated: Use MessageIdentifier.ProtoReflect.Descriptor instead.
   445  func (*MessageIdentifier) Descriptor() ([]byte, []int) {
   446  	return file_loadtest_proto_rawDescGZIP(), []int{5}
   447  }
   448  
   449  func (x *MessageIdentifier) GetPublisherClientId() int64 {
   450  	if x != nil {
   451  		return x.PublisherClientId
   452  	}
   453  	return 0
   454  }
   455  
   456  func (x *MessageIdentifier) GetSequenceNumber() int32 {
   457  	if x != nil {
   458  		return x.SequenceNumber
   459  	}
   460  	return 0
   461  }
   462  
   463  // Request a statistics update.
   464  type CheckRequest struct {
   465  	state         protoimpl.MessageState
   466  	sizeCache     protoimpl.SizeCache
   467  	unknownFields protoimpl.UnknownFields
   468  }
   469  
   470  func (x *CheckRequest) Reset() {
   471  	*x = CheckRequest{}
   472  	if protoimpl.UnsafeEnabled {
   473  		mi := &file_loadtest_proto_msgTypes[6]
   474  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   475  		ms.StoreMessageInfo(mi)
   476  	}
   477  }
   478  
   479  func (x *CheckRequest) String() string {
   480  	return protoimpl.X.MessageStringOf(x)
   481  }
   482  
   483  func (*CheckRequest) ProtoMessage() {}
   484  
   485  func (x *CheckRequest) ProtoReflect() protoreflect.Message {
   486  	mi := &file_loadtest_proto_msgTypes[6]
   487  	if protoimpl.UnsafeEnabled && x != nil {
   488  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   489  		if ms.LoadMessageInfo() == nil {
   490  			ms.StoreMessageInfo(mi)
   491  		}
   492  		return ms
   493  	}
   494  	return mi.MessageOf(x)
   495  }
   496  
   497  // Deprecated: Use CheckRequest.ProtoReflect.Descriptor instead.
   498  func (*CheckRequest) Descriptor() ([]byte, []int) {
   499  	return file_loadtest_proto_rawDescGZIP(), []int{6}
   500  }
   501  
   502  type CheckResponse struct {
   503  	state         protoimpl.MessageState
   504  	sizeCache     protoimpl.SizeCache
   505  	unknownFields protoimpl.UnknownFields
   506  
   507  	// Histogram of latencies, each one a delta from the previous CheckResponse sent.
   508  	// The bounds of the nth bucket (starting from the 0th bucket) are
   509  	// [1.5^(n-1), 1.5^n) milliseconds.  The lower bound of the 0th bucket is 0 seconds.
   510  	BucketValues []int64 `protobuf:"varint,1,rep,packed,name=bucket_values,json=bucketValues,proto3" json:"bucket_values,omitempty"`
   511  	// The duration from the start of the loadtest to its completion or now if is_finished is false.
   512  	RunningDuration *durationpb.Duration `protobuf:"bytes,2,opt,name=running_duration,json=runningDuration,proto3" json:"running_duration,omitempty"`
   513  	// True if the load test has finished running.
   514  	IsFinished bool `protobuf:"varint,3,opt,name=is_finished,json=isFinished,proto3" json:"is_finished,omitempty"`
   515  	// MessageIdentifiers of all messages since the last Check.
   516  	ReceivedMessages []*MessageIdentifier `protobuf:"bytes,4,rep,name=received_messages,json=receivedMessages,proto3" json:"received_messages,omitempty"`
   517  	// Number of failed messages since the last check.
   518  	Failed int64 `protobuf:"varint,5,opt,name=failed,proto3" json:"failed,omitempty"`
   519  }
   520  
   521  func (x *CheckResponse) Reset() {
   522  	*x = CheckResponse{}
   523  	if protoimpl.UnsafeEnabled {
   524  		mi := &file_loadtest_proto_msgTypes[7]
   525  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   526  		ms.StoreMessageInfo(mi)
   527  	}
   528  }
   529  
   530  func (x *CheckResponse) String() string {
   531  	return protoimpl.X.MessageStringOf(x)
   532  }
   533  
   534  func (*CheckResponse) ProtoMessage() {}
   535  
   536  func (x *CheckResponse) ProtoReflect() protoreflect.Message {
   537  	mi := &file_loadtest_proto_msgTypes[7]
   538  	if protoimpl.UnsafeEnabled && x != nil {
   539  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   540  		if ms.LoadMessageInfo() == nil {
   541  			ms.StoreMessageInfo(mi)
   542  		}
   543  		return ms
   544  	}
   545  	return mi.MessageOf(x)
   546  }
   547  
   548  // Deprecated: Use CheckResponse.ProtoReflect.Descriptor instead.
   549  func (*CheckResponse) Descriptor() ([]byte, []int) {
   550  	return file_loadtest_proto_rawDescGZIP(), []int{7}
   551  }
   552  
   553  func (x *CheckResponse) GetBucketValues() []int64 {
   554  	if x != nil {
   555  		return x.BucketValues
   556  	}
   557  	return nil
   558  }
   559  
   560  func (x *CheckResponse) GetRunningDuration() *durationpb.Duration {
   561  	if x != nil {
   562  		return x.RunningDuration
   563  	}
   564  	return nil
   565  }
   566  
   567  func (x *CheckResponse) GetIsFinished() bool {
   568  	if x != nil {
   569  		return x.IsFinished
   570  	}
   571  	return false
   572  }
   573  
   574  func (x *CheckResponse) GetReceivedMessages() []*MessageIdentifier {
   575  	if x != nil {
   576  		return x.ReceivedMessages
   577  	}
   578  	return nil
   579  }
   580  
   581  func (x *CheckResponse) GetFailed() int64 {
   582  	if x != nil {
   583  		return x.Failed
   584  	}
   585  	return 0
   586  }
   587  
   588  var File_loadtest_proto protoreflect.FileDescriptor
   589  
   590  var file_loadtest_proto_rawDesc = []byte{
   591  	0x0a, 0x0e, 0x6c, 0x6f, 0x61, 0x64, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
   592  	0x12, 0x16, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e,
   593  	0x6c, 0x6f, 0x61, 0x64, 0x74, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   594  	0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69,
   595  	0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   596  	0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74,
   597  	0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x9d, 0x04, 0x0a, 0x0c, 0x53, 0x74,
   598  	0x61, 0x72, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x70, 0x72,
   599  	0x6f, 0x6a, 0x65, 0x63, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x70, 0x72, 0x6f,
   600  	0x6a, 0x65, 0x63, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x02, 0x20,
   601  	0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x39, 0x0a, 0x0a, 0x73, 0x74,
   602  	0x61, 0x72, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a,
   603  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66,
   604  	0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72,
   605  	0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x3e, 0x0a, 0x0d, 0x74, 0x65, 0x73, 0x74, 0x5f, 0x64, 0x75,
   606  	0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67,
   607  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44,
   608  	0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0c, 0x74, 0x65, 0x73, 0x74, 0x44, 0x75, 0x72,
   609  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1f, 0x0a, 0x0b, 0x69, 0x6e, 0x63, 0x6c, 0x75, 0x64, 0x65,
   610  	0x5f, 0x69, 0x64, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0a, 0x69, 0x6e, 0x63, 0x6c,
   611  	0x75, 0x64, 0x65, 0x49, 0x64, 0x73, 0x12, 0x4e, 0x0a, 0x0e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62,
   612  	0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x25,
   613  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x6c,
   614  	0x6f, 0x61, 0x64, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x50, 0x75, 0x62, 0x73, 0x75, 0x62, 0x4f, 0x70,
   615  	0x74, 0x69, 0x6f, 0x6e, 0x73, 0x48, 0x00, 0x52, 0x0d, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x4f,
   616  	0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x57, 0x0a, 0x11, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73,
   617  	0x68, 0x65, 0x72, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x08, 0x20, 0x01, 0x28,
   618  	0x0b, 0x32, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75,
   619  	0x62, 0x2e, 0x6c, 0x6f, 0x61, 0x64, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69,
   620  	0x73, 0x68, 0x65, 0x72, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x48, 0x01, 0x52, 0x10, 0x70,
   621  	0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x65, 0x72, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12,
   622  	0x5a, 0x0a, 0x12, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x72, 0x5f, 0x6f, 0x70,
   623  	0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67, 0x6f,
   624  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x6c, 0x6f, 0x61, 0x64,
   625  	0x74, 0x65, 0x73, 0x74, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x72, 0x4f,
   626  	0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x48, 0x01, 0x52, 0x11, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72,
   627  	0x69, 0x62, 0x65, 0x72, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x1f, 0x0a, 0x0b, 0x63,
   628  	0x70, 0x75, 0x5f, 0x73, 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x05,
   629  	0x52, 0x0a, 0x63, 0x70, 0x75, 0x53, 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67, 0x42, 0x09, 0x0a, 0x07,
   630  	0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x42, 0x10, 0x0a, 0x0e, 0x63, 0x6c, 0x69, 0x65, 0x6e,
   631  	0x74, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x22, 0x0f, 0x0a, 0x0d, 0x53, 0x74, 0x61,
   632  	0x72, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xaa, 0x01, 0x0a, 0x10, 0x50,
   633  	0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x65, 0x72, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12,
   634  	0x12, 0x0a, 0x04, 0x72, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x02, 0x52, 0x04, 0x72,
   635  	0x61, 0x74, 0x65, 0x12, 0x40, 0x0a, 0x0e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x5f, 0x64, 0x75, 0x72,
   636  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f,
   637  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75,
   638  	0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0d, 0x62, 0x61, 0x74, 0x63, 0x68, 0x44, 0x75, 0x72,
   639  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1d, 0x0a, 0x0a, 0x62, 0x61, 0x74, 0x63, 0x68, 0x5f, 0x73,
   640  	0x69, 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x09, 0x62, 0x61, 0x74, 0x63, 0x68,
   641  	0x53, 0x69, 0x7a, 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f,
   642  	0x73, 0x69, 0x7a, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0b, 0x6d, 0x65, 0x73, 0x73,
   643  	0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x22, 0x13, 0x0a, 0x11, 0x53, 0x75, 0x62, 0x73, 0x63,
   644  	0x72, 0x69, 0x62, 0x65, 0x72, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x22, 0x33, 0x0a, 0x0d,
   645  	0x50, 0x75, 0x62, 0x73, 0x75, 0x62, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x22, 0x0a,
   646  	0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20,
   647  	0x01, 0x28, 0x09, 0x52, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f,
   648  	0x6e, 0x22, 0x6c, 0x0a, 0x11, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x49, 0x64, 0x65, 0x6e,
   649  	0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x12, 0x2e, 0x0a, 0x13, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73,
   650  	0x68, 0x65, 0x72, 0x5f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20,
   651  	0x01, 0x28, 0x03, 0x52, 0x11, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x65, 0x72, 0x43, 0x6c,
   652  	0x69, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x27, 0x0a, 0x0f, 0x73, 0x65, 0x71, 0x75, 0x65, 0x6e,
   653  	0x63, 0x65, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52,
   654  	0x0e, 0x73, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x65, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x22,
   655  	0x0e, 0x0a, 0x0c, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22,
   656  	0x8b, 0x02, 0x0a, 0x0d, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
   657  	0x65, 0x12, 0x23, 0x0a, 0x0d, 0x62, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x5f, 0x76, 0x61, 0x6c, 0x75,
   658  	0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x03, 0x52, 0x0c, 0x62, 0x75, 0x63, 0x6b, 0x65, 0x74,
   659  	0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x12, 0x44, 0x0a, 0x10, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e,
   660  	0x67, 0x5f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b,
   661  	0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
   662  	0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0f, 0x72, 0x75, 0x6e,
   663  	0x6e, 0x69, 0x6e, 0x67, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1f, 0x0a, 0x0b,
   664  	0x69, 0x73, 0x5f, 0x66, 0x69, 0x6e, 0x69, 0x73, 0x68, 0x65, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28,
   665  	0x08, 0x52, 0x0a, 0x69, 0x73, 0x46, 0x69, 0x6e, 0x69, 0x73, 0x68, 0x65, 0x64, 0x12, 0x56, 0x0a,
   666  	0x11, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x64, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67,
   667  	0x65, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
   668  	0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x6c, 0x6f, 0x61, 0x64, 0x74, 0x65, 0x73,
   669  	0x74, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66,
   670  	0x69, 0x65, 0x72, 0x52, 0x10, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x64, 0x4d, 0x65, 0x73,
   671  	0x73, 0x61, 0x67, 0x65, 0x73, 0x12, 0x16, 0x0a, 0x06, 0x66, 0x61, 0x69, 0x6c, 0x65, 0x64, 0x18,
   672  	0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x66, 0x61, 0x69, 0x6c, 0x65, 0x64, 0x32, 0xbc, 0x01,
   673  	0x0a, 0x0e, 0x4c, 0x6f, 0x61, 0x64, 0x74, 0x65, 0x73, 0x74, 0x57, 0x6f, 0x72, 0x6b, 0x65, 0x72,
   674  	0x12, 0x54, 0x0a, 0x05, 0x53, 0x74, 0x61, 0x72, 0x74, 0x12, 0x24, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
   675  	0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x6c, 0x6f, 0x61, 0x64, 0x74, 0x65,
   676  	0x73, 0x74, 0x2e, 0x53, 0x74, 0x61, 0x72, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
   677  	0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e,
   678  	0x6c, 0x6f, 0x61, 0x64, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x53, 0x74, 0x61, 0x72, 0x74, 0x52, 0x65,
   679  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x54, 0x0a, 0x05, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x12,
   680  	0x24, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e,
   681  	0x6c, 0x6f, 0x61, 0x64, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65,
   682  	0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
   683  	0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x6c, 0x6f, 0x61, 0x64, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x43,
   684  	0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x3f, 0x5a, 0x3d,
   685  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6f, 0x6d,
   686  	0x2f, 0x67, 0x6f, 0x2f, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2f, 0x6c, 0x6f, 0x61, 0x64, 0x74,
   687  	0x65, 0x73, 0x74, 0x2f, 0x70, 0x62, 0x3b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5f, 0x70, 0x75,
   688  	0x62, 0x73, 0x75, 0x62, 0x5f, 0x6c, 0x6f, 0x61, 0x64, 0x74, 0x65, 0x73, 0x74, 0x62, 0x06, 0x70,
   689  	0x72, 0x6f, 0x74, 0x6f, 0x33,
   690  }
   691  
   692  var (
   693  	file_loadtest_proto_rawDescOnce sync.Once
   694  	file_loadtest_proto_rawDescData = file_loadtest_proto_rawDesc
   695  )
   696  
   697  func file_loadtest_proto_rawDescGZIP() []byte {
   698  	file_loadtest_proto_rawDescOnce.Do(func() {
   699  		file_loadtest_proto_rawDescData = protoimpl.X.CompressGZIP(file_loadtest_proto_rawDescData)
   700  	})
   701  	return file_loadtest_proto_rawDescData
   702  }
   703  
   704  var file_loadtest_proto_msgTypes = make([]protoimpl.MessageInfo, 8)
   705  var file_loadtest_proto_goTypes = []interface{}{
   706  	(*StartRequest)(nil),          // 0: google.pubsub.loadtest.StartRequest
   707  	(*StartResponse)(nil),         // 1: google.pubsub.loadtest.StartResponse
   708  	(*PublisherOptions)(nil),      // 2: google.pubsub.loadtest.PublisherOptions
   709  	(*SubscriberOptions)(nil),     // 3: google.pubsub.loadtest.SubscriberOptions
   710  	(*PubsubOptions)(nil),         // 4: google.pubsub.loadtest.PubsubOptions
   711  	(*MessageIdentifier)(nil),     // 5: google.pubsub.loadtest.MessageIdentifier
   712  	(*CheckRequest)(nil),          // 6: google.pubsub.loadtest.CheckRequest
   713  	(*CheckResponse)(nil),         // 7: google.pubsub.loadtest.CheckResponse
   714  	(*timestamppb.Timestamp)(nil), // 8: google.protobuf.Timestamp
   715  	(*durationpb.Duration)(nil),   // 9: google.protobuf.Duration
   716  }
   717  var file_loadtest_proto_depIdxs = []int32{
   718  	8,  // 0: google.pubsub.loadtest.StartRequest.start_time:type_name -> google.protobuf.Timestamp
   719  	9,  // 1: google.pubsub.loadtest.StartRequest.test_duration:type_name -> google.protobuf.Duration
   720  	4,  // 2: google.pubsub.loadtest.StartRequest.pubsub_options:type_name -> google.pubsub.loadtest.PubsubOptions
   721  	2,  // 3: google.pubsub.loadtest.StartRequest.publisher_options:type_name -> google.pubsub.loadtest.PublisherOptions
   722  	3,  // 4: google.pubsub.loadtest.StartRequest.subscriber_options:type_name -> google.pubsub.loadtest.SubscriberOptions
   723  	9,  // 5: google.pubsub.loadtest.PublisherOptions.batch_duration:type_name -> google.protobuf.Duration
   724  	9,  // 6: google.pubsub.loadtest.CheckResponse.running_duration:type_name -> google.protobuf.Duration
   725  	5,  // 7: google.pubsub.loadtest.CheckResponse.received_messages:type_name -> google.pubsub.loadtest.MessageIdentifier
   726  	0,  // 8: google.pubsub.loadtest.LoadtestWorker.Start:input_type -> google.pubsub.loadtest.StartRequest
   727  	6,  // 9: google.pubsub.loadtest.LoadtestWorker.Check:input_type -> google.pubsub.loadtest.CheckRequest
   728  	1,  // 10: google.pubsub.loadtest.LoadtestWorker.Start:output_type -> google.pubsub.loadtest.StartResponse
   729  	7,  // 11: google.pubsub.loadtest.LoadtestWorker.Check:output_type -> google.pubsub.loadtest.CheckResponse
   730  	10, // [10:12] is the sub-list for method output_type
   731  	8,  // [8:10] is the sub-list for method input_type
   732  	8,  // [8:8] is the sub-list for extension type_name
   733  	8,  // [8:8] is the sub-list for extension extendee
   734  	0,  // [0:8] is the sub-list for field type_name
   735  }
   736  
   737  func init() { file_loadtest_proto_init() }
   738  func file_loadtest_proto_init() {
   739  	if File_loadtest_proto != nil {
   740  		return
   741  	}
   742  	if !protoimpl.UnsafeEnabled {
   743  		file_loadtest_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   744  			switch v := v.(*StartRequest); i {
   745  			case 0:
   746  				return &v.state
   747  			case 1:
   748  				return &v.sizeCache
   749  			case 2:
   750  				return &v.unknownFields
   751  			default:
   752  				return nil
   753  			}
   754  		}
   755  		file_loadtest_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   756  			switch v := v.(*StartResponse); i {
   757  			case 0:
   758  				return &v.state
   759  			case 1:
   760  				return &v.sizeCache
   761  			case 2:
   762  				return &v.unknownFields
   763  			default:
   764  				return nil
   765  			}
   766  		}
   767  		file_loadtest_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
   768  			switch v := v.(*PublisherOptions); i {
   769  			case 0:
   770  				return &v.state
   771  			case 1:
   772  				return &v.sizeCache
   773  			case 2:
   774  				return &v.unknownFields
   775  			default:
   776  				return nil
   777  			}
   778  		}
   779  		file_loadtest_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
   780  			switch v := v.(*SubscriberOptions); i {
   781  			case 0:
   782  				return &v.state
   783  			case 1:
   784  				return &v.sizeCache
   785  			case 2:
   786  				return &v.unknownFields
   787  			default:
   788  				return nil
   789  			}
   790  		}
   791  		file_loadtest_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
   792  			switch v := v.(*PubsubOptions); i {
   793  			case 0:
   794  				return &v.state
   795  			case 1:
   796  				return &v.sizeCache
   797  			case 2:
   798  				return &v.unknownFields
   799  			default:
   800  				return nil
   801  			}
   802  		}
   803  		file_loadtest_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
   804  			switch v := v.(*MessageIdentifier); i {
   805  			case 0:
   806  				return &v.state
   807  			case 1:
   808  				return &v.sizeCache
   809  			case 2:
   810  				return &v.unknownFields
   811  			default:
   812  				return nil
   813  			}
   814  		}
   815  		file_loadtest_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
   816  			switch v := v.(*CheckRequest); i {
   817  			case 0:
   818  				return &v.state
   819  			case 1:
   820  				return &v.sizeCache
   821  			case 2:
   822  				return &v.unknownFields
   823  			default:
   824  				return nil
   825  			}
   826  		}
   827  		file_loadtest_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
   828  			switch v := v.(*CheckResponse); i {
   829  			case 0:
   830  				return &v.state
   831  			case 1:
   832  				return &v.sizeCache
   833  			case 2:
   834  				return &v.unknownFields
   835  			default:
   836  				return nil
   837  			}
   838  		}
   839  	}
   840  	file_loadtest_proto_msgTypes[0].OneofWrappers = []interface{}{
   841  		(*StartRequest_PubsubOptions)(nil),
   842  		(*StartRequest_PublisherOptions)(nil),
   843  		(*StartRequest_SubscriberOptions)(nil),
   844  	}
   845  	type x struct{}
   846  	out := protoimpl.TypeBuilder{
   847  		File: protoimpl.DescBuilder{
   848  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   849  			RawDescriptor: file_loadtest_proto_rawDesc,
   850  			NumEnums:      0,
   851  			NumMessages:   8,
   852  			NumExtensions: 0,
   853  			NumServices:   1,
   854  		},
   855  		GoTypes:           file_loadtest_proto_goTypes,
   856  		DependencyIndexes: file_loadtest_proto_depIdxs,
   857  		MessageInfos:      file_loadtest_proto_msgTypes,
   858  	}.Build()
   859  	File_loadtest_proto = out.File
   860  	file_loadtest_proto_rawDesc = nil
   861  	file_loadtest_proto_goTypes = nil
   862  	file_loadtest_proto_depIdxs = nil
   863  }
   864
View as plain text