pub struct ServerBuilder<T: TransportPort = AnyTransport> { /* private fields */ }Expand description
Generic builder for BACnetServer with a pre-built transport. The
transport type defaults to AnyTransport, as BACnetServer’s does.
Implementations§
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn mutation_policy(self, policy: MutationPolicy) -> Self
pub fn mutation_policy(self, policy: MutationPolicy) -> Self
Select local mutation authorization (default: MutationPolicy::Permissive).
SC mTLS channel/peer authentication is not service authorization.
Sourcepub fn policy(self, policy: impl ServerPolicy) -> Self
pub fn policy(self, policy: impl ServerPolicy) -> Self
Install the server’s authorization policy; see ServerPolicy, or
FnPolicy to build one from closures.
It replaces any policy set before; put every decision in one policy
(one FnPolicy chain) rather than calling this twice.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn audit_reporters(self, profile: AuditReportersConfig) -> Self
pub fn audit_reporters(self, profile: AuditReportersConfig) -> Self
Enable the narrow target audit profile; see AuditReportersConfig.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn reinit_password(self, password: impl Into<String>) -> Self
pub fn reinit_password(self, password: impl Into<String>) -> Self
Set the password required for ReinitializeDevice requests.
Sourcepub fn on_reinitialize<F>(self, handler: F) -> Selfwhere
F: Fn(&ReinitializeContext, &mut ObjectDatabase) -> Result<(), Error> + Send + Sync + 'static,
pub fn on_reinitialize<F>(self, handler: F) -> Selfwhere
F: Fn(&ReinitializeContext, &mut ObjectDatabase) -> Result<(), Error> + Send + Sync + 'static,
Set the ReinitializeDevice handler. It must reply before restarting and
stay quick; see ReinitializeHandler.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn time_sync_policy(self, policy: TimeSyncPolicy) -> Self
pub fn time_sync_policy(self, policy: TimeSyncPolicy) -> Self
Configure opt-in inbound clock restrictions; default is unrestricted allow.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn dcc_disable_rate_limit(self, limit: Option<DccDisableRateLimit>) -> Self
pub fn dcc_disable_rate_limit(self, limit: Option<DccDisableRateLimit>) -> Self
Limit authorized DISABLE_INITIATION globally; None (default) disables it. ENABLE is exempt. Each new native server starts with a full bucket.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn dcc_password(self, password: impl Into<String>) -> Self
pub fn dcc_password(self, password: impl Into<String>) -> Self
Set the password required for DeviceCommunicationControl requests.
Sourcepub fn dcc_source_restriction(
self,
restriction: Option<DccSourceRestriction>,
) -> Self
pub fn dcc_source_restriction( self, restriction: Option<DccSourceRestriction>, ) -> Self
Restrict claimed DCC sources; None preserves unrestricted policy behavior.
Sourcepub fn dcc_policy(self, policy: DccPolicy) -> Self
pub fn dcc_policy(self, policy: DccPolicy) -> Self
Select explicit local DCC authorization (default: deny all).
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn registered_network_port(self, oid: ObjectIdentifier) -> Self
pub fn registered_network_port(self, oid: ObjectIdentifier) -> Self
Select the concrete built-in Network Port for this owned B/IP or B/IPv6 link, in whichever mode the transport runs. The object must already describe the concrete interface and configured UDP port (zero is allowed): an IPV4 object for B/IP, an IPV6 one for B/IPv6. A B/IPv6 transport must be built with the served Device’s instance, which is its VMAC (#2057). Startup validates, then publishes the actual bind and mode.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn request_admission_policy(self, policy: RequestAdmissionPolicy) -> Self
pub fn request_admission_policy(self, policy: RequestAdmissionPolicy) -> Self
Set positive global and peer handler limits, validated before startup.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn read_property_multiple_budget(
self,
budget: ReadPropertyMultipleBudget,
) -> Self
pub fn read_property_multiple_budget( self, budget: ReadPropertyMultipleBudget, ) -> Self
Set positive per-service RPM limits, validated before transport startup.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn get_alarm_summary_budget(self, budget: GetAlarmSummaryBudget) -> Self
pub fn get_alarm_summary_budget(self, budget: GetAlarmSummaryBudget) -> Self
Set limits validated before transport startup.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn atomic_read_file_budget(self, budget: AtomicReadFileBudget) -> Self
pub fn atomic_read_file_budget(self, budget: AtomicReadFileBudget) -> Self
Set AtomicReadFile limits validated before transport startup.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn atomic_write_file_budget(self, budget: AtomicWriteFileBudget) -> Self
pub fn atomic_write_file_budget(self, budget: AtomicWriteFileBudget) -> Self
Set AtomicWriteFile payload limits, validated before transport startup.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn read_range_budget(self, budget: ReadRangeBudget) -> Self
pub fn read_range_budget(self, budget: ReadRangeBudget) -> Self
Set ReadRange page limits, validated before startup.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn get_event_information_budget(
self,
budget: GetEventInformationBudget,
) -> Self
pub fn get_event_information_budget( self, budget: GetEventInformationBudget, ) -> Self
Set GetEventInformation limits, validated before startup.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn get_enrollment_summary_budget(
self,
budget: GetEnrollmentSummaryBudget,
) -> Self
pub fn get_enrollment_summary_budget( self, budget: GetEnrollmentSummaryBudget, ) -> Self
Set GetEnrollmentSummary limits validated before transport startup.
Source§impl<T: TransportPort + 'static> ServerBuilder<T>
impl<T: TransportPort + 'static> ServerBuilder<T>
Sourcepub fn device(self, identity: DeviceIdentity) -> Self
pub fn device(self, identity: DeviceIdentity) -> Self
Set the one Device identity. With no supplied database, startup creates a stock Device after resolving the owned transport’s receive capacity.
Sourcepub fn database(self, db: ObjectDatabase) -> Self
pub fn database(self, db: ObjectDatabase) -> Self
Set the object database (transfers ownership).
Sourcepub fn device_binding(self, binding: DeviceBinding) -> Result<Self, Error>
pub fn device_binding(self, binding: DeviceBinding) -> Result<Self, Error>
Register one explicit unicast route for a Device recipient.
Sourcepub fn audit_notification_sink(self, sink: ObjectIdentifier) -> Self
pub fn audit_notification_sink(self, sink: ObjectIdentifier) -> Self
Select the only local Audit Log that receives authorized notifications.
Sourcepub fn enable_fault_detection(self, enabled: bool) -> Self
pub fn enable_fault_detection(self, enabled: bool) -> Self
Enable periodic fault detection / reliability evaluation.
When enabled, every object’s opt-in reliability hook runs every 10 seconds; the default hook is a no-op.
Reliability evaluation only; Event Enrollment evaluation is configured
by enable_event_enrollment.
Sourcepub fn enable_event_enrollment(self, enabled: bool) -> Self
pub fn enable_event_enrollment(self, enabled: bool) -> Self
Enable periodic Event Enrollment evaluation (default true).
Sourcepub fn event_enrollment_interval_secs(self, secs: u64) -> Self
pub fn event_enrollment_interval_secs(self, secs: u64) -> Self
Set the interval in seconds between Event Enrollment evaluation passes (default 10).
Sourcepub fn discovery_policy(self, policy: DiscoveryPolicy) -> Self
pub fn discovery_policy(self, policy: DiscoveryPolicy) -> Self
Set the discovery rate-limiting and duplicate suppression policy.
Sourcepub fn cov_policy(self, policy: CovPolicy) -> Self
pub fn cov_policy(self, policy: CovPolicy) -> Self
Set the COV quota and notification work budget policy, checked by
CovPolicy::validate before transport startup.
Sourcepub async fn build(self) -> Result<BACnetServer<T>, Error>
pub async fn build(self) -> Result<BACnetServer<T>, Error>
Build and start the server.