sync

package
v1.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 30, 2021 License: Apache-2.0 Imports: 25 Imported by: 0

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL