TRKJ/EdgeNode
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeNode.git synced 2025-11-09 20:10:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化代码

Browse Source
This commit is contained in:
GoEdgeLab
2022-11-17 20:28:55 +08:00
parent faae65d71a
commit 0fe1c1efd8
1 changed files with 0 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
internal/rpc/rpc_client.go
View File

@@ -27,9 +27,6 @@ type RPCClient struct {
apiConfig *configs.APIConfig apiConfig *configs.APIConfig
conns []*grpc.ClientConn conns []*grpc.ClientConn
ctx context.Context
ctxUpdatedAt int64
locker sync.RWMutex locker sync.RWMutex
NodeRPC pb.NodeServiceClient NodeRPC pb.NodeServiceClient
@@ -97,12 +94,6 @@ func NewRPCClient(apiConfig *configs.APIConfig) (*RPCClient, error) {
// Context 节点上下文信息 // Context 节点上下文信息
func (this *RPCClient) Context() context.Context { func (this *RPCClient) Context() context.Context {
var currentTime = time.Now().Unix()
if this.ctx != nil && this.ctxUpdatedAt > currentTime-5 {
return this.ctx
}
var m = maps.Map{ var m = maps.Map{
"timestamp": time.Now().Unix(), "timestamp": time.Now().Unix(),
"type": "node", "type": "node",
@@ -122,10 +113,6 @@ func (this *RPCClient) Context() context.Context {
var ctx = context.Background() var ctx = context.Background()
ctx = metadata.AppendToOutgoingContext(ctx, "nodeId", this.apiConfig.NodeId, "token", token) ctx = metadata.AppendToOutgoingContext(ctx, "nodeId", this.apiConfig.NodeId, "token", token)
this.ctxUpdatedAt = currentTime
this.ctx = ctx
return ctx return ctx
} }