1 interface inheriting from IPipe
Microsoft.ML.Core (1)
Data\IHostEnvironment.cs (1)
247public interface IChannel : IPipe<ChannelMessage>
1 implementation of IPipe
Microsoft.ML.Core (1)
Environment\HostEnvironmentBase.cs (1)
156protected abstract class PipeBase<TMessage> : ChannelProviderBase, IPipe<TMessage>, IMessageSource
22 references to IPipe
Microsoft.ML.Core (10)
Data\IHostEnvironment.cs (1)
24IPipe<TMessage> StartPipe<TMessage>(string name);
Data\ServerChannel.cs (3)
63using (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)
411protected override IPipe<TMessage> CreatePipe<TMessage>(ChannelProviderBase parent, string name) 479protected 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}"/>. 488public IPipe<TMessage> StartPipe<TMessage>(string name) 495protected abstract IPipe<TMessage> CreatePipe<TMessage>(ChannelProviderBase parent, string name);
Microsoft.ML.Data (11)
Commands\CrossValidationCommand.cs (1)
139protected override void SendTelemetryCore(IPipe<TelemetryMessage> pipe)
Commands\DataCommand.cs (4)
111using (var pipe = prov.StartPipe<TelemetryMessage>("TelemetryPipe")) 117protected void SendTelemetryComponent(IPipe<TelemetryMessage> pipe, IComponentFactory factory) 128protected virtual void SendTelemetryCore(IPipe<TelemetryMessage> pipe) 141using (var pipe = prov.StartPipe<TelemetryMessage>("TelemetryPipe"))
Commands\TrainCommand.cs (1)
130protected override void SendTelemetryCore(IPipe<TelemetryMessage> pipe)
Commands\TrainTestCommand.cs (1)
113protected override void SendTelemetryCore(IPipe<TelemetryMessage> pipe)
MLContext.cs (1)
176IPipe<TMessage> IChannelProvider.StartPipe<TMessage>(string name) => _env.StartPipe<TMessage>(name);
Utilities\LocalEnvironment.cs (2)
83protected override IPipe<TMessage> CreatePipe<TMessage>(ChannelProviderBase parent, string name) 107protected override IPipe<TMessage> CreatePipe<TMessage>(ChannelProviderBase parent, string name)
Utilities\TimerScope.cs (1)
51using (var pipe = _host.StartPipe<TelemetryMessage>("TelemetryPipe"))
Microsoft.ML.Maml (1)
MAML.cs (1)
106using (var telemetryPipe = mainHost.StartPipe<TelemetryMessage>("TelemetryPipe"))