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