guangwu
|
4f13fe8188
|
io/ioutil deprecated (#3215)
|
2023-05-06 16:37:43 +08:00 |
|
Kevin Wan
|
3a493cd6a6
|
chore: add more tests (#3006)
|
2023-03-10 17:36:39 +08:00 |
|
Kevin Wan
|
464ed51728
|
feat: mapreduce generic version (#2827)
* feat: mapreduce generic version
* fix: gateway mr type issue
---------
Co-authored-by: kevin.wan <kevin.wan@yijinin.com>
|
2023-01-29 18:01:23 +08:00 |
|
Kevin Wan
|
ae87114282
|
chore: change interface{} to any (#2818)
* chore: change interface{} to any
* chore: update goctl version to 1.5.0
* chore: update goctl deps
|
2023-01-24 16:32:02 +08:00 |
|
cui fliter
|
fc59aec2e7
|
fix a few function names on comments (#2496)
Signed-off-by: cui fliter <imcusg@gmail.com>
Signed-off-by: cui fliter <imcusg@gmail.com>
|
2022-10-10 22:12:11 +08:00 |
|
Kevin Wan
|
1a6d7b3ef6
|
chore: gofumpt (#2439)
|
2022-09-22 22:40:01 +08:00 |
|
Kevin Wan
|
d935c83a54
|
feat: support baggage propagation in httpc (#2375)
* feat: support baggage propagation in httpc
* chore: use go 1.16
* chore: use go 1.16
* chore: use go ^1.16
* chore: remove deprecated
|
2022-09-10 15:18:52 +08:00 |
|
Kevin Wan
|
d978563523
|
fix: more accurate panic message on mapreduce (#2311)
|
2022-08-27 22:47:25 +08:00 |
|
wxc
|
d200ba4a7b
|
feat: CompareAndSwapInt32 may be better than AddInt32 (#2077)
|
2022-07-01 12:41:32 +08:00 |
|
NoTryNoSuccess
|
fb519fa547
|
core/mr:a little optimization for collector initialization in ForEach function (#1937)
Co-authored-by: notrynosuccess <daihongshan@gmail.com>
|
2022-05-27 17:19:40 +08:00 |
|
Kevin Wan
|
bb75cc796e
|
test: change fuzz tests (#1504)
|
2022-02-05 09:44:01 +08:00 |
|
Kevin Wan
|
ec299085f5
|
docs: update tal-tech to zeromico in docs (#1498)
|
2022-02-01 13:03:30 +08:00 |
|
Kevin Wan
|
6c2abe7474
|
fix: goroutine stuck on edge case (#1495)
* fix: goroutine stuck on edge case
* refactor: simplify mapreduce implementation
|
2022-01-30 13:09:21 +08:00 |
|
Kevin Wan
|
14a902c1a7
|
feat: handling panic in mapreduce, panic in calling goroutine, not inside goroutines (#1490)
* feat: handle panic
* chore: update fuzz test
* chore: optimize square sum algorithm
|
2022-01-28 10:59:41 +08:00 |
|
Kevin Wan
|
b9b80c068b
|
ci: add translator action (#1441)
|
2022-01-12 17:57:39 +08:00 |
|
Kevin Wan
|
8d6d37f71e
|
remove unnecessary drain, fix data race (#1435)
* remove unnecessary drain, fix data race
* chore: fix parameter order
* refactor: rename MapVoid to ForEach in mr
|
2022-01-11 16:17:51 +08:00 |
|
Kevin Wan
|
ea4f2af67f
|
fix: mr goroutine leak on context deadline (#1433)
* fix: mr goroutine leak on context deadline
* test: update fx test check
|
2022-01-10 22:06:10 +08:00 |
|
Kevin Wan
|
a91c3907a8
|
feat: rename module from tal-tech to zeromicro (#1413)
|
2022-01-04 15:51:32 +08:00 |
|
Kevin Wan
|
c19d2637ea
|
feat: implement fx.NoneMatch, fx.First, fx.Last (#1402)
* chore: use workers from options in fx.unlimitedWalk
* feat: add fx.NoneMatch
* feat: add fx.First, fx.Last
* chore: add more comments
* docs: add mr readme
|
2022-01-02 13:33:15 +08:00 |
|
Kevin Wan
|
fe1da14332
|
chore: simplify mapreduce (#1401)
|
2022-01-01 19:24:35 +08:00 |
|
Kevin Wan
|
c0647f0719
|
feat: support context in MapReduce (#1368)
|
2021-12-25 20:42:52 +08:00 |
|
Kevin Wan
|
d0f9e57022
|
fix #957 (#959)
|
2021-08-26 16:47:28 +08:00 |
|
Kevin Wan
|
a87978568a
|
fix #676 (#682)
|
2021-05-10 23:10:57 +08:00 |
|
heyanfu
|
7405d7f506
|
spelling mistakes (#634)
|
2021-04-17 20:15:19 +08:00 |
|
Kevin Wan
|
bbb9126302
|
fix golint issues in core/mr (#500)
|
2021-02-22 09:47:06 +08:00 |
|
kevin
|
f994e1df1a
|
add more tests
|
2020-09-16 20:03:30 +08:00 |
|
kevin
|
df37597ac3
|
simplify mapreduce code
|
2020-09-16 16:48:59 +08:00 |
|
kevin
|
a8fb010333
|
drain pipe if reducer not drained
|
2020-09-12 17:13:32 +08:00 |
|
kevin
|
1cb17311dd
|
add unit test for mapreduce
|
2020-09-06 18:19:19 +08:00 |
|
kevin
|
e987eb60d3
|
fix mapreduce problem when reducer doesn't write
|
2020-09-06 18:13:42 +08:00 |
|
kevin
|
0a7e0cce77
|
update package reference
|
2020-08-08 16:40:10 +08:00 |
|
kevin
|
8c7f871f89
|
refactor
|
2020-07-29 23:15:05 +08:00 |
|
kevin
|
dc744766a9
|
rename mapreduce to mr
|
2020-07-29 22:34:37 +08:00 |
|