diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Query.Internal.KafkaQueryContext.html b/docs/api/MASES.EntityFrameworkCore.KNet.Query.Internal.KafkaQueryContext.html index 9a62db47..d0931b4f 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Query.Internal.KafkaQueryContext.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Query.Internal.KafkaQueryContext.html @@ -132,7 +132,7 @@

Properties Improve this Doc - View Source + View Source

Cluster

diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.IKafkaSerdesEntityType.html b/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.IKafkaSerdesEntityType.html deleted file mode 100644 index 4801376f..00000000 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.IKafkaSerdesEntityType.html +++ /dev/null @@ -1,631 +0,0 @@ - - - - - - - - Interface IKafkaSerdesEntityType - | Kafka Bridge website - - - - - - - - - - - - - - - -
-
- - - - -
- - - -
- - - - - - diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.IKafkaSerdesFactory.html b/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.IKafkaSerdesFactory.html deleted file mode 100644 index 30f1b217..00000000 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.IKafkaSerdesFactory.html +++ /dev/null @@ -1,316 +0,0 @@ - - - - - - - - Interface IKafkaSerdesFactory - | Kafka Bridge website - - - - - - - - - - - - - - - -
-
- - - - -
- - - -
- - - - - - diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.KafkaSerdesEntityType.html b/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.KafkaSerdesEntityType.html deleted file mode 100644 index 41bfcd43..00000000 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.KafkaSerdesEntityType.html +++ /dev/null @@ -1,749 +0,0 @@ - - - - - - - - Class KafkaSerdesEntityType - | Kafka Bridge website - - - - - - - - - - - - - - - -
-
- - - - -
- - - -
- - - - - - diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.KafkaSerdesEntityTypeData.html b/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.KafkaSerdesEntityTypeData.html deleted file mode 100644 index 8c25e40a..00000000 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.KafkaSerdesEntityTypeData.html +++ /dev/null @@ -1,272 +0,0 @@ - - - - - - - - Class KafkaSerdesEntityTypeData - | Kafka Bridge website - - - - - - - - - - - - - - - -
-
- - - - -
- - - -
- - - - - - diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.KafkaSerdesFactory.html b/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.KafkaSerdesFactory.html deleted file mode 100644 index df611053..00000000 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.KafkaSerdesFactory.html +++ /dev/null @@ -1,419 +0,0 @@ - - - - - - - - Class KafkaSerdesFactory - | Kafka Bridge website - - - - - - - - - - - - - - - -
-
- - - - -
- - - -
- - - - - - diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.EntityTypeProducer-1.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.EntityTypeProducer-1.html index a97a967a..ac2c1878 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.EntityTypeProducer-1.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.EntityTypeProducer-1.html @@ -137,7 +137,7 @@

Constructors Improve this Doc - View Source + View Source

EntityTypeProducer(IEntityType, IKafkaCluster)

@@ -169,6 +169,38 @@
Parameters
+

Properties +

+ + | + Improve this Doc + + + View Source + + +

ValueBuffers

+
+
+
Declaration
+
+
public IEnumerable<ValueBuffer> ValueBuffers { get; }
+
+
Property Value
+ + + + + + + + + + + + + +
TypeDescription
IEnumerable<ValueBuffer>

Methods

@@ -176,7 +208,7 @@

Methods Improve this Doc - View Source + View Source

Commit(IEnumerable<IKafkaRowBag>)

@@ -223,7 +255,7 @@
Returns
Improve this Doc
- View Source + View Source

Dispose()

@@ -233,36 +265,6 @@
Declaration
public void Dispose()
- - | - Improve this Doc - - - View Source - - -

GetValueBuffer()

-
-
-
Declaration
-
-
public IEnumerable<ValueBuffer> GetValueBuffer()
-
-
Returns
- - - - - - - - - - - - - -
TypeDescription
IEnumerable<ValueBuffer>

Implements

IEntityTypeProducer @@ -281,7 +283,7 @@

Implements

