server/src/streaming/users/permissioner_rules/partitions.rs

use crate::streaming::users::permissioner::Permissioner;
use iggy::error::IggyError;

impl Permissioner {
    pub fn create_partitions(
        &self,
        user_id: u32,
        stream_id: u32,
        topic_id: u32,
    ) -> Result<(), IggyError> {
        self.update_topic(user_id, stream_id, topic_id)
    }

    pub fn delete_partitions(
        &self,
        user_id: u32,
        stream_id: u32,
        topic_id: u32,
    ) -> Result<(), IggyError> {
        self.update_topic(user_id, stream_id, topic_id)
    }
}