[Question] Pubsub Implementation about kratos HOT 2 OPEN

🤖

Yes, it is possible to implement an event handler like Pubsub or Kafka on Kratos. A similar issue was discussed in the Kratos repository under the title [Feature] Discussion on the definition and usage of event interface. The solution suggested was to define two interfaces, Sender and Receiver, with methods for sending, receiving, acknowledging, and not acknowledging messages. Here is the suggested implementation:

type Sender interface {
   Send(ctx context.Context, msg Message) error
}

type Receiver interface {
   Receive(ctx context.Context) (Message, error)
   Ack(msg Message) error
   Nack(msg Message) error
}

In this solution, the context is passed to the Send and Receive methods to provide runtime information. This approach can be adapted to work with different event-driven systems like Pubsub or Kafka.

You can find more details about this solution in the issue discussion. Also, this feature was referenced in the Kratos roadmap and in a pull request titled feat(events):add PubSub/Events.

Please let me know if you need further clarification or assistance.

Sources

• [Feature] Discussion on the definition and usage of event interface

This response is meant to be useful and save you time. It is not meant to be a precise solution, but rather a starting point for your own research.

Help me be more useful! Please leave a 👍 if this is helpful and 👎 if it is irrelevant.

If you want to continue the conversation, start your reply with @dosu-bot.

from kratos.

🤖

Hello @muhadif,

I'm Dosu, a bot designed to assist with the Kratos repository. I'm here to help you tackle bugs, answer your questions, and guide you on your journey to becoming a contributor. While we wait for a human maintainer, I'm here to provide assistance. I'm currently taking a look at your issue and will get back to you with a response shortly.

from kratos.