1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
|
# encoding: utf-8
#
# Author:: Dominik Richter (<dominik.richter@gmail.com>)
# Author:: Christoph Hartmann (<chris@lollyrock.com>)
require "logger"
require_relative "../errors"
require_relative "../extras"
require_relative "../options"
class Train::Plugins
class Transport
include Train::Extras
Train::Options.attach(self)
require_relative "base_connection"
# Initialize a new Transport object
#
# @param [Hash] config = nil the configuration for this transport
# @return [Transport] the transport object
def initialize(options = {})
@options = merge_options({}, options || {})
@logger = @options[:logger] || Logger.new($stdout, level: :fatal)
end
# Create a connection to the target. Options may be provided
# for additional configuration.
#
# @param [Hash] _options = nil provide optional configuration params
# @return [Connection] the connection for this configuration
def connection(_options = nil)
raise Train::ClientError, "#{self.class} does not implement #connection()"
end
# Register the inheriting class with as a train plugin using the
# provided name.
#
# @param [String] name of the plugin, by which it will be found
def self.name(name)
Train::Plugins.registry[name] = self
end
private
# @return [Logger] logger for reporting information
attr_reader :logger
end
end
|
