class MagicPipe::Transports::Base

Attributes

logger[R]
metrics[R]

Public Class Methods

new(config, metrics) click to toggle source
# File lib/magic_pipe/transports/base.rb, line 4
def initialize(config, metrics)
  @config = config
  @metrics = metrics
  @logger = @config.logger
end

Public Instance Methods

submit!(payload, metadata) click to toggle source
# File lib/magic_pipe/transports/base.rb, line 12
def submit!(payload, metadata)
  raise MagicPipe::Transports::NotImplementedError
end