consensusmessage

Documentation

Index

• type ConsensusTopicWatcher
  • func NewConsensusTopicWatcher(nodeClient *hederaClient.HederaNodeClient, ...) *ConsensusTopicWatcher
  • func (ctw ConsensusTopicWatcher) Watch(q *queue.Queue)

Types

type ConsensusTopicWatcher

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

func NewConsensusTopicWatcher

func NewConsensusTopicWatcher(nodeClient *hederaClient.HederaNodeClient, mirrorClient *hederaClient.HederaMirrorClient, topicID hedera.TopicID, repository repositories.StatusRepository, maxRetries int, startTimestamp int64) *ConsensusTopicWatcher

func (ConsensusTopicWatcher) Watch

func (ctw ConsensusTopicWatcher) Watch(q *queue.Queue)