Contents

# typed: false
require 'ddtrace/contrib/analytics'
require 'ddtrace/contrib/action_cable/event'

module Datadog
  module Contrib
    module ActionCable
      module Events
        # Defines instrumentation for 'broadcast.action_cable' event.
        #
        # A single 'broadcast' event will trigger as many 'transmit' events
        # as there are clients subscribed to a channel.
        module Broadcast
          include ActionCable::Event

          EVENT_NAME = 'broadcast.action_cable'.freeze

          module_function

          def event_name
            self::EVENT_NAME
          end

          def span_name
            Ext::SPAN_BROADCAST
          end

          def span_type
            # Starts a broadcast of messages over WebSockets
            Datadog::Ext::AppTypes::WEB
          end

          def process(span, _event, _id, payload)
            channel = payload[:broadcasting] # Channel has high cardinality
            span.service = configuration[:service_name]
            span.span_type = span_type

            # Set analytics sample rate
            if Contrib::Analytics.enabled?(configuration[:analytics_enabled])
              Contrib::Analytics.set_sample_rate(span, configuration[:analytics_sample_rate])
            end

            span.set_tag(Ext::TAG_CHANNEL, channel)
            span.set_tag(Ext::TAG_BROADCAST_CODER, payload[:coder])
          end
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
ddtrace-0.54.2	lib/ddtrace/contrib/action_cable/events/broadcast.rb
ddtrace-0.54.1	lib/ddtrace/contrib/action_cable/events/broadcast.rb
ddtrace-0.54.0	lib/ddtrace/contrib/action_cable/events/broadcast.rb
ddtrace-0.53.0	lib/ddtrace/contrib/action_cable/events/broadcast.rb
ddtrace-0.52.0	lib/ddtrace/contrib/action_cable/events/broadcast.rb