Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Added xreadgroup, xtrim, xclaim, xautoclaim, xpending commands #52

Merged
merged 11 commits into from
Jul 8, 2022
Merged

Added xreadgroup, xtrim, xclaim, xautoclaim, xpending commands #52

Changes from 1 commit
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
939f394
Added xreadgroup, xtrim commands
Swoorup Jun 10, 2022
d80d320
Remove only tag
Swoorup Jun 10, 2022
b9031fa
Fix binary compatibility
Swoorup Jun 11, 2022
6668ee3
Review suggestion
Swoorup Jun 11, 2022
a0af04e
Added xpendingsummary
Swoorup Jun 17, 2022
e8d5627
Added LastConsumed comment
Swoorup Jun 17, 2022
1394d77
Added xclaimsummary and xclaimdetail
Swoorup Jun 17, 2022
d948cb4
Fix test compilation error
Swoorup Jun 17, 2022
ce20705
Add comment on remaining commands
Swoorup Jun 17, 2022
481a1b3
Added xautoclaim
Swoorup Jun 18, 2022
93f6b0e
Fix property name
Swoorup Jun 18, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 5 additions & 1 deletion core/src/main/scala/io/chrisdavenport/rediculous/RedisCommands.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -361,11 +361,15 @@ object RedisCommands {
RedisCtx[F].unkeyed(NEL("XREVRANGE", stream :: end ::: start ::: count))
}

def xgroupcreate[F[_]: RedisCtx](stream: String, groupName: String, startId: String, mkStream: Boolean = false): F[Status] = {
def xgroupcreate[F[_]: RedisCtx](stream: String, groupName: String, startId: String, mkStream: Boolean): F[Status] = {
val mkStreamFragment = Alternative[List].guard(mkStream).as("MKSTREAM")
RedisCtx[F].unkeyed(NEL("XGROUP", "CREATE" :: stream :: groupName :: startId :: mkStreamFragment))
}

@deprecated("use xgroupcreate(stream: String, groupName: String, startId: String, mkStream: Boolean) instead", "0.3.3")
def xgroupcreate[F[_]: RedisCtx](stream: String, groupName: String, startId: String): F[Status] =
Swoorup marked this conversation as resolved.
Show resolved Hide resolved
xgroupcreate(stream, groupName, startId, false)

def xgroupsetid[F[_]: RedisCtx](stream: String, groupName: String, messageId: String): F[Status] =
RedisCtx[F].unkeyed(NEL.of("XGROUP", "SETID", stream, groupName, messageId))

Expand Down