forked from driskell/logstash-forwarder
-
Notifications
You must be signed in to change notification settings - Fork 0
/
DESIGN
46 lines (40 loc) · 1.39 KB
/
DESIGN
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
Same basic functional design as the original lumberjack:
Harvester reads events from files
Event:
Byte offset of start of event (number)
Line number of event (number)
File origin of event (string)
Message (string)
Work model:
Harvester(s)
-> Enveloper (flush when full or after N idle seconds)
-> Compressor (compresses whole envelopes)
-> Encryptor (encrypts compressed envelopes)
-> Emitter (ships over the wire)
Sending an envelope of an encrypted, compressed batch of messages allows
me freedom to pick any message-oriented protocol. The previous implementation
of lumberjack requried channel-encryption (with tls) which limited the
kind of transportation tools.
Previously, compression was done on envelopes, but TLS was used to communicate
securely.
Messaging model w/ ZMQ:
* REQREP message model
REQREP has high latency (lock step request-response) but since
I'm sending multiple events at once, I believe that latency is
unimportant.
Messaging model w/ Redis:
* RPUSH + LPOP
* PUBLISH + SUBSCRIBE
Types of events:
File Event - represents an event read from a file
- file origin of event
- byte offset of event
- line number of event
- event message (the contents)
Compressed Envelope
- number of items
- type of item
- compressed payload
Encrypted Envelope
- cipher
- payload