Class: Rage::Telemetry::Spans::BroadcastSSEStream

Inherits:

Object

• Object
• Rage::Telemetry::Spans::BroadcastSSEStream

Defined in:

lib/rage/telemetry/spans/broadcast_sse_stream.rb

Overview

The sse.stream.broadcast span wraps the process of broadcasting a message to an unbounded SSE stream.

This span is started when Rage::SSE.broadcast is called, and ends when the broadcast operation is complete. See handle for the list of arguments passed to handler methods.

See Also:

• Rage::Telemetry::Handler

Class Method Summary

• .handle(id:, name:, stream:) ⇒ Object

Class Method Details

.handle(id:, name:, stream:) ⇒ Object

Note:

Rage automatically detects which parameters your handler method accepts and only passes those parameters. You can omit any of the parameters described here.

Examples:

class MyTelemetryHandler < Rage::Telemetry::Handler
  handle "sse.stream.broadcast", with: :my_handler

  def my_handler(id:, name:, stream:)
    yield
  end
end

Parameters:

• id ("sse.stream.broadcast") —

  ID of the span

• name ("Rage::SSE.broadcast") —

  human-readable name of the operation

• stream (Object) —

  the identifier of the stream to which the message is being broadcasted

Yield Returns:

• (Rage::Telemetry::SpanResult)

# File 'lib/rage/telemetry/spans/broadcast_sse_stream.rb', line 16

def handle(id:, name:, stream:)
end