tk/Ocelot
1
0
Fork 0
mirror of https://github.com/nsnail/Ocelot.git synced 2025-08-04 17:28:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat：fix kube config

Browse Source
This commit is contained in:
geffzhang
2019-01-20 13:17:57 +08:00
parent 23248b080e
commit c212604b85
8 changed files with 53 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/Ocelot.Provider.Kubernetes/KubeProvider.cs
View File

@ -10,14 +10,14 @@ using System.Threading.Tasks;
namespace Ocelot.Provider.Kubernetes
{
public class KubeProvider : IServiceDiscoveryProvider
public class Kube : IServiceDiscoveryProvider
{
private KubeRegistryConfiguration kubeRegistryConfiguration;
private IOcelotLoggerFactory factory;
private IKubeApiClient kubeApi;
private IKubeApiClientFactory kubeClientFactory;
public KubeProvider(KubeRegistryConfiguration kubeRegistryConfiguration, IOcelotLoggerFactory factory, IKubeApiClientFactory kubeClientFactory)
public Kube(KubeRegistryConfiguration kubeRegistryConfiguration, IOcelotLoggerFactory factory, IKubeApiClientFactory kubeClientFactory)
{
this.kubeRegistryConfiguration = kubeRegistryConfiguration;
this.factory = factory;

4
src/Ocelot.Provider.Kubernetes/KubernetesProviderFactory.cs
View File

@ -11,7 +11,7 @@ namespace Ocelot.Provider.Kubernetes
public static ServiceDiscoveryFinderDelegate Get = (provider, config, name) =>
{
var factory = provider.GetService<IOcelotLoggerFactory>();
if (config.Type?.ToLower() == "k8s")
if (config.Type?.ToLower() == "kube")
{
return GetkubeProvider(provider, config, name, factory);
}
@ -31,7 +31,7 @@ namespace Ocelot.Provider.Kubernetes
AllowInsecure = true // Don't validate server certificate
};
var k8sServiceDiscoveryProvider = new KubeProvider(k8sRegistryConfiguration, factory, kubeClientFactory);
var k8sServiceDiscoveryProvider = new Kube(k8sRegistryConfiguration, factory, kubeClientFactory);
return k8sServiceDiscoveryProvider;
}