( ctx context.Context, ids *ttnpb.GatewayIdentifiers, stats *ttnpb.GatewayConnectionStats, )
| 309 | } |
| 310 | |
| 311 | func registerGatewayConnect( |
| 312 | ctx context.Context, |
| 313 | ids *ttnpb.GatewayIdentifiers, |
| 314 | stats *ttnpb.GatewayConnectionStats, |
| 315 | ) { |
| 316 | events.Publish(evtGatewayConnect.NewWithIdentifiersAndData(ctx, ids, stats)) |
| 317 | gsMetrics.gatewaysConnected.WithLabelValues(ctx, stats.Protocol).Inc() |
| 318 | } |
| 319 | |
| 320 | func registerGatewayDisconnect(ctx context.Context, ids *ttnpb.GatewayIdentifiers, protocol string, err error) { |
| 321 | events.Publish(evtGatewayDisconnect.NewWithIdentifiersAndData(ctx, ids, err)) |
no test coverage detected