Skip to main content

Operation

Enum Operation 

Source
pub enum Operation {
Show 32 variants Hello(HelloAgreement), Present(PassPresent), DraftsRun(DraftsRun), Branches(BranchPage), Collections(CollectionPage), Get(DocumentRead), List(DocumentPage), History(HistoryPage), Follow(HeadFollow), Review(ReviewPage), ReviewCounts(ReviewPage), MergePrepare(ReviewPage), MergeDangling(ReviewPage), Mutate(Mutation), Receipt(ReceiptQuery), CountsRebuild(CountsRebuild), CountsAudit(Selection), EdgesOut(EdgePage), EdgesIn(EdgePage), GraphExport(GraphPage), VectorGet(VectorRead), VectorList(VectorPage), VectorSearch(VectorSearch), VectorSearchText(VectorSearchText), StoreStats(StoreRead), VectorFields(StoreRead), EmbedRewalk(EmbedRewalk), Relations(RelationsRead), QueryRun(QueryRequest), QueryCheck(CheckRequest), QueryWords(WordsRequest), ChangesList(ChangesRequest),
}
Expand description

Reads select a captured version; mutations have a separate stable identity.

Variants§

§

Hello(HelloAgreement)

§

Present(PassPresent)

Presents the connection’s Lys pass; every later request on the connection is decided from it (ACCESS-001 R2). Answers {holder, expires} once the pass verifies.

§

DraftsRun(DraftsRun)

Runs one page of the drafts Lys approved for this database, with the connection’s pass as the connector’s: each is applied exactly once and acknowledged (ACCESS-001 R2). Answers {acknowledged, next}; nothing polls or retries on its own.

§

Branches(BranchPage)

§

Collections(CollectionPage)

§

Get(DocumentRead)

§

List(DocumentPage)

§

History(HistoryPage)

§

Follow(HeadFollow)

Answers a stream of frames, all with the request’s id: the branch’s head {branch, version} at once, then one each time its published version changes, ended by a refusal: pass_expired when the connection’s pass expires, branch_unknown when the branch is gone. Pushed by the publish itself; nothing polls (serve/follow.rs).

§

Review(ReviewPage)

§

ReviewCounts(ReviewPage)

Answers partial owner-key counts; sum pages until done is true.

§

MergePrepare(ReviewPage)

Answers pinned three-way owner lines without admitting a mutation.

§

MergeDangling(ReviewPage)

Answers merge endpoint findings without choosing a conflict winner.

§

Mutate(Mutation)

§

Receipt(ReceiptQuery)

§

CountsRebuild(CountsRebuild)

Recounts visible rows atomically; a repeated request replays its receipt.

§

CountsAudit(Selection)

Compares kept counts with visible rows without changing the selected version.

§

EdgesOut(EdgePage)

Answers {selection, edges: [Edge], next_after}: edges leaving node.

§

EdgesIn(EdgePage)

Answers {selection, edges: [Edge], next_after}: edges arriving at node.

§

GraphExport(GraphPage)

Answers {selection, edges: [Edge], next_after}: every edge of the version.

§

VectorGet(VectorRead)

Answers {selection, vector}; vector is null when none is stored.

§

VectorList(VectorPage)

Answers {selection, vectors: [{document_id, vector}], next_after}.

§

VectorSearch(VectorSearch)

Answers {selection, hits: [{document_id, score}], scanned}.

§

VectorSearchText(VectorSearchText)

Answers {selection, hits: [{document_id, score}], compared, stale, coverage}: text embedded as a question, then the field searched.

§

StoreStats(StoreRead)

§

VectorFields(StoreRead)

§

EmbedRewalk(EmbedRewalk)

Answers {branch, collection, field, through}: opens one walk of the field toward through for the texts it passed as longer than the model reads (EMB-E2 (j)).

§

Relations(RelationsRead)

Answers {selection, relations: [Relation]} at the captured version.

§

QueryRun(QueryRequest)

Answers {selection, rows: [{value, origin}], next, engine, reading, collection, records_read}: one page of a query’s rows at one captured moment; collection is the one a pipeline read, else null.

§

QueryCheck(CheckRequest)

§

QueryWords(WordsRequest)

§

ChangesList(ChangesRequest)

Answers {from, to, rows: [{kind, origin, before, after}], next, changes_read}: the documents changed between two versions.

Implementations§

Source§

impl Operation

Source

pub const WIRE_NAMES: &'static [&'static str]

Every wire name of this vocabulary, in declaration order; the route matrix is checked against it.

Trait Implementations§

Source§

impl Debug for Operation

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl<'de> Deserialize<'de> for Operation

Source§

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>
where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
Source§

impl Serialize for Operation

Source§

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>
where __S: Serializer,

Serialize this value into the given Serde serializer. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoMaybeUndefined<T> for T

Source§

fn into_maybe_undefined(self) -> MaybeUndefined<T>

Converts this value into a three-state builder argument.
Source§

impl<T> IntoOption<T> for T

Source§

fn into_option(self) -> Option<T>

Converts this value into an optional builder argument.
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more