Trait DatahubClientTrait 

pub trait DatahubClientTrait {
    // Required methods
    fn list_project<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = DHResult<ListProjectResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn create_project<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        comment: &'life2 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn get_project<'life0, 'life1, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<GetProjectResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn update_project<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        comment: &'life2 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn delete_project<'life0, 'life1, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn create_topic<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        create_topic_payload: &'life3 CreateTopicPayload<'_>,
    ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn get_topic<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<GetTopicResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn list_topic<'life0, 'life1, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<ListTopicResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn update_topic<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        comment: &'life3 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn delete_topic<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn append_filed<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        field_name: &'life3 str,
        field_type: FieldType,
    ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn list_shard<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<ListShardResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn split_shard<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        shard_id: &'life3 str,
        split_key: &'life4 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<SplitShardResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait,
             'life4: 'async_trait;
    fn merge_shard<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        shard_id: &'life3 str,
        adjacent_shard_id: &'life4 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<MergeShardResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait,
             'life4: 'async_trait;
    fn get_cursor<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        shard_id: &'life3 str,
        cursor_type: CursorType,
        parameter: i64,
    ) -> Pin<Box<dyn Future<Output = DHResult<QueryCursorResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn write_data<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        write_data_payload: &'life3 WriteDataPayload<'_>,
    ) -> Pin<Box<dyn Future<Output = DHResult<WriteDataResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn read_data<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        shard_id: &'life3 str,
        read_data_payload: &'life4 ReadDataPayload<'_>,
    ) -> Pin<Box<dyn Future<Output = DHResult<ReadDataResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait,
             'life4: 'async_trait;
    fn create_subscriptions<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        comment: &'life3 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<CreateSubscriptionRes>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn get_subscription<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        sub_id: &'life3 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<GetSubscriptionRes>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn list_subscriptions<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        page_index: u32,
        page_size: u32,
    ) -> Pin<Box<dyn Future<Output = DHResult<ListSubscriptionRes>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn delete_subscription<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        sub_id: &'life3 str,
    ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn set_subscription_state<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        sub_id: &'life3 str,
        state: i32,
    ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn open_subscription_session<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        sub_id: &'life3 str,
        shard_ids: &'life4 [&'life5 str],
    ) -> Pin<Box<dyn Future<Output = DHResult<SubscriptionSessionOptRes>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait,
             'life4: 'async_trait,
             'life5: 'async_trait;
    fn get_subscription_offset<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        sub_id: &'life3 str,
        shard_ids: &'life4 [&'life5 str],
    ) -> Pin<Box<dyn Future<Output = DHResult<SubscriptionSessionOptRes>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait,
             'life4: 'async_trait,
             'life5: 'async_trait;
    fn commit_subscription_offset<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
        &'life0 mut self,
        project_name: &'life1 str,
        topic_name: &'life2 str,
        sub_id: &'life3 str,
        offset_map: &'life4 HashMap<String, SubscriptionOffset>,
    ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait,
             'life4: 'async_trait;
}

Required Methods

fn list_project<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = DHResult<ListProjectResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

查询Project列表

fn create_project<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, project_name: &'life1 str, comment: &'life2 str, ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

创建Project

fn get_project<'life0, 'life1, 'async_trait>( &'life0 mut self, project_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = DHResult<GetProjectResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

查询Project

fn update_project<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, project_name: &'life1 str, comment: &'life2 str, ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

更新Project

fn delete_project<'life0, 'life1, 'async_trait>( &'life0 mut self, project_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

删除Project

fn create_topic<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, create_topic_payload: &'life3 CreateTopicPayload<'_>, ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

创建Topic

fn get_topic<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = DHResult<GetTopicResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

查询Topic

fn list_topic<'life0, 'life1, 'async_trait>( &'life0 mut self, project_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = DHResult<ListTopicResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

查询Topic列表

fn update_topic<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, comment: &'life3 str, ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

更新Topic

fn delete_topic<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

删除Topic

fn append_filed<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, field_name: &'life3 str, field_type: FieldType, ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

新增Field

fn list_shard<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = DHResult<ListShardResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

获取Shard列表

fn split_shard<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, shard_id: &'life3 str, split_key: &'life4 str, ) -> Pin<Box<dyn Future<Output = DHResult<SplitShardResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

分裂Shard

fn merge_shard<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, shard_id: &'life3 str, adjacent_shard_id: &'life4 str, ) -> Pin<Box<dyn Future<Output = DHResult<MergeShardResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

合并Shard

fn get_cursor<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, shard_id: &'life3 str, cursor_type: CursorType, parameter: i64, ) -> Pin<Box<dyn Future<Output = DHResult<QueryCursorResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

查询数据Cursor

fn write_data<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, write_data_payload: &'life3 WriteDataPayload<'_>, ) -> Pin<Box<dyn Future<Output = DHResult<WriteDataResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

写入数据

fn read_data<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, shard_id: &'life3 str, read_data_payload: &'life4 ReadDataPayload<'_>, ) -> Pin<Box<dyn Future<Output = DHResult<ReadDataResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

读取数据

fn create_subscriptions<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, comment: &'life3 str, ) -> Pin<Box<dyn Future<Output = DHResult<CreateSubscriptionRes>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

创建订阅

fn get_subscription<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, sub_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = DHResult<GetSubscriptionRes>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

查询订阅

fn list_subscriptions<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, page_index: u32, page_size: u32, ) -> Pin<Box<dyn Future<Output = DHResult<ListSubscriptionRes>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

查询订阅列表

fn delete_subscription<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, sub_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

删除订阅

fn set_subscription_state<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, sub_id: &'life3 str, state: i32, ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

更新订阅状态

fn open_subscription_session<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, sub_id: &'life3 str, shard_ids: &'life4 [&'life5 str], ) -> Pin<Box<dyn Future<Output = DHResult<SubscriptionSessionOptRes>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

open点位session

fn get_subscription_offset<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, sub_id: &'life3 str, shard_ids: &'life4 [&'life5 str], ) -> Pin<Box<dyn Future<Output = DHResult<SubscriptionSessionOptRes>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

查询点位

fn commit_subscription_offset<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 mut self, project_name: &'life1 str, topic_name: &'life2 str, sub_id: &'life3 str, offset_map: &'life4 HashMap<String, SubscriptionOffset>, ) -> Pin<Box<dyn Future<Output = DHResult<EmptyResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

提交点位

Implementors

impl DatahubClientTrait for DatahubJsonClient