Sha256: 94bea837928b3a6853655043101f86921d477051ad92b92ab0388796bba35cb2
Contents?: true
Size: 647 Bytes
Versions: 41
Compression:
Stored size: 647 Bytes
Contents
# frozen_string_literal: true
module Rdkafka
class Admin
class DeleteGroupsHandle < AbstractHandle
layout :pending, :bool, # TODO: ???
:response, :int,
:error_string, :pointer,
:result_name, :pointer
# @return [String] the name of the operation
def operation_name
"delete groups"
end
def create_result
DeleteGroupsReport.new(self[:error_string], self[:result_name])
end
def raise_error
raise RdkafkaError.new(
self[:response],
broker_message: create_result.error_string
)
end
end
end
end
Version data entries
41 entries across 41 versions & 2 rubygems