event

type BookCreatedMessage struct {
	ID        string
	Name      string
	CreatedAt time.Time
}

type EventStore interface {
	Close()
	SubsribeBookCreated() (<-chan BookCreatedMessage, error)
	OnBookCreated(f func(BookCreatedMessage)) error
}

type Message interface {
	Key() string
}

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