recovery

Documentation

Index

• type Recovery
  • func NewProcess(c config.Hedera, transfers service.Transfers, messages service.Messages, ...) (*Recovery, error)
  • func (r Recovery) ComputeIntervals() (transfersFrom int64, messagesFrom int64, to int64, err error)
  • func (r Recovery) Start(transfersFrom, messagesFrom, to int64) error

Types

type Recovery

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

func NewProcess

func NewProcess(
	c config.Hedera,
	transfers service.Transfers,
	messages service.Messages,
	contracts service.Contracts,
	statusTransferRepo repository.Status,
	statusMessagesRepo repository.Status,
	transferRepo repository.Transfer,
	mirrorClient client.MirrorNode,
	nodeClient client.HederaNode,
) (*Recovery, error)

func (Recovery) ComputeIntervals

func (r Recovery) ComputeIntervals() (transfersFrom int64, messagesFrom int64, to int64, err error)

ComputeIntervals calculates the `from` and `to` unix nano timestamps to be used for the recovery process for both the transfers and messages recovery

func (Recovery) Start

func (r Recovery) Start(transfersFrom, messagesFrom, to int64) error

Start starts the main recovery process