| .. |
|
api
|
736b128804
feat(checkpoint): add rule options to kuiper conf
|
преди 4 години |
|
checkpoints
|
42ba74c6e3
feat(kvStore):Replace go-cache with sqlite (#635)
|
преди 4 години |
|
cli
|
01bdee14ae
feat(rule): support get topo of a rule (#437)
|
преди 4 години |
|
collectors
|
1674c039b2
refactor(all): format by go fmt
|
преди 5 години |
|
contexts
|
2894141c7f
refactor(checkpoint): do not add internal api to StreamContext
|
преди 4 години |
|
demo
|
1674c039b2
refactor(all): format by go fmt
|
преди 5 години |
|
extensions
|
1f26bd1cce
feat(source): remove sharedSubscription option from mqtt source
|
преди 4 години |
|
nodes
|
9531d41833
Cli query related change (#648)
|
преди 4 години |
|
operators
|
c14dbd254e
feat(sql): column pruning
|
преди 4 години |
|
planner
|
c14dbd254e
feat(sql): column pruning
|
преди 4 години |
|
server
|
692528db21
feat(ping):Add a ping api for keep-alive detection #626 (#651)
|
преди 4 години |
|
sinks
|
ff8aaf27fd
feat: add redisstream message bus #549
|
преди 4 години |
|
states
|
42ba74c6e3
feat(kvStore):Replace go-cache with sqlite (#635)
|
преди 4 години |
|
test
|
7a26bf9675
test(checkpoint): refactor test
|
преди 4 години |
|
funcs.go
|
d3298cb225
feat(checkpoint): checkpoint controllers
|
преди 4 години |
|
streams.go
|
0d445ffeed
fix(topo): topo cancel "close closed channel" error (#636)
|
преди 4 години |
|
util.go
|
1674c039b2
refactor(all): format by go fmt
|
преди 5 години |
|
util_test.go
|
b6626a59a7
feat(plugin): register func and delete func implementation and test
|
преди 5 години |
ngjaying
c14dbd254e
feat(sql): column pruning