Versions in this module Expand all Collapse all v3 v3.7.3 Apr 29, 2020 Changes in this version + type ApplicationUplinkQueue struct + Group string + ID string + MaxLen int64 + Redis *ttnredis.Client + func NewApplicationUplinkQueue(cl *ttnredis.Client, maxLen int64, group, id string) *ApplicationUplinkQueue + func (q *ApplicationUplinkQueue) Add(ctx context.Context, ups ...*ttnpb.ApplicationUp) error + func (q *ApplicationUplinkQueue) Subscribe(ctx context.Context, appID ttnpb.ApplicationIdentifiers, ...) error + type DeviceRegistry struct + Redis *ttnredis.Client + func (r *DeviceRegistry) GetByEUI(ctx context.Context, joinEUI, devEUI types.EUI64, paths []string) (*ttnpb.EndDevice, context.Context, error) + func (r *DeviceRegistry) GetByID(ctx context.Context, appID ttnpb.ApplicationIdentifiers, devID string, ...) (*ttnpb.EndDevice, context.Context, error) + func (r *DeviceRegistry) RangeByAddr(ctx context.Context, addr types.DevAddr, paths []string, ...) error + func (r *DeviceRegistry) SetByID(ctx context.Context, appID ttnpb.ApplicationIdentifiers, devID string, ...) (*ttnpb.EndDevice, context.Context, error) + type DownlinkTaskQueue struct + func NewDownlinkTaskQueue(cl *ttnredis.Client, maxLen int64, group, id string) *DownlinkTaskQueue + func (q *DownlinkTaskQueue) Add(ctx context.Context, devID ttnpb.EndDeviceIdentifiers, startAt time.Time, ...) error + func (q *DownlinkTaskQueue) Pop(ctx context.Context, ...) error + type UplinkDeduplicator struct + Redis *ttnredis.Client + func NewUplinkDeduplicator(cl *ttnredis.Client) *UplinkDeduplicator + func (d *UplinkDeduplicator) AccumulatedMetadata(ctx context.Context, up *ttnpb.UplinkMessage) ([]*ttnpb.RxMetadata, error) + func (d *UplinkDeduplicator) DeduplicateUplink(ctx context.Context, up *ttnpb.UplinkMessage, window time.Duration) (bool, error)