lib/bolt/transport/base.rb in bolt-1.2.0 vs lib/bolt/transport/base.rb in bolt-1.3.0
- old
+ new
@@ -151,10 +151,15 @@
@logger.debug { "Uploading: '#{source}' to #{destination} on #{target.uri}" }
upload(target, source, destination, filter_options(target, options))
end
end
+ def batch_connected?(targets)
+ assert_batch_size_one("connected?()", targets)
+ connected?(targets.first)
+ end
+
# Split the given list of targets into a list of batches. The default
# implementation returns single-node batches.
#
# Transports may override this method, and the corresponding batch_*
# methods, to implement their own batch processing.
@@ -178,9 +183,14 @@
end
# Transports should override this method with their own implementation of file upload.
def upload(*_args)
raise NotImplementedError, "upload() must be implemented by the transport class"
+ end
+
+ # Transports should override this method with their own implementation of a connection test.
+ def connected?(_targets)
+ raise NotImplementedError, "connected?() must be implemented by the transport class"
end
# Unwraps any Sensitive data in an arguments Hash, so the plain-text is passed
# to the Task/Script.
#