Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Aggregator ¶
type Aggregator struct {
// contains filtered or unexported fields
}
Aggregator combines multiple watchers into a single view. It wraps introspection.AggregateWatchers to provide a simple wrapper.
func (*Aggregator) AddWatcher ¶
func (a *Aggregator) AddWatcher(w interface{})
AddWatcher registers a watcher (must implement Watch method).
func (*Aggregator) Watch ¶
func (a *Aggregator) Watch(ctx context.Context) <-chan introspection.StateSnapshot
Watch returns the aggregated state channel.
Source Files
Click to show internal directories.
Click to hide internal directories.