Improve this Doc
  • - View Source + View Source
  • diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.EntityTypeProducers.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.EntityTypeProducers.html index 93283aad..a1005cde 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.EntityTypeProducers.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.EntityTypeProducers.html @@ -117,7 +117,7 @@

    Methods Improve this Doc - View Source + View Source

    Create<TKey>(IEntityType, IKafkaCluster)

    @@ -190,7 +190,7 @@
    Type Parameters
    Improve this Doc
  • - View Source + View Source
  • diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IEntityTypeData.html similarity index 51% rename from docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.html rename to docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IEntityTypeData.html index 19a8cbbd..b5249d74 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Serdes.Internal.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IEntityTypeData.html @@ -5,10 +5,10 @@ - Namespace MASES.EntityFrameworkCore.KNet.Serdes.Internal + <title>Interface IEntityTypeData | Kafka Bridge website - @@ -68,27 +68,58 @@
    -
    +
    -

    Namespace MASES.EntityFrameworkCore.KNet.Serdes.Internal + +

    Interface IEntityTypeData

    -
    -

    Classes -

    -

    KafkaSerdesEntityType

    -
    -

    KafkaSerdesEntityTypeData

    -
    -

    KafkaSerdesFactory

    -
    -

    Interfaces +

    Namespace: MASES.EntityFrameworkCore.KNet.Storage.Internal
    +
    Assembly: MASES.EntityFrameworkCore.KNet.dll
    +
    Syntax
    +
    +
    public interface IEntityTypeData
    +
    +

    Methods

    -

    IKafkaSerdesEntityType

    -
    -

    IKafkaSerdesFactory

    -
    + + | + Improve this Doc + + + View Source + + +

    GetData(IEntityType, ref Object[])

    +
    +
    +
    Declaration
    +
    +
    void GetData(IEntityType tName, ref object[] array)
    +
    +
    Parameters
    + + + + + + + + + + + + + + + + + + + + +
    TypeNameDescription
    IEntityTypetName
    Object[]array
    @@ -96,6 +127,12 @@

    -

    Methods +

    Properties

    | - Improve this Doc + Improve this Doc - View Source + View Source - -

    Commit(IEnumerable<IKafkaRowBag>)

    + +

    ValueBuffers

    Declaration
    -
    IEnumerable<Future<RecordMetadata>> Commit(IEnumerable<IKafkaRowBag> records)
    +
    IEnumerable<ValueBuffer> ValueBuffers { get; }
    -
    Parameters
    +
    Property Value
    - - - +
    TypeName Description
    IEnumerable<IKafkaRowBag>recordsIEnumerable<ValueBuffer>
    -
    Returns
    +

    Methods +

    + + | + Improve this Doc + + + View Source + + +

    Commit(IEnumerable<IKafkaRowBag>)

    +
    +
    +
    Declaration
    +
    +
    IEnumerable<Future<RecordMetadata>> Commit(IEnumerable<IKafkaRowBag> records)
    +
    +
    Parameters
    + - + +
    TypeName Description
    IEnumerable<Java.Util.Concurrent.Future<Org.Apache.Kafka.Clients.Producer.RecordMetadata>>IEnumerable<IKafkaRowBag>records
    - - | - Improve this Doc - - - View Source - - -

    GetValueBuffer()

    -
    -
    -
    Declaration
    -
    -
    IEnumerable<ValueBuffer> GetValueBuffer()
    -
    Returns
    @@ -155,7 +157,7 @@
    Returns
    - + diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IKafkaCluster.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IKafkaCluster.html index c718e675..c5b4de89 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IKafkaCluster.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IKafkaCluster.html @@ -88,7 +88,7 @@

    Properties Improve this Doc - View Source + View Source

    Options

    @@ -113,36 +113,6 @@
    Property Value
    IEnumerable<ValueBuffer>IEnumerable<Java.Util.Concurrent.Future<Org.Apache.Kafka.Clients.Producer.RecordMetadata>>
    - - | - Improve this Doc - - - View Source - - -

    SerdesFactory

    -
    -
    -
    Declaration
    -
    -
    IKafkaSerdesFactory SerdesFactory { get; }
    -
    -
    Property Value
    - - - - - - - - - - - - - -
    TypeDescription
    IKafkaSerdesFactory

    Methods

    @@ -150,7 +120,7 @@

    Methods Improve this Doc - View Source + View Source

    CreateTable(IEntityType)

    @@ -197,7 +167,7 @@
    Returns
    Improve this Doc
    - View Source + View Source

    EnsureConnected(IModel, IDiagnosticsLogger<DbLoggerCategory.Update>)

    @@ -249,7 +219,7 @@
    Returns
    Improve this Doc - View Source + View Source

    EnsureCreated(IUpdateAdapterFactory, IModel, IDiagnosticsLogger<DbLoggerCategory.Update>)

    @@ -306,7 +276,7 @@
    Returns
    Improve this Doc - View Source + View Source

    EnsureDeleted(IUpdateAdapterFactory, IModel, IDiagnosticsLogger<DbLoggerCategory.Update>)

    @@ -363,7 +333,7 @@
    Returns
    Improve this Doc - View Source + View Source

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

    @@ -412,18 +382,18 @@
    Returns
    | - Improve this Doc + Improve this Doc - View Source + View Source - -

    GetData(IEntityType)

    + +

    GetIntegerValueGenerator<TProperty>(IProperty)

    Declaration
    -
    IEnumerable<ValueBuffer> GetData(IEntityType entityType)
    +
    KafkaIntegerValueGenerator<TProperty> GetIntegerValueGenerator<TProperty>(IProperty property)
    Parameters
    @@ -436,8 +406,8 @@
    Parameters
    - - + + @@ -452,25 +422,40 @@
    Returns
    - + + + + +
    IEntityTypeentityTypeIPropertyproperty
    IEnumerable<ValueBuffer>KafkaIntegerValueGenerator<TProperty>
    +
    Type Parameters
    + + + + + + + + + +
    NameDescription
    TProperty
    | - Improve this Doc + Improve this Doc - View Source + View Source - -

    GetIntegerValueGenerator<TProperty>(IProperty)

    + +

    GetValueBuffers(IEntityType)

    Declaration
    -
    KafkaIntegerValueGenerator<TProperty> GetIntegerValueGenerator<TProperty>(IProperty property)
    +
    IEnumerable<ValueBuffer> GetValueBuffers(IEntityType entityType)
    Parameters
    @@ -483,8 +468,8 @@
    Parameters
    - - + + @@ -499,22 +484,7 @@
    Returns
    - - - - -
    IPropertypropertyIEntityTypeentityType
    KafkaIntegerValueGenerator<TProperty>
    -
    Type Parameters
    - - - - - - - - - - + @@ -530,7 +500,7 @@
    Type Parameters
    Improve this Doc
  • - View Source + View Source
  • diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IKafkaRowBag.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IKafkaRowBag.html index beb7a0dd..ae2e8399 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IKafkaRowBag.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IKafkaRowBag.html @@ -88,7 +88,7 @@

    Properties Improve this Doc - View Source + View Source

    AssociatedTopicName

    @@ -118,7 +118,7 @@
    Property Value
    Improve this Doc - View Source + View Source

    UpdateEntry

    @@ -154,7 +154,7 @@
    Property Value
    Improve this Doc
  • - View Source + View Source
  • diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IKafkaStreamsBaseRetriever.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IKafkaStreamsBaseRetriever.html index edcf1792..80125a46 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IKafkaStreamsBaseRetriever.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.IKafkaStreamsBaseRetriever.html @@ -92,7 +92,7 @@

    +
    +
    Inherited Members
    +
    + IEntityTypeProducer.Commit(IEnumerable<IKafkaRowBag>) +
    +
    + IEntityTypeProducer.ValueBuffers +
    +

    Namespace: MASES.EntityFrameworkCore.KNet.Storage.Internal
    Assembly: MASES.EntityFrameworkCore.KNet.dll
    Syntax
    -
    public interface IKafkaTable
    +
    public interface IKafkaTable : IEntityTypeProducer

    Properties

    @@ -88,7 +97,7 @@

    Properties Improve this Doc - View Source + View Source

    Cluster

    @@ -118,7 +127,7 @@
    Property Value
    Improve this Doc - View Source + View Source

    EntityType

    @@ -148,7 +157,7 @@
    Property Value
    Improve this Doc - View Source + View Source

    Rows

    @@ -173,36 +182,6 @@
    Property Value
    NameDescription
    TPropertyIEnumerable<ValueBuffer>
    - - | - Improve this Doc - - - View Source - - -

    ValueBuffers

    -
    -
    -
    Declaration
    -
    -
    IEnumerable<ValueBuffer> ValueBuffers { get; }
    -
    -
    Property Value
    - - - - - - - - - - - - - -
    TypeDescription
    IEnumerable<ValueBuffer>

    Methods

    @@ -210,7 +189,7 @@

    Methods Improve this Doc - View Source + View Source

    BumpValueGenerators(Object[])

    @@ -237,59 +216,12 @@
    Parameters
    - - | - Improve this Doc - - - View Source - - -

    Commit(IEnumerable<IKafkaRowBag>)

    -
    -
    -
    Declaration
    -
    -
    IEnumerable<Future<RecordMetadata>> Commit(IEnumerable<IKafkaRowBag> records)
    -
    -
    Parameters
    - - - - - - - - - - - - - - - -
    TypeNameDescription
    IEnumerable<IKafkaRowBag>records
    -
    Returns
    - - - - - - - - - - - - - -
    TypeDescription
    IEnumerable<Java.Util.Concurrent.Future<Org.Apache.Kafka.Clients.Producer.RecordMetadata>>
    | Improve this Doc - View Source + View Source

    Create(IUpdateEntry)

    @@ -336,7 +268,7 @@
    Returns
    Improve this Doc
    - View Source + View Source

    Delete(IUpdateEntry)

    @@ -383,7 +315,7 @@
    Returns
    Improve this Doc - View Source + View Source

    GetIntegerValueGenerator<TProperty>(IProperty, IReadOnlyList<IKafkaTable>)

    @@ -480,7 +412,7 @@
    Returns
    Improve this Doc - View Source + View Source

    Update(IUpdateEntry)

    diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KNetEntityTypeData-1.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KNetEntityTypeData-1.html index d2127c61..bca6eee9 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KNetEntityTypeData-1.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KNetEntityTypeData-1.html @@ -80,6 +80,10 @@
    Inheritance
    Object
    KNetEntityTypeData<TKey>
    +
    +
    Implements
    +
    IEntityTypeData
    +
    Inherited Members
    @@ -109,7 +113,7 @@
    Assembly: MASES.EntityFrameworkCore.KNet.dll
    Syntax
    [JsonSerializable(typeof(KNetEntityTypeData<>))]
    -public class KNetEntityTypeData<TKey>
    +public class KNetEntityTypeData<TKey> : IEntityTypeData
    Type Parameters
    @@ -133,7 +137,7 @@

    Constructors Improve this Doc - View Source + View Source

    KNetEntityTypeData()

    @@ -148,7 +152,7 @@
    Declaration
    Improve this Doc - View Source + View Source

    KNetEntityTypeData(IEntityType, IProperty[], Object[])

    @@ -192,7 +196,7 @@

    Properties Improve this Doc - View Source + View Source

    Data

    @@ -222,7 +226,7 @@
    Property Value
    Improve this Doc - View Source + View Source

    TypeName

    @@ -251,18 +255,18 @@

    Methods

    | - Improve this Doc + Improve this Doc - View Source + View Source -

    GetData(IEntityType)

    +

    GetData(IEntityType, ref Object[])

    Declaration
    -
    public object[] GetData(IEntityType tName)
    +
    public void GetData(IEntityType tName, ref object[] array)
    Parameters
    @@ -279,23 +283,17 @@
    Parameters
    - -
    tName
    -
    Returns
    - - - - - - - - +
    TypeDescription
    Object[]array
    +

    Implements

    +
    + IEntityTypeData +
    @@ -307,7 +305,7 @@
    Returns
    Improve this Doc
  • - View Source + View Source
  • diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html index 983e5c09..3d31492b 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html @@ -119,18 +119,18 @@

    Constructors

    | - Improve this Doc + Improve this Doc View Source -

    KafkaCluster(KafkaOptionsExtension, IKafkaTableFactory, IKafkaSerdesFactory)

    +

    KafkaCluster(KafkaOptionsExtension, IKafkaTableFactory)

    Declaration
    -
    public KafkaCluster(KafkaOptionsExtension options, IKafkaTableFactory tableFactory, IKafkaSerdesFactory serdesFactory)
    +
    public KafkaCluster(KafkaOptionsExtension options, IKafkaTableFactory tableFactory)
    Parameters
    @@ -152,11 +152,6 @@
    Parameters
    - - - - -
    tableFactory
    IKafkaSerdesFactoryserdesFactory

    Properties @@ -166,7 +161,7 @@

    Properties Improve this Doc - View Source + View Source

    Options

    @@ -191,36 +186,6 @@
    Property Value
    - - | - Improve this Doc - - - View Source - - -

    SerdesFactory

    -
    -
    -
    Declaration
    -
    -
    public virtual IKafkaSerdesFactory SerdesFactory { get; }
    -
    -
    Property Value
    - - - - - - - - - - - - - -
    TypeDescription
    IKafkaSerdesFactory

    Methods

    @@ -228,7 +193,7 @@

    Methods Improve this Doc - View Source + View Source

    CreateTable(IEntityType)

    @@ -275,7 +240,7 @@
    Returns
    Improve this Doc
    - View Source + View Source

    Dispose()

    @@ -290,7 +255,7 @@
    Declaration
    Improve this Doc - View Source + View Source

    EnsureConnected(IModel, IDiagnosticsLogger<DbLoggerCategory.Update>)

    @@ -342,7 +307,7 @@
    Returns
    Improve this Doc - View Source + View Source

    EnsureCreated(IUpdateAdapterFactory, IModel, IDiagnosticsLogger<DbLoggerCategory.Update>)

    @@ -399,7 +364,7 @@
    Returns
    Improve this Doc - View Source + View Source

    EnsureDeleted(IUpdateAdapterFactory, IModel, IDiagnosticsLogger<DbLoggerCategory.Update>)

    @@ -456,7 +421,7 @@
    Returns
    Improve this Doc - View Source + View Source

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

    @@ -505,18 +470,18 @@
    Returns
    | - Improve this Doc + Improve this Doc - View Source + View Source - -

    GetData(IEntityType)

    + +

    GetIntegerValueGenerator<TProperty>(IProperty)

    Declaration
    -
    public virtual IEnumerable<ValueBuffer> GetData(IEntityType entityType)
    +
    public virtual KafkaIntegerValueGenerator<TProperty> GetIntegerValueGenerator<TProperty>(IProperty property)
    Parameters
    @@ -529,8 +494,8 @@
    Parameters
    - - + + @@ -545,25 +510,40 @@
    Returns
    - + + + + +
    IEntityTypeentityTypeIPropertyproperty
    IEnumerable<ValueBuffer>KafkaIntegerValueGenerator<TProperty>
    +
    Type Parameters
    + + + + + + + + + +
    NameDescription
    TProperty
    | - Improve this Doc + Improve this Doc - View Source + View Source - -

    GetIntegerValueGenerator<TProperty>(IProperty)

    + +

    GetValueBuffers(IEntityType)

    Declaration
    -
    public virtual KafkaIntegerValueGenerator<TProperty> GetIntegerValueGenerator<TProperty>(IProperty property)
    +
    public virtual IEnumerable<ValueBuffer> GetValueBuffers(IEntityType entityType)
    Parameters
    @@ -576,8 +556,8 @@
    Parameters
    - - + + @@ -592,22 +572,7 @@
    Returns
    - - - - -
    IPropertypropertyIEntityTypeentityType
    KafkaIntegerValueGenerator<TProperty>
    -
    Type Parameters
    - - - - - - - - - - + @@ -630,7 +595,7 @@

    Implements

    Improve this Doc
  • - View Source + View Source
  • diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaClusterCache.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaClusterCache.html index b8791c10..4e91d93d 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaClusterCache.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaClusterCache.html @@ -118,18 +118,18 @@

    Constructors

    | - Improve this Doc + Improve this Doc - View Source + View Source -

    KafkaClusterCache(IKafkaTableFactory, IKafkaSerdesFactory, IKafkaSingletonOptions)

    +

    KafkaClusterCache(IKafkaTableFactory, IKafkaSingletonOptions)

    Declaration
    -
    public KafkaClusterCache(IKafkaTableFactory tableFactory, IKafkaSerdesFactory serdesFactory, IKafkaSingletonOptions options)
    +
    public KafkaClusterCache(IKafkaTableFactory tableFactory, IKafkaSingletonOptions options)
    Parameters
    NameDescription
    TPropertyIEnumerable<ValueBuffer>
    @@ -146,11 +146,6 @@
    Parameters
    - - - - - @@ -165,7 +160,7 @@

    Methods Improve this Doc - View Source + View Source

    GetCluster(KafkaOptionsExtension)

    @@ -226,7 +221,7 @@

    Extension Methods

    Improve this Doc
  • - View Source + View Source
  • diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaStreamsBaseRetriever-2.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaStreamsBaseRetriever-4.html similarity index 77% rename from docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaStreamsBaseRetriever-2.html rename to docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaStreamsBaseRetriever-4.html index 20d54db2..cf797db6 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaStreamsBaseRetriever-2.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaStreamsBaseRetriever-4.html @@ -5,10 +5,10 @@ - Class KafkaStreamsBaseRetriever<K, V> + <title>Class KafkaStreamsBaseRetriever<TKey, TValue, K, V> | Kafka Bridge website - @@ -68,17 +68,17 @@
    -
    +
    -

    Class KafkaStreamsBaseRetriever<K, V> +

    Class KafkaStreamsBaseRetriever<TKey, TValue, K, V>

    Inheritance
    -
    KafkaStreamsBaseRetriever<K, V>
    +
    KafkaStreamsBaseRetriever<TKey, TValue, K, V>
    @@ -113,9 +113,9 @@
    Inherited Members
    Namespace: MASES.EntityFrameworkCore.KNet.Storage.Internal
    Assembly: MASES.EntityFrameworkCore.KNet.dll
    -
    Syntax
    +
    Syntax
    -
    public class KafkaStreamsBaseRetriever<K, V> : IKafkaStreamsBaseRetriever
    +
    public class KafkaStreamsBaseRetriever<TKey, TValue, K, V> : IKafkaStreamsBaseRetriever where TValue : IEntityTypeData
    Type Parameters
    tableFactory
    IKafkaSerdesFactoryserdesFactory
    IKafkaSingletonOptions options
    @@ -126,6 +126,14 @@
    Type Parameters
    + + + + + + + + @@ -140,18 +148,18 @@

    Constructors

    | - Improve this Doc + Improve this Doc - View Source + View Source - -

    KafkaStreamsBaseRetriever(IKafkaCluster, IEntityType, IKNetSerDes<K>, IKNetSerDes<KNetEntityTypeData<K>>, String, StreamsBuilder, KStream<K, V>)

    + +

    KafkaStreamsBaseRetriever(IKafkaCluster, IEntityType, IKNetSerDes<TKey>, IKNetSerDes<TValue>, String, StreamsBuilder, KStream<K, V>)

    Declaration
    -
    public KafkaStreamsBaseRetriever(IKafkaCluster kafkaCluster, IEntityType entityType, IKNetSerDes<K> keySerdes, IKNetSerDes<KNetEntityTypeData<K>> valueSerdes, string storageId, StreamsBuilder builder, KStream<K, V> root)
    +
    public KafkaStreamsBaseRetriever(IKafkaCluster kafkaCluster, IEntityType entityType, IKNetSerDes<TKey> keySerdes, IKNetSerDes<TValue> valueSerdes, string storageId, StreamsBuilder builder, KStream<K, V> root)
    Parameters
    TKey
    TValue
    K
    @@ -174,12 +182,12 @@
    Parameters
    - + - + @@ -204,13 +212,13 @@

    Methods

    | - Improve this Doc + Improve this Doc - View Source + View Source - -

    Dispose()

    + +

    Dispose()

    Declaration
    @@ -219,13 +227,13 @@
    Declaration
    | - Improve this Doc + Improve this Doc - View Source + View Source - -

    GetEnumerator()

    + +

    GetEnumerator()

    Declaration
    @@ -251,13 +259,13 @@

    Explicit Interface Implementations

    | - Improve this Doc + Improve this Doc - View Source + View Source - -

    IEnumerable.GetEnumerator()

    + +

    IEnumerable.GetEnumerator()

    Declaration
    @@ -297,10 +305,10 @@

    Implements

    diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaStreamsTableRetriever-1.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaStreamsTableRetriever-1.html index 9054f00e..fa4e490d 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaStreamsTableRetriever-1.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaStreamsTableRetriever-1.html @@ -78,7 +78,7 @@

    Inheritance
    Object
    -
    KafkaStreamsBaseRetriever<TKey, Byte[]>
    +
    KafkaStreamsBaseRetriever<TKey, KNetEntityTypeData<TKey>, Byte[], Byte[]>
    KafkaStreamsTableRetriever<TKey>
    @@ -90,13 +90,13 @@
    Implements
    Inherited Members
    - KafkaStreamsBaseRetriever<TKey, Byte[]>.GetEnumerator() + KafkaStreamsBaseRetriever<TKey, KNetEntityTypeData<TKey>, Byte[], Byte[]>.GetEnumerator()
    - KafkaStreamsBaseRetriever<TKey, Byte[]>.IEnumerable.GetEnumerator() + KafkaStreamsBaseRetriever<TKey, KNetEntityTypeData<TKey>, Byte[], Byte[]>.IEnumerable.GetEnumerator()
    - KafkaStreamsBaseRetriever<TKey, Byte[]>.Dispose() + KafkaStreamsBaseRetriever<TKey, KNetEntityTypeData<TKey>, Byte[], Byte[]>.Dispose()
    Object.Equals(Object) @@ -124,7 +124,7 @@
    Namespace: Syntax
    -
    public sealed class KafkaStreamsTableRetriever<TKey> : KafkaStreamsBaseRetriever<TKey, byte[]>, IKafkaStreamsBaseRetriever
    +
    public sealed class KafkaStreamsTableRetriever<TKey> : KafkaStreamsBaseRetriever<TKey, KNetEntityTypeData<TKey>, byte[], byte[]>, IKafkaStreamsBaseRetriever
    Type Parameters
    MASES.KNet.Serialization.IKNetSerDes<K>MASES.KNet.Serialization.IKNetSerDes<TKey> keySerdes
    MASES.KNet.Serialization.IKNetSerDes<KNetEntityTypeData<K>>MASES.KNet.Serialization.IKNetSerDes<TValue> valueSerdes
    diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaTable-1.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaTable-1.html index 48f647a8..9eeaf01a 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaTable-1.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaTable-1.html @@ -83,6 +83,7 @@
    Inheritance
    Implements
    IKafkaTable
    +
    IEntityTypeProducer
    IDisposable
    @@ -113,7 +114,7 @@
    Namespace: Syntax
    -
    public class KafkaTable<TKey> : IKafkaTable
    +
    public class KafkaTable<TKey> : IKafkaTable, IEntityTypeProducer
    Type Parameters
    @@ -137,7 +138,7 @@

    Constructors Improve this Doc - View Source + View Source

    KafkaTable(IKafkaCluster, IEntityType, Boolean)

    @@ -181,7 +182,7 @@

    Properties Improve this Doc - View Source + View Source

    Cluster

    @@ -211,7 +212,7 @@
    Property Value
    Improve this Doc - View Source + View Source

    EntityType

    @@ -241,7 +242,7 @@
    Property Value
    Improve this Doc - View Source + View Source

    Rows

    @@ -271,7 +272,7 @@
    Property Value
    Improve this Doc - View Source + View Source

    ValueBuffers

    @@ -303,7 +304,7 @@

    Methods Improve this Doc - View Source + View Source

    BumpValueGenerators(Object[])

    @@ -335,7 +336,7 @@
    Parameters
    Improve this Doc - View Source + View Source

    Commit(IEnumerable<IKafkaRowBag>)

    @@ -382,7 +383,7 @@
    Returns
    Improve this Doc - View Source + View Source

    Create(IUpdateEntry)

    @@ -429,7 +430,7 @@
    Returns
    Improve this Doc - View Source + View Source

    Delete(IUpdateEntry)

    @@ -476,7 +477,7 @@
    Returns
    Improve this Doc - View Source + View Source

    Dispose()

    @@ -491,7 +492,7 @@
    Declaration
    Improve this Doc - View Source + View Source

    GetIntegerValueGenerator<TProperty>(IProperty, IReadOnlyList<IKafkaTable>)

    @@ -558,7 +559,7 @@
    Type Parameters
    Improve this Doc - View Source + View Source

    SnapshotRows()

    @@ -588,7 +589,7 @@
    Returns
    Improve this Doc - View Source + View Source

    ThrowUpdateConcurrencyException(IUpdateEntry, Dictionary<IProperty, Object>)

    @@ -628,7 +629,7 @@
    Parameters
    Improve this Doc - View Source + View Source

    Update(IUpdateEntry)

    @@ -674,6 +675,9 @@

    Implements

    IKafkaTable
    +
    + IEntityTypeProducer +
    IDisposable
    @@ -688,7 +692,7 @@

    Implements

    Improve this Doc
  • - View Source + View Source
  • diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.ObjectType.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.ObjectType.html index 65bcc614..08876c34 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.ObjectType.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.ObjectType.html @@ -122,7 +122,7 @@

    Constructors Improve this Doc - View Source + View Source

    ObjectType()

    @@ -137,7 +137,7 @@
    Declaration
    Improve this Doc - View Source + View Source

    ObjectType(IProperty, Object)

    @@ -176,7 +176,7 @@

    Properties Improve this Doc - View Source + View Source

    TypeName

    @@ -206,7 +206,7 @@
    Property Value
    Improve this Doc - View Source + View Source

    Value

    @@ -238,7 +238,7 @@

    Methods Improve this Doc - View Source + View Source

    OnDeserialized()

    @@ -263,7 +263,7 @@

    Implements

    Improve this Doc
  • - View Source + View Source
  • diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.html index f0c3c603..6b461ec8 100644 --- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.html +++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.html @@ -93,7 +93,7 @@

    KafkaRowBag<TKey>

    -

    KafkaStreamsBaseRetriever<K, V>

    +

    KafkaStreamsBaseRetriever<TKey, TValue, K, V>

    KafkaStreamsTableRetriever<TKey>

    @@ -117,6 +117,8 @@

    Interfaces

    +

    IEntityTypeData

    +

    IEntityTypeProducer

    IKafkaCluster

    diff --git a/docs/api/Microsoft.Extensions.DependencyInjection.KafkaServiceCollectionExtensions.html b/docs/api/Microsoft.Extensions.DependencyInjection.KafkaServiceCollectionExtensions.html index c940ad3a..8a62d91d 100644 --- a/docs/api/Microsoft.Extensions.DependencyInjection.KafkaServiceCollectionExtensions.html +++ b/docs/api/Microsoft.Extensions.DependencyInjection.KafkaServiceCollectionExtensions.html @@ -122,7 +122,7 @@