open-nomad/helper
Drew Bailey 86080e25a9
Send events to EventSinks (#9171)
* Process to send events to configured sinks

This PR adds a SinkManager to a server which is responsible for managing
managed sinks. Managed sinks subscribe to the event broker and send
events to a sink writer (webhook). When changes to the eventstore are
made the sinkmanager and managed sink are responsible for reloading or
starting a new managed sink.

* periodically check in sink progress to raft

Save progress on the last successfully sent index to raft. This allows a
managed sink to resume close to where it left off in the event of a lost
server or leadership change

dereference eventsink so we can accurately use the watchch

When using a pointer to eventsink struct it was updated immediately and our reload logic would not trigger
2020-10-26 17:27:54 -04:00
..
args address review comments 2018-10-30 13:58:52 -04:00
boltdd Implement 'batch mode' for persisting allocations on the client. (#9093) 2020-10-20 16:15:37 -04:00
codec Pull inmem codec to helper 2018-02-15 13:59:00 -08:00
constraints/semver test: assert semvers are *not* compared lexically 2019-11-19 10:59:40 -08:00
discover skip running test executables 2017-10-19 16:49:57 -07:00
escapingio Handle when a new line follows an escaping char 2020-08-31 20:31:44 -04:00
fields goimports 2019-01-22 15:44:31 -08:00
flag-helpers agent: add optional param to -dev flag for connect (#6126) 2019-08-14 15:29:37 -04:00
flatmap Enable more linters 2017-09-26 15:26:33 -07:00
freeport Fix undefined: getEphemeralPortRange error on FreeBSD. 2020-02-27 14:54:55 -05:00
gated-writer
grpc-middleware/logging helper: Add initial grpc logging middleware 2020-03-23 13:58:29 -04:00
logging cli Ui implementation that logs to a hclogger 2019-02-19 17:53:14 -06:00
mount helper/mount: Add mount helper package 2020-03-23 13:58:29 -04:00
noxssrw agent: prevent XSS by controlling Content-Type 2020-03-25 09:45:43 -04:00
pluginutils driver/docker: allow configurable pull context timeout setting. 2020-08-12 08:58:07 +01:00
pool RPC errors must be wrapped in order to wrap internal errors (#8632) 2020-08-11 09:13:52 -04:00
raftutil Send events to EventSinks (#9171) 2020-10-26 17:27:54 -04:00
snapshot Apply suggestions from code review 2020-05-31 21:29:17 -04:00
stats Extend timeout based on user feedback 2018-06-21 15:27:56 -04:00
testlog tests: prefix agent logs to identify agent sources 2020-06-07 16:38:11 -04:00
testtask Update helper/testtask/testtask_windows.go 2019-01-17 18:43:14 +01:00
tlsutil config: accept CA PEM files with extra whitespace 2018-09-06 11:38:56 -07:00
useragent Set user-agent when talking to GCE metadata 2018-04-10 10:36:46 -04:00
uuid Remove structs import from api 2017-09-29 10:36:08 -07:00
winsvc Added service wrapper code (#6220) 2019-11-11 15:16:07 -05:00
funcs.go artifact/template: make destination path absolute inside taskdir (#9149) 2020-10-22 15:47:49 -04:00
funcs_test.go artifact/template: make destination path absolute inside taskdir (#9149) 2020-10-22 15:47:49 -04:00