Struct kanidmd_lib::server::QueryServerReadTransaction

pub struct QueryServerReadTransaction<'a> { /* private fields */ }

Trait Implementations

impl<'a> QueryServerTransaction<'a> for QueryServerReadTransaction<'a>

type AccessControlsTransactionType = AccessControlsReadTransaction<'a>

type BackendTransactionType = BackendReadTransaction<'a>

type SchemaTransactionType = SchemaReadTransaction

fn get_be_txn(&self) -> &BackendReadTransaction<'a>

fn get_schema(&self) -> &SchemaReadTransaction

fn get_accesscontrols(&self) -> &AccessControlsReadTransaction<'a>

fn get_resolve_filter_cache(
    &self
) -> &mut ARCacheReadTxn<'a, (IdentityId, Filter<FilterValid>), Filter<FilterValidResolved>, ()>

fn get_domain_uuid(&self) -> Uuid

fn get_domain_name(&self) -> &str

fn get_domain_display_name(&self) -> &str

fn search_ext(
    &self,
    se: &SearchEvent
) -> Result<Vec<Entry<EntryReduced, EntryCommitted>>, OperationError>

Conduct a search and apply access controls to yield a set of entries that have been reduced to the set of user visible avas. Note that if you provide a SearchEvent for the internal user, this query will fail. It is invalid for the access module to attempt to reduce avas for internal searches, and you should use fn search instead.

fn search(
    &self,
    se: &SearchEvent
) -> Result<Vec<Arc<EntrySealedCommitted>>, OperationError>

fn exists(&self, ee: &ExistsEvent) -> Result<bool, OperationError>

fn name_to_uuid(&self, name: &str) -> Result<Uuid, OperationError>

fn uuid_to_spn(&self, uuid: Uuid) -> Result<Option<Value>, OperationError>

fn uuid_to_rdn(&self, uuid: Uuid) -> Result<String, OperationError>

fn internal_exists(
    &self,
    filter: Filter<FilterInvalid>
) -> Result<bool, OperationError>

From internal, generate an “exists” event and dispatch

fn internal_search(
    &self,
    filter: Filter<FilterInvalid>
) -> Result<Vec<Arc<EntrySealedCommitted>>, OperationError>

fn impersonate_search_valid(
    &self,
    f_valid: Filter<FilterValid>,
    f_intent_valid: Filter<FilterValid>,
    event: &Identity
) -> Result<Vec<Arc<EntrySealedCommitted>>, OperationError>

fn impersonate_search_ext_valid(
    &self,
    f_valid: Filter<FilterValid>,
    f_intent_valid: Filter<FilterValid>,
    event: &Identity
) -> Result<Vec<Entry<EntryReduced, EntryCommitted>>, OperationError>

Applies ACP to filter result entries.

fn impersonate_search(
    &self,
    filter: Filter<FilterInvalid>,
    filter_intent: Filter<FilterInvalid>,
    event: &Identity
) -> Result<Vec<Arc<EntrySealedCommitted>>, OperationError>

fn impersonate_search_ext(
    &self,
    filter: Filter<FilterInvalid>,
    filter_intent: Filter<FilterInvalid>,
    event: &Identity
) -> Result<Vec<Entry<EntryReduced, EntryCommitted>>, OperationError>

fn internal_search_uuid(
    &self,
    uuid: &Uuid
) -> Result<Arc<EntrySealedCommitted>, OperationError>

Get a single entry by its UUID. This is used heavily for internal server operations, especially in login and ACP checks.

fn impersonate_search_ext_uuid(
    &self,
    uuid: &Uuid,
    event: &Identity
) -> Result<Entry<EntryReduced, EntryCommitted>, OperationError>

fn impersonate_search_uuid(
    &self,
    uuid: &Uuid,
    event: &Identity
) -> Result<Arc<EntrySealedCommitted>, OperationError>

fn clone_value(&self, attr: &str, value: &str) -> Result<Value, OperationError>

Do a schema aware conversion from a String:String to String:Value for modification present.

fn clone_partialvalue(
    &self,
    attr: &str,
    value: &str
) -> Result<PartialValue, OperationError>

fn resolve_valueset(
    &self,
    value: &ValueSet
) -> Result<Vec<String>, OperationError>

fn resolve_valueset_ldap(
    &self,
    value: &ValueSet,
    basedn: &str
) -> Result<Vec<String>, OperationError>

fn get_db_domain_name(&self) -> Result<String, OperationError>

Pull the domain name from the database

fn get_domain_fernet_private_key(&self) -> Result<String, OperationError>

fn get_domain_es256_private_key(&self) -> Result<Vec<u8>, OperationError>

fn get_password_badlist(&self) -> Result<HashSet<String>, OperationError>

fn get_oauth2rs_set(
    &self
) -> Result<Vec<Arc<EntrySealedCommitted>>, OperationError>

impl<'a> Send for QueryServerReadTransaction<'a>

impl<'a> Sync for QueryServerReadTransaction<'a>