Struct DistributedModelStore

core/services/nodes/distributed_store.go:14–17

DistributedModelStore wraps a local in-memory store with PostgreSQL-backed lookup via NodeRegistry. Models that aren't in the local cache are looked up in the database — this makes shutdown, listing, and watchdog work even when the frontend process restarted or a different instance loaded the model.

// in the database — this makes shutdown, listing, and watchdog work even when
// the frontend process restarted or a different instance loaded the model.
type DistributedModelStore struct {
	local    model.ModelStore
	registry ModelLookup
}

func NewDistributedModelStore(local model.ModelStore, registry ModelLookup) *DistributedModelStore {
	return &DistributedModelStore{local: local, registry: registry}