Method GatewayRights

pkg/auth/rights/cache.go:238–256

(ctx context.Context, gtwID *ttnpb.GatewayIdentifiers)

}

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

func (f *inMemoryCache) OrganizationRights(ctx context.Context, orgID *ttnpb.OrganizationIdentifiers) (rights *ttnpb.Rights, err error) {
	defer func() { registerRightsRequest(ctx, "organization", rights, err) }()