Sha256: ccb05dea32e2b85f0a723348fdcc292e47370a23f9d9162aa1b0dc4c4c475cf5
Contents?: true
Size: 684 Bytes
Versions: 14
Compression:
Stored size: 684 Bytes
Contents
require 'zeebe/client'
zeebe_client = Zeebe::Client::GatewayProtocol::Gateway::Stub.new('localhost:26500', :this_channel_is_insecure)
topology = zeebe_client.topology(Zeebe::Client::GatewayProtocol::TopologyRequest.new)
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}"
Version data entries
14 entries across 14 versions & 1 rubygems