Sha256: 75ab209fca2f0673f323333c89225130826d92de67873eb4e90f9cbcd555fe22

Contents?: true

Size: 1.96 KB

Versions: 26

Compression:

Stored size: 1.96 KB

Contents

class Skynet
  
  class Error < StandardError
  end
  
  class RequestExpiredError < Skynet::Error
	end
	
	class InvalidMessage < Skynet::Error
  end
  
  class AbstractClassError < Skynet::Error
  end
	
  class MessageQueueAdapter

    def list_results(data,timeout=nil)
      raise AbstractClassError.new("You must implement list_results in a subclass.")
    end

    def list_tasks(template,timeout=nil)
      raise AbstractClassError.new("You must implement method in a subclass.")
    end

    def take_next_task(template,timeout=nil)
      raise AbstractClassError.new("You must implement method in a subclass.")
    end

    def write_message(template,timeout=nil)
      raise AbstractClassError.new("You must implement method in a subclass.")
    end

    def write_result(template,timeout=nil)
      raise AbstractClassError.new("You must implement method in a subclass.")
    end

    def take_result(template,timeout=nil)
      raise AbstractClassError.new("You must implement method in a subclass.")
    end

    def write_error(template,timeout=nil)
      raise AbstractClassError.new("You must implement method in a subclass.")
    end            

    def write_worker_status(template,timeout=nil)
      raise AbstractClassError.new("You must implement method in a subclass.")
    end

    def take_worker_status(template,timeout=nil)
      raise AbstractClassError.new("You must implement method in a subclass.")
    end

    def read_all_worker_statuses(template,timeout=nil)
      raise AbstractClassError.new("You must implement method in a subclass.")
    end

    def get_worker_version(template,timeout=nil)
      raise AbstractClassError.new("You must implement method in a subclass.")
    end

    def set_worker_version(template,timeout=nil)
      raise AbstractClassError.new("You must implement method in a subclass.")
    end
      
    def clear_outstanding_tasks
      raise AbstractClassError.new("You must implement clear_outstanding_tasks in a subclass.")
    end  

  end
end

Version data entries

26 entries across 26 versions & 3 rubygems

Version Path
brendan-skynet-0.9.3.1 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.3.2 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.3.3 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.3.5 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.3.6 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.3.7 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.3.8 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.303 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.304 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.305 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.31 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.310 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.311 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.312 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.313 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.314 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.315 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.316 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.317 lib/skynet/message_queue_adapters/message_queue_adapter.rb
brendan-skynet-0.9.318 lib/skynet/message_queue_adapters/message_queue_adapter.rb