registry

type MemoryStore struct {
	// contains filtered or unexported fields
}

type RegistryStore interface {
	Put(entry ResourceEntry) (old *ResourceEntry, existed bool)
	// PutIfAbsent inserts the entry only if no entry with the same key exists.
	// Returns the existing entry and true if one was already present.
	PutIfAbsent(entry ResourceEntry) (existing *ResourceEntry, loaded bool)
	Get(pluginID, connectionID, resourceKey, namespace, id string) (*ResourceEntry, bool)
	Delete(pluginID, connectionID, resourceKey, namespace, id string) (*ResourceEntry, bool)
	DeleteByConnection(pluginID, connectionID string) []ResourceEntry
	ScanByLabel(pluginID, connectionID, resourceKey string, selector map[string]string) []ResourceEntry
	ScanByResourceKey(pluginID, connectionID, resourceKey string) []ResourceEntry
}

type ResourceEntry struct {
	PluginID     string
	ConnectionID string
	ResourceKey  string            // e.g. "core::v1::Pod", "ec2::Instance"
	ID           string            // resource name/identifier
	Namespace    string            // scope within connection (empty if unscoped)
	UID          string            // dedup key
	Labels       map[string]string // for selector-based relationship resolution
	CreatedAt    time.Time
}