34 lines
820 B
Go
34 lines
820 B
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.
|
||
|
|
type Item struct {
|
||
|
|
Alloc 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{}
|
||
|
|
|
||
|
|
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{}{}
|
||
|
|
}
|