Поделиться через

EventHubCheckpointer.Create Метод

  • Ссылка

Определение

Пространство имен:
Orleans.ServiceBus.Providers
Сборка:
OrleansServiceBus.dll
Сборка:
Orleans.Streaming.EventHubs.dll
Пакет:
Microsoft.Orleans.OrleansServiceBus v1.5.10
Пакет:
Microsoft.Orleans.OrleansServiceBus v2.4.5
Пакет:
Microsoft.Orleans.OrleansServiceBus v3.6.5

Перегрузки

Create(ICheckpointerSettings, String, String)

Заводская функция, которая создает и инициализирует контрольную точку
Create(AzureTableStreamCheckpointerOptions, String, String, String, ILoggerFactory)

Заводская функция, которая создает и инициализирует контрольную точку

Create(ICheckpointerSettings, String, String)

Заводская функция, которая создает и инициализирует контрольную точку

public static System.Threading.Tasks.Task<Orleans.Streams.IStreamQueueCheckpointer<string>> Create (Orleans.ServiceBus.Providers.ICheckpointerSettings settings, string streamProviderName, string partition);
static member Create : Orleans.ServiceBus.Providers.ICheckpointerSettings * string * string -> System.Threading.Tasks.Task<Orleans.Streams.IStreamQueueCheckpointer<string>>
Public Shared Function Create (settings As ICheckpointerSettings, streamProviderName As String, partition As String) As Task(Of IStreamQueueCheckpointer(Of String))

Параметры

settings
ICheckpointerSettings
streamProviderName
String
partition
String

Возвращаемое значение

Task<IStreamQueueCheckpointer<String>>

Применяется к

Create(AzureTableStreamCheckpointerOptions, String, String, String, ILoggerFactory)

Исходный код:
EventHubCheckpointer.cs

Заводская функция, которая создает и инициализирует контрольную точку

public static System.Threading.Tasks.Task<Orleans.Streams.IStreamQueueCheckpointer<string>> Create (Orleans.Configuration.AzureTableStreamCheckpointerOptions options, string streamProviderName, string partition, string serviceId, Microsoft.Extensions.Logging.ILoggerFactory loggerFactory);
static member Create : Orleans.Configuration.AzureTableStreamCheckpointerOptions * string * string * string * Microsoft.Extensions.Logging.ILoggerFactory -> System.Threading.Tasks.Task<Orleans.Streams.IStreamQueueCheckpointer<string>>
Public Shared Function Create (options As AzureTableStreamCheckpointerOptions, streamProviderName As String, partition As String, serviceId As String, loggerFactory As ILoggerFactory) As Task(Of IStreamQueueCheckpointer(Of String))

Параметры

options
AzureTableStreamCheckpointerOptions
streamProviderName
String
partition
String
serviceId
String
loggerFactory
ILoggerFactory

Возвращаемое значение

Task<IStreamQueueCheckpointer<String>>

Применяется к