graphembedding

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

type Config struct {
	Ports        *component.PortConfig `json:"ports" schema:"type:ports,description:Port configuration,category:basic"`
	EmbedderType string                `` /* 153-byte string literal not displayed */
	BatchSize    int                   `json:"batch_size" schema:"type:int,description:Batch size for embedding generation,category:advanced"`

	// Workers is the number of concurrent embedding worker goroutines.
	//
	// This used to be derived as batch_size/10, which yielded ZERO workers for any
	// batch_size under 10 and left the component silently processing nothing
	// (gh#620). Worker count is its own operator knob because it is a concurrency
	// setting, not a batching one — no graph processor batches.
	Workers int `json:"workers,omitempty" schema:"type:int,description:Number of concurrent embedding worker goroutines,category:advanced"`

	// MaxTextLen is the source-text truncation cap (in characters) applied before
	// embedding. Text beyond it is truncated at a word boundary and the truncation is
	// counted (text_truncated_total), so the bytes actually embedded are discoverable
	// rather than silently dropped. The cap is part of what the vector depends on, so
	// it participates in the dedup key (#602): changing it re-embeds affected
	// entities. 0 selects a per-embedder-type default (4000 bm25 / 8000 neural).
	MaxTextLen int `` /* 247-byte string literal not displayed */

	// TextSuffixes controls which triple predicates are extracted for embedding.
	// Predicates ending with any of these suffixes will have their text values embedded.
	// When empty, defaults to: .title, .content, .description, .summary, .text, .name, .body, .abstract, .subject
	TextSuffixes []string `` /* 191-byte string literal not displayed */

	// Dependency startup configuration
	StartupAttempts int `` /* 130-byte string literal not displayed */
	StartupInterval int `` /* 134-byte string literal not displayed */
	CoalesceMs      int `` /* 141-byte string literal not displayed */
}

type SearchRequest struct {
	Query string `json:"query"`
	Limit int    `json:"limit"`
	// Scope optionally constrains the search to candidates whose entity ID
	// matches at least one of these dot-delimited prefixes (OR-matched, via
	// graph.MatchesAnyIDPrefix). Empty/absent = no filter (today's behavior).
	// The filter is applied at the candidate source in every similarity path so
	// a small domain is never crowded out of the ranked window (ADR-071).
	// Decoded with json.Unmarshal (unknown-field-tolerant), so a producer that
	// sends Scope to an un-migrated server degrades to an unscoped search.
	Scope []string `json:"scope,omitempty"`
}

type SearchResponse struct {
	Query        string         `json:"query"`
	Results      []SearchResult `json:"results"`
	Duration     string         `json:"duration"`
	EmbedderType string         `json:"embedder_type,omitempty"` // "bm25" or "http"
}

type SearchResult struct {
	EntityID   string  `json:"entity_id"`
	Similarity float64 `json:"similarity"`
}

type SimilarEntity struct {
	EntityID   string  `json:"entity_id"`
	Similarity float64 `json:"similarity"`
}

type SimilarRequest struct {
	EntityID string `json:"entity_id"`
	Limit    int    `json:"limit"`
}

type SimilarResponse struct {
	EntityID string          `json:"entity_id"`
	Similar  []SimilarEntity `json:"similar"`
	Duration string          `json:"duration"`
}