pub struct TextGraphSearchRequest {Show 15 fields
pub graph_name: String,
pub query: String,
pub k: u32,
pub ef: u32,
pub skip_server_llm: bool,
pub extra_queries: Vec<String>,
pub fact_k: u32,
pub chunk_k: u32,
pub include_answer_bundle: bool,
pub granularities: Vec<String>,
pub rrf_k: u32,
pub conflict_policy: i32,
pub include_dissent: bool,
pub entity_consolidate: bool,
pub context_date: String,
}Fields§
§graph_name: String§query: Stringraw text — gateway embeds this
k: u32§ef: u320 = default
skip_server_llm: boolBackward-compatibility flag only. Gateway now uses server-side unified inference mode configuration for all requests.
extra_queries: Vec<String>Optional caller-provided rewritten queries for better retrieval. Each entry is embedded and searched alongside the main query. Used by MCP plugins where the host LLM generates rewrites at zero cost.
fact_k: u32Per-type result limits. When set (> 0), the response additionally
populates fact_results and chunk_results with at most this many
entries each. The combined results field is always populated for
backward compatibility.
max extracted-fact results (0 = default 7)
chunk_k: u32max raw-chunk results (0 = default 5)
include_answer_bundle: boolWhen true, the gateway also returns a response-level answer-oriented evidence bundle built from the final ranked result set.
granularities: Vec<String>(#827 LongMemEval Phase 5a) Multi-granularity ingest + RRF fusion. When non-empty, the gateway runs one ANN ranking per requested granularity (sentence/round/session/fact), folds each to sessions, and fuses the per-granularity session rankings via Reciprocal Rank Fusion. Empty ⇒ legacy sentence-only behavior (zero regression). Recognized values: “sentence”, “round”, “session”, “fact”.
rrf_k: u32RRF constant k in score(d) = Σ_g weight_g / (rrf_k + rank_g(d)).
0 ⇒ default 60 (the Elasticsearch/OpenSearch rrf retriever default).
conflict_policy: i32Conflict-as-data per-request opt-in (issue #812 / #783). When set to a
value other than UNSPECIFIED, the gateway runs a read-time conflict
re-rank over the final result set: it scans contradicts edges, groups
contradictory claims into conflict sets, arbitrates each set with this
policy (PR #711), and demotes the losing claims below the winner (never
removing them) before truncating to k. UNSPECIFIED = use the graph/env
default (off unless configured) → byte-identical to pre-#812 behaviour.
include_dissent: boolWhen true, conflict_resolutions_json includes the full per-loser detail
(demoted_score, reason) for every demoted claim. When false, the JSON is
still emitted for any resolved set but with the loser list collapsed to
node ids only. No effect unless conflict_policy fires.
entity_consolidate: bool(#830 LongMemEval Phase 5d) Read-time entity consolidation. When true, the
gateway dereferences each query entity term through the persisted gcanon:
identity cluster (Phase 5c) and OR-expands retrieval over the cluster’s
surface forms via the existing load_alias_map query-expansion seam, so
evidence written under any surface in the cluster is recalled regardless
of which surface the query used. Each consolidated result is stamped with
canonical_entity_id. Default false ⇒ byte-identical to pre-#830 behaviour;
a gcanon: miss / resolution-off falls back to today’s recall (never an
error). Honoured only when entity resolution is enabled (this flag OR the
STATELET_ENTITY_RESOLVE env default).
context_date: StringOptional caller-supplied reference date for relative-time queries and the
response-level answer-oriented memory pack. Kept out of query so date
tokens do not perturb retrieval ranking.
Implementations§
Source§impl TextGraphSearchRequest
impl TextGraphSearchRequest
Sourcepub fn conflict_policy(&self) -> ConflictPolicy
pub fn conflict_policy(&self) -> ConflictPolicy
Returns the enum value of conflict_policy, or the default if the field is set to an invalid enum value.
Sourcepub fn set_conflict_policy(&mut self, value: ConflictPolicy)
pub fn set_conflict_policy(&mut self, value: ConflictPolicy)
Sets conflict_policy to the provided enum value.
Trait Implementations§
Source§impl Clone for TextGraphSearchRequest
impl Clone for TextGraphSearchRequest
Source§fn clone(&self) -> TextGraphSearchRequest
fn clone(&self) -> TextGraphSearchRequest
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for TextGraphSearchRequest
impl Debug for TextGraphSearchRequest
Source§impl Default for TextGraphSearchRequest
impl Default for TextGraphSearchRequest
Source§impl Message for TextGraphSearchRequest
impl Message for TextGraphSearchRequest
Source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Source§fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
Source§fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Source§fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
Source§fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Source§fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Source§fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Source§fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self. Read moreSource§fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self.Source§impl PartialEq for TextGraphSearchRequest
impl PartialEq for TextGraphSearchRequest
impl StructuralPartialEq for TextGraphSearchRequest
Auto Trait Implementations§
impl Freeze for TextGraphSearchRequest
impl RefUnwindSafe for TextGraphSearchRequest
impl Send for TextGraphSearchRequest
impl Sync for TextGraphSearchRequest
impl Unpin for TextGraphSearchRequest
impl UnsafeUnpin for TextGraphSearchRequest
impl UnwindSafe for TextGraphSearchRequest
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request