Skip to content

Latest commit

 

History

History

remotetapprocessor

Remote Tap Processor

Status
Stability alpha: logs, metrics, traces
Distributions contrib
Issues Open issues Closed issues
Code Owners @atoulme
Emeritus @pmcollins

The Remote Tap processor, which can be positioned anywhere in a pipeline, allows data to pass through to the next component. Simultaneously, it makes a portion of the data accessible to WebSocket clients connecting on a configurable port. This functionality resembles that of the Unix tee command, which enables data to flow through while duplicating and redirecting it for inspection.

To avoid overloading clients, the amount of telemetry duplicated over any open WebSockets is rate limited by an adjustable amount.

Config

The Remote Tap processor has two configurable fields: endpoint and limit:

  • endpoint: The endpoint on which the WebSocket processor listens. Optional. Defaults to 0.0.0.0:12001. The component.UseLocalHostAsDefaultHost feature gate changes this to localhost:12001. This will become the default in a future release.

  • limit: The rate limit over the WebSocket in messages per second. Can be a float or an integer. Optional. Defaults to 1.

Example configuration:

processors:
  remotetap:
    endpoint: 0.0.0.0:12001
    limit: 1 # rate limit 1 msg/sec