Skip to main content

NotmuchStore

ecr_store::notmuch_store

Struct NotmuchStore

pub struct NotmuchStore { /* private fields */ }

Implementations§

impl NotmuchStore

pub fn open() -> Result<Self>

pub fn new(paths: Arc<MailPaths>) -> Self

pub fn paths(&self) -> &MailPaths

pub fn notmuch(&self) -> &Notmuch

pub fn index_status(&self) -> Option<IndexStatus>

pub async fn refresh_index(&self) -> Result<Option<Refreshed>>

Builds or catches up the index, rebuilding it if that is what it takes.

This is the caller that is allowed to be slow — a first build of a 46k inbox is around 80 seconds — so it is never run from a request. The server spawns it at startup and the watcher runs it when the database moves; reads fall through to notmuch for as long as it takes.

Trait Implementations§

impl MailStore for NotmuchStore

async fn count_batch(&self, queries: &[String]) -> Result<Vec<u64>>

The sidebar’s rows are mostly tags, and one saved free-text query among them must not cost every other row its answer — so the ones the index can take are taken, and only the rest reach notmuch, still in one batch.

async fn revision(&self) -> Result<Revision>

async fn accounts(&self) -> Result<Vec<Account>>

async fn search_threads(&self, query: &Query) -> Result<Vec<ThreadSummary>>

async fn count(&self, query: &Query) -> Result<usize>

async fn thread(&self, id: &ThreadId) -> Result<Thread>

async fn message(&self, id: &MessageId) -> Result<Message>

async fn body(&self, id: &MessageId, options: BodyOptions) -> Result<Body>

async fn part(&self, id: &MessageId, part: &PartId) -> Result<Part>

async fn tag(&self, ops: &[TagOp]) -> Result<Revision>

async fn sync( &self, accounts: &[AccountId], progress: &dyn ProgressSink, ) -> Result<SyncReport>

async fn send(&self, account: &AccountId, raw: &[u8]) -> Result<()>

async fn doctor(&self) -> Doctor

Auto Trait Implementations§

impl !Freeze for NotmuchStore

impl !RefUnwindSafe for NotmuchStore

impl !UnwindSafe for NotmuchStore

impl Send for NotmuchStore

impl Sync for NotmuchStore

impl Unpin for NotmuchStore

impl UnsafeUnpin for NotmuchStore

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

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

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

fn in_current_span(self) -> Instrumented<Self>

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

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

fn into(self) -> U

Calls U::from(self).

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

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

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

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

impl<T> Same for T

type Output = T

Should always be Self

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

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

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

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

The type returned in the event of a conversion error.

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

Performs the conversion.

impl<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

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