Sha256: 359e97817cb4b993113bdc9b8fb42e022a5135764b1257bca0fb094e424b6861
Contents?: true
Size: 875 Bytes
Versions: 31
Compression:
Stored size: 875 Bytes
Contents
# frozen_string_literal: true
module Rdkafka
class Admin
class IncrementalAlterConfigsHandle < 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
"incremental alter configs"
end
# @return [DescribeAclReport] instance with an array of acls that matches the request filters.
def create_result
IncrementalAlterConfigsReport.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
31 entries across 31 versions & 2 rubygems