consensusmessage

Documentation

Index

• type ConsensusMessageHandler
  • func NewConsensusMessageHandler(configuration config.ConsensusMessageHandler, bridgeContractAddress string, ...) *ConsensusMessageHandler
  • func (cmh ConsensusMessageHandler) Handle(payload []byte)
  • func (cmh ConsensusMessageHandler) Recover(queue *queue.Queue)

Types

type ConsensusMessageHandler

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

func NewConsensusMessageHandler

func NewConsensusMessageHandler(
	configuration config.ConsensusMessageHandler,
	bridgeContractAddress string,
	messageRepository repositories.MessageRepository,
	transactionRepository repositories.TransactionRepository,
	ethereumClient *ethereum.EthereumClient,
	hederaNodeClient *hederaClient.HederaNodeClient,
	scheduler *scheduler.Scheduler,
	signer *eth.Signer,
) *ConsensusMessageHandler

func (ConsensusMessageHandler) Handle

func (cmh ConsensusMessageHandler) Handle(payload []byte)

func (ConsensusMessageHandler) Recover

func (cmh ConsensusMessageHandler) Recover(queue *queue.Queue)