StreamSubscriptionManagerExtensions.AddSubscription 方法

定义

命名空间:

Orleans.Streams.PubSub

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.0

重载

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, GrainId)	将指定的粒度订阅到指定的流。
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Guid, String)	将指定的粒度订阅到指定的流。
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Int64, String)	将指定的粒度订阅到指定的流。
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, String, String)	将指定的粒度订阅到指定的流。
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Guid, String, String)	将指定的粒度订阅到指定的流。
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Int64, String, String)	将指定的粒度订阅到指定的流。

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, GrainId)

将指定的粒度订阅到指定的流。

public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Runtime.StreamId streamId, string streamProviderName, Orleans.Runtime.GrainId grainId) where TGrainInterface : Orleans.IGrainWithGuidKey;

static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Runtime.StreamId * string * Orleans.Runtime.GrainId -> System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> (requires 'GrainInterface :> Orleans.IGrainWithGuidKey)

<Extension()>
Public Function AddSubscription(Of TGrainInterface As IGrainWithGuidKey) (manager As IStreamSubscriptionManager, grainFactory As IGrainFactory, streamId As StreamId, streamProviderName As String, grainId As GrainId) As Task(Of StreamSubscription)

类型参数

TGrainInterface

grain 接口类型。

参数

manager

IStreamSubscriptionManager

经理。

grainFactory

IGrainFactory

粒度工厂。

streamId

StreamId

流标识符。

streamProviderName

String

流提供程序的名称。

grainId

GrainId

要订阅的粒度。

返回

Task<StreamSubscription>

新添加的订阅。

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Guid, String)

将指定的粒度订阅到指定的流。

public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Runtime.StreamId streamId, string streamProviderName, Guid primaryKey, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithGuidKey;

static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Runtime.StreamId * string * Guid * string -> System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> (requires 'GrainInterface :> Orleans.IGrainWithGuidKey)

<Extension()>
Public Function AddSubscription(Of TGrainInterface As IGrainWithGuidKey) (manager As IStreamSubscriptionManager, grainFactory As IGrainFactory, streamId As StreamId, streamProviderName As String, primaryKey As Guid, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

类型参数

TGrainInterface

grain 是主要实现的接口。

参数

manager

IStreamSubscriptionManager

经理。

grainFactory

IGrainFactory

粒度工厂。

streamId

StreamId

流标识符。

streamProviderName

String

流提供程序的名称。

primaryKey

Guid

grain 的主键。

grainClassNamePrefix

String

grain 类名前缀。

返回

Task<StreamSubscription>

新添加的订阅。

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Int64, String)

将指定的粒度订阅到指定的流。

public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Runtime.StreamId streamId, string streamProviderName, long primaryKey, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithIntegerKey;

static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Runtime.StreamId * string * int64 * string -> System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> (requires 'GrainInterface :> Orleans.IGrainWithIntegerKey)

<Extension()>
Public Function AddSubscription(Of TGrainInterface As IGrainWithIntegerKey) (manager As IStreamSubscriptionManager, grainFactory As IGrainFactory, streamId As StreamId, streamProviderName As String, primaryKey As Long, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

类型参数

TGrainInterface

grain 是主要实现的接口。

参数

manager

IStreamSubscriptionManager

经理。

grainFactory

IGrainFactory

粒度工厂。

streamId

StreamId

流标识符。

streamProviderName

String

流提供程序的名称。

primaryKey

Int64

grain 的主键。

grainClassNamePrefix

String

grain 类名前缀。

返回

Task<StreamSubscription>

新添加的订阅。

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, String, String)

将指定的粒度订阅到指定的流。

public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Runtime.StreamId streamId, string streamProviderName, string primaryKey, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithStringKey;

static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Runtime.StreamId * string * string * string -> System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> (requires 'GrainInterface :> Orleans.IGrainWithStringKey)

<Extension()>
Public Function AddSubscription(Of TGrainInterface As IGrainWithStringKey) (manager As IStreamSubscriptionManager, grainFactory As IGrainFactory, streamId As StreamId, streamProviderName As String, primaryKey As String, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

类型参数

TGrainInterface

grain 是主要实现的接口。

参数

manager

IStreamSubscriptionManager

经理。

grainFactory

IGrainFactory

粒度工厂。

streamId

StreamId

流标识符。

streamProviderName

String

流提供程序的名称。

primaryKey

String

grain 的主键。

grainClassNamePrefix

String

grain 类名前缀。

返回

Task<StreamSubscription>

新添加的订阅。

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Guid, String, String)

将指定的粒度订阅到指定的流。

public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Runtime.StreamId streamId, string streamProviderName, Guid primaryKey, string keyExtension, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithGuidCompoundKey;

static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Runtime.StreamId * string * Guid * string * string -> System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> (requires 'GrainInterface :> Orleans.IGrainWithGuidCompoundKey)

<Extension()>
Public Function AddSubscription(Of TGrainInterface As IGrainWithGuidCompoundKey) (manager As IStreamSubscriptionManager, grainFactory As IGrainFactory, streamId As StreamId, streamProviderName As String, primaryKey As Guid, keyExtension As String, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

类型参数

TGrainInterface

grain 是主要实现的接口。

参数

manager

IStreamSubscriptionManager

经理。

grainFactory

IGrainFactory

粒度工厂。

streamId

StreamId

流标识符。

streamProviderName

String

流提供程序的名称。

primaryKey

Guid

grain 的主键。

keyExtension

String

grain 的密钥扩展。

grainClassNamePrefix

String

grain 类名前缀。

返回

Task<StreamSubscription>

新添加的订阅。

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Int64, String, String)

将指定的粒度订阅到指定的流。

public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Runtime.StreamId streamId, string streamProviderName, long primaryKey, string keyExtension, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithIntegerCompoundKey;

static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Runtime.StreamId * string * int64 * string * string -> System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> (requires 'GrainInterface :> Orleans.IGrainWithIntegerCompoundKey)

<Extension()>
Public Function AddSubscription(Of TGrainInterface As IGrainWithIntegerCompoundKey) (manager As IStreamSubscriptionManager, grainFactory As IGrainFactory, streamId As StreamId, streamProviderName As String, primaryKey As Long, keyExtension As String, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

类型参数

TGrainInterface

grain 是主要实现的接口。

参数

manager

IStreamSubscriptionManager

经理。

grainFactory

IGrainFactory

粒度工厂。

streamId

StreamId

流标识符。

streamProviderName

String

流提供程序的名称。

primaryKey

Int64

grain 的主键。

keyExtension

String

grain 的密钥扩展。

grainClassNamePrefix

String

grain 类名前缀。

返回

Task<StreamSubscription>

新添加的订阅。