Function relayLoopbackFunc

pkg/networkserver/relay.go:226–240

(
	conn *grpc.ClientConn,
	up *ttnpb.UplinkMessage,
	callOpts ...grpc.CallOption,
)

}

func relayLoopbackFunc(
	conn *grpc.ClientConn,
	up *ttnpb.UplinkMessage,
	callOpts ...grpc.CallOption,
) func(context.Context) error {
	client := ttnpb.NewGsNsClient(conn)
	return func(ctx context.Context) error {
		switch _, err := client.HandleUplink(ctx, up, callOpts...); {
		case err == nil, errors.IsNotFound(err), errors.IsAlreadyExists(err):
			return nil
		default:
			return err
		}
	}
}

func relayUpdateRules(
	deviceID string, sessionKeyID []byte, rules []*ttnpb.RelayUplinkForwardingRule,