MemoryStreamQueueGrain Класс

Определение

Пространство имен:

Orleans.Providers

Сборка:

Orleans.Streaming.dll

Пакет:

Microsoft.Orleans.Streaming v8.2.0

Очередь потока памяти. Это зерно работает в качестве очереди хранилища данных событий. Поддерживаются операции enqueue и Dequeue. Максимальное число событий задает максимальное ограничение хранилища для очереди.

public class MemoryStreamQueueGrain : Orleans.Grain, Orleans.IGrainWithGuidKey, Orleans.Providers.IMemoryStreamQueueGrain, Orleans.Runtime.IGrainMigrationParticipant

type MemoryStreamQueueGrain = class
    inherit Grain
    interface IMemoryStreamQueueGrain
    interface IGrainWithGuidKey
    interface IGrain
    interface IAddressable
    interface IGrainMigrationParticipant

Public Class MemoryStreamQueueGrain
Inherits Grain
Implements IGrainMigrationParticipant, IGrainWithGuidKey, IMemoryStreamQueueGrain

Наследование

Object

Grain

MemoryStreamQueueGrain

Реализации

IGrain IGrainWithGuidKey IMemoryStreamQueueGrain IAddressable IGrainMigrationParticipant

Конструкторы

MemoryStreamQueueGrain()

Очередь потока памяти. Это зерно работает в качестве очереди хранилища данных событий. Поддерживаются операции enqueue и Dequeue. Максимальное число событий задает максимальное ограничение хранилища для очереди.

Свойства

GrainContext	Очередь потока памяти. Это зерно работает в качестве очереди хранилища данных событий. Поддерживаются операции enqueue и Dequeue. Максимальное число событий задает максимальное ограничение хранилища для очереди. (Унаследовано от Grain)
GrainFactory	Получает объект, который можно использовать для доступа к другим зернам. Значение NULL, если это зерно не связано с средой выполнения, например при создании непосредственно для модульного тестирования. (Унаследовано от Grain)
GrainReference	Очередь потока памяти. Это зерно работает в качестве очереди хранилища данных событий. Поддерживаются операции enqueue и Dequeue. Максимальное число событий задает максимальное ограничение хранилища для очереди. (Унаследовано от Grain)
IdentityString	Строковое представление SiloIdentity зерна, включая тип и первичный ключ. (Унаследовано от Grain)
RuntimeIdentity	Уникальный идентификатор текущего сило. В этой строке нет семантического содержимого, но это может быть полезно для ведения журнала. (Унаследовано от Grain)
ServiceProvider	Возвращает IServiceProvider, управляемый средой выполнения. Значение NULL, если это зерно не связано с средой выполнения, например при создании непосредственно для модульного тестирования. (Унаследовано от Grain)

Методы

