func servePlugin()

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
}