Method eventIndexKey

pkg/events/redis/store.go:63–67

eventIndexKey returns the Redis for indexing events with the given correlationID. Since correlation IDs are user input (and can therefore contain characters that we may not want in Redis keys) we hash them.

(_ context.Context, correlationID string)

// Since correlation IDs are user input (and can therefore contain characters that
// we may not want in Redis keys) we hash them.
func (ps *PubSubStore) eventIndexKey(_ context.Context, correlationID string) string {
	h := fnv.New128a()
	h.Write([]byte(correlationID))
	return ps.client.Key("event_index", base64.RawStdEncoding.EncodeToString(h.Sum(nil)))
}

func (ps *PubSubStore) eventStream(ctx context.Context, ids *ttnpb.EntityIdentifiers) string {
	if ids == nil {