diff options
| author | alex <[email protected]> | 2026-07-12 15:00:16 +0200 |
|---|---|---|
| committer | alex <[email protected]> | 2026-07-12 15:00:16 +0200 |
| commit | 6cb3313793bf45e197b3048f0abd2f600bf97bb5 (patch) | |
| tree | 019a0995c7f9422ec9d739c77379ee7cc1a96b9c /pkg/commands/multi.go | |
| parent | ce9d9f8b2183bc0a31bfa40e780ae07182bc7cf8 (diff) | |
| download | redis-clone-6cb3313793bf45e197b3048f0abd2f600bf97bb5.tar.xz redis-clone-6cb3313793bf45e197b3048f0abd2f600bf97bb5.zip | |
multi exec and discardmulti/execute
Diffstat (limited to 'pkg/commands/multi.go')
| -rw-r--r-- | pkg/commands/multi.go | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/pkg/commands/multi.go b/pkg/commands/multi.go new file mode 100644 index 0000000..2b0fcb7 --- /dev/null +++ b/pkg/commands/multi.go @@ -0,0 +1,18 @@ +package commands + +import ( + "errors" + "net" + "redisClone/pkg/core" +) + +func Multi(db core.RedisDB, session *ClientSession, conn net.Conn, execArgs []string) interface{} { + if session.InTransaction { + return errors.New("MULTI calls can not be nested") + } + session.InTransaction = true + + session.Queue = make([][]string, 0) + + return core.SimpleString("OK") +}
\ No newline at end of file |
