Retrieve application and pod statuses #1332
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
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,107 @@ | ||
| import subprocess | ||
| import sys | ||
| import json | ||
| from crmetrics import CRBase | ||
|
|
||
| ''' | ||
| new plugin app-status -- takes in kind and instance and displays | ||
| kind, namespace, name and status and lists pods in that application | ||
| with their status | ||
|
|
||
| application name is the namespace and pods will be under this namespace | ||
| for application status itself, name would just be the helm release | ||
|
|
||
| Input: name of kind and name of application instance | ||
|
|
||
| TODO: reexamine all error checks for plugins | ||
| ''' | ||
|
|
||
|
|
||
| class AppStatusFinder(CRBase): | ||
|
|
||
| def get_app_instance_status(self, kind, instance, kubeconfig): | ||
| cmd = 'kubectl get %s %s -o json %s' % (kind, instance, kubeconfig) | ||
| out, err = self._run_command(cmd) | ||
| if err != "": | ||
| print("Something went wrong while getting app instance status.") | ||
| print(err) | ||
| exit(1) | ||
| ''' | ||
| with response, check if status exists | ||
| check if helmrelease exists and extract name of instance | ||
| or check if status contains an error | ||
| otherwise (i.e. status missing), display "App not deployed properly" | ||
| ''' | ||
| # response = json.dumps(json.loads(out), indent=4) | ||
|
|
||
| response = json.loads(out) | ||
| if 'status' in response: | ||
| if 'helmrelease' in response['status']: | ||
| helm_release = response['status']['helmrelease'].strip('\n') | ||
| ns, name = helm_release.split(':') | ||
| return name, ns, True, None | ||
| else: | ||
| # an error has occurred | ||
| status = response['status'] | ||
| return status, None, False, None | ||
|
There was a problem hiding this comment. I suggest defining variables for the second and third return parameters and setting their values after lines 21 and 25. That way, by looking at the return statement it will be clear what parameters are being returned. |
||
|
|
||
| else: | ||
| return '', 'Application not deployed properly', False, None | ||
|
|
||
|
|
||
|
|
||
|
|
||
| def get_app_pods(self, namespace, kubeconfig): | ||
| cmd = 'kubectl get pods -n %s %s -o json' % (namespace, kubeconfig) | ||
| # pods = self._get_resources(None, 'pods', namespace, kubeconfig) | ||
| out, err = self._run_command(cmd) | ||
| # format? | ||
| response = json.loads(out) | ||
| pods = [] | ||
| for pod in response['items']: | ||
| name = pod['metadata']['name'] | ||
| typ = pod['kind'] | ||
| ns = pod['metadata']['namespace'] | ||
| phase = pod['status']['phase'] | ||
| pods.append((name, typ, ns, phase)) | ||
| return pods | ||
|
|
||
|
|
||
| if __name__ == '__main__': | ||
| appStatusFinder = AppStatusFinder() | ||
| kind = sys.argv[1] | ||
| instance = sys.argv[2] | ||
| kubeconfig = sys.argv[3] | ||
|
|
||
| valid_consumer_api = appStatusFinder.verify_kind_is_consumerapi(kind, kubeconfig) | ||
| if not valid_consumer_api: | ||
| print(("{} is not a valid Consumer API.").format(kind)) | ||
| exit(0) | ||
|
|
||
| res_exists, ns, err = appStatusFinder.check_res_exists(kind, instance, kubeconfig) | ||
| if not res_exists: | ||
| print(err) | ||
| exit(0) | ||
|
|
||
| working, error = appStatusFinder.validate_kind_and_instance(kind, instance, ns) | ||
| if working == False: | ||
| print(err) | ||
| exit(1) | ||
|
|
||
| release_name_or_status, release_ns, deployed, err = appStatusFinder.get_app_instance_status(kind, instance, kubeconfig) | ||
|
There was a problem hiding this comment. Don't need the last parameter since it is always returned as None. |
||
| if err is not None: | ||
|
There was a problem hiding this comment. Don't need this check. The error check is happening in lines 12-15. |
||
| print(err) | ||
| exit(1) | ||
|
|
||
| if deployed: | ||
| deploy_str = 'Deployed' | ||
| else: | ||
| print(release_name_or_status) | ||
| exit(1) | ||
|
|
||
| # if not deployed, there's probably an error -- maybe display a different response in this case | ||
| pods = appStatusFinder.get_app_pods(instance, kubeconfig) | ||
|
|
||
| print("{:<35} {:<35} {:<35} {:<35}".format("NAME", "TYPE", "NAMESPACE", "STATUS")) | ||
| print("{:<35} {:<35} {:<35} {:<35}".format(release_name_or_status, 'helmrelease', release_ns, deploy_str)) | ||
| for pod_name, typ, pod_ns, phase in pods: | ||
| print("{:<35} {:<35} {:<35} {:<35}".format(pod_name, typ, pod_ns, phase)) | ||
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,53 @@ | ||
| #!/bin/bash | ||
|
There was a problem hiding this comment. You have made this file executable, right? (chmod +x kubectl-appstatus) |
||
|
|
||
| source utils.sh | ||
|
|
||
| print_help () { | ||
| echo "NAME" | ||
| echo " kubectl appstatus" | ||
| echo "" | ||
| echo "SYNOPSIS" | ||
| echo " kubectl appstatus <Kind> <Instance> -k <Absolute path to kubeconfig>" | ||
| echo "" | ||
| echo "DESCRIPTION" | ||
| echo " kubectl appstatus shows the status of the application instance and its pods" | ||
| exit 0 | ||
| } | ||
|
|
||
| if (( $# < 2 )); then | ||
| print_help | ||
| fi | ||
|
|
||
| kind=$1 | ||
| instance=$2 | ||
| kubeconfig="" | ||
|
|
||
| shift; | ||
| shift; | ||
|
|
||
| while getopts ":k:" opt; do | ||
| case ${opt} in | ||
| k ) | ||
| kubeconfig1=$OPTARG | ||
| if [ ! -f $kubeconfig1 ]; then | ||
| echo "Kubeconfig $kubeconfig1 does not exist." | ||
| exit 0 | ||
| fi;; | ||
| ? ) | ||
| echo "Invalid option: ${1} " 1>&2 | ||
| print_help | ||
| exit 0 | ||
| ;; | ||
| esac | ||
| done | ||
|
|
||
| kubeconfig="--kubeconfig="$kubeconfig1 | ||
|
|
||
| canonicalKind=$(get_canonical_kind $kind) | ||
|
|
||
| if [[ $canonicalKind == *"Unknown"* ]]; then | ||
| echo "$canonicalKind" | ||
| exit 0 | ||
| fi | ||
|
|
||
| python3 /$KUBEPLUS_HOME/plugins/appstatus.py $canonicalKind $instance $kubeconfig | ||
Oops, something went wrong.
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Get rid of TODO