DMSCFrameBuilder

Struct DMSCFrameBuilder 

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

Frame builder for creating protocol frames with automatic sequence numbering.

The DMSCFrameBuilder provides a convenient interface for constructing DMSC frames while automatically managing sequence numbers. Rather than manually tracking and incrementing sequence numbers for each frame, the builder maintains an internal counter that is automatically incremented after each frame construction. This ensures proper sequence numbering without the risk of human error.

§Builder Pattern Advantages

Using the frame builder provides several benefits over direct frame construction:

  • Automatic Sequencing: No need to manually track and increment sequence numbers
  • Type Safety: Compile-time checking of frame type construction
  • Convenience Methods: Domain-specific constructors for each frame type
  • State Management: Builder maintains state across frame constructions

§Sequence Number Management

The builder maintains an internal sequence counter that is automatically incremented after each frame construction. The counter uses wrapping arithmetic (modulo 2^32) to handle overflow gracefully. You can query or set the current sequence number using next_sequence() and set_sequence() methods.

§Python Bindings

When compiled with the pyo3 feature, this struct provides Python bindings:

from dmsc import DMSCFrameBuilder

# Create builder for convenient frame construction
builder = DMSCFrameBuilder.new()

# Build frames without manually tracking sequence numbers
control_frame = builder.build_control_frame(b"\x01\x02\x03")
data_frame = builder.build_data_frame(b"Hello, World!")
auth_frame = builder.build_auth_frame(b"token=abc123")

# Check current sequence number
print(f"Next sequence: {builder.next_sequence()}")

# Reset sequence for new session
builder.set_sequence(0)

§Examples

Building multiple frames with automatic sequencing:

use dmsc::protocol::frames::DMSCFrameBuilder;

let mut builder = DMSCFrameBuilder::new();

// Build a series of data frames
let frame1 = builder.build_data_frame(b"Message 1".to_vec())
    .expect("Failed to build frame");
let frame2 = builder.build_data_frame(b"Message 2".to_vec())
    .expect("Failed to build frame");
let frame3 = builder.build_data_frame(b"Message 3".to_vec())
    .expect("Failed to build frame");

assert_eq!(frame1.sequence_number(), 0);
assert_eq!(frame2.sequence_number(), 1);
assert_eq!(frame3.sequence_number(), 2);

// Current sequence is now 3
assert_eq!(builder.next_sequence(), 3);

Building different frame types:

use dmsc::protocol::frames::DMSCFrameBuilder;

let mut builder = DMSCFrameBuilder::new();

// Control frame
let control = builder.build_control_frame(vec![0x01, 0x00, 0x01])
    .expect("Failed to build control frame");

// Authentication frame
let auth = builder.build_auth_frame(b"credentials=secret".to_vec())
    .expect("Failed to build auth frame");

// Keep-alive frame
let keepalive = builder.build_keepalive_frame()
    .expect("Failed to build keepalive frame");

// Error frame
let error = builder.build_error_frame(0x0401, "Timeout".to_string())
    .expect("Failed to build error frame");

Managing sequence numbers:

use dmsc::protocol::frames::DMSCFrameBuilder;

let mut builder = DMSCFrameBuilder::new();

// Build some frames
let _ = builder.build_data_frame(b"Frame 0".to_vec()).unwrap();
let _ = builder.build_data_frame(b"Frame 1".to_vec()).unwrap();
let _ = builder.build_data_frame(b"Frame 2".to_vec()).unwrap();

// Check current sequence
assert_eq!(builder.next_sequence(), 3);

// Set specific sequence for resend or new session
builder.set_sequence(100);

let next = builder.build_data_frame(b"Frame 100".to_vec()).unwrap();
assert_eq!(next.sequence_number(), 100);
assert_eq!(builder.next_sequence(), 101);

§Thread Safety

This struct is not thread-safe. Multiple threads should not concurrently access the same builder instance without external synchronization. For concurrent frame building, either use separate builder instances per thread or wrap access with a Mutex or RwLock.

§Performance Characteristics

  • Frame construction is O(1) for fixed-size headers
  • Payload copying is O(n) where n is payload size
  • Sequence number operations are O(1)
  • Minimal heap allocation for small payloads

Implementations§

Source§

impl DMSCFrameBuilder

Source

pub fn new() -> Self

Source

pub fn build_control_frame( &mut self, control_data: Vec<u8>, ) -> DMSCResult<DMSCFrame>

Source

pub fn build_data_frame(&mut self, data: Vec<u8>) -> DMSCResult<DMSCFrame>

Source

pub fn build_auth_frame(&mut self, auth_data: Vec<u8>) -> DMSCResult<DMSCFrame>

Source

pub fn build_keepalive_frame(&mut self) -> DMSCResult<DMSCFrame>

Source

pub fn build_error_frame( &mut self, error_code: u32, error_message: String, ) -> DMSCResult<DMSCFrame>

Source

