Class: PulsarSdk::Protocol::Namespace

Inherits:
Object
  • Object
show all
Defined in:
lib/pulsar_sdk/protocol/namespace.rb

Instance Method Summary collapse

Constructor Details

#initialize(client) ⇒ Namespace

Returns a new instance of Namespace.



4
5
6
 
# File 'lib/pulsar_sdk/protocol/namespace.rb', line 4

def initialize(client)
  @client = client
end

Instance Method Details

#topics(namespace) ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
 
# 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