LoadEvent loads an event by its UID.
(ctx context.Context, uid string)
| 122 | |
| 123 | // LoadEvent loads an event by its UID. |
| 124 | func (ps *PubSubStore) LoadEvent(ctx context.Context, uid string) (*ttnpb.Event, error) { |
| 125 | data, err := ps.client.Get(ctx, ps.eventDataKey(ctx, uid)).Result() |
| 126 | if err != nil { |
| 127 | return nil, ttnredis.ConvertError(err) |
| 128 | } |
| 129 | evtPB := &ttnpb.Event{} |
| 130 | if err = decodeEventData(data, evtPB); err != nil { |
| 131 | return nil, err |
| 132 | } |
| 133 | return evtPB, nil |
| 134 | } |
| 135 | |
| 136 | func xMessageHasEventName(names ...string) func(msg redis.XMessage) bool { |
| 137 | if len(names) == 0 { |
no test coverage detected