Struct kanidm_unix_common::cache::CacheLayer
source · [−]pub struct CacheLayer { /* private fields */ }Implementations
sourceimpl CacheLayer
impl CacheLayer
pub async fn new(
path: &str,
timeout_seconds: u64,
client: KanidmClient,
pam_allow_groups: Vec<String>,
default_shell: String,
home_prefix: String,
home_attr: HomeAttr,
home_alias: Option<HomeAttr>,
uid_attr_map: UidAttr,
gid_attr_map: UidAttr
) -> Result<Self, ()>
pub async fn attempt_online(&self)
pub async fn mark_offline(&self)
pub async fn clear_cache(&self) -> Result<(), ()>
pub async fn invalidate(&self) -> Result<(), ()>
pub async fn check_nxcache(&self, id: &Id) -> bool
pub async fn get_sshkeys(&self, account_id: &str) -> Result<Vec<String>, ()>
pub async fn get_nssaccounts(&self) -> Result<Vec<NssUser>, ()>
pub async fn get_nssaccount_name(
&self,
account_id: &str
) -> Result<Option<NssUser>, ()>
pub async fn get_nssaccount_gid(&self, gid: u32) -> Result<Option<NssUser>, ()>
pub async fn get_nssgroups(&self) -> Result<Vec<NssGroup>, ()>
pub async fn get_nssgroup_name(
&self,
grp_id: &str
) -> Result<Option<NssGroup>, ()>
pub async fn get_nssgroup_gid(&self, gid: u32) -> Result<Option<NssGroup>, ()>
pub async fn pam_account_allowed(
&self,
account_id: &str
) -> Result<Option<bool>, ()>
pub async fn pam_account_authenticate(
&self,
account_id: &str,
cred: &str
) -> Result<Option<bool>, ()>
pub async fn pam_account_beginsession(
&self,
account_id: &str
) -> Result<Option<HomeDirectoryInfo>, ()>
pub async fn test_connection(&self) -> bool
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for CacheLayer
impl Send for CacheLayer
impl Sync for CacheLayer
impl Unpin for CacheLayer
impl !UnwindSafe for CacheLayer
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> From<T> for T
impl<T> From<T> for T
const: unstable · sourcefn from(t: T) -> T
fn from(t: T) -> T
Returns the argument unchanged.
+
Struct kanidm_unix_common::cache::CacheLayer
source · [−]pub struct CacheLayer { /* private fields */ }Implementations
sourceimpl CacheLayer
impl CacheLayer
pub async fn new(
path: &str,
timeout_seconds: u64,
client: KanidmClient,
pam_allow_groups: Vec<String>,
default_shell: String,
home_prefix: String,
home_attr: HomeAttr,
home_alias: Option<HomeAttr>,
uid_attr_map: UidAttr,
gid_attr_map: UidAttr
) -> Result<Self, ()>
pub async fn attempt_online(&self)
pub async fn mark_offline(&self)
pub async fn clear_cache(&self) -> Result<(), ()>
pub async fn invalidate(&self) -> Result<(), ()>
pub async fn check_nxcache(&self, id: &Id) -> bool
pub async fn get_sshkeys(&self, account_id: &str) -> Result<Vec<String>, ()>
pub async fn get_nssaccounts(&self) -> Result<Vec<NssUser>, ()>
pub async fn get_nssaccount_name(
&self,
account_id: &str
) -> Result<Option<NssUser>, ()>
pub async fn get_nssaccount_gid(&self, gid: u32) -> Result<Option<NssUser>, ()>
pub async fn get_nssgroups(&self) -> Result<Vec<NssGroup>, ()>
pub async fn get_nssgroup_name(
&self,
grp_id: &str
) -> Result<Option<NssGroup>, ()>
pub async fn get_nssgroup_gid(&self, gid: u32) -> Result<Option<NssGroup>, ()>
pub async fn pam_account_allowed(
&self,
account_id: &str
) -> Result<Option<bool>, ()>
pub async fn pam_account_authenticate(
&self,
account_id: &str,
cred: &str
) -> Result<Option<bool>, ()>
pub async fn pam_account_beginsession(
&self,
account_id: &str
) -> Result<Option<HomeDirectoryInfo>, ()>
pub async fn test_connection(&self) -> bool
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for CacheLayer
impl Send for CacheLayer
impl Sync for CacheLayer
impl Unpin for CacheLayer
impl !UnwindSafe for CacheLayer
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T, U> Into<U> for Twhere
U: From<T>,
impl<T, U> Into<U> for Twhere
U: From<T>,
const: unstable · sourcefn into(self) -> U
fn into(self) -> U
Calls U::from(self).
Struct kanidmd_core::actors::v1_read::QueryServerReadV1
source · [−]pub struct QueryServerReadV1 { /* private fields */ }Implementations
sourceimpl QueryServerReadV1
impl QueryServerReadV1
pub fn new(idms: Arc<IdmServer>, ldap: Arc<LdapServer>) -> Self
pub fn start_static(idms: Arc<IdmServer>, ldap: Arc<LdapServer>) -> &'static Self
pub async fn handle_search(
&self,
uat: Option<String>,
req: SearchRequest,
eventid: Uuid
) -> Result<SearchResponse, OperationError>
pub async fn handle_auth(
&self,
sessionid: Option<Uuid>,
req: AuthRequest,
eventid: Uuid
) -> Result<AuthResult, OperationError>
pub async fn handle_online_backup(
&self,
msg: OnlineBackupEvent,
outpath: &str,
versions: usize
) -> Result<(), OperationError>
pub async fn handle_whoami(
&self,
uat: Option<String>,
eventid: Uuid
) -> Result<WhoamiResponse, OperationError>
pub async fn handle_whoami_uat(
&self,
uat: Option<String>,
eventid: Uuid
) -> Result<UserAuthToken, OperationError>
pub async fn handle_internalsearch(
&self,
uat: Option<String>,
filter: Filter<FilterInvalid>,
attrs: Option<Vec<String>>,
eventid: Uuid
) -> Result<Vec<ProtoEntry>, OperationError>
pub async fn handle_internalsearchrecycled(
&self,
uat: Option<String>,
filter: Filter<FilterInvalid>,
attrs: Option<Vec<String>>,
eventid: Uuid
) -> Result<Vec<ProtoEntry>, OperationError>
pub async fn handle_internalradiusread(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<Option<String>, OperationError>
pub async fn handle_internalradiustokenread(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<RadiusAuthToken, OperationError>
pub async fn handle_internalunixusertokenread(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<UnixUserToken, OperationError>
pub async fn handle_internalunixgrouptokenread(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<UnixGroupToken, OperationError>
pub async fn handle_internalsshkeyread(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<Vec<String>, OperationError>
pub async fn handle_internalsshkeytagread(
&self,
uat: Option<String>,
uuid_or_name: String,
tag: String,
eventid: Uuid
) -> Result<Option<String>, OperationError>
pub async fn handle_service_account_api_token_get(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<Vec<ApiToken>, OperationError>
pub async fn handle_account_user_auth_token_get(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<Vec<UatStatus>, OperationError>
pub async fn handle_idmaccountunixauth(
&self,
uat: Option<String>,
uuid_or_name: String,
cred: String,
eventid: Uuid
) -> Result<Option<UnixUserToken>, OperationError>
pub async fn handle_idmcredentialstatus(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<CredentialStatus, OperationError>
pub async fn handle_idmbackupcodeview(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<BackupCodesView, OperationError>
pub async fn handle_idmcredentialupdatestatus(
&self,
session_token: CUSessionToken,
eventid: Uuid
) -> Result<CUStatus, OperationError>
pub async fn handle_idmcredentialupdate(
&self,
session_token: CUSessionToken,
scr: CURequest,
eventid: Uuid
) -> Result<CUStatus, OperationError>
pub async fn handle_oauth2_basic_secret_read(
&self,
uat: Option<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<Option<String>, OperationError>
pub async fn handle_oauth2_token_exchange(
&self,
client_authz: Option<String>,
token_req: AccessTokenRequest,
eventid: Uuid
) -> Result<AccessTokenResponse, Oauth2Error>
pub async fn handle_oauth2_token_introspect(
&self,
client_authz: String,
intr_req: AccessTokenIntrospectRequest,
eventid: Uuid
) -> Result<AccessTokenIntrospectResponse, Oauth2Error>
pub async fn handle_oauth2_openid_userinfo(
&self,
client_id: String,
client_authz: String,
eventid: Uuid
) -> Result<OidcToken, Oauth2Error>
pub async fn handle_oauth2_openid_discovery(
&self,
client_id: String,
eventid: Uuid
) -> Result<OidcDiscoveryResponse, OperationError>
pub async fn handle_oauth2_openid_publickey(
&self,
client_id: String,
eventid: Uuid
) -> Result<JwkKeySet, OperationError>
pub async fn handle_list_applinks(
&self,
uat: Option<String>,
eventid: Uuid
) -> Result<Vec<AppLink>, OperationError>
pub async fn get_domain_display_name(&self, eventid: Uuid) -> String
pub async fn handle_auth_valid(
&self,
uat: Option<String>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_ldaprequest(
&self,
eventid: Uuid,
protomsg: LdapMsg,
uat: Option<LdapBoundToken>
) -> Option<LdapResponseState>
sourceimpl QueryServerReadV1
impl QueryServerReadV1
pub async fn handle_scim_sync_status(
&self,
bearer: Option<String>,
eventid: Uuid
) -> Result<ScimSyncState, OperationError>
Auto Trait Implementations
impl !RefUnwindSafe for QueryServerReadV1
impl Send for QueryServerReadV1
impl Sync for QueryServerReadV1
impl Unpin for QueryServerReadV1
impl !UnwindSafe for QueryServerReadV1
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> From<T> for T
impl<T> From<T> for T
const: unstable · sourcefn from(t: T) -> T
fn from(t: T) -> T
Returns the argument unchanged.
+Struct kanidmd_core::actors::v1_read::QueryServerReadV1
source · [−]pub struct QueryServerReadV1 { /* private fields */ }Implementations
sourceimpl QueryServerReadV1
impl QueryServerReadV1
pub fn new(idms: Arc<IdmServer>, ldap: Arc<LdapServer>) -> Self
pub fn start_static(idms: Arc<IdmServer>, ldap: Arc<LdapServer>) -> &'static Self
pub async fn handle_search(
&self,
uat: Option<String>,
req: SearchRequest,
eventid: Uuid
) -> Result<SearchResponse, OperationError>
pub async fn handle_auth(
&self,
sessionid: Option<Uuid>,
req: AuthRequest,
eventid: Uuid
) -> Result<AuthResult, OperationError>
pub async fn handle_online_backup(
&self,
msg: OnlineBackupEvent,
outpath: &str,
versions: usize
) -> Result<(), OperationError>
pub async fn handle_whoami(
&self,
uat: Option<String>,
eventid: Uuid
) -> Result<WhoamiResponse, OperationError>
pub async fn handle_whoami_uat(
&self,
uat: Option<String>,
eventid: Uuid
) -> Result<UserAuthToken, OperationError>
pub async fn handle_internalsearch(
&self,
uat: Option<String>,
filter: Filter<FilterInvalid>,
attrs: Option<Vec<String>>,
eventid: Uuid
) -> Result<Vec<ProtoEntry>, OperationError>
pub async fn handle_internalsearchrecycled(
&self,
uat: Option<String>,
filter: Filter<FilterInvalid>,
attrs: Option<Vec<String>>,
eventid: Uuid
) -> Result<Vec<ProtoEntry>, OperationError>
pub async fn handle_internalradiusread(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<Option<String>, OperationError>
pub async fn handle_internalradiustokenread(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<RadiusAuthToken, OperationError>
pub async fn handle_internalunixusertokenread(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<UnixUserToken, OperationError>
pub async fn handle_internalunixgrouptokenread(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<UnixGroupToken, OperationError>
pub async fn handle_internalsshkeyread(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<Vec<String>, OperationError>
pub async fn handle_internalsshkeytagread(
&self,
uat: Option<String>,
uuid_or_name: String,
tag: String,
eventid: Uuid
) -> Result<Option<String>, OperationError>
pub async fn handle_service_account_api_token_get(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<Vec<ApiToken>, OperationError>
pub async fn handle_account_user_auth_token_get(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<Vec<UatStatus>, OperationError>
pub async fn handle_idmaccountunixauth(
&self,
uat: Option<String>,
uuid_or_name: String,
cred: String,
eventid: Uuid
) -> Result<Option<UnixUserToken>, OperationError>
pub async fn handle_idmcredentialstatus(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<CredentialStatus, OperationError>
pub async fn handle_idmbackupcodeview(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<BackupCodesView, OperationError>
pub async fn handle_idmcredentialupdatestatus(
&self,
session_token: CUSessionToken,
eventid: Uuid
) -> Result<CUStatus, OperationError>
pub async fn handle_idmcredentialupdate(
&self,
session_token: CUSessionToken,
scr: CURequest,
eventid: Uuid
) -> Result<CUStatus, OperationError>
pub async fn handle_oauth2_basic_secret_read(
&self,
uat: Option<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<Option<String>, OperationError>
pub async fn handle_oauth2_token_exchange(
&self,
client_authz: Option<String>,
token_req: AccessTokenRequest,
eventid: Uuid
) -> Result<AccessTokenResponse, Oauth2Error>
pub async fn handle_oauth2_token_introspect(
&self,
client_authz: String,
intr_req: AccessTokenIntrospectRequest,
eventid: Uuid
) -> Result<AccessTokenIntrospectResponse, Oauth2Error>
pub async fn handle_oauth2_openid_userinfo(
&self,
client_id: String,
client_authz: String,
eventid: Uuid
) -> Result<OidcToken, Oauth2Error>
pub async fn handle_oauth2_openid_discovery(
&self,
client_id: String,
eventid: Uuid
) -> Result<OidcDiscoveryResponse, OperationError>
pub async fn handle_oauth2_openid_publickey(
&self,
client_id: String,
eventid: Uuid
) -> Result<JwkKeySet, OperationError>
pub async fn handle_list_applinks(
&self,
uat: Option<String>,
eventid: Uuid
) -> Result<Vec<AppLink>, OperationError>
pub async fn get_domain_display_name(&self, eventid: Uuid) -> String
pub async fn handle_auth_valid(
&self,
uat: Option<String>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_ldaprequest(
&self,
eventid: Uuid,
protomsg: LdapMsg,
uat: Option<LdapBoundToken>
) -> Option<LdapResponseState>
sourceimpl QueryServerReadV1
impl QueryServerReadV1
pub async fn handle_scim_sync_status(
&self,
bearer: Option<String>,
eventid: Uuid
) -> Result<ScimSyncState, OperationError>
Auto Trait Implementations
impl !RefUnwindSafe for QueryServerReadV1
impl Send for QueryServerReadV1
impl Sync for QueryServerReadV1
impl Unpin for QueryServerReadV1
impl !UnwindSafe for QueryServerReadV1
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T, U> Into<U> for Twhere
U: From<T>,
impl<T, U> Into<U> for Twhere
U: From<T>,
const: unstable · sourcefn into(self) -> U
fn into(self) -> U
Calls U::from(self).
Struct kanidmd_core::actors::v1_write::QueryServerWriteV1
source · [−]pub struct QueryServerWriteV1 { /* private fields */ }Implementations
sourceimpl QueryServerWriteV1
impl QueryServerWriteV1
pub async fn handle_sync_account_token_generate(
&self,
uat: Option<String>,
uuid_or_name: String,
label: String,
eventid: Uuid
) -> Result<String, OperationError>
pub async fn handle_sync_account_token_destroy(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_scim_sync_apply(
&self,
bearer: Option<String>,
changes: ScimSyncRequest,
eventid: Uuid
) -> Result<(), OperationError>
sourceimpl QueryServerWriteV1
impl QueryServerWriteV1
pub fn new(idms: Arc<IdmServer>) -> Self
pub fn start_static(idms: Arc<IdmServer>) -> &'static QueryServerWriteV1
pub async fn handle_create(
&self,
uat: Option<String>,
req: CreateRequest,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_modify(
&self,
uat: Option<String>,
req: ModifyRequest,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_delete(
&self,
uat: Option<String>,
req: DeleteRequest,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_internalpatch(
&self,
uat: Option<String>,
filter: Filter<FilterInvalid>,
update: ProtoEntry,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_internaldelete(
&self,
uat: Option<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_reviverecycled(
&self,
uat: Option<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_service_account_credential_generate(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<String, OperationError>
pub async fn handle_service_account_api_token_generate(
&self,
uat: Option<String>,
uuid_or_name: String,
label: String,
expiry: Option<OffsetDateTime>,
read_write: bool,
eventid: Uuid
) -> Result<String, OperationError>
pub async fn handle_service_account_api_token_destroy(
&self,
uat: Option<String>,
uuid_or_name: String,
token_id: Uuid,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_account_user_auth_token_destroy(
&self,
uat: Option<String>,
uuid_or_name: String,
token_id: Uuid,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_logout(
&self,
uat: Option<String>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_idmcredentialupdate(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<(CUSessionToken, CUStatus), OperationError>
pub async fn handle_idmcredentialupdateintent(
&self,
uat: Option<String>,
uuid_or_name: String,
ttl: Option<Duration>,
eventid: Uuid
) -> Result<CUIntentToken, OperationError>
pub async fn handle_idmcredentialexchangeintent(
&self,
intent_token: CUIntentToken,
eventid: Uuid
) -> Result<(CUSessionToken, CUStatus), OperationError>
pub async fn handle_idmcredentialupdatecommit(
&self,
session_token: CUSessionToken,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_idmcredentialupdatecancel(
&self,
session_token: CUSessionToken,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_service_account_into_person(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_regenerateradius(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<String, OperationError>
pub async fn handle_purgeattribute(
&self,
uat: Option<String>,
uuid_or_name: String,
attr: String,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_removeattributevalues(
&self,
uat: Option<String>,
uuid_or_name: String,
attr: String,
values: Vec<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_appendattribute(
&self,
uat: Option<String>,
uuid_or_name: String,
attr: String,
values: Vec<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_setattribute(
&self,
uat: Option<String>,
uuid_or_name: String,
attr: String,
values: Vec<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_sshkeycreate(
&self,
uat: Option<String>,
uuid_or_name: String,
tag: String,
key: String,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_idmaccountunixextend(
&self,
uat: Option<String>,
uuid_or_name: String,
ux: AccountUnixExtend,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_idmgroupunixextend(
&self,
uat: Option<String>,
uuid_or_name: String,
gx: GroupUnixExtend,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_idmaccountunixsetcred(
&self,
uat: Option<String>,
uuid_or_name: String,
cred: String,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_oauth2_scopemap_update(
&self,
uat: Option<String>,
group: String,
scopes: Vec<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_oauth2_scopemap_delete(
&self,
uat: Option<String>,
group: String,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_oauth2_sup_scopemap_update(
&self,
uat: Option<String>,
group: String,
scopes: Vec<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_oauth2_sup_scopemap_delete(
&self,
uat: Option<String>,
group: String,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_oauth2_token_revoke(
&self,
client_authz: String,
intr_req: TokenRevokeRequest,
eventid: Uuid
) -> Result<(), Oauth2Error>
pub async fn handle_purgetombstoneevent(&self, msg: PurgeTombstoneEvent)
pub async fn handle_purgerecycledevent(&self, msg: PurgeRecycledEvent)
Auto Trait Implementations
impl !RefUnwindSafe for QueryServerWriteV1
impl Send for QueryServerWriteV1
impl Sync for QueryServerWriteV1
impl Unpin for QueryServerWriteV1
impl !UnwindSafe for QueryServerWriteV1
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> From<T> for T
impl<T> From<T> for T
const: unstable · sourcefn from(t: T) -> T
fn from(t: T) -> T
Returns the argument unchanged.
+Struct kanidmd_core::actors::v1_write::QueryServerWriteV1
source · [−]pub struct QueryServerWriteV1 { /* private fields */ }Implementations
sourceimpl QueryServerWriteV1
impl QueryServerWriteV1
pub async fn handle_sync_account_token_generate(
&self,
uat: Option<String>,
uuid_or_name: String,
label: String,
eventid: Uuid
) -> Result<String, OperationError>
pub async fn handle_sync_account_token_destroy(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_scim_sync_apply(
&self,
bearer: Option<String>,
changes: ScimSyncRequest,
eventid: Uuid
) -> Result<(), OperationError>
sourceimpl QueryServerWriteV1
impl QueryServerWriteV1
pub fn new(idms: Arc<IdmServer>) -> Self
pub fn start_static(idms: Arc<IdmServer>) -> &'static QueryServerWriteV1
pub async fn handle_create(
&self,
uat: Option<String>,
req: CreateRequest,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_modify(
&self,
uat: Option<String>,
req: ModifyRequest,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_delete(
&self,
uat: Option<String>,
req: DeleteRequest,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_internalpatch(
&self,
uat: Option<String>,
filter: Filter<FilterInvalid>,
update: ProtoEntry,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_internaldelete(
&self,
uat: Option<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_reviverecycled(
&self,
uat: Option<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_service_account_credential_generate(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<String, OperationError>
pub async fn handle_service_account_api_token_generate(
&self,
uat: Option<String>,
uuid_or_name: String,
label: String,
expiry: Option<OffsetDateTime>,
read_write: bool,
eventid: Uuid
) -> Result<String, OperationError>
pub async fn handle_service_account_api_token_destroy(
&self,
uat: Option<String>,
uuid_or_name: String,
token_id: Uuid,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_account_user_auth_token_destroy(
&self,
uat: Option<String>,
uuid_or_name: String,
token_id: Uuid,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_logout(
&self,
uat: Option<String>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_idmcredentialupdate(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<(CUSessionToken, CUStatus), OperationError>
pub async fn handle_idmcredentialupdateintent(
&self,
uat: Option<String>,
uuid_or_name: String,
ttl: Option<Duration>,
eventid: Uuid
) -> Result<CUIntentToken, OperationError>
pub async fn handle_idmcredentialexchangeintent(
&self,
intent_token: CUIntentToken,
eventid: Uuid
) -> Result<(CUSessionToken, CUStatus), OperationError>
pub async fn handle_idmcredentialupdatecommit(
&self,
session_token: CUSessionToken,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_idmcredentialupdatecancel(
&self,
session_token: CUSessionToken,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_service_account_into_person(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_regenerateradius(
&self,
uat: Option<String>,
uuid_or_name: String,
eventid: Uuid
) -> Result<String, OperationError>
pub async fn handle_purgeattribute(
&self,
uat: Option<String>,
uuid_or_name: String,
attr: String,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_removeattributevalues(
&self,
uat: Option<String>,
uuid_or_name: String,
attr: String,
values: Vec<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_appendattribute(
&self,
uat: Option<String>,
uuid_or_name: String,
attr: String,
values: Vec<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_setattribute(
&self,
uat: Option<String>,
uuid_or_name: String,
attr: String,
values: Vec<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_sshkeycreate(
&self,
uat: Option<String>,
uuid_or_name: String,
tag: String,
key: String,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_idmaccountunixextend(
&self,
uat: Option<String>,
uuid_or_name: String,
ux: AccountUnixExtend,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_idmgroupunixextend(
&self,
uat: Option<String>,
uuid_or_name: String,
gx: GroupUnixExtend,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_idmaccountunixsetcred(
&self,
uat: Option<String>,
uuid_or_name: String,
cred: String,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_oauth2_scopemap_update(
&self,
uat: Option<String>,
group: String,
scopes: Vec<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_oauth2_scopemap_delete(
&self,
uat: Option<String>,
group: String,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_oauth2_sup_scopemap_update(
&self,
uat: Option<String>,
group: String,
scopes: Vec<String>,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_oauth2_sup_scopemap_delete(
&self,
uat: Option<String>,
group: String,
filter: Filter<FilterInvalid>,
eventid: Uuid
) -> Result<(), OperationError>
pub async fn handle_oauth2_token_revoke(
&self,
client_authz: String,
intr_req: TokenRevokeRequest,
eventid: Uuid
) -> Result<(), Oauth2Error>
pub async fn handle_purgetombstoneevent(&self, msg: PurgeTombstoneEvent)
pub async fn handle_purgerecycledevent(&self, msg: PurgeRecycledEvent)
Auto Trait Implementations
impl !RefUnwindSafe for QueryServerWriteV1
impl Send for QueryServerWriteV1
impl Sync for QueryServerWriteV1
impl Unpin for QueryServerWriteV1
impl !UnwindSafe for QueryServerWriteV1
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T, U> Into<U> for Twhere
U: From<T>,
impl<T, U> Into<U> for Twhere
U: From<T>,
const: unstable · sourcefn into(self) -> U
fn into(self) -> U
Calls U::from(self).
Function kanidmd_core::https::create_https_server
source · [−]pub fn create_https_server(
address: String,
opt_tls_params: Option<&TlsConfiguration>,
role: ServerRole,
trust_x_forward_for: bool,
cookie_key: &[u8; 32],
jws_signer: JwsSigner,
status_ref: &'static StatusActor,
qe_w_ref: &'static QueryServerWriteV1,
qe_r_ref: &'static QueryServerReadV1,
rx: Receiver<CoreAction>
) -> Result<JoinHandle<()>, ()>Function kanidmd_core::https::create_https_server
source · [−]pub fn create_https_server(
address: String,
opt_tls_params: Option<&TlsConfiguration>,
role: ServerRole,
trust_x_forward_for: bool,
cookie_key: &[u8; 32],
jws_signer: JwsSigner,
status_ref: &'static StatusActor,
qe_w_ref: &'static QueryServerWriteV1,
qe_r_ref: &'static QueryServerReadV1,
rx: Receiver<CoreAction>
) -> Result<JoinHandle<()>, ()>Struct kanidmd_core::https::AppState
source · [−]pub struct AppState {
- pub status_ref: &'static StatusActor,
+ pub status_ref: &'static StatusActor,
pub qe_w_ref: &'static QueryServerWriteV1,
pub qe_r_ref: &'static QueryServerReadV1,
pub jws_signer: Arc<JwsSigner>,
pub jws_validator: Arc<JwsValidator>,
pub js_files: Vec<JavaScriptFile>,
-}Fields
status_ref: &'static StatusActorqe_w_ref: &'static QueryServerWriteV1qe_r_ref: &'static QueryServerReadV1jws_signer: Arc<JwsSigner>jws_validator: Arc<JwsValidator>js_files: Vec<JavaScriptFile>The SHA384 hashes of javascript files we’re going to serve to users
+}Fields
status_ref: &'static StatusActorqe_w_ref: &'static QueryServerWriteV1qe_r_ref: &'static QueryServerReadV1jws_signer: Arc<JwsSigner>jws_validator: Arc<JwsValidator>js_files: Vec<JavaScriptFile>The SHA384 hashes of javascript files we’re going to serve to users
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for AppState
impl Send for AppState
impl Sync for AppState
impl Unpin for AppState
impl !UnwindSafe for AppState
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Instruments this type with the current setup_async_test in kanidmd_testkit - Rust 
Function kanidmd_testkit::
source · [−]setup_async_test in kanidmd_testkit - Rust Function kanidmd_testkit::
source · [−]Rustdoc settings 
Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings Rustdoc settings
Span, returning an
diff --git a/docs/master/rustdoc/kanidmd_testkit/fn.setup_async_test.html b/docs/master/rustdoc/kanidmd_testkit/fn.setup_async_test.html
index 7a4abc2b7..56c6d5cb9 100644
--- a/docs/master/rustdoc/kanidmd_testkit/fn.setup_async_test.html
+++ b/docs/master/rustdoc/kanidmd_testkit/fn.setup_async_test.html
@@ -1 +1 @@
-Function kanidmd_testkit::setup_async_test
source · [−]pub async fn setup_async_test() -> (KanidmClient, CoreHandle)Function kanidmd_testkit::setup_async_test
source · [−]pub async fn setup_async_test() -> (KanidmClient, CoreHandle)Rustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
BackRustdoc settings
Back