event-shuttle

command module

v0.0.0-...-0f5cdac Latest Latest Go to latest Published: May 4, 2015 License: MIT Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/sclasen/event-shuttle

Links

Open Source Insights

README ¶

event-shuttle

goal: unix system service that collects events and reliably delivers them to kafka, relieving other services on the same system from having to do so.

journals events through bolt-db so that in the event of an kafka outage, events can still be accepted, and will be delivered when kafka becomes available.

listens on 127.0.0.1:3887, rest-api is POST /:topic -d message
journals events to bolt db.
discovers brokers via netflix exhibitor, or a seed broker list.
delivers events to kafka.

 event-shuttle --help
Usage of event-shuttle:
  -brokers="": comma seperated list of ip:port to use as seed brokers
  -db="events.db": name of the boltdb database file
  -debug=false: start a pprof http server on 6060
  -exhibitor=false: use EXHIBITOR_URL from env to lookup seed brokers
  -port="3887": port on which to listen for events

using a broker list

event-shuttle -brokers 1.2.3.4:9092,1.2.3.5:9092

using netflix exhibitor to find brokers

EXHIBITOR_URL=<some httpsUrl with creds> event-shuttle -exhibitor=true

Documentation ¶

There is no documentation for this package.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
Godeps
_workspace/src/code.google.com/p/snappy-go/snappy Package snappy implements the snappy block-based compression format.	Package snappy implements the snappy block-based compression format.
_workspace/src/github.com/Shopify/sarama Package sarama provides client libraries for the Kafka 0.8 protocol.	Package sarama provides client libraries for the Kafka 0.8 protocol.
_workspace/src/github.com/bmizerany/assert
_workspace/src/github.com/bmizerany/assert/example
_workspace/src/github.com/bmizerany/pat Package pat implements a simple URL pattern muxer	Package pat implements a simple URL pattern muxer
_workspace/src/github.com/boltdb/bolt Package bolt implements a low-level key/value store in pure Go.	Package bolt implements a low-level key/value store in pure Go.
_workspace/src/github.com/boltdb/bolt/cmd/bolt
_workspace/src/github.com/kr/pretty Package pretty provides pretty-printing for Go values.	Package pretty provides pretty-printing for Go values.
_workspace/src/github.com/kr/text Package text provides rudimentary functions for manipulating text in paragraphs.	Package text provides rudimentary functions for manipulating text in paragraphs.
_workspace/src/github.com/kr/text/colwriter Package colwriter provides a write filter that formats input lines in multiple columns.	Package colwriter provides a write filter that formats input lines in multiple columns.
_workspace/src/github.com/kr/text/mc Command mc prints in multiple columns.	Command mc prints in multiple columns.
_workspace/src/github.com/sclasen/sarama Package sarama provides client libraries for the Kafka 0.8 protocol.	Package sarama provides client libraries for the Kafka 0.8 protocol.
_workspace/src/github.com/stretchr/testify/assert

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL