Sha256: 03f633fc64d19d1b7b2375395faaadb0975c8f6bb11fe722ad2d993d149c029b
Contents?: true
Size: 1.1 KB
Versions: 8
Compression:
Stored size: 1.1 KB
Contents
# frozen_string_literal: true
module KubernetesDeploy
class Cloudsql < KubernetesResource
TIMEOUT = 10.minutes
def sync(cache)
super
@proxy_deployment = cache.get_instance(Deployment.kind, "cloudsql-#{cloudsql_resource_uuid}")
@proxy_service = cache.get_instance(Service.kind, "cloudsql-#{@name}")
end
def status
deploy_succeeded? ? "Provisioned" : "Unknown"
end
def deploy_succeeded?
proxy_deployment_ready? && proxy_service_ready?
end
def deploy_failed?
false
end
private
def proxy_deployment_ready?
return false unless (status = @proxy_deployment["status"])
# all cloudsql-proxy pods are running
status.fetch("availableReplicas", -1) == status.fetch("replicas", 0)
end
def proxy_service_ready?
return false unless @proxy_service.present?
# the service has an assigned cluster IP and is therefore functioning
@proxy_service.dig("spec", "clusterIP").present?
end
def cloudsql_resource_uuid
return unless @instance_data
@instance_data.dig("metadata", "uid")
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems