Class Operators
Rendezvous related operators.
Namespace: Microsoft.Psi.Interop.Rendezvous
Assembly: Microsoft.Psi.Interop.dll
Syntax
public static class Operators : object
Methods
View SourceToNetMQSource<T>(Rendezvous.NetMQSourceEndpoint, Pipeline, String, IFormatDeserializer, Boolean)
Create a NetMQSource<T> from a Rendezvous.NetMQSourceEndpoint.
Declaration
public static NetMQSource<T> ToNetMQSource<T>(this Rendezvous.NetMQSourceEndpoint endpoint, Pipeline pipeline, string topic, IFormatDeserializer deserializer, bool useSourceOriginatingTimes = true)
Parameters
Type | Name | Description |
---|---|---|
Rendezvous.NetMQSourceEndpoint | endpoint | Rendezvous.NetMQSourceEndpoint from which to create . |
Pipeline | pipeline | The pipeline to add the component to. |
String | topic | Topic name. |
IFormatDeserializer | deserializer | The deserializer to use to deserialize messages. |
System.Boolean | useSourceOriginatingTimes | Flag indicating whether or not to post with originating times received over the socket. If false, we ignore them and instead use pipeline's current time. |
Returns
Type | Description |
---|---|
NetMQSource<T> |
Type Parameters
Name | Description |
---|---|
T | Type of data stream. |
ToRemoteClockImporter(Rendezvous.RemoteClockExporterEndpoint, Pipeline)
Create a RemoteClockImporter from a Rendezvous.RemoteClockExporterEndpoint.
Declaration
public static RemoteClockImporter ToRemoteClockImporter(this Rendezvous.RemoteClockExporterEndpoint endpoint, Pipeline pipeline)
Parameters
Type | Name | Description |
---|---|---|
Rendezvous.RemoteClockExporterEndpoint | endpoint | Rendezvous.RemoteClockExporterEndpoint from which to create . |
Pipeline | pipeline | The pipeline to add the component to. |
Returns
Type | Description |
---|---|
RemoteClockImporter |
ToRemoteImporter(Rendezvous.RemoteExporterEndpoint, Pipeline)
Create a RemoteImporter from a Rendezvous.RemoteExporterEndpoint.
Declaration
public static RemoteImporter ToRemoteImporter(this Rendezvous.RemoteExporterEndpoint endpoint, Pipeline pipeline)
Parameters
Type | Name | Description |
---|---|---|
Rendezvous.RemoteExporterEndpoint | endpoint | Rendezvous.RemoteExporterEndpoint from which to create . |
Pipeline | pipeline | The pipeline to add the component to. |
Returns
Type | Description |
---|---|
RemoteImporter |
ToRendezvousEndpoint(NetMQWriter)
Create a rendezvous endpoint from a NetMQWriter.
Declaration
public static Rendezvous.Endpoint ToRendezvousEndpoint(this NetMQWriter writer)
Parameters
Type | Name | Description |
---|---|---|
NetMQWriter | writer | NetMQWriter from which to create endpoint. |
Returns
Type | Description |
---|---|
Rendezvous.Endpoint | Rendezvous endpoint. |
ToRendezvousEndpoint(RemoteClockExporter, String)
Create a rendezvous endpoint from a RemoteClockExporter.
Declaration
public static Rendezvous.Endpoint ToRendezvousEndpoint(this RemoteClockExporter exporter, string host)
Parameters
Type | Name | Description |
---|---|---|
RemoteClockExporter | exporter | RemoteClockExporter from which to create endpoint. |
String | host | Host address with which to create endpoint. |
Returns
Type | Description |
---|---|
Rendezvous.Endpoint | Rendezvous endpoint. |
ToRendezvousEndpoint(RemoteExporter, String)
Create a rendezvous endpoint from a RemoteExporter.
Declaration
public static Rendezvous.Endpoint ToRendezvousEndpoint(this RemoteExporter exporter, string host)
Parameters
Type | Name | Description |
---|---|---|
RemoteExporter | exporter | RemoteExporter from which to create endpoint. |
String | host | Host name with which to create endpoint. |
Returns
Type | Description |
---|---|
Rendezvous.Endpoint | Rendezvous endpoint. |
ToRendezvousEndpoint<T>(TcpWriter<T>, String, String)
Create a rendezvous endpoint from a TcpWriter<T>.
Declaration
public static Rendezvous.Endpoint ToRendezvousEndpoint<T>(this TcpWriter<T> writer, string address, string streamName)
Parameters
Type | Name | Description |
---|---|---|
TcpWriter<T> | writer | TcpWriter<T> from which to create endpoint. |
String | address | Address with which to create endpoint. |
String | streamName | The name of the rendezvous stream. |
Returns
Type | Description |
---|---|
Rendezvous.Endpoint | Rendezvous endpoint. |
Type Parameters
Name | Description |
---|---|
T | Type of data stream. |
ToTcpSource<T>(Rendezvous.TcpSourceEndpoint, Pipeline, IFormatDeserializer, Action<T>, Boolean, String)
Create a TcpSource<T> from a Rendezvous.TcpSourceEndpoint.
Declaration
public static TcpSource<T> ToTcpSource<T>(this Rendezvous.TcpSourceEndpoint endpoint, Pipeline pipeline, IFormatDeserializer deserializer, Action<T> deallocator = null, bool useSourceOriginatingTimes = true, string name = "TcpSource")
Parameters
Type | Name | Description |
---|---|---|
Rendezvous.TcpSourceEndpoint | endpoint | Rendezvous.TcpSourceEndpoint from which to create . |
Pipeline | pipeline | The pipeline to add the component to. |
IFormatDeserializer | deserializer | The deserializer to use to deserialize messages. |
Action<T> | deallocator | An optional deallocator for the data. |
System.Boolean | useSourceOriginatingTimes | An optional parameter indicating whether to use originating times received from the source over the network or to re-timestamp with the current pipeline time upon receiving. |
String | name | An optional name for the TCP source component. |
Returns
Type | Description |
---|---|
TcpSource<T> |
Type Parameters
Name | Description |
---|---|
T | Type of data stream. |
WriteToRendezvousProcess<T>(IProducer<T>, String, Rendezvous.Process, String, Int32, IFormatSerializer, DeliveryPolicy)
Writes a stream to a specified rendezvous process.
Declaration
public static void WriteToRendezvousProcess<T>(this IProducer<T> source, string streamName, Rendezvous.Process rendezvousProcess, string address, int port, IFormatSerializer serializer, DeliveryPolicy deliveryPolicy = null)
Parameters
Type | Name | Description |
---|---|---|
IProducer<T> | source | The source stream to write. |
String | streamName | The name under which to write the stream to the rendezvous process. |
Rendezvous.Process | rendezvousProcess | The rendezvous process. |
String | address | The address to write the stream to. |
System.Int32 | port | The port to write the stream to. |
IFormatSerializer | serializer | The serializer to use when writing the stream. |
DeliveryPolicy | deliveryPolicy | An optional delivery policy. |
Type Parameters
Name | Description |
---|---|
T | The type of data in the stream. |