http://code.secondbit.org/events/ en-us events Changelog http://code.secondbit.org/events/rev/df95f058a7b5 http://code.secondbit.org/events/rev/df95f058a7b5 changeset df95f058a7b5 branch default bookmark tag tip user Paddy <paddy@impractical.co> description Update to new nsqio repo.

The go-nsq client is now located under a nsqio org on Github, so we need to
update the import path. files nsq.go
]]> Paddy <paddy@impractical.co> Mon, 14 Dec 2015 04:02:50 -0800 http://code.secondbit.org/events/rev/2d030022b4b5 http://code.secondbit.org/events/rev/2d030022b4b5 changeset 2d030022b4b5 branch bookmark tag user Paddy <paddy@secondbit.org> description Create our Model helper.

Create a Model interface that any type can implement by just providing getters
that will be used to build Events produced around that type.

Add a PublishModelEvent helper that takes a Publisher, a Model, and an action
(as a string) and builds a consistent Event around the Model, then publishes it
to the Publisher.

This is a helpful wrapper in most of our systems, and will probably handle 99%
of our NSQ publishes, because most of our infrastructure is going to be
something like "a new profile was created" or "a new login was created" or "a
profile was updated" and we just want to disseminate that information across all
our services, to push based on it, or trigger actions. This abstracts it out
nicely to a standard format and a nice, easy way to send those messages. files model.go
]]> Paddy <paddy@secondbit.org> Wed, 15 Jul 2015 00:22:57 -0400 http://code.secondbit.org/events/rev/ce1212549d47 http://code.secondbit.org/events/rev/ce1212549d47 changeset ce1212549d47 branch bookmark tag user Paddy <paddy@secondbit.org> description Create Publisher interface and stdout publisher.

Create a Publisher interface that allows us to use different implementations and
switch between them easily. The NSQ publisher already implements the interface,
so it was really just copying that.

Create an implmentation of the Publisher interface that just logs the data to
stdout. files event.go
stdout.go
]]> Paddy <paddy@secondbit.org> Wed, 15 Jul 2015 00:19:41 -0400 http://code.secondbit.org/events/rev/987595765978 http://code.secondbit.org/events/rev/987595765978 changeset 987595765978 branch bookmark tag user Paddy <paddy@secondbit.org> description Create NSQ helpers.

Create an NSQPublisher helper that will allow us to publish events in the system
in a consistent way. It basically just uses our dictated Event type, to make
sure everything's using the same format.

Create an NSQSubscriber helper that will allow us to listen for events in the
system. It basically creates an nsq.Consumer, adds a handler to it, connects it
to lookupds, and has a helper to block until the consumer is told to stop.

Eventually, if github.com/bitly/nsq/issues/601 goes well, we should also have
this poll our DNS to check for new nsqlookupds, and automatically connect to
them. files nsq.go
]]> Paddy <paddy@secondbit.org> Tue, 14 Jul 2015 00:05:45 -0400 http://code.secondbit.org/events/rev/e86251b04826 http://code.secondbit.org/events/rev/e86251b04826 changeset e86251b04826 branch bookmark tag user Paddy <paddy@secondbit.org> description Add constants, ignore empty data.

Add constants for ActionCreated, ActionUpdated, and ActionDeleted, as they'll be
used by pretty much everything, and we don't need duplicate definitions in each
and every codebase.

Add an `omitempty` tag to the Data property of our message, so if there's no
data to be associated with a message, we don't send something empty, which would
be silly. files event.go
]]> Paddy <paddy@secondbit.org> Mon, 13 Jul 2015 23:52:30 -0400 http://code.secondbit.org/events/rev/2e19675ea220 http://code.secondbit.org/events/rev/2e19675ea220 changeset 2e19675ea220 branch bookmark tag user Paddy <paddy@secondbit.org> description Implement events package.

This is the package we'll use to keep all the cross-binary "ping" notification
code in sync. We'll use it to define shared types and helper functions.

For now, just define the Event type. We'll use this to broadcast "something
happened!" files event.go
]]> Paddy <paddy@secondbit.org> Fri, 15 May 2015 22:51:31 -0400