This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/lib/handsoap/service.rb b/lib/handsoap/service.rb | |
index 278f761..84ffef1 100644 | |
--- a/lib/handsoap/service.rb | |
+++ b/lib/handsoap/service.rb | |
@@ -36,8 +36,9 @@ module Handsoap | |
SOAP_NAMESPACE = { 1 => 'http://schemas.xmlsoap.org/soap/envelope/', 2 => 'http://www.w3.org/2001/12/soap-encoding' } | |
class Response | |
- def initialize(http_body, soap_namespace) | |
+ def initialize(http_body, http_headers, soap_namespace) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/lib/handsoap/service.rb b/lib/handsoap/service.rb | |
index 278f761..84ffef1 100644 | |
--- a/lib/handsoap/service.rb | |
+++ b/lib/handsoap/service.rb | |
@@ -36,8 +36,9 @@ module Handsoap | |
SOAP_NAMESPACE = { 1 => 'http://schemas.xmlsoap.org/soap/envelope/', 2 => 'http://www.w3.org/2001/12/soap-encoding' } | |
class Response | |
- def initialize(http_body, soap_namespace) | |
+ def initialize(http_body, http_headers, soap_namespace) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/lib/handsoap/service.rb b/lib/handsoap/service.rb | |
index 278f761..65bcf02 100644 | |
--- a/lib/handsoap/service.rb | |
+++ b/lib/handsoap/service.rb | |
@@ -36,8 +36,9 @@ module Handsoap | |
SOAP_NAMESPACE = { 1 => 'http://schemas.xmlsoap.org/soap/envelope/', 2 => 'http://www.w3.org/2001/12/soap-encoding' } | |
class Response | |
- def initialize(http_body, soap_namespace) | |
+ def initialize(http_body, http_headers, soap_namespace) |
This file has been truncated, but you can view the full file.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
--- | |
ActionParameter: | |
kind: enum | |
values: | |
- targetName | |
- alarmName | |
- oldStatus | |
- newStatus | |
- triggeringSummary | |
- declaringSummary |
This file has been truncated, but you can view the full file.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
--- | |
ActionParameter: | |
kind: enum | |
values: | |
- targetName | |
- alarmName | |
- oldStatus | |
- newStatus | |
- triggeringSummary | |
- declaringSummary |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2380c2380 | |
< version-id-ref: | |
--- | |
> version-id-ref: vim.version.version5 | |
2398c2398 | |
< version-id-ref: | |
--- | |
> version-id-ref: vim.version.version5 | |
2429c2429 | |
< version-id-ref: |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
vms | broker rss | broker pss | core rss | core pss | |
---|---|---|---|---|---|
512 | 617373696 | 466311000 | 410808320 | 240913000 | |
512 | 627089408 | 475305000 | 411824128 | 241698000 | |
512 | 629538816 | 474907000 | 417386496 | 243138000 | |
1024 | 724451328 | 576678000 | 417533952 | 275404000 | |
1024 | 721645568 | 568973000 | 420847616 | 272733000 | |
1024 | 719630336 | 571175000 | 435142656 | 287623000 | |
2048 | 823386112 | 665574000 | 456396800 | 313372000 | |
2048 | 790781952 | 637716000 | 450441216 | 313120000 | |
2048 | 802078720 | 646835000 | 448385024 | 308714000 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
vms | cache | no cache | |
---|---|---|---|
2048 | 1332331000 | 1232292000 | |
2048 | 1327165000 | 1156366000 | |
2048 | 1359262000 | 1272160000 | |
2048 | 1341953000 | 1205501000 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
require 'kafka' | |
$producer = Kafka.new(seed_brokers: ['localhost:9092']).producer | |
def send_or_update(ems, persister, count, batch_size) | |
if count == :rest || count > batch_size | |
inventory_yaml = persister.to_yaml | |
puts "sending inventory to kafka, #{inventory_yaml.size} bytes" | |
$producer.produce(inventory_yaml, topic: 'inventory') |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
require 'kafka' | |
kafka = Kafka.new( | |
seed_brokers: ["0.0.0.0:9092"], | |
client_id: "miq-persistor" | |
) | |
consumer = kafka.consumer(group_id: "miq-persisters") | |
consumer.subscribe("inventory") | |
consumer.each_message do |message| |
OlderNewer