Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectionInfoTracker ¶
type ConnectionInfoTracker interface {
ConnectionInfo(streamID core_xds.StreamID) xds_context.ConnectionInfo
}
type DataplaneMetadataTracker ¶
type DataplaneMetadataTracker interface {
Metadata(streamID core_xds.StreamID) *core_xds.DataplaneMetadata
}
type DataplaneProxyBuilder ¶
type DataplaneProxyBuilder struct { CachingResManager manager.ReadOnlyResourceManager NonCachingResManager manager.ReadOnlyResourceManager LookupIP lookup.LookupIPFunc DataSourceLoader datasource.Loader MetadataTracker DataplaneMetadataTracker PermissionMatcher permissions.TrafficPermissionsMatcher LogsMatcher logs.TrafficLogsMatcher FaultInjectionMatcher faultinjections.FaultInjectionMatcher RateLimitMatcher ratelimits.RateLimitMatcher Zone string // contains filtered or unexported fields }
type DataplaneWatchdog ¶
type DataplaneWatchdog struct { DataplaneWatchdogDependencies // contains filtered or unexported fields }
func NewDataplaneWatchdog ¶
func NewDataplaneWatchdog(deps DataplaneWatchdogDependencies, proxyId *core_xds.ProxyId, streamId int64) *DataplaneWatchdog
func (*DataplaneWatchdog) Cleanup ¶
func (d *DataplaneWatchdog) Cleanup() error
func (*DataplaneWatchdog) Sync ¶
func (d *DataplaneWatchdog) Sync() error
type DataplaneWatchdogDependencies ¶
type DataplaneWatchdogDependencies struct {
// contains filtered or unexported fields
}
type DataplaneWatchdogFactory ¶
type DataplaneWatchdogFactory interface {
New(proxyId *core_xds.ProxyId, streamId int64) util_watchdog.Watchdog
}
DataplaneWatchdogFactory returns a Watchdog that creates a new XdsContext and Proxy and executes SnapshotReconciler if there is any change
func DefaultDataplaneWatchdogFactory ¶
func DefaultDataplaneWatchdogFactory( rt core_runtime.Runtime, metadataTracker DataplaneMetadataTracker, connectionInfoTracker ConnectionInfoTracker, dataplaneReconciler SnapshotReconciler, ingressReconciler SnapshotReconciler, xdsMetrics *xds_metrics.Metrics, meshSnapshotCache *mesh.Cache, envoyCpCtx *xds_context.ControlPlaneContext, apiVersion envoy.APIVersion, ) (DataplaneWatchdogFactory, error)
func NewDataplaneWatchdogFactory ¶
func NewDataplaneWatchdogFactory( xdsSyncMetrics *xds_metrics.Metrics, refreshInterval time.Duration, deps DataplaneWatchdogDependencies, ) (DataplaneWatchdogFactory, error)
type IngressProxyBuilder ¶
type IngressProxyBuilder struct { ResManager manager.ResourceManager ReadOnlyResManager manager.ReadOnlyResourceManager LookupIP lookup.LookupIPFunc MetadataTracker DataplaneMetadataTracker // contains filtered or unexported fields }
type SnapshotReconciler ¶
type SnapshotReconciler interface { Reconcile(ctx xds_context.Context, proxy *core_xds.Proxy) error Clear(proxyId *core_xds.ProxyId) error }
SnapshotReconciler reconciles Envoy XDS configuration (Snapshot) by executing all generators (pkg/xds/generator)
Click to show internal directories.
Click to hide internal directories.