examples/demo.rb in zeebe-client-0.0.1 vs examples/demo.rb in zeebe-client-0.1.0

- old
+ new

@@ -1,8 +1,20 @@ require 'zeebe/client' -stub = Zeebe::Client::GatewayProtocol::Gateway::Stub.new('localhost:26500', :this_channel_is_insecure) +zeebe_client = Zeebe::Client::GatewayProtocol::Gateway::Stub.new('localhost:26500', :this_channel_is_insecure) -puts stub.topology(Zeebe::Client::GatewayProtocol::TopologyRequest.new).inspect +topology = zeebe_client.topology(Zeebe::Client::GatewayProtocol::TopologyRequest.new) -puts stub.list_workflows(Zeebe::Client::GatewayProtocol::ListWorkflowsRequest.new).inspect +puts "Zeebe topology:" +puts " Cluster size: #{topology.clusterSize}" +puts " Replication factor: #{topology.replicationFactor}" +puts " Brokers:" + +topology.brokers.each do |b| + puts " - id: #{b.nodeId}, address: #{b.host}:#{b.port}, partitions: #{b.partitions.map { |p| p.partitionId }}" +end + +workflows = zeebe_client.list_workflows(Zeebe::Client::GatewayProtocol::ListWorkflowsRequest.new).workflows + +puts "" +puts "Zeebe workflows: #{workflows.inspect}"