Class: Rdkafka::Admin::DeleteGroupsHandle

Inherits:

Rdkafka::AbstractHandle

• Object
• FFI::Struct
• Rdkafka::AbstractHandle
• Rdkafka::Admin::DeleteGroupsHandle

Defined in:

lib/rdkafka/admin/delete_groups_handle.rb

Overview

Handle for delete groups operation

Constant Summary

Constants inherited from Rdkafka::AbstractHandle

Rdkafka::AbstractHandle::REGISTRY

Instance Method Summary

• #create_result ⇒ DeleteGroupsReport

  Creates the result report.

• #operation_name ⇒ String

  The name of the operation.

• #raise_error ⇒ Object

  Raises an error if the operation failed.

Methods inherited from Rdkafka::AbstractHandle

#initialize, #pending?, register, remove, #unlock, #wait

Methods included from Helpers::Time

#monotonic_now, #monotonic_now_ms

Constructor Details

This class inherits a constructor from Rdkafka::AbstractHandle

Instance Method Details

#create_result ⇒ DeleteGroupsReport

Creates the result report

Returns:

• (DeleteGroupsReport)

# File 'lib/rdkafka/admin/delete_groups_handle.rb', line 19

def create_result
  DeleteGroupsReport.new(self[:error_string], self[:result_name])
end

#operation_name ⇒ String

Returns the name of the operation.

Returns:

• (String) —

  the name of the operation

# File 'lib/rdkafka/admin/delete_groups_handle.rb', line 13

def operation_name
  "delete groups"
end

#raise_error ⇒ Object

Raises an error if the operation failed

Raises:

• (RdkafkaError)

# File 'lib/rdkafka/admin/delete_groups_handle.rb', line 25

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