Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectionInfoTracker ¶
type ConnectionInfoTracker interface {
ConnectionInfo(dpKey core_model.ResourceKey) *xds_context.ConnectionInfo
}
type DataplaneMetadataTracker ¶
type DataplaneMetadataTracker interface {
Metadata(dpKey core_model.ResourceKey) *core_xds.DataplaneMetadata
}
type DataplaneProxyBuilder ¶
type DataplaneProxyBuilder struct { MetadataTracker DataplaneMetadataTracker Zone string APIVersion envoy.APIVersion }
func DefaultDataplaneProxyBuilder ¶ added in v1.8.1
func DefaultDataplaneProxyBuilder( config kuma_cp.Config, metadataTracker DataplaneMetadataTracker, apiVersion envoy.APIVersion, ) *DataplaneProxyBuilder
func (*DataplaneProxyBuilder) Build ¶ added in v1.8.1
func (p *DataplaneProxyBuilder) Build(key core_model.ResourceKey, meshContext xds_context.MeshContext) (*core_xds.Proxy, error)
type DataplaneWatchdog ¶
type DataplaneWatchdog struct { DataplaneWatchdogDependencies // contains filtered or unexported fields }
func NewDataplaneWatchdog ¶
func NewDataplaneWatchdog(deps DataplaneWatchdogDependencies, dpKey core_model.ResourceKey) *DataplaneWatchdog
func (*DataplaneWatchdog) Cleanup ¶
func (d *DataplaneWatchdog) Cleanup() error
type DataplaneWatchdogDependencies ¶
type DataplaneWatchdogDependencies struct {
// contains filtered or unexported fields
}
type DataplaneWatchdogFactory ¶
type DataplaneWatchdogFactory interface {
New(dpKey core_model.ResourceKey) 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, dataplaneReconciler SnapshotReconciler, ingressReconciler SnapshotReconciler, egressReconciler 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 EgressProxyBuilder ¶ added in v1.8.1
type EgressProxyBuilder struct { ResManager manager.ResourceManager ReadOnlyResManager manager.ReadOnlyResourceManager LookupIP lookup.LookupIPFunc MetadataTracker DataplaneMetadataTracker // contains filtered or unexported fields }
func DefaultEgressProxyBuilder ¶ added in v1.8.1
func DefaultEgressProxyBuilder( ctx context.Context, rt core_runtime.Runtime, metadataTracker DataplaneMetadataTracker, meshCache *mesh.Cache, apiVersion envoy.APIVersion, ) *EgressProxyBuilder
func (*EgressProxyBuilder) Build ¶ added in v1.8.1
func (p *EgressProxyBuilder) Build( key core_model.ResourceKey, ) (*xds.Proxy, error)
type IngressProxyBuilder ¶
type IngressProxyBuilder struct { ResManager manager.ResourceManager ReadOnlyResManager manager.ReadOnlyResourceManager LookupIP lookup.LookupIPFunc MetadataTracker DataplaneMetadataTracker // contains filtered or unexported fields }
func DefaultIngressProxyBuilder ¶ added in v1.8.1
func DefaultIngressProxyBuilder( rt core_runtime.Runtime, metadataTracker DataplaneMetadataTracker, apiVersion envoy.APIVersion, meshCache *mesh.Cache, ) *IngressProxyBuilder
func (*IngressProxyBuilder) Build ¶ added in v1.8.1
func (p *IngressProxyBuilder) Build(key core_model.ResourceKey) (*xds.Proxy, error)
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.