Struct WebSocketContract 

pub struct WebSocketContract { /* private fields */ }

WebSocket contract implementation

Defines message types and topics for a WebSocket connection, enabling schema validation and drift detection.

Implementations

impl WebSocketContract

pub fn new(contract_id: String, version: String) -> Self

Create a new WebSocket contract

pub fn add_message_type( &mut self, message_type: WebSocketMessageType, ) -> Result<(), ContractError>

Add a message type to the contract

pub fn remove_message_type(&mut self, message_type_id: &str)

Remove a message type from the contract

pub fn get_message_types_for_topic( &self, topic: &str, ) -> Vec<&WebSocketMessageType>

Get message types for a specific topic

Trait Implementations

impl ProtocolContract for WebSocketContract

fn protocol(&self) -> Protocol

Get the protocol type this contract represents

fn contract_id(&self) -> &str

Get a unique identifier for this contract

fn version(&self) -> &str

Get the contract version

fn operations(&self) -> Vec<ContractOperation>

Get all operations/methods/topics defined in this contract

fn get_operation(&self, operation_id: &str) -> Option<&ContractOperation>

Get a specific operation by identifier

fn diff<'life0, 'life1, 'async_trait>( &'life0 self, other: &'life1 dyn ProtocolContract, ) -> Pin<Box<dyn Future<Output = Result<ContractDiffResult, ContractError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Compare this contract with another contract of the same protocol

fn validate<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, operation_id: &'life1 str, request: &'life2 ContractRequest, ) -> Pin<Box<dyn Future<Output = Result<ValidationResult, ContractError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Validate a request/message against this contract

fn get_schema(&self, operation_id: &str) -> Option<Value>

Get schema information for an operation

fn to_json(&self) -> Result<Value, ContractError>

Serialize the contract to a JSON representation