waiting

package
v1.0.4 Latest Latest
Warning

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

Go to latest
Published: Apr 28, 2019 License: MIT Imports: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BlockFilter

type BlockFilter interface {
	HandleBlock(block *common.Block)
}

type MultiWaiting

type MultiWaiting struct {
	WaitArray []WaitInterface
	// contains filtered or unexported fields
}

func NewMultiWaiting

func NewMultiWaiting(args ...WaitInterface) *MultiWaiting

func (*MultiWaiting) Waiting

func (mw *MultiWaiting) Waiting() int

type TransactionFilter

type TransactionFilter interface {
	HandleTx(transaction *common.RPCTransaction)
}

type TxHandle

type TxHandle struct {
	Filter []TransactionFilter
}

func (*TxHandle) HandleBlock

func (Tf *TxHandle) HandleBlock(block *common.Block)

type WaitBlockHeight

type WaitBlockHeight struct {
	Web3Waiting

	Result uint64
	// contains filtered or unexported fields
}

func NewWaitBlockHeight

func NewWaitBlockHeight(web *manager.Manager, height uint64) *WaitBlockHeight

func (*WaitBlockHeight) Waiting

func (w *WaitBlockHeight) Waiting()

type WaitInterface

type WaitInterface interface {
	Done() chan struct{}
	Quit()
	Waiting()
}

type WaitMinerNumChange

type WaitMinerNumChange struct {
	Web3Waiting
	Number uint64
	Result uint64
}

func NewWaitMinerNumChange

func NewWaitMinerNumChange(web *manager.Manager, number uint64) *WaitMinerNumChange

func (*WaitMinerNumChange) Waiting

func (w *WaitMinerNumChange) Waiting()

type WaitTime

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

func NewWaitTime

func NewWaitTime(wt time.Duration) *WaitTime

func (*WaitTime) Done

func (w *WaitTime) Done() chan struct{}

func (*WaitTime) Quit

func (w *WaitTime) Quit()

func (*WaitTime) Waiting

func (w *WaitTime) Waiting()

type WaitTxReceipt

type WaitTxReceipt struct {
	Web3Waiting

	Receipt *dto.TransactionReceipt
	// contains filtered or unexported fields
}

func NewWaitTxReceipt

func NewWaitTxReceipt(web *manager.Manager, txHash string) *WaitTxReceipt

func (*WaitTxReceipt) Waiting

func (w *WaitTxReceipt) Waiting()

type WaitTxReceiptAry

type WaitTxReceiptAry struct {
	Web3Waiting
	Receipts map[string]*dto.TransactionReceipt
	// contains filtered or unexported fields
}

func NewWaitTxReceiptAry

func NewWaitTxReceiptAry(web *manager.Manager, txHashAry []string) *WaitTxReceiptAry

func (*WaitTxReceiptAry) Waiting

func (wt *WaitTxReceiptAry) Waiting()

type WaitVManStrDisappear

type WaitVManStrDisappear struct {
	Web3Waiting
	Manstr string
	IsHere bool
}

func NewWaitVManStrDisappear

func NewWaitVManStrDisappear(web *manager.Manager, manstr string) *WaitVManStrDisappear

func (*WaitVManStrDisappear) Waiting

func (w *WaitVManStrDisappear) Waiting()

type WaitingBlock

type WaitingBlock struct {
	Web3Waiting

	Filter []BlockFilter
	// contains filtered or unexported fields
}

func (*WaitingBlock) Waiting

func (w *WaitingBlock) Waiting()

type Web3Waiting

type Web3Waiting struct {
	Web3 *manager.Manager
	// contains filtered or unexported fields
}

func (*Web3Waiting) Done

func (w *Web3Waiting) Done() chan struct{}

func (*Web3Waiting) Quit

func (w *Web3Waiting) Quit()

func (*Web3Waiting) WaitingFn

func (w *Web3Waiting) WaitingFn(fn func())

Jump to

Keyboard shortcuts

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