response

package
v0.10.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 20, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Register

func Register(
	logger log.Logger,
	validateOpts *ach.ValidateOpts,
	ftpServer *ftp.Server,
	transformer *FileTransfomer,
)

Types

type CorrectionTransformer

type CorrectionTransformer struct{}

func (*CorrectionTransformer) MorphEntry

func (t *CorrectionTransformer) MorphEntry(fh ach.FileHeader, ed *ach.EntryDetail, action *service.Action) (*ach.EntryDetail, error)

type EntryTransformer

type EntryTransformer interface {
	MorphEntry(fh ach.FileHeader, ed *ach.EntryDetail, action *service.Action) (*ach.EntryDetail, error)
}

type EntryTransformers

type EntryTransformers []EntryTransformer

func (EntryTransformers) MorphEntry

func (et EntryTransformers) MorphEntry(fh ach.FileHeader, ed *ach.EntryDetail, action *service.Action) (*ach.EntryDetail, error)

type FTPFileWriter

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

func (*FTPFileWriter) Write

func (w *FTPFileWriter) Write(path string, r io.Reader, futureDated *time.Duration) error

func (*FTPFileWriter) WriteFile added in v0.3.0

func (w *FTPFileWriter) WriteFile(filepath string, file *ach.File, futureDated *time.Duration) error

type FTPWatcher

type FTPWatcher struct {
	ftp.NullNotifier
	// contains filtered or unexported fields
}

func (*FTPWatcher) AfterFilePut

func (notify *FTPWatcher) AfterFilePut(conn *ftp.Conn, dstPath string, size int64, err error)

type FileTransfomer

type FileTransfomer struct {
	Matcher      match.Matcher
	Entry        EntryTransformers
	Writer       FileWriter
	ValidateOpts *ach.ValidateOpts
	// contains filtered or unexported fields
}

func NewFileTransformer

func NewFileTransformer(logger log.Logger, cfg *service.Config, responses []service.Response, writer FileWriter) *FileTransfomer

func (*FileTransfomer) Transform

func (ft *FileTransfomer) Transform(file *ach.File) error

type FileWriter

type FileWriter interface {
	Write(filepath string, r io.Reader, delay *time.Duration) error
	WriteFile(filename string, file *ach.File, delay *time.Duration) error
}

func NewFileWriter

func NewFileWriter(logger log.Logger, cfg service.ServerConfig, ftpServer *ftp.Server) FileWriter

type ReturnTransformer

type ReturnTransformer struct{}

func (*ReturnTransformer) MorphEntry

func (t *ReturnTransformer) MorphEntry(fh ach.FileHeader, ed *ach.EntryDetail, action *service.Action) (*ach.EntryDetail, error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL