Documentation ¶
Index ¶
- 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, auditSaver *AuditSaver, fileProcessors Processors) error
- func ReturnEmitter(logger log.Logger, cfg service.ODFIReturns, svc events.Emitter) *returnEmitter
- type AuditSaver
- type Downloader
- type File
- type FileProcessor
- type MockProcessor
- type MockScheduler
- type PeriodicScheduler
- type Processors
- type Scheduler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CleanupEmptyFiles ¶
CleanupEmptyFiles deletes empty ACH files if file is older than value in config
func CorrectionEmitter ¶
func PrenoteEmitter ¶
func ProcessFiles ¶
func ProcessFiles(dl *downloadedFiles, auditSaver *AuditSaver, fileProcessors Processors) error
func ReturnEmitter ¶
Types ¶
type AuditSaver ¶ added in v0.8.0
type AuditSaver struct {
// contains filtered or unexported fields
}
func SaveFilesIntoAuditTrail ¶ added in v0.8.0
func SaveFilesIntoAuditTrail(hostname string, cfg *service.AuditTrail) (*AuditSaver, error)
type Downloader ¶
func NewDownloader ¶
func NewDownloader(logger log.Logger, cfg service.ODFIStorage) (Downloader, error)
type FileProcessor ¶
type MockProcessor ¶
type MockProcessor struct {
Err error
}
func (*MockProcessor) Handle ¶
func (pc *MockProcessor) Handle(file File) error
func (*MockProcessor) Type ¶
func (pc *MockProcessor) Type() string
type MockScheduler ¶
type MockScheduler struct {
Err error
}
func (*MockScheduler) RegisterRoutes ¶
func (*MockScheduler) RegisterRoutes(_ *admin.Server)
func (*MockScheduler) Shutdown ¶
func (*MockScheduler) Shutdown()
func (*MockScheduler) Start ¶
func (s *MockScheduler) Start() error
type PeriodicScheduler ¶
type PeriodicScheduler struct {
// contains filtered or unexported fields
}
func (*PeriodicScheduler) RegisterRoutes ¶
func (s *PeriodicScheduler) RegisterRoutes(svc *admin.Server)
func (*PeriodicScheduler) Shutdown ¶
func (s *PeriodicScheduler) Shutdown()
func (*PeriodicScheduler) Start ¶
func (s *PeriodicScheduler) Start() error
type Processors ¶
type Processors []FileProcessor
func SetupProcessors ¶
func SetupProcessors(pcs ...FileProcessor) Processors
func (Processors) HandleAll ¶
func (pcs Processors) HandleAll(file File) error
Click to show internal directories.
Click to hide internal directories.