jeroenrinzema / commander

Build event-driven and event streaming applications with ease

Commander 🚀

Commander is Go library for writing event-driven applications. Enabling event sourcing, RPC over messages, SAGA's, bidirectional streaming and more! Dialects could be used to stream messages from one to another.

Getting started

1. 🚀 Examples

---

• Basic
  • Single Mock pub/sub
  • Multi group pub/sub
  • Message streaming
• Real world examples
  • Kafka
  • Zipkin middleware

Contributing

Thank you for your interest in contributing to Commander! ❤ Check out the open projects and/or issues and feel free to join any ongoing discussion.

Everyone is welcome to contribute, whether it's in the form of code, documentation, bug reports, feature requests, or anything else. We encourage you to experiment with the project and make contributions to help evolve it to meet your needs!

See the contributing guide for more details.

commander's Issues

CLI Design

I want to start developing a CLI interface that could be used for debugging/testing purposes.

Feel free to join the discussion or opt in if you have any ideas.

Development of dialects

Commander allows different dialects to be developed. Currently the project has dialects for mocking and Kafka. Supporting more dialects could increase the versatility of the project. I am looking for contributes wanting to develop more dialects. Examples are:

• RabbitMQ
• Redis
• GRPC
• HTTP(2)

some protocols (ex: GRPC, HTTP(2)) are not streaming/event driven protocols but could be used to create connectors between dialects (#11).

bufio scanner race condition

A race condition is triggered while scanning the io.Reader for the next byte buffer.

This due to the shared byte buffer returned on read.
The next byte buffer is read before the current byte buffer is processed.

data race

Describe the bug
data race between close ready channel, create and select
https://github.com/jeroenrinzema/commander/blob/master/dialects/kafka/consumer/group.go#L67
we can receive new ready channel here (not closed)
https://github.com/jeroenrinzema/commander/blob/master/dialects/kafka/consumer/group.go#L56

To Reproduce
Steps to reproduce the behavior. Please include code examples:

1. Setup '...'
2. Emit event '....'
3. Await x seconds '....'
4. See error

Expected behavior
A clear and concise description of what you expected to happen.

Desktop (please complete the following information):

• OS: [e.g. Linux]
• Golang version

Additional context
Add any other context about the problem here.

infinit lock

Describe the bug
forget to call wg.Done() and if we call Close() then we are lock on wg.Wait()
https://github.com/jeroenrinzema/commander/blob/master/dialects/kafka/consumer/group.go#L94
https://github.com/jeroenrinzema/commander/blob/master/dialects/kafka/consumer/group.go#L89

To Reproduce
Steps to reproduce the behavior. Please include code examples:

1. Setup '...'
2. Emit event '....'
3. Await x seconds '....'
4. See error

Expected behavior
A clear and concise description of what you expected to happen.

Desktop (please complete the following information):

• OS: [e.g. Linux]
• Golang version

Additional context
Add any other context about the problem here.

Mocking dialect is unstable

The mocking dialect is at the moment very unstable and needs major rethinking.
Currently issues such as race detections and deadlocks are common.

This issue has a high priority and should be fixed.

Streaming between dialects

Businesses have a lot of times multiple pieces of infrastructure which requires integrations to be made. Streaming between dialects could allow two totally different dialects to stream from one another (ex: Redis - Kafka, Kafka - RabbitMQ).

This requires the consume, handle and writer interfaces to be modified. The API should feel natural and not in the way. An idea is to move the consuming and writing from the groups to the dialect.

dialect.Handle(commander.EventTopic, "action", func())

and the writer to include the dialect.

writer.ProduceEvent(dialect, "action", 1, uuid.UUID, nil)