chore: release v0.2.1 (#386)

* define not found instance error.

* define ErrInstanceNotFound at kerrors.

* tuning err msg for no instance.

* refactor:replace additional atomic operations

* fix:solving the concurrency problem of Hooks.

* optimize: adjust minMaxIdleTimeout to 2s

* optimize: lbcache is global, it doesn't need register ProbeFunc for diagnosis

* docs: update readme with new blog

* chore:upgrade choleraehyq/pid for Go 1.18

* fix(client): fix oneway seqid and lower loss rate (#363)

* optimize: use instance tag instead of remoteinfo tag firstly (#374)

* fix: combine services (#367)

* fix(tool): fix import of protobuf combineservice (#359)

* refactor(loadbalancer): merge function buildWeightedVirtualNodes into buildVirtualNodes (#343)

* refactor(loadbalancer): merge function buildWeightedVirtualNodes into buildVirtualNodes

* Fix readme blog link

* fix(generic): detect circular thrift IDL dependency (#383)

* chore: update version v0.2.1

Co-authored-by: horizonzy <[email protected]>
Co-authored-by: dongzeXD <[email protected]>
Co-authored-by: dongze <[email protected]>
Co-authored-by: YangruiEmma <[email protected]>
Co-authored-by: Joway <[email protected]>
Co-authored-by: luoguangming.ivan <[email protected]>
Co-authored-by: YangruiEmma <[email protected]>
Co-authored-by: HeyJavaBean <[email protected]>
Co-authored-by: lsjbd <[email protected]>
Co-authored-by: Anthony-Dong <[email protected]>
Co-authored-by: Simon Wang <[email protected]>
Co-authored-by: 王恒 <[email protected]>

Author: 11 people

README.md

@@ -91,6 +91,7 @@ We provide the [kitex-benchmark](https://github.com/cloudwego/kitex-benchmark) p
 
 - [Performance Optimization on Kitex](https://www.cloudwego.io/blog/2021/09/23/performance-optimization-on-kitex/)
 - [ByteDance Practice on Go Network Library](https://www.cloudwego.io/blog/2021/10/09/bytedance-practices-on-go-network-library/)
+- [Getting Started With Kitex's Practice: Performance Testing Guide](https://www.cloudwego.io/blog/2021/11/24/getting-started-with-kitexs-practice-performance-testing-guide/)
 
 ## Contributing
 
@@ -106,7 +107,7 @@ Kitex is distributed under the [Apache License, version 2.0](https://github.com/
 - Issues: [Issues](https://github.com/cloudwego/kitex/issues)
 - Lark: Scan the QR code below with [Lark](https://www.larksuite.com/zh_cn/download) to join our CloudWeGo/kitex user group.
 
-  ![LarkGroup](docs/images/lark_group.png)
+  ![LarkGroup](images/lark_group.png)
 
 ## Landscapes
 

README_cn.md

@@ -91,6 +91,7 @@ Kitex[kaɪt'eks] 字节跳动内部的 Golang 微服务 RPC 框架，具有**高
 
 - [字节跳动 Go RPC 框架 Kitex 性能优化实践](https://www.cloudwego.io/zh/blog/2021/09/23/%E5%AD%97%E8%8A%82%E8%B7%B3%E5%8A%A8-go-rpc-%E6%A1%86%E6%9E%B6-kitex-%E6%80%A7%E8%83%BD%E4%BC%98%E5%8C%96%E5%AE%9E%E8%B7%B5/)
 - [字节跳动在 Go 网络库上的实践](https://www.cloudwego.io/zh/blog/2021/10/09/%E5%AD%97%E8%8A%82%E8%B7%B3%E5%8A%A8%E5%9C%A8-go-%E7%BD%91%E7%BB%9C%E5%BA%93%E4%B8%8A%E7%9A%84%E5%AE%9E%E8%B7%B5/)
+- [RPC 框架 Kitex 实践入门：性能测试指南](https://www.cloudwego.io/zh/blog/2021/11/24/rpc-%E6%A1%86%E6%9E%B6-kitex-%E5%AE%9E%E8%B7%B5%E5%85%A5%E9%97%A8%E6%80%A7%E8%83%BD%E6%B5%8B%E8%AF%95%E6%8C%87%E5%8D%97/)
 
 ## 贡献代码
 
@@ -106,7 +107,7 @@ Kitex 基于[Apache License 2.0](LICENSE) 许可证，其依赖的三方组件
 - Issues: [Issues](https://github.com/cloudwego/kitex/issues)
 - 飞书用户群（[注册飞书](https://www.feishu.cn/)进群）
 
-  ![LarkGroup](docs/images/lark_group_cn.png)
+  ![LarkGroup](images/lark_group_cn.png)
 
 ## Landscapes
 

client/option.go

@@ -155,6 +155,9 @@ func WithHostPorts(hostports ...string) Option {
 				}, nil
 			},
 			NameFunc: func() string { return o.Targets },
+			TargetFunc: func(ctx context.Context, target rpcinfo.EndpointInfo) string {
+				return o.Targets
+			},
 		}
 	}}
 }

go.mod

@@ -6,7 +6,7 @@ require (
 	github.com/apache/thrift v0.13.0
 	github.com/bytedance/gopkg v0.0.0-20210910103821-e4efae9c17c3
 	github.com/cespare/xxhash v1.1.0
-	github.com/choleraehyq/pid v0.0.12
+	github.com/choleraehyq/pid v0.0.13
 	github.com/cloudwego/netpoll v0.2.0
 	github.com/cloudwego/netpoll-http2 v0.0.6
 	github.com/cloudwego/thriftgo v0.1.2

go.sum

@@ -12,6 +12,8 @@ github.com/cespare/xxhash v1.1.0 h1:a6HrQnmkObjyL+Gs60czilIUGqrzKutQD6XZog3p+ko=
 github.com/cespare/xxhash v1.1.0/go.mod h1:XrSqR1VqqWfGrhpAt58auRo0WTKS1nRRg3ghfAqPWnc=
 github.com/choleraehyq/pid v0.0.12 h1:JLiTCsz2gStQZ3YWet+p9hktRnWzk7VJigpzvGV+I2o=
 github.com/choleraehyq/pid v0.0.12/go.mod h1:uhzeFgxJZWQsZulelVQZwdASxQ9TIPZYL4TPkQMtL/U=
+github.com/choleraehyq/pid v0.0.13 h1:Tc/jYjHC50SDCxSX+DWHfMmFqtwGR8EiQ08qJ/EK8zs=
+github.com/choleraehyq/pid v0.0.13/go.mod h1:uhzeFgxJZWQsZulelVQZwdASxQ9TIPZYL4TPkQMtL/U=
 github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
 github.com/cloudwego/netpoll v0.1.0/go.mod h1:rZOiNI0FYjuvNybXKKhAPUja03loJi/cdv2F55AE6E8=
 github.com/cloudwego/netpoll v0.2.0 h1:MmZX/jS6ozso86mnbVJ7fUO1hL4LOH/XngXN7Pn347A=

docs/images/lark_group.png renamed to images/lark_group.png

@@ -27,7 +27,7 @@ type IdleConfig struct {
 
 const (
 	defaultMaxIdleTimeout = 30 * time.Second
-	minMaxIdleTimeout     = 3 * time.Second
+	minMaxIdleTimeout     = 2 * time.Second
 )
 
 // CheckPoolConfig to check invalid param.

docs/images/lark_group_cn.png renamed to images/lark_group_cn.png

@@ -50,7 +50,6 @@ const (
 	DestServiceKey ProbeName = "dest_service"
 	ConnPoolKey    ProbeName = "conn_pool"
 	RetryPolicyKey ProbeName = "retry_policy"
-	LbCacheKey     ProbeName = "lb_cache"
 )
 
 // WrapAsProbeFunc is to wrap probe data as ProbeFunc, the data is some infos that you want to diagnosis, like config info.

pkg/connpool/config.go

@@ -19,7 +19,6 @@ package event
 import (
 	"sync"
 	"sync/atomic"
-	"unsafe"
 )
 
 const (
@@ -66,8 +65,7 @@ func (q *queue) Push(e *Event) {
 		newV := oldV + 1
 		if atomic.CompareAndSwapUint32(&q.tail, old, new) && atomic.CompareAndSwapUint32(q.tailVersion[old], oldV, newV) {
 			q.mu.Lock()
-			p := (*unsafe.Pointer)(unsafe.Pointer(&q.ring[old]))
-			atomic.StorePointer(p, unsafe.Pointer(e))
+			q.ring[old] = e
 			q.mu.Unlock()
 			break
 		}