index
:
delta/redis.git
1906-merge
2.2
2.4
2.6
2.8
2.8-fastscript
3.0
3.2
4.0
5.0
6.0
6.2
7.0
7.2
ack
acl
acl-api-pr
acl-log
antiaffinity
aofeof
aofrdb
argv-accounting
arm
baserock/3.0
baserock/ps/proto-web-system
better-random-member
bulkaccept-2.8
cgroups
client-unblock
cluster-api-improvements
cluster-data-as-pong
conduct
config-rewrite
cow-pipe
csc2
current-client-fix
dict-clustered-entries
dictc
diskless-short-read
diskless_slave_refresh2
dynamic-hz
expirealgo
faster-info
faster-ll2string
faster-rdb-loading
fasterio
fastscript
fix-double-multi
fix-expires-6537
free_clients_during_loading
freelist
fsync-safety
geo
hashed-pass-opcode
ipv6
issue-1240
issue_2175
latency
lazyfree
lcs
ldb
less-mstime
less-mstime-28
lfu
localtime
lpos
master-replica
meaningful-offset
memopt
memsync
module-block-on-keys
module-blocking-commands
module-hooks
module-io-context
modules-get-client-info-by-id
modules-replication
multi-if
new-keyspace
no-mo-first
no-mo-second
nordb
nosync
o1-bpop
o1-bpop-5.0
onepass-bulk
oran-memory-profiling
precise-timeout
precise-timeout-2
psync-fixes
psync2
psync2-rdb-fixes
psync2-test-improvement
queue-in-multi
rdb-check
rdb-script-aux
rdb9
rdbchanges
resp3
rssmaxmemory
sds
sentinel-32
sharedapi
siphash
slave-diskless
slave-script-timeout
slaves_capa
statemachine
strcompr
stream-propagation-fix
stream-propagation-fix-2
streams
testing
thread-safe-context
threaded-core-commands
threaded-io
tls-conn-errors
tracking-noloop
unstable
unstable_hmset_args
wait-aof
waitpid-fix
zaddnx
ziplist-improvements
zpop
zunion
github.com: antirez/redis.git
summary
refs
log
tree
commit
diff
log msg
author
committer
range
path:
root
/
src
/
stream.h
Commit message (
Expand
)
Author
Age
Files
Lines
*
Add stream consumer group lag tracking and reporting (#9127)
Itamar Haber
2022-02-23
1
-2
/
+15
*
Adds auto-seq-only-generation via `XADD ... <ms>-*` (#9217)
Itamar Haber
2021-11-30
1
-1
/
+1
*
Fix if consumer is created as a side effect without notify and dirty++ (#9263)
menwen
2021-08-02
1
-4
/
+9
*
Fixed some typos, add a spell check ci and others minor fix (#8890)
Binbin
2021-06-10
1
-1
/
+1
*
Add modules API for streams (#8288)
Viktor Söderqvist
2021-01-28
1
-0
/
+7
*
Sanitize dump payload: ziplist, listpack, zipmap, intset, stream
Oran Agra
2020-12-06
1
-0
/
+1
*
Adds exclusive ranges to X[REV]RANGE (#8072)
Itamar Haber
2020-12-03
1
-1
/
+2
*
Add COPY command (#7953)
swamp0407
2020-11-17
1
-0
/
+1
*
Stream: Inconsistency between master and replica some XREADGROUP case (#7526)
valentinogeron
2020-09-24
1
-1
/
+2
*
Squash merging 125 typo/grammar/comment/doc PRs (#7773)
Oran Agra
2020-09-10
1
-1
/
+1
*
XPENDING should not update consumer's seen-time
Guy Benoish
2020-05-04
1
-1
/
+6
*
Stream: Handle streamID-related edge cases
Guy Benoish
2019-12-26
1
-0
/
+1
*
Support streams in general module API functions
Guy Benoish
2019-11-06
1
-0
/
+1
*
stream.h: fix typo
Jamison Judge
2019-10-07
1
-1
/
+1
*
prevent diskless replica from terminating on short read
Oran Agra
2019-07-17
1
-0
/
+1
*
Streams: add streamCompareID() declaration in stream.h.
dejun.xdj
2018-07-14
1
-0
/
+1
*
Streams: iterator entry deletion abilities.
antirez
2018-04-17
1
-0
/
+2
*
CG: AOF rewriting implemented.
antirez
2018-03-23
1
-0
/
+1
*
CG: Replication WIP 1: XREADGROUP and XCLAIM propagated as XCLAIM.
antirez
2018-03-19
1
-1
/
+8
*
CG: RDB loading first implementation.
antirez
2018-03-15
1
-0
/
+2
*
CG: XPENDING should not create consumers and obey to count.
antirez
2018-03-15
1
-1
/
+1
*
CG: Now XREADGROUP + blocking operations work.
antirez
2018-03-15
1
-0
/
+2
*
CG: first draft of streamReplyWithRangeFromConsumerPEL().
antirez
2018-03-15
1
-1
/
+1
*
CG: creation of NACK entries in PELs.
antirez
2018-03-15
1
-5
/
+5
*
CG: consumer lookup + initial streamReplyWithRange() work to supprot CG.
antirez
2018-03-15
1
-2
/
+2
*
CG: XGROUPREAD group option parsing and groups lookup.
antirez
2018-03-15
1
-1
/
+1
*
CG: data structures design + XGROUP CREATE implementation.
antirez
2018-03-15
1
-1
/
+40
*
Streams: state machine for reverse iteration WIP 1.
antirez
2017-12-01
1
-3
/
+4
*
Streams: items compression implemented.
antirez
2017-12-01
1
-0
/
+5
*
Streams: export iteration API.
antirez
2017-12-01
1
-0
/
+31
*
Streams: RDB saving.
antirez
2017-12-01
1
-0
/
+1
*
Streams: 12 commits squashed into the initial Streams implementation.
antirez
2017-12-01
1
-0
/
+21