(ctx context.Context, _ *ttnpb.GatewayIdentifiers)
| 176 | } |
| 177 | |
| 178 | func (is IS) newRegistryClient(ctx context.Context, _ *ttnpb.GatewayIdentifiers) (ttnpb.GatewayRegistryClient, error) { |
| 179 | cc, err := is.GetPeerConn(ctx, ttnpb.ClusterRole_ENTITY_REGISTRY, nil) |
| 180 | if err != nil { |
| 181 | return nil, err |
| 182 | } |
| 183 | return ttnpb.NewGatewayRegistryClient(cc), nil |
| 184 | } |
| 185 | |
| 186 | func (is IS) newGatewayBatchAccessClient(ctx context.Context) (ttnpb.GatewayBatchAccessClient, error) { |
| 187 | cc, err := is.GetPeerConn(ctx, ttnpb.ClusterRole_ENTITY_REGISTRY, nil) |
no test coverage detected