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
ᕙ(⇀‸↼‶)ᕗ | |
[2017-10-31T15:47:21,738][ERROR][logstash.outputs.rabbitmq] Error while publishing. Will retry. {:message=>"MarchHare::ChannelAlreadyClosed", :exception=>MarchHare::ChannelAlreadyClosed, :backtrace=>["/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/exceptions.rb:121:in `convert_and_reraise'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/channel.rb:980:in `converting_rjc_exceptions_to_ruby'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/channel.rb:978:in `converting_rjc_exceptions_to_ruby'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/channel.rb:606:in `basic_publish'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/exchange.rb:77:in `publish'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-rabbitmq-4.0.11-java/lib/logstash/outputs/rabbitmq.rb:62:in `publish'", "org/jruby/RubyPr |
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
ᕙ(⇀‸↼‶)ᕗ | |
[2017-10-31T15:47:21,738][ERROR][logstash.outputs.rabbitmq] Error while publishing. Will retry. {:message=>"MarchHare::ChannelAlreadyClosed", :exception=>MarchHare::ChannelAlreadyClosed, :backtrace=>["/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/exceptions.rb:121:in `convert_and_reraise'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/channel.rb:980:in `converting_rjc_exceptions_to_ruby'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/channel.rb:978:in `converting_rjc_exceptions_to_ruby'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/channel.rb:606:in `basic_publish'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/exchange.rb:77:in `publish'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-rabbitmq-4.0.11-java/lib/logstash/outputs/rabbitmq.rb:62:in `publish'", "org/jruby/RubyPr |
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
Without circular ref | |
client.choria -> nats1.fed | |
nats3.fed -> fb builder:1 -> nats2.choria | |
nats1.choria -> dev1-0.choria -> nats1.choria | |
nats3.choria -> fb builder:2 -> nats2.fed | |
nats1.fed -> client.choria | |
With circular 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
--- | |
functions: | |
json_decode: | |
function: wishbone.function.decode.json | |
uppercase: | |
function: wishbone.function.process.uppercase | |
arguments: | |
source: "@data.value" | |
destination: "@data.value" |
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
#!/usr/bin/python | |
from testlap import TestLap | |
class DictEval(): | |
''' | |
eval() a dict string into an actual dict object | |
''' | |
def __init__(self): |
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
#!/usr/bin/env python | |
# -*- coding: utf-8 -*- | |
# | |
import json | |
from jsonschema import validate | |
class Greeting(object): |
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
from wishbone.module.testevent import TestEvent | |
from wishbone.module.stdout import STDOUT | |
from wishbone.router import Default | |
from wishbone.actor import ActorConfig | |
input_config = ActorConfig("input") | |
output_config = ActorConfig("output") | |
router = Default() | |
router.registerModule(TestEvent, input_config, {"message": "Hello world!"}) |
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
--- | |
lookups: | |
event: | |
module: wishbone.lookup.event | |
modules: | |
input: | |
module: wishbone.input.twitter | |
description: Collects events of the authenticated user | |
arguments: |
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
--- | |
modules: | |
input: | |
module: wishbone.input.hammer | |
arguments: | |
batch_size: 100 | |
set_size: 100 | |
graphite: | |
module: wishbone.encode.graphite |
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
modules: | |
input: | |
module: wishbone.input.httpserver | |
fresh: | |
module: wishbone.flow.fresh | |
arguments: | |
timeout: 120 | |
timeout_payload: | |
service_key: abcdefghijklmnopqrstuvwxyz |