pub trait OffsetAdmin: Send {
Show 19 methods
// Required methods
async fn reset_offset_by_timestamp_old(
&self,
cluster_name: Option<CheetahString>,
consumer_group: CheetahString,
topic: CheetahString,
timestamp: u64,
force: bool,
) -> ClientResult<Vec<RollbackStats>>;
async fn reset_offset_by_timestamp(
&self,
cluster_name: Option<CheetahString>,
topic: CheetahString,
group: CheetahString,
timestamp: u64,
is_force: bool,
) -> ClientResult<HashMap<MessageQueue, u64>>;
async fn reset_offset_new(
&self,
consumer_group: CheetahString,
topic: CheetahString,
timestamp: u64,
) -> ClientResult<()>;
async fn reset_offset_new_concurrent(
&self,
group: CheetahString,
topic: CheetahString,
timestamp: u64,
) -> AdminToolResult<BrokerOperatorResult>;
async fn query_consume_time_span(
&self,
topic: CheetahString,
group: CheetahString,
) -> ClientResult<Vec<QueueTimeSpan>>;
async fn query_consume_time_span_concurrent(
&self,
topic: CheetahString,
group: CheetahString,
) -> AdminToolResult<Vec<QueueTimeSpan>>;
async fn delete_expired_commit_log(
&self,
cluster: Option<CheetahString>,
addr: Option<CheetahString>,
) -> ClientResult<bool>;
async fn delete_expired_commit_log_by_addr(
&self,
addr: CheetahString,
) -> ClientResult<bool>;
async fn clone_group_offset(
&self,
src_group: CheetahString,
dest_group: CheetahString,
topic: CheetahString,
is_offline: bool,
) -> ClientResult<()>;
async fn update_consume_offset(
&self,
broker_addr: CheetahString,
consume_group: CheetahString,
mq: MessageQueue,
offset: u64,
) -> ClientResult<()>;
async fn reset_offset_by_queue_id(
&self,
broker_addr: CheetahString,
consumer_group: CheetahString,
topic_name: CheetahString,
queue_id: i32,
reset_offset: u64,
) -> ClientResult<()>;
async fn reset_master_flush_offset(
&self,
broker_addr: CheetahString,
master_flush_offset: u64,
) -> ClientResult<()>;
async fn set_commit_log_read_ahead_mode(
&self,
broker_addr: CheetahString,
mode: CheetahString,
) -> ClientResult<CheetahString>;
async fn update_lite_pull_consumer_offset(
&self,
addr: CheetahString,
topic: CheetahString,
group: CheetahString,
queue_id: i32,
offset: u64,
) -> ClientResult<()>;
async fn export_rocksdb_consumer_offset_to_json(
&self,
broker_addr: CheetahString,
file_path: CheetahString,
) -> ClientResult<()>;
async fn export_rocksdb_consumer_offset_from_memory(
&self,
broker_addr: CheetahString,
) -> ClientResult<CheetahString>;
async fn search_offset(
&self,
broker_addr: CheetahString,
topic_name: CheetahString,
queue_id: i32,
timestamp: u64,
timeout_millis: u64,
) -> ClientResult<u64>;
async fn min_offset(
&self,
broker_addr: CheetahString,
message_queue: MessageQueue,
timeout_millis: u64,
) -> ClientResult<i64>;
async fn max_offset(
&self,
broker_addr: CheetahString,
message_queue: MessageQueue,
timeout_millis: u64,
) -> ClientResult<i64>;
}Required Methods§
async fn reset_offset_by_timestamp_old( &self, cluster_name: Option<CheetahString>, consumer_group: CheetahString, topic: CheetahString, timestamp: u64, force: bool, ) -> ClientResult<Vec<RollbackStats>>
async fn reset_offset_by_timestamp( &self, cluster_name: Option<CheetahString>, topic: CheetahString, group: CheetahString, timestamp: u64, is_force: bool, ) -> ClientResult<HashMap<MessageQueue, u64>>
async fn reset_offset_new( &self, consumer_group: CheetahString, topic: CheetahString, timestamp: u64, ) -> ClientResult<()>
async fn reset_offset_new_concurrent( &self, group: CheetahString, topic: CheetahString, timestamp: u64, ) -> AdminToolResult<BrokerOperatorResult>
async fn query_consume_time_span( &self, topic: CheetahString, group: CheetahString, ) -> ClientResult<Vec<QueueTimeSpan>>
async fn query_consume_time_span_concurrent( &self, topic: CheetahString, group: CheetahString, ) -> AdminToolResult<Vec<QueueTimeSpan>>
async fn delete_expired_commit_log( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> ClientResult<bool>
async fn delete_expired_commit_log_by_addr( &self, addr: CheetahString, ) -> ClientResult<bool>
async fn clone_group_offset( &self, src_group: CheetahString, dest_group: CheetahString, topic: CheetahString, is_offline: bool, ) -> ClientResult<()>
async fn update_consume_offset( &self, broker_addr: CheetahString, consume_group: CheetahString, mq: MessageQueue, offset: u64, ) -> ClientResult<()>
async fn reset_offset_by_queue_id( &self, broker_addr: CheetahString, consumer_group: CheetahString, topic_name: CheetahString, queue_id: i32, reset_offset: u64, ) -> ClientResult<()>
async fn reset_master_flush_offset( &self, broker_addr: CheetahString, master_flush_offset: u64, ) -> ClientResult<()>
async fn set_commit_log_read_ahead_mode( &self, broker_addr: CheetahString, mode: CheetahString, ) -> ClientResult<CheetahString>
async fn update_lite_pull_consumer_offset( &self, addr: CheetahString, topic: CheetahString, group: CheetahString, queue_id: i32, offset: u64, ) -> ClientResult<()>
async fn export_rocksdb_consumer_offset_to_json( &self, broker_addr: CheetahString, file_path: CheetahString, ) -> ClientResult<()>
async fn export_rocksdb_consumer_offset_from_memory( &self, broker_addr: CheetahString, ) -> ClientResult<CheetahString>
async fn search_offset( &self, broker_addr: CheetahString, topic_name: CheetahString, queue_id: i32, timestamp: u64, timeout_millis: u64, ) -> ClientResult<u64>
async fn min_offset( &self, broker_addr: CheetahString, message_queue: MessageQueue, timeout_millis: u64, ) -> ClientResult<i64>
async fn max_offset( &self, broker_addr: CheetahString, message_queue: MessageQueue, timeout_millis: u64, ) -> ClientResult<i64>
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".