Sha256: ce5117966fac7dd1c96edb0a8bd65616f3518be97b7115c31d601df44e24935c
Contents?: true
Size: 799 Bytes
Versions: 41
Compression:
Stored size: 799 Bytes
Contents
# frozen_string_literal: true
module Rdkafka
class Admin
class DeleteAclHandle < AbstractHandle
layout :pending, :bool,
:response, :int,
:response_string, :pointer,
:matching_acls, :pointer,
:matching_acls_count, :int
# @return [String] the name of the operation
def operation_name
"delete acl"
end
# @return [DeleteAclReport] instance with an array of matching_acls
def create_result
DeleteAclReport.new(matching_acls: self[:matching_acls], matching_acls_count: self[:matching_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
41 entries across 41 versions & 2 rubygems