ClientSessionBuilder

Struct ClientSessionBuilder 

Source
pub struct ClientSessionBuilder { /* private fields */ }
Expand description

Builder for constructing ClientSession instances

Provides a fluent API for creating client sessions with different routing modes.

§Examples

use std::net::SocketAddr;
use std::sync::Arc;
use nntp_proxy::session::ClientSession;
use nntp_proxy::pool::BufferPool;
use nntp_proxy::router::BackendSelector;
use nntp_proxy::config::RoutingMode;
use nntp_proxy::types::BufferSize;
use nntp_proxy::auth::AuthHandler;

let addr: SocketAddr = "127.0.0.1:8080".parse().unwrap();
let buffer_pool = BufferPool::new(BufferSize::DEFAULT, 10);
let auth_handler = Arc::new(AuthHandler::new(None, None));

// Standard 1:1 routing mode
let session = ClientSession::builder(addr, buffer_pool.clone(), auth_handler.clone())
    .build();

// Per-command routing mode
let router = Arc::new(BackendSelector::new());
let session = ClientSession::builder(addr, buffer_pool.clone(), auth_handler)
    .with_router(router)
    .with_routing_mode(RoutingMode::PerCommand)
    .build();

Implementations§

Source§

impl ClientSessionBuilder

Source

pub fn with_router(self, router: Arc<BackendSelector>) -> Self

Configure the session to use per-command routing with a backend router

When a router is provided, the session will route each command independently to potentially different backend servers.

Source

pub fn with_routing_mode(self, mode: RoutingMode) -> Self

Set the routing mode for this session

§Arguments
  • mode - The routing mode (Standard, PerCommand, or Hybrid)

Note: If you use with_router(), you typically want PerCommand or Hybrid mode.

Source

pub fn with_auth_handler(self, auth_handler: Arc<AuthHandler>) -> Self

Set the authentication handler

Source

pub fn build(self) -> ClientSession

Build the client session

Creates a new ClientSession with a unique client ID and the configured routing mode.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more