Class: Fog::Kubevirt::Compute::Services

Inherits:
Collection
  • Object
show all
Defined in:
lib/fog/kubevirt/compute/models/services.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#kind ⇒ Object (readonly)

Returns the value of attribute kind.



8
9
10
 
# File 'lib/fog/kubevirt/compute/models/services.rb', line 8

def kind
  @kind
end

#resource_version ⇒ Object (readonly)

Returns the value of attribute resource_version.



8
9
10
 
# File 'lib/fog/kubevirt/compute/models/services.rb', line 8

def resource_version
  @resource_version
end

Instance Method Details

#all(filters = {}) ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/fog/kubevirt/compute/models/services.rb', line 12

def all(filters = {})
  begin
    srvs = service.list_services(filters)

    @kind = srvs.kind
    @resource_version = srvs.resource_version
  rescue ::Fog::Kubevirt::Errors::ClientError
    # we assume that we get 404
    srvs = []

    @kind = 'Service'
  end

  load srvs
end

#create(args = {}) ⇒ Object

Creates a service using provided paramters: :name [String] - name of a service :port [int] - a port which will be exposed on node and cluster :target_port [int] - a vmi port which will be forwarded :vmi_name [String] - name of a vmi to be selected :service_type [String] - service type used to create service

Parameters:

  • attributes (Hash) —

    containing details about service to be created.



41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'lib/fog/kubevirt/compute/models/services.rb', line 41

def create(args = {})
  port = args[:port]
  name = args[:name]
  target_port = args[:target_port]
  vmi_name = args[:vmi_name]
  service_type = args[:service_type]

  srv = {
    :apiVersion => "v1",
    :kind => "Service",
    :metadata => {
      :name      => name,
      :namespace => service.namespace
    },
    :spec => {
      :externalTrafficPolicy => "Cluster",
      :ports => [
        {:nodePort   => port,
         :port       => port,
         :protocol   => "TCP",
         :targetPort => target_port
        }
      ],
      :selector => {
        :"kubevirt.io/vm" => vmi_name
      },
      :type => service_type
    }
  }

  service.create_service(srv)
end

#delete(name) ⇒ Object 



74
75
76
77
78
79
80
81
82
83
 
# File 'lib/fog/kubevirt/compute/models/services.rb', line 74

def delete(name)
  begin
    srv = get(name)
  rescue ::Fog::Kubevirt::Errors::ClientError
    # the service doesn't exist
    srv = nil
  end

  service.delete_service(name, service.namespace) unless srv.nil?
end

#get(name) ⇒ Object 



28
29
30
 
# File 'lib/fog/kubevirt/compute/models/services.rb', line 28

def get(name)
  new service.get_service(name)
end