Sha256: 9563d0f240fa8d90f74c27b3835448576589c8a5441733e170da70fa42cc163e
Contents?: true
Size: 747 Bytes
Versions: 30
Compression:
Stored size: 747 Bytes
Contents
# frozen_string_literal: true
module Rdkafka
class Admin
class DeleteTopicHandle < AbstractHandle
layout :pending, :bool,
:response, :int,
:error_string, :pointer,
:result_name, :pointer
# @return [String] the name of the operation
def operation_name
"delete topic"
end
# @return [Boolean] whether the delete topic was successful
def create_result
DeleteTopicReport.new(self[:error_string], self[:result_name])
end
def raise_error
raise RdkafkaError.new(
self[:response],
broker_message: DeleteTopicReport.new(self[:error_string], self[:result_name]).error_string
)
end
end
end
end
Version data entries
30 entries across 30 versions & 2 rubygems