Struct NnrpServerConfig 

pub struct NnrpServerConfig {
    pub transport: RuntimeTransportKind,
    pub supported_profiles: Vec<u16>,
    pub supported_cache_objects: Vec<CacheObjectKind>,
    pub max_cache_objects: usize,
    pub max_cache_object_bytes: u32,
    pub schema_registry: SchemaRegistry,
    pub resume_token_bytes: u32,
    pub max_in_flight_operations: u16,
    pub granted_operation_credit: u16,
    pub lease_ttl_ms: u32,
    pub resume_window_ms: u32,
    pub application_policy: Arc<dyn NnrpServerPolicy>,
}

Fields

transport: RuntimeTransportKind

supported_profiles: Vec<u16>

supported_cache_objects: Vec<CacheObjectKind>

max_cache_objects: usize

max_cache_object_bytes: u32

schema_registry: SchemaRegistry

resume_token_bytes: u32

max_in_flight_operations: u16

granted_operation_credit: u16

lease_ttl_ms: u32

resume_window_ms: u32

application_policy: Arc<dyn NnrpServerPolicy>

Implementations

impl NnrpServerConfig

pub fn with_transport(self, transport: RuntimeTransportKind) -> Self

pub fn with_supported_profiles(self, profiles: impl Into<Vec<u16>>) -> Self

pub fn with_supported_cache_objects( self, objects: impl Into<Vec<CacheObjectKind>>, ) -> Self

pub fn with_cache_limits( self, max_objects: usize, max_object_bytes: u32, ) -> Self

pub fn with_schema_registry(self, schema_registry: SchemaRegistry) -> Self

pub fn with_resume_token_bytes(self, resume_token_bytes: u32) -> Self

pub fn with_application_policy<P>(self, policy: P) -> Self

where P: NnrpServerPolicy + 'static,

Trait Implementations

impl Clone for NnrpServerConfig

fn clone(&self) -> NnrpServerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NnrpServerConfig

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

Formats the value using the given formatter.

impl Default for NnrpServerConfig

fn default() -> Self

Returns the “default value” for a type.