sync

Documentation

Index

• type ConnectionInfoTracker
• type DataplaneMetadataTracker
• type DataplaneProxyBuilder
• type DataplaneWatchdog
  • func NewDataplaneWatchdog(deps DataplaneWatchdogDependencies, proxyId *core_xds.ProxyId, streamId int64) *DataplaneWatchdog
  • func (d *DataplaneWatchdog) Cleanup() error
  • func (d *DataplaneWatchdog) Sync() error
• type DataplaneWatchdogDependencies
• type DataplaneWatchdogFactory
  • func DefaultDataplaneWatchdogFactory(rt core_runtime.Runtime, metadataTracker DataplaneMetadataTracker, ...) (DataplaneWatchdogFactory, error)
  • func NewDataplaneWatchdogFactory(xdsSyncMetrics *xds_metrics.Metrics, refreshInterval time.Duration, ...) (DataplaneWatchdogFactory, error)
• type IngressProxyBuilder
• type SnapshotReconciler

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)