Struct puff_rs::context::PuffContext

pub struct PuffContext { /* private fields */ }

The central control structure for dispatching tasks onto coroutine workers. All tasks in the same runtime will have access to the same dispatcher. The dispatcher contains a reference to the parent Tokio Runtime as well as references to all coroutine workers.

Implementations

impl PuffContext

pub fn empty(handle: Handle) -> PuffContext

Creates an empty RuntimeDispatcher with no active threads for testing.

pub fn new(handle: Handle) -> PuffContext

Creates a new RuntimeDispatcher using the supplied RuntimeConfig.

pub fn new_with_options(
    handle: Handle,
    redis: Option<RedisClient>,
    postgres: Option<PostgresClient>,
    python_dispatcher: Option<PythonDispatcher>,
    pubsub_client: Option<PubSubClient>,
    gql_root: Option<Arc<RootNode<'static, PuffGqlObject, PuffGqlObject, PuffGqlObject, AggroScalarValue>>>
) -> PuffContext

Creates a new RuntimeDispatcher using the supplied RuntimeConfig. This function will start the number of coroutine_threads specified in your config. Includes options.

pub fn handle(&self) -> Handle

A Handle into the multi-threaded async runtime

pub fn pubsub(&self) -> PubSubClient

The global configured PubSubClient

pub fn python_dispatcher(&self) -> PythonDispatcher

A Handle into the multi-threaded async runtime

pub fn redis(&self) -> RedisClient

The configured redis client. Panics if not enabled.

pub fn postgres(&self) -> PostgresClient

The configured postgres client. Panics if not enabled.

pub fn gql(
    &self
) -> Arc<RootNode<'static, PuffGqlObject, PuffGqlObject, PuffGqlObject, AggroScalarValue>>

The configured graphql root node. Panics if not enabled.

Trait Implementations

impl Clone for PuffContext

fn clone(&self) -> PuffContext

Returns a copy of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for PuffContext

fn default() -> Self

Returns the “default value” for a type.

impl Puff for PuffContext

fn puff(&self) -> Self