 ngjaying
|
b7ea1cde85
Merge pull request #156 from emqx/edgex_sink
|
il y a 5 ans |
 RockyJin
|
492dfdd99c
add edgex message bus sink
|
il y a 5 ans |
|
ngjaying
|
4933d3b4d6
feat(stream): reduce default cache length to 1024 to avoid large memory footprint
|
il y a 5 ans |
|
ngjaying
|
61eb5e40f1
feat(stream): support error sink
|
il y a 5 ans |
|
ngjaying
|
189448e90f
refactor(stream): node status clear after restart
|
il y a 5 ans |
|
ngjaying
|
1674c039b2
refactor(all): format by go fmt
|
il y a 5 ans |
|
ngjaying
|
e4f7c1c3e7
feat(stream): sink cache save/load
|
il y a 5 ans |
|
ngjaying
|
7ffdeb046d
feat(stream): add cache for sink
|
il y a 5 ans |
|
ngjaying
|
131533eb9e
Merge remote-tracking branch 'origin/master' into temp
|
il y a 5 ans |
|
ngjaying
|
14b97431f7
bug(test): fix processor test
|
il y a 5 ans |
|
ngjaying
|
b8bd585140
feat(prometheus): allow to open/close prometheus by config
|
il y a 5 ans |
|
ngjaying
|
42a211476c
bug(stream): restart source should re-read the config
|
il y a 5 ans |
|
ngjaying
|
7deef9554a
feat(metrics): print merics in order
|
il y a 5 ans |
|
ngjaying
|
cec5e64095
feat(metrics): add metric for channel length
|
il y a 5 ans |
|
ngjaying
|
f09d3ec447
feat(stream): export bufferLength option for source/sink and rule
|
il y a 5 ans |
|
ngjaying
|
b04d85c5ec
refactor(stream): refactor for concurrent run
|
il y a 5 ans |
|
ngjaying
|
4b8ef37da1
fix<query>: fix the result was not returned problem
|
il y a 5 ans |
|
ngjaying
|
98778f1ace
fix<stream>: fix nil creation of source/sink
|
il y a 5 ans |
|
ngjaying
|
4b2e0ed4ca
feat<metrics>: support metrics for multiple instances
|
il y a 5 ans |
|
ngjaying
|
88c3763b02
feat<metrics>: add metrics for operations
|
il y a 5 ans |
|
ngjaying
|
ee945be78f
feat<stream>: add runAsync config for sink
|
il y a 5 ans |
|
ngjaying
|
f5b9460df1
feat<stream>: add concurrency support for sink
|
il y a 5 ans |
|
ngjaying
|
007bb16ac9
feat(sink): rest sink implementation
|
il y a 5 ans |
|
RockyJin
|
5762b09dbf
fix go module issue
|
il y a 5 ans |
|
RockyJin
|
183374243d
refactor import path
|
il y a 5 ans |
|
ngjaying
|
e4b4b5eb52
bug(status): correct rule status and source config reload
|
il y a 5 ans |
|
ngjaying
|
1aaf875785
feat(extension): context and sink refactor. stream compose refactor
|
il y a 5 ans |
