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

Version	Path
karafka-rdkafka-0.14.1	lib/rdkafka/admin/delete_acl_handle.rb