pkg/SugarDB
1
0
Fork 0
mirror of https://github.com/EchoVault/SugarDB.git synced 2025-10-07 17:00:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

Implemented outward-facing API for Pub/Sub module

Browse Source
This commit is contained in:
Kelvin Mwinuka
2024-03-30 02:30:37 +08:00
parent 682261b35d
commit c56e749167
4 changed files with 501 additions and 336 deletions
Download Patch File Download Diff File Expand all files Collapse all files

660
coverage/coverage.out
View File

@@ -1,334 +1,4 @@
mode: set
github.com/echovault/echovault/pkg/modules/generic/commands.go:33.13,34.34 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:34.34,38.3 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:40.2,41.29 2 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:41.29,43.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:51.104,53.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:53.16,55.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:57.2,62.16 5 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:62.16,64.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:68.2,68.16 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:68.16,69.34 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:69.34,71.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:71.9,73.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:76.2,76.44 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:76.44,78.34 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:78.34,80.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:81.3,81.36 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:82.8,82.51 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:82.51,84.33 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:84.33,86.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:87.3,87.45 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:88.8,90.34 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:90.34,93.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:93.9,96.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:98.2,98.16 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:98.16,100.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:101.2,103.76 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:103.76,105.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:108.2,108.28 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:108.28,110.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:112.2,112.17 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:115.105,116.44 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:116.44,118.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:120.2,123.15 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:123.15,124.29 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:124.29,125.16 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:125.16,131.5 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:136.2,136.30 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:136.30,137.15 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:137.15,142.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:147.2,147.28 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:147.28,148.31 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:148.31,149.52 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:149.52,151.5 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:152.4,153.12 2 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:155.3,155.60 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:155.60,157.4 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:158.3,158.55 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:162.2,162.28 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:162.28,163.58 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:163.58,165.4 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:168.2,168.38 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:171.104,173.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:173.16,175.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:176.2,178.33 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:178.33,180.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:182.2,183.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:183.16,185.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:186.2,190.51 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:193.105,195.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:195.16,197.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:199.2,202.27 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:202.27,203.31 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:203.31,205.12 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:207.3,207.33 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:207.33,209.18 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:209.18,211.5 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:212.4,213.12 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:215.3,215.19 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:217.2,217.15 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:217.15,218.34 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:218.34,219.14 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:219.14,222.5 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:226.2,226.28 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:226.28,228.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:230.2,232.30 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:232.30,233.24 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:233.24,235.12 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:237.3,237.96 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:240.2,240.19 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:243.104,245.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:245.16,247.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:248.2,249.27 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:249.27,251.17 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:251.17,253.12 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:255.3,255.13 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:257.2,257.51 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:260.108,262.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:262.16,264.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:266.2,268.33 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:268.33,270.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:272.2,272.51 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:272.51,274.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:275.2,278.31 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:278.31,280.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:282.2,284.30 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:287.111,289.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:289.16,291.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:293.2,295.33 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:295.33,297.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:299.2,299.52 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:299.52,301.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:302.2,306.31 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:306.31,308.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:310.2,311.46 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:311.46,313.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:315.2,315.47 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:318.104,320.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:320.16,322.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:324.2,326.33 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:326.33,328.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:330.2,330.52 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:330.52,332.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:333.2,337.31 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:337.31,339.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:341.2,342.39 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:342.39,344.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:346.2,346.12 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:346.12,348.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:350.2,350.47 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:353.107,355.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:355.16,357.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:359.2,363.16 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:363.16,365.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:366.2,367.42 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:367.42,369.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:371.2,371.33 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:371.33,373.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:375.2,375.51 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:375.51,377.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:378.2,380.19 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:380.19,383.3 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:385.2,387.33 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:388.12,389.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:389.39,391.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:392.3,392.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:393.12,394.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:394.39,396.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:397.3,397.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:398.12,399.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:399.39,401.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:402.3,402.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:402.39,404.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:405.3,405.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:406.12,407.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:407.39,408.40 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:408.40,410.5 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:411.4,411.47 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:413.3,413.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:414.10,415.71 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:418.2,418.30 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:421.109,423.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:423.16,425.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:427.2,431.16 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:431.16,433.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:434.2,435.44 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:435.44,437.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:439.2,439.33 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:439.33,441.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:443.2,443.51 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:443.51,445.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:446.2,448.19 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:448.19,451.3 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:453.2,455.33 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:456.12,457.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:457.39,459.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:460.3,460.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:461.12,462.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:462.39,464.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:465.3,465.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:466.12,467.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:467.39,469.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:470.3,470.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:470.39,472.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:473.3,473.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:474.12,475.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:475.39,476.40 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:476.40,478.5 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:479.4,479.47 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:481.3,481.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:482.10,483.71 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:486.2,486.30 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:489.33,658.2 1 0
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:22.49,23.34 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:23.34,25.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:26.2,26.30 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:29.50,30.25 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:30.25,32.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:33.2,34.30 2 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:34.30,35.15 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:35.15,37.4 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:39.2,39.18 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:42.49,43.19 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:43.19,45.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:46.2,46.30 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:49.50,50.18 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:50.18,52.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:53.2,53.21 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:56.49,57.18 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:57.18,59.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:60.2,60.21 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:63.53,64.19 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:64.19,66.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:67.2,67.21 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:70.56,71.19 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:71.19,73.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:74.2,74.21 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:77.49,78.19 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:78.19,80.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:81.2,81.21 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:84.52,85.34 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:85.34,87.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:88.2,88.30 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:91.54,92.34 1 0
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:92.34,94.3 1 0
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:95.2,95.30 1 0
github.com/echovault/echovault/pkg/modules/generic/utils.go:31.77,32.19 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:32.19,34.3 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:35.2,35.33 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:36.13,38.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:40.12,41.26 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:41.26,43.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:44.3,45.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:47.12,48.26 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:48.26,50.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:51.3,52.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:54.12,55.19 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:55.19,57.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:58.3,58.29 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:58.29,60.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:61.3,63.17 3 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:63.17,65.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:66.3,67.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:69.12,70.19 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:70.19,72.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:73.3,73.29 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:73.29,75.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:76.3,78.17 3 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:78.17,80.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:81.3,82.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:84.14,85.19 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:85.19,87.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:88.3,88.29 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:88.29,90.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:91.3,93.17 3 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:93.17,95.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:96.3,97.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:99.14,100.19 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:100.19,102.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:103.3,103.29 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:103.29,105.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:106.3,108.17 3 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:108.17,110.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:111.3,112.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:114.10,115.95 1 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:28.115,34.29 4 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:34.29,35.54 1 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:35.54,41.42 4 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:41.42,43.5 1 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:45.4,48.12 3 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:51.3,51.36 1 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:51.36,58.43 5 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:58.43,60.5 1 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:62.4,64.21 2 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:68.2,70.25 2 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:73.109,77.35 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:77.35,78.65 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:78.65,79.41 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:79.41,81.5 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:82.4,82.12 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:84.3,84.13 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:87.2,87.51 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:90.110,91.18 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:92.9,97.36 4 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:97.36,98.66 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:98.66,99.52 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:99.52,103.6 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:104.5,104.13 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:106.4,107.14 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:109.3,110.26 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:112.9,116.45 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:116.45,118.4 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:119.3,119.42 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:119.42,123.37 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:123.37,124.67 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:124.67,125.53 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:125.53,126.59 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:126.59,130.8 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:132.6,132.14 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:134.5,134.54 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:134.54,137.6 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:139.9,139.50 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:139.50,143.37 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:143.37,144.67 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:144.67,145.53 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:145.53,147.24 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:147.24,150.8 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:152.6,152.14 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:154.5,154.33 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:154.33,157.6 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:159.9,159.49 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:159.49,163.37 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:163.37,164.67 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:164.67,165.53 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:165.53,166.55 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:166.55,170.8 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:172.6,172.14 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:174.5,174.50 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:174.50,177.6 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:179.9,181.4 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:182.3,183.26 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:184.10,185.50 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:189.103,191.2 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:193.33,201.60 1 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:201.60,201.86 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:210.60,212.5 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:220.62,220.88 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:229.62,229.88 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:239.62,239.88 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:250.60,252.5 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:253.113,254.49 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:254.49,256.6 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:257.5,257.41 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:266.60,268.5 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:269.113,271.18 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:271.18,273.6 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:274.5,274.53 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:283.60,285.5 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:286.113,287.47 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:287.47,289.6 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:290.5,290.41 1 0
github.com/echovault/echovault/pkg/modules/acl/commands.go:33.108,34.34 1 1
github.com/echovault/echovault/pkg/modules/acl/commands.go:34.34,36.3 1 1
github.com/echovault/echovault/pkg/modules/acl/commands.go:37.2,38.9 2 1
@@ -797,6 +467,82 @@ github.com/echovault/echovault/pkg/modules/hash/key_funcs.go:99.2,99.22 1 1
github.com/echovault/echovault/pkg/modules/hash/key_funcs.go:102.50,103.18 1 1
github.com/echovault/echovault/pkg/modules/hash/key_funcs.go:103.18,105.3 1 1
github.com/echovault/echovault/pkg/modules/hash/key_funcs.go:106.2,106.22 1 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:28.115,34.29 4 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:34.29,35.54 1 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:35.54,41.42 4 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:41.42,43.5 1 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:45.4,48.12 3 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:51.3,51.36 1 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:51.36,58.43 5 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:58.43,60.5 1 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:62.4,64.21 2 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:68.2,70.25 2 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:73.109,77.35 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:77.35,78.65 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:78.65,79.41 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:79.41,81.5 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:82.4,82.12 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:84.3,84.13 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:87.2,87.51 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:90.110,91.18 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:92.9,97.36 4 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:97.36,98.66 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:98.66,99.52 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:99.52,103.6 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:104.5,104.13 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:106.4,107.14 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:109.3,110.26 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:112.9,116.45 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:116.45,118.4 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:119.3,119.42 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:119.42,123.37 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:123.37,124.67 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:124.67,125.53 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:125.53,126.59 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:126.59,130.8 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:132.6,132.14 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:134.5,134.54 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:134.54,137.6 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:139.9,139.50 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:139.50,143.37 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:143.37,144.67 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:144.67,145.53 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:145.53,147.24 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:147.24,150.8 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:152.6,152.14 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:154.5,154.33 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:154.33,157.6 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:159.9,159.49 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:159.49,163.37 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:163.37,164.67 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:164.67,165.53 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:165.53,166.55 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:166.55,170.8 3 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:172.6,172.14 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:174.5,174.50 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:174.50,177.6 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:179.9,181.4 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:182.3,183.26 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:184.10,185.50 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:189.103,191.2 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:193.33,201.60 1 1
github.com/echovault/echovault/pkg/modules/admin/commands.go:201.60,201.86 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:210.60,212.5 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:220.62,220.88 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:229.62,229.88 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:239.62,239.88 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:250.60,252.5 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:253.113,254.49 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:254.49,256.6 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:257.5,257.41 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:266.60,268.5 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:269.113,271.18 2 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:271.18,273.6 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:274.5,274.53 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:283.60,285.5 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:286.113,287.47 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:287.47,289.6 1 0
github.com/echovault/echovault/pkg/modules/admin/commands.go:290.5,290.41 1 0
github.com/echovault/echovault/pkg/modules/connection/commands.go:25.108,26.18 1 1
github.com/echovault/echovault/pkg/modules/connection/commands.go:27.10,28.50 1 1
github.com/echovault/echovault/pkg/modules/connection/commands.go:29.9,30.34 1 1
@@ -1022,6 +768,260 @@ github.com/echovault/echovault/pkg/modules/list/key_funcs.go:82.2,82.30 1 1
github.com/echovault/echovault/pkg/modules/list/key_funcs.go:85.51,86.19 1 1
github.com/echovault/echovault/pkg/modules/list/key_funcs.go:86.19,88.3 1 1
github.com/echovault/echovault/pkg/modules/list/key_funcs.go:89.2,89.38 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:33.13,34.34 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:34.34,38.3 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:40.2,41.29 2 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:41.29,43.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:51.104,53.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:53.16,55.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:57.2,62.16 5 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:62.16,64.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:68.2,68.16 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:68.16,69.34 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:69.34,71.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:71.9,73.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:76.2,76.44 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:76.44,78.34 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:78.34,80.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:81.3,81.36 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:82.8,82.51 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:82.51,84.33 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:84.33,86.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:87.3,87.45 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:88.8,90.34 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:90.34,93.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:93.9,96.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:98.2,98.16 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:98.16,100.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:101.2,103.76 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:103.76,105.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:108.2,108.28 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:108.28,110.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:112.2,112.17 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:115.105,116.44 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:116.44,118.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:120.2,123.15 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:123.15,124.29 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:124.29,125.16 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:125.16,131.5 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:136.2,136.30 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:136.30,137.15 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:137.15,142.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:147.2,147.28 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:147.28,148.31 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:148.31,149.52 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:149.52,151.5 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:152.4,153.12 2 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:155.3,155.60 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:155.60,157.4 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:158.3,158.55 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:162.2,162.28 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:162.28,163.58 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:163.58,165.4 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:168.2,168.38 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:171.104,173.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:173.16,175.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:176.2,178.33 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:178.33,180.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:182.2,183.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:183.16,185.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:186.2,190.51 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:193.105,195.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:195.16,197.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:199.2,202.27 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:202.27,203.31 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:203.31,205.12 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:207.3,207.33 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:207.33,209.18 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:209.18,211.5 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:212.4,213.12 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:215.3,215.19 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:217.2,217.15 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:217.15,218.34 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:218.34,219.14 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:219.14,222.5 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:226.2,226.28 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:226.28,228.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:230.2,232.30 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:232.30,233.24 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:233.24,235.12 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:237.3,237.96 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:240.2,240.19 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:243.104,245.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:245.16,247.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:248.2,249.27 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:249.27,251.17 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:251.17,253.12 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:255.3,255.13 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:257.2,257.51 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:260.108,262.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:262.16,264.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:266.2,268.33 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:268.33,270.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:272.2,272.51 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:272.51,274.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:275.2,278.31 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:278.31,280.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:282.2,284.30 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:287.111,289.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:289.16,291.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:293.2,295.33 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:295.33,297.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:299.2,299.52 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:299.52,301.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:302.2,306.31 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:306.31,308.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:310.2,311.46 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:311.46,313.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:315.2,315.47 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:318.104,320.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:320.16,322.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:324.2,326.33 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:326.33,328.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:330.2,330.52 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:330.52,332.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:333.2,337.31 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:337.31,339.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:341.2,342.39 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:342.39,344.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:346.2,346.12 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:346.12,348.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:350.2,350.47 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:353.107,355.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:355.16,357.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:359.2,363.16 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:363.16,365.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:366.2,367.42 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:367.42,369.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:371.2,371.33 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:371.33,373.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:375.2,375.51 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:375.51,377.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:378.2,380.19 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:380.19,383.3 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:385.2,387.33 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:388.12,389.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:389.39,391.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:392.3,392.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:393.12,394.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:394.39,396.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:397.3,397.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:398.12,399.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:399.39,401.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:402.3,402.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:402.39,404.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:405.3,405.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:406.12,407.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:407.39,408.40 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:408.40,410.5 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:411.4,411.47 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:413.3,413.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:414.10,415.71 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:418.2,418.30 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:421.109,423.16 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:423.16,425.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:427.2,431.16 3 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:431.16,433.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:434.2,435.44 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:435.44,437.3 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:439.2,439.33 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:439.33,441.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:443.2,443.51 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:443.51,445.3 1 0
github.com/echovault/echovault/pkg/modules/generic/commands.go:446.2,448.19 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:448.19,451.3 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:453.2,455.33 2 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:456.12,457.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:457.39,459.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:460.3,460.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:461.12,462.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:462.39,464.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:465.3,465.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:466.12,467.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:467.39,469.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:470.3,470.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:470.39,472.4 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:473.3,473.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:474.12,475.39 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:475.39,476.40 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:476.40,478.5 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:479.4,479.47 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:481.3,481.46 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:482.10,483.71 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:486.2,486.30 1 1
github.com/echovault/echovault/pkg/modules/generic/commands.go:489.33,658.2 1 0
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:22.49,23.34 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:23.34,25.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:26.2,26.30 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:29.50,30.25 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:30.25,32.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:33.2,34.30 2 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:34.30,35.15 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:35.15,37.4 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:39.2,39.18 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:42.49,43.19 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:43.19,45.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:46.2,46.30 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:49.50,50.18 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:50.18,52.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:53.2,53.21 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:56.49,57.18 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:57.18,59.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:60.2,60.21 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:63.53,64.19 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:64.19,66.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:67.2,67.21 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:70.56,71.19 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:71.19,73.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:74.2,74.21 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:77.49,78.19 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:78.19,80.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:81.2,81.21 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:84.52,85.34 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:85.34,87.3 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:88.2,88.30 1 1
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:91.54,92.34 1 0
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:92.34,94.3 1 0
github.com/echovault/echovault/pkg/modules/generic/key_funcs.go:95.2,95.30 1 0
github.com/echovault/echovault/pkg/modules/generic/utils.go:31.77,32.19 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:32.19,34.3 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:35.2,35.33 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:36.13,38.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:40.12,41.26 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:41.26,43.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:44.3,45.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:47.12,48.26 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:48.26,50.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:51.3,52.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:54.12,55.19 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:55.19,57.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:58.3,58.29 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:58.29,60.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:61.3,63.17 3 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:63.17,65.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:66.3,67.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:69.12,70.19 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:70.19,72.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:73.3,73.29 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:73.29,75.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:76.3,78.17 3 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:78.17,80.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:81.3,82.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:84.14,85.19 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:85.19,87.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:88.3,88.29 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:88.29,90.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:91.3,93.17 3 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:93.17,95.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:96.3,97.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:99.14,100.19 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:100.19,102.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:103.3,103.29 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:103.29,105.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:106.3,108.17 3 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:108.17,110.4 1 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:111.3,112.46 2 1
github.com/echovault/echovault/pkg/modules/generic/utils.go:114.10,115.95 1 1
github.com/echovault/echovault/pkg/modules/pubsub/commands.go:27.113,29.9 2 1
github.com/echovault/echovault/pkg/modules/pubsub/commands.go:29.9,31.3 1 0
github.com/echovault/echovault/pkg/modules/pubsub/commands.go:33.2,35.24 2 1

2
docker-compose.yaml
View File

@@ -22,7 +22,7 @@ services:
- MTLS=false
- BOOTSTRAP_CLUSTER=false
- ACL_CONFIG=/etc/config/echovault/acl.yml
- REQUIRE_PASS=true
- REQUIRE_PASS=false
- PASSWORD=password1
- FORWARD_COMMAND=false
- SNAPSHOT_THRESHOLD=1000

167
pkg/echovault/api_pubsub.go
View File

@@ -13,3 +13,170 @@
// limitations under the License.
package echovault
import (
"bytes"
"github.com/echovault/echovault/internal"
"github.com/tidwall/resp"
"net"
)
type connMap struct {
readConn *net.Conn
writeConn *net.Conn
}
var conns map[string]connMap
type ReadMessage func() []string
func (server *EchoVault) SUBSCRIBE(name string, channels ...string) ReadMessage {
// Initialize connection tracker if calling subscribe for the first time
if conns == nil {
conns = make(map[string]connMap)
}
// If connection with this name does not exist, create new connection it
var readConn net.Conn
var writeConn net.Conn
if _, ok := conns[name]; !ok {
readConn, writeConn = net.Pipe()
conns[name] = connMap{
readConn: &readConn,
writeConn: &writeConn,
}
}
// Subscribe connection to the provided channels
cmd := append([]string{"SUBSCRIBE"}, channels...)
go func() {
_, _ = server.handleCommand(server.context, internal.EncodeCommand(cmd), conns[name].writeConn, false)
}()
return func() []string {
r := resp.NewConn(readConn)
v, _, _ := r.ReadValue()
res := make([]string, len(v.Array()))
for i := 0; i < len(res); i++ {
res[i] = v.Array()[i].String()
}
return res
}
}
func (server *EchoVault) UNSUBSCRIBE(name string, channels ...string) {
if conns == nil {
return
}
if _, ok := conns[name]; !ok {
return
}
cmd := append([]string{"UNSUBSCRIBE"}, channels...)
_, _ = server.handleCommand(server.context, internal.EncodeCommand(cmd), conns[name].writeConn, false)
}
func (server *EchoVault) PSUBSCRIBE(name string, patterns ...string) ReadMessage {
// Initialize connection tracker if calling subscribe for the first time
if conns == nil {
conns = make(map[string]connMap)
}
// If connection with this name does not exist, create new connection it
var readConn net.Conn
var writeConn net.Conn
if _, ok := conns[name]; !ok {
readConn, writeConn = net.Pipe()
conns[name] = connMap{
readConn: &readConn,
writeConn: &writeConn,
}
}
// Subscribe connection to the provided channels
cmd := append([]string{"PSUBSCRIBE"}, patterns...)
go func() {
_, _ = server.handleCommand(server.context, internal.EncodeCommand(cmd), conns[name].writeConn, false)
}()
return func() []string {
r := resp.NewConn(readConn)
v, _, _ := r.ReadValue()
res := make([]string, len(v.Array()))
for i := 0; i < len(res); i++ {
res[i] = v.Array()[i].String()
}
return res
}
}
func (server *EchoVault) PUNSUBSCRIBE(name string, patterns ...string) {
if conns == nil {
return
}
if _, ok := conns[name]; !ok {
return
}
cmd := append([]string{"PUNSUBSCRIBE"}, patterns...)
_, _ = server.handleCommand(server.context, internal.EncodeCommand(cmd), conns[name].writeConn, false)
}
func (server *EchoVault) PUBLISH(channel, message string) (string, error) {
b, err := server.handleCommand(server.context, internal.EncodeCommand([]string{"PUBLISH", channel, message}), nil, false)
if err != nil {
return "", err
}
return internal.ParseStringResponse(b)
}
func (server *EchoVault) PUBSUB_CHANNELS(pattern string) ([]string, error) {
cmd := []string{"PUBSUB", "CHANNELS"}
if pattern != "" {
cmd = append(cmd, pattern)
}
b, err := server.handleCommand(server.context, internal.EncodeCommand(cmd), nil, false)
if err != nil {
return nil, err
}
return internal.ParseStringArrayResponse(b)
}
func (server *EchoVault) PUBSUB_NUMPAT() (int, error) {
b, err := server.handleCommand(server.context, internal.EncodeCommand([]string{"PUBSUB", "NUMPAT"}), nil, false)
if err != nil {
return 0, err
}
return internal.ParseIntegerResponse(b)
}
func (server *EchoVault) PUBSUB_NUMSUB(channels ...string) (map[string]int, error) {
cmd := append([]string{"PUBSUB", "NUMSUB"}, channels...)
b, err := server.handleCommand(server.context, internal.EncodeCommand(cmd), nil, false)
if err != nil {
return nil, err
}
r := resp.NewReader(bytes.NewReader(b))
v, _, err := r.ReadValue()
if err != nil {
return nil, err
}
arr := v.Array()
result := make(map[string]int, len(arr))
for _, entry := range arr {
e := entry.Array()
result[e[0].String()] = e[1].Integer()
}
return result, nil
}

4
pkg/echovault/modules.go
View File

@@ -65,14 +65,12 @@ func (server *EchoVault) handleCommand(ctx context.Context, message []byte, conn
handler = subCommand.HandlerFunc
}
if conn != nil {
if conn != nil && server.ACL != nil {
// Authorize connection if it's provided and if ACL module is present
if server.ACL != nil {
if err = server.ACL.AuthorizeConnection(conn, cmd, command, subCommand); err != nil {
return nil, err
}
}
}
// If the command is a write command, wait for state copy to finish.
if internal.IsWriteCommand(command, subCommand) {