Commit History

Автор SHA1 Съобщение Дата
  RockyJin 22b2e2d335 refactor: add debug info преди 4 години
  RockyJin 6921bea393 refactor: add debug info преди 4 години
  RockyJin b496097c74 fix: panic issue #416 преди 4 години
  ngjaying 3aed002017 feat(checkpoint): sink cache align with check point преди 4 години
  ngjaying 2894141c7f refactor(checkpoint): do not add internal api to StreamContext преди 4 години
  ngjaying 34c92c469a feat(checkpoint): implement state store преди 4 години
  ngjaying d3298cb225 feat(checkpoint): checkpoint controllers преди 4 години
  RockyJin e5e272a486 feat(templates): several fixes for sink data templates преди 4 години
  RockyJin a3f5cf0b6a feat(sink):merge code from master преди 4 години
  ngjaying 49effbfbd4 bug(stream): fix sink infinite resend after rule stopped problem (#278) преди 5 години
  ngjaying 66012ae4cd feat(plugin): Support to return a constructor function for plugins преди 5 години
  ngjaying 1b32d541d7 feat(sink): support sink template for all преди 5 години
  RockyJin cc09772e7d benchmark test for edgex source преди 5 години
  RockyJin 54c0845294 revert the omit empty result fix преди 5 години
  RockyJin 7e981d7fda update docs преди 5 години
  ngjaying 2ebd3e5831 feat(plugins): support to load plugin with version преди 5 години
  ngjaying a35504eeae refactor(plugins): move GetPlugin to plugins/manager преди 5 години
  ngjaying b7ea1cde85 Merge pull request #156 from emqx/edgex_sink преди 5 години
  RockyJin 492dfdd99c add edgex message bus sink преди 5 години
  ngjaying 4933d3b4d6 feat(stream): reduce default cache length to 1024 to avoid large memory footprint преди 5 години
  ngjaying 61eb5e40f1 feat(stream): support error sink преди 5 години
  ngjaying 189448e90f refactor(stream): node status clear after restart преди 5 години
  ngjaying 1674c039b2 refactor(all): format by go fmt преди 5 години
  ngjaying e4f7c1c3e7 feat(stream): sink cache save/load преди 5 години
  ngjaying 7ffdeb046d feat(stream): add cache for sink преди 5 години
  ngjaying 131533eb9e Merge remote-tracking branch 'origin/master' into temp преди 5 години
  ngjaying 14b97431f7 bug(test): fix processor test преди 5 години
  ngjaying b8bd585140 feat(prometheus): allow to open/close prometheus by config преди 5 години
  ngjaying 42a211476c bug(stream): restart source should re-read the config преди 5 години
  ngjaying 7deef9554a feat(metrics): print merics in order преди 5 години