51 type StartRequest struct {  struct
80 func (m *StartRequest) Reset()                    { *m = StartRequest{} }  argument
81 func (m *StartRequest) String() string            { return proto.CompactTextString(m) }  argument
82 func (*StartRequest) ProtoMessage()               {}  argument
83 func (*StartRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }  argument
110 func (m *StartRequest) GetStopConditions() isStartRequest_StopConditions {  argument
116 func (m *StartRequest) GetOptions() isStartRequest_Options {  argument
123 func (m *StartRequest) GetProject() string {  argument
130 func (m *StartRequest) GetTopic() string {  argument
137 func (m *StartRequest) GetRequestRate() int32 {  argument
144 func (m *StartRequest) GetMessageSize() int32 {  argument
151 func (m *StartRequest) GetMaxOutstandingRequests() int32 {  argument
158 func (m *StartRequest) GetStartTime() *google_protobuf1.Timestamp {  argument
165 func (m *StartRequest) GetBurnInDuration() *google_protobuf.Duration {  argument
172 func (m *StartRequest) GetPublishBatchSize() int32 {  argument
179 func (m *StartRequest) GetPublishBatchDuration() *google_protobuf.Duration {  argument
186 func (m *StartRequest) GetTestDuration() *google_protobuf.Duration {  argument
193 func (m *StartRequest) GetNumberOfMessages() int32 {  argument
200 func (m *StartRequest) GetPubsubOptions() *PubsubOptions {  argument
207 func (m *StartRequest) GetKafkaOptions() *KafkaOptions {  argument
215 func (*StartRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg pro…  argument
225 	m := msg.(*StartRequest)
260 	m := msg.(*StartRequest)
299 	m := msg.(*StartRequest)
515 	proto.RegisterType((*StartRequest)(nil), "google.pubsub.loadtest.StartRequest")
538 	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)  argument
551 func (c *loadtestClient) Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*St…
573 	Start(context.Context, *StartRequest) (*StartResponse, error)  argument
583 	in := new(StartRequest)
595 		return srv.(LoadtestServer).Start(ctx, req.(*StartRequest))
639 	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)  argument
654 func (c *loadtestWorkerClient) Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption…
676 	Start(context.Context, *StartRequest) (*StartResponse, error)  argument
688 	in := new(StartRequest)
700 		return srv.(LoadtestWorkerServer).Start(ctx, req.(*StartRequest))