pub fn next_sequence(&self) -> u32

Source

pub fn set_sequence(&mut self, sequence: u32)

Trait Implementations§

Source§

impl<'py> IntoPyObject<'py> for DMSCFrameBuilder

Source§

type Target = DMSCFrameBuilder

The Python output type
Source§

type Output = Bound<'py, <DMSCFrameBuilder as IntoPyObject<'py>>::Target>

The smart pointer type to use. Read more
Source§

type Error = PyErr

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

fn into_pyobject( self, py: Python<'py>, ) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>

Performs the conversion.
Source§

impl PyClass for DMSCFrameBuilder

Source§

type Frozen = False

Whether the pyclass is frozen. Read more
Source§

impl PyClassImpl for DMSCFrameBuilder

Source§

const IS_BASETYPE: bool = false

#[pyclass(subclass)]
Source§

const IS_SUBCLASS: bool = false

#[pyclass(extends=…)]
Source§

const IS_MAPPING: bool = false

#[pyclass(mapping)]
Source§

const IS_SEQUENCE: bool = false

#[pyclass(sequence)]
Source§

const IS_IMMUTABLE_TYPE: bool = false

#[pyclass(immutable_type)]
Source§

const RAW_DOC: &'static CStr = /// - Minimal heap allocation for small payloads

Docstring for the class provided on the struct or enum. Read more
Source§

const DOC: &'static CStr

Fully rendered class doc, including the text_signature if a constructor is defined. Read more
Source§

type BaseType = PyAny

Base class
Source§

type ThreadChecker = SendablePyClass<DMSCFrameBuilder>

This handles following two situations: Read more
Source§

type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild

Immutable or mutable
Source§

type Dict = PyClassDummySlot

Specify this class has #[pyclass(dict)] or not.
Source§

type WeakRef = PyClassDummySlot

Specify this class has #[pyclass(weakref)] or not.
Source§

type BaseNativeType = PyAny

The closest native ancestor. This is PyAny by default, and when you declare #[pyclass(extends=PyDict)], it’s PyDict.
Source§

fn items_iter() -> PyClassItemsIter

Source§

fn lazy_type_object() -> &'static LazyTypeObject<Self>

§

fn dict_offset() -> Option<isize>

§

fn weaklist_offset() -> Option<isize>

Source§

impl PyTypeInfo for DMSCFrameBuilder

Source§

const NAME: &'static str = "DMSCFrameBuilder"

Class name.
Source§

const MODULE: Option<&'static str> = ::core::option::Option::None

Module name, if any.
Source§

fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject

Returns the PyTypeObject instance for this type.
§

fn type_object(py: Python<'_>) -> Bound<'_, PyType>

Returns the safe abstraction over the type object.
§

fn is_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type or a subclass of this type.
§

fn is_exact_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type.
Source§

impl DerefToPyAny for DMSCFrameBuilder

Source§

impl ExtractPyClassWithClone for DMSCFrameBuilder

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
§

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

§

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

§

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

§

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

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.

§

impl<T> Instrument for T

§

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

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

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> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
§

impl<'py, T> IntoPyObjectExt<'py> for T
where T: IntoPyObject<'py>,

§

fn into_bound_py_any(self, py: Python<'py>) -> Result<Bound<'py, PyAny>, PyErr>

Converts self into an owned Python object, dropping type information.
§

fn into_py_any(self, py: Python<'py>) -> Result<Py<PyAny>, PyErr>

Converts self into an owned Python object, dropping type information and unbinding it from the 'py lifetime.
§

fn into_pyobject_or_pyerr(self, py: Python<'py>) -> Result<Self::Output, PyErr>

Converts self into a Python object. Read more
Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
§

impl<T> Pointable for T

§

const ALIGN: usize

The alignment of pointer.
§

type Init = T

The type for initializers.
§

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

Initializes a with the given initializer. Read more
§

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

Dereferences the given pointer. Read more
§

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

Mutably dereferences the given pointer. Read more
§

unsafe fn drop(ptr: usize)

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

impl<T> PyErrArguments for T
where T: for<'py> IntoPyObject<'py> + Send + Sync,

§

fn arguments(self, py: Python<'_>) -> Py<PyAny>

Arguments for exception
§

impl<T> PyTypeCheck for T
where T: PyTypeInfo,

§

const NAME: &'static str = T::NAME

👎Deprecated since 0.27.0: Use ::classinfo_object() instead and format the type name at runtime. Note that using built-in cast features is often better than manual PyTypeCheck usage.
Name of self. This is used in error messages, for example.
§

fn type_check(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of Self, which may include a subtype. Read more
§

fn classinfo_object(py: Python<'_>) -> Bound<'_, PyAny>

Returns the expected type as a possible argument for the isinstance and issubclass function. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
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.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

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
§

fn with_current_subscriber(self) -> WithDispatch<Self>

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

impl<T> Ungil for T
where T: Send,