Interface IStreamsManager

Namespace

MASES.EntityFrameworkCore.KNet.Storage.Internal

Assembly

MASES.EntityFrameworkCore.KNet.dll

Central interface for stream management

public interface IStreamsManager

Methods

CreateAndStartTopology()

Creates and start the topology

void CreateAndStartTopology()

EnsureSynchronized(IEntityType, long)

Verify if local instance is synchronized with the IKEFCoreCluster instance

bool? EnsureSynchronized(IEntityType entity, long timeout)

Parameters

entity IEntityType

timeout long

Returns

bool?

PartitionOffsetWritten(IEntityType, int, long)

Invoked when a new partiton/offset is received for entity

void PartitionOffsetWritten(IEntityType entity, int partition, long offset)

Parameters

entity IEntityType

The IEntityType

partition int

The partiton where the data was stored

offset long

The offset received