Class EventSeeding

Namespace

Cratis.Chronicle.Seeding

Assembly

Cratis.Chronicle.dll

Represents an implementation of IEventSeeding.

public class EventSeeding : IEventSeeding, IEventSeedingBuilder

Inheritance

object

EventSeeding

Implements

IEventSeeding

IEventSeedingBuilder

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

MethodCalls.CallGenericMethod<TOut, T>(T, Expression<Func<T, Func<TOut>>>, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1>(T, Expression<Func<T, Func<T1, TOut>>>, T1, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2>(T, Expression<Func<T, Func<T1, T2, TOut>>>, T1, T2, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2, T3>(T, Expression<Func<T, Func<T1, T2, T3, TOut>>>, T1, T2, T3, params Type[])

ConverterExtensions.ConvertTo(object, Type)

ConceptExtensions.GetConceptValue(object)

ConceptExtensions.IsConcept(object)

JsonValueExtensions.ToJsonValue(object?)

ObservableExtensions.InvokeAndWrapWithSubject<TResult>(object, Func<CancellationToken, IObservable<TResult>>)

ObservableExtensions.InvokeAndWrapWithTransformSubject<TResult, TSource>(object, Func<CancellationToken, IObservable<TSource>>, Func<TSource, TResult>)

Remarks

Initializes a new instance of the EventSeeding class.

Constructors

EventSeeding(EventStoreName, IChronicleConnection, IEventTypes, IEventSerializer, IClientArtifactsProvider, IServiceProvider, IClientArtifactsActivator, ILogger<EventSeeding>)

Represents an implementation of IEventSeeding.

public EventSeeding(EventStoreName eventStoreName, IChronicleConnection connection, IEventTypes eventTypes, IEventSerializer eventSerializer, IClientArtifactsProvider clientArtifactsProvider, IServiceProvider serviceProvider, IClientArtifactsActivator artifactActivator, ILogger<EventSeeding> logger)

Parameters

eventStoreName EventStoreName

The event store name.

connection IChronicleConnection

The Chronicle connection.

eventTypes IEventTypes

The event types.

eventSerializer IEventSerializer

The event serializer.

clientArtifactsProvider IClientArtifactsProvider

The client artifacts provider.

serviceProvider IServiceProvider

The service provider.

artifactActivator IClientArtifactsActivator

The artifact activator.

logger ILogger<EventSeeding>

The logger.

Remarks

Initializes a new instance of the EventSeeding class.

EventSeeding(EventStoreName, IChronicleConnection, IEventTypes, IEventSerializer, IClientArtifactsProvider, IServiceProvider, IClientArtifactsActivator, ILogger<EventSeeding>, IEventSources?)

Initializes a new instance of the EventSeeding class with typed routing support.

public EventSeeding(EventStoreName eventStoreName, IChronicleConnection connection, IEventTypes eventTypes, IEventSerializer eventSerializer, IClientArtifactsProvider clientArtifactsProvider, IServiceProvider serviceProvider, IClientArtifactsActivator artifactActivator, ILogger<EventSeeding> logger, IEventSources? eventSources)

Parameters

eventStoreName EventStoreName

The event store name.

connection IChronicleConnection

The Chronicle connection.

eventTypes IEventTypes

The event types.

eventSerializer IEventSerializer

The event serializer.

clientArtifactsProvider IClientArtifactsProvider

The client artifacts provider.

serviceProvider IServiceProvider

The service provider.

artifactActivator IClientArtifactsActivator

The artifact activator.

logger ILogger<EventSeeding>

The logger.

eventSources IEventSources

The event source definitions.

Methods

Discover()

Discovers all registered event seeders.

public Task Discover()

Returns

Task

Awaitable task.

ForEventSource(EventSourceId, EventStreamType, EventStreamId, IEnumerable<object>, EventSourceType?)

Seeds events onto an event stream.

public IEventSeedingBuilder ForEventSource(EventSourceId eventSourceId, EventStreamType eventStreamType, EventStreamId eventStreamId, IEnumerable<object> events, EventSourceType? eventSourceType = null)

Parameters

eventSourceId EventSourceId

The event source identifier.

eventStreamType EventStreamType

The stream type.

eventStreamId EventStreamId

The stream identifier.

events IEnumerable<object>

The events to seed.

eventSourceType EventSourceType

The optional source type.

Returns

IEventSeedingBuilder

The builder for continuation.

Exceptions

EventSeedingRoutingNotSupported

The implementation does not support routing.

ForEventSource(EventSourceId, IEnumerable<object>)

Seed events for a specific event source id with multiple event types. By default, seed data applies to all namespaces globally.

public IEventSeedingBuilder ForEventSource(EventSourceId eventSourceId, IEnumerable<object> events)

Parameters

eventSourceId EventSourceId

The event source id to seed for.

events IEnumerable<object>

Collection of events to seed.

Returns

IEventSeedingBuilder

The builder for continuation.

ForEvents(IEnumerable<EventForEventSourceId>)

Seeds individually routed events, merging their tags with event-type tags.

public IEventSeedingBuilder ForEvents(IEnumerable<EventForEventSourceId> events)

Parameters

events IEnumerable<EventForEventSourceId>

The routed events.

Returns

IEventSeedingBuilder

The builder for continuation.

Exceptions

EventSeedingRoutingNotSupported

The implementation does not support routing.

ForNamespace(EventStoreNamespaceName)

Configure seed data to be specific to a namespace.

public IEventSeedingScopeBuilder ForNamespace(EventStoreNamespaceName @namespace)

Parameters

namespace EventStoreNamespaceName

The namespace to seed for.

Returns

IEventSeedingScopeBuilder

A scoped builder for namespace-specific seed data.

For<TEvent>(EventSourceId, EventStreamType, EventStreamId, IEnumerable<TEvent>, EventSourceType?)

Seeds events of one type onto an event stream.

public IEventSeedingBuilder For<TEvent>(EventSourceId eventSourceId, EventStreamType eventStreamType, EventStreamId eventStreamId, IEnumerable<TEvent> events, EventSourceType? eventSourceType = null) where TEvent : class

Parameters

eventSourceId EventSourceId

The event source identifier.

eventStreamType EventStreamType

The stream type.

eventStreamId EventStreamId

The stream identifier.

events IEnumerable<TEvent>

The events to seed.

eventSourceType EventSourceType

The optional source type.

Returns

IEventSeedingBuilder

The builder for continuation.

Type Parameters

TEvent

The event type.

Exceptions

EventSeedingRoutingNotSupported

The implementation does not support routing.

For<TEvent>(EventSourceId, IEnumerable<TEvent>)

Seed events for a specific event type and event source id. By default, seed data applies to all namespaces globally.

public IEventSeedingBuilder For<TEvent>(EventSourceId eventSourceId, IEnumerable<TEvent> events) where TEvent : class

Parameters

eventSourceId EventSourceId

The event source id to seed for.

events IEnumerable<TEvent>

Collection of events to seed.

Returns

IEventSeedingBuilder

The builder for continuation.

Type Parameters

TEvent

Type of event to seed.

Register()

Registers all discovered event seeders by invoking them and sending seed data to the server.

public Task Register()

Returns

Task

Awaitable task.

Exceptions

EventSeedingRoutingNotSupported

Thrown before sending entries when routing support is not confirmed by the kernel.