Sha256: a4b674434339a94c8b2efc4382a3357cf723fc2dfafada247da3af49fa387253
Contents?: true
Size: 1.54 KB
Versions: 7
Compression:
Stored size: 1.54 KB
Contents
# frozen_string_literal: true
module KubernetesDeploy
class Cloudsql < KubernetesResource
TIMEOUT = 5.minutes
def initialize(name, namespace, context, file)
@name = name
@namespace = namespace
@context = context
@file = file
end
def sync
_, _err, st = run_kubectl("get", type, @name)
@found = st.success?
@status = if cloudsql_proxy_deployment_exists? && mysql_service_exists?
"Provisioned"
else
"Unknown"
end
log_status
end
def deploy_succeeded?
cloudsql_proxy_deployment_exists? && mysql_service_exists?
end
def deploy_failed?
false
end
def tpr?
true
end
def exists?
@found
end
private
def cloudsql_proxy_deployment_exists?
deployment, _err, st = run_kubectl("get", "deployments", "cloudsql-proxy", "-o=json")
if st.success?
parsed = JSON.parse(deployment)
if parsed.fetch("status", {}).fetch("availableReplicas", -1) == parsed.fetch("status", {}).fetch("replicas", 0)
# all cloudsql-proxy pods are running
return true
end
end
false
end
def mysql_service_exists?
service, _err, st = run_kubectl("get", "services", "mysql", "-o=json")
if st.success?
parsed = JSON.parse(service)
if parsed.fetch("spec", {}).fetch("clusterIP", "") != ""
# the service has an assigned cluster IP and is therefore functioning
return true
end
end
false
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems