cryptotransfer

Documentation

Index

• type Watcher
  • func NewWatcher(transfers service.Transfers, client client.MirrorNode, accountID string, ...) *Watcher
  • func (ctw Watcher) Watch(q *pair.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,
	maxRetries int,
	startTimestamp int64,
	contractService service.Contracts,
) *Watcher

func (Watcher) Watch

func (ctw Watcher) Watch(q *pair.Queue)