class Bosh::Cli::DirectorTask

Attributes

offset[RW]

Public Class Methods

new(director, task_id, log_type = nil) click to toggle source
# File lib/cli/director_task.rb, line 5
def initialize(director, task_id, log_type = nil)
  @director = director
  @task_id = task_id
  @offset = 0
  @log_type = log_type
  @buf = ""
end

Public Instance Methods

cancel() click to toggle source
# File lib/cli/director_task.rb, line 53
def cancel
  @director.cancel_task(@task_id)
end
flush_output() click to toggle source
# File lib/cli/director_task.rb, line 47
def flush_output
  out = @buf
  @buf = ""
  out.blank? ? nil : "#{out}\n"
end
output() click to toggle source
# File lib/cli/director_task.rb, line 21
def output
  body, new_offset = @director.get_task_output(@task_id, @offset, @log_type)

  @buf << body if body

  if new_offset
    @offset = new_offset
  else
    return flush_output
  end

  last_nl = @buf.rindex("\n")

  if last_nl.nil?
    result = nil
  elsif last_nl != @buf.size - 1
    result = @buf[0..last_nl]
    @buf = @buf[last_nl+1..-1]
  else
    result = @buf
    @buf = ""
  end

  result
end
result() click to toggle source
# File lib/cli/director_task.rb, line 17
def result
  @director.get_task_result(@task_id)
end
state() click to toggle source
# File lib/cli/director_task.rb, line 13
def state
  @director.get_task_state(@task_id)
end