renaming

Author: Lucas-Fernandes-Martins

apix/config/v1alpha1/endpointpickerconfig_types.go

@@ -239,18 +239,18 @@ type DataLayerConfig struct {
 	// If omitted, the EPP uses the default Kubernetes-based discovery.
 	Discovery *DiscoveryConfig `json:"discovery,omitempty"`
 	// +optional
-	// SharedStateStorePluginRef names the plugin instance to use as the cross-EPP
-	// shared state store. The reference is to the name of an entry in the
-	// top-level Plugins section. If omitted, no shared state store is used
-	// and plugins that read shared state fall back to local data.
-	SharedStateStorePluginRef string `json:"sharedStateStorePluginRef,omitempty"`
+	// CrossReplicaStorePluginRef names the plugin instance to use as the cross-EPP
+	// cross-replica store. The reference is to the name of an entry in the
+	// top-level Plugins section. If omitted, no cross-replica store is used
+	// and plugins that read cross-replica state fall back to local data.
+	CrossReplicaStorePluginRef string `json:"crossReplicaStorePluginRef,omitempty"`
 }
 
 func (dlc *DataLayerConfig) String() string {
 	if dlc == nil {
 		return nilString
 	}
-	return fmt.Sprintf("{Sources: %v, Discovery: %v, SharedStateStorePluginRef: %s}", dlc.Sources, dlc.Discovery, dlc.SharedStateStorePluginRef)
+	return fmt.Sprintf("{Sources: %v, Discovery: %v, CrossReplicaStorePluginRef: %s}", dlc.Sources, dlc.Discovery, dlc.CrossReplicaStorePluginRef)
 }
 
 // DiscoveryConfig references the EndpointDiscovery plugin to use.

pkg/epp/config/loader/configloader.go

@@ -432,10 +432,10 @@ func buildDataLayerConfig(rawDataConfig *configapi.DataLayerConfig, handle fwkpl
 		return &cfg, nil
 	}
 
