| .. |
|
api
|
736b128804
feat(checkpoint): add rule options to kuiper conf
|
%!s(int64=4) %!d(string=hai) anos |
|
checkpoints
|
3aed002017
feat(checkpoint): sink cache align with check point
|
%!s(int64=4) %!d(string=hai) anos |
|
cli
|
06d32c050b
bug: fix cli describe plugin crash issue
|
%!s(int64=4) %!d(string=hai) anos |
|
collectors
|
1674c039b2
refactor(all): format by go fmt
|
%!s(int64=5) %!d(string=hai) anos |
|
contexts
|
2894141c7f
refactor(checkpoint): do not add internal api to StreamContext
|
%!s(int64=4) %!d(string=hai) anos |
|
demo
|
1674c039b2
refactor(all): format by go fmt
|
%!s(int64=5) %!d(string=hai) anos |
|
extensions
|
8de9f4ea01
Print info (#379)
|
%!s(int64=4) %!d(string=hai) anos |
|
nodes
|
bc22dd11ef
fix(sink): sink cache error recovery (#410)
|
%!s(int64=4) %!d(string=hai) anos |
|
server
|
22e2846851
feat():add sink hint (#414)
|
%!s(int64=4) %!d(string=hai) anos |
|
sinks
|
cabce69d36
merge code from master
|
%!s(int64=4) %!d(string=hai) anos |
|
states
|
2894141c7f
refactor(checkpoint): do not add internal api to StreamContext
|
%!s(int64=4) %!d(string=hai) anos |
|
test
|
7a26bf9675
test(checkpoint): refactor test
|
%!s(int64=4) %!d(string=hai) anos |
|
funcs.go
|
d3298cb225
feat(checkpoint): checkpoint controllers
|
%!s(int64=4) %!d(string=hai) anos |
|
streams.go
|
3aed002017
feat(checkpoint): sink cache align with check point
|
%!s(int64=4) %!d(string=hai) anos |
|
util.go
|
1674c039b2
refactor(all): format by go fmt
|
%!s(int64=5) %!d(string=hai) anos |
|
util_test.go
|
b6626a59a7
feat(plugin): register func and delete func implementation and test
|
%!s(int64=5) %!d(string=hai) anos |
EMQmyd
22e2846851
feat():add sink hint (#414)