Trait WsMethod 

pub trait WsMethod:
    Send
    + Sync
    + 'static {
    type Params: DeserializeOwned + Send;

    const METHOD: &'static str;
    const IS_STREAMING: bool = false;

    // Required method
    fn handle<'async_trait>(
        ctx: Arc<WsContext>,
        req: WsRequest,
        params: Self::Params,
        sink: WsOpSink,
    ) -> Pin<Box<dyn Future<Output = WsResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait;

    // Provided method
    fn validate(_params: &Self::Params) -> WsResult<()> { ... }
}

Trait for WebSocket method handlers

Each method handler implements this trait to define:

• The method name (e.g., “rpki.validate”)
• Whether it’s a streaming method
• How to parse and validate parameters
• How to execute the method

Required Associated Constants

const METHOD: &'static str

Fully qualified method name, e.g., “rpki.validate”

Provided Associated Constants

const IS_STREAMING: bool = false

Whether this method is streaming (returns progress/stream messages)

Required Associated Types

type Params: DeserializeOwned + Send

Parameter type for this method

Required Methods

fn handle<'async_trait>( ctx: Arc<WsContext>, req: WsRequest, params: Self::Params, sink: WsOpSink, ) -> Pin<Box<dyn Future<Output = WsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait,

Execute the method

For non-streaming methods, this should send a single result via the sink. For streaming methods, this may send progress/stream messages followed by a result.

Provided Methods

fn validate(_params: &Self::Params) -> WsResult<()>

Validate parameters after parsing

Override this to perform additional validation beyond JSON deserialization.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl WsMethod for As2relRelationshipHandler

const METHOD: &'static str = "as2rel.relationship"

const IS_STREAMING: bool = false

type Params = As2relRelationshipParams

impl WsMethod for As2relSearchHandler

const METHOD: &'static str = "as2rel.search"

const IS_STREAMING: bool = false

type Params = As2relSearchParams

impl WsMethod for As2relUpdateHandler

const METHOD: &'static str = "as2rel.update"

const IS_STREAMING: bool = false

type Params = As2relUpdateParams

impl WsMethod for CountryLookupHandler

const METHOD: &'static str = "country.lookup"

const IS_STREAMING: bool = false

type Params = CountryLookupParams

impl WsMethod for DatabaseRefreshHandler

const METHOD: &'static str = "database.refresh"

const IS_STREAMING: bool = false

type Params = DatabaseRefreshParams

impl WsMethod for DatabaseStatusHandler

const METHOD: &'static str = "database.status"

const IS_STREAMING: bool = false

type Params = DatabaseStatusParams

impl WsMethod for InspectQueryHandler

const METHOD: &'static str = "inspect.query"

const IS_STREAMING: bool = true

type Params = InspectQueryParams

impl WsMethod for InspectRefreshHandler

const METHOD: &'static str = "inspect.refresh"

const IS_STREAMING: bool = true

type Params = InspectRefreshParams

impl WsMethod for IpLookupHandler

const METHOD: &'static str = "ip.lookup"

const IS_STREAMING: bool = false

type Params = IpLookupParams

impl WsMethod for IpPublicHandler

const METHOD: &'static str = "ip.public"

const IS_STREAMING: bool = false

type Params = IpPublicParams

impl WsMethod for Pfx2asLookupHandler

const METHOD: &'static str = "pfx2as.lookup"

const IS_STREAMING: bool = false

type Params = Pfx2asLookupParams

impl WsMethod for RpkiAspasHandler

const METHOD: &'static str = "rpki.aspas"

const IS_STREAMING: bool = false

type Params = RpkiAspasParams

impl WsMethod for RpkiRoasHandler

const METHOD: &'static str = "rpki.roas"

const IS_STREAMING: bool = false

type Params = RpkiRoasParams

impl WsMethod for RpkiValidateHandler

const METHOD: &'static str = "rpki.validate"

const IS_STREAMING: bool = false

type Params = RpkiValidateParams

impl WsMethod for SystemInfoHandler

const METHOD: &'static str = "system.info"

const IS_STREAMING: bool = false

type Params = SystemInfoParams

impl WsMethod for TimeParseHandler

const METHOD: &'static str = "time.parse"

const IS_STREAMING: bool = false

type Params = TimeParseParams