Class: Smplkit::ManagementClient::LoggersNamespace

Inherits:

Object

• Object
• Smplkit::ManagementClient::LoggersNamespace

Defined in:

lib/smplkit/management/client.rb

Instance Method Summary

• #_update_logger(logger) ⇒ Object
• #delete(id) ⇒ Object
• #flush ⇒ Object
• #get(id) ⇒ Object
• #initialize(api_client) ⇒ LoggersNamespace constructor

  A new instance of LoggersNamespace.

• #list(page_number: nil, page_size: nil) ⇒ Object
• #register(source) ⇒ Object

Constructor Details

#initialize(api_client) ⇒ LoggersNamespace

Returns a new instance of LoggersNamespace.

# File 'lib/smplkit/management/client.rb', line 762

def initialize(api_client)
  @api = SmplkitGeneratedClient::Logging::LoggersApi.new(api_client)
  @buffer = Management::LoggerRegistrationBuffer.new
end

Instance Method Details

#_update_logger(logger) ⇒ Object

# File 'lib/smplkit/management/client.rb', line 814

def _update_logger(logger)
  response = ErrorMapping.call { @api.update_logger(logger.id || logger.name, logger_body(logger)) }
  Smplkit::Logging::Helpers.logger_resource_to_model(self, ResourceShim.from_model(response.data))
end

#delete(id) ⇒ Object

# File 'lib/smplkit/management/client.rb', line 808

def delete(id)
  normalized = Smplkit::Logging::Normalize.normalize_logger_name(id)
  ErrorMapping.call { @api.delete_logger(normalized) }
  true
end

#flush ⇒ Object

# File 'lib/smplkit/management/client.rb', line 773

def flush
  batch = @buffer.drain
  return if batch.empty?

  items = batch.map do |entry|
    SmplkitGeneratedClient::Logging::LoggerBulkItem.new(
      id: entry["id"],
      resolved_level: entry["resolved_level"],
      level: entry["level"],
      service: entry["service"],
      environment: entry["environment"]
    )
  end
  body = SmplkitGeneratedClient::Logging::LoggerBulkRequest.new(loggers: items)
  ErrorMapping.call { @api.bulk_register_loggers(body) }
rescue StandardError => e
  Smplkit.debug("registration", "logger flush failed: #{e.class}: #{e.message}")
end

#get(id) ⇒ Object

# File 'lib/smplkit/management/client.rb', line 802

def get(id)
  normalized = Smplkit::Logging::Normalize.normalize_logger_name(id)
  response = ErrorMapping.call { @api.get_logger(normalized) }
  Smplkit::Logging::Helpers.logger_resource_to_model(self, ResourceShim.from_model(response.data))
end

#list(page_number: nil, page_size: nil) ⇒ Object

# File 'lib/smplkit/management/client.rb', line 792

def list(page_number: nil, page_size: nil)
  opts = {}
  opts[:page_number] = page_number unless page_number.nil?
  opts[:page_size] = page_size unless page_size.nil?
  response = ErrorMapping.call { @api.list_loggers(opts) }
  (response.data || []).map do |r|
    Smplkit::Logging::Helpers.logger_resource_to_model(self, ResourceShim.from_model(r))
  end
end

#register(source) ⇒ Object

# File 'lib/smplkit/management/client.rb', line 767

def register(source)
  sources = source.is_a?(Array) ? source : [source]
  sources.each { |s| @buffer.add(s) }
  flush if @buffer.pending_count >= Management::LOGGER_BATCH_FLUSH_SIZE
end