• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

C# IEventStore类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了C#中IEventStore的典型用法代码示例。如果您正苦于以下问题:C# IEventStore类的具体用法?C# IEventStore怎么用?C# IEventStore使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



IEventStore类属于命名空间,在下文中一共展示了IEventStore类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C#代码示例。

示例1: DefaultCommitEventService

 /// <summary>Parameterized constructor.
 /// </summary>
 /// <param name="waitingCommandService"></param>
 /// <param name="aggregateRootTypeCodeProvider"></param>
 /// <param name="aggregateRootFactory"></param>
 /// <param name="eventStreamConvertService"></param>
 /// <param name="eventSourcingService"></param>
 /// <param name="memoryCache"></param>
 /// <param name="aggregateStorage"></param>
 /// <param name="retryCommandService"></param>
 /// <param name="eventStore"></param>
 /// <param name="eventPublisher"></param>
 /// <param name="actionExecutionService"></param>
 /// <param name="eventSynchronizerProvider"></param>
 /// <param name="loggerFactory"></param>
 public DefaultCommitEventService(
     IWaitingCommandService waitingCommandService,
     IAggregateRootTypeCodeProvider aggregateRootTypeCodeProvider,
     IAggregateRootFactory aggregateRootFactory,
     IEventStreamConvertService eventStreamConvertService,
     IEventSourcingService eventSourcingService,
     IMemoryCache memoryCache,
     IAggregateStorage aggregateStorage,
     IRetryCommandService retryCommandService,
     IEventStore eventStore,
     IEventPublisher eventPublisher,
     IActionExecutionService actionExecutionService,
     IEventSynchronizerProvider eventSynchronizerProvider,
     ILoggerFactory loggerFactory)
 {
     _waitingCommandService = waitingCommandService;
     _aggregateRootTypeCodeProvider = aggregateRootTypeCodeProvider;
     _aggregateRootFactory = aggregateRootFactory;
     _eventStreamConvertService = eventStreamConvertService;
     _eventSourcingService = eventSourcingService;
     _memoryCache = memoryCache;
     _aggregateStorage = aggregateStorage;
     _retryCommandService = retryCommandService;
     _eventStore = eventStore;
     _eventPublisher = eventPublisher;
     _actionExecutionService = actionExecutionService;
     _eventSynchronizerProvider = eventSynchronizerProvider;
     _logger = loggerFactory.Create(GetType().Name);
 }
开发者ID:key-value,项目名称:enode,代码行数:44,代码来源:DefaultCommitEventService.cs


示例2: CreateKernel

        protected override global::Ninject.IKernel CreateKernel()
        {
            Store = Bootstrapper.Instance.Get<IEventStore>();
            DataCache = Bootstrapper.Instance.Get<IRepositoryCache>();

            return Bootstrapper.Instance.Kernel;
        }
开发者ID:nullkiller,项目名称:GetEventStoreSample,代码行数:7,代码来源:Global.asax.cs


示例3: DefaultCommandExecutor

        public DefaultCommandExecutor(
            IProcessingCommandCache processingCommandCache,
            ICommandAsyncResultManager commandAsyncResultManager,
            ICommandHandlerProvider commandHandlerProvider,
            IAggregateRootTypeProvider aggregateRootTypeProvider,
            IMemoryCache memoryCache,
            IRepository repository,
            IRetryCommandService retryCommandService,
            IEventStore eventStore,
            IEventPublisher eventPublisher,
            IEventPersistenceSynchronizerProvider eventPersistenceSynchronizerProvider,
            ICommandContext commandContext,
            ILoggerFactory loggerFactory)
        {
            _processingCommandCache = processingCommandCache;
            _commandAsyncResultManager = commandAsyncResultManager;
            _commandHandlerProvider = commandHandlerProvider;
            _aggregateRootTypeProvider = aggregateRootTypeProvider;
            _memoryCache = memoryCache;
            _repository = repository;
            _retryCommandService = retryCommandService;
            _eventStore = eventStore;
            _eventPublisher = eventPublisher;
            _eventPersistenceSynchronizerProvider = eventPersistenceSynchronizerProvider;
            _commandContext = commandContext;
            _trackingContext = commandContext as ITrackingContext;
            _logger = loggerFactory.Create(GetType().Name);

            if (_trackingContext == null)
            {
                throw new Exception("command context must also implement ITrackingContext interface.");
            }
        }
开发者ID:hjlfmy,项目名称:enode,代码行数:33,代码来源:DefaultCommandExecutor.cs


示例4: Initialize

 public void Initialize(IEventStore eventStore, bool purgeExistingViews = false)
 {
     foreach (var batch in eventStore.Stream().Batch(1000))
     {
         Dispatch(eventStore, batch.Select(e => _domainEventSerializer.Deserialize(e)));
     }
 }
