engine

Documentation

Overview

Package engine is the stable public facade for Reconify's reconciliation engine.

Index

• Variables
• type AmbiguousGroupPair
• type AmountDiffPair
• type CounterpartInput
• type CounterpartStream
• type DuplicateGroup
• type FileInfo
• type GroupedAmountDiffPair
• type GroupedEventWriter
• type GroupedMatchedPair
• type GroupedTimingDiffPair
• type IndexFallback
• type IndexSelection
• type IndexSelectionSetter
• type ManyToManyAmountDiffPair
• type ManyToManyEventWriter
• type ManyToManyMatchedPair
• type ManyToManyTimingDiffPair
• type MatchedPair
• type PairConfigSnap
• type PartitionedCounterpart
• type PartitionedCounterpartInput
• type PartitionedOptions
• type ProgressEvent
• type ProgressFunc
• type ReconcileOptions
• type Result
• type ResultWriter
• type RightIndex
• type RunInfo
• type RunInfoSetter
• type SourceBreakdownWriter
• type Summary
• type TelemetryEvent
• type TelemetryOptions
• type TelemetrySink
• type TimingDiffPair
• type Transaction
• type Warning
• type WarningObserver

Variables

var ApplyDuplicatePolicy = matching.ApplyDuplicatePolicy

Matching forwarding.

var BuildRunInfo = reconcile.BuildRunInfo

Audit and partition-routing forwarding.

var NewDiskIndex = index.NewDiskIndex

var NewMemoryIndex = index.NewMemoryIndex

Index forwarding.

var NewResultWriter = output.NewResultWriter

Output forwarding.

var NewTelemetryRunID = telemetry.NewTelemetryRunID

Telemetry forwarding.

var Parse = parser.Parse

var ParseCSV = parser.ParseCSV

var ParseCSVEach = parser.ParseCSVEach

var ParseEach = parser.ParseEach

Parser forwarding.

var ParseWithTelemetry = reconcile.ParseWithTelemetry

var PartitionDuplicateSafe = reconcile.PartitionDuplicateSafe

var PartitionKeyColumns = reconcile.PartitionKeyColumns

var ReadInputHeaders = parser.ReadInputHeaders

var Reconcile = reconcile.Reconcile

Reconciliation forwarding.

var ReconcileMultiSource = reconcile.ReconcileMultiSource

var ReconcileMultiSourceWithTelemetry = reconcile.ReconcileMultiSourceWithTelemetry

var ReconcilePartitioned = reconcile.ReconcilePartitioned

var ReconcilePartitionedMultiSource = reconcile.ReconcilePartitionedMultiSource

var ReconcilePartitionedMultiSourceWithOptions = reconcile.ReconcilePartitionedMultiSourceWithOptions

var ReconcilePartitionedMultiSourceWithOptionsAndTelemetry = reconcile.ReconcilePartitionedMultiSourceWithOptionsAndTelemetry

var ReconcilePartitionedMultiSourceWithTelemetry = reconcile.ReconcilePartitionedMultiSourceWithTelemetry

var ReconcilePartitionedWithOptions = reconcile.ReconcilePartitionedWithOptions

var ReconcilePartitionedWithOptionsAndTelemetry = reconcile.ReconcilePartitionedWithOptionsAndTelemetry

var ReconcilePartitionedWithTelemetry = reconcile.ReconcilePartitionedWithTelemetry

var ReconcileStreaming = reconcile.ReconcileStreaming

var ReconcileStreamingMultiSource = reconcile.ReconcileStreamingMultiSource

var ReconcileStreamingMultiSourceWithTelemetry = reconcile.ReconcileStreamingMultiSourceWithTelemetry

var ReconcileStreamingWithProgress = reconcile.ReconcileStreamingWithProgress

var ReconcileStreamingWithTelemetry = reconcile.ReconcileStreamingWithTelemetry

var ReconcileWithTelemetry = reconcile.ReconcileWithTelemetry

var ResolveParserType = parser.ResolveParserType

var SanitizeCSVField = output.SanitizeCSVField

var VerifyAuditFiles = reconcile.VerifyAuditFiles

var WrapWithResultMode = output.WrapWithResultMode

var WrapWithResultModeAndWarnings = output.WrapWithResultModeAndWarnings

var WriteResult = output.WriteResult

var WriteResultEvents = output.WriteResultEvents

Types

type AmbiguousGroupPair

type AmbiguousGroupPair = domain.AmbiguousGroupPair

type AmountDiffPair

type AmountDiffPair = domain.AmountDiffPair

type CounterpartInput

type CounterpartInput = reconcile.CounterpartInput

type CounterpartStream

type CounterpartStream = reconcile.CounterpartStream

type DuplicateGroup

type DuplicateGroup = domain.DuplicateGroup

type FileInfo

type FileInfo = domain.FileInfo

type GroupedAmountDiffPair

type GroupedAmountDiffPair = domain.GroupedAmountDiffPair

type GroupedEventWriter

type GroupedEventWriter = output.GroupedEventWriter

type GroupedMatchedPair

type GroupedMatchedPair = domain.GroupedMatchedPair

type GroupedTimingDiffPair

type GroupedTimingDiffPair = domain.GroupedTimingDiffPair

type IndexFallback

type IndexFallback = domain.IndexFallback

type IndexSelection

type IndexSelection = domain.IndexSelection

type IndexSelectionSetter

type IndexSelectionSetter = output.IndexSelectionSetter

type ManyToManyAmountDiffPair

type ManyToManyAmountDiffPair = domain.ManyToManyAmountDiffPair

type ManyToManyEventWriter

type ManyToManyEventWriter = output.ManyToManyEventWriter

type ManyToManyMatchedPair

type ManyToManyMatchedPair = domain.ManyToManyMatchedPair

type ManyToManyTimingDiffPair

type ManyToManyTimingDiffPair = domain.ManyToManyTimingDiffPair

type MatchedPair

type MatchedPair = domain.MatchedPair

type PairConfigSnap

type PairConfigSnap = domain.PairConfigSnap

type PartitionedCounterpart

type PartitionedCounterpart = reconcile.PartitionedCounterpart

type PartitionedCounterpartInput

type PartitionedCounterpartInput = reconcile.PartitionedCounterpartInput

type PartitionedOptions

type PartitionedOptions = reconcile.PartitionedOptions

Reconciliation aliases.

type ProgressEvent

type ProgressEvent = telemetry.ProgressEvent

type ProgressFunc

type ProgressFunc = telemetry.ProgressFunc

type ReconcileOptions

type ReconcileOptions = matching.ReconcileOptions

Matching aliases.

type Result

type Result = domain.Result

type ResultWriter

type ResultWriter = output.ResultWriter

Output aliases.

type RightIndex

type RightIndex = index.RightIndex

Index aliases.

type RunInfo

type RunInfo = domain.RunInfo

type RunInfoSetter

type RunInfoSetter = output.RunInfoSetter

type SourceBreakdownWriter

type SourceBreakdownWriter = output.SourceBreakdownWriter

type Summary

type Summary = domain.Summary

type TelemetryEvent

type TelemetryEvent = telemetry.TelemetryEvent

Telemetry aliases.

type TelemetryOptions

type TelemetryOptions = telemetry.TelemetryOptions

type TelemetrySink

type TelemetrySink = telemetry.TelemetrySink

type TimingDiffPair

type TimingDiffPair = domain.TimingDiffPair

type Transaction

type Transaction = domain.Transaction

Domain aliases.

type Warning

type Warning = domain.Warning

type WarningObserver

type WarningObserver = domain.WarningObserver