Loading crates/gkg-server/proto/gkg.proto +0 −8 Original line number Diff line number Diff line Loading @@ -83,14 +83,6 @@ message QueryMetadata { string query_type = 1; // e.g. "traversal", "aggregation", "search" repeated string raw_query_strings = 2; // compiled ClickHouse SQL(s) for debugging int32 row_count = 3; // rows returned after redaction (and cursor slicing if applicable) PaginationInfo pagination = 4; // present when query included a cursor } // Pagination metadata returned when the query includes a cursor. // Absent for queries without cursor — the agent interprets absence as "no pagination". message PaginationInfo { bool has_more = 1; // true if more authorized rows exist beyond this page int64 total_rows = 2; // total authorized rows before cursor slicing } // Server-sent error when query compilation or execution fails. Loading crates/gkg-server/src/grpc/service.rs +3 −8 Original line number Diff line number Diff line Loading @@ -15,10 +15,9 @@ use crate::pipeline::{QueryPipelineService, receive_query_request, send_query_er use crate::proto::{ ExecuteQueryMessage, ExecuteQueryResult, GetClusterHealthRequest, GetClusterHealthResponse, GetGraphSchemaRequest, GetGraphSchemaResponse, GetGraphStatsRequest, GetGraphStatsResponse, ListToolsRequest, ListToolsResponse, PaginationInfo, QueryMetadata, ResponseFormat, SchemaDomain, SchemaEdge, SchemaEdgeVariant, SchemaNode, SchemaNodeStyle, SchemaProperty, StructuredSchema, ToolDefinition as ProtoToolDefinition, execute_query_message, get_graph_schema_response, ListToolsRequest, ListToolsResponse, QueryMetadata, ResponseFormat, SchemaDomain, SchemaEdge, SchemaEdgeVariant, SchemaNode, SchemaNodeStyle, SchemaProperty, StructuredSchema, ToolDefinition as ProtoToolDefinition, execute_query_message, get_graph_schema_response, }; use crate::tools::{ToolRegistry, ToolService}; use query_engine::formatters::{GoonFormatter, GraphFormatter, ResultFormatter}; Loading Loading @@ -142,10 +141,6 @@ impl crate::proto::knowledge_graph_service_server::KnowledgeGraphService query_type: output.query_type, raw_query_strings: output.raw_query_strings, row_count: i32::try_from(output.row_count).unwrap_or(i32::MAX), pagination: output.pagination.map(|p| PaginationInfo { has_more: p.has_more, total_rows: p.total_rows as i64, }), }); let _ = tx Loading crates/gkg-server/src/proto/gkg.v1.rs +0 −14 Original line number Diff line number Diff line Loading @@ -64,20 +64,6 @@ pub struct QueryMetadata { /// rows returned after redaction (and cursor slicing if applicable) #[prost(int32, tag = "3")] pub row_count: i32, /// present when query included a cursor #[prost(message, optional, tag = "4")] pub pagination: ::core::option::Option<PaginationInfo>, } /// Pagination metadata returned when the query includes a cursor. /// Absent for queries without cursor — the agent interprets absence as "no pagination". #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)] pub struct PaginationInfo { /// true if more authorized rows exist beyond this page #[prost(bool, tag = "1")] pub has_more: bool, /// total authorized rows before cursor slicing #[prost(int64, tag = "2")] pub total_rows: i64, } /// Server-sent error when query compilation or execution fails. #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)] Loading Loading
crates/gkg-server/proto/gkg.proto +0 −8 Original line number Diff line number Diff line Loading @@ -83,14 +83,6 @@ message QueryMetadata { string query_type = 1; // e.g. "traversal", "aggregation", "search" repeated string raw_query_strings = 2; // compiled ClickHouse SQL(s) for debugging int32 row_count = 3; // rows returned after redaction (and cursor slicing if applicable) PaginationInfo pagination = 4; // present when query included a cursor } // Pagination metadata returned when the query includes a cursor. // Absent for queries without cursor — the agent interprets absence as "no pagination". message PaginationInfo { bool has_more = 1; // true if more authorized rows exist beyond this page int64 total_rows = 2; // total authorized rows before cursor slicing } // Server-sent error when query compilation or execution fails. Loading
crates/gkg-server/src/grpc/service.rs +3 −8 Original line number Diff line number Diff line Loading @@ -15,10 +15,9 @@ use crate::pipeline::{QueryPipelineService, receive_query_request, send_query_er use crate::proto::{ ExecuteQueryMessage, ExecuteQueryResult, GetClusterHealthRequest, GetClusterHealthResponse, GetGraphSchemaRequest, GetGraphSchemaResponse, GetGraphStatsRequest, GetGraphStatsResponse, ListToolsRequest, ListToolsResponse, PaginationInfo, QueryMetadata, ResponseFormat, SchemaDomain, SchemaEdge, SchemaEdgeVariant, SchemaNode, SchemaNodeStyle, SchemaProperty, StructuredSchema, ToolDefinition as ProtoToolDefinition, execute_query_message, get_graph_schema_response, ListToolsRequest, ListToolsResponse, QueryMetadata, ResponseFormat, SchemaDomain, SchemaEdge, SchemaEdgeVariant, SchemaNode, SchemaNodeStyle, SchemaProperty, StructuredSchema, ToolDefinition as ProtoToolDefinition, execute_query_message, get_graph_schema_response, }; use crate::tools::{ToolRegistry, ToolService}; use query_engine::formatters::{GoonFormatter, GraphFormatter, ResultFormatter}; Loading Loading @@ -142,10 +141,6 @@ impl crate::proto::knowledge_graph_service_server::KnowledgeGraphService query_type: output.query_type, raw_query_strings: output.raw_query_strings, row_count: i32::try_from(output.row_count).unwrap_or(i32::MAX), pagination: output.pagination.map(|p| PaginationInfo { has_more: p.has_more, total_rows: p.total_rows as i64, }), }); let _ = tx Loading
crates/gkg-server/src/proto/gkg.v1.rs +0 −14 Original line number Diff line number Diff line Loading @@ -64,20 +64,6 @@ pub struct QueryMetadata { /// rows returned after redaction (and cursor slicing if applicable) #[prost(int32, tag = "3")] pub row_count: i32, /// present when query included a cursor #[prost(message, optional, tag = "4")] pub pagination: ::core::option::Option<PaginationInfo>, } /// Pagination metadata returned when the query includes a cursor. /// Absent for queries without cursor — the agent interprets absence as "no pagination". #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)] pub struct PaginationInfo { /// true if more authorized rows exist beyond this page #[prost(bool, tag = "1")] pub has_more: bool, /// total authorized rows before cursor slicing #[prost(int64, tag = "2")] pub total_rows: i64, } /// Server-sent error when query compilation or execution fails. #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)] Loading