Versions in this module Expand all Collapse all v1 v1.0.0 Nov 21, 2018 Changes in this version + type AggregateMeta struct + AggregateID int8 + ID objectid.ObjectID + Version int64 + type EventResponse struct + Error error + Event model.Event + type EventsIO struct + func Init(config IOConfig) (*EventsIO, error) + func (e *EventsIO) BuildState(correlationID uuuid.UUID) (<-chan *EventResponse, error) + func (e *EventsIO) Close() + func (e *EventsIO) Context() context.Context + func (e *EventsIO) RoutinesGroup() *errgroup.Group + func (e *EventsIO) Wait() <-chan error + type IOConfig struct + KafkaConfig KafkaConfig + MongoConfig MongoConfig + type KafkaConfig struct + ESQueryReqProd *kafka.ProducerConfig + ESQueryReqTopic string + ESQueryResCons *kafka.ConsumerConfig + type MongoConfig struct + AggCollection *mongo.Collection + AggregateID int8 + Connection *mongo.ConnectionConfig + MetaCollectionName string + MetaDatabaseName string Incompatible versions in this module v2.0.0+incompatible Nov 26, 2018
Go to main page