class PulsarSdk::Protocol::Namespace
Public Class Methods
new(client)
click to toggle source
# File lib/pulsar_sdk/protocol/namespace.rb, line 4 def initialize(client) @client = client end
Public Instance Methods
topics(namespace)
click to toggle source
# File lib/pulsar_sdk/protocol/namespace.rb, line 8 def topics(namespace) base_cmd = Pulsar::Proto::BaseCommand.new( type: Pulsar::Proto::BaseCommand::Type::GET_TOPICS_OF_NAMESPACE, getTopicsOfNamespace: Pulsar::Proto::CommandGetTopicsOfNamespace.new( namespace: namespace, mode: Pulsar::Proto::CommandGetTopicsOfNamespace::Mode.resolve(:ALL) ) ) resp = @client.request_any_broker(base_cmd) resp.getTopicsOfNamespaceResponse&.topics end