forked from longhorn/longhorn-tests
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by: Yang Chiu <[email protected]>
- Loading branch information
Showing
13 changed files
with
307 additions
and
27 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1 +1,2 @@ | ||
| from host.host import Host | ||
| from host.aws import Aws | ||
| from host.harvester import Harvester |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,32 @@ | ||
| import yaml | ||
| from abc import ABC, abstractmethod | ||
| from node.node import Node | ||
|
|
||
|
|
||
| class Base(ABC): | ||
|
|
||
| def __init__(self): | ||
| with open('/tmp/instance_mapping', 'r') as f: | ||
| self.mapping = yaml.safe_load(f) | ||
| self.node = Node() | ||
|
|
||
| @abstractmethod | ||
| def reboot_all_nodes(self, shut_down_time_in_sec): | ||
| return NotImplemented | ||
|
|
||
| @abstractmethod | ||
| def reboot_node(self, node_name, shut_down_time_in_sec): | ||
| return NotImplemented | ||
|
|
||
| @abstractmethod | ||
| def reboot_all_worker_nodes(self, shut_down_time_in_sec): | ||
| return NotImplemented | ||
|
|
||
| @abstractmethod | ||
| def power_off_node(self, node_name): | ||
| return NotImplemented | ||
|
|
||
| @abstractmethod | ||
| def power_on_node(self, node_name): | ||
| return NotImplemented | ||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,21 @@ | ||
| from host.base import Base | ||
|
|
||
| class Harvester(Base): | ||
|
|
||
| def __init__(self): | ||
| super().__init__() | ||
|
|
||
| def reboot_all_nodes(self, shut_down_time_in_sec): | ||
| raise NotImplementedError | ||
|
|
||
| def reboot_node(self, node_name, shut_down_time_in_sec): | ||
| raise NotImplementedError | ||
|
|
||
| def reboot_all_worker_nodes(self, shut_down_time_in_sec): | ||
| raise NotImplementedError | ||
|
|
||
| def power_off_node(self, node_name): | ||
| raise NotImplementedError | ||
|
|
||
| def power_on_node(self, node_name): | ||
| raise NotImplementedError |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,8 @@ | ||
| connect_to_vpn(){ | ||
| mkdir -p /dev/net | ||
| mknod /dev/net/tun c 10 200 | ||
| chmod 600 /dev/net/tun | ||
| openvpn --config vpn.ovpn --daemon | ||
| sleep 10 | ||
| cat /var/log/openvpn.log | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,146 @@ | ||
| terraform { | ||
| required_providers { | ||
| rancher2 = { | ||
| source = "rancher/rancher2" | ||
| version = "3.0.0-rc2" | ||
| } | ||
| } | ||
| } | ||
|
|
||
| provider "rancher2" { | ||
| api_url = var.lab_url | ||
| insecure = true | ||
| access_key = var.lab_access_key | ||
| secret_key = var.lab_secret_key | ||
| } | ||
|
|
||
| resource "random_string" "random_suffix" { | ||
| length = 8 | ||
| special = false | ||
| lower = true | ||
| upper = false | ||
| } | ||
|
|
||
| data "rancher2_cluster_v2" "hal-cluster" { | ||
| name = "hal" | ||
| } | ||
|
|
||
| resource "rancher2_cloud_credential" "e2e-credential" { | ||
| name = "e2e-credential-${random_string.random_suffix.id}" | ||
| harvester_credential_config { | ||
| cluster_id = data.rancher2_cluster_v2.hal-cluster.cluster_v1_id | ||
| cluster_type = "imported" | ||
| kubeconfig_content = data.rancher2_cluster_v2.hal-cluster.kube_config | ||
| } | ||
| } | ||
|
|
||
| resource "rancher2_machine_config_v2" "e2e-machine-config" { | ||
|
|
||
| generate_name = "e2e-machine-config-${random_string.random_suffix.id}" | ||
|
|
||
| harvester_config { | ||
|
|
||
| vm_namespace = "longhorn-qa" | ||
|
|
||
| cpu_count = "4" | ||
| memory_size = "8" | ||
|
|
||
| disk_info = <<EOF | ||
| { | ||
| "disks": [{ | ||
| "imageName": "longhorn-qa/image-nbv7f", | ||
| "size": 100, | ||
| "bootOrder": 1 | ||
| }] | ||
| } | ||
| EOF | ||
|
|
||
| network_info = <<EOF | ||
| { | ||
| "interfaces": [{ | ||
| "networkName": "longhorn-qa/vlan104" | ||
| }] | ||
| } | ||
| EOF | ||
|
|
||
| ssh_user = "ubuntu" | ||
|
|
||
| user_data = <<EOF | ||
| #cloud-config | ||
| ssh_authorized_keys: | ||
| - >- | ||
| ${file(var.ssh_public_key_file_path)} | ||
| package_update: true | ||
| packages: | ||
| - qemu-guest-agent | ||
| - iptables | ||
| runcmd: | ||
| - - systemctl | ||
| - enable | ||
| - '--now' | ||
| - qemu-guest-agent.service | ||
| EOF | ||
| } | ||
| } | ||
|
|
||
| resource "rancher2_cluster_v2" "e2e-cluster" { | ||
|
|
||
| name = "e2e-cluster-${random_string.random_suffix.id}" | ||
|
|
||
| kubernetes_version = var.k8s_distro_version | ||
|
|
||
| rke_config { | ||
| machine_pools { | ||
| name = "control-plane-pool" | ||
| cloud_credential_secret_name = rancher2_cloud_credential.e2e-credential.id | ||
| control_plane_role = true | ||
| etcd_role = true | ||
| worker_role = false | ||
| quantity = 1 | ||
| machine_config { | ||
| kind = rancher2_machine_config_v2.e2e-machine-config.kind | ||
| name = rancher2_machine_config_v2.e2e-machine-config.name | ||
| } | ||
| } | ||
| machine_pools { | ||
| name = "worker-pool" | ||
| cloud_credential_secret_name = rancher2_cloud_credential.e2e-credential.id | ||
| control_plane_role = false | ||
| etcd_role = false | ||
| worker_role = true | ||
| quantity = 3 | ||
| machine_config { | ||
| kind = rancher2_machine_config_v2.e2e-machine-config.kind | ||
| name = rancher2_machine_config_v2.e2e-machine-config.name | ||
| } | ||
| } | ||
| machine_selector_config { | ||
| config = { | ||
| cloud-provider-name = "" | ||
| } | ||
| } | ||
| machine_global_config = <<EOF | ||
| cni: "calico" | ||
| disable-kube-proxy: false | ||
| etcd-expose-metrics: false | ||
| EOF | ||
| upgrade_strategy { | ||
| control_plane_concurrency = "10%" | ||
| worker_concurrency = "10%" | ||
| } | ||
| etcd { | ||
| snapshot_schedule_cron = "0 */5 * * *" | ||
| snapshot_retention = 5 | ||
| } | ||
| chart_values = "" | ||
| } | ||
| } | ||
|
|
||
| output "kube_config" { | ||
| value = rancher2_cluster_v2.e2e-cluster.kube_config | ||
| sensitive = "true" | ||
| } | ||
|
|
||
| output "cluster_id" { | ||
| value = rancher2_cluster_v2.e2e-cluster.cluster_v1_id | ||
| } |
Oops, something went wrong.