Commit Graph

35 Commits (2096cd574932adf371b064b1aeb0ef7799ef20e2)

Author SHA1 Message Date
Kevin Wan 45be48a4ee
chore: coding style (#3959) 9 months ago
Kevin Wan 77da459165
chore: make test stable (#3412) 1 year ago
guangwu 4f13fe8188
io/ioutil deprecated (#3215) 2 years ago
Kevin Wan 3a493cd6a6
chore: add more tests (#3006) 2 years ago
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>
2 years ago
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
2 years ago
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>
2 years ago
Kevin Wan 1a6d7b3ef6
chore: gofumpt (#2439) 2 years ago
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
2 years ago
Kevin Wan d978563523
fix: more accurate panic message on mapreduce (#2311) 2 years ago
wxc d200ba4a7b
feat: CompareAndSwapInt32 may be better than AddInt32 (#2077) 2 years ago
NoTryNoSuccess fb519fa547
core/mr:a little optimization for collector initialization in ForEach function (#1937)
Co-authored-by: notrynosuccess <daihongshan@gmail.com>
3 years ago
Kevin Wan bb75cc796e
test: change fuzz tests (#1504) 3 years ago
Kevin Wan ec299085f5
docs: update tal-tech to zeromico in docs (#1498) 3 years ago
Kevin Wan 6c2abe7474
fix: goroutine stuck on edge case (#1495)
* fix: goroutine stuck on edge case

* refactor: simplify mapreduce implementation
3 years ago
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
3 years ago
Kevin Wan b9b80c068b
ci: add translator action (#1441) 3 years ago
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
3 years ago
Kevin Wan ea4f2af67f
fix: mr goroutine leak on context deadline (#1433)
* fix: mr goroutine leak on context deadline

* test: update fx test check
3 years ago
Kevin Wan a91c3907a8
feat: rename module from tal-tech to zeromicro (#1413) 3 years ago
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
3 years ago
Kevin Wan fe1da14332
chore: simplify mapreduce (#1401) 3 years ago
Kevin Wan c0647f0719
feat: support context in MapReduce (#1368) 3 years ago
Kevin Wan d0f9e57022
fix #957 (#959) 3 years ago
Kevin Wan a87978568a
fix #676 (#682) 4 years ago
heyanfu 7405d7f506
spelling mistakes (#634) 4 years ago
Kevin Wan bbb9126302
fix golint issues in core/mr (#500) 4 years ago
kevin f994e1df1a add more tests 4 years ago
kevin df37597ac3 simplify mapreduce code 4 years ago
kevin a8fb010333 drain pipe if reducer not drained 4 years ago
kevin 1cb17311dd add unit test for mapreduce 4 years ago
kevin e987eb60d3 fix mapreduce problem when reducer doesn't write 4 years ago
kevin 0a7e0cce77 update package reference 4 years ago
kevin 8c7f871f89 refactor 4 years ago
kevin dc744766a9 rename mapreduce to mr 4 years ago