Sha256: 3a3a0525428a28a87d93ec79995631b9a3a2a72baae2115a7b0db5d57079863b
Contents?: true
Size: 1.77 KB
Versions: 6
Compression:
Stored size: 1.77 KB
Contents
# frozen_string_literal: true
module KubernetesDeploy
class Cloudsql < KubernetesResource
TIMEOUT = 10.minutes
def sync
_, _err, st = kubectl.run("get", type, @name)
@found = st.success?
@deployment_exists = cloudsql_proxy_deployment_exists?
@service_exists = mysql_service_exists?
@status = if @deployment_exists && @service_exists
"Provisioned"
else
"Unknown"
end
end
def deploy_succeeded?
@service_exists && @deployment_exists
end
def deploy_failed?
false
end
def exists?
@found
end
private
def cloudsql_proxy_deployment_exists?
deployment, _err, st = kubectl.run("get", "deployments", "cloudsql-#{cloudsql_resource_uuid}", "-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 = kubectl.run("get", "services", "cloudsql-#{@name}", "-o=json")
if st.success?
parsed = JSON.parse(service)
if parsed.dig("spec", "clusterIP").present?
# the service has an assigned cluster IP and is therefore functioning
return true
end
end
false
end
def cloudsql_resource_uuid
return @cloudsql_resource_uuid if defined?(@cloudsql_resource_uuid) && @cloudsql_resource_uuid
cloudsql, _err, st = kubectl.run("get", "cloudsqls", @name, "-o=json")
if st.success?
parsed = JSON.parse(cloudsql)
@cloudsql_resource_uuid = parsed.dig("metadata", "uid")
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems