runner/plugin.go

package runner

import (
	"github.com/dodopizza/jaeger-kusto/config"
	"github.com/hashicorp/go-hclog"
	storageGRPC "github.com/jaegertracing/jaeger/plugin/storage/grpc"
	"github.com/jaegertracing/jaeger/plugin/storage/grpc/shared"
	googleGRPC "google.golang.org/grpc"
)

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
}