Struct kanidm::actors::v1_write::QueryServerWriteV1

pub struct QueryServerWriteV1 { /* private fields */ }

Implementations

Auto Trait Implementations

Blanket Implementations

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Returns the argument unchanged.

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

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

Calls U::from(self).

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

The alignment of pointer.

The type for initializers.

Initializes a with the given initializer. Read more

Dereferences the given pointer. Read more

Mutably dereferences the given pointer. Read more

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

Should always be Self

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

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

Struct kanidm::actors::v1_write::QueryServerWriteV1

Implementations

impl QueryServerWriteV1

pub fn new(log_level: Option<u32>, idms: Arc<IdmServer>) -> Self

pub fn start_static( log_level: Option<u32>, 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_credentialset( &self, uat: Option<String>, uuid_or_name: String, sac: SetCredentialRequest, eventid: Uuid) -> Result<SetCredentialResponse, 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_idmaccountsetpassword( &self, uat: Option<String>, cleartext: 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_idmaccountpersonextend( &self, uat: Option<String>, uuid_or_name: String, px: AccountPersonSet, eventid: Uuid) -> Result<(), OperationError>

pub async fn handle_idmaccountpersonset( &self, uat: Option<String>, uuid_or_name: String, px: AccountPersonSet, 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_create( &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>

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

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

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

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> Pointable for T

const ALIGN: usize = mem::align_of::()

type Init = T

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

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

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

unsafe fn drop(ptr: usize)

impl<T> Same<T> for T

type Output = T

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

type Error = Infallible

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

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

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

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

impl<V, T> VZip<V> for T where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

pub fn start_static(
log_level: Option<u32>,
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_credentialset(
&self,
uat: Option<String>,
uuid_or_name: String,
sac: SetCredentialRequest,
eventid: Uuid
) -> Result<SetCredentialResponse, 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_idmaccountsetpassword(
&self,
uat: Option<String>,
cleartext: 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_idmaccountpersonextend(
&self,
uat: Option<String>,
uuid_or_name: String,
px: AccountPersonSet,
eventid: Uuid
) -> Result<(), OperationError>

pub async fn handle_idmaccountpersonset(
&self,
uat: Option<String>,
uuid_or_name: String,
px: AccountPersonSet,
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_create(
&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>

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

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

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

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

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

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

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

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