开发者ID:mcquiggd,项目名称:Cirqus,代码行数:7,代码来源:SynchronousViewManagerEventDispatcher.cs


示例5: EventApplier

 public EventApplier(IEventStore eventstore, HandlerRegistry handlerregistry, IHandlerInstanceResolver resolver,IParameterResolver parameterresolver)
 {
     this.eventstore = eventstore;
     this.handlerregistry = handlerregistry;
     this.resolver = resolver;
     this.parameterresolver = parameterresolver;
 }
开发者ID:rmoorman,项目名称:Scritchy,代码行数:7,代码来源:EventApplier.cs


示例6: CollectionService

 public CollectionService(
     IEventStore eventStore, 
     IPublishEvents eventsPublisher)
 {
     this.eventStore = eventStore;
     this.eventsPublisher = eventsPublisher;
 }
开发者ID:victorpictor,项目名称:Kan,代码行数:7,代码来源:CollectionService.cs


示例7: CommandBus

 public CommandBus(IEventStore eventstore, HandlerRegistry handlerregistry, IHandlerInstanceResolver resolver,IParameterResolver ParameterResolver)
 {
     this.eventstore = eventstore;
     this.handlerregistry = handlerregistry;
     this.resolver = resolver;
     this.ParameterResolver = ParameterResolver;
 }
开发者ID:rmoorman,项目名称:Scritchy,代码行数:7,代码来源:CommandBus.cs


示例8: MagistrateRegistry

        public MagistrateRegistry(IEventStore store)
        {
            Scan(a =>
            {
                a.TheCallingAssembly();
                a.WithDefaultConventions();

                a.AddAllTypesOf(typeof(IRequestHandler<,>));
                a.AddAllTypesOf(typeof(INotificationHandler<>));
                a.AddAllTypesOf(typeof(IController));
            });

            For<SingleInstanceFactory>().Use<SingleInstanceFactory>(ctx => t => ctx.GetInstance(t));
            For<MultiInstanceFactory>().Use<MultiInstanceFactory>(ctx => t => ctx.GetAllInstances(t));
            For<IMediator>().Use<Mediator>();

            Policies.Add<ServicePolicy>();
            Policies.Add<ReadModelPolicy>();

            For<Projectionist>().Singleton();
            For<IEventStore>()
                .Use(context => new ProjectionStore(store, context.GetInstance<Projectionist>().Apply));
            For<AggregateStore<Guid>>().Use(ctx => new AggregateStore<Guid>(ctx.GetInstance<IEventStore>()));

            For<JsonSerializerSettings>().Use(new JsonSerializerSettings
            {
                ContractResolver = new CamelCasePropertyNamesContractResolver()
            });
        }
开发者ID:Pondidum,项目名称:Magistrate,代码行数:29,代码来源:MagistrateRegistry.cs


示例9: UserStoryService

 public UserStoryService(
     IEventStore eventStore,
     IPublishEvents eventsPublisher)
 {
     this.eventsPublisher = eventsPublisher;
     this.eventStore = eventStore;
 }
开发者ID:victorpictor,项目名称:Kan,代码行数:7,代码来源:UserStoryService.cs


示例10: Arrange

 public void Arrange()
 {
     // Arrange.
     eventStore = MockRepository.GenerateMock<IEventStore>();
     repository = new Repository<SchedulerJob>(eventStore);
     schedulerJobCommandHandlers = new SchedulerJobCommandHandlers(repository);
 }
开发者ID:ntulip,项目名称:Elasticity,代码行数:7,代码来源:CommandsToEventStoreTests.cs


示例11: Dispatch

 public void Dispatch(IEventStore eventStore, IEnumerable<DomainEvent> events)
 {
     foreach (var e in events)
     {
         Console.WriteLine(e);
     }
 }
开发者ID:linearregression,项目名称:Cirqus,代码行数:7,代码来源:ConsoleOutEventDispatcher.cs


示例12: ErrorQueueLoader

 public ErrorQueueLoader(ITransactor transactor, IEventStore eventStore, IEventErrorStoreRepository eventErrorStoreRepository, IHandlerSequenceRespository handlerSequenceRepRespository)
 {
     _transactor = transactor;
     _eventStore = eventStore;
     _eventErrorStoreRepository = eventErrorStoreRepository;
     _handlerSequenceRepRespository = handlerSequenceRepRespository;
 }
开发者ID:brucewu16899,项目名称:lacjam,代码行数:7,代码来源:ErrorQueueLoader.cs


示例13: RegistrationApplicationService

 public RegistrationApplicationService( IEventStore eventStore,IDomainIdentityService ids, IUserIndexService uniqueness,  PasswordGenerator generator)
 {
     _eventStore = eventStore;
     _ids = ids;
     _uniqueness = uniqueness;
     _generator = generator;
 }
