watcher

Documentation

Index

• func IndexHasChange(new, old uint64) bool
• func MaxFound(new, old uint64) uint64
• type Watcher

Functions

func IndexHasChange

func IndexHasChange(new, old uint64) bool

IndexHasChange is used to check whether a returned blocking query has an updated index, compared to a tracked value.

func MaxFound

func MaxFound(new, old uint64) uint64

MaxFound is used to determine which value passed is the greatest. This is used to track the most recently found highest index value.

Types

type Watcher

type Watcher interface {

	// Run is used to run the watcher loop. The input channel should be the channel where objects
	// are sent to be acted upon when they are determined to be new.
	Run(updateChan chan interface{})
}

Watcher is the interface to satisfy when creating a watcher to run blocking queries on an API and process updates as required.