47 type StartRequest struct {  struct
76 func (m *StartRequest) Reset()                    { *m = StartRequest{} }  argument
77 func (m *StartRequest) String() string            { return proto.CompactTextString(m) }  argument
78 func (*StartRequest) ProtoMessage()               {}  argument
79 func (*StartRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }  argument
106 func (m *StartRequest) GetStopConditions() isStartRequest_StopConditions {  argument
112 func (m *StartRequest) GetOptions() isStartRequest_Options {  argument
119 func (m *StartRequest) GetProject() string {  argument
126 func (m *StartRequest) GetTopic() string {  argument
133 func (m *StartRequest) GetRequestRate() int32 {  argument
140 func (m *StartRequest) GetMessageSize() int32 {  argument
147 func (m *StartRequest) GetMaxOutstandingRequests() int32 {  argument
154 func (m *StartRequest) GetStartTime() *google_protobuf1.Timestamp {  argument
161 func (m *StartRequest) GetBurnInDuration() *google_protobuf.Duration {  argument
168 func (m *StartRequest) GetPublishBatchSize() int32 {  argument
175 func (m *StartRequest) GetPublishBatchDuration() *google_protobuf.Duration {  argument
182 func (m *StartRequest) GetTestDuration() *google_protobuf.Duration {  argument
189 func (m *StartRequest) GetNumberOfMessages() int32 {  argument
196 func (m *StartRequest) GetPubsubOptions() *PubsubOptions {  argument
203 func (m *StartRequest) GetKafkaOptions() *KafkaOptions {  argument
211 func (*StartRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg pro…  argument
221 	m := msg.(*StartRequest)
256 	m := msg.(*StartRequest)
295 	m := msg.(*StartRequest)
511 	proto.RegisterType((*StartRequest)(nil), "google.pubsub.loadtest.StartRequest")
534 	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)  argument
547 func (c *loadtestClient) Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*St…
569 	Start(context.Context, *StartRequest) (*StartResponse, error)  argument
579 	in := new(StartRequest)
591 		return srv.(LoadtestServer).Start(ctx, req.(*StartRequest))
635 	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)  argument
650 func (c *loadtestWorkerClient) Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption…
672 	Start(context.Context, *StartRequest) (*StartResponse, error)  argument
684 	in := new(StartRequest)
696 		return srv.(LoadtestWorkerServer).Start(ctx, req.(*StartRequest))