Method storeEvent

pkg/events/redis/store.go:76–90

(
	ctx context.Context, tx redis.Cmdable, evt events.Event, correlationIDKeys map[string][]any,
)

}

func (ps *PubSubStore) storeEvent(
	ctx context.Context, tx redis.Cmdable, evt events.Event, correlationIDKeys map[string][]any,
) error {
	b, err := encodeEventData(evt)
	if err != nil {
		return err
	}
	ttl := random.Jitter(ps.historyTTL, ttlJitter)
	tx.Set(ctx, ps.eventDataKey(evt.Context(), evt.UniqueID()), b, ttl)
	for _, cid := range evt.CorrelationIds() {
		key := ps.eventIndexKey(evt.Context(), cid)
		correlationIDKeys[key] = append(correlationIDKeys[key], evt.UniqueID())
	}
	return nil
}

// loadEventData loads event data for every event in evts (by UniqueID)
// and set additional fields in the events.