Class KNetCompactedReplicatorBuffered<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 ByteBuffer

public class KNetCompactedReplicatorBuffered<K, V> : KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>, IKNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>, 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, ByteBuffer, ByteBuffer>

KNetCompactedReplicatorBuffered<K, V>

Implements

IKNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>

IDictionary<K, V>

ICollection<KeyValuePair<K, V>>

IEnumerable<KeyValuePair<K, V>>

IEnumerable

IDisposable

Inherited Members

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.OnRemoteAdd

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.OnRemoteUpdate

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.OnRemoteRemove

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.OnLocalAdd

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.OnLocalUpdate

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.OnLocalRemove

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.OnDelayedStore

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.AccessRights

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.UpdateMode

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.BootstrapServers

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.StateName

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.GroupId

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Partitions

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.ConsumerInstances

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.ReplicationFactor

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.ConsumePollTimeout

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.TopicConfig

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.ConsumerConfig

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.ProducerConfig

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.KeySerDesSelector

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.KeySerDes

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.ValueSerDesSelector

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.ValueSerDes

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.IsStarted

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.IsAssigned

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.CurrentPartitionLags

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.CurrentConsumersSyncState

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Start()

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.StartAndWait(int)

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.WaitForStateAssignment(int)

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.SyncWait(int)

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Flush()

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.ProducerMetrics<TMetric>()

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.ConsumerMetrics<TMetric>()

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

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Keys

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Values

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Count

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.IsReadOnly

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Add(K, V)

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Add(KeyValuePair<K, V>)

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Clear()

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Contains(KeyValuePair<K, V>)

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.ContainsKey(K)

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

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.GetEnumerator()

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Remove(K)

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Remove(KeyValuePair<K, V>)

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.TryGetValue(K, out V)

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.Dispose()

KNetCompactedReplicator<K, V, ByteBuffer, ByteBuffer>.ToString()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()