Versions in this module Expand all Collapse all v1 v1.0.2 Mar 24, 2022 v1.0.1 Mar 13, 2022 Changes in this version + type RepayPlan struct + AccountNo string + CreateTime time.Time + Id int64 + InitDate time.Time + Interest float64 + LoanNo string + Principal float64 + RepayDate time.Time + RepayState string + Term int + UpdateTime time.Time + type RepayPlanHandler struct + func (h *RepayPlanHandler) Process(item interface{}, chunkCtx *gobatch.ChunkContext) (interface{}, gobatch.BatchError) + func (h *RepayPlanHandler) Write(items []interface{}, chunkCtx *gobatch.ChunkContext) gobatch.BatchError + type StatsHandler struct + func (ss *StatsHandler) Handle(execution *gobatch.StepExecution) gobatch.BatchError + type Trade struct + AccountNo string + Amount float64 + InterestRate float64 + Status string + Terms int + TradeNo string + TradeTime time.Time + Type string + type TradeImporter struct + func (p *TradeImporter) Write(items []interface{}, chunkCtx *gobatch.ChunkContext) gobatch.BatchError + type TradeReader struct + func (h *TradeReader) Close(execution *gobatch.StepExecution) gobatch.BatchError + func (h *TradeReader) Open(execution *gobatch.StepExecution) gobatch.BatchError + func (h *TradeReader) ReadItem(key interface{}) (interface{}, error) + func (h *TradeReader) ReadKeys() ([]interface{}, error)