Sha256: fc002ca30c8350b1e10805b5f48320c1dcc9549afaf1045493c8fb4fe1d18ee6
Contents?: true
Size: 878 Bytes
Versions: 7
Compression:
Stored size: 878 Bytes
Contents
# frozen_string_literal: true
module Multiwoven
module Integrations::Core
class DestinationConnector < BaseConnector
# Records are transformed json payload send it to the destination
# SyncConfig is the Protocol::SyncConfig object
def write(_sync_config, _records, _action = "destination_insert")
raise "Not implemented"
# return Protocol::TrackingMessage
end
def tracking_message(success, failure, log_message_array)
Multiwoven::Integrations::Protocol::TrackingMessage.new(
success: success, failed: failure, logs: log_message_array
).to_multiwoven_message
end
def auth_headers(access_token)
{
"Accept" => "application/json",
"Authorization" => "Bearer #{access_token}",
"Content-Type" => "application/json"
}
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems