sync

Documentation

Index

• type ConnectionInfoTracker
• type DataplaneMetadataTracker
• type DataplaneProxyBuilder
  • func DefaultDataplaneProxyBuilder(config dubbo_cp.Config, apiVersion core_xds.APIVersion) *DataplaneProxyBuilder
  • func (p *DataplaneProxyBuilder) Build(ctx context.Context, key core_model.ResourceKey, ...) (*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) (SyncResult, error)
• type DataplaneWatchdogDependencies
• type DataplaneWatchdogFactory
  • func DefaultDataplaneWatchdogFactory(rt core_runtime.Runtime, metadataTracker DataplaneMetadataTracker, ...) (DataplaneWatchdogFactory, error)
  • func NewDataplaneWatchdogFactory(refreshInternal time.Duration, deps DataplaneWatchdogDependencies) (DataplaneWatchdogFactory, error)
• type IngressProxyBuilder
  • func DefaultIngressProxyBuilder(rt core_runtime.Runtime, apiVersion core_xds.APIVersion) *IngressProxyBuilder
  • func (p *IngressProxyBuilder) Build(ctx context.Context, key core_model.ResourceKey, ...) (*core_xds.Proxy, error)
• type SnapshotReconciler
• type Status
• type SyncResult

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 {
	Zone       string
	APIVersion core_xds.APIVersion
}

func DefaultDataplaneProxyBuilder

func DefaultDataplaneProxyBuilder(
	config dubbo_cp.Config,
	apiVersion core_xds.APIVersion,
) *DataplaneProxyBuilder

func (*DataplaneProxyBuilder) Build

func (p *DataplaneProxyBuilder) Build(ctx context.Context, 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) (SyncResult, error)

type DataplaneWatchdogDependencies

type DataplaneWatchdogDependencies struct {
	DataplaneProxyBuilder *DataplaneProxyBuilder
	DataplaneReconciler   SnapshotReconciler
	IngressProxyBuilder   *IngressProxyBuilder
	IngressReconciler     SnapshotReconciler
	EnvoyCpCtx            *xds_context.ControlPlaneContext
	MetadataTracker       DataplaneMetadataTracker
	ResManager            core_manager.ReadOnlyResourceManager
	MeshCache             *mesh.Cache
}

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,
	envoyCpCtx *xds_context.ControlPlaneContext,
	apiVersion core_xds.APIVersion,
) (DataplaneWatchdogFactory, error)

func NewDataplaneWatchdogFactory

func NewDataplaneWatchdogFactory(
	refreshInternal time.Duration,
	deps DataplaneWatchdogDependencies,
) (DataplaneWatchdogFactory, error)

type IngressProxyBuilder

type IngressProxyBuilder struct {
	ResManager manager.ResourceManager
	LookupIP   lookup.LookupIPFunc
	// contains filtered or unexported fields
}

func DefaultIngressProxyBuilder

func DefaultIngressProxyBuilder(
	rt core_runtime.Runtime,
	apiVersion core_xds.APIVersion,
) *IngressProxyBuilder

func (*IngressProxyBuilder) Build

func (p *IngressProxyBuilder) Build(
	ctx context.Context,
	key core_model.ResourceKey,
	aggregatedMeshCtxs xds_context.AggregatedMeshContexts,
) (*core_xds.Proxy, error)

type SnapshotReconciler

type SnapshotReconciler interface {
	Reconcile(ctx context.Context, ctx2 xds_context.Context, proxy *core_xds.Proxy) (bool, error)
	Clear(proxyId *core_xds.ProxyId) error
}

SnapshotReconciler reconciles Envoy XDS configuration (Snapshot) by executing all generators (pkg/xds/generator)

type Status

type Status string

var (
	SkipStatus      Status = "skip"
	GeneratedStatus Status = "generated"
	ChangedStatus   Status = "changed"
)

type SyncResult

type SyncResult struct {
	ProxyType mesh_proto.ProxyType
	Status    Status
}