Documentation
      ¶
    
    
  
    
  
    Overview ¶
Package loadtest implements load testing for pubsub, following the interface defined in https://github.com/GoogleCloudPlatform/pubsub/tree/master/load-test-framework/ .
This package is experimental.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubServer ¶
type PubServer struct {
	ID string
	// contains filtered or unexported fields
}
    func (*PubServer) Execute ¶
func (l *PubServer) Execute(ctx context.Context, _ *pb.ExecuteRequest) (*pb.ExecuteResponse, error)
func (*PubServer) Start ¶
func (l *PubServer) Start(ctx context.Context, req *pb.StartRequest) (*pb.StartResponse, error)
type SubServer ¶
type SubServer struct {
	// contains filtered or unexported fields
}
    func (*SubServer) Execute ¶
func (s *SubServer) Execute(ctx context.Context, _ *pb.ExecuteRequest) (*pb.ExecuteResponse, error)
func (*SubServer) Start ¶
func (s *SubServer) Start(ctx context.Context, req *pb.StartRequest) (*pb.StartResponse, error)
      
      Source Files
      ¶
    
- loadtest.go
 
 Click to show internal directories. 
   Click to hide internal directories.