Method ClientRights

pkg/auth/rights/cache.go:218–236

(ctx context.Context, clientID *ttnpb.ClientIdentifiers)

}

func (f *inMemoryCache) ClientRights(ctx context.Context, clientID *ttnpb.ClientIdentifiers) (rights *ttnpb.Rights, err error) {
	defer func() { registerRightsRequest(ctx, "client", rights, err) }()
	req := newEntityReq(ctx, clientID.GetEntityIdentifiers())
	f.mu.Lock()
	res := f.clientRights[req]
	if !res.valid(f.successTTL, f.errorTTL) {
		res = newRes()
		f.clientRights[req] = res
		go func() {
			res.set(f.Fetcher.ClientRights(ctx, clientID))
		}()
	}
	f.maybeCleanup()
	f.mu.Unlock()
	if err := res.wait(ctx); err != nil {
		return nil, err
	}
	return res.rights, res.err
}

func (f *inMemoryCache) GatewayRights(ctx context.Context, gtwID *ttnpb.GatewayIdentifiers) (rights *ttnpb.Rights, err error) {
	defer func() { registerRightsRequest(ctx, "gateway", rights, err) }()