Added sample kubeconfig files to testing project

This commit is contained in:
Sergio Sisternes
2017-06-26 23:08:29 +02:00
parent 799a6bf052
commit de9edb1c23
3 changed files with 100 additions and 13 deletions

View File

@@ -96,14 +96,15 @@ namespace k8s
{ {
Context activeContext; Context activeContext;
// set the currentCOntext to passed context if not null
if (!string.IsNullOrWhiteSpace(currentContext))
{
if (k8SConfig.Contexts == null) if (k8SConfig.Contexts == null)
{ {
throw new KubeConfigException("No contexts found in kubeconfig"); throw new KubeConfigException("No contexts found in kubeconfig");
} }
// set the currentCOntext to passed context if not null
if (!string.IsNullOrWhiteSpace(currentContext))
{
activeContext = k8SConfig.Contexts.FirstOrDefault(c => c.Name.Equals(currentContext, StringComparison.OrdinalIgnoreCase)); activeContext = k8SConfig.Contexts.FirstOrDefault(c => c.Name.Equals(currentContext, StringComparison.OrdinalIgnoreCase));
if (activeContext != null) if (activeContext != null)
{ {

View File

@@ -1,11 +1,20 @@
using System; using System;
using Xunit; using Xunit;
using k8s; using k8s;
using System.IO;
namespace k8s.Tests namespace k8s.Tests
{ {
public class KubernetesClientConfigurationTests public class KubernetesClientConfigurationTests
{ {
/// <summary>
/// This file contains a sample kubeconfig file
/// </summary>
private static readonly string kubeConfigFileName = "assets/kubeconfig.yml";
private static readonly string kubeConfigNoContexts = "assets/kubeconfig-no-context.yml";
/// <summary> /// <summary>
/// Checks Host is loaded from the default configuration file /// Checks Host is loaded from the default configuration file
/// </summary> /// </summary>
@@ -17,16 +26,93 @@ namespace k8s.Tests
} }
/// <summary> /// <summary>
/// Checks if the are pods /// Check if host is properly loaded, per context
/// </summary>
[Theory]
[InlineData("federal-context", "https://horse.org:4443")]
[InlineData("queen-anne-context", "https://pig.org:443")]
public void ContextHostTest(string context, string host)
{
var fi = new FileInfo(kubeConfigFileName);
var cfg = new KubernetesClientConfiguration(fi, context);
Assert.Equal(host, cfg.Host);
}
/// <summary>
/// Checks if user-based token is loaded properly from the config file, per context
/// </summary>
/// <param name="context"></param>
/// <param name="username"></param>
/// <param name="token"></param>
[Theory]
[InlineData("queen-anne-context", "black-user" ,"black-token")]
public void ContextUserTokenTest(string context, string username, string token)
{
var fi = new FileInfo(kubeConfigFileName);
var cfg = new KubernetesClientConfiguration(fi, context);
Assert.Equal(context, cfg.CurrentContext);
Assert.Equal(username, cfg.Username);
Assert.Equal(token, cfg.AccessToken);
}
/// <summary>
/// Checks if certificate-based authentication is loaded properly from the config file, per context
/// </summary>
/// <param name="context">Context to retreive the configuration</param>
/// <param name="clientCertData">'client-certificate-data' node content</param>
/// <param name="clientCertKey">'client-key-data' content</param>
[Theory]
[InlineData("federal-context", "path/to/my/client/cert" ,"path/to/my/client/key")]
public void ContextCertificateTest(string context, string clientCertData, string clientCertKey)
{
var fi = new FileInfo(kubeConfigFileName);
var cfg = new KubernetesClientConfiguration(fi, context);
Assert.Equal(context, cfg.CurrentContext);
Assert.Equal(cfg.ClientCertificateData, clientCertData);
Assert.Equal(cfg.ClientCertificateKey, clientCertKey);
}
/// <summary>
/// Test that an Exception is thrown when initializating a KubernetClientConfiguration whose config file Context is not present
/// </summary> /// </summary>
[Fact] [Fact]
public void ListDefaultNamespacedPod() public void ContextNotFoundTest()
{ {
var k8sClientConfig = new KubernetesClientConfiguration(); var fi = new FileInfo(kubeConfigFileName);
IKubernetes client = new Kubernetes(k8sClientConfig); Assert.Throws<k8s.Exceptions.KubeConfigException>(() => new KubernetesClientConfiguration(fi, "context-not-found"));
var listTask = client.ListNamespacedPodWithHttpMessagesAsync("default").Result;
var list = listTask.Body;
Assert.NotEqual(0, list.Items.Count);
} }
/// <summary>
/// Test if KubeConfigException is thrown when no Contexts and we use the default context name
/// </summary>
[Fact]
public void NoContexts()
{
var fi = new FileInfo(kubeConfigNoContexts);
Assert.Throws<k8s.Exceptions.KubeConfigException>(() => new KubernetesClientConfiguration(fi));
}
/// <summary>
/// Test if KubeConfigException is thrown when no Contexts are set and we specify a concrete context name
/// </summary>
[Fact]
public void NoContextsExplicit()
{
var fi = new FileInfo(kubeConfigNoContexts);
Assert.Throws<k8s.Exceptions.KubeConfigException>(() => new KubernetesClientConfiguration(fi, "context"));
}
// /// <summary>
// /// Checks if the are pods
// /// </summary>
// [Fact]
// public void ListDefaultNamespacedPod()
// {
// var k8sClientConfig = new KubernetesClientConfiguration();
// IKubernetes client = new Kubernetes(k8sClientConfig);
// var listTask = client.ListNamespacedPodWithHttpMessagesAsync("default").Result;
// var list = listTask.Body;
// Assert.NotEqual(0, list.Items.Count);
// }
} }
} }