event

type EventStore interface {
	Close()
	PublishMeowCreated(meow schema.Meow) error
	SubscribeMeowCreated() (<-chan MeowCreatedMessage, error)
	OnMeowCreated(f func(MeowCreatedMessage)) error
}

type MeowCreatedMessage struct {
	ID        string
	Body      string
	CreatedAt time.Time
}

type Message interface {
	Key() string
}

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