OBSOLETE CF component to forward metrics from the Loggregator Firehose to DataDog
Go Other
Switch branches/tags
Nothing to show
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Failed to load latest commit information.
datadogclient Discard large metrics Jan 9, 2017
lattice Use correct lattice TC url Jul 27, 2015
logger Adds gosteno logger Apr 21, 2016
testhelpers Use new noaa RetryError Oct 10, 2016
uaatokenfetcher Uses gosteno logger for UaaTokenFetcher. Apr 26, 2016
.gitignore Add script to run unit tests and static analysis Apr 16, 2015
LICENSE Remove appendix from LICENSE Jan 13, 2017



Build Status Coverage Status

This component has been moved to DataDog/datadog-firehose-nozzle.

Additionally, the blobs for this release are no longer available. You should not expect to be able to deploy this release.

The datadog-firehose-nozzle is a CF component which forwards metrics from the Loggregator Firehose to Datadog

Configure CloudFoundry UAA for Firehose Nozzle

The datadog firehose nozzle requires a UAA user who is authorized to access the loggregator firehose. You can add a user by editing your CloudFoundry manifest to include the details about this user under the properties.uaa.clients section. For example to add a user datadog-firehose-nozzle:

        access-token-validity: 1209600
        authorized-grant-types: authorization_code,client_credentials,refresh_token
        override: true
        secret: <password>
        scope: openid,oauth.approvals,doppler.firehose
        authorities: oauth.login,doppler.firehose


The datadog nozzle uses a configuration file to obtain the firehose URL, datadog API key and other configuration parameters. The firehose and the datadog servers both require authentication -- the firehose requires a valid username/password and datadog requires a valid API key.

You can start the firehose nozzle by executing:

go run main.go -config config/datadog-firehose-nozzle.json"


The configuration file specifies the interval at which the nozzle will flush metrics to datadog. By default this is set to 15 seconds.


For the most part, the datadog-firehose-nozzle forwards metrics from the loggregator firehose to datadog without too much processing. A notable exception is the datadog.nozzle.slowConsumerAlert metric. The metric is a binary value (0 or 1) indicating whether or not the nozzle is forwarding metrics to datadog at the same rate that it is receiving them from the firehose: 0 means the the nozzle is keeping up with the firehose, and 1 means that the nozzle is falling behind.

The nozzle determines the value of datadog.nozzle.slowConsumerAlert with the following rules:

  1. When the nozzle receives a websocket Close frame with status 1008, it publishes the value 1. Traffic Controller pings clients to determine if the connections are still alive. If it does not receive a Pong response before the KeepAlive deadline, it decides that the connection is too slow (or even dead) and sends the Close frame.

  2. Otherwise, the nozzle publishes 0.


You need ginkgo to run the tests. The tests can be executed by:

ginkgo -r



There is a bosh release that will configure, start and monitor the datadog nozzle: https://github.com/cloudfoundry-incubator/datadog-firehose-nozzle-release


There is a docker image which can be used to deploy the datadog nozzle to lattice. If you are running lattice locally with Vagrant, you can use the following command line to start the nozzle:

ltc create datadog-nozzle cloudfoundry/datadog-nozzle-lattice \

The API KEY is your datadog API key used to publish metrics. The METRIC PREFIX gets prepended to all metric names going through the nozzle.

The docker image runs the nozzle with the config provided in lattice/lattice-datadog-firehose-nozzle.json. If you are not running lattice locally you will have to also configure the traffic controller URL

ltc create datadog-nozzle cloudfoundry/datadog-nozzle-lattice \

Any of the configuration parameters can be overloaded by using environment variables. The following parameters are supported

Environment variable Description
NOZZLE_UAAURL UAA URL which the nozzle uses to get an authentication token for the firehose
NOZZLE_CLIENT Client who has access to the firehose
NOZZLE_CLIENT_SECRET Secret for the client
NOZZLE_TRAFFICCONTROLLERURL Loggregator's traffic controller URL
NOZZLE_FIREHOSESUBSCRIPTIONID Subscription ID used when connecting to the firehose. Nozzles with the same subscription ID get a proportional share of the firehose
NOZZLE_DATADOGAPIKEY The API key used when publishing metrics to datadog
NOZZLE_DATADOGTIMEOUTSECONDS The number of seconds to set the timeout for writes to Datadog
NOZZLE_METRICPREFIX The metric prefix is prepended to all metrics flowing through the nozzle
NOZZLE_DEPLOYMENT The deployment name for the nozzle. Used for tagging metrics internal to the nozzle
NOZZLE_DEPLOYMENT_FILTER If set, the nozzle will only send metrics with this deployment name
NOZZLE_FLUSHDURATIONSECONDS Number of seconds to buffer data before publishing to Datadog
NOZZLE_INSECURESSLSKIPVERIFY If true, allows insecure connections to the UAA and the Trafficcontroller
NOZZLE_DISABLEACCESSCONTROL If true, disables authentication with the UAA. Used in lattice deployments


The concourse pipeline for the datadog nozzle is present here