open-nomad/nomad/watch/watch.go

package watch

// The watch package provides a means of describing a watch for a blocking
// query. It is exported so it may be shared between Nomad's RPC layer and
// the underlying state store.

// Item describes the scope of a watch. It is used to provide a uniform
// input for subscribe/unsubscribe and notification firing. Specifying
// multiple fields does not place a watch on multiple items. Each Item
// describes exactly one scoped watch.
type Item struct {
	Alloc     string
	AllocEval string
	AllocJob  string
	AllocNode string
	Eval      string
	Job       string
	Node      string
	Table     string
}

// Items is a helper used to construct a set of watchItems. It deduplicates
// the items as they are added using map keys.
type Items map[Item]struct{}

// NewItems creates a new Items set and adds the given items.
func NewItems(items ...Item) Items {
	wi := make(Items)
	for _, item := range items {
		wi.Add(item)
	}
	return wi
}

// Add adds an item to the watch set.
func (wi Items) Add(i Item) {
	wi[i] = struct{}{}
}