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

实现IP库检查更新

Browse Source
This commit is contained in:
GoEdgeLab
2022-08-23 14:32:39 +08:00
parent 98d8f546de
commit 3ad1cb9b3d
3 changed files with 113 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
internal/rpc/rpc_client.go
View File

@@ -79,6 +79,10 @@ func (this *RPCClient) IPLibraryRPC() pb.IPLibraryServiceClient {
return pb.NewIPLibraryServiceClient(this.pickConn())
}
func (this *RPCClient) IPLibraryArtifactRPC() pb.IPLibraryArtifactServiceClient {
return pb.NewIPLibraryArtifactServiceClient(this.pickConn())
}
func (this *RPCClient) RegionCountryRPC() pb.RegionCountryServiceClient {
return pb.NewRegionCountryServiceClient(this.pickConn())
}
@@ -141,7 +145,7 @@ func (this *RPCClient) SSLCertRPC() pb.SSLCertServiceClient {
// Context 节点上下文信息
func (this *RPCClient) Context() context.Context {
ctx := context.Background()
var ctx = context.Background()
m := maps.Map{
"timestamp": time.Now().Unix(),
"type": "node",
@@ -157,7 +161,7 @@ func (this *RPCClient) Context() context.Context {
utils.PrintError(err)
return context.Background()
}
token := base64.StdEncoding.EncodeToString(data)
var token = base64.StdEncoding.EncodeToString(data)
ctx = metadata.AppendToOutgoingContext(ctx, "nodeId", this.apiConfig.NodeId, "token", token)
return ctx
}