Sha256: f167695251b22af17ae1f31a3dd928d56550c36bc305a85ce476dc14ea82f7ad
Contents?: true
Size: 1.81 KB
Versions: 10
Compression:
Stored size: 1.81 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
def deploy_method
:replace
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
10 entries across 10 versions & 1 rubygems