DeactivateOnIdle()	Деактивируйте эту активацию зерна после завершения текущего вызова метода зерна. Этот вызов помечает эту активацию текущего зерна, который будет деактивирован и удален в конце текущего метода. Следующий вызов этого зерна приведет к использованию другой активации, что обычно означает, что новая активация будет создана автоматически средой выполнения. (Унаследовано от Grain)
DelayDeactivation(TimeSpan)	Задержка деактивации этой активации по крайней мере в течение указанного периода времени. Положительное значение timeSpan означает "запретить GC этой активации в течение этого периода времени". Отрицательное значение timeSpan означает "отмена предыдущего параметра вызова DelayDeactivation и выполнение этой активации в зависимости от обычных параметров сборки мусора активации". Метод ДеактивацииOnIdle отменяет или переопределяет любой текущий параметр "сохранить в живых", что делает это зерно немедленно доступным для деактивации. (Унаследовано от Grain)
Dequeue(Int32)	Отменяет до максимального количества данных события maxCount из очереди.
Enqueue(MemoryMessageData)	Заквещает данные события. Если текущее общее число достигает максимального предела. создает исключение.
GetLogger()	Возвращает объект средства ведения журнала, который код этого зерна может использовать для трассировки. Имя средства ведения журнала будет производным от имени класса зерна. (Унаследовано от Grain)
GetLogger(String)	Возвращает объект средства ведения журнала, который код этого зерна может использовать для трассировки. (Унаследовано от Grain)
GetReminder(String)	Возвращает ранее зарегистрированное напоминание. (Унаследовано от Grain)
GetReminders()	Возвращает список всех напоминаний, зарегистрированных зерном. (Унаследовано от Grain)
GetStreamProvider(String)	Очередь потока памяти. Это зерно работает в качестве очереди хранилища данных событий. Поддерживаются операции enqueue и Dequeue. Максимальное число событий задает максимальное ограничение хранилища для очереди. (Унаследовано от Grain)
GetStreamProviders()	Очередь потока памяти. Это зерно работает в качестве очереди хранилища данных событий. Поддерживаются операции enqueue и Dequeue. Максимальное число событий задает максимальное ограничение хранилища для очереди. (Унаследовано от Grain)
MigrateOnIdle()	Запускает попытку переноса этого экземпляра в другое расположение. Миграция фиксирует текущую RequestContext, что делает его доступным для директора размещения активации, чтобы он смог рассмотреть его при выборе нового расположения. Миграция будет выполняться асинхронно, если запросы не выполняются, и не произойдет, если директор размещения активации не выбирает альтернативное расположение. (Унаследовано от Grain)
OnActivateAsync()	Этот метод вызывается в конце процесса активации зерна. Он вызывается до отправки сообщений в зерно. Для зерна с объявленным постоянным состоянием этот метод вызывается после заполнения свойства State. (Унаследовано от Grain)
OnActivateAsync(CancellationToken)	Этот метод вызывается в конце процесса активации зерна. Он вызывается до отправки сообщений в зерно. Для зерна с объявленным постоянным состоянием этот метод вызывается после заполнения свойства State. (Унаследовано от Grain)
OnDeactivateAsync()	Этот метод вызывается в начале процесса деактивации зерна. (Унаследовано от Grain)
OnDeactivateAsync(DeactivationReason, CancellationToken)	Этот метод вызывается в начале процесса деактивации зерна. (Унаследовано от Grain)
Participate(IGrainLifecycle)	Очередь потока памяти. Это зерно работает в качестве очереди хранилища данных событий. Поддерживаются операции enqueue и Dequeue. Максимальное число событий задает максимальное ограничение хранилища для очереди. (Унаследовано от Grain)
RegisterOrUpdateReminder(String, TimeSpan, TimeSpan)	Регистрирует постоянное, надежное напоминание для отправки регулярных уведомлений (напоминаний) на зерно. Зерно должно реализовать интерфейс Orleans.IRemindable, а напоминания об этом зерне будут отправлены в метод обратного вызова ReceiveReminder. Если текущее зерно деактивируется при срабатывании таймера, для получения этого напоминания будет создана новая активация этого зерна. Если существующее напоминание с тем же именем уже существует, это напоминание будет перезаписан с этим новым напоминанием. Напоминания всегда будут получены одной активацией этого зерна, даже если для этого зерна существует несколько активаций. (Унаследовано от Grain)
RegisterTimer(Func<Object,Task>, Object, TimeSpan, TimeSpan)	Устаревшие.. Регистрирует таймер для отправки периодических обратных вызовов в это зерно. (Унаследовано от Grain)
UnregisterReminder(IGrainReminder)	Отменяет регистрацию ранее зарегистрированного напоминания. (Унаследовано от Grain)

Явные реализации интерфейса

IGrainMigrationParticipant.OnDehydrate(IDehydrationContext)	Очередь потока памяти. Это зерно работает в качестве очереди хранилища данных событий. Поддерживаются операции enqueue и Dequeue. Максимальное число событий задает максимальное ограничение хранилища для очереди.
IGrainMigrationParticipant.OnRehydrate(IRehydrationContext)	Очередь потока памяти. Это зерно работает в качестве очереди хранилища данных событий. Поддерживаются операции enqueue и Dequeue. Максимальное число событий задает максимальное ограничение хранилища для очереди.

Методы расширения

DeactivateOnIdle(IGrainBase)	Деактивируйте эту активацию зерна после завершения текущего вызова метода зерна. Этот вызов помечает эту активацию текущего зерна, который будет деактивирован и удален в конце текущего метода. Следующий вызов этого зерна приведет к использованию другой активации, что обычно означает, что новая активация будет создана автоматически средой выполнения.
MigrateOnIdle(IGrainBase)	Запускает попытку переноса этого экземпляра в другое расположение. Миграция фиксирует текущую RequestContext, что делает его доступным для директора размещения активации, чтобы он смог рассмотреть его при выборе нового расположения. Миграция будет выполняться асинхронно, если запросы не выполняются, и не произойдет, если директор размещения активации не выбирает альтернативное расположение.
RegisterGrainTimer(IGrainBase, Func<CancellationToken,Task>, GrainTimerCreationOptions)	Создает таймер зерна.
RegisterGrainTimer(IGrainBase, Func<CancellationToken,Task>, TimeSpan, TimeSpan)	Создает таймер зерна.
RegisterGrainTimer(IGrainBase, Func<Task>, GrainTimerCreationOptions)	Очередь потока памяти. Это зерно работает в качестве очереди хранилища данных событий. Поддерживаются операции enqueue и Dequeue. Максимальное число событий задает максимальное ограничение хранилища для очереди.
RegisterGrainTimer(IGrainBase, Func<Task>, TimeSpan, TimeSpan)	Создает таймер зерна.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,CancellationToken,Task>, TState, GrainTimerCreationOptions)	Создает таймер зерна.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,CancellationToken,Task>, TState, TimeSpan, TimeSpan)	Создает таймер зерна.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,Task>, TState, GrainTimerCreationOptions)	Очередь потока памяти. Это зерно работает в качестве очереди хранилища данных событий. Поддерживаются операции enqueue и Dequeue. Максимальное число событий задает максимальное ограничение хранилища для очереди.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,Task>, TState, TimeSpan, TimeSpan)	Создает таймер зерна.
AsReference(IAddressable, Type)	Возвращает типизированные ссылки на предоставленное зерно.
AsReference<TGrainInterface>(IAddressable)	Возвращает типизированные ссылки на предоставленное зерно.
Cast(IAddressable, Type)	Возвращает типизированные ссылки на предоставленное зерно.
Cast<TGrainInterface>(IAddressable)	Возвращает типизированные ссылки на предоставленное зерно.
GetGrainId(IAddressable)	Возвращает идентификатор зерна, соответствующий предоставленному зерне.
GetPrimaryKey(IAddressable)	Возвращает Guid представление первичного ключа зерна.
GetPrimaryKey(IAddressable, String)	Возвращает Guid представление первичного ключа зерна.
GetPrimaryKeyLong(IAddressable)	Возвращает long представление первичного ключа зерна.
GetPrimaryKeyLong(IAddressable, String)	Возвращает long представление первичного ключа зерна.
GetPrimaryKeyString(IAddressable)	Возвращает первичный ключ string зерна.
IsPrimaryKeyBasedOnLong(IAddressable)	Возвращает, является ли часть первичного ключа типом long.
GetReminder(Grain, String)	Возвращает ранее зарегистрированное напоминание.
GetReminder(IGrainBase, String)	Возвращает ранее зарегистрированное напоминание.
GetReminders(Grain)	Возвращает список всех напоминаний, зарегистрированных зерном.
GetReminders(IGrainBase)	Возвращает список всех напоминаний, зарегистрированных зерном.
RegisterOrUpdateReminder(Grain, String, TimeSpan, TimeSpan)	Регистрирует постоянное, надежное напоминание для отправки регулярных уведомлений (напоминаний) на зерно. Зерно должно реализовать интерфейс Orleans.IRemindable, а напоминания об этом зерне будут отправлены в метод обратного вызова ReceiveReminder. Если текущее зерно деактивируется при срабатывании таймера, для получения этого напоминания будет создана новая активация этого зерна. Если существующее напоминание с тем же именем уже существует, это напоминание будет перезаписан с этим новым напоминанием. Напоминания всегда будут получены одной активацией этого зерна, даже если для этого зерна существует несколько активаций.
RegisterOrUpdateReminder(IGrainBase, String, TimeSpan, TimeSpan)	Регистрирует постоянное, надежное напоминание для отправки регулярных уведомлений (напоминаний) на зерно. Зерно должно реализовать интерфейс Orleans.IRemindable, а напоминания об этом зерне будут отправлены в метод обратного вызова ReceiveReminder. Если текущее зерно деактивируется при срабатывании таймера, для получения этого напоминания будет создана новая активация этого зерна. Если существующее напоминание с тем же именем уже существует, это напоминание будет перезаписан с этим новым напоминанием. Напоминания всегда будут получены одной активацией этого зерна, даже если для этого зерна существует несколько активаций.
UnregisterReminder(Grain, IGrainReminder)	Отменяет регистрацию ранее зарегистрированного напоминания.
UnregisterReminder(IGrainBase, IGrainReminder)	Отменяет регистрацию ранее зарегистрированного напоминания.
GetStreamProvider(Grain, String)	Возвращает поставщик потоков с указанным name.
GetStreamProvider(IGrainBase, String)	Возвращает поставщик потоков с указанным name.