report

Documentation

Index

• type GetPriceByTimeFn
• type TransferReportJob
  • func NewTransferReportJob(database *mongo.Database, pageSize int64, getPriceByTime GetPriceByTimeFn, ...) *TransferReportJob
  • func (j *TransferReportJob) Run(ctx context.Context) error

Types

type GetPriceByTimeFn

type GetPriceByTimeFn func(ctx context.Context, coingeckoID string, day time.Time) (decimal.Decimal, error)

type TransferReportJob

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

func NewTransferReportJob

func NewTransferReportJob(database *mongo.Database, pageSize int64, getPriceByTime GetPriceByTimeFn, outputPath string, tokenProvider *domain.TokenProvider, logger *zap.Logger) *TransferReportJob

NewTransferReportJob creates a new transfer report job.

func (*TransferReportJob) Run

func (j *TransferReportJob) Run(ctx context.Context) error

Run runs the transfer report job.