Contents

module Filbunke
  class Repository
    attr_accessor :name,
                  :host,
                  :port,
                  :local_path,
                  :file_umask,
                  :directory_umask,
                  :user,
                  :pass,
                  :hadoop_binary,
                  :run_every,
                  :hydra_concurrency,
                  :batch_size

    def initialize(repository_config)
      @name = repository_config["filbunke_server_repository"]
      @host = repository_config["filbunke_server_host"]
      @port = repository_config["filbunke_server_port"]
      @local_path = repository_config["local_path"]
      @file_umask = repository_config["file_umask"].to_i
      @directory_umask = repository_config["directory_umask"].to_i
      @user = repository_config["file_url_username"]
      @pass = repository_config["file_url_password"]
      @hadoop_binary = repository_config["hadoop_binary"]
      @run_every = repository_config.fetch("run_every", 10).to_i
      @hydra_concurrency = repository_config.fetch("hydra_concurrency", 100).to_i
      # batch_size == 0 means use default configured in filbunke-server
      @batch_size = repository_config.fetch("batch_size", 0).to_i
   end
 end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
filbunke-1.13.5	lib/filbunke/repository.rb
filbunke-1.13.4	lib/filbunke/repository.rb
filbunke-1.13.3	lib/filbunke/repository.rb
filbunke-1.13.2	lib/filbunke/repository.rb
filbunke-1.13.1	lib/filbunke/repository.rb
filbunke-1.13.0	lib/filbunke/repository.rb