Skip to content

Commit

Permalink
Rename BrokeredService -> ProxiedService in service broker
Browse files Browse the repository at this point in the history
- Update service list uri for cloud controller interactions

Change-Id: Iecea2bc49c12313cf1304b21aacfcedb8300e821
  • Loading branch information
Harshawardhan Gadgil committed Aug 22, 2012
1 parent 3cf7337 commit 3771022
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions service_broker/lib/service_broker/async_gateway.rb
Expand Up @@ -48,7 +48,7 @@ def setup(opts)
@cld_ctrl_uri = http_uri(opts[:cloud_controller_uri])
@external_uri = opts[:external_uri]
@offering_uri = "#{@cld_ctrl_uri}/services/v1/offerings/"
@service_list_uri = "#{@cld_ctrl_uri}/brokered_services/#{API_VERSION}/offerings"
@service_list_uri = "#{@cld_ctrl_uri}/proxied_services/#{API_VERSION}/offerings"
@router_start_channel = nil
@proxy_opts = opts[:proxy]
@ready_to_serve = false
Expand Down Expand Up @@ -150,8 +150,8 @@ def fetch_brokered_services
if http.response_header.status == 200
# For V1, we can't get enough information such as services credentials from CC.
# If CC return a service label that not known by SB, we simply print it out rather than serve it.
resp = VCAP::Services::Api::ListBrokeredServicesResponse.decode(http.response)
resp.brokered_services.each {|bsvc| @logger.info("Fetch brokered service from CC: label=#{bsvc["label"]}")}
resp = VCAP::Services::Api::ListProxiedServicesResponse.decode(http.response)
resp.proxied_services.each {|bsvc| @logger.info("Fetch brokered service from CC: label=#{bsvc["label"]}")}
return true
else
@logger.warn("Failed to fetch brokered services, status=#{http.response_header.status}")
Expand Down Expand Up @@ -180,7 +180,7 @@ def advertise_saved_services(active=true)
def advertise_pre_defined_services(services)
services[:label] = "#{services[:name]}-#{services[:version]}"
%w(name version).each {|key| services.delete(key.to_sym)}
req = VCAP::Services::Api::BrokeredServiceOfferingRequest.new(services)
req = VCAP::Services::Api::ProxiedServiceOfferingRequest.new(services)
advertise_brokered_service(req)
rescue => e
@logger.warn("Failed to advertise pre-defined services #{services.inspect}: #{e}")
Expand All @@ -206,7 +206,7 @@ def on_exit(stop_event_loop=true)

# Advertise or modify a brokered service offerings
post "/service-broker/#{API_VERSION}/offerings" do
req = VCAP::Services::Api::BrokeredServiceOfferingRequest.decode(request_body)
req = VCAP::Services::Api::ProxiedServiceOfferingRequest.decode(request_body)
@logger.debug("Advertise brokered service for label=#{req.label}")

Fiber.new {
Expand Down

0 comments on commit 3771022

Please sign in to comment.