upload

Documentation

Index

• func RegisterAdminServer(svc *admin.Server)
• func RenderACHFilename(raw string, data FilenameData) (string, error)
• type Agent
  • func New(logger log.Logger, cfg service.UploadAgents, id string) (Agent, error)
• type CreatedAgents
• type FTPTransferAgent
  • func (agent *FTPTransferAgent) Close() error
  • func (agent *FTPTransferAgent) Delete(path string) error
  • func (agent *FTPTransferAgent) GetInboundFiles() ([]File, error)
  • func (agent *FTPTransferAgent) GetReconciliationFiles() ([]File, error)
  • func (agent *FTPTransferAgent) GetReturnFiles() ([]File, error)
  • func (agent *FTPTransferAgent) Hostname() string
  • func (agent *FTPTransferAgent) ID() string
  • func (agent *FTPTransferAgent) InboundPath() string
  • func (agent *FTPTransferAgent) OutboundPath() string
  • func (agent *FTPTransferAgent) Ping() error
  • func (agent *FTPTransferAgent) ReconciliationPath() string
  • func (agent *FTPTransferAgent) ReturnPath() string
  • func (agent *FTPTransferAgent) UploadFile(f File) error
• type File
  • func (f File) Close() error
• type FilenameData
• type MockAgent
  • func (a *MockAgent) Close() error
  • func (a *MockAgent) Delete(path string) error
  • func (a *MockAgent) GetInboundFiles() ([]File, error)
  • func (a *MockAgent) GetReconciliationFiles() ([]File, error)
  • func (a *MockAgent) GetReturnFiles() ([]File, error)
  • func (a *MockAgent) Hostname() string
  • func (a *MockAgent) ID() string
  • func (a *MockAgent) InboundPath() string
  • func (a *MockAgent) OutboundPath() string
  • func (a *MockAgent) Ping() error
  • func (a *MockAgent) ReconciliationPath() string
  • func (a *MockAgent) ReturnPath() string
  • func (a *MockAgent) UploadFile(f File) error
• type RetryAgent
  • func (rt *RetryAgent) Close() error
  • func (rt *RetryAgent) Delete(path string) error
  • func (rt *RetryAgent) GetInboundFiles() ([]File, error)
  • func (rt *RetryAgent) GetReconciliationFiles() ([]File, error)
  • func (rt *RetryAgent) GetReturnFiles() ([]File, error)
  • func (rt *RetryAgent) Hostname() string
  • func (rt *RetryAgent) ID() string
  • func (rt *RetryAgent) InboundPath() string
  • func (rt *RetryAgent) OutboundPath() string
  • func (rt *RetryAgent) Ping() error
  • func (rt *RetryAgent) ReconciliationPath() string
  • func (rt *RetryAgent) ReturnPath() string
  • func (rt *RetryAgent) String() string
  • func (rt *RetryAgent) UploadFile(f File) error
• type SFTPTransferAgent
  • func (agent *SFTPTransferAgent) Close() error
  • func (agent *SFTPTransferAgent) Delete(path string) error
  • func (agent *SFTPTransferAgent) GetInboundFiles() ([]File, error)
  • func (agent *SFTPTransferAgent) GetReconciliationFiles() ([]File, error)
  • func (agent *SFTPTransferAgent) GetReturnFiles() ([]File, error)
  • func (agent *SFTPTransferAgent) Hostname() string
  • func (agent *SFTPTransferAgent) ID() string
  • func (agent *SFTPTransferAgent) InboundPath() string
  • func (agent *SFTPTransferAgent) OutboundPath() string
  • func (agent *SFTPTransferAgent) Ping() error
  • func (agent *SFTPTransferAgent) ReconciliationPath() string
  • func (agent *SFTPTransferAgent) ReturnPath() string
  • func (agent *SFTPTransferAgent) UploadFile(f File) error

Functions

func RegisterAdminServer

func RegisterAdminServer(svc *admin.Server)

func RenderACHFilename

func RenderACHFilename(raw string, data FilenameData) (string, error)

Types

type Agent

type Agent interface {
	ID() string

	GetInboundFiles() ([]File, error)
	GetReconciliationFiles() ([]File, error)
	GetReturnFiles() ([]File, error)
	UploadFile(f File) error
	Delete(path string) error

	InboundPath() string
	OutboundPath() string
	ReconciliationPath() string
	ReturnPath() string
	Hostname() string

	Ping() error
	Close() error
}

Agent represents an interface for uploading and retrieving ACH files from a remote service.

func New

func New(logger log.Logger, cfg service.UploadAgents, id string) (Agent, error)

type CreatedAgents

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

type FTPTransferAgent

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

FTPTransferAgent is an FTP implementation of a Agent

func (*FTPTransferAgent) Close

func (agent *FTPTransferAgent) Close() error

func (*FTPTransferAgent) Delete

func (agent *FTPTransferAgent) Delete(path string) error

func (*FTPTransferAgent) GetInboundFiles

func (agent *FTPTransferAgent) GetInboundFiles() ([]File, error)

func (*FTPTransferAgent) GetReconciliationFiles

func (agent *FTPTransferAgent) GetReconciliationFiles() ([]File, error)

func (*FTPTransferAgent) GetReturnFiles

func (agent *FTPTransferAgent) GetReturnFiles() ([]File, error)

func (*FTPTransferAgent) Hostname

func (agent *FTPTransferAgent) Hostname() string

func (*FTPTransferAgent) ID

func (agent *FTPTransferAgent) ID() string

func (*FTPTransferAgent) InboundPath

func (agent *FTPTransferAgent) InboundPath() string

