event

type EventStore interface {
	Close()
	PublishGiggleCreated(giggle schema.Giggle) error
	SubscribeGiggleCreated() (<-chan GiggleCreatedMessage, error)
	OnGiggleCreated(f func(GiggleCreatedMessage)) error
}

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

type Message interface {
	Key() string
}

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