mongodb

type BackgroundContextStrategy struct {
	// contains filtered or unexported fields
}

type ContextStrategy interface {
	Append() (context.Context, context.CancelFunc)
	GetEventsFor() (context.Context, context.CancelFunc)
	FromVersion() (context.Context, context.CancelFunc)
	CountEventsFor() (context.Context, context.CancelFunc)
	CreateIndices() (context.Context, context.CancelFunc)
}

type EventStore struct {
	// contains filtered or unexported fields
}

type MongoEvent struct {
	ID         string    `bson:"aggregate_id,omitempty"`
	Version    int       `bson:"version"`
	Type       string    `bson:"type"`
	Payload    string    `bson:"payload"`
	RecordedOn time.Time `bson:"recorded_on"`
}

type Option func(eventStore *EventStore)

type TimeoutContextStrategy struct {
	// contains filtered or unexported fields
}

type TimeoutContextStrategyOption func(s *TimeoutContextStrategy)