Struct RequestChannelService 

pub struct RequestChannelService { /* private fields */ }

A Service sending Requests over a RequestSender channel

Implementations

impl RequestChannelService

pub fn new(tx: RequestSender) -> Self

Trait Implementations

impl Clone for RequestChannelService

fn clone(&self) -> RequestChannelService

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RequestChannelService

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<State> Service<State, Request> for RequestChannelService

where State: Send + Sync + 'static,

type Response = Response

The type of response returned by the service.

type Error = ServiceError

The type of error returned by the service.

async fn serve( &self, ctx: Context<State>, req: Request, ) -> Result<Self::Response, Self::Error>

Serve a response or error for the given request, using the given context.

fn boxed(self) -> BoxService<S, Request, Self::Response, Self::Error>

Box this service to allow for dynamic dispatch.

impl Storage for RequestChannelService

fn register_broker<'life0, 'async_trait>( &'life0 self, broker_registration: BrokerRegistrationRequest, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

On startup a broker will register with storage.

fn incremental_alter_resource<'life0, 'async_trait>( &'life0 self, resource: AlterConfigsResource, ) -> Pin<Box<dyn Future<Output = Result<AlterConfigsResourceResponse>> + Send + 'async_trait>>

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

Incrementally alter a resource on this storage.

fn create_topic<'life0, 'async_trait>( &'life0 self, topic: CreatableTopic, validate_only: bool, ) -> Pin<Box<dyn Future<Output = Result<Uuid>> + Send + 'async_trait>>

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

Create a topic on this storage.

fn delete_records<'life0, 'life1, 'async_trait>( &'life0 self, topics: &'life1 [DeleteRecordsTopic], ) -> Pin<Box<dyn Future<Output = Result<Vec<DeleteRecordsTopicResult>>> + Send + 'async_trait>>

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

Delete records on this storage.

fn delete_topic<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 TopicId, ) -> Pin<Box<dyn Future<Output = Result<ErrorCode>> + Send + 'async_trait>>

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

Delete a topic from this storage.

fn brokers<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<DescribeClusterBroker>>> + Send + 'async_trait>>

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

Query the brokers registered with this storage.

fn produce<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, transaction_id: Option<&'life1 str>, topition: &'life2 Topition, batch: Batch, ) -> Pin<Box<dyn Future<Output = Result<i64>> + Send + 'async_trait>>

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

Produce a deflated batch to this storage.

fn fetch<'life0, 'life1, 'async_trait>( &'life0 self, topition: &'life1 Topition, offset: i64, min_bytes: u32, max_bytes: u32, isolation: IsolationLevel, ) -> Pin<Box<dyn Future<Output = Result<Vec<Batch>>> + Send + 'async_trait>>

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

Fetch deflated batches from storage.

fn offset_stage<'life0, 'life1, 'async_trait>( &'life0 self, topition: &'life1 Topition, ) -> Pin<Box<dyn Future<Output = Result<OffsetStage>> + Send + 'async_trait>>

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

Query the offset stage for a topic partition.

fn list_offsets<'life0, 'life1, 'async_trait>( &'life0 self, isolation_level: IsolationLevel, offsets: &'life1 [(Topition, ListOffset)], ) -> Pin<Box<dyn Future<Output = Result<Vec<(Topition, ListOffsetResponse)>>> + Send + 'async_trait>>

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

Query the offsets for one or more topic partitions.

fn offset_commit<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, group_id: &'life1 str, retention_time_ms: Option<Duration>, offsets: &'life2 [(Topition, OffsetCommitRequest)], ) -> Pin<Box<dyn Future<Output = Result<Vec<(Topition, ErrorCode)>>> + Send + 'async_trait>>

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

Commit offsets for one or more topic partitions in a consumer group.

fn committed_offset_topitions<'life0, 'life1, 'async_trait>( &'life0 self, group_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<BTreeMap<Topition, i64>>> + Send + 'async_trait>>

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

Fetch all committed offsets in a consumer group.

fn offset_fetch<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, group_id: Option<&'life1 str>, topics: &'life2 [Topition], require_stable: Option<bool>, ) -> Pin<Box<dyn Future<Output = Result<BTreeMap<Topition, i64>>> + Send + 'async_trait>>

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

Fetch committed offsets for one or more topic partitions in a consumer group.

fn metadata<'life0, 'life1, 'async_trait>( &'life0 self, topics: Option<&'life1 [TopicId]>, ) -> Pin<Box<dyn Future<Output = Result<MetadataResponse>> + Send + 'async_trait>>

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

Query broker and topic metadata.

fn describe_config<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, name: &'life1 str, resource: ConfigResource, keys: Option<&'life2 [String]>, ) -> Pin<Box<dyn Future<Output = Result<DescribeConfigsResult>> + Send + 'async_trait>>

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

Query the configuration of a resource in this storage.

fn describe_topic_partitions<'life0, 'life1, 'async_trait>( &'life0 self, topics: Option<&'life1 [TopicId]>, partition_limit: i32, cursor: Option<Topition>, ) -> Pin<Box<dyn Future<Output = Result<Vec<DescribeTopicPartitionsResponseTopic>>> + Send + 'async_trait>>

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

Describe the topic partitions found in this storage.

fn list_groups<'life0, 'life1, 'async_trait>( &'life0 self, states_filter: Option<&'life1 [String]>, ) -> Pin<Box<dyn Future<Output = Result<Vec<ListedGroup>>> + Send + 'async_trait>>

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

Query available groups optionally with a state filter.

fn delete_groups<'life0, 'life1, 'async_trait>( &'life0 self, group_ids: Option<&'life1 [String]>, ) -> Pin<Box<dyn Future<Output = Result<Vec<DeletableGroupResult>>> + Send + 'async_trait>>

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

Delete one or more groups from storage.

fn describe_groups<'life0, 'life1, 'async_trait>( &'life0 self, group_ids: Option<&'life1 [String]>, include_authorized_operations: bool, ) -> Pin<Box<dyn Future<Output = Result<Vec<NamedGroupDetail>>> + Send + 'async_trait>>

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

Describe the groups found in this storage.

fn update_group<'life0, 'life1, 'async_trait>( &'life0 self, group_id: &'life1 str, detail: GroupDetail, version: Option<Version>, ) -> Pin<Box<dyn Future<Output = Result<Version, UpdateError<GroupDetail>>> + Send + 'async_trait>>

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

Conditionally update the state of a group in this storage.

fn init_producer<'life0, 'life1, 'async_trait>( &'life0 self, transaction_id: Option<&'life1 str>, transaction_timeout_ms: i32, producer_id: Option<i64>, producer_epoch: Option<i16>, ) -> Pin<Box<dyn Future<Output = Result<ProducerIdResponse>> + Send + 'async_trait>>

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

Initialise a transactional or idempotent producer in this storage.

fn txn_add_offsets<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, transaction_id: &'life1 str, producer_id: i64, producer_epoch: i16, group_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<ErrorCode>> + Send + 'async_trait>>

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

Add offsets to a transaction for a producer.

fn txn_add_partitions<'life0, 'async_trait>( &'life0 self, partitions: TxnAddPartitionsRequest, ) -> Pin<Box<dyn Future<Output = Result<TxnAddPartitionsResponse>> + Send + 'async_trait>>

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

Add partitions to a transaction.

fn txn_offset_commit<'life0, 'async_trait>( &'life0 self, offsets: TxnOffsetCommitRequest, ) -> Pin<Box<dyn Future<Output = Result<Vec<TxnOffsetCommitResponseTopic>>> + Send + 'async_trait>>

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

Commit an offset within a transaction.

fn txn_end<'life0, 'life1, 'async_trait>( &'life0 self, transaction_id: &'life1 str, producer_id: i64, producer_epoch: i16, committed: bool, ) -> Pin<Box<dyn Future<Output = Result<ErrorCode>> + Send + 'async_trait>>

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

Commit or abort a running transaction.

fn maintain<'life0, 'async_trait>( &'life0 self, now: SystemTime, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Run periodic maintenance on this storage.

fn cluster_id<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

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

fn node<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<i32>> + Send + 'async_trait>>

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

fn advertised_listener<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Url>> + Send + 'async_trait>>

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

fn delete_user_scram_credential<'life0, 'life1, 'async_trait>( &'life0 self, user: &'life1 str, mechanism: ScramMechanism, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn upsert_user_scram_credential<'life0, 'life1, 'async_trait>( &'life0 self, user: &'life1 str, mechanism: ScramMechanism, credential: ScramCredential, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn user_scram_credential<'life0, 'life1, 'async_trait>( &'life0 self, user: &'life1 str, mechanism: ScramMechanism, ) -> Pin<Box<dyn Future<Output = Result<Option<ScramCredential>>> + Send + 'async_trait>>

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

fn ping<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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