event

type Message interface {
	Key() string
}

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

type ReactionCreatedMessage struct {
	ID          string
	PersonID    string
	Details     string
	Description string
	Type        string
	Date        time.Time
}

type ReactionEventStore interface {
	Close()
	PublishReactionCreated(reaction domain.Reaction) error
	SubscribeReactionCreated() (<-chan ReactionCreatedMessage, error)
	OnReactionCreated(f func(ReactionCreatedMessage)) error
}