Trait AuthAdmin 

pub trait AuthAdmin: Send {
    // Required methods
    async fn create_and_update_plain_access_config(
        &self,
        addr: CheetahString,
        config: PlainAccessConfig,
    ) -> ClientResult<()>;
    async fn delete_plain_access_config(
        &self,
        addr: CheetahString,
        access_key: CheetahString,
    ) -> ClientResult<()>;
    async fn update_global_white_addr_config(
        &self,
        addr: CheetahString,
        global_white_addrs: CheetahString,
        acl_file_full_path: Option<CheetahString>,
    ) -> ClientResult<()>;
    async fn examine_broker_cluster_acl_version_info(
        &self,
        addr: CheetahString,
    ) -> ClientResult<CheetahString>;
    async fn get_user_subscription_group(
        &self,
        broker_addr: CheetahString,
        timeout_millis: u64,
    ) -> ClientResult<SubscriptionGroupWrapper>;
    async fn get_user_topic_config(
        &self,
        broker_addr: CheetahString,
        special_topic: bool,
        timeout_millis: u64,
    ) -> ClientResult<TopicConfigSerializeWrapper>;
    async fn create_user(
        &self,
        broker_addr: CheetahString,
        username: CheetahString,
        password: CheetahString,
        user_type: CheetahString,
    ) -> ClientResult<()>;
    async fn create_user_with_info(
        &self,
        broker_addr: CheetahString,
        username: CheetahString,
        password: CheetahString,
    ) -> ClientResult<()>;
    async fn update_user(
        &self,
        broker_addr: CheetahString,
        username: CheetahString,
        password: CheetahString,
        user_type: CheetahString,
        user_status: CheetahString,
    ) -> ClientResult<()>;
    async fn update_user_with_info(
        &self,
        broker_addr: CheetahString,
        username: CheetahString,
        password: CheetahString,
    ) -> ClientResult<()>;
    async fn delete_user(
        &self,
        broker_addr: CheetahString,
        username: CheetahString,
    ) -> ClientResult<()>;
    async fn get_user(
        &self,
        broker_addr: CheetahString,
        username: CheetahString,
    ) -> ClientResult<Option<UserInfo>>;
    async fn list_users(
        &self,
        broker_addr: CheetahString,
        filter: CheetahString,
    ) -> ClientResult<Vec<UserInfo>>;
    async fn create_acl(
        &self,
        broker_addr: CheetahString,
        subject: CheetahString,
        resources: Vec<CheetahString>,
        actions: Vec<CheetahString>,
        source_ips: Vec<CheetahString>,
        decision: CheetahString,
    ) -> ClientResult<()>;
    async fn create_acl_with_info(
        &self,
        broker_addr: CheetahString,
        subject: CheetahString,
    ) -> ClientResult<()>;
    async fn update_acl(
        &self,
        broker_addr: CheetahString,
        subject: CheetahString,
        resources: Vec<CheetahString>,
        actions: Vec<CheetahString>,
        source_ips: Vec<CheetahString>,
        decision: CheetahString,
    ) -> ClientResult<()>;
    async fn update_acl_with_info(
        &self,
        broker_addr: CheetahString,
        subject: CheetahString,
    ) -> ClientResult<()>;
    async fn delete_acl(
        &self,
        broker_addr: CheetahString,
        subject: CheetahString,
        resource: CheetahString,
    ) -> ClientResult<()>;
    async fn get_acl(
        &self,
        broker_addr: CheetahString,
        subject: CheetahString,
    ) -> ClientResult<AclInfo>;
    async fn list_acl(
        &self,
        broker_addr: CheetahString,
        subject_filter: CheetahString,
        resource_filter: CheetahString,
    ) -> ClientResult<Vec<AclInfo>>;

    // Provided methods
    async fn list_user(
        &self,
        broker_addr: CheetahString,
        filter: CheetahString,
    ) -> ClientResult<Vec<UserInfo>> { ... }
    async fn delete_acl_entry(
        &self,
        broker_addr: CheetahString,
        subject: CheetahString,
        policy_type: CheetahString,
        resource: CheetahString,
    ) -> ClientResult<()> { ... }
}

Required Methods

async fn create_and_update_plain_access_config( &self, addr: CheetahString, config: PlainAccessConfig, ) -> ClientResult<()>

async fn delete_plain_access_config( &self, addr: CheetahString, access_key: CheetahString, ) -> ClientResult<()>

async fn update_global_white_addr_config( &self, addr: CheetahString, global_white_addrs: CheetahString, acl_file_full_path: Option<CheetahString>, ) -> ClientResult<()>

async fn examine_broker_cluster_acl_version_info( &self, addr: CheetahString, ) -> ClientResult<CheetahString>

async fn get_user_subscription_group( &self, broker_addr: CheetahString, timeout_millis: u64, ) -> ClientResult<SubscriptionGroupWrapper>

async fn get_user_topic_config( &self, broker_addr: CheetahString, special_topic: bool, timeout_millis: u64, ) -> ClientResult<TopicConfigSerializeWrapper>

async fn create_user( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, user_type: CheetahString, ) -> ClientResult<()>

async fn create_user_with_info( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, ) -> ClientResult<()>

async fn update_user( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, user_type: CheetahString, user_status: CheetahString, ) -> ClientResult<()>

async fn update_user_with_info( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, ) -> ClientResult<()>

async fn delete_user( &self, broker_addr: CheetahString, username: CheetahString, ) -> ClientResult<()>

async fn get_user( &self, broker_addr: CheetahString, username: CheetahString, ) -> ClientResult<Option<UserInfo>>

async fn list_users( &self, broker_addr: CheetahString, filter: CheetahString, ) -> ClientResult<Vec<UserInfo>>

async fn create_acl( &self, broker_addr: CheetahString, subject: CheetahString, resources: Vec<CheetahString>, actions: Vec<CheetahString>, source_ips: Vec<CheetahString>, decision: CheetahString, ) -> ClientResult<()>

async fn create_acl_with_info( &self, broker_addr: CheetahString, subject: CheetahString, ) -> ClientResult<()>

async fn update_acl( &self, broker_addr: CheetahString, subject: CheetahString, resources: Vec<CheetahString>, actions: Vec<CheetahString>, source_ips: Vec<CheetahString>, decision: CheetahString, ) -> ClientResult<()>

async fn update_acl_with_info( &self, broker_addr: CheetahString, subject: CheetahString, ) -> ClientResult<()>

async fn delete_acl( &self, broker_addr: CheetahString, subject: CheetahString, resource: CheetahString, ) -> ClientResult<()>

async fn get_acl( &self, broker_addr: CheetahString, subject: CheetahString, ) -> ClientResult<AclInfo>

async fn list_acl( &self, broker_addr: CheetahString, subject_filter: CheetahString, resource_filter: CheetahString, ) -> ClientResult<Vec<AclInfo>>

Provided Methods

async fn list_user( &self, broker_addr: CheetahString, filter: CheetahString, ) -> ClientResult<Vec<UserInfo>>

async fn delete_acl_entry( &self, broker_addr: CheetahString, subject: CheetahString, policy_type: CheetahString, resource: CheetahString, ) -> ClientResult<()>

Deletes one resource from an explicitly selected ACL policy type.

Errors

Returns an error for empty identities, unsupported policy types, or failed RPCs. Implementations that only support the legacy API may reject this operation.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl AuthAdmin for DefaultMQAdminExt

impl AuthAdmin for DefaultMQAdminExtImpl