handler

Documentation

Overview

Package handler provides request handler implementations.

Index

• Constants
• Variables
• type Worker
  • func NewWorker() *Worker
  • func (w *Worker) Ping(ctx context.Context, req *api.PingRequest) (*api.PingResponse, error)
  • func (w *Worker) Run(req *api.RunRequest, srv api.Worker_RunServer) error

Constants

const ResultBufferSize = 1000

ResultBufferSize sets the amount of objects in the result buffer.

Variables

var (
	// ErrUnknownBrowser indicates an error when an unknown browser type is given.
	ErrUnknownBrowser = status.Error(codes.InvalidArgument, "unknown browser type in request")
)

Types

type Worker

type Worker struct{}

Worker implements the gRPC worker service handler.

func NewWorker

func NewWorker() *Worker

NewWorker returns a new Worker.

func (*Worker) Ping

func (w *Worker) Ping(ctx context.Context, req *api.PingRequest) (*api.PingResponse, error)

Ping responds with a PingResponse message to incoming ping requests.

func (*Worker) Run

func (w *Worker) Run(req *api.RunRequest, srv api.Worker_RunServer) error

Run handles incoming run requests. It starts a new loadtest and sends the response results of the runners as single messages via gRPC stream. Closing the gRPC channel stops the load test and shuts all runners down.