inbound

package

v0.10.4 Latest Latest Go to latest Published: Jul 22, 2021 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

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

Cleanup deletes files on remote servers if enabled via config

func CleanupEmptyFiles(logger log.Logger, agent upload.Agent, dl *downloadedFiles, now time.Time, after time.Duration) error

CleanupEmptyFiles deletes empty ACH files if file is older than value in config

func NewCorrectionProcessor(logger log.Logger) *correctionProcessor

func NewPrenoteProcessor(logger log.Logger) *prenoteProcessor

func NewReturnProcessor(logger log.Logger, transferRepo transfers.Repository) *returnProcessor

func ProcessFiles(dl *downloadedFiles, fileProcessors Processors) error

func SaveReturnCode(repo transfers.Repository, transferID string, ed *ach.EntryDetail) error

type Downloader interface {
	CopyFilesFromRemote(agent upload.Agent) (*downloadedFiles, error)
}

func NewDownloader(logger log.Logger, cfg *config.Storage) Downloader

type FileProcessor interface {
	Type() string

	// Handle processes an ACH file with whatever logic is implemented
	Handle(file *ach.File) error
}

type MockProcessor struct {
	Err error
}

func (pc *MockProcessor) Handle(file *ach.File) error

func (pc *MockProcessor) Type() string

type MockScheduler struct {
	Err error
}

func (s *MockScheduler) Shutdown()

func (s *MockScheduler) Start() error

type PeriodicScheduler struct {
	// contains filtered or unexported fields
}

func (s *PeriodicScheduler) Shutdown()

func (s *PeriodicScheduler) Start() error

type Processors []FileProcessor

func SetupProcessors(pcs ...FileProcessor) Processors

func (pcs Processors) HandleAll(file *ach.File) error

type Scheduler interface {
	Start() error
	Shutdown()
}

func NewPeriodicScheduler(
	cfg *config.Config,
	agent upload.Agent,
	processors Processors,
) Scheduler