Sha256: dac98dbcb59f3efc256b8ef539f3cbb63b11b9cbd54ee542552ab25f3ee86d0e
Contents?: true
Size: 804 Bytes
Versions: 47
Compression:
Stored size: 804 Bytes
Contents
# frozen_string_literal: true
module Rdkafka
class Admin
class CreateAclHandle < AbstractHandle
layout :pending, :bool,
:response, :int,
:response_string, :pointer
# @return [String] the name of the operation
def operation_name
"create acl"
end
# @return [CreateAclReport] instance with rdkafka_response value as 0 and rdkafka_response_string value as empty string if the acl creation was successful
def create_result
CreateAclReport.new(rdkafka_response: self[:response], rdkafka_response_string: self[:response_string])
end
def raise_error
raise RdkafkaError.new(
self[:response],
broker_message: self[:response_string].read_string
)
end
end
end
end
Version data entries
47 entries across 47 versions & 2 rubygems