events

Documentation

Index

• func ReadEvent(data []byte, evt interface{}) error
• type Batch
• type CorrectionFile
• type Emitter
  • func NewEmitter(logger log.Logger, cfg *service.EventsConfig) (Emitter, error)
• type Event
  • func (evt Event) Bytes() []byte
  • func (evt Event) MarshalJSON() ([]byte, error)
• type FileUploaded
• type IncomingFile
• type MockEmitter
  • func (*MockEmitter) Send(evt Event) error
• type PrenoteFile
• type ReconciliationFile
• type ReturnFile

Functions

func ReadEvent

func ReadEvent(data []byte, evt interface{}) error

Types

type Batch

type Batch struct {
	Header  *ach.BatchHeader   `json:"batchHeader"`
	Entries []*ach.EntryDetail `json:"entryDetails"`
}

type CorrectionFile

type CorrectionFile struct {
	Filename    string    `json:"filename"`
	File        *ach.File `json:"file"`
	Corrections []Batch   `json:"corrections"`
}

type Emitter

type Emitter interface {
	Send(evt Event) error
}

func NewEmitter

func NewEmitter(logger log.Logger, cfg *service.EventsConfig) (Emitter, error)

type Event

type Event struct {
	Event interface{} `json:"event"`
	Type  string      `json:"type"`
}

func (Event) Bytes

func (evt Event) Bytes() []byte

func (Event) MarshalJSON

func (evt Event) MarshalJSON() ([]byte, error)

type FileUploaded

type FileUploaded struct {
	FileID     string    `json:"fileID"`
	ShardKey   string    `json:"shardKey"`
	Filename   string    `json:"filename"`
	UploadedAt time.Time `json:"uploadedAt"`
}

type IncomingFile

type IncomingFile struct {
	Filename string    `json:"filename"`
	File     *ach.File `json:"file"`
}

type MockEmitter

type MockEmitter struct{}

func (*MockEmitter) Send

func (*MockEmitter) Send(evt Event) error

type PrenoteFile

type PrenoteFile struct {
	Filename string    `json:"filename"`
	File     *ach.File `json:"file"`
	Batches  []Batch   `json:"batches"`
}

type ReconciliationFile

type ReconciliationFile struct {
	Filename        string    `json:"filename"`
	File            *ach.File `json:"file"`
	Reconciliations []Batch   `json:"returns"`
}

type ReturnFile

type ReturnFile struct {
	Filename string    `json:"filename"`
	File     *ach.File `json:"file"`
	Returns  []Batch   `json:"returns"`
}