event

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

type EventStore interface {
	Close()
	PublishBookCreated(moew schema.Book) error
}

type Message interface {
	Key() string
}

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