spectator-reg-tdigest


License

License

Categories

Categories

Net
GroupId

GroupId

com.netflix.spectator
ArtifactId

ArtifactId

spectator-reg-tdigest
Last Version

Last Version

0.38.1
Release Date

Release Date

Type

Type

jar
Description

Description

spectator-reg-tdigest
spectator-reg-tdigest
Project URL

Project URL

https://github.com/Netflix/spectator
Source Code Management

Source Code Management

https://github.com/Netflix/spectator.git

Download spectator-reg-tdigest

How to add to project

<!-- https://jarcasting.com/artifacts/com.netflix.spectator/spectator-reg-tdigest/ -->
<dependency>
    <groupId>com.netflix.spectator</groupId>
    <artifactId>spectator-reg-tdigest</artifactId>
    <version>0.38.1</version>
</dependency>
// https://jarcasting.com/artifacts/com.netflix.spectator/spectator-reg-tdigest/
implementation 'com.netflix.spectator:spectator-reg-tdigest:0.38.1'
// https://jarcasting.com/artifacts/com.netflix.spectator/spectator-reg-tdigest/
implementation ("com.netflix.spectator:spectator-reg-tdigest:0.38.1")
'com.netflix.spectator:spectator-reg-tdigest:jar:0.38.1'
<dependency org="com.netflix.spectator" name="spectator-reg-tdigest" rev="0.38.1">
  <artifact name="spectator-reg-tdigest" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.netflix.spectator', module='spectator-reg-tdigest', version='0.38.1')
)
libraryDependencies += "com.netflix.spectator" % "spectator-reg-tdigest" % "0.38.1"
[com.netflix.spectator/spectator-reg-tdigest "0.38.1"]

Dependencies

runtime (9)

Group / Artifact Type Version
org.slf4j : slf4j-api jar 1.7.20
com.netflix.spectator : spectator-api jar 0.38.1
com.netflix.spectator : spectator-nflx-plugin jar 0.38.1
com.amazonaws : aws-java-sdk-kinesis jar 1.10.66
com.google.inject : guice jar 4.0
com.fasterxml.jackson.core : jackson-core jar 2.7.2
com.fasterxml.jackson.dataformat : jackson-dataformat-smile jar 2.7.2
com.typesafe : config jar 1.3.0
com.tdunning : t-digest jar 3.1

Project Modules

There are no modules declared in this project.

Spectator

Simple library for instrumenting code to record dimensional time series.

Requirements

  • Java 8 or higher.
  • Java 7 or higher for spectator 0.27.x or earlier.

Documentation

Dependencies

To instrument your code you need to depend on the api library. This provides the minimal interfaces for you to code against and build test cases. The only dependency is slf4j.

com.netflix.spectator:spectator-api:0.101.0

If running at Netflix with the standard platform, see the Netflix Integration page on the wiki.

Instrumenting Code

Suppose we have a server and we want to keep track of:

  • Number of requests received with dimensions for breaking down by status code, country, and the exception type if the request fails in an unexpected way.
  • Latency for handling requests.
  • Summary of the response sizes.
  • Current number of active connections on the server.

Here is some sample code that does that:

// In the application initialization setup a registry
Registry registry = new DefaultRegistry();
Server s = new Server(registry);

public class Server {
  private final Registry registry;
  private final Id requestCountId;
  private final Timer requestLatency;
  private final DistributionSummary responseSizes;

  @Inject
  public Server(Registry registry) {
    this.registry = registry;

    // Create a base id for the request count. The id will get refined with
    // additional dimensions when we receive a request.
    requestCountId = registry.createId("server.requestCount");

    // Create a timer for tracking the latency. The reference can be held onto
    // to avoid additional lookup cost in critical paths.
    requestLatency = registry.timer("server.requestLatency");

    // Create a distribution summary meter for tracking the response sizes.
    responseSizes = registry.distributionSummary("server.responseSizes");

    // Gauge type that can be sampled. In this case it will invoke the
    // specified method via reflection to get the value. The registry will
    // keep a weak reference to the object passed in so that registration will
    // not prevent garbage collection of the server object.
    registry.methodValue("server.numConnections", this, "getNumConnections");
  }

  public Response handle(Request req) {
    final long s = System.nanoTime();
    requestLatency.record(() -> {
      try {
        Response res = doSomething(req);

        // Update the counter id with dimensions based on the request. The
        // counter will then be looked up in the registry which should be
        // fairly cheap, such as lookup of id object in a ConcurrentHashMap.
        // However, it is more expensive than having a local variable set
        // to the counter.
        final Id cntId = requestCountId
          .withTag("country", req.country())
          .withTag("status", res.status());
        registry.counter(cntId).increment();

        responseSizes.record(res.body().size());

        return res;
      } catch (Exception e) {
        final Id cntId = requestCountId
          .withTag("country", req.country())
          .withTag("status", "exception")
          .withTag("error", e.getClass().getSimpleName());
        registry.counter(cntId).increment();
        throw e;
      }
    });
  }

  public int getNumConnections() {
    // however we determine the current number of connections on the server
  }
}
com.netflix.spectator

Netflix, Inc.

Netflix Open Source Platform

Versions

Version
0.38.1
0.38.0
0.37.0
0.36.0
0.35.1
0.35.0
0.34.1
0.33.0
0.30.0
0.29.1
0.29.0
0.28.0
0.27.0
0.26.0
0.25.0
0.24.0
0.23.0
0.22.0
0.21.0