Class KafkaCluster

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 class KafkaCluster : IKafkaCluster, IDisposable

Inheritance

object

KafkaCluster

Implements

IKafkaCluster

IDisposable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

KafkaCluster(KafkaOptionsExtension, IKafkaTableFactory)

Dfault initializer

public KafkaCluster(KafkaOptionsExtension options, IKafkaTableFactory tableFactory)

Parameters

options KafkaOptionsExtension

tableFactory IKafkaTableFactory

Properties

ClusterId

The Apche Kafka cluster identifier

public virtual string ClusterId { get; }

Property Value

string

Options

The KafkaOptionsExtension

public virtual KafkaOptionsExtension Options { get; }

Property Value

KafkaOptionsExtension

Methods

CreateTable(IEntityType)

Creates a table for IEntityType on Apache Kafka cluster

public virtual string CreateTable(IEntityType entityType)

Parameters

entityType IEntityType

Returns

string

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public virtual void Dispose()

EnsureConnected(IModel, IDiagnosticsLogger<Update>)

Execute the EnsureDatabaseConnected()

public virtual 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()

public virtual 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()

public virtual 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

public virtual 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>

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

Parameters

property IProperty

Returns

KafkaIntegerValueGenerator<TProperty>

Type Parameters

TProperty

GetValueBuffers(IEntityType)

Retrieve the ValueBuffer

public virtual IEnumerable<ValueBuffer> GetValueBuffers(IEntityType entityType)

Parameters

entityType IEntityType

Returns

IEnumerable<ValueBuffer>