Interface IDataStreamerReceiverContext

Namespace

Apache.Ignite.Table

Assembly

Apache.Ignite.dll

Data streamer receiver execution context. See IDataStreamerReceiver<TItem, TArg, TResult>.

public interface IDataStreamerReceiverContext

Properties

Ignite

Gets the Ignite API entry point.

IIgnite Ignite { get; }

Property Value

IIgnite

LoggerFactory

Gets the logger factory backed by the server node log.

Messages are forwarded to the Ignite node executing this receiver and written under the category name passed to CreateLogger(string), so per-category level filtering is controlled by the server's logging configuration (IsEnabled(LogLevel) reflects the server-side levels). BeginScope<TState>(TState) is supported; the active scope is prepended to each message.

public sealed class MyReceiver : IDataStreamerReceiver<string, object?, string>
{
    public ValueTask<IList<string>?> ReceiveAsync(
        IList<string> page, object? arg, IDataStreamerReceiverContext context, CancellationToken ct)
    {
        ILogger logger = context.LoggerFactory.CreateLogger<MyReceiver>();
        logger.LogInformation("Received {Count} items", page.Count);
        return ValueTask.FromResult<IList<string>?>(null);
    }
}

ILoggerFactory LoggerFactory { get; }

Property Value

ILoggerFactory