v1

package

v0.0.0-...-0de0edb Latest Latest Go to latest Published: Nov 24, 2024 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func NewRegistrationEvents(consumer *queue.Consumer, commands CommandBus, logger logger.Logger)

type CommandBus interface {
	Dispatch(context.Context, core.Command) (any, error)
}

type RegistrationEvent struct {
	ID    string `json:"id"`
	Email string `json:"email"`
}

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

func (r *RegistrationEvents) Handle(ctx context.Context, event *kafka.Message) error