example2

package
v1.0.1 Latest Latest
Warning

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

Go to latest
Published: Mar 13, 2022 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type RepayPlan

type RepayPlan struct {
	Id         int64
	AccountNo  string
	LoanNo     string
	Term       int
	Principal  float64
	Interest   float64
	InitDate   time.Time
	RepayDate  time.Time
	RepayState string
	CreateTime time.Time
	UpdateTime time.Time
}

type RepayPlanHandler

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

func (*RepayPlanHandler) Process

func (h *RepayPlanHandler) Process(item interface{}, chunkCtx *gobatch.ChunkContext) (interface{}, gobatch.BatchError)

func (*RepayPlanHandler) Write

func (h *RepayPlanHandler) Write(items []interface{}, chunkCtx *gobatch.ChunkContext) gobatch.BatchError

type StatsHandler

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

func (*StatsHandler) Handle

func (ss *StatsHandler) Handle(execution *gobatch.StepExecution) gobatch.BatchError

type Trade

type Trade struct {
	TradeNo      string    `order:"0" header:"trade_no"`
	AccountNo    string    `order:"1" header:"account_no"`
	Type         string    `order:"2" header:"type"`
	Amount       float64   `order:"3" header:"amount"`
	Terms        int       `order:"4" header:"terms"`
	InterestRate float64   `order:"5" header:"interest_rate"`
	TradeTime    time.Time `order:"7" header:"trade_time"`
	Status       string    `order:"6" header:"status"`
}

type TradeImporter

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

func (*TradeImporter) Write

func (p *TradeImporter) Write(items []interface{}, chunkCtx *gobatch.ChunkContext) gobatch.BatchError

type TradeReader

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

func (*TradeReader) Close

func (h *TradeReader) Close(execution *gobatch.StepExecution) gobatch.BatchError

func (*TradeReader) Open

func (h *TradeReader) Open(execution *gobatch.StepExecution) gobatch.BatchError

func (*TradeReader) ReadItem

func (h *TradeReader) ReadItem(key interface{}) (interface{}, error)

func (*TradeReader) ReadKeys

func (h *TradeReader) ReadKeys() ([]interface{}, error)

Jump to

Keyboard shortcuts

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