to a socket.
- MessageSocketMux#run now will return if there's no work left to do (like if
our socket is dead)
- Updated client play code to quit when we get all messaged ack'd
client and server networking.
A SocketMux can handle any message type. The only difference between a client
and a server is who initiates the TCP connection.
Clients call SocketMux#connect
Servers call SocketMux#listen
- Only strip upper-ascii in message values that are strings
- Shuffle namespacing around. Flat LogStash to heirarchical LogStash::Net::...
- Add stub Indexer server
- handle all date stuff in Log, not the sub-classes
- use "encoding" and "type" properly, rather than "type" and "name"
- switch to having a group of Groks, and doing first-pattern-match
- make example config.rb a little easier to read
because JSON.dump assumes UTF-8
- server: when we decode a message, if we have a handler for <msgname>Handler,
we should call that handler with the message as an argument.
- load all pattern files under patterns/
- grok captures don't include @LINE, so put it there ourselves
- properly filter grok captures per comments
- tear out grok cmdline stuff
- switch to seconds since epoch for @DATE
- add firewalls pattern with initial netscreen session close pattern
- Add MessageStream.clear for wiping messages in the stream.
- Make socket reading faster and more reliable (since read(N) may return elss
than N bytes)
Fun stats, dumping lines of apache logs into sandbox/srv.rb
from sandbox/client.rb:
1421000 finished @ 163/sec => 8680.2 secs
1422000 finished @ 163/sec => 8678.5 secs
1423000 finished @ 163/sec => 8679.1 secs
8500 lines per second? That's about 2MB/sec. Not bad?
to the correct message instance (an IndexEvent request becomes an
IndexEventRequest instance, etc)
- We use some metaprogramming tricks to bind Message JSON fields to
functions, see BindToHash and hashbind in net/message.rb
- Protocol versioning is poor right now, but it is present.
- The server code is not well-written, yet. I just wanted real client/server
encode/decode testing.
- Add some play code to sandbox/
