Linting
This commit is contained in:
parent
4b3f4db451
commit
74ebf0521b
2 changed files with 34 additions and 15 deletions
|
@ -4,6 +4,15 @@ on:
|
|||
- 'main'
|
||||
|
||||
jobs:
|
||||
lint:
|
||||
- uses: actions/checkout@v4
|
||||
- uses: actions/setup-python@v5
|
||||
with:
|
||||
python-version: '3.10'
|
||||
cache: 'pip'
|
||||
- run: |
|
||||
pip install flake8 api.py
|
||||
|
||||
build:
|
||||
runs-on: docker
|
||||
steps:
|
||||
|
|
40
api.py
40
api.py
|
@ -2,14 +2,18 @@ import os
|
|||
import random
|
||||
from flask import (
|
||||
Flask,
|
||||
request,
|
||||
jsonify,
|
||||
)
|
||||
from flask_restful import reqparse, abort, Resource, Api
|
||||
from flask_restful import (
|
||||
Resource,
|
||||
Api
|
||||
)
|
||||
from kubernetes import client as k8s_client
|
||||
from kubernetes.client import api_client
|
||||
from kubernetes import config, watch, dynamic
|
||||
from kubernetes.dynamic.exceptions import ResourceNotFoundError
|
||||
from kubernetes import (
|
||||
config,
|
||||
dynamic
|
||||
)
|
||||
# from kubernetes.dynamic.exceptions import ResourceNotFoundError
|
||||
|
||||
|
||||
app = Flask(__name__)
|
||||
|
@ -27,19 +31,26 @@ client = dynamic.DynamicClient(
|
|||
)
|
||||
custom_object_api = k8s_client.CustomObjectsApi()
|
||||
|
||||
first_names = ['Ada', 'Bela', 'Cade', 'Dax', 'Eva', 'Fynn', 'Gia', 'Hugo', 'Ivy', 'Jax']
|
||||
last_names = ['Smith', 'Johnson', 'Williams', 'Jones', 'Brown', 'Davis', 'Miller', 'Wilson', 'Moore', 'Taylor']
|
||||
first_names = ['Ada', 'Bela', 'Cade', 'Dax', 'Eva',
|
||||
'Fynn', 'Gia', 'Hugo', 'Ivy', 'Jax']
|
||||
last_names = ['Smith', 'Johnson', 'Williams', 'Jones', 'Brown', 'Davis',
|
||||
'Miller', 'Wilson', 'Moore', 'Taylor']
|
||||
|
||||
|
||||
def create_name():
|
||||
first_name = random.choice(first_names)
|
||||
last_name = random.choice(last_names)
|
||||
return f"{first_name}{last_name}"
|
||||
|
||||
|
||||
class DBCluster(Resource):
|
||||
def get(self):
|
||||
namespace = "test"
|
||||
clusters = []
|
||||
mariadb_resource = client.resources.get(api_version='k8s.mariadb.com/v1alpha1', kind='MariaDB')
|
||||
mariadb_resource = client.resources.get(
|
||||
api_version='k8s.mariadb.com/v1alpha1',
|
||||
kind='MariaDB'
|
||||
)
|
||||
mariadbs = mariadb_resource.get(namespace=namespace)
|
||||
for mariadb in mariadbs.items:
|
||||
name = mariadb.metadata.name
|
||||
|
@ -49,7 +60,7 @@ class DBCluster(Resource):
|
|||
def post(self):
|
||||
namespace = "test"
|
||||
name = random.choice(first_names).lower()
|
||||
print(name )
|
||||
print(name)
|
||||
mariadb = {
|
||||
'apiVersion': 'k8s.mariadb.com/v1alpha1',
|
||||
'kind': 'MariaDB',
|
||||
|
@ -85,17 +96,17 @@ class DBCluster(Resource):
|
|||
)
|
||||
return mariadb_instance
|
||||
|
||||
|
||||
class DBClusterDetails(Resource):
|
||||
def get(self, name):
|
||||
namespace = "test"
|
||||
cluster = {}
|
||||
mariadb_resource = client.resources.get(api_version='k8s.mariadb.com/v1alpha1', kind='MariaDB')
|
||||
mariadb_resource = client.resources.get(
|
||||
api_version='k8s.mariadb.com/v1alpha1',
|
||||
kind='MariaDB'
|
||||
)
|
||||
mariadbs = mariadb_resource.get(namespace=namespace)
|
||||
for mariadb in mariadbs.items:
|
||||
if mariadb.metadata.name == name:
|
||||
for k,v in mariadb.metadata:
|
||||
print(k,v)
|
||||
|
||||
data = {
|
||||
"name": mariadb.metadata.name,
|
||||
"storage": mariadb.spec.storage.size,
|
||||
|
@ -103,7 +114,6 @@ class DBClusterDetails(Resource):
|
|||
return data
|
||||
|
||||
|
||||
|
||||
api.add_resource(DBCluster, '/clusters')
|
||||
api.add_resource(DBClusterDetails, '/clusters/<string:name>')
|
||||
|
||||
|
|
Loading…
Add table
Reference in a new issue