Struct PluginServer

pub struct PluginServer<P> { /* private fields */ }

Runs the Hipcheck plugin protocol based on the user’s implementation of the Plugin trait.

This struct implements the underlying gRPC protocol that is not exposed to the plugin author.

Implementations

impl<P: Plugin> PluginServer<P>

pub fn register( plugin: P, log_level_opt: impl Into<Option<LogLevel>>, ) -> PluginServer<P>

Create a new plugin server for the provided plugin.

pub async fn listen_local(self, port: u16) -> Result<()>

Run the plugin server on the loopback address and provided port.

pub async fn listen(self, host: Host, port: u16) -> Result<()>

Run the plugin server on the provided port.

Trait Implementations

impl<P: Plugin> PluginService for PluginServer<P>

type GetQuerySchemasStream = ReceiverStream<Result<GetQuerySchemasResponse, Status>>

Server streaming response type for the GetQuerySchemas method.

type InitiateQueryProtocolStream = ReceiverStream<Result<InitiateQueryProtocolResponse, Status>>

Server streaming response type for the InitiateQueryProtocol method.

fn set_configuration<'life0, 'async_trait>( &'life0 self, req: Req<SetConfigurationReq>, ) -> Pin<Box<dyn Future<Output = QueryResult<Resp<SetConfigurationResp>>> + Send + 'async_trait>>

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

fn get_default_policy_expression<'life0, 'async_trait>( &'life0 self, _req: Req<GetDefaultPolicyExpressionReq>, ) -> Pin<Box<dyn Future<Output = QueryResult<Resp<GetDefaultPolicyExpressionResp>>> + Send + 'async_trait>>

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

fn explain_default_query<'life0, 'async_trait>( &'life0 self, _req: Req<ExplainDefaultQueryReq>, ) -> Pin<Box<dyn Future<Output = QueryResult<Resp<ExplainDefaultQueryResp>>> + Send + 'async_trait>>

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

fn get_query_schemas<'life0, 'async_trait>( &'life0 self, _req: Req<GetQuerySchemasReq>, ) -> Pin<Box<dyn Future<Output = QueryResult<Resp<Self::GetQuerySchemasStream>>> + Send + 'async_trait>>

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

fn initiate_query_protocol<'life0, 'async_trait>( &'life0 self, req: Req<Streaming<InitiateQueryProtocolReq>>, ) -> Pin<Box<dyn Future<Output = QueryResult<Resp<Self::InitiateQueryProtocolStream>>> + Send + 'async_trait>>

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