Class KNetCompactedReplicator<K, V>

Namespace

MASES.KNet.Replicator

Assembly

MASES.KNet.dll

Provides a reliable dictionary, persisted in a COMPACTED Kafka topic and shared among applications, extends KNetCompactedReplicator<K, V, TJVMK, TJVMV> using array of byte

public class KNetCompactedReplicator<K, V> : KNetCompactedReplicator<K, V, byte[], byte[]>, IKNetCompactedReplicator<K, V, byte[], byte[]>, IDictionary<K, V>, ICollection<KeyValuePair<K, V>>, IEnumerable<KeyValuePair<K, V>>, IEnumerable, IDisposable where V : class

Type Parameters

K

The type of keys in the dictionary

V

The type of values in the dictionary. Must be a nullable type

Inheritance

object

KNetCompactedReplicator<K, V, byte[], byte[]>

KNetCompactedReplicator<K, V>

Implements

IKNetCompactedReplicator<K, V, byte[], byte[]>

IDictionary<K, V>

ICollection<KeyValuePair<K, V>>

IEnumerable<KeyValuePair<K, V>>

IEnumerable

IDisposable

Inherited Members

KNetCompactedReplicator<K, V, byte[], byte[]>.OnRemoteAdd

KNetCompactedReplicator<K, V, byte[], byte[]>.OnRemoteUpdate

KNetCompactedReplicator<K, V, byte[], byte[]>.OnRemoteRemove

KNetCompactedReplicator<K, V, byte[], byte[]>.OnLocalAdd

KNetCompactedReplicator<K, V, byte[], byte[]>.OnLocalUpdate

KNetCompactedReplicator<K, V, byte[], byte[]>.OnLocalRemove

KNetCompactedReplicator<K, V, byte[], byte[]>.OnDelayedStore

KNetCompactedReplicator<K, V, byte[], byte[]>.AccessRights

KNetCompactedReplicator<K, V, byte[], byte[]>.UpdateMode

KNetCompactedReplicator<K, V, byte[], byte[]>.BootstrapServers

KNetCompactedReplicator<K, V, byte[], byte[]>.StateName

KNetCompactedReplicator<K, V, byte[], byte[]>.GroupId

KNetCompactedReplicator<K, V, byte[], byte[]>.Partitions

KNetCompactedReplicator<K, V, byte[], byte[]>.ConsumerInstances

KNetCompactedReplicator<K, V, byte[], byte[]>.ReplicationFactor

KNetCompactedReplicator<K, V, byte[], byte[]>.ConsumePollTimeout

KNetCompactedReplicator<K, V, byte[], byte[]>.TopicConfig

KNetCompactedReplicator<K, V, byte[], byte[]>.ConsumerConfig

KNetCompactedReplicator<K, V, byte[], byte[]>.ProducerConfig

KNetCompactedReplicator<K, V, byte[], byte[]>.KeySerDesSelector

KNetCompactedReplicator<K, V, byte[], byte[]>.KeySerDes

KNetCompactedReplicator<K, V, byte[], byte[]>.ValueSerDesSelector

KNetCompactedReplicator<K, V, byte[], byte[]>.ValueSerDes

KNetCompactedReplicator<K, V, byte[], byte[]>.IsStarted

KNetCompactedReplicator<K, V, byte[], byte[]>.IsAssigned

KNetCompactedReplicator<K, V, byte[], byte[]>.CurrentPartitionLags

KNetCompactedReplicator<K, V, byte[], byte[]>.CurrentConsumersSyncState

KNetCompactedReplicator<K, V, byte[], byte[]>.Start()

KNetCompactedReplicator<K, V, byte[], byte[]>.StartAndWait(int)

KNetCompactedReplicator<K, V, byte[], byte[]>.WaitForStateAssignment(int)

KNetCompactedReplicator<K, V, byte[], byte[]>.SyncWait(int)

KNetCompactedReplicator<K, V, byte[], byte[]>.Flush()

KNetCompactedReplicator<K, V, byte[], byte[]>.ProducerMetrics<TMetric>()

KNetCompactedReplicator<K, V, byte[], byte[]>.ConsumerMetrics<TMetric>()

KNetCompactedReplicator<K, V, byte[], byte[]>.this[K]

KNetCompactedReplicator<K, V, byte[], byte[]>.Keys

KNetCompactedReplicator<K, V, byte[], byte[]>.Values

KNetCompactedReplicator<K, V, byte[], byte[]>.Count

KNetCompactedReplicator<K, V, byte[], byte[]>.IsReadOnly

KNetCompactedReplicator<K, V, byte[], byte[]>.Add(K, V)

KNetCompactedReplicator<K, V, byte[], byte[]>.Add(KeyValuePair<K, V>)

KNetCompactedReplicator<K, V, byte[], byte[]>.Clear()

KNetCompactedReplicator<K, V, byte[], byte[]>.Contains(KeyValuePair<K, V>)

KNetCompactedReplicator<K, V, byte[], byte[]>.ContainsKey(K)

KNetCompactedReplicator<K, V, byte[], byte[]>.CopyTo(KeyValuePair<K, V>[], int)

KNetCompactedReplicator<K, V, byte[], byte[]>.GetEnumerator()

KNetCompactedReplicator<K, V, byte[], byte[]>.Remove(K)

KNetCompactedReplicator<K, V, byte[], byte[]>.Remove(KeyValuePair<K, V>)

KNetCompactedReplicator<K, V, byte[], byte[]>.TryGetValue(K, out V)

KNetCompactedReplicator<K, V, byte[], byte[]>.Dispose()

KNetCompactedReplicator<K, V, byte[], byte[]>.ToString()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()