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