read_only

Documentation

Index

• Constants
• type Service
  • func New(mirrorNode client.MirrorNode, transferRepository repository.Transfer, ...) *Service
  • func (s Service) FindAssetTransfer(transferID string, asset string, expectedTransfers []model.Hedera, ...)
  • func (s Service) FindNftTransfer(transferID string, tokenID string, serialNum int64, sender string, ...)
  • func (s Service) FindTransfer(transferID string, fetch func() (*mirror_node.Response, error), ...)

Constants

const CryptoTransfer = "CRYPTOTRANSFER"

Types

type Service

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

func New

func New(
	mirrorNode client.MirrorNode,
	transferRepository repository.Transfer,
	pollingInterval time.Duration) *Service

func (Service) FindAssetTransfer

func (s Service) FindAssetTransfer(
	transferID string,
	asset string,
	expectedTransfers []model.Hedera,
	fetch func() (*mirror_node.Response, error),
	save func(transactionID, scheduleID, status string) error)

func (Service) FindNftTransfer

func (s Service) FindNftTransfer(
	transferID string, tokenID string, serialNum int64, sender string, receiver string,
	save func(transactionID, scheduleID, status string) error)

func (Service) FindTransfer

func (s Service) FindTransfer(
	transferID string,
	fetch func() (*mirror_node.Response, error),
	save func(transactionID, scheduleID, status string) error)