opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-09-24 16:03:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

host session use internal endpoint

Browse Source
This commit is contained in:
wanyaoqi
2020-04-01 20:00:59 +08:00
parent 40bc2e3ae1
commit a3318a87c0
2 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/hostman/hostutils/hostutils.go
+3 -3
View File
@@ -53,15 +53,15 @@ type IHost interface {
}
func GetComputeSession(ctx context.Context) *mcclient.ClientSession {
return auth.GetAdminSessionWithPublic(ctx, options.HostOptions.Region, "v2")
return auth.GetAdminSessionWithInternal(ctx, options.HostOptions.Region, "v2")
}
func GetK8sSession(ctx context.Context) *mcclient.ClientSession {
return auth.GetAdminSessionWithPublic(ctx, options.HostOptions.Region, "")
return auth.GetAdminSessionWithInternal(ctx, options.HostOptions.Region, "")
}
func GetImageSession(ctx context.Context, zone string) *mcclient.ClientSession {
return auth.AdminSessionWithPublic(ctx, options.HostOptions.Region, zone, "v1")
return auth.AdminSessionWithInternal(ctx, options.HostOptions.Region, zone, "v1")
}
func TaskFailed(ctx context.Context, reason string) {
pkg/mcclient/auth/auth.go
+5
View File
@@ -356,6 +356,11 @@ func GetAdminSessionWithPublic(ctx context.Context, region string,
return GetSessionWithPublic(ctx, manager.adminCredential, region, apiVersion)
}
func GetAdminSessionWithInternal(
ctx context.Context, region string, apiVersion string) *mcclient.ClientSession {
return GetSessionWithInternal(ctx, manager.adminCredential, region, apiVersion)
}
func GetSession(ctx context.Context, token mcclient.TokenCredential, region string, apiVersion string) *mcclient.ClientSession {
if len(globalEndpointType) != 0 {
return getSessionByType(ctx, token, region, apiVersion, globalEndpointType)