-	if ref := rawDataConfig.SharedStateStorePluginRef; ref != "" {
-		store, ok := handle.Plugin(ref).(fwkdl.SharedStateStore)
+	if ref := rawDataConfig.CrossReplicaStorePluginRef; ref != "" {
+		store, ok := handle.Plugin(ref).(fwkdl.CrossReplicaStore)
 		if !ok {
-			return nil, fmt.Errorf("the plugin %s is not a fwkdl.SharedStateStore", ref)
+			return nil, fmt.Errorf("the plugin %s is not a fwkdl.CrossReplicaStore", ref)
 		}
 		cfg.Store = store
 	}

pkg/epp/datalayer/config.go

@@ -29,7 +29,7 @@ import (
 // the set-up phase.
 type Config struct {
 	Sources []DataSourceConfig // the data sources configured in the data layer
-	Store   fwkdl.SharedStateStore
+	Store   fwkdl.CrossReplicaStore
 }
 
 func (c *Config) String() string {

pkg/epp/datalayer/runtime.go

@@ -53,7 +53,7 @@ type Runtime struct {
 	notification *notificationManager
 	endpoint     *endpointManager
 	extractors   *extractorMap
-	store        fwkdl.SharedStateStore
+	store        fwkdl.CrossReplicaStore
 
 	pendingMu            sync.Mutex
 	pendingRegistrations []fwkdl.PendingRegistration // code-registered (source-type, extractor) pairs, resolved by Configure()
@@ -446,8 +446,8 @@ func (r *Runtime) dispatchEndpointEvent(ctx context.Context, logger logr.Logger,
 				if err := epExt.Extract(ctx, *processed); err != nil {
 					logger.Error(err, "endpoint extractor failed", "extractor", ext.TypedName())
 				}
-				if contributor, ok := ext.(fwkdl.SharedStateContributor); ok && r.store != nil {
-					spec := contributor.SharedState()
+				if contributor, ok := ext.(fwkdl.CrossReplicaContributor); ok && r.store != nil {
+					spec := contributor.CrossReplicaState()
 					endpointID := processed.Endpoint.GetMetadata().GetNamespacedName().String()
 					switch processed.Type {
 					case fwkdl.EventAddOrUpdate:

pkg/epp/framework/interface/datalayer/state_store.go

@@ -25,11 +25,11 @@ import (
 // StateKey namespaces cross-EPP shared state.
 type StateKey string
 
-// SharedStateStore is a cross-EPP state store for sharing state across replicas.
+// CrossReplicaStore is a cross-EPP state store for sharing state across replicas.
 // Implementations own the sync mechanism (e.g., Redis pub/sub, gossip) and the
 // aggregation strategy (e.g., sum for in-flight load, union for cache state).
 // The store can dispatch per StateKey for different aggregation strategies.
-type SharedStateStore interface {
+type CrossReplicaStore interface {
 	fwkplugin.Plugin
 
 	// Set writes a value for the given key and endpoint. The runtime calls
@@ -46,16 +46,16 @@ type SharedStateStore interface {
 	Delete(ctx context.Context, key StateKey, endpointID string) error
 }
 
-// SharedStateContributor is an opt-in interface for endpoint extractors that
+// CrossReplicaContributor is an opt-in interface for endpoint extractors that
 // want their installed attributes to reflect cross-replica aggregate state.
 // The plugin's Extract method is unchanged; the runtime detects this interface
 // and wires the store transparently.
-type SharedStateContributor interface {
-	SharedState() SharedStateSpec
+type CrossReplicaContributor interface {
+	CrossReplicaState() CrossReplicaSpec
 }
 
-// SharedStateSpec declares what a SharedStateContributor publishes and where.
-type SharedStateSpec struct {
+// CrossReplicaSpec declares what a CrossReplicaContributor publishes and where.
+type CrossReplicaSpec struct {
 	// StateKey namespaces this contributor's data in the store.
 	StateKey StateKey
 

pkg/epp/framework/plugins/datalayer/cross_plugin/state_store_mock.go

@@ -28,9 +28,9 @@ import (
 
 const LocalStateStoreType = "local-state-store"
 
-var _ fwkdl.SharedStateStore = (*LocalStateStore)(nil)
+var _ fwkdl.CrossReplicaStore = (*LocalStateStore)(nil)
 
-// LocalStateStore is an in-memory mock SharedStateStore for single-replica
+// LocalStateStore is an in-memory mock CrossReplicaStore for single-replica
 // deployments and testing. No cross-replica sync is performed.
 type LocalStateStore struct {
 	typedName fwkplugin.TypedName

pkg/epp/framework/plugins/requestcontrol/dataproducer/inflightload/producer.go

@@ -116,7 +116,7 @@ var (
 	_ requestcontrol.DataProducer          = &InFlightLoadProducer{}
 	_ datalayer.EndpointExtractor          = (*InFlightLoadProducer)(nil)
 	_ datalayer.Registrant                 = &InFlightLoadProducer{}
-	_ datalayer.SharedStateContributor     = (*InFlightLoadProducer)(nil)
+	_ datalayer.CrossReplicaContributor    = (*InFlightLoadProducer)(nil)
 	_ fwkplugin.ConsumerPlugin             = &InFlightLoadProducer{}
 	_ fwkplugin.StateDumper                = &InFlightLoadProducer{}
 )
@@ -279,9 +279,9 @@ func (p *InFlightLoadProducer) RegisterDependencies(r datalayer.Registrar) error
 	})
 }
 
-// SharedState declares the cross-EPP state this plugin contributes.
-func (p *InFlightLoadProducer) SharedState() datalayer.SharedStateSpec {
-	return datalayer.SharedStateSpec{
+// CrossReplicaState declares the cross-EPP state this plugin contributes.
+func (p *InFlightLoadProducer) CrossReplicaState() datalayer.CrossReplicaSpec {
+	return datalayer.CrossReplicaSpec{
 		StateKey:     datalayer.StateKey("inflight:" + p.typedName.Name),
 		AttributeKey: p.dk.String(),
 		Supply: func(endpointID string) func() datalayer.Cloneable {

pkg/epp/requestcontrol/director.go

@@ -129,7 +129,7 @@ func NewDirectorWithConfig(
 	admissionController AdmissionController,
 	endpointCandidates contracts.EndpointCandidates,
 	config *Config,
-	store fwkdl.SharedStateStore,
+	store fwkdl.CrossReplicaStore,
 ) *Director {
 	return &Director{
 		datastore:             datastore,
@@ -202,7 +202,7 @@ type Director struct {
 	admissionController   AdmissionController
 	endpointCandidates    contracts.EndpointCandidates
 	requestControlPlugins Config
-	store                 fwkdl.SharedStateStore
+	store                 fwkdl.CrossReplicaStore
 	// We just need a pointer to an int32 variable since Priority is a pointer in InferenceObjective.
 	// No need to set this in the constructor, since the value we want is the default (0)
 	// and value types cannot be nil.
@@ -622,8 +622,8 @@ func (d *Director) runDataProducerPlugins(ctx context.Context,
 		if err := dataProducerPluginsWithTimeout(ctx, producerTimeout(p), []fwkrc.DataProducer{p}, request, endpoints); err != nil {
 			return err
 		}
-		if contributor, ok := p.(fwkdl.SharedStateContributor); ok && d.store != nil {
-			spec := contributor.SharedState()
+		if contributor, ok := p.(fwkdl.CrossReplicaContributor); ok && d.store != nil {
+			spec := contributor.CrossReplicaState()
 			for _, ep := range endpoints {
 				if ep == nil || ep.GetMetadata() == nil {
 					continue