Class: Fog::NFV::OpenStack::Real

Inherits:
Object
  • Object
show all
Includes:
OpenStack::Core
Defined in:
lib/fog/openstack/nfv.rb,
lib/fog/openstack/requests/nfv/get_vnf.rb,
lib/fog/openstack/requests/nfv/get_vnfd.rb,
lib/fog/openstack/requests/nfv/list_vnfs.rb,
lib/fog/openstack/requests/nfv/create_vnf.rb,
lib/fog/openstack/requests/nfv/delete_vnf.rb,
lib/fog/openstack/requests/nfv/list_vnfds.rb,
lib/fog/openstack/requests/nfv/update_vnf.rb,
lib/fog/openstack/requests/nfv/create_vnfd.rb,
lib/fog/openstack/requests/nfv/delete_vnfd.rb

Instance Attribute Summary

Attributes included from OpenStack::Core

#auth_token, #auth_token_expiration, #current_tenant, #current_user, #current_user_id, #openstack_cache_ttl, #openstack_domain_id, #openstack_domain_name, #openstack_identity_prefix, #openstack_project_domain, #openstack_project_domain_id, #openstack_project_id, #openstack_user_domain, #openstack_user_domain_id

Instance Method Summary collapse

Methods included from OpenStack::Core

#credentials, #initialize_identity, #reload

Constructor Details

#initialize(options = {}) ⇒ Real

Returns a new instance of Real.



101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
 
# File 'lib/fog/openstack/nfv.rb', line 101

def initialize(options = {})
  initialize_identity options

  @openstack_service_type  = options[:openstack_service_type] || ['servicevm']
  @openstack_service_name  = options[:openstack_service_name]

  @connection_options = options[:connection_options] || {}

  authenticate

  unless @path.match(SUPPORTED_VERSIONS)
    @path = "/" + Fog::OpenStack.get_supported_version(
      SUPPORTED_VERSIONS,
      @openstack_management_uri,
      @auth_token,
      @connection_options
    )
  end

  @persistent = options[:persistent] || false
  @connection = Fog::Core::Connection.new("#{@scheme}://#{@host}:#{@port}", @persistent, @connection_options)
end

Instance Method Details

#create_vnf(options) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/fog/openstack/requests/nfv/create_vnf.rb', line 5

def create_vnf(options)
  options_valid = [
    :auth,
    :vnf,
  ]

  # Filter only allowed creation attributes
  data = options.select do |key, _|
    options_valid.include?(key.to_sym) || options_valid.include?(key.to_s)
  end

  request(
    :body    => Fog::JSON.encode(data),
    :expects => 201,
    :method  => "POST",
    :path    => "vnfs"
  )
end

#create_vnfd(options) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/fog/openstack/requests/nfv/create_vnfd.rb', line 5

def create_vnfd(options)
  options_valid = [
    :auth,
    :vnfd,
  ]

  # Filter only allowed creation attributes
  data = options.select do |key, _|
    options_valid.include?(key.to_sym) || options_valid.include?(key.to_s)
  end

  request(
    :body    => Fog::JSON.encode(data),
    :expects => 201,
    :method  => "POST",
    :path    => "vnfds"
  )
end

#delete_vnf(vnf_id) ⇒ Object 



5
6
7
8
9
10
11
 
# File 'lib/fog/openstack/requests/nfv/delete_vnf.rb', line 5

def delete_vnf(vnf_id)
  request(
    :expects => 204,
    :method  => "DELETE",
    :path    => "vnfs/#{vnf_id}"
  )
end

#delete_vnfd(vnfd_id) ⇒ Object 



5
6
7
8
9
10
11
 
# File 'lib/fog/openstack/requests/nfv/delete_vnfd.rb', line 5

def delete_vnfd(vnfd_id)
  request(
    :expects => 204,
    :method  => "DELETE",
    :path    => "vnfds/#{vnfd_id}"
  )
end

#get_vnf(vnf_id) ⇒ Object 



5
6
7
8
9
10
11
 
# File 'lib/fog/openstack/requests/nfv/get_vnf.rb', line 5

def get_vnf(vnf_id)
  request(
    :expects => 200,
    :method  => 'GET',
    :path    => "vnfs/#{vnf_id}"
  )
end

#get_vnfd(vnfd_id) ⇒ Object 



5
6
7
8
9
10
11
 
# File 'lib/fog/openstack/requests/nfv/get_vnfd.rb', line 5

def get_vnfd(vnfd_id)
  request(
    :expects => 200,
    :method  => 'GET',
    :path    => "vnfds/#{vnfd_id}"
  )
end

#list_vnfds(options = {}) ⇒ Object 



5
6
7
8
9
10
11
12
 
# File 'lib/fog/openstack/requests/nfv/list_vnfds.rb', line 5

def list_vnfds(options = {})
  request(
    :expects => 200,
    :method  => 'GET',
    :path    => "vnfds",
    :query   => options
  )
end

#list_vnfs(options = {}) ⇒ Object 



5
6
7
8
9
10
11
12
 
# File 'lib/fog/openstack/requests/nfv/list_vnfs.rb', line 5

def list_vnfs(options = {})
  request(
    :expects => 200,
    :method  => 'GET',
    :path    => "vnfs",
    :query   => options
  )
end

#request(params) ⇒ Object 



124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
 
# File 'lib/fog/openstack/nfv.rb', line 124

def request(params)
  response = @connection.request(
    params.merge(
      :headers => {
        'Content-Type' => 'application/json',
        'X-Auth-Token' => @auth_token
      }.merge!(params[:headers] || {}),
      :path    => "#{@path}/#{params[:path]}"
    )
  )
rescue Excon::Errors::Unauthorized    => error
  if error.response.body != "Bad username or password" # token expiration
    @openstack_must_reauthenticate = true
    authenticate
    retry
  else # bad credentials
    raise error
  end
rescue Excon::Errors::HTTPStatusError => error
  raise case error
        when Excon::Errors::NotFound
          Fog::NFV::OpenStack::NotFound.slurp(error)
        else
          error
        end
else
  unless response.body.empty?
    response.body = Fog::JSON.decode(response.body)
  end
  response
end

#update_vnf(id, options) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/fog/openstack/requests/nfv/update_vnf.rb', line 5

def update_vnf(id, options)
  options_valid = [
    :auth,
    :vnf,
  ]

  # Filter only allowed creation attributes
  data = options.select do |key, _|
    options_valid.include?(key.to_sym) || options_valid.include?(key.to_s)
  end

  request(
    :body    => Fog::JSON.encode(data),
    :expects => 200,
    :method  => "PUT",
    :path    => "vnfs/#{id}",
  )
end