def start_streaming
      info 'start streaming logs from containers'

      Docker::Container.all.each do |container|
        begin
          self.stream_container_logs(container) unless container.skip_logs?
        rescue Docker::Error::NotFoundError => exc
          # Could be thrown since container.skip_logs? actually loads the container details
          warn exc.message
        rescue => exc
          error exc
        end
      end

      @streaming = true
    end
def start_streaming
      info 'start streaming logs from containers'

      Docker::Container.all.each do |container|
        begin
          self.stream_container_logs(container) unless container.skip_logs?
        rescue Docker::Error::NotFoundError => exc
          # Could be thrown since container.skip_logs? actually loads the container details
          warn exc.message
        rescue => exc
          error exc
        end
      end

      @streaming = true
    end
requires etcd to be available to read log timestamps