Skip to content

Instantly share code, notes, and snippets.

@guyboertje
guyboertje / log-sample.xml
Created January 31, 2019 14:29
Logstash xml file processing
<?xml version="1.0" encoding="UTF-8" ?>
<ExecutionLogModel>
<LogEvent level="INFO" time="2018-07-10T04:12:26Z" shapename="initializing..." shapetype="initializing..." shapelabel="" shapeextendedinfo="">
<Message>Executing Process Performance Management- Past(Child)-STAGE (Continuation f_0_0)</Message>
</LogEvent>
<LogEvent level="INFO" time="2018-07-10T04:12:26Z" shapename="shape10" shapetype="Try/Catch" shapelabel="" shapeextendedinfo="">
<Message>Executing Try/Catch Shape continuation as f_0_0 with 1 document(s).</Message>
</LogEvent>
<LogEvent level="INFO" time="2018-07-10T04:12:26Z" shapename="shape10" shapetype="Try/Catch" shapelabel="" shapeextendedinfo="">
<Message>Shape executed successfully in 82 ms.</Message>
@guyboertje
guyboertje / queue.rake
Created December 1, 2016 09:49
rakelib/queue.rake
namespace "queue" do
desc "print out contents of checkpoint file (specify path)"
task "print-checkpoint", [:ckpfile] do |t, args|
bin = IO.read(args.ckpfile, mode: "rb")
# + Short.BYTES // version 16 bits
# + Integer.BYTES // pageNum 32 bits
# + Integer.BYTES // firstUnackedPageNum 32 bits
# + Long.BYTES // firstUnackedSeqNum 64 bits
# + Long.BYTES // minSeqNum 64 bits
# + Integer.BYTES // eventCount 32 bits
def enqueue(event)
q1 = SizedQueue.new(1)
tt = Thread.new(q1) do |q|
sleep 5
q.push 42
end
wt = Thread.new(q1) do |q|
@otherqueue.push event
# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
require "logstash/filters/translate"
describe LogStash::Filters::Translate do
let(:config) { Hash.new }
subject { described_class.new(config) }
describe "exact translation" do
@guyboertje
guyboertje / gist:3788293
Created September 26, 2012 14:13
virtus hacks console output
h = {description: 'blah', id: '1046d670-e9ff-012f-5d84-38f6b11b6fe1', images: [1,2,3], name: 'bob', owner_id: '1005bc90-e9ff-012f-5d84-38f6b11b6fe1', creating_user_id: '1005bb10-e9ff-012f-5d84-38f6b11b6fe1', summary: 'aasdasd', tags: [1,2,3], upc: 333222}
=> {:description=>"blah", :id=>"1046d670-e9ff-012f-5d84-38f6b11b6fe1", :images=>[1, 2, 3], :name=>"bob", :owner_id=>"1005bc90-e9ff-012f-5d84-38f6b11b6fe1", :creating_user_id=>"1005bb10-e9ff-012f-5d84-38f6b11b6fe1", :summary=>"aasdasd", :tags=>[1, 2, 3], :upc=>333222}
1.9.3p194 :002 > h[:digital_commodities] = [{asset_id: '1046e450-e9ff-012f-5d84-38f6b11b6fe1', commodity_id: '10552d90-e9ff-012f-5d84-38f6b11b6fe1', from_warehouse: false, meta_data_changed: false, meta_data: {}, tags: []}]
=> [{:asset_id=>"1046e450-e9ff-012f-5d84-38f6b11b6fe1", :commodity_id=>"10552d90-e9ff-012f-5d84-38f6b11b6fe1", :from_warehouse=>false, :meta_data_changed=>false, :meta_data=>{}, :tags=>[]}]
1.9.3p194 :003 > h[:public_copy_missing] = [1,2,3,4]
@guyboertje
guyboertje / Entity_sales_doc.txt
Created April 17, 2012 13:51
Entity related Sales
Regards the building of collections of documents for entity reporting.
Prerequisites:
Import of entities
Import of products
Import of users
Actions:
Import of historic sales
Import of joining/leaving mailinglists
var WeightedMarkerClusters;
var __bind = function(fn, me){ return function(){ return fn.apply(me, arguments); }; };
(function($, w) {}, WeightedMarkerClusters = (function() {
function WeightedMarkerClusters(jq_element, options) {
this.ele = jq_element;
this.opts = options;
this.markerCluster = null;
this.entity_id = this.ele.parent().find(".context").eq(0).data("entityId");
this.map = this.ele.find(this.opts.map_selector).eq(0);
this.map.gmap3({
@guyboertje
guyboertje / dci-builder.rb
Created March 2, 2012 19:51
DCI: Builder approach
module RoleExtender
def new properties = {}
include_roles nil, properties
end
private
def include_roles roles, properties
instance = allocate()
@guyboertje
guyboertje / irb_output.txt
Created September 16, 2015 11:06
Check of sleeping threads
irb(main):067:0> s2 = Supervisor2.new
=> #<Supervisor2:0x5fbdfdcf>
irb(main):068:0> s2.run
sleeping for 30
=> [#<Thread:0x156b88f5 run>, #<Thread:0x3bf9ce3e run>]
irb(main):069:0> s2.stop
=> [#<Thread:0x156b88f5 dead>, #<Thread:0x3bf9ce3e run>]
irb(main):070:0> s3 = Supervisor3.new
=> #<Supervisor3:0x71def8f8>
irb(main):071:0> s3.run
@guyboertje
guyboertje / cabin_helper.rb
Created August 19, 2015 08:51
cabin mocking version 2
class LogTracker
def filter(&block)
cache.detect(&block)
end
def cache()
@cache ||= []
end
def <<(hash)