INNER CODE UNIT · Python

check_service

vchinnipilli/kubestriker · kubestriker/__main__.py:233

def check_service(url, token):
    '''
    This function checks for various services running
    '''
    session = requests.Session()
    session.verify = False
    session.headers = {'Authorization': 'Bearer {}'.format(token)}
    try:
        response = session.get(url, timeout=5)
        if response.status_code ==200:
            return True
        else:
            decoded_data = yaml.safe_load(decode_jwt_token_data(token))
            namespace = decoded_data.get('kubernetes.io/serviceaccount/namespace')
            namespace_url = url+"/api/v1/namespaces/"+namespace+"/pods"
            namespace_response = session.get(namespace_url, timeout=5)
            if namespace_response.status_code == 200:
                return True

View source record →