Struct HTTPSubgraphExecutor 

pub struct HTTPSubgraphExecutor {
    pub subgraph_name: String,
    pub endpoint: Uri,
    pub http_client: Arc<HttpClient>,
    pub header_map: HeaderMap,
    pub semaphore: Arc<Semaphore>,
    pub dedupe_enabled: bool,
    pub in_flight_requests: InflightRequestsMap,
    pub telemetry_context: Arc<TelemetryContext>,
    pub config: Arc<HiveRouterConfig>,
}

Fields

subgraph_name: String

endpoint: Uri

http_client: Arc<HttpClient>

header_map: HeaderMap

semaphore: Arc<Semaphore>

dedupe_enabled: bool

in_flight_requests: InflightRequestsMap

telemetry_context: Arc<TelemetryContext>

config: Arc<HiveRouterConfig>

Implementations

impl HTTPSubgraphExecutor

pub fn new( subgraph_name: String, endpoint: Uri, http_client: Arc<HttpClient>, semaphore: Arc<Semaphore>, dedupe_enabled: bool, in_flight_requests: InflightRequestsMap, telemetry_context: Arc<TelemetryContext>, config: Arc<HiveRouterConfig>, ) -> Self

Trait Implementations

impl SubgraphExecutor for HTTPSubgraphExecutor

fn endpoint(&self) -> &Uri

fn execute<'a, 'life0, 'async_trait>( &'life0 self, execution_request: SubgraphExecutionRequest<'a>, timeout: Option<Duration>, plugin_req_state: &'a Option<PluginRequestState<'a>>, ) -> Pin<Box<dyn Future<Output = Result<SubgraphResponse<'a>, SubgraphExecutorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn to_boxed_arc<'a>(self) -> Arc<Box<dyn SubgraphExecutor + Send + Sync + 'a>>

where Self: Sized + Send + Sync + 'a,