Method: Scalyr::Common::Client::ClientSession#initialize

Defined in:
lib/scalyr/common/client.rb

#initialize(logger, add_events_uri, compression_type, compression_level, ssl_verify_peer, ssl_ca_bundle_path, append_builtin_cert, record_stats_for_status, flush_quantile_estimates_on_status_send, connect_timeout, socket_timeout, request_timeout, pool_max, pool_max_per_route) ⇒ ClientSession

Returns a new instance of ClientSession.



59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
 
# File 'lib/scalyr/common/client.rb', line 59

def initialize(logger, add_events_uri, compression_type, compression_level,
               ssl_verify_peer, ssl_ca_bundle_path, append_builtin_cert,
               record_stats_for_status, flush_quantile_estimates_on_status_send,
               connect_timeout, socket_timeout, request_timeout, pool_max, pool_max_per_route)
  @logger = logger
  @add_events_uri = add_events_uri  # typically /addEvents
  @compression_type = compression_type
  @compression_level = compression_level
  @ssl_verify_peer = ssl_verify_peer
  @ssl_ca_bundle_path = ssl_ca_bundle_path
  @append_builtin_cert = append_builtin_cert
  @record_stats_for_status = record_stats_for_status
  @flush_quantile_estimates_on_status_send = flush_quantile_estimates_on_status_send
  @connect_timeout = connect_timeout
  @socket_timeout = socket_timeout
  @request_timeout = request_timeout
  @pool_max = pool_max
  @pool_max_per_route = pool_max_per_route

  # A cert to use by default to avoid issues caused by the OpenSSL library not validating certs according to standard
  @cert_string = CA_CERT_STRING

  # Request statistics are accumulated across multiple threads and must be accessed through a mutex
  @stats_lock = Mutex.new
  @latency_stats = get_new_latency_stats
  @stats = {
      :total_requests_sent => 0, # The total number of RPC requests sent.
      :total_requests_failed => 0, # The total number of RPC requests that failed.
      :total_request_bytes_sent => 0, # The total number of bytes sent over the network.
      :total_compressed_request_bytes_sent => 0,  # The total number of compressed bytes sent over the network
      :total_response_bytes_received => 0,  # The total number of bytes received.
      :total_request_latency_secs => 0, #  The total number of secs spent waiting for a responses (so average latency
      # can be calculated by dividing this number by @total_requests_sent).
      # This includes connection establishment time.
      :total_serialization_duration_secs => 0, # The total duration (in seconds) it took to serialize (JSON dumos) all the request bodies.
      # You can calculate avg compression duration by diving this value with total_requests_sent
      :total_compression_duration_secs => 0, # The total duration (in seconds) it took to compress all the request bodies.
      # You can calculate avg compression duration by diving this value with total_requests_sent
      :compression_type => @compression_type,
      :compression_level => @compression_level,
  }
end