Class: Rdkafka::Callbacks::CreateAclResult

Inherits:
Object
  • Object
show all
Defined in:
lib/rdkafka/callbacks.rb

Overview

Extracts attributes of rd_kafka_acl_result_t

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(acl_result_pointer) ⇒ CreateAclResult

Returns a new instance of CreateAclResult.

Parameters:

  • acl_result_pointer (FFI::Pointer) —

    pointer to the ACL result struct



70
71
72
73
74
 
# File 'lib/rdkafka/callbacks.rb', line 70

def initialize(acl_result_pointer)
  rd_kafka_error_pointer = Bindings.rd_kafka_acl_result_error(acl_result_pointer)
  @result_error = Rdkafka::Bindings.rd_kafka_error_code(rd_kafka_error_pointer)
  @error_string = Rdkafka::Bindings.rd_kafka_error_string(rd_kafka_error_pointer)
end

Instance Attribute Details

#error_string ⇒ Object (readonly)

Returns the value of attribute error_string.



67
68
69
 
# File 'lib/rdkafka/callbacks.rb', line 67

def error_string
  @error_string
end

#result_error ⇒ Object (readonly)

Returns the value of attribute result_error.



67
68
69
 
# File 'lib/rdkafka/callbacks.rb', line 67

def result_error
  @result_error
end

Class Method Details

.create_acl_results_from_array(count, array_pointer) ⇒ Array<CreateAclResult>

Returns array of ACL results.

Parameters:

  • count (Integer) —

    number of results

  • array_pointer (FFI::Pointer) —

    pointer to the results array

Returns:



79
80
81
82
83
84
 
# File 'lib/rdkafka/callbacks.rb', line 79

def self.create_acl_results_from_array(count, array_pointer)
  (1..count).map do |index|
    result_pointer = (array_pointer + (index - 1)).read_pointer
    new(result_pointer)
  end
end