开发者ID:AGiorgetti,项目名称:lokad-cqrs,代码行数:7,代码来源:RegistrationApplicationService.cs


示例14: DefaultEventService

 public DefaultEventService(
     IJsonSerializer jsonSerializer,
     IScheduleService scheduleService,
     ITypeNameProvider typeNameProvider,
     IMemoryCache memoryCache,
     IAggregateRootFactory aggregateRootFactory,
     IAggregateStorage aggregateStorage,
     IEventStore eventStore,
     IMessagePublisher<DomainEventStreamMessage> domainEventPublisher,
     IOHelper ioHelper,
     ILoggerFactory loggerFactory)
 {
     _eventMailboxDict = new ConcurrentDictionary<string, EventMailBox>();
     _ioHelper = ioHelper;
     _jsonSerializer = jsonSerializer;
     _scheduleService = scheduleService;
     _typeNameProvider = typeNameProvider;
     _memoryCache = memoryCache;
     _aggregateRootFactory = aggregateRootFactory;
     _aggregateStorage = aggregateStorage;
     _eventStore = eventStore;
     _domainEventPublisher = domainEventPublisher;
     _logger = loggerFactory.Create(GetType().FullName);
     _batchSize = ENodeConfiguration.Instance.Setting.EventMailBoxPersistenceMaxBatchSize;
 }
开发者ID:ulswww,项目名称:enode,代码行数:25,代码来源:DefaultEventService.cs


示例15: MindReader

        public MindReader(IEventStore store, StreamName streamName,  EmoEngine engine)
        {
            this.engine = engine;
            this.store = store;
            this.streamName = streamName;

            RegisterHandlers();
        }
开发者ID:jfloodnet,项目名称:BrainStore,代码行数:8,代码来源:MindReader.cs


示例16: NotifyChanges

 public void NotifyChanges(IEventStore eventStore, EventStream streamOfEvents)
 {
     foreach( var notifierType in _notifiers ) 
     {
         var notifier = _container.Get(notifierType) as IEventStoreChangeNotifier;
         notifier.Notify(eventStore, streamOfEvents);
     }  
 }
开发者ID:JoB70,项目名称:Bifrost,代码行数:8,代码来源:EventStoreChangeManager.cs


示例17: SequencedEventSelector

 public SequencedEventSelector(ITransactor transactor,
                               IEventStore eventStore,
                               IHandlerSequenceRespository handlerSequenceRespository)
 {
     _transactor = transactor;
     _eventStore = eventStore;
     _handlerSequenceRespository = handlerSequenceRespository;
 }
开发者ID:brucewu16899,项目名称:lacjam,代码行数:8,代码来源:SequencedEventSelector.cs


示例18: ResetAllEventsForAllSubscriptionsTask

 public ResetAllEventsForAllSubscriptionsTask(
         IEventSubscriptionManager eventSubcriptionManager,
         IEventStore eventStore
     )
 {
     _eventSubscriptionManager = eventSubcriptionManager;
     _eventStore = eventStore;
 }
开发者ID:LenFon,项目名称:Bifrost,代码行数:8,代码来源:ResetAllEventsForAllSubscriptionsTask.cs


示例19: FactoryBasedAggregateRootRepository

        public FactoryBasedAggregateRootRepository(IEventStore eventStore, IDomainEventSerializer domainEventSerializer, IDomainTypeNameMapper domainTypeNameMapper, Func<Type, AggregateRoot> aggregateRootFactoryMethod)
            : base(eventStore, domainEventSerializer, domainTypeNameMapper)
        {
            if (aggregateRootFactoryMethod == null)
                throw new ArgumentNullException("aggregateRootFactoryMethod");

            _aggregateRootFactoryMethod = aggregateRootFactoryMethod;
        }
开发者ID:RichieYang,项目名称:Cirqus,代码行数:8,代码来源:FactoryBasedAggregateRootRepository.cs


示例20: BuildApplicationServices

        public static IEnumerable<object> BuildApplicationServices(IEventStore eventStore, IDocumentStore projectionStore)
        {
            var loginIndexService = new LoginIndexLookupService(projectionStore);

            yield return new Security.SecurityApplicationService(eventStore);
            yield return new Profile.ProfileApplicationService(eventStore);
            yield return new Registration.RegistrationApplicationService(eventStore, loginIndexService);
            yield break;
        }
开发者ID:AlexeyRaga,项目名称:Ziggurat,代码行数:9,代码来源:RegistrationDomainBoundedContext.cs



注:本文中的IEventStore类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
C# IEventStoreConnection类代码示例发布时间:2022-05-24
下一篇:
C# IEventSource类代码示例发布时间:2022-05-24
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap