Skip to content

Instantly share code, notes, and snippets.

View taotetek's full-sized avatar
💭
Left for Gitlab. Microsoft still contracts with ICE.

taotetek taotetek

💭
Left for Gitlab. Microsoft still contracts with ICE.
View GitHub Profile
module(load="imczmq")
input(
type="imczmq"
endpoints=">tcp://127.0.0.1:31337"
socktype="ROUTER"
authtype="CURVESERVER"
clientcertpath="/home/bknox/.curve/"
servercertpath="/home/bknox/.curve/logging_server_cert"
)
@taotetek
taotetek / credit.c
Last active July 12, 2018 15:11
Updated Credit Based Flow Control Example ( See: http://hintjens.com/blog:15 )
#include "czmq.h"
// DEBUG - set to true for some output
#define DEBUG false
#define TRANSIT_TOTAL 1024 * 1024
#define TRANSIT_SLICE TRANSIT_TOTAL / 4
#define FRAGMENT_SIZE 65536
#define SERVER_HWM (TRANSIT_TOTAL / FRAGMENT_SIZE) * 2
#define TICK_SECONDS 5
$  ./autogen.sh
autoreconf: Entering directory `.'
autoreconf: configure.ac: not using Gettext
autoreconf: running: aclocal -I config --force -I config
configure.ac:138: error: AC_SUBST: `json-c_CFLAGS' is not a valid shell variable name
../../lib/autoconf/general.m4:1511: AC_ARG_VAR is expanded from...
/usr/share/aclocal/pkg.m4:106: PKG_CHECK_MODULES is expanded from...
configure.ac:138: the top level
autom4te: /usr/bin/m4 failed with exit status: 1
aclocal: error: echo failed with exit status: 1
<project
name = "normz"
description = "zeromq microservice for log normalization"
script = "zproject.gsl"
email = "[email protected]"
>
<include filename = "license.xml" />
<version major = "0" minor = "1" patch = "0" />
<use project = "czmq">
<known_projects>
<!-- ZeroMQ Projects -->
<use project = "zmq"
repository = "https://github.com/zeromq/libzmq"
test = "zmq_init"
cmake_name = "ZeroMQ" />
<use project = "czmq"
input(type="imudp" port="514" ruleset="to_sagan") # listen for udp on port 514
input(type="imtcp" port="514" ruleset="to_sagan") # listen for tcp on port 514
## REMOTE RULES ###############################################################
# send all remote logs to sagan for analysis
ruleset(name="to_sagan") {
action(type="omfile" file="|/var/run/sagan/sagan.fifo" template="sagan_template")
}
@taotetek
taotetek / test.conf
Created June 18, 2015 18:19
proof of concept for dynamic template output on actions
module (
load="imtcp"
)
input(type="imtcp" port="514" ruleset="test_dynamic")
template(name="had_cee" type="list") {
constant(value="CEE WOOT WOOT: ")
property(name="msg")
}
import os, streams, parsexml, strutils, macros
macro readModelAndBuildAST(filename: string): stmt =
let
inputString = slurp(filename.strVal)
var s = newStringStream(inputString)
var x: XmlParser
open(x, s, $filename)
wow.nim(10, 30) Error: type mismatch: got (NimNode)
but expected one of:
macros.newIdentNode(i: NimIdent)
macros.newIdentNode(i: string)
import os, streams, parsexml, strutils, macros
macro readModelAndBuildAST(filename: string): stmt =
let
inputString = slurp(filename.strVal)
var s = newStringStream(inputString)
var x: XmlParser
open(x, s, filename)