Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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)
Click to show internal directories.
Click to hide internal directories.