Struct RiGateway 

pub struct RiGateway { /* private fields */ }

Main gateway struct implementing the RiModule trait.

This struct provides the core gateway functionality, including request handling, routing, middleware execution, rate limiting, and circuit breaking.

Implementations

impl RiGateway

pub fn new() -> Self

Creates a new gateway instance with default configuration.

Returns

A new RiGateway instance

pub fn router(&self) -> Arc<RiRouter>

Returns a reference to the router.

Returns

An Arc providing thread-safe access to the router

pub fn middleware_chain(&self) -> Arc<RiMiddlewareChain>

Returns a reference to the middleware chain.

Returns

An Arc providing thread-safe access to the middleware chain

pub async fn handle_request( &self, request: RiGatewayRequest, ) -> RiGatewayResponse

Handles a gateway request.

This method processes a request through the gateway pipeline, including:

1. Rate limiting
2. Circuit breaker check
3. Middleware chain execution
4. Request routing
5. Route handler execution

Parameters

• request: The request to handle

Returns

A RiGatewayResponse containing the response to the request

Trait Implementations

impl Default for RiGateway

fn default() -> Self

Returns the “default value” for a type.

impl<'py> IntoPyObject<'py> for RiGateway

type Target = RiGateway

The Python output type

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

The smart pointer type to use.

type Error = PyErr

The type returned in the event of a conversion error.

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

Performs the conversion.

impl PyClass for RiGateway

type Frozen = False

Whether the pyclass is frozen.

impl PyClassImpl for RiGateway

const IS_BASETYPE: bool = false

#[pyclass(subclass)]

const IS_SUBCLASS: bool = false

#[pyclass(extends=…)]

const IS_MAPPING: bool = false

#[pyclass(mapping)]

const IS_SEQUENCE: bool = false

#[pyclass(sequence)]

const IS_IMMUTABLE_TYPE: bool = false

#[pyclass(immutable_type)]

const RAW_DOC: &'static CStr = c"Main gateway struct implementing the RiModule trait.\n\nThis struct provides the core gateway functionality, including request handling,\nrouting, middleware execution, rate limiting, and circuit breaking.\x00"

Docstring for the class provided on the struct or enum.

const DOC: &'static CStr

Fully rendered class doc, including the text_signature if a constructor is defined.

type BaseType = PyAny

Base class

type ThreadChecker = SendablePyClass<RiGateway>

This handles following two situations:

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

Immutable or mutable

type Dict = PyClassDummySlot

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

type WeakRef = PyClassDummySlot

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

type BaseNativeType = PyAny

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

fn items_iter() -> PyClassItemsIter

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

fn dict_offset() -> Option<isize>

fn weaklist_offset() -> Option<isize>

impl PyClassNewTextSignature for RiGateway

const TEXT_SIGNATURE: &'static str = "()"

impl PyMethods<RiGateway> for PyClassImplCollector<RiGateway>

fn py_methods(self) -> &'static PyClassItems

impl PyTypeInfo for RiGateway

const NAME: &'static str = "RiGateway"

Class name.

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

Module name, if any.

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.

impl RiModule for RiGateway

fn name(&self) -> &str

Returns the name of the gateway module.

Returns

The module name as a string

fn init<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 mut RiServiceContext, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

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

Initializes the gateway module.

Parameters

• ctx: Service context containing configuration and other services

Returns

A RiResult<()> indicating success or failure

fn after_shutdown<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut RiServiceContext, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

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

Performs cleanup after the gateway has shut down.

This method ensures proper resource cleanup during gateway shutdown:

• Clears all rate limiter buckets
• Resets the circuit breaker to closed state
• Clears all registered routes

Parameters

• _ctx: Service context (not used in this implementation)

Returns

A RiResult<()> indicating success or failure

Logs

Logs cleanup progress at INFO level for debugging purposes

fn is_critical(&self) -> bool

Indicates if the module is critical to the operation of the system.

fn priority(&self) -> i32

Returns the priority of the module.

fn dependencies(&self) -> Vec<&str>

Returns the list of module dependencies.

fn before_start<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut RiServiceContext, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

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

Prepares the module for startup.

fn start<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut RiServiceContext, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

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

Starts the service module.

fn after_start<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut RiServiceContext, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

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

Performs post-startup operations.

fn before_shutdown<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut RiServiceContext, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

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

Prepares the module for shutdown.

fn shutdown<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut RiServiceContext, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

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

Shuts down the service module.

impl DerefToPyAny for RiGateway

impl ExtractPyClassWithClone for RiGateway