cryptotransfer

Documentation

Index

• type Watcher
  • func NewWatcher(transfers service.Transfers, client client.MirrorNode, accountID string, ...) *Watcher
  • func (ctw Watcher) Watch(q qi.Queue)

Types

type Watcher

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

func NewWatcher

func NewWatcher(
	transfers service.Transfers,
	client client.MirrorNode,
	accountID string,
	pollingInterval time.Duration,
	repository repository.Status,
	startTimestamp int64,
	contractServices map[uint64]service.Contracts,
	assetsService service.Assets,
	validator bool,
	prometheusService service.Prometheus,
	pricingService service.Pricing,
	blacklistedAccounts []string,
) *Watcher

func (Watcher) Watch

func (ctw Watcher) Watch(q qi.Queue)