grr-plugin 0.2.0

A Rust-based go-plugin implementation, to allow Rust plugins into Go programs.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

// Copied from: https://github.com/hashicorp/go-plugin/blob/master/grpc_controller.go
pub mod grpc_plugins {
    tonic::include_proto!("plugin");
}

use grpc_plugins::grpc_controller_server::{GrpcController, GrpcControllerServer};
use grpc_plugins::Empty;
use tonic::{async_trait, Request, Response, Status};

pub fn new_server(trigger: triggered::Trigger) -> GrpcControllerServer<GrpcControllerImpl> {
    GrpcControllerServer::new(GrpcControllerImpl { trigger })
}

#[derive(Clone)]
pub struct GrpcControllerImpl {
    trigger: triggered::Trigger,
}

#[async_trait]
impl GrpcController for GrpcControllerImpl {
    async fn shutdown(&self, _req: Request<Empty>) -> Result<Response<Empty>, Status> {
        log::info!("shutdown called. Stopping grpc server...");

        self.trigger.trigger();
        Ok(Response::new(Empty {}))
    }
}