Function registerDropStatus

pkg/gatewayserver/observability.go:338–345

(ctx context.Context, gtw *ttnpb.Gateway, _ *ttnpb.GatewayStatus, host string, err error)

}

func registerDropStatus(ctx context.Context, gtw *ttnpb.Gateway, _ *ttnpb.GatewayStatus, host string, err error) {
	events.Publish(evtDropStatus.NewWithIdentifiersAndData(ctx, gtw, err))
	errorLabel := unknown
	if ttnErr, ok := errors.From(err); ok {
		errorLabel = ttnErr.FullName()
	}
	gsMetrics.statusDropped.WithLabelValues(ctx, host, errorLabel).Inc()
}

func registerReceiveUplink(ctx context.Context, gtw *ttnpb.Gateway, msg *ttnpb.GatewayUplinkMessage, protocol string) {
	events.Publish(evtReceiveUp.NewWithIdentifiersAndData(ctx, gtw, msg))