Skip to content

Latest commit

 

History

History
61 lines (46 loc) · 5.01 KB

File metadata and controls

61 lines (46 loc) · 5.01 KB
title description weight
k6/net/grpc
k6 gRPC API
11

k6/net/grpc

The k6/net/grpc module provides a gRPC client for Remote Procedure Calls (RPC) over HTTP/2. It supports unary and streaming (starting on v0.49) RPCs.

Class/Method Description
Client gRPC client used for making RPC calls to a gRPC Server.
Client.load(importPaths, ...protoFiles) Loads and parses the given protocol buffer definitions to be made available for RPC requests.
Client.connect(address [,params]) Connects to a given gRPC service.
Client.invoke(url, request [,params]) Makes an unary RPC for the given service/method and returns a Response.
Client.close() Close the connection to the gRPC service.
Params RPC Request specific options.
Response Returned by RPC requests.
Constants Define constants to distinguish between gRPC Response statuses.
Stream(client, url, [,params]) Creates a new GRPC stream.
Stream.on(event, handler) Adds a new listener to one of the possible stream events.
Stream.write(message) Writes a message to the stream.
Stream.end() Signals to the server that the client has finished sending.

gRPC metrics

k6 takes specific measurements for gRPC requests. For the complete list, refer to the Metrics reference.

Example

{{< code >}}

import grpc from 'k6/net/grpc';
import { check, sleep } from 'k6';

const client = new grpc.Client();
client.load(['definitions'], 'hello.proto');

export default () => {
  client.connect('grpcbin.test.k6.io:9001', {
    // plaintext: false
  });

  const data = { greeting: 'Bert' };
  const response = client.invoke('hello.HelloService/SayHello', data);

  check(response, {
    'status is OK': (r) => r && r.status === grpc.StatusOK,
  });

  console.log(JSON.stringify(response.message));

  client.close();
  sleep(1);
};

{{< /code >}}