response

Documentation

Index

• func Register(logger log.Logger, validateOpts *ach.ValidateOpts, ftpServer *ftp.Server, ...)
• type CorrectionTransformer
  • func (t *CorrectionTransformer) MorphEntry(ctx context.Context, fh ach.FileHeader, bh *ach.BatchHeader, ...) (*ach.EntryDetail, error)
• type EntryTransformer
• type EntryTransformers
  • func (et EntryTransformers) MorphEntry(ctx context.Context, fh ach.FileHeader, bh *ach.BatchHeader, ...) (*ach.EntryDetail, error)
• type FTPFileWriter
  • func (w *FTPFileWriter) Write(path string, r io.Reader, futureDated *time.Duration) error
  • func (w *FTPFileWriter) WriteFile(filepath string, file *ach.File, futureDated *time.Duration) error
• type FTPWatcher
  • func (notify *FTPWatcher) AfterFilePut(conn *ftp.Conn, dstPath string, size int64, err error)
• type FileTransfomer
  • func NewFileTransformer(logger log.Logger, cfg *service.Config, responses []service.Response, ...) *FileTransfomer
  • func (ft *FileTransfomer) Transform(ctx context.Context, file *ach.File) error
• type FileWriter
  • func NewFileWriter(logger log.Logger, cfg service.ServerConfig, ftpServer *ftp.Server) FileWriter
• type ReturnTransformer
  • func (t *ReturnTransformer) MorphEntry(ctx context.Context, fh ach.FileHeader, bh *ach.BatchHeader, ...) (*ach.EntryDetail, error)

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(ctx context.Context, fh ach.FileHeader, bh *ach.BatchHeader, ed *ach.EntryDetail, action *service.Action) (*ach.EntryDetail, error)

type EntryTransformer

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

type EntryTransformers

type EntryTransformers []EntryTransformer

func (EntryTransformers) MorphEntry

func (et EntryTransformers) MorphEntry(ctx context.Context, fh ach.FileHeader, bh *ach.BatchHeader, 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

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(ctx context.Context, 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(ctx context.Context, fh ach.FileHeader, bh *ach.BatchHeader, ed *ach.EntryDetail, action *service.Action) (*ach.EntryDetail, error)