mirror of
https://github.com/hibiken/asynq.git
synced 2025-10-26 11:16:12 +08:00
Commit Graph
Select branches
Hide Pull Requests
dependabot/go_modules/github.com/redis/go-redis/v9-9.7.1
dependabot/go_modules/github.com/spf13/cast-1.7.1
dependabot/go_modules/golang.org/x/sys-0.31.0
dependabot/go_modules/golang.org/x/time-0.11.0
dependabot/go_modules/google.golang.org/protobuf-1.36.5
dependabot/go_modules/tools/github.com/gdamore/tcell/v2-2.8.1
dependabot/go_modules/tools/github.com/hibiken/asynq-0.25.1
dependabot/go_modules/tools/github.com/prometheus/client_golang-1.21.1
dependabot/go_modules/tools/github.com/spf13/cobra-1.9.1
dependabot/go_modules/tools/github.com/spf13/viper-1.19.0
dependabot/go_modules/x/github.com/google/uuid-1.6.0
dependabot/go_modules/x/github.com/hibiken/asynq-0.25.1
dependabot/go_modules/x/github.com/prometheus/client_golang-1.21.1
dependabot/go_modules/x/github.com/redis/go-redis/v9-9.7.1
develop
go-versions
master
revert-491-master
revert-937-dependabot/go_modules/golang.org/x/time-0.7.0
sohail/activate-dependabot
sohail/changelog/v0.25.0
sohail/pm-redis-conn-hotfix
sohail/recoverer-fix
sohail/release-v0.25.0
sohail/unix-stop-signal
#1
#10
#100
#1000
#1000
#1003
#1004
#1005
#1005
#1006
#1009
#101
#1010
#1011
#1012
#1012
#1014
#1018
#1019
#102
#1020
#1020
#1023
#1023
#1024
#1024
#1025
#1026
#1027
#1027
#1029
#1029
#1031
#1031
#1032
#1032
#1033
#1033
#1034
#1034
#1035
#1035
#1036
#1036
#1042
#1042
#1047
#1047
#1054
#1054
#1058
#1058
#1059
#1059
#106
#1061
#1061
#1063
#1063
#1064
#1066
#1066
#1067
#1069
#107
#1070
#1070
#1073
#1073
#1082
#1082
#11
#110
#111
#112
#113
#114
#115
#116
#117
#118
#12
#120
#126
#127
#128
#13
#130
#133
#134
#135
#136
#137
#14
#140
#141
#142
#144
#145
#146
#148
#149
#15
#150
#151
#152
#153
#156
#157
#159
#16
#161
#162
#163
#165
#169
#17
#170
#171
#174
#176
#177
#178
#18
#180
#181
#184
#185
#186
#188
#188
#189
#190
#191
#193
#2
#200
#202
#205
#207
#208
#209
#21
#211
#217
#219
#22
#225
#226
#229
#231
#232
#234
#235
#236
#237
#238
#239
#24
#247
#248
#249
#25
#251
#252
#253
#254
#255
#257
#258
#262
#268
#27
#272
#276
#279
#280
#283
#287
#289
#29
#294
#296
#298
#3
#30
#302
#303
#31
#310
#312
#317
#319
#32
#323
#324
#33
#331
#333
#336
#337
#34
#345
#346
#35
#350
#36
#364
#365
#366
#367
#370
#374
#375
#377
#378
#384
#386
#391
#392
#394
#399
#4
#400
#402
#404
#406
#407
#408
#41
#415
#42
#424
#426
#43
#432
#433
#44
#440
#448
#451
#452
#454
#455
#457
#467
#469
#47
#470
#476
#477
#48
#482
#484
#486
#49
#490
#491
#494
#494
#496
#5
#502
#505
#505
#509
#51
#514
#514
#517
#52
#528
#533
#534
#537
#54
#543
#543
#550
#557
#559
#56
#560
#561
#562
#563
#563
#564
#564
#567
#57
#576
#576
#577
#58
#585
#588
#59
#596
#597
#598
#598
#6
#602
#606
#606
#607
#61
#614
#615
#616
#619
#62
#620
#621
#623
#623
#627
#637
#638
#64
#644
#644
#647
#647
#65
#657
#658
#66
#665
#667
#67
#673
#674
#676
#677
#677
#68
#680
#682
#683
#683
#687
#689
#692
#694
#696
#697
#698
#699
#7
#70
#700
#701
#702
#703
#704
#705
#706
#707
#708
#709
#71
#712
#713
#714
#715
#72
#720
#726
#727
#73
#732
#734
#736
#736
#739
#74
#740
#742
#743
#75
#750
#753
#754
#758
#759
#76
#760
#761
#767
#770
#771
#772
#776
#777
#778
#779
#780
#784
#788
#79
#791
#795
#796
#8
#80
#802
#807
#809
#81
#810
#812
#813
#814
#815
#816
#817
#818
#818
#82
#822
#823
#824
#825
#827
#828
#829
#833
#834
#835
#838
#838
#839
#840
#841
#843
#849
#85
#857
#858
#86
#860
#865
#865
#868
#870
#874
#876
#877
#877
#878
#878
#879
#879
#882
#89
#891
#895
#896
#9
#914
#916
#918
#92
#920
#921
#922
#924
#925
#926
#927
#928
#929
#93
#930
#931
#932
#933
#934
#935
#936
#937
#938
#939
#939
#94
#940
#941
#942
#944
#945
#946
#947
#948
#95
#950
#953
#954
#955
#956
#957
#958
#96
#962
#963
#964
#965
#966
#969
#97
#970
#971
#972
#973
#973
#976
#976
#977
#978
#978
#980
#982
#984
#984
#988
#988
#989
#99
#990
#991
#991
#992
#992
#995
#995
#996
v0.1.0
v0.10.0
v0.10.0.rc1
v0.11.0
v0.12.0
v0.13.0
v0.13.1
v0.14.0
v0.14.1
v0.15.0
v0.16.0
v0.16.1
v0.17.0
v0.17.1
v0.17.2
v0.18.0
v0.18.1
v0.18.2
v0.18.3
v0.18.4
v0.18.5
v0.18.6
v0.19.0
v0.19.1
v0.2.0
v0.2.1
v0.2.2
v0.20.0
v0.21.0
v0.22.0
v0.22.1
v0.23.0
v0.24.0
v0.24.1
v0.25.0
v0.25.1
v0.3.0
v0.4.0
v0.5.0
v0.6.0
v0.6.1
v0.6.2
v0.7.0
v0.7.1
v0.8.0
v0.8.1
v0.8.2
v0.8.3
v0.9.0
v0.9.1
v0.9.2
v0.9.3
v0.9.4
Select branches
Hide Pull Requests
dependabot/go_modules/github.com/redis/go-redis/v9-9.7.1
dependabot/go_modules/github.com/spf13/cast-1.7.1
dependabot/go_modules/golang.org/x/sys-0.31.0
dependabot/go_modules/golang.org/x/time-0.11.0
dependabot/go_modules/google.golang.org/protobuf-1.36.5
dependabot/go_modules/tools/github.com/gdamore/tcell/v2-2.8.1
dependabot/go_modules/tools/github.com/hibiken/asynq-0.25.1
dependabot/go_modules/tools/github.com/prometheus/client_golang-1.21.1
dependabot/go_modules/tools/github.com/spf13/cobra-1.9.1
dependabot/go_modules/tools/github.com/spf13/viper-1.19.0
dependabot/go_modules/x/github.com/google/uuid-1.6.0
dependabot/go_modules/x/github.com/hibiken/asynq-0.25.1
dependabot/go_modules/x/github.com/prometheus/client_golang-1.21.1
dependabot/go_modules/x/github.com/redis/go-redis/v9-9.7.1
develop
go-versions
master
revert-491-master
revert-937-dependabot/go_modules/golang.org/x/time-0.7.0
sohail/activate-dependabot
sohail/changelog/v0.25.0
sohail/pm-redis-conn-hotfix
sohail/recoverer-fix
sohail/release-v0.25.0
sohail/unix-stop-signal
#1
#10
#100
#1000
#1000
#1003
#1004
#1005
#1005
#1006
#1009
#101
#1010
#1011
#1012
#1012
#1014
#1018
#1019
#102
#1020
#1020
#1023
#1023
#1024
#1024
#1025
#1026
#1027
#1027
#1029
#1029
#1031
#1031
#1032
#1032
#1033
#1033
#1034
#1034
#1035
#1035
#1036
#1036
#1042
#1042
#1047
#1047
#1054
#1054
#1058
#1058
#1059
#1059
#106
#1061
#1061
#1063
#1063
#1064
#1066
#1066
#1067
#1069
#107
#1070
#1070
#1073
#1073
#1082
#1082
#11
#110
#111
#112
#113
#114
#115
#116
#117
#118
#12
#120
#126
#127
#128
#13
#130
#133
#134
#135
#136
#137
#14
#140
#141
#142
#144
#145
#146
#148
#149
#15
#150
#151
#152
#153
#156
#157
#159
#16
#161
#162
#163
#165
#169
#17
#170
#171
#174
#176
#177
#178
#18
#180
#181
#184
#185
#186
#188
#188
#189
#190
#191
#193
#2
#200
#202
#205
#207
#208
#209
#21
#211
#217
#219
#22
#225
#226
#229
#231
#232
#234
#235
#236
#237
#238
#239
#24
#247
#248
#249
#25
#251
#252
#253
#254
#255
#257
#258
#262
#268
#27
#272
#276
#279
#280
#283
#287
#289
#29
#294
#296
#298
#3
#30
#302
#303
#31
#310
#312
#317
#319
#32
#323
#324
#33
#331
#333
#336
#337
#34
#345
#346
#35
#350
#36
#364
#365
#366
#367
#370
#374
#375
#377
#378
#384
#386
#391
#392
#394
#399
#4
#400
#402
#404
#406
#407
#408
#41
#415
#42
#424
#426
#43
#432
#433
#44
#440
#448
#451
#452
#454
#455
#457
#467
#469
#47
#470
#476
#477
#48
#482
#484
#486
#49
#490
#491
#494
#494
#496
#5
#502
#505
#505
#509
#51
#514
#514
#517
#52
#528
#533
#534
#537
#54
#543
#543
#550
#557
#559
#56
#560
#561
#562
#563
#563
#564
#564
#567
#57
#576
#576
#577
#58
#585
#588
#59
#596
#597
#598
#598
#6
#602
#606
#606
#607
#61
#614
#615
#616
#619
#62
#620
#621
#623
#623
#627
#637
#638
#64
#644
#644
#647
#647
#65
#657
#658
#66
#665
#667
#67
#673
#674
#676
#677
#677
#68
#680
#682
#683
#683
#687
#689
#692
#694
#696
#697
#698
#699
#7
#70
#700
#701
#702
#703
#704
#705
#706
#707
#708
#709
#71
#712
#713
#714
#715
#72
#720
#726
#727
#73
#732
#734
#736
#736
#739
#74
#740
#742
#743
#75
#750
#753
#754
#758
#759
#76
#760
#761
#767
#770
#771
#772
#776
#777
#778
#779
#780
#784
#788
#79
#791
#795
#796
#8
#80
#802
#807
#809
#81
#810
#812
#813
#814
#815
#816
#817
#818
#818
#82
#822
#823
#824
#825
#827
#828
#829
#833
#834
#835
#838
#838
#839
#840
#841
#843
#849
#85
#857
#858
#86
#860
#865
#865
#868
#870
#874
#876
#877
#877
#878
#878
#879
#879
#882
#89
#891
#895
#896
#9
#914
#916
#918
#92
#920
#921
#922
#924
#925
#926
#927
#928
#929
#93
#930
#931
#932
#933
#934
#935
#936
#937
#938
#939
#939
#94
#940
#941
#942
#944
#945
#946
#947
#948
#95
#950
#953
#954
#955
#956
#957
#958
#96
#962
#963
#964
#965
#966
#969
#97
#970
#971
#972
#973
#973
#976
#976
#977
#978
#978
#980
#982
#984
#984
#988
#988
#989
#99
#990
#991
#991
#992
#992
#995
#995
#996
v0.1.0
v0.10.0
v0.10.0.rc1
v0.11.0
v0.12.0
v0.13.0
v0.13.1
v0.14.0
v0.14.1
v0.15.0
v0.16.0
v0.16.1
v0.17.0
v0.17.1
v0.17.2
v0.18.0
v0.18.1
v0.18.2
v0.18.3
v0.18.4
v0.18.5
v0.18.6
v0.19.0
v0.19.1
v0.2.0
v0.2.1
v0.2.2
v0.20.0
v0.21.0
v0.22.0
v0.22.1
v0.23.0
v0.24.0
v0.24.1
v0.25.0
v0.25.1
v0.3.0
v0.4.0
v0.5.0
v0.6.0
v0.6.1
v0.6.2
v0.7.0
v0.7.1
v0.8.0
v0.8.1
v0.8.2
v0.8.3
v0.9.0
v0.9.1
v0.9.2
v0.9.3
v0.9.4
-
9e548fc097
Implement reusing redis client
Jeroen Bobbeldijk
2023-09-19 10:16:51 +02:00 -
de18fe9839
Update README about supported Go versions
go-versions
Ken Hibino
2023-09-17 19:35:33 -07:00 -
714d62bb75
Bound build to the latest two go versions
Ken Hibino
2023-09-17 19:26:16 -07:00 -
6a7bf2ceff
Bump github.com/google/uuid from 1.3.0 to 1.3.1 in /x
dependabot[bot]
2023-08-21 23:16:42 +00:00 -
e7fa0ae865
Bump google.golang.org/protobuf from 1.26.0 to 1.31.0
dependabot[bot]
2023-07-31 23:39:58 +00:00 -
fc4b6713f6
Bump github.com/spf13/cast from 1.3.1 to 1.5.1
dependabot[bot]
2023-07-31 23:40:04 +00:00 -
6b98c0bbae
Bump github.com/google/uuid from 1.2.0 to 1.3.0 (#699)
dependabot[bot]
2023-07-31 16:14:25 +08:00 -
ed1ab8ee55
Bump github.com/golang/protobuf from 1.5.2 to 1.5.3 (#703)
dependabot[bot]
2023-07-31 16:14:12 +08:00 -
e18c0381ad
Bump golang.org/x/time from 0.0.0-20190308202827-9d24e82272b4 to 0.3.0 (#696)
dependabot[bot]
2023-07-31 15:59:16 +08:00 -
8b422c237c
feat (ci/cd): add dependabot weekly checks
Mohammed Sohail
2023-07-24 13:37:53 +08:00 -
e6f74c1c2b
Bump golang.org/x/text from 0.3.7 to 0.3.8 in /tools (#619)
dependabot[bot]
2023-07-24 15:12:45 +08:00 -
54e2307fdd
feat (ci/cd): add dependabot weekly checks
sohail/activate-dependabot
Mohammed Sohail
2023-07-24 13:37:53 +08:00 -
6edba6994e
Bump github.com/prometheus/client_golang from 1.11.0 to 1.11.1 in /tools (#614)
dependabot[bot]
2023-07-24 11:44:52 +08:00 -
571f0d2613
Bump github.com/prometheus/client_golang from 1.11.0 to 1.11.1 in /x (#615)
dependabot[bot]
2023-07-24 11:43:45 +08:00 -
fd08c06232
Revert "feat (add): panic error handling (#491)"
revert-491-master
Ken Hibino
2023-07-20 07:08:49 -07:00 -
2165ed133b
Upgrade tools to use redis v9
Andrew Bezzub
2023-07-17 13:39:18 -07:00 -
551b0c7119
feat (add): panic error handling (#491)
Trịnh Đức Bảo Linh(Kevin)
2023-07-20 20:33:39 +07:00 -
123d560a44
chore: replace loop with mux.mws = append(mux.mws, mws...)
guoguangwu
2023-07-07 10:03:11 +08:00 -
5bef53d1ac
Update README.md to include sponsoring section
Ken Hibino
2023-07-07 21:00:05 -07:00 -
90af7749ca
Update FUNDING.yml
Ken Hibino
2023-07-07 20:54:12 -07:00 -
e4b8663154
chore: unnecessary use of fmt.Sprintf
guoguangwu
2023-07-07 10:05:34 +08:00 -
fde294be32
v0.24.1
v0.24.1
Ken Hibino
2023-05-01 06:48:07 -07:00 -
cbb1be34ac
(tools & x): revert to v8 version
cc777ebMohammed Sohail
2023-04-10 07:56:25 +00:00 -
6ed70adf3b
fix: breaking build below go < 1.18
Mohammed Sohail
2023-04-08 08:10:57 +00:00 -
1f42d71e9b
pkg (tools): revert replace directive in go.mod
Mohammed Sohail
2023-03-31 09:58:51 +00:00 -
f966a6c3b8
completely update Redis package
Phước Trung
2023-03-22 10:01:51 +07:00 -
8b057b8767
tests: restore ignore goleak.IgnoreTopFunction
Mohammed Sohail
2023-03-31 07:26:59 +00:00 -
c72bfef094
fix unit test
Phước Trung
2023-03-22 10:11:14 +07:00 -
dffb78cca4
pkg: remove v8 refs
Mohammed Sohail
2023-03-14 14:53:59 +00:00 -
0275df8df4
Update redis/go-redis to v9
Emanuel Bennici
2023-01-11 15:41:38 +01:00 -
cc777ebdaa
fix some typos
cui fliter
2023-01-05 15:23:05 +08:00 -
783071c47f
v0.24.0
v0.24.0
Ken Hibino
2023-01-02 14:55:33 -08:00 -
bafed907e9
Fix redis script error
Ken Hibino
2023-01-02 13:17:18 -08:00 -
0b8cfad703
(cli:fix) Read --cluster flag from config file
Ken Hibino
2022-12-18 20:27:02 -08:00 -
c08f142b56
fix redis sentinel url parse
Zhidong Chen
2022-09-09 10:27:02 +08:00 -
c70ff6a335
fix a missing ticker.stop()
徐胖
2022-06-27 04:10:06 +08:00 -
a04ba6411d
Fix dash command flags
Ken Hibino
2022-06-22 20:57:11 -07:00 -
d0209d9273
Remove error log from Scheduler
Ken Hibino
2022-06-04 12:48:56 -07:00 -
6c954c87bf
Update readme
Ken Hibino
2022-06-03 04:14:45 -07:00 -
86fe31990b
(cli): Add dash command
Ken Hibino
2022-06-02 19:23:06 -07:00 -
e0e5d1ac24
Add pre and post enqueue callback options for Scheduler
Chih Sean Hsu
2022-05-28 01:50:02 +08:00 -
30d409371b
Fix comment typos
Trịnh Đức Bảo Linh
2022-05-17 11:14:15 +07:00 -
aefd276146
Upgrade goleak version
Mohab Abd El-Dayem
2022-05-08 19:17:22 +02:00 -
94ad9e5e74
Update CONTRIBUTING.md to use git ssh
Mohab Abd El-Dayem
2022-05-08 18:21:33 +02:00 -
5187844ca5
Update CLI install command in README
Ken Hibino
2022-05-06 16:55:54 -07:00 -
4dd2b5738a
(cli): Improve help command output
Ken Hibino
2022-05-06 16:18:40 -07:00 -
9116c096ec
docs: correct typo (deafult => default)
Jeffrey Lo
2022-05-04 20:07:09 -04:00 -
5c723f597e
Correct the error message to cancel an active tasks
Erwan Leboucher
2022-04-13 10:37:18 +02:00 -
dd6f84c575
(cli): Use asynq v0.23
Ken Hibino
2022-04-13 06:07:31 -07:00 -
c438339c3d
Fix date in changelog
Ken Hibino
2022-04-12 06:22:42 -07:00 -
901938b0fe
Update readme
Ken Hibino
2022-04-11 17:07:24 -07:00 -
245d4fe663
v0.23.0
v0.23.0
Ken Hibino
2022-04-11 16:57:33 -07:00 -
94719e325c
Update CHANGELOG.md
Ken Hibino
2022-04-11 16:52:07 -07:00 -
8b2a787759
Rename variables for public API documentation
Ken Hibino
2022-04-10 17:55:21 -07:00 -
451be7e50f
(cli): Update stats command to print the number of aggregating tasks
Ken Hibino
2022-04-09 15:52:58 -07:00 -
578321f226
(cli): Extend task ls command to list aggregating tasks
Ken Hibino
2022-04-09 15:47:33 -07:00 -
2c783566f3
(cli): Add group ls command
Ken Hibino
2022-04-09 06:49:22 -07:00 -
39718f8bea
Always enqueue the aggregated task in the same queue
Ken Hibino
2022-04-07 06:19:04 -07:00 -
829f64fd38
Define GroupAggregator interface
Ken Hibino
2022-04-07 06:13:49 -07:00 -
a369443955
Add batch actions to inspector for aggregating tasks
Ken Hibino
2022-03-30 05:58:38 -07:00 -
de139cc18e
Update RDB.RunTask to schedule aggregating task
Ken Hibino
2022-03-29 06:27:56 -07:00 -
74db013ab9
Add RDB.RunAllAggregatingTasks
Ken Hibino
2022-03-29 06:15:01 -07:00 -
725105ca03
Update RDB.ArchiveTask to archive aggregating task
Ken Hibino
2022-03-28 06:59:57 -07:00 -
d8f31e45f1
Add RDB.ArchiveAllAggregatingTasks
Ken Hibino
2022-03-28 06:29:44 -07:00 -
9023cbf4be
Update RDB.DeleteTask to handle aggregating task
Ken Hibino
2022-03-27 16:25:03 -07:00 -
9279c09125
Add RDB.DeleteAllAggregatingTasks
Ken Hibino
2022-03-27 15:52:46 -07:00 -
bc27126670
Fix memory usage lua script
Ken Hibino
2022-03-26 14:33:03 -07:00 -
0cfa7f47ba
Fix memory_usage lua script
Ken Hibino
2022-03-23 16:21:45 -07:00 -
8a4fb71dd5
Update go.mod with replace directive
Ken Hibino
2022-03-22 06:30:43 -07:00 -
7fb5b25944
Add Inspector.ListAggregatingTasks
Ken Hibino
2022-03-22 06:23:22 -07:00 -
71bd8f0535
Add RDB.ListAggregating
Ken Hibino
2022-03-20 06:27:41 -07:00 -
4c8432e0ce
Add Inspector.Groups method
Ken Hibino
2022-03-19 07:23:09 -07:00 -
e939b5d166
Rename asynqtest package to testutil
Ken Hibino
2022-03-19 07:16:55 -07:00 -
1acd62c760
Move test helpers to asynqtest package
Ken Hibino
2022-03-19 07:12:41 -07:00 -
0149396bae
Add RDB.GroupStats for inspecting groups
Ken Hibino
2022-03-18 06:55:22 -07:00 -
45ed560708
Add Group field to TaskInfo struct
Ken Hibino
2022-03-16 20:22:07 -07:00 -
01eeb8756e
(cli): Update queue inspect cmd to show # of groups and aggregating tasks
Ken Hibino
2022-03-16 16:41:44 -07:00 -
47af17cfb4
Fix RDB.CurrentStats to report the correct queue size
Ken Hibino
2022-03-16 16:31:19 -07:00 -
eb064c2bab
Fix AggregationCheck with unlimited size to clear group name from all-groups set
Ken Hibino
2022-03-15 17:03:09 -07:00 -
652939dd3a
Update memory usage redis lua script to account for groups
Ken Hibino
2022-03-15 16:30:25 -07:00 -
efe3c74037
Show number of groups and aggregating task count in QueueInfo
Ken Hibino
2022-03-15 06:52:56 -07:00 -
74d2eea4e0
Clear group if aggregation set empties the group
Ken Hibino
2022-03-13 06:44:42 -07:00 -
60a4dc1401
Add test for DeleteAggregationSet error case
Ken Hibino
2022-03-12 15:29:38 -08:00 -
4b716780ef
Rewrite test for DeleteAggregationSet function with a new pattern
Ken Hibino
2022-03-12 15:18:32 -08:00 -
e63f41fb24
Fix DeleteAggregationSet
Ken Hibino
2022-03-11 15:54:47 -08:00 -
1c388baf06
Implement RDB.ReclaimStaleAggregationSets
Ken Hibino
2022-03-11 12:04:35 -08:00 -
47a66231b3
Store aggregation set *key* in all aggreationsets zset
Ken Hibino
2022-03-11 11:10:44 -08:00 -
3551d3334c
Use zset for aggregation set to preserve score
Ken Hibino
2022-03-11 10:59:05 -08:00 -
8b16ede8bc
Declare ReclaimStaleAggregationSets
Ken Hibino
2022-03-11 10:44:12 -08:00 -
c8658a53e6
Add aggregator test
Ken Hibino
2022-03-11 08:54:00 -08:00 -
562506c7ba
Fix client to return error when nil task is passed
Ken Hibino
2022-03-10 15:59:58 -08:00 -
888b5590fb
Make GroupMaxSize and GroupMaxDelay config optional
Ken Hibino
2022-03-10 15:48:02 -08:00 -
196db64d4d
Run aggregator on the server
Ken Hibino
2022-03-10 12:15:28 -08:00 -
4b35eb0e1a
Fix RDB.AggregationCheck when run against an empty group
Ken Hibino
2022-03-10 11:54:47 -08:00 -
b29fe58434
Implement RDB.ListGroups
Ken Hibino
2022-03-10 11:06:48 -08:00 -
7849b1114c
Implement RDB.DeleteAggregationSet
Ken Hibino
2022-03-10 11:00:28 -08:00 -
99c00bffeb
Implement RDB.AggregationCheck
Ken Hibino
2022-03-09 17:05:16 -08:00 -
4542b52da8
Check for aggregation at an interval <= gracePeriod
Ken Hibino
2022-03-09 06:01:37 -08:00 -
d841dc2f8d
Add initial implementation of aggregator
Ken Hibino
2022-03-08 06:38:35 -08:00 -
ab28234767
Update client dependency to base.Broker
Ken Hibino
2022-03-08 05:59:58 -08:00