Sha256: 3046902789b09d9f01883ecefb9a6593e61c0fa27a09bc2ec0c830d0bb3c3e6d
Contents?: true
Size: 1.2 KB
Versions: 10
Compression:
Stored size: 1.2 KB
Contents
# typed: ignore
# Copyright (c) 2015 Sqreen. All Rights Reserved.
# Please refer to our terms for more information: https://www.sqreen.com/terms.html
require 'sqreen/ecosystem/tracing/modules/determine_ip'
require 'sqreen/ecosystem/tracing/signals/tracing_producer'
require 'sqreen/ecosystem/module_api'
require 'sqreen/ecosystem/module_api/tracing/producer_data'
module Sqreen
module Ecosystem
module Tracing
module Modules
class Producer
include ModuleApi::Tracing
include ModuleApi::TracingIdGeneration
include ModuleApi::Loggable
consumes ModuleApi::Tracing::ProducerData
fixed_scope 'producer'
# @param [ModuleApi::Tracing::ProducerData] data
def receive(data)
signal = Tracing::Signals::TracingProducer.new
signal.payload = Tracing::Signals::TracingProducer::Payload.new(
message_type: data.message_type,
host: data.host || '',
ip: data.ip,
topic: data.topic,
tracing_identifier: data.tracing_identifier || create_tracing_id
)
submit_signal signal
end
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems