File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -513,12 +513,12 @@ def send_dsm_payload(data, headers)
513513 # Create HTTP request to DSM endpoint
514514 agent_host = Datadog . configuration . agent . host || 'localhost'
515515 agent_port = Datadog . configuration . agent . port || 8126
516- uri = URI ( "http:// #{ agent_host } : #{ agent_port } / v0.1/pipeline_stats" )
516+ path = '/ v0.1/pipeline_stats'
517517
518- http = Net ::HTTP . new ( uri . host , uri . port )
518+ http = Net ::HTTP . new ( agent_host , agent_port )
519519 http . use_ssl = false
520520
521- request = Net ::HTTP ::Post . new ( uri )
521+ request = Net ::HTTP ::Post . new ( path )
522522 headers . each { |k , v | request [ k ] = v }
523523
524524 # Set binary data with proper encoding
Original file line number Diff line number Diff line change @@ -39,6 +39,7 @@ module Datadog
3939
4040 def decode_pathway_b64 : (::String encoded_ctx) -> PathwayContext?
4141 def perform : () -> (bool | nil )
42+ def flush_stats : () -> void
4243
4344 def get_current_pathway : () -> PathwayContext?
4445 def stop : (?bool force_stop, ?::Integer timeout) -> void
You can’t perform that action at this time.
0 commit comments