Class: DockerSync::SyncStrategy::Rsync
- Inherits:
-
Object
- Object
- DockerSync::SyncStrategy::Rsync
- Includes:
- Thor::Shell
- Defined in:
- lib/docker-sync/sync_strategy/rsync.rb
Instance Method Summary collapse
- #clean ⇒ Object
- #get_container_name ⇒ Object
- #get_docker_env ⇒ Object
- #get_group_mapping ⇒ Object
- #get_user_mapping ⇒ Object
- #get_volume_name ⇒ Object
-
#health_check ⇒ Object
sleep until rsync –dry-run succeeds in connecting to the daemon on the configured IP and port.
-
#initialize(sync_name, options) ⇒ Rsync
constructor
A new instance of Rsync.
- #reset_container ⇒ Object
- #run ⇒ Object
-
#start_container ⇒ Object
starts a rsync docker container listening on the specific port this container exposes a named volume and is on one side used as the rsync-endpoint for the local rsync command, on the other side the volume is mounted into the app-container to share the code / content.
- #stop ⇒ Object
- #stop_container ⇒ Object
- #sync ⇒ Object
- #sync_options ⇒ Object
Constructor Details
#initialize(sync_name, options) ⇒ Rsync
Returns a new instance of Rsync.
13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 13 def initialize(sync_name, ) @sync_name = sync_name @options = # if a custom image is set, apply it if @options.key?('image') @docker_image = @options['image'] else @docker_image = 'eugenmayer/rsync' end begin Dependencies::Rsync.ensure! rescue StandardError => e say_status 'error', "#{@sync_name} has been configured to sync with rsync, but no rsync or fswatch binary available", :red say_status 'error', e., :red exit 1 end end |
Instance Method Details
#clean ⇒ Object
168 169 170 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 168 def clean reset_container end |
#get_container_name ⇒ Object
89 90 91 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 89 def get_container_name return "#{@sync_name}" end |
#get_docker_env ⇒ Object
150 151 152 153 154 155 156 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 150 def get_docker_env env_mapping = [] env_mapping << "-e VOLUME=#{@options['dest']}" env_mapping << "-e TZ=$(basename $(dirname `readlink /etc/localtime`))/$(basename `readlink /etc/localtime`)" env_mapping << "-e ALLOW=#{@options['sync_host_allow']}" if @options['sync_host_allow'] env_mapping.join(' ') end |
#get_group_mapping ⇒ Object
141 142 143 144 145 146 147 148 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 141 def get_group_mapping group_mapping = '' if @options.key?('sync_groupid') raise 'for now, rsync does no longer support groupid, but for nearly all cases sync_userid should be enough' #group_mapping = "#{group_mapping} -e GROUP_ID=#{@options['sync_groupid']}" end return group_mapping end |
#get_user_mapping ⇒ Object
133 134 135 136 137 138 139 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 133 def get_user_mapping user_mapping = '' if @options.key?('sync_userid') user_mapping = "#{user_mapping} -e OWNER_UID=#{@options['sync_userid']}" end return user_mapping end |
#get_volume_name ⇒ Object
93 94 95 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 93 def get_volume_name return @sync_name end |
#health_check ⇒ Object
sleep until rsync –dry-run succeeds in connecting to the daemon on the configured IP and port.
75 76 77 78 79 80 81 82 83 84 85 86 87 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 75 def health_check health_check_cmd = "rsync --dry-run rsync://#{@options['sync_host_ip']}:#{@options['sync_host_port']}:: 2> /dev/null" retry_counter = 0 health_check_status = `#{health_check_cmd}` while health_check_status == '' && retry_counter < 10 do say_status 'ok', "waiting for rsync daemon on rsync://#{@options['sync_host_ip']}:#{@options['sync_host_port']}", :white if @options['verbose'] retry_counter += 1 health_check_status = `#{health_check_cmd}` sleep 1 end end |
#reset_container ⇒ Object
162 163 164 165 166 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 162 def reset_container stop_container `docker ps -a | grep #{get_container_name} && docker rm #{get_container_name}` `docker volume ls -q | grep #{get_volume_name} && docker volume rm #{get_volume_name}` end |
#run ⇒ Object
32 33 34 35 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 32 def run start_container sync end |
#start_container ⇒ Object
starts a rsync docker container listening on the specific port this container exposes a named volume and is on one side used as the rsync-endpoint for the local rsync command, on the other side the volume is mounted into the app-container to share the code / content
100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 100 def start_container say_status 'ok', "Starting rsync for sync #{@sync_name}", :white container_name = get_container_name volume_name = get_volume_name running = `docker ps --filter 'status=running' --filter 'name=#{container_name}' --format "{{.Names}}" | grep '^#{container_name}$'` if running == '' # container is yet not running say_status 'ok', "#{container_name} container not running", :white if @options['verbose'] exists = `docker ps --filter "status=exited" --filter "name=#{container_name}" --format "{{.Names}}" | grep '^#{container_name}$'` if exists == '' # container has yet not been created say_status 'ok', "creating #{container_name} container", :white if @options['verbose'] user_mapping = get_user_mapping group_mapping = get_group_mapping docker_env = get_docker_env cmd = "docker run -p '#{@options['sync_host_port']}:873' -v #{volume_name}:#{@options['dest']} #{user_mapping} #{group_mapping} #{docker_env} --name #{container_name} -d #{@docker_image}" else # container already created, just start / reuse it say_status 'ok', "starting #{container_name} container", :white if @options['verbose'] cmd = "docker start #{container_name}" end say_status 'command', cmd, :white if @options['verbose'] `#{cmd}` || raise('Start failed') else say_status 'ok', "#{container_name} container still running", :blue if @options['verbose'] end say_status 'ok', "#{container_name}: starting initial sync of #{@options['src']}", :white if @options['verbose'] health_check sync say_status 'success', 'Rsync server started', :green end |
#stop ⇒ Object
172 173 174 175 176 177 178 179 180 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 172 def stop say_status 'ok', "Stopping sync container #{get_container_name}" begin stop_container rescue StandardError => e say_status 'error', "Stopping failed of #{get_container_name}:", :red puts e. end end |
#stop_container ⇒ Object
158 159 160 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 158 def stop_container `docker ps | grep #{get_container_name} && docker stop #{get_container_name}` end |
#sync ⇒ Object
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 37 def sync args = cmd = 'rsync ' + args.join(' ') say_status 'command', cmd, :white if @options['verbose'] out = `#{cmd}` if $?.exitstatus > 0 say_status 'error', "Error starting sync, exit code #{$?.exitstatus}", :red say_status 'message', out else TerminalNotifier.notify( "Synced #{@options['src']}", :title => @sync_name ) if @options['notify_terminal'] say_status 'ok', "Synced #{@options['src']}", :white if @options['verbose'] say_status 'output', out end end end |
#sync_options ⇒ Object
58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 |
# File 'lib/docker-sync/sync_strategy/rsync.rb', line 58 def args = [] unless @options['sync_excludes'].nil? args = @options['sync_excludes'].map { |pattern| "--exclude='#{pattern}'" } + args end args.push('-ap') args.push(@options['sync_args']) if @options.key?('sync_args') # we do not need to user usermap/groupmap since we started our container the way that it also maps user/group like we defined # in the config - see start_container #args.push("--usermap='*:#{@options['sync_user']}'") if @options.key?('sync_user') #args.push("--groupmap='*:#{@options['sync_group']}'") if @options.key?('sync_group') args.push("'#{@options['src']}'") args.push("rsync://#{@options['sync_host_ip']}:#{@options['sync_host_port']}/volume") return args end |