diff --git a/internal/rpc/rpc_client.go b/internal/rpc/rpc_client.go index 37dcba6..d181738 100644 --- a/internal/rpc/rpc_client.go +++ b/internal/rpc/rpc_client.go @@ -27,9 +27,6 @@ type RPCClient struct { apiConfig *configs.APIConfig conns []*grpc.ClientConn - ctx context.Context - ctxUpdatedAt int64 - locker sync.RWMutex NodeRPC pb.NodeServiceClient @@ -97,12 +94,6 @@ func NewRPCClient(apiConfig *configs.APIConfig) (*RPCClient, error) { // 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{ "timestamp": time.Now().Unix(), "type": "node", @@ -122,10 +113,6 @@ func (this *RPCClient) Context() context.Context { var ctx = context.Background() ctx = metadata.AppendToOutgoingContext(ctx, "nodeId", this.apiConfig.NodeId, "token", token) - - this.ctxUpdatedAt = currentTime - this.ctx = ctx - return ctx }