Sha256: 1080e3ace3b6be0a3c186c086a76075f2bc11ad753b7ffa9c45e1ff859474d7e
Contents?: true
Size: 1.84 KB
Versions: 13
Compression:
Stored size: 1.84 KB
Contents
# frozen_string_literal: true
require 'hako/schema'
module Hako
module Schedulers
class EcsServiceComparator
def initialize(expected_service)
@expected_service = expected_service
@schema = service_schema
end
# @param [Aws::ECS::Types::Service] actual_service
# @return [Boolean]
def different?(actual_service)
!@schema.same?(actual_service.to_h, @expected_service)
end
private
def service_schema
Schema::Structure.new.tap do |struct|
struct.member(:desired_count, Schema::Integer.new)
struct.member(:task_definition, Schema::String.new)
struct.member(:deployment_configuration, Schema::WithDefault.new(deployment_configuration_schema, default_configuration))
struct.member(:platform_version, Schema::String.new)
struct.member(:network_configuration, Schema::Nullable.new(network_configuration_schema))
end
end
def deployment_configuration_schema
Schema::Structure.new.tap do |struct|
struct.member(:maximum_percent, Schema::Integer.new)
struct.member(:minimum_healthy_percent, Schema::Integer.new)
end
end
def network_configuration_schema
Schema::Structure.new.tap do |struct|
struct.member(:awsvpc_configuration, awsvpc_configuration_schema)
end
end
def awsvpc_configuration_schema
Schema::Structure.new.tap do |struct|
struct.member(:subnets, Schema::UnorderedArray.new(Schema::String.new))
struct.member(:security_groups, Schema::UnorderedArray.new(Schema::String.new))
struct.member(:assign_public_ip, Schema::String.new)
end
end
def default_configuration
{
maximum_percent: 200,
minimum_healthy_percent: 100,
}
end
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems