Interface IKafkaCluster

Namespace

MASES.EntityFrameworkCore.KNet.Storage.Internal

Assembly

MASES.EntityFrameworkCore.KNet.dll

This is an internal API that supports the Entity Framework Core infrastructure and not subject to the same compatibility standards as public APIs. It may be changed or removed without notice in any release. You should only use it directly in your code with extreme caution and knowing that doing so can result in application failures when updating to a new Entity Framework Core release.

public interface IKafkaCluster : IDisposable

Inherited Members

IDisposable.Dispose()

Properties

ClusterId

The Apche Kafka cluster identifier

string ClusterId { get; }

Property Value

string

Options

The KafkaOptionsExtension

KafkaOptionsExtension Options { get; }

Property Value

KafkaOptionsExtension

Methods

CreateTopicForEntity(IEntityType)

Creates a topic for IEntityType on Apache Kafka cluster

string CreateTopicForEntity(IEntityType entityType)

Parameters

entityType IEntityType

Returns

string

EnsureConnected(IModel, IDiagnosticsLogger<Update>)

Execute the EnsureDatabaseConnected()

bool EnsureConnected(IModel designModel, IDiagnosticsLogger<DbLoggerCategory.Update> updateLogger)

Parameters

designModel IModel

updateLogger IDiagnosticsLogger<DbLoggerCategory.Update>

Returns

bool

EnsureCreated(IUpdateAdapterFactory, IModel, IDiagnosticsLogger<Update>)

Execute the EnsureDatabaseCreated()

bool EnsureCreated(IUpdateAdapterFactory updateAdapterFactory, IModel designModel, IDiagnosticsLogger<DbLoggerCategory.Update> updateLogger)

Parameters

updateAdapterFactory IUpdateAdapterFactory

designModel IModel

updateLogger IDiagnosticsLogger<DbLoggerCategory.Update>

Returns

bool

EnsureDeleted(IUpdateAdapterFactory, IModel, IDiagnosticsLogger<Update>)

Execute the EnsureDatabaseDeleted()

bool EnsureDeleted(IUpdateAdapterFactory updateAdapterFactory, IModel designModel, IDiagnosticsLogger<DbLoggerCategory.Update> updateLogger)

Parameters

updateAdapterFactory IUpdateAdapterFactory

designModel IModel

updateLogger IDiagnosticsLogger<DbLoggerCategory.Update>

Returns

bool

ExecuteTransaction(IList<IUpdateEntry>, IDiagnosticsLogger<Update>)

Executes a transaction

int ExecuteTransaction(IList<IUpdateEntry> entries, IDiagnosticsLogger<DbLoggerCategory.Update> updateLogger)

Parameters

entries IList<IUpdateEntry>

updateLogger IDiagnosticsLogger<DbLoggerCategory.Update>

Returns

int

GetIntegerValueGenerator<TProperty>(IProperty)

Gets the KafkaIntegerValueGenerator<TValue>

KafkaIntegerValueGenerator<TProperty> GetIntegerValueGenerator<TProperty>(IProperty property)

Parameters

property IProperty

Returns

KafkaIntegerValueGenerator<TProperty>

Type Parameters

TProperty

GetValueBuffers(IEntityType)

Retrieve the ValueBuffer

IEnumerable<ValueBuffer> GetValueBuffers(IEntityType entityType)

Parameters

entityType IEntityType

Returns

IEnumerable<ValueBuffer>