worker

Documentation

Index

• type BillTask
  • func NewBillTask(bill *model.Bill, statements map[uint32]int64) *BillTask
• type BlockchainWorker
  • func MustNewBlockchainWorkerFromViper(provider *blockchain.Provider, sqliteStore *sqlite.SqliteStore, ...) *BlockchainWorker
  • func (worker *BlockchainWorker) Run(ctx context.Context)

Types

type BillTask

type BillTask struct {
	*model.Bill
	Statements  map[uint32]int64
	TryTimes    uint
	CreatedAt   time.Time
	SubmittedAt time.Time
}

func NewBillTask

func NewBillTask(bill *model.Bill, statements map[uint32]int64) *BillTask

type BlockchainWorker

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

func MustNewBlockchainWorkerFromViper

func MustNewBlockchainWorkerFromViper(
	provider *blockchain.Provider, sqliteStore *sqlite.SqliteStore,
	billSvc *service.BillingService, chainSvc *service.BlockchainService,
) *BlockchainWorker

func (*BlockchainWorker) Run

func (worker *BlockchainWorker) Run(ctx context.Context)