Sha256: 2861cbd1aec6f259fac67da00e428d7cd0852b42a238dd69c162723f0d840528
Contents?: true
Size: 850 Bytes
Versions: 28
Compression:
Stored size: 850 Bytes
Contents
# frozen_string_literal: true
module Rdkafka
class Admin
class DescribeConfigsHandle < AbstractHandle
layout :pending, :bool,
:response, :int,
:response_string, :pointer,
:config_entries, :pointer,
:entry_count, :int
# @return [String] the name of the operation.
def operation_name
"describe configs"
end
# @return [DescribeAclReport] instance with an array of acls that matches the request filters.
def create_result
DescribeConfigsReport.new(
config_entries: self[:config_entries],
entry_count: self[:entry_count]
)
end
def raise_error
raise RdkafkaError.new(
self[:response],
broker_message: self[:response_string].read_string
)
end
end
end
end
Version data entries
28 entries across 28 versions & 2 rubygems