func (*FTPTransferAgent) OutboundPath

func (agent *FTPTransferAgent) OutboundPath() string

func (*FTPTransferAgent) Ping

func (agent *FTPTransferAgent) Ping() error

func (*FTPTransferAgent) ReconciliationPath

func (agent *FTPTransferAgent) ReconciliationPath() string

func (*FTPTransferAgent) ReturnPath

func (agent *FTPTransferAgent) ReturnPath() string

func (*FTPTransferAgent) UploadFile

func (agent *FTPTransferAgent) UploadFile(f File) error

uploadFile saves the content of File at the given filename in the OutboundPath directory

The File's contents will always be closed

type File

type File struct {
	Filename string
	Contents io.ReadCloser
}

func (File) Close

func (f File) Close() error

type FilenameData

type FilenameData struct {
	RoutingNumber string

	// GPG is true if the file has been encrypted with GPG
	GPG bool

	// Index is the Nth file uploaded for a shard during a cutoff time
	Index int

	// ShardName is the name of a shard uploading this file
	ShardName string
}

type MockAgent

type MockAgent struct {
	InboundFiles        []File
	ReconciliationFiles []File
	ReturnFiles         []File
	UploadedFile        *File  // non-nil on file upload
	DeletedFile         string // filepath of last deleted file

	Err error
	// contains filtered or unexported fields
}

func (*MockAgent) Close

func (a *MockAgent) Close() error

func (*MockAgent) Delete

func (a *MockAgent) Delete(path string) error

func (*MockAgent) GetInboundFiles

func (a *MockAgent) GetInboundFiles() ([]File, error)

func (*MockAgent) GetReconciliationFiles

func (a *MockAgent) GetReconciliationFiles() ([]File, error)

func (*MockAgent) GetReturnFiles

func (a *MockAgent) GetReturnFiles() ([]File, error)

func (*MockAgent) Hostname

func (a *MockAgent) Hostname() string

func (*MockAgent) ID

func (a *MockAgent) ID() string

func (*MockAgent) InboundPath

func (a *MockAgent) InboundPath() string

func (*MockAgent) OutboundPath

func (a *MockAgent) OutboundPath() string

func (*MockAgent) Ping

func (a *MockAgent) Ping() error

func (*MockAgent) ReconciliationPath

func (a *MockAgent) ReconciliationPath() string

func (*MockAgent) ReturnPath

func (a *MockAgent) ReturnPath() string

func (*MockAgent) UploadFile

func (a *MockAgent) UploadFile(f File) error

type RetryAgent

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

func (*RetryAgent) Close

func (rt *RetryAgent) Close() error

func (*RetryAgent) Delete

func (rt *RetryAgent) Delete(path string) error

func (*RetryAgent) GetInboundFiles

func (rt *RetryAgent) GetInboundFiles() ([]File, error)

Network'd calls

func (*RetryAgent) GetReconciliationFiles

func (rt *RetryAgent) GetReconciliationFiles() ([]File, error)

func (*RetryAgent) GetReturnFiles

func (rt *RetryAgent) GetReturnFiles() ([]File, error)

func (*RetryAgent) Hostname

func (rt *RetryAgent) Hostname() string

func (*RetryAgent) ID

func (rt *RetryAgent) ID() string

func (*RetryAgent) InboundPath

func (rt *RetryAgent) InboundPath() string

Non-Network calls, so pass-through

func (*RetryAgent) OutboundPath

func (rt *RetryAgent) OutboundPath() string

func (*RetryAgent) Ping

func (rt *RetryAgent) Ping() error

func (*RetryAgent) ReconciliationPath

func (rt *RetryAgent) ReconciliationPath() string

func (*RetryAgent) ReturnPath

func (rt *RetryAgent) ReturnPath() string

func (*RetryAgent) String

func (rt *RetryAgent) String() string

func (*RetryAgent) UploadFile

func (rt *RetryAgent) UploadFile(f File) error

type SFTPTransferAgent

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

func (*SFTPTransferAgent) Close

func (agent *SFTPTransferAgent) Close() error

func (*SFTPTransferAgent) Delete

func (agent *SFTPTransferAgent) Delete(path string) error

func (*SFTPTransferAgent) GetInboundFiles

func (agent *SFTPTransferAgent) GetInboundFiles() ([]File, error)

func (*SFTPTransferAgent) GetReconciliationFiles

func (agent *SFTPTransferAgent) GetReconciliationFiles() ([]File, error)

func (*SFTPTransferAgent) GetReturnFiles

func (agent *SFTPTransferAgent) GetReturnFiles() ([]File, error)

func (*SFTPTransferAgent) Hostname

func (agent *SFTPTransferAgent) Hostname() string

func (*SFTPTransferAgent) ID

func (agent *SFTPTransferAgent) ID() string

func (*SFTPTransferAgent) InboundPath

func (agent *SFTPTransferAgent) InboundPath() string

func (*SFTPTransferAgent) OutboundPath

func (agent *SFTPTransferAgent) OutboundPath() string

func (*SFTPTransferAgent) Ping

func (agent *SFTPTransferAgent) Ping() error

func (*SFTPTransferAgent) ReconciliationPath

func (agent *SFTPTransferAgent) ReconciliationPath() string

func (*SFTPTransferAgent) ReturnPath

func (agent *SFTPTransferAgent) ReturnPath() string

func (*SFTPTransferAgent) UploadFile

func (agent *SFTPTransferAgent) UploadFile(f File) error

uploadFile saves the content of File at the given filename in the OutboundPath directory

The File's contents will always be closed