sync

Documentation

Index

• type ConnectionInfoTracker
• type DataplaneMetadataTracker
• type DataplaneProxyBuilder
  • func DefaultDataplaneProxyBuilder(config kuma_cp.Config, metadataTracker DataplaneMetadataTracker, ...) *DataplaneProxyBuilder
  • func (p *DataplaneProxyBuilder) Build(key core_model.ResourceKey, meshContext xds_context.MeshContext) (*core_xds.Proxy, error)
• type DataplaneWatchdog
  • func NewDataplaneWatchdog(deps DataplaneWatchdogDependencies, dpKey core_model.ResourceKey) *DataplaneWatchdog
  • func (d *DataplaneWatchdog) Cleanup() error
  • func (d *DataplaneWatchdog) Sync(ctx context.Context) 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 EgressProxyBuilder
  • func DefaultEgressProxyBuilder(ctx context.Context, rt core_runtime.Runtime, ...) *EgressProxyBuilder
  • func (p *EgressProxyBuilder) Build(key core_model.ResourceKey) (*xds.Proxy, error)
• type IngressProxyBuilder
  • func DefaultIngressProxyBuilder(rt core_runtime.Runtime, metadataTracker DataplaneMetadataTracker, ...) *IngressProxyBuilder
  • func (p *IngressProxyBuilder) Build(key core_model.ResourceKey) (*xds.Proxy, error)
• type SnapshotReconciler

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

func DefaultDataplaneProxyBuilder(
	config kuma_cp.Config,
	metadataTracker DataplaneMetadataTracker,
	apiVersion envoy.APIVersion,
) *DataplaneProxyBuilder

func (*DataplaneProxyBuilder) Build

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

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

type EgressProxyBuilder struct {
	ResManager         manager.ResourceManager
	ReadOnlyResManager manager.ReadOnlyResourceManager
	LookupIP           lookup.LookupIPFunc
	MetadataTracker    DataplaneMetadataTracker
	// contains filtered or unexported fields
}

func DefaultEgressProxyBuilder

func DefaultEgressProxyBuilder(
	ctx context.Context,
	rt core_runtime.Runtime,
	metadataTracker DataplaneMetadataTracker,
	meshCache *mesh.Cache,
	apiVersion envoy.APIVersion,
) *EgressProxyBuilder

func (*EgressProxyBuilder) Build

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

func DefaultIngressProxyBuilder(
	rt core_runtime.Runtime,
	metadataTracker DataplaneMetadataTracker,
	apiVersion envoy.APIVersion,
	meshCache *mesh.Cache,
) *IngressProxyBuilder

func (*IngressProxyBuilder) Build

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)