Sha256: c4e50e30a6c8d161082bc58a592bdf226d3a73b56394f620ab98157e77c03cb7
Contents?: true
Size: 1.79 KB
Versions: 5
Compression:
Stored size: 1.79 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 tpr?
true
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
redis, _err, st = kubectl.run("get", "cloudsqls", @name, "-o=json")
if st.success?
parsed = JSON.parse(redis)
@cloudsql_resource_uuid = parsed.dig("metadata", "uid")
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems