message

Documentation

Index

• type Watcher
  • func NewWatcher(client client.MirrorNode, topicID string, repository repository.Status, ...) *Watcher
  • func (cmw Watcher) Watch(q *pair.Queue)

Types

type Watcher

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

func NewWatcher

func NewWatcher(client client.MirrorNode, topicID string, repository repository.Status, pollingInterval time.Duration, maxRetries int, startTimestamp int64) *Watcher

func (Watcher) Watch

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