in gems/aws-sdk-kinesis/lib/aws-sdk-kinesis/endpoint_provider.rb [11:195]
def resolve_endpoint(parameters)
if Aws::Endpoints::Matchers.set?(parameters.stream_arn) && Aws::Endpoints::Matchers.not(Aws::Endpoints::Matchers.set?(parameters.endpoint)) && Aws::Endpoints::Matchers.set?(parameters.region) && (partition_result = Aws::Endpoints::Matchers.aws_partition(parameters.region)) && Aws::Endpoints::Matchers.not(Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(partition_result, "name"), "aws-iso")) && Aws::Endpoints::Matchers.not(Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(partition_result, "name"), "aws-iso-b"))
if (arn = Aws::Endpoints::Matchers.aws_parse_arn(parameters.stream_arn))
if Aws::Endpoints::Matchers.valid_host_label?(Aws::Endpoints::Matchers.attr(arn, "accountId"), false)
if Aws::Endpoints::Matchers.valid_host_label?(Aws::Endpoints::Matchers.attr(arn, "region"), false)
if Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(arn, "service"), "kinesis")
if (arn_type = Aws::Endpoints::Matchers.attr(arn, "resourceId[0]")) && Aws::Endpoints::Matchers.not(Aws::Endpoints::Matchers.string_equals?(arn_type, ""))
if Aws::Endpoints::Matchers.string_equals?(arn_type, "stream")
if Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(partition_result, "name"), "#{arn['partition']}")
if Aws::Endpoints::Matchers.set?(parameters.operation_type)
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_fips, true) && Aws::Endpoints::Matchers.boolean_equals?(parameters.use_dual_stack, true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsFIPS"), true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsDualStack"), true)
return Aws::Endpoints::Endpoint.new(url: "https://#{arn['accountId']}.#{parameters.operation_type}-kinesis-fips.#{parameters.region}.#{partition_result['dualStackDnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "DualStack is enabled, but this partition does not support DualStack."
end
raise ArgumentError, "FIPS is enabled, but this partition does not support FIPS."
end
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_fips, true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsFIPS"), true)
return Aws::Endpoints::Endpoint.new(url: "https://#{arn['accountId']}.#{parameters.operation_type}-kinesis-fips.#{parameters.region}.#{partition_result['dnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "FIPS is enabled but this partition does not support FIPS"
end
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_dual_stack, true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsDualStack"), true)
return Aws::Endpoints::Endpoint.new(url: "https://#{arn['accountId']}.#{parameters.operation_type}-kinesis.#{parameters.region}.#{partition_result['dualStackDnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "DualStack is enabled but this partition does not support DualStack"
end
return Aws::Endpoints::Endpoint.new(url: "https://#{arn['accountId']}.#{parameters.operation_type}-kinesis.#{parameters.region}.#{partition_result['dnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "Operation Type is not set. Please contact service team for resolution."
end
raise ArgumentError, "Partition: #{arn['partition']} from ARN doesn't match with partition name: #{partition_result['name']}."
end
raise ArgumentError, "Invalid ARN: Kinesis ARNs don't support `#{arn_type}` arn types."
end
raise ArgumentError, "Invalid ARN: No ARN type specified"
end
raise ArgumentError, "Invalid ARN: The ARN was not for the Kinesis service, found: #{arn['service']}."
end
raise ArgumentError, "Invalid ARN: Invalid region."
end
raise ArgumentError, "Invalid ARN: Invalid account id."
end
raise ArgumentError, "Invalid ARN: Failed to parse ARN."
end
if Aws::Endpoints::Matchers.set?(parameters.consumer_arn) && Aws::Endpoints::Matchers.not(Aws::Endpoints::Matchers.set?(parameters.endpoint)) && Aws::Endpoints::Matchers.set?(parameters.region) && (partition_result = Aws::Endpoints::Matchers.aws_partition(parameters.region)) && Aws::Endpoints::Matchers.not(Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(partition_result, "name"), "aws-iso")) && Aws::Endpoints::Matchers.not(Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(partition_result, "name"), "aws-iso-b"))
if (arn = Aws::Endpoints::Matchers.aws_parse_arn(parameters.consumer_arn))
if Aws::Endpoints::Matchers.valid_host_label?(Aws::Endpoints::Matchers.attr(arn, "accountId"), false)
if Aws::Endpoints::Matchers.valid_host_label?(Aws::Endpoints::Matchers.attr(arn, "region"), false)
if Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(arn, "service"), "kinesis")
if (arn_type = Aws::Endpoints::Matchers.attr(arn, "resourceId[0]")) && Aws::Endpoints::Matchers.not(Aws::Endpoints::Matchers.string_equals?(arn_type, ""))
if Aws::Endpoints::Matchers.string_equals?(arn_type, "stream")
if Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(partition_result, "name"), "#{arn['partition']}")
if Aws::Endpoints::Matchers.set?(parameters.operation_type)
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_fips, true) && Aws::Endpoints::Matchers.boolean_equals?(parameters.use_dual_stack, true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsFIPS"), true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsDualStack"), true)
return Aws::Endpoints::Endpoint.new(url: "https://#{arn['accountId']}.#{parameters.operation_type}-kinesis-fips.#{parameters.region}.#{partition_result['dualStackDnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "DualStack is enabled, but this partition does not support DualStack."
end
raise ArgumentError, "FIPS is enabled, but this partition does not support FIPS."
end
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_fips, true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsFIPS"), true)
return Aws::Endpoints::Endpoint.new(url: "https://#{arn['accountId']}.#{parameters.operation_type}-kinesis-fips.#{parameters.region}.#{partition_result['dnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "FIPS is enabled but this partition does not support FIPS"
end
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_dual_stack, true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsDualStack"), true)
return Aws::Endpoints::Endpoint.new(url: "https://#{arn['accountId']}.#{parameters.operation_type}-kinesis.#{parameters.region}.#{partition_result['dualStackDnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "DualStack is enabled but this partition does not support DualStack"
end
return Aws::Endpoints::Endpoint.new(url: "https://#{arn['accountId']}.#{parameters.operation_type}-kinesis.#{parameters.region}.#{partition_result['dnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "Operation Type is not set. Please contact service team for resolution."
end
raise ArgumentError, "Partition: #{arn['partition']} from ARN doesn't match with partition name: #{partition_result['name']}."
end
raise ArgumentError, "Invalid ARN: Kinesis ARNs don't support `#{arn_type}` arn types."
end
raise ArgumentError, "Invalid ARN: No ARN type specified"
end
raise ArgumentError, "Invalid ARN: The ARN was not for the Kinesis service, found: #{arn['service']}."
end
raise ArgumentError, "Invalid ARN: Invalid region."
end
raise ArgumentError, "Invalid ARN: Invalid account id."
end
raise ArgumentError, "Invalid ARN: Failed to parse ARN."
end
if Aws::Endpoints::Matchers.set?(parameters.resource_arn) && Aws::Endpoints::Matchers.not(Aws::Endpoints::Matchers.set?(parameters.endpoint)) && Aws::Endpoints::Matchers.set?(parameters.region) && (partition_result = Aws::Endpoints::Matchers.aws_partition(parameters.region)) && Aws::Endpoints::Matchers.not(Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(partition_result, "name"), "aws-iso")) && Aws::Endpoints::Matchers.not(Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(partition_result, "name"), "aws-iso-b"))
if (arn = Aws::Endpoints::Matchers.aws_parse_arn(parameters.resource_arn))
if Aws::Endpoints::Matchers.valid_host_label?(Aws::Endpoints::Matchers.attr(arn, "accountId"), false)
if Aws::Endpoints::Matchers.valid_host_label?(Aws::Endpoints::Matchers.attr(arn, "region"), false)
if Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(arn, "service"), "kinesis")
if (arn_type = Aws::Endpoints::Matchers.attr(arn, "resourceId[0]")) && Aws::Endpoints::Matchers.not(Aws::Endpoints::Matchers.string_equals?(arn_type, ""))
if Aws::Endpoints::Matchers.string_equals?(arn_type, "stream")
if Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(partition_result, "name"), "#{arn['partition']}")
if Aws::Endpoints::Matchers.set?(parameters.operation_type)
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_fips, true) && Aws::Endpoints::Matchers.boolean_equals?(parameters.use_dual_stack, true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsFIPS"), true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsDualStack"), true)
return Aws::Endpoints::Endpoint.new(url: "https://#{arn['accountId']}.#{parameters.operation_type}-kinesis-fips.#{parameters.region}.#{partition_result['dualStackDnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "DualStack is enabled, but this partition does not support DualStack."
end
raise ArgumentError, "FIPS is enabled, but this partition does not support FIPS."
end
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_fips, true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsFIPS"), true)
return Aws::Endpoints::Endpoint.new(url: "https://#{arn['accountId']}.#{parameters.operation_type}-kinesis-fips.#{parameters.region}.#{partition_result['dnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "FIPS is enabled but this partition does not support FIPS"
end
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_dual_stack, true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsDualStack"), true)
return Aws::Endpoints::Endpoint.new(url: "https://#{arn['accountId']}.#{parameters.operation_type}-kinesis.#{parameters.region}.#{partition_result['dualStackDnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "DualStack is enabled but this partition does not support DualStack"
end
return Aws::Endpoints::Endpoint.new(url: "https://#{arn['accountId']}.#{parameters.operation_type}-kinesis.#{parameters.region}.#{partition_result['dnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "Operation Type is not set. Please contact service team for resolution."
end
raise ArgumentError, "Partition: #{arn['partition']} from ARN doesn't match with partition name: #{partition_result['name']}."
end
raise ArgumentError, "Invalid ARN: Kinesis ARNs don't support `#{arn_type}` arn types."
end
raise ArgumentError, "Invalid ARN: No ARN type specified"
end
raise ArgumentError, "Invalid ARN: The ARN was not for the Kinesis service, found: #{arn['service']}."
end
raise ArgumentError, "Invalid ARN: Invalid region."
end
raise ArgumentError, "Invalid ARN: Invalid account id."
end
raise ArgumentError, "Invalid ARN: Failed to parse ARN."
end
if Aws::Endpoints::Matchers.set?(parameters.endpoint)
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_fips, true)
raise ArgumentError, "Invalid Configuration: FIPS and custom endpoint are not supported"
end
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_dual_stack, true)
raise ArgumentError, "Invalid Configuration: Dualstack and custom endpoint are not supported"
end
return Aws::Endpoints::Endpoint.new(url: parameters.endpoint, headers: {}, properties: {})
end
if Aws::Endpoints::Matchers.set?(parameters.region)
if (partition_result = Aws::Endpoints::Matchers.aws_partition(parameters.region))
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_fips, true) && Aws::Endpoints::Matchers.boolean_equals?(parameters.use_dual_stack, true)
if Aws::Endpoints::Matchers.boolean_equals?(true, Aws::Endpoints::Matchers.attr(partition_result, "supportsFIPS")) && Aws::Endpoints::Matchers.boolean_equals?(true, Aws::Endpoints::Matchers.attr(partition_result, "supportsDualStack"))
return Aws::Endpoints::Endpoint.new(url: "https://kinesis-fips.#{parameters.region}.#{partition_result['dualStackDnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "FIPS and DualStack are enabled, but this partition does not support one or both"
end
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_fips, true)
if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsFIPS"), true)
if Aws::Endpoints::Matchers.string_equals?(Aws::Endpoints::Matchers.attr(partition_result, "name"), "aws-us-gov")
return Aws::Endpoints::Endpoint.new(url: "https://kinesis.#{parameters.region}.amazonaws.com", headers: {}, properties: {})
end
return Aws::Endpoints::Endpoint.new(url: "https://kinesis-fips.#{parameters.region}.#{partition_result['dnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "FIPS is enabled but this partition does not support FIPS"
end
if Aws::Endpoints::Matchers.boolean_equals?(parameters.use_dual_stack, true)
if Aws::Endpoints::Matchers.boolean_equals?(true, Aws::Endpoints::Matchers.attr(partition_result, "supportsDualStack"))
return Aws::Endpoints::Endpoint.new(url: "https://kinesis.#{parameters.region}.#{partition_result['dualStackDnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "DualStack is enabled but this partition does not support DualStack"
end
return Aws::Endpoints::Endpoint.new(url: "https://kinesis.#{parameters.region}.#{partition_result['dnsSuffix']}", headers: {}, properties: {})
end
end
raise ArgumentError, "Invalid Configuration: Missing Region"
raise ArgumentError, 'No endpoint could be resolved'
end