sync

package
v1.8.1 Latest Latest
Warning

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

Go to latest
Published: Oct 5, 2022 License: Apache-2.0 Imports: 32 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(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

type DataplaneWatchdog

type DataplaneWatchdog struct {
	DataplaneWatchdogDependencies
	// contains filtered or unexported fields
}

func (*DataplaneWatchdog) Cleanup

func (d *DataplaneWatchdog) Cleanup() error

func (*DataplaneWatchdog) Sync

func (d *DataplaneWatchdog) Sync(ctx context.Context) 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

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