in runner/plugin.go [11:28]
func servePlugin(c *config.PluginConfig, store shared.StoragePlugin, logger hclog.Logger) error {
pluginServices := shared.PluginServices{
Store: store,
}
tracer, closer, err := config.NewPluginTracer(c)
if err != nil {
return err
}
defer closer.Close()
logger.Info("starting plugin")
storageGRPC.ServeWithGRPCServer(&pluginServices, func(options []googleGRPC.ServerOption) *googleGRPC.Server {
return newGRPCServerWithTracer(tracer)
})
return nil
}