Class: Rdkafka::Admin::DescribeConfigsHandle

Inherits:
Rdkafka::AbstractHandle show all
Defined in:
lib/rdkafka/admin/describe_configs_handle.rb

Constant Summary

Constants inherited from Rdkafka::AbstractHandle

Rdkafka::AbstractHandle::REGISTRY

Instance Method Summary collapse

Methods inherited from Rdkafka::AbstractHandle

#initialize, #pending?, register, remove, #unlock, #wait

Methods included from Helpers::Time

#monotonic_now

Constructor Details

This class inherits a constructor from Rdkafka::AbstractHandle

Instance Method Details

#create_result ⇒ DescribeAclReport

Returns instance with an array of acls that matches the request filters.

Returns:

  • (DescribeAclReport) —

    instance with an array of acls that matches the request filters.



18
19
20
21
22
23
 
# File 'lib/rdkafka/admin/describe_configs_handle.rb', line 18

def create_result
  DescribeConfigsReport.new(
    config_entries: self[:config_entries],
    entry_count: self[:entry_count]
  )
end

#operation_name ⇒ String

Returns the name of the operation.

Returns:

  • (String) —

    the name of the operation.



13
14
15
 
# File 'lib/rdkafka/admin/describe_configs_handle.rb', line 13

def operation_name
  "describe configs"
end

#raise_error ⇒ Object

Raises:



25
26
27
28
29
30
 
# File 'lib/rdkafka/admin/describe_configs_handle.rb', line 25

def raise_error
  raise RdkafkaError.new(
    self[:response],
    broker_message: self[:response_string].read_string
  )
end