1 interface inheriting from IPipe
Microsoft.ML.Core (1)
Data\IHostEnvironment.cs (1)
247
public interface IChannel :
IPipe
<ChannelMessage>
1 implementation of IPipe
Microsoft.ML.Core (1)
Environment\HostEnvironmentBase.cs (1)
156
protected abstract class PipeBase<TMessage> : ChannelProviderBase,
IPipe
<TMessage>, IMessageSource
22 references to IPipe
Microsoft.ML.Core (10)
Data\IHostEnvironment.cs (1)
24
IPipe
<TMessage> StartPipe<TMessage>(string name);
Data\ServerChannel.cs (3)
63
using (
var
pipe = provider.StartPipe<IPendingBundleNotification>("Server"))
155
/// <see cref="
IPipe
{IPendingBundleNotification}"/> that the server will listen to throughout its
195
/// is a notification sent through an <see cref="
IPipe
{IPendingBundleNotification}"/>, to indicate that
Environment\ConsoleEnvironment.cs (2)
411
protected override
IPipe
<TMessage> CreatePipe<TMessage>(ChannelProviderBase parent, string name)
479
protected override
IPipe
<TMessage> CreatePipe<TMessage>(ChannelProviderBase parent, string name)
Environment\HostEnvironmentBase.cs (4)
152
/// Base class for implementing <see cref="
IPipe
{TMessage}"/>. Deriving classes can optionally override
266
/// An optional implementation of <see cref="
IPipe
{TMessage}"/>.
488
public
IPipe
<TMessage> StartPipe<TMessage>(string name)
495
protected abstract
IPipe
<TMessage> CreatePipe<TMessage>(ChannelProviderBase parent, string name);
Microsoft.ML.Data (11)
Commands\CrossValidationCommand.cs (1)
139
protected override void SendTelemetryCore(
IPipe
<TelemetryMessage> pipe)
Commands\DataCommand.cs (4)
111
using (
var
pipe = prov.StartPipe<TelemetryMessage>("TelemetryPipe"))
117
protected void SendTelemetryComponent(
IPipe
<TelemetryMessage> pipe, IComponentFactory factory)
128
protected virtual void SendTelemetryCore(
IPipe
<TelemetryMessage> pipe)
141
using (
var
pipe = prov.StartPipe<TelemetryMessage>("TelemetryPipe"))
Commands\TrainCommand.cs (1)
130
protected override void SendTelemetryCore(
IPipe
<TelemetryMessage> pipe)
Commands\TrainTestCommand.cs (1)
113
protected override void SendTelemetryCore(
IPipe
<TelemetryMessage> pipe)
MLContext.cs (1)
176
IPipe
<TMessage> IChannelProvider.StartPipe<TMessage>(string name) => _env.StartPipe<TMessage>(name);
Utilities\LocalEnvironment.cs (2)
83
protected override
IPipe
<TMessage> CreatePipe<TMessage>(ChannelProviderBase parent, string name)
107
protected override
IPipe
<TMessage> CreatePipe<TMessage>(ChannelProviderBase parent, string name)
Utilities\TimerScope.cs (1)
51
using (
var
pipe = _host.StartPipe<TelemetryMessage>("TelemetryPipe"))
Microsoft.ML.Maml (1)
MAML.cs (1)
106
using (
var
telemetryPipe = mainHost.StartPipe<TelemetryMessage>("TelemetryPipe"))