loadtest - ActiveState ActiveGo 1.8
...

Package loadtest

import "cloud.google.com/go/pubsub/loadtest"
Overview
Index
Subdirectories

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.

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)

Subdirectories

Name Synopsis
..
cmd
pb Package google_pubsub_loadtest is a generated protocol buffer package.