odfi

Aug 11, 2022

Changes in this version

type MockProcessor

+ HandledFile *File

Jul 27, 2022

Changes in this version

+ func IncomingEmitter(logger log.Logger, cfg service.ODFIIncoming, recon service.ODFIReconciliation, ...) *incomingEmitter

Sep 14, 2021

Changes in this version

+ type AuditSaver struct

+ func SaveFilesIntoAuditTrail(hostname string, cfg *service.AuditTrail) (*AuditSaver, error)

Jun 11, 2021

Changes in this version

+ func Cleanup(logger log.Logger, agent upload.Agent, dl *downloadedFiles) error

+ func CleanupEmptyFiles(logger log.Logger, agent upload.Agent, dl *downloadedFiles) error

+ func CorrectionEmitter(logger log.Logger, cfg service.ODFICorrections, svc events.Emitter) *correctionProcessor

+ func CreditReconciliationEmitter(logger log.Logger, cfg service.ODFIReconciliation, svc events.Emitter) *creditReconciliation

+ func PrenoteEmitter(logger log.Logger, cfg service.ODFIPrenotes, svc events.Emitter) *prenoteEmitter

+ func ProcessFiles(dl *downloadedFiles, fileProcessors Processors) error

+ func ReturnEmitter(logger log.Logger, cfg service.ODFIReturns, svc events.Emitter) *returnEmitter

+ type Downloader interface

+ CopyFilesFromRemote func(agent upload.Agent) (*downloadedFiles, error)

+ func NewDownloader(logger log.Logger, cfg service.ODFIStorage) (Downloader, error)

+ type File struct

+ ACHFile *ach.File

+ Filepath string

+ type FileProcessor interface

+ Handle func(file File) error

+ Type func() string

+ type MockProcessor struct

+ Err error

+ func (pc *MockProcessor) Handle(file File) error

+ func (pc *MockProcessor) Type() string

+ type MockScheduler struct

+ Err error

+ func (*MockScheduler) RegisterRoutes(_ *admin.Server)

+ func (*MockScheduler) Shutdown()

+ func (s *MockScheduler) Start() error

+ type PeriodicScheduler struct

+ func (s *PeriodicScheduler) RegisterRoutes(svc *admin.Server)

+ func (s *PeriodicScheduler) Shutdown()

+ func (s *PeriodicScheduler) Start() error

+ type Processors []FileProcessor

+ func SetupProcessors(pcs ...FileProcessor) Processors

+ func (pcs Processors) HandleAll(file File) error

+ type Scheduler interface

+ RegisterRoutes func(svc *admin.Server)

+ Shutdown func()

+ Start func() error

+ func NewPeriodicScheduler(logger log.Logger, cfg *service.Config, processors Processors) (Scheduler, error)