Class: Rdkafka::Admin::CreateAclHandle

Inherits:
Rdkafka::AbstractHandle show all
Defined in:
lib/rdkafka/admin/create_acl_handle.rb

Constant Summary

Constants inherited from Rdkafka::AbstractHandle

Rdkafka::AbstractHandle::REGISTRY

Instance Method Summary collapse

Methods inherited from Rdkafka::AbstractHandle

#pending?, register, remove, #wait

Methods included from Helpers::Time

#monotonic_now

Instance Method Details

#create_result ⇒ CreateAclReport

Returns instance with rdkafka_response value as 0 and rdkafka_response_string value as empty string if the acl creation was successful.

Returns:

  • (CreateAclReport) —

    instance with rdkafka_response value as 0 and rdkafka_response_string value as empty string if the acl creation was successful



16
17
18
 
# File 'lib/rdkafka/admin/create_acl_handle.rb', line 16

def create_result
  CreateAclReport.new(rdkafka_response: self[:response], rdkafka_response_string: self[:response_string])
end

#operation_name ⇒ String

Returns the name of the operation.

Returns:

  • (String) —

    the name of the operation



11
12
13
 
# File 'lib/rdkafka/admin/create_acl_handle.rb', line 11

def operation_name
  "create acl"
end

#raise_error ⇒ Object

Raises:



20
21
22
23
24
25
 
# File 'lib/rdkafka/admin/create_acl_handle.rb', line 20

def raise_error
  raise RdkafkaError.new(
      self[:response],
      broker_message: self[:response_string].read_string
  )
end