pub struct TunnelingClientContext<C> {
inner: C,
rewrites: Arc<Mutex<BTreeMap<BrokerAddr, BrokerRewriteHandle>>>,
default_tunnel: TunnelConfig,
in_task: InTask,
ssh_tunnel_manager: SshTunnelManager,
ssh_timeout_config: SshTimeoutConfig,
aws_config: Option<SdkConfig>,
runtime: Handle,
}
Expand description
A client context that supports rewriting broker addresses.
Fields§
§inner: C
§rewrites: Arc<Mutex<BTreeMap<BrokerAddr, BrokerRewriteHandle>>>
§default_tunnel: TunnelConfig
§in_task: InTask
§ssh_tunnel_manager: SshTunnelManager
§ssh_timeout_config: SshTimeoutConfig
§aws_config: Option<SdkConfig>
§runtime: Handle
Implementations§
Source§impl<C> TunnelingClientContext<C>
impl<C> TunnelingClientContext<C>
Sourcepub fn new(
inner: C,
runtime: Handle,
ssh_tunnel_manager: SshTunnelManager,
ssh_timeout_config: SshTimeoutConfig,
aws_config: Option<SdkConfig>,
in_task: InTask,
) -> TunnelingClientContext<C>
pub fn new( inner: C, runtime: Handle, ssh_tunnel_manager: SshTunnelManager, ssh_timeout_config: SshTimeoutConfig, aws_config: Option<SdkConfig>, in_task: InTask, ) -> TunnelingClientContext<C>
Constructs a new context that wraps inner
.
Sourcepub fn set_default_tunnel(&mut self, tunnel: TunnelConfig)
pub fn set_default_tunnel(&mut self, tunnel: TunnelConfig)
Adds the default broker rewrite rule.
Connections to brokers that aren’t specified in other rewrites will be rewritten to connect to
rewrite_host
and rewrite_port
instead.
Sourcepub async fn add_ssh_tunnel(
&self,
broker: BrokerAddr,
tunnel: SshTunnelConfig,
) -> Result<(), Error>
pub async fn add_ssh_tunnel( &self, broker: BrokerAddr, tunnel: SshTunnelConfig, ) -> Result<(), Error>
Adds an SSH tunnel for a specific broker.
Overrides the existing SSH tunnel or rewrite for this broker, if any.
This tunnel allows the rewrite to evolve over time, for example, if the ssh tunnel’s address changes if it fails and restarts.
Sourcepub fn add_broker_rewrite(&self, broker: BrokerAddr, rewrite: BrokerRewrite)
pub fn add_broker_rewrite(&self, broker: BrokerAddr, rewrite: BrokerRewrite)
Adds a broker rewrite rule.
Overrides the existing SSH tunnel or rewrite for this broker, if any.
rewrite
is BrokerRewrite
that specifies how to rewrite the address for broker
.
Sourcepub fn tunnel_status(&self) -> SshTunnelStatus
pub fn tunnel_status(&self) -> SshTunnelStatus
Returns a consolidated SshTunnelStatus
that communicates the status
of all active ssh tunnels self
knows about.
Trait Implementations§
Source§impl<C> ClientContext for TunnelingClientContext<C>where
C: ClientContext,
impl<C> ClientContext for TunnelingClientContext<C>where
C: ClientContext,
Source§const ENABLE_REFRESH_OAUTH_TOKEN: bool = true
const ENABLE_REFRESH_OAUTH_TOKEN: bool = true
OAUTHBEARER
token
by calling ClientContext::generate_oauth_token
. Read moreSource§fn generate_oauth_token(
&self,
_oauthbearer_config: Option<&str>,
) -> Result<OAuthToken, Box<dyn Error>>
fn generate_oauth_token( &self, _oauthbearer_config: Option<&str>, ) -> Result<OAuthToken, Box<dyn Error>>
Source§fn resolve_broker_addr(
&self,
host: &str,
port: u16,
) -> Result<Vec<SocketAddr>, Error>
fn resolve_broker_addr( &self, host: &str, port: u16, ) -> Result<Vec<SocketAddr>, Error>
Source§fn log(&self, level: RDKafkaLogLevel, fac: &str, log_message: &str)
fn log(&self, level: RDKafkaLogLevel, fac: &str, log_message: &str)
Source§fn error(&self, error: KafkaError, reason: &str)
fn error(&self, error: KafkaError, reason: &str)
Source§fn stats(&self, statistics: Statistics)
fn stats(&self, statistics: Statistics)
statistics.interval.ms
configuration parameter must be specified. Read moreSource§impl<C: Clone> Clone for TunnelingClientContext<C>
impl<C: Clone> Clone for TunnelingClientContext<C>
Source§fn clone(&self) -> TunnelingClientContext<C>
fn clone(&self) -> TunnelingClientContext<C>
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl<C> ConsumerContext for TunnelingClientContext<C>where
C: ConsumerContext,
impl<C> ConsumerContext for TunnelingClientContext<C>where
C: ConsumerContext,
Source§fn rebalance(
&self,
native_client: &NativeClient,
err: RDKafkaRespErr,
tpl: &mut TopicPartitionList,
)
fn rebalance( &self, native_client: &NativeClient, err: RDKafkaRespErr, tpl: &mut TopicPartitionList, )
pre_rebalance
and
post_rebalance
methods. If this
method is overridden, it will be responsibility of the user to call them
if needed.Source§fn pre_rebalance<'a>(&self, rebalance: &Rebalance<'a>)
fn pre_rebalance<'a>(&self, rebalance: &Rebalance<'a>)
Source§fn post_rebalance<'a>(&self, rebalance: &Rebalance<'a>)
fn post_rebalance<'a>(&self, rebalance: &Rebalance<'a>)
Source§fn commit_callback(&self, result: KafkaResult<()>, offsets: &TopicPartitionList)
fn commit_callback(&self, result: KafkaResult<()>, offsets: &TopicPartitionList)
Source§fn main_queue_min_poll_interval(&self) -> Timeout
fn main_queue_min_poll_interval(&self) -> Timeout
Source§impl<C> ProducerContext for TunnelingClientContext<C>where
C: ProducerContext,
impl<C> ProducerContext for TunnelingClientContext<C>where
C: ProducerContext,
Source§type DeliveryOpaque = <C as ProducerContext>::DeliveryOpaque
type DeliveryOpaque = <C as ProducerContext>::DeliveryOpaque
DeliveryOpaque
is a user-defined structure that will be passed to
the producer when producing a message, and returned to the delivery
method once the message has been delivered, or failed to.Source§fn delivery(
&self,
delivery_result: &DeliveryResult<'_>,
delivery_opaque: Self::DeliveryOpaque,
)
fn delivery( &self, delivery_result: &DeliveryResult<'_>, delivery_opaque: Self::DeliveryOpaque, )
DeliveryOpaque
will be the one provided by the user
when calling send.Auto Trait Implementations§
impl<C> Freeze for TunnelingClientContext<C>where
C: Freeze,
impl<C> !RefUnwindSafe for TunnelingClientContext<C>
impl<C> Send for TunnelingClientContext<C>where
C: Send,
impl<C> Sync for TunnelingClientContext<C>where
C: Sync,
impl<C> Unpin for TunnelingClientContext<C>where
C: Unpin,
impl<C> !UnwindSafe for TunnelingClientContext<C>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request