Sha256: c8c5a37504bac40639cfc0970f672e7e053fdc9defffc454dd8dea6c46335c79

Contents?: true

Size: 1.02 KB

Versions: 6

Compression:

Stored size: 1.02 KB

Contents

require 'sqreen/ecosystem/tracing/modules/determine_ip'
require 'sqreen/ecosystem/tracing/signals/tracing_client'
require 'sqreen/ecosystem/loggable'
require 'sqreen/ecosystem/module_api'
require 'sqreen/ecosystem/module_api/tracing'
require 'sqreen/ecosystem/module_api/tracing/client_data'

module Sqreen
  module Ecosystem
    module Tracing
      module Modules
        class Client
          include ModuleApi::Tracing
          include ModuleApi::TracingIdGeneration
          include ModuleApi::Loggable

          consumes    ModuleApi::Tracing::ClientData
          fixed_scope 'client'

          def receive(data)
            signal = Tracing::Signals::TracingClient.new
            signal.payload = Tracing::Signals::TracingClient::Payload.new(
              transport: data.transport,
              host: data.host || '',
              ip: data.ip,
              tracing_identifier: data.tracing_identifier || create_tracing_id
            )

            submit_signal signal
          end
        end
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
sqreen-1.22.0-java lib/sqreen/ecosystem/tracing/modules/client.rb
sqreen-1.22.0 lib/sqreen/ecosystem/tracing/modules/client.rb
sqreen-1.21.1-java lib/sqreen/ecosystem/tracing/modules/client.rb
sqreen-1.21.1 lib/sqreen/ecosystem/tracing/modules/client.rb
sqreen-1.21.0-java lib/sqreen/ecosystem/tracing/modules/client.rb
sqreen-1.21.0 lib/sqreen/ecosystem/tracing/modules/client.rb