dogmatiq / aperture

🚫 An intensely minimal projection-only Dogma engine.

Aperture

Aperture is an intensely minimal projection-only Dogma engine.

Aperture's primary purpose is to integrate Dogma projections with event-driven systems that are not necessarily already using Dogma. Given a user-supplied source of event messages, it provides the bare minimum of logic needed to correctly apply those events to Dogma projections.

aperture's Issues

Upload coverage reports under CI whenever CODECOV_TOKEN is available.

As per the changes to the CI configuration template in dogmatiq/template-go@eb5bb57.

Memory cursor in irrecoverable state after sealing with cursors

Reproduction:

• Append message of type X to memory stream
• Seal the memory stream
• Open a consumer that only subscribes to type Y
• Call Next

I expected this to return a ErrStreamSealed, however it hangs forever. The above is a contrived example, however this will occur if the ending message is any message the consumer hasn't subscribed to and Seal is called before the last message is encountered.

Initial gut feel is (c *memoryCursor) get() (Envelope, <-chan struct{}, error) needs to check whether the stream is sealed before the if c.stream.ready == nil { ... } check, so that a channel that will never be closed isn't returned.

Support application discovery using the configkit API.

Implement an event stream that uses dogmatiq/interopspec.

Blocked by dogmatiq/verity#335

Update to use configkit.

Update all godoc.org URLs to pkg.go.dev.

See dogmatiq/dogma#112 and dogmatiq/dogma@b3c4407 for an example.

Add a non-event-sourcing implementation.

This will need to be something like a queue-based approach. The projection OCC system can be used to mark a message ID as handled by storing some non-zero-length version using the message ID as the resource.

The queue abstraction should support an ACK/NACK approach. After a message is ACK'd its associated resource can be deleted.

Archive Aperture once Veracity has feature-parity.

Launch projectors from a dogma.Application.

Use Go v1.15 in CI configuration.

See the template repo CI configuration.