Interface IStreamsManager

Namespace

MASES.EntityFrameworkCore.KNet.Storage.Internal

Assembly

MASES.EntityFrameworkCore.KNet.dll

Central interface for stream management

public interface IStreamsManager

Methods

CreateAndStartTopology(IKEFCoreDatabase)

Creates and start the topology

void CreateAndStartTopology(IKEFCoreDatabase database)

Parameters

database IKEFCoreDatabase

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(string, int, long)

Invoked when a new partiton/offset is received for topic

void PartitionOffsetWritten(string topic, int partition, long offset)

Parameters

topic string

The topic associated to the IEntityType

partition int

The partiton where the data was stored

offset long

The offset received

Register(IStreamsChangeManager, IKEFCoreDatabase, IEntityType)

Register an instance of IKEFCoreDatabase

void Register(IStreamsChangeManager producer, IKEFCoreDatabase database, IEntityType entity)

Parameters

producer IStreamsChangeManager

The IStreamsChangeManager requesting the operation

database IKEFCoreDatabase

IKEFCoreDatabase

entity IEntityType

Associated IEntityType

StopTopology()

Stop topology waiting for a new CreateAndStartTopology(IKEFCoreDatabase)

bool StopTopology()

Returns

bool

Unregister(IStreamsChangeManager, IKEFCoreDatabase)

Unregister an instance of IKEFCoreDatabase

void Unregister(IStreamsChangeManager producer, IKEFCoreDatabase database)

Parameters

producer IStreamsChangeManager

The IStreamsChangeManager requesting the operation

database IKEFCoreDatabase

IKEFCoreDatabase