import "istio.io/istio/galley/pkg/config/processing/snapshotter"
analyzingdistributor.go distributor.go snapshot.go snapshotoptions.go snapshotter.go statusupdater.go
type AnalyzingDistributor struct {
// contains filtered or unexported fields
}AnalyzingDistributor is an snapshotter. Distributor implementation that will perform analysis on a snapshot before publishing. It will update the CRD status with the analysis results.
func NewAnalyzingDistributor(s AnalyzingDistributorSettings) *AnalyzingDistributor
NewAnalyzingDistributor returns a new instance of AnalyzingDistributor.
func (d *AnalyzingDistributor) Distribute(name string, s *Snapshot)
Distribute implements snapshotter.Distributor
type AnalyzingDistributorSettings struct {
// The status updater to route diagnostic messages to
StatusUpdater StatusUpdater
// The top-level combined analyzer that will perform the analysis
Analyzer *analysis.CombinedAnalyzer
// The downstream distributor to call, after the analysis is done.
Distributor Distributor
// The snapshots that will get analyzed.
AnalysisSnapshots []string
// The snapshot that will trigger the analysis.
// TODO(https://github.com/istio/istio/issues/17543): This should be eventually replaced by the AnalysisSnapshots
// and a matching debounce mechanism.
TriggerSnapshot string
// An optional hook that will be called whenever a collection is accessed. Useful for testing.
CollectionReporter CollectionReporterFn
// Namespaces that should be analyzed
AnalysisNamespaces []string
}AnalyzingDistributorSettings are settings for an AnalyzingDistributor
type CollectionReporterFn func(collection.Name)
CollectionReporterFn is a hook function called whenever a collection is accessed through the AnalyzingDistributor's context
Distributor interface abstracts the snapshotImpl distribution mechanism. Typically, this is implemented by the MCP layer.
HandlerFn handles generated snapshots
type InMemoryDistributor struct {
// contains filtered or unexported fields
}InMemoryDistributor is an in-memory Distributor implementation.
func NewInMemoryDistributor() *InMemoryDistributor
NewInMemoryDistributor returns a new instance of InMemoryDistributor
func (d *InMemoryDistributor) Distribute(name string, s *Snapshot)
Distribute is an implementation of Distributor.Distribute
func (d *InMemoryDistributor) GetSnapshot(name string) snapshot.Snapshot
GetSnapshot get the snapshotImpl of the specified name
func (d *InMemoryDistributor) NumSnapshots() int
NumSnapshots returns the current number of snapshots.
type InMemoryStatusUpdater struct {
// contains filtered or unexported fields
}InMemoryStatusUpdater is an in-memory implementation of StatusUpdater
func (u *InMemoryStatusUpdater) Get() diag.Messages
Get returns the current set of captured diag.Messages
func (u *InMemoryStatusUpdater) Update(m diag.Messages)
Update implements StatusUpdater
func (u *InMemoryStatusUpdater) WaitForReport(cancelCh chan struct{}) bool
WaitForReport blocks until a report is available. Returns true if a report is available, false if cancelCh was closed.
type MCPDistributor struct {
// contains filtered or unexported fields
}MCPDistributor distributes a snapshot to the MCP layer.
func NewMCPDistributor(c *snapshot.Cache) *MCPDistributor
NewMCPDistributor returns a new instance of MCPDistributor
func (d *MCPDistributor) Distribute(name string, s *Snapshot)
Distribute is an implementation of SetSnapshot
type Snapshot struct {
// contains filtered or unexported fields
}Snapshot is an implementation of MCP's snapshot.Snapshot interface. It also exposes additional query methods for analysis purposes.
Collections implements snapshotImpl.Snapshot
Find the resource with the given name and collection.
func (s *Snapshot) ForEach(col collection.Name, fn analysis.IteratorFn)
ForEach iterates all resources in a given collection.
Resources implements snapshotImpl.Snapshot
String implements io.Stringer
Version implements snapshotImpl.Snapshot
type SnapshotOptions struct {
Distributor Distributor
// The group name for the snapshotImpl.
Group string
// The publishing strategy for the snapshotImpl.
Strategy strategy.Instance
// The set of collections to Snapshot.
Collections []collection.Name
}SnapshotOptions is settings for a single snapshotImpl target.
type Snapshotter struct {
// contains filtered or unexported fields
}Snapshotter is a processor that handles input events and creates snapshotImpl collections.
func NewSnapshotter(xforms []event.Transformer, settings []SnapshotOptions) (*Snapshotter, error)
NewSnapshotter returns a new Snapshotter.
func (s *Snapshotter) Handle(e event.Event)
Handle implements Processor
func (s *Snapshotter) Start()
Start implements Processor
func (s *Snapshotter) Stop()
Stop implements Processor
StatusUpdater updates resource statuses, based on the given diagnostic messages.
| Path | Synopsis |
|---|---|
| strategy |
Package snapshotter imports 17 packages (graph) and is imported by 5 packages. Updated 2019-10-20. Refresh now. Tools for package owners.