Class: Docker::Distribution::Connection

Inherits:
Object
  • Object
show all
Includes:
Error
Defined in:
lib/docker/distribution/api/connection.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(url, opts) ⇒ Connection

Create a new Connection. This method takes a url (String) and options (Hash). These are passed to Excon, so any options valid for ‘Excon.new` can be passed here.



14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/docker/distribution/api/connection.rb', line 14

def initialize(url, opts)
  case
    when !url.is_a?(String)
      raise ArgumentError, "Expected a String, got: '#{url.class}'"
    when !opts.is_a?(Hash)
      raise ArgumentError, "Expected a Hash, got: '#{opts.class}'"
    else
      uri = URI.parse(url)
      if ['https', 'http'].include? uri.scheme
        @url, @options = url, opts
      else
        @url, @options = "http://#{uri}", opts
      end
  end
end

Instance Attribute Details

#options ⇒ Object (readonly)

Returns the value of attribute options.



9
10
11
 
# File 'lib/docker/distribution/api/connection.rb', line 9

def options
  @options
end

#url ⇒ Object (readonly)

Returns the value of attribute url.



9
10
11
 
# File 'lib/docker/distribution/api/connection.rb', line 9

def url
  @url
end

Instance Method Details

#log_request(request) ⇒ Object 



57
58
59
60
61
62
63
 
# File 'lib/docker/distribution/api/connection.rb', line 57

def log_request(request)
  if Api.logger
    Api.logger.debug(
      [request[:method], request[:path], request[:query], request[:body]]
    )
  end
end

#request(*args, &block) ⇒ Object

Send a request to the server with the ‘



39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
 
# File 'lib/docker/distribution/api/connection.rb', line 39

def request(*args, &block)
  request = compile_request_params(*args, &block)
  log_request(request)
  resource.request(request)
rescue Excon::Errors::BadRequest => ex
  raise ClientError, ex.response.body
rescue Excon::Errors::Unauthorized => ex
  raise UnauthorizedError, ex.response.body
rescue Excon::Errors::NotFound => ex
  raise NotFoundError, ex.response.body
rescue Excon::Errors::Conflict => ex
  raise ConflictError, ex.response.body
rescue Excon::Errors::InternalServerError => ex
  raise ServerError, ex.response.body
rescue Excon::Errors::Timeout => ex
  raise TimeoutError, ex.message
end

#to_s ⇒ Object 



70
71
72
 
# File 'lib/docker/distribution/api/connection.rb', line 70

def to_s
  "Docker::Distribution::Connection { :url => #{url}, :options => #{options} }"
end