Sha256: 704904b253be0f17bb16fe2bbf3214753920cc5d4710e8873e52cabddf322902
Contents?: true
Size: 666 Bytes
Versions: 61
Compression:
Stored size: 666 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
end
end
end
Version data entries
61 entries across 61 versions & 1 rubygems