import "istio.io/istio/galley/pkg/config/processing"
processor.go runtime.go session.go
type ProcessorOptions struct { MeshConfig *v1alpha1.MeshConfig DomainSuffix string }
ProcessorOptions are options that are passed to event.Processors during startup.
type ProcessorProvider func(o ProcessorOptions) event.Processor
ProcessorProvider returns a new Processor instance for the given ProcessorOptions.
type Runtime struct {
// contains filtered or unexported fields
}
Runtime is the top-level config processing machinery. Through runtime options, it takes in a set of Sources and a Processor. Once started, Runtime will go through a startup phase, where it waits for MeshConfig to arrive before starting the Processor. If, the Runtime receives any event.RESET events, or if there is a change to the MeshConfig, then the Runtime will stop the processor and sources and will restart them again.
Internally, Runtime uses the session type to implement this stateful behavior. The session handles state transitions and is responsible for starting/stopping the Sources, Processors, in the correct order.
func NewRuntime(o RuntimeOptions) *Runtime
NewRuntime returns a new instance of a processing.Runtime.
Start the Runtime
Stop the Runtime
type RuntimeOptions struct { Source event.Source ProcessorProvider ProcessorProvider DomainSuffix string }
RuntimeOptions is options for Runtime
func (o RuntimeOptions) Clone() RuntimeOptions
Clone returns a cloned copy of the RuntimeOptions.
Path | Synopsis |
---|---|
snapshotter | |
snapshotter/strategy | |
transformer |
Package processing imports 9 packages (graph) and is imported by 4 packages. Updated 2020-11-12. Refresh now. Tools for package owners.