in src/Library/Inputs/GrpcInput/GrpcInput.cs [33:68]
public void Start()
{
if (this.IsRunning)
{
throw new InvalidOperationException(
FormattableString.Invariant($"Can't Start the input, it's already running"));
}
this.stats = new InputStats();
this.cts = new CancellationTokenSource();
try
{
this.server = new Server
{
Services =
{
Tracespan.HandleTraceSpanService.BindService(new IstioMixerTraceSpanService( (request, context) =>
{
this.OnDataReceived(request, context);
return Task.FromResult(new ReportResult());
}))
},
Ports = {new ServerPort(this.host, this.port, ServerCredentials.Insecure)}
};
this.server.Start();
this.IsRunning = true;
}
catch (System.Exception e)
{
throw new InvalidOperationException(
FormattableString.Invariant($"Could not initialize the gRPC server. {e.ToString()}"));
}
}