pub struct App<R: ThrusterRequest, T: 'static + Context + Clone + Send + Sync, S: Send> {
pub delete_root: Node<T>,
pub get_root: Node<T>,
pub options_root: Node<T>,
pub post_root: Node<T>,
pub put_root: Node<T>,
pub patch_root: Node<T>,
pub context_generator: fn(_: R, _: &S, _: &str) -> T,
pub state: Arc<S>,
pub connection_timeout: u64,
}
Expand description
App, the main component of Thruster. The App is the entry point for your application
and handles all incomming requests. Apps are also composeable, that is, via the subapp
method, you can use all of the methods and middlewares contained within an app as a subset
of your app’s routes.
There are three main parts to creating a thruster app:
- Use
App.create
to create a new app with a custom context generator - Add routes and middleware via
.get
,.post
, etc. - Build the app future with
App.build
and spawn it on the executor
Examples
Subapp
let mut app1 = App::<Request, BasicContext>::new();
fn test_fn_1(context: BasicContext, next: impl Fn(BasicContext) -> MiddlewareReturnValue<BasicContext> + Send) -> MiddlewareReturnValue<BasicContext> {
Box::new(future::ok(BasicContext {
body: context.params.get("id").unwrap().to_owned(),
params: context.params,
query_params: context.query_params
}))
};
app1.get("/:id", middleware![BasicContext => test_fn_1]);
let mut app2 = App::<Request, BasicContext>::new();
app2.use_sub_app("/test", app1);
In the above example, the route /test/some-id
will return some-id
in the body of the response.
The provided start methods are great places to start, but you can also simply use Thruster as a router
and create your own version of an HTTP server by directly calling App.resolve
with a Request object.
It will then return a future with the Response object that corresponds to the request. This can be
useful if trying to integrate with a different type of load balancing system within the threads of the
application.
Fields
delete_root: Node<T>
get_root: Node<T>
options_root: Node<T>
post_root: Node<T>
put_root: Node<T>
patch_root: Node<T>
context_generator: fn(_: R, _: &S, _: &str) -> T
Generate context is common to all App
s. It’s the function that’s called upon receiving a request
that translates an acutal Request
struct to your custom Context type. It should be noted that
the context_generator should be as fast as possible as this is called with every request, including
404s.
state: Arc<S>
connection_timeout: u64
The connection timeout for the app in milliseconds. Defaults to 3600000ms (1 hour)
Implementations
Creates a new instance of app with the library supplied BasicContext
. Useful for trivial
examples, likely not a good solution for real code bases. The advantage is that the
context_generator is already supplied for the developer.
Create a new app with the given context generator. The app does not begin listening until start is called.
pub fn use_middleware(
&mut self,
path: &str,
middlewares: MiddlewareTuple<T>
) -> &mut App<R, T, S> where
T: Clone,
pub fn use_middleware(
&mut self,
path: &str,
middlewares: MiddlewareTuple<T>
) -> &mut App<R, T, S> where
T: Clone,
Add method-agnostic middleware for a route. This is useful for applying headers, logging, and anything else that might not be sensitive to the HTTP method for the endpoint.
Add an app as a predetermined set of routes and middleware. Will prefix whatever string is passed in to all of the routes. This is a main feature of Thruster, as it allows projects to be extermely modular and composeable in nature.
Add a route that responds to GET
s to a given path
Add a route that responds to OPTION
s to a given path
Add a route that responds to POST
s to a given path
Add a route that responds to PUT
s to a given path
Add a route that responds to DELETE
s to a given path
Add a route that responds to PATCH
s to a given path
pub fn set404(&mut self, middlewares: MiddlewareTuple<T>) -> &mut App<R, T, S> where
T: Clone,
pub fn set404(&mut self, middlewares: MiddlewareTuple<T>) -> &mut App<R, T, S> where
T: Clone,
Sets the middleware if no route is successfully matched. Note, that due to type restrictions, we Context needs to implement Clone in order to call this function, even though clone will never be called.
Sets whether this app router uses strict mode for route parsing or not. Strict mode considers
/a
to be distinct from /a/
.
pub fn resolve_from_method_and_path<'m>(
&'m self,
method: &str,
path: String
) -> NodeOutput<'m, T>
pub fn match_and_resolve<'m>(
&'m self,
request: R
) -> ReusableBoxFuture<Result<T::Response, Error>>ⓘNotable traits for ReusableBoxFuture<T>impl<T> Future for ReusableBoxFuture<T> type Output = T;
impl<T> Future for ReusableBoxFuture<T> type Output = T;