Struct GraphQLState 

pub struct GraphQLState {
    pub pool: PgPool,
    pub schema_cache: Arc<SchemaCache>,
    pub generated_schema: GeneratedSchema,
    pub schema: Schema,
    pub config: SchemaConfig,
    pub subscription_fields: Vec<SubscriptionField>,
    pub broker: Arc<RwLock<Option<NotifyBroker>>>,
}

GraphQL execution state shared across requests.

Fields

pool: PgPool

Database connection pool

schema_cache: Arc<SchemaCache>

Schema cache

generated_schema: GeneratedSchema

Generated GraphQL schema

schema: Schema

async-graphql Schema (built dynamically)

config: SchemaConfig

Schema configuration

subscription_fields: Vec<SubscriptionField>

Subscription fields

broker: Arc<RwLock<Option<NotifyBroker>>>

Notification broker for subscriptions

Implementations

impl GraphQLState

pub fn new( pool: PgPool, schema_cache: Arc<SchemaCache>, config: SchemaConfig, ) -> Result<Self, GraphQLError>

Create new GraphQL state from schema cache.

pub fn rebuild(&mut self) -> Result<(), GraphQLError>

Rebuild the schema (e.g., after schema cache refresh).

pub async fn init_subscriptions(&self) -> Result<(), BrokerError>

Initialize the subscription broker.

This should be called after creating the state to enable subscriptions.

pub async fn stop_subscriptions(&self)

Stop the subscription broker.

pub async fn get_broker(&self) -> Option<Arc<RwLock<Option<NotifyBroker>>>>

Get the notification broker.