Contents

module Larrow::Runner
  module Model
  class Node
    include Larrow::Runner::Service
    include Larrow::Qingcloud
    attr_accessor :instance, :eip
    attr_accessor :user,:host
    def initialize instance, eip, user='root'
      self.instance = instance
      self.eip = eip
      self.host = eip.address
      self.user = user
      @executor = Executor.new host, user, nil, nil
    end

    def execute command, base_dir:nil
      block = if block_given?
                -> (data) { yield data }
              else
                -> (data) {
                  data.split(/\r?\n/).each do |msg|
                    RunLogger.level(1).info msg 
                  end
                }
              end
      @executor.execute command, base_dir: base_dir, &block
    end

    def stop
      self.instance = instance.stop
    end

    def destroy
      instance.destroy.force
      eip.destroy.force
      self
    end

    def dump
      {
        instance:{id: instance.id},
        eip:{id:eip.id, address:eip.address}
      }
    end

    def self.show resources, level=0
      resources.map do |hash|
        node = load_obj hash
        RunLogger.level(level).info "instance: #{node.instance.id}"
        RunLogger.level(level).info "eip:"
        RunLogger.level(level+1).info "id: #{node.eip.id}"
        RunLogger.level(level+1).info "address: #{node.eip.address}"
      end
    end

    def self.cleanup resources
      resources.map do |hash|
        node = load_obj hash
        future{node.destroy}
      end.map do |instance|
        RunLogger.detail "node cleaned: #{instance.address}"
      end
    end

    def self.load_obj data
        instance = Instance.new data[:instance][:id]
        eip = Eip.new data[:eip][:id],address:data[:eip][:address]
        new instance,eip
    end

  end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
larrow-runner-0.0.1	lib/larrow/runner